Code liniting

Author: PicoCreator

src/main/java/picoded/dstack/mongodb/MongoDBStack.java

@@ -59,8 +59,8 @@ public static String getFullConnectionURL(GenericConvertMap<String, Object> conf
 		int port = config.getInt("port", 27017);
 		String opts = config.getString("opt_str", "w=majority&retryWrites=true&retryReads=true"
 			+ "&maxPoolSize=10&compressors=zstd");
-			// "&readPreference=master&readConcernLevel=majority"
-		  // "&readPreference=nearest&readConcernLevel=linearizable"
+		// "&readPreference=master&readConcernLevel=majority"
+		// "&readPreference=nearest&readConcernLevel=linearizable"
 
 		// Lets do a logging, for missing read concern if its not configured
 		if (opts.indexOf("readConcernLevel") < 0) {
@@ -75,10 +75,10 @@ public static String getFullConnectionURL(GenericConvertMap<String, Object> conf
 			// Unless you know what your doing from a performance standpoint, it is strongly recommended to use 
 			// `readConcernLevel=linearizable`
 			//
-			LOGGER.warning("MongoDB is configured without readConcernLevel, "+
-			"this is alright for a single node, but `readConcernLevel=linearizable`"+
-			"or `readPreference=master&readConcernLevel=majority`"+
-			"is highly recommended for replica clusters to ensure read after write consistency.");
+			LOGGER.warning("MongoDB is configured without readConcernLevel, "
+				+ "this is alright for a single node, but `readConcernLevel=linearizable`"
+				+ "or `readPreference=master&readConcernLevel=majority`"
+				+ "is highly recommended for replica clusters to ensure read after write consistency.");
 		}
 
 		// In the future we may want to support opt_map

src/main/java/picoded/dstack/struct/cache/StructCacheUtil.java

@@ -14,7 +14,8 @@ class StructCacheUtil {
 	 * Utility function used to build a new Cache2k cache instance
 	 * This handles all the various common config settings, and set it up accordingly
 	 */
-	static <V> Cache<String, V> setupCache2kMap(Cache2kBuilder<String,V> builder, String name, GenericConvertMap<String, Object> config) {
+	static <V> Cache<String, V> setupCache2kMap(Cache2kBuilder<String, V> builder, String name,
+		GenericConvertMap<String, Object> config) {
 
 		//
 		// Get Config

src/main/java/picoded/dstack/struct/cache/StructCache_DataObjectMap.java

@@ -148,7 +148,9 @@ public void systemSetup() {
 			}
 
 			// Build the cache
-			_valueMap = StructCacheUtil.setupCache2kMap(new Cache2kBuilder<String, Map<String,Object>>(){}, cacheName(), configMap());
+			_valueMap = StructCacheUtil.setupCache2kMap(
+				new Cache2kBuilder<String, Map<String, Object>>() {
+				}, cacheName(), configMap());
 
 			// Add it back to the global cache
 			globalCacheMap.put(cacheName(), _valueMap);

src/main/java/picoded/dstack/struct/cache/StructCache_KeyValueMap.java

@@ -22,7 +22,7 @@
  * Built ontop of the StructCache_KeyValueMap implementation.
  **/
 public class StructCache_KeyValueMap extends Core_KeyValueMap {
-
+	
 	//--------------------------------------------------------------------------
 	//
 	// Constructor
@@ -59,14 +59,14 @@ static public class CacheValue implements Serializable {
 		public String value;
 		public long expire;
 	}
-
+	
 	static CacheValue cacheValueBuilder(String val, long exp) {
 		CacheValue ret = new CacheValue();
 		ret.value = val;
 		ret.expire = exp;
 		return ret;
 	}
-
+	
 	/**
 	 * Global static cache map,
 	 * Used to persist all the various cache maps used.
@@ -158,32 +158,33 @@ public void systemSetup() {
 			}
 
 			// Build the cache
-			Cache2kBuilder<String, CacheValue> builder = new Cache2kBuilder<String, CacheValue>(){};
+			Cache2kBuilder<String, CacheValue> builder = new Cache2kBuilder<String, CacheValue>() {
+			};
 			builder.storeByReference(true);
 			_valueMap = StructCacheUtil.setupCache2kMap(builder, cacheName(), configMap());
 
 			// Add it back to the global cache
 			globalCacheMap.put(cacheName(), _valueMap);
 		}
-
+		
 	}
-
+	
 	@Override
 	public void systemDestroy() {
 		synchronized (StructCache_KeyValueMap.class) {
 			_valueMap.clear();
 			globalCacheMap.remove(cacheName());
 			_valueMap = null;
 		}
-
+		
 	}
-
+	
 	@Override
 	public void maintenance() {
 		// Does nothing
-
+		
 	}
-
+	
 	//--------------------------------------------------------------------------
 	//
 	// Set and get values
@@ -203,21 +204,21 @@ public void maintenance() {
 	@Override
 	public String setValueRaw(String key, String value, long expire) {
 		// Handles null removal
-		if( value == null ) {
+		if (value == null) {
 			valueMap().remove(key);
 			return null;
 		}
-
+		
 		// Store and configure expiry
 		valueMap().put(key, cacheValueBuilder(value, expire));
-		if( expire > 0 ) {
+		if (expire > 0) {
 			// Note that cache expiry config, may take priority
 			// so this should not be relied on in itself
 			valueMap().expireAt(key, expire);
 		}
 		return null;
 	}
-
+	
 	/**
 	 * [Internal use, to be extended in future implementation]
 	 * Sets the expire time stamp value, raw without validation
@@ -230,22 +231,22 @@ public String setValueRaw(String key, String value, long expire) {
 	@Override
 	public void setExpiryRaw(String key, long time) {
 		CacheValue cv = valueMap().get(key);
-		if( cv == null ) {
+		if (cv == null) {
 			// Does nothing if cv == null
 			return;
 		}
-
+		
 		// Set the actual expire value
 		cv.expire = time;
-
+		
 		// Configure cache2k expire values
-		if( time > 0 ) {
+		if (time > 0) {
 			// Note that cache expiry config, may take priority
 			// so this should not be relied on in itself
 			valueMap().expireAt(key, time);
 		}
 	}
-
+	
 	/**
 	 * [Internal use, to be extended in future implementation]
 	 *
@@ -259,15 +260,15 @@ public void setExpiryRaw(String key, long time) {
 	@Override
 	public MutablePair<String, Long> getValueExpiryRaw(String key, long now) {
 		CacheValue cv = valueMap().get(key);
-		if( cv == null ) {
+		if (cv == null) {
 			// Does nothing if cv == null
 			return null;
 		}
-		if( cv.expire > 0 && cv.expire <= System.currentTimeMillis() ) {
+		if (cv.expire > 0 && cv.expire <= System.currentTimeMillis()) {
 			// Value should be expired, does nothing
 			return null;
 		}
-		return new MutablePair<String,Long>(cv.value, cv.expire);
+		return new MutablePair<String, Long>(cv.value, cv.expire);
 	}
 
 	//--------------------------------------------------------------------------
@@ -279,33 +280,33 @@ public MutablePair<String, Long> getValueExpiryRaw(String key, long now) {
 	@Override
 	public Set<String> keySet(String value) {
 		// Optimized for all
-		if( value == null ) {
+		if (value == null) {
 			return valueMap().asMap().keySet();
 		}
-
+		
 		// We have to do a search
 		Set<String> full = valueMap().asMap().keySet();
 		Set<String> ret = new HashSet<>();
 		long now = System.currentTimeMillis();
-
+		
 		// Lets iterate each key
-		for(String key : full) {
+		for (String key : full) {
 			CacheValue cv = valueMap().get(key);
-			if( cv == null ) {
+			if (cv == null) {
 				// Does nothing if cv == null
 				continue;
 			}
-			if( cv.expire > 0 && cv.expire <= now ) {
+			if (cv.expire > 0 && cv.expire <= now) {
 				// Value should be expired, does nothing
 				continue;
 			}
-			if( cv.value == value ) {
+			if (cv.value == value) {
 				ret.add(key);
 			}
 		}
-
+		
 		// Return the filtered set
 		return ret;
 	}
-
+	
 }