Code liniting

Author: PicoCreator

src/main/java/picoded/dstack/FileWorkspaceMap.java

@@ -125,7 +125,7 @@ default FileWorkspace[] getArrayFromID(String[] idArray, boolean isUnchecked) {
 	 **/
 	@Override
 	void clear();
-
+	
 	/**
 	 * Return the current list of ID keys for fileWorkspaceMap
 	 **/

src/main/java/picoded/dstack/file/layered/FileLayered_FileWorkspaceMap.java

@@ -77,38 +77,38 @@ public Set<String> keySet() {
 		// For each one of it, process it!
 		for (File l1_dir : l1_dirList) {
 			// Skip if its not a directory
-			if( !l1_dir.isDirectory() ) {
+			if (!l1_dir.isDirectory()) {
 				continue;
 			}
-
+			
 			// List all the files/folders
 			File[] l2_dirList = l1_dir.listFiles();
 
-			for(File l2_dir : l2_dirList) {
+			for (File l2_dir : l2_dirList) {
 				// Skip if its not a directory
-				if( !l2_dir.isDirectory() ) {
+				if (!l2_dir.isDirectory()) {
 					continue;
 				}
-
+				
 				// Get the oidDirLIst
 				File[] oid_list = l2_dir.listFiles();
-
+				
 				// For each oid dir
-				for(File oid_dir : oid_list) {
+				for (File oid_dir : oid_list) {
 					// Get the presumed oid
 					String oid = oid_dir.getName();
-
+					
 					// Validate the dir name (oid)
-					if( !validateOid(oid) ) {
+					if (!validateOid(oid)) {
 						continue;
 					}
-
+					
 					// Add the oid to the ret set
 					ret.add(oid);
 				}
 			}
 		}
-
+		
 		// Return the full keyset
 		return ret;
 	}

src/main/java/picoded/dstack/file/simple/FileSimple_FileWorkspaceMap.java

@@ -651,22 +651,22 @@ public Set<String> keySet() {
 		// For each one of it, process it!
 		for (File subFile : dirList) {
 			// Skip if its not a directory
-			if( !subFile.isDirectory() ) {
+			if (!subFile.isDirectory()) {
 				continue;
 			}
-
+			
 			// Get the presumed oid
 			String oid = subFile.getName();
-
+			
 			// Validate the dir name (oid)
-			if( !validateOid(oid) ) {
+			if (!validateOid(oid)) {
 				continue;
 			}
-
+			
 			// Add the oid to the ret set
 			ret.add(oid);
 		}
-
+		
 		// Return the full keyset
 		return ret;
 	}

src/main/java/picoded/dstack/jsql/JSql_FileWorkspaceMap.java

@@ -672,7 +672,7 @@ public Set<String> keySet() {
 		}
 		return ListValueConv.toStringSet(r.getObjectList("oID"));
 	}
-
+	
 	/**
 	 * Gets and return a random object ID
 	 *
@@ -691,5 +691,4 @@ public String randomObjectID() {
 		return r.getStringArray("oID")[0];
 	}
 
-
 }

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

@@ -59,10 +59,10 @@ 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=nearest&readConcernLevel=linearizable"
+		// "&readPreference=nearest&readConcernLevel=linearizable"
 
 		// Lets do a logging, for missing read concern if its not configured
-		if( opts.indexOf("readConcernLevel") < 0 ) {
+		if (opts.indexOf("readConcernLevel") < 0) {
 			//
 			// readConcernLevel is a complicated topic, do consider reading up
 			// https://jepsen.io/analyses/mongodb-4.2.6
@@ -74,11 +74,11 @@ 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`"+
-			"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`"
+				+ "is highly recommended for replica clusters to ensure read after write consistency.");
 		}
-
+		
 		// In the future we may want to support opt_map
 		// GenericConvertMap<String,Object> optMap = config.getGenericConvertStringMap("opt_map", "{}");
 

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

@@ -294,7 +294,7 @@ public Set<String> keySet() {
 
 		// Lets fetch everything ... D=
 		DistinctIterable<String> search = collection.distinct("_oid", String.class);
-
+		
 		// Lets iterate the search
 		try (MongoCursor<String> cursor = search.iterator()) {
 			while (cursor.hasNext()) {

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

@@ -908,7 +908,7 @@ public Set<String> keySet() {
 
 		// Lets fetch everything ... D=
 		DistinctIterable<String> search = filesCollection.distinct("metadata.oid", String.class);
-
+		
 		// Lets iterate the search
 		try (MongoCursor<String> cursor = search.iterator()) {
 			while (cursor.hasNext()) {
@@ -920,5 +920,4 @@ public Set<String> keySet() {
 		return ret;
 	}
 
-	
 }

src/main/java/picoded/dstack/redisson/Redisson_DataObjectMap.java

@@ -137,14 +137,14 @@ public void clear() {
 		//Delete all the keys of all the existing databases
 		redisson.getKeys().flushall();
 	}
-
+	
 	/**
 	 * Teardown and delete the backend storage table, etc. If needed
 	 **/
 	public void systemDestroy() {
 		redisMap.delete();
 	}
-
+	
 	/**
 	 * [Internal use, to be extended in future implementation]
 	 *
@@ -168,51 +168,54 @@ public void DataObjectRemoteDataMap_update(String _oid, Map<String, Object> full
 		Set<String> updateKeys) {
 
 		Map<String, Object> clonedMap = new HashMap<String, Object>();
-
+		
 		// Lets iterate the keys, and decide accordingly
 		for (String key : fullMap.keySet()) {
 			// Get the full map value
 			Object val = fullMap.get(key);
-
+			
 			if (updateKeys.contains(key)) {
 				clonedMap.put(key, val);
 			}
 		}
-
+		
 		// call the default implementation, basically equal to redisMap.put(_oid,clonedMap)
 		super.DataObjectRemoteDataMap_update(_oid, clonedMap, updateKeys);
 	}
-
-	public Map<String,Object> ObjToMap(Object obj) {
-		if( obj instanceof Map ) { return (Map<String,Object>) obj; }
-		else {return null;}
+	
+	public Map<String, Object> ObjToMap(Object obj) {
+		if (obj instanceof Map) {
+			return (Map<String, Object>) obj;
+		} else {
+			return null;
+		}
 	}
 
 	/**
 	 * Gets the complete remote data map, for DataObject.
 	 * @return null if not exists, else a map with the data
 	 **/
 	public Map<String, Object> DataObjectRemoteDataMap_get(String _oid) {
-
+		
 		//Map Slicing 
 		Set<String> keys = new HashSet<String>();
 		Map<String, Object> mapSlice = new HashMap<String, Object>();
-		Map.Entry<String,Object> res = null;
+		Map.Entry<String, Object> res = null;
 		Object tmpObj = null;
-
+		
 		keys.add(_oid);
 		mapSlice = redisMap.getAll(keys);
 
-		Iterator<Map.Entry<String,Object>> it = mapSlice.entrySet().iterator();
-		if(it.hasNext()){
+		Iterator<Map.Entry<String, Object>> it = mapSlice.entrySet().iterator();
+		if (it.hasNext()) {
 			res = it.next();
 			tmpObj = res.getValue();
 		}
-
+		
 		if (tmpObj == null) {
 			return null;
 		}
-
+		
 		Map<String, Object> resObj = null;
 		resObj = ObjToMap(tmpObj);
 
@@ -221,14 +224,14 @@ public Map<String, Object> DataObjectRemoteDataMap_get(String _oid) {
 		// Lets iterate through the object
 		Set<String> fullKeys = resObj.keySet();
 		for (String key : fullKeys) {
-	
+			
 			// Get the value
 			Object val = resObj.get(key);
-					
+			
 			// Populate the ret map
 			ret.put(key, val);
 		}
-	
+		
 		return ret;
 	}
 

src/main/java/picoded/dstack/redisson/Redisson_KeyValueMap.java

@@ -90,7 +90,7 @@ private String name() {
 	 * @return backendmap memoizer
 	 */
 	// private RMap<String, Map<String, Object>> _backendRMap = null;
-	private RMapCache<String, String>  _backendRMap = null;
+	private RMapCache<String, String> _backendRMap = null;
 
 	/**
 	 * @return Storage map used for the backend operations of one "DataObjectMap"
@@ -164,10 +164,10 @@ public void maintenance() {
 	public Set<String> keySet(String value) {
 		// The return hashset
 		HashSet<String> ret = new HashSet<String>();
-		List<String> retList = null; 
-        if (value == null) {
+		List<String> retList = null;
+		if (value == null) {
 			// Lets fetch everything
-            retList = new ArrayList<String>(backendMap().readAllKeySet());
+			retList = new ArrayList<String>(backendMap().readAllKeySet());
 			// Return the full keyset
 			retList.forEach(k -> ret.add(k));
 		} else {
@@ -202,14 +202,12 @@ public Set<String> keySet(String value) {
 	 **/
 	public void setExpiryRaw(String key, long time) {
 		if (time > 0) {
-			backendMap()
-				.updateEntryExpiration(key, Math.max(time - System.currentTimeMillis(), 1),
-					TimeUnit.MILLISECONDS,0,TimeUnit.MILLISECONDS);
+			backendMap().updateEntryExpiration(key, Math.max(time - System.currentTimeMillis(), 1),
+				TimeUnit.MILLISECONDS, 0, TimeUnit.MILLISECONDS);
 		} else {
 			backendMap()
-				.updateEntryExpiration(key, 0, 
-					TimeUnit.MILLISECONDS,0,TimeUnit.MILLISECONDS);
-		}	
+				.updateEntryExpiration(key, 0, TimeUnit.MILLISECONDS, 0, TimeUnit.MILLISECONDS);
+		}
 	}
 
 	/**
@@ -254,28 +252,28 @@ public String setValueRaw(String key, String value, long expire) {
 	 * @return String value, and expiry pair
 	 **/
 	public MutablePair<String, Long> getValueExpiryRaw(String key, long now) {
-
+		
 		Set<String> keys = new HashSet<String>();
 		Map<String, String> mapSlice = new HashMap<String, String>();
-		Map.Entry<String,String> entry = null;
-
+		Map.Entry<String, String> entry = null;
+		
 		keys.add(key);
 		mapSlice = backendMap().getAll(keys);
-
-		Iterator<Map.Entry<String,String>> it = mapSlice.entrySet().iterator();
-		if(it.hasNext()){
+		
+		Iterator<Map.Entry<String, String>> it = mapSlice.entrySet().iterator();
+		if (it.hasNext()) {
 			entry = it.next();
 			if (entry == null) {
 				return null;
 			}
 			String value = entry.getValue();
-
+			
 			// Get the raw TTL
 			long rawTTL = backendMap().remainTimeToLive(key);
-			if( rawTTL <= -2 ) {
+			if (rawTTL <= -2) {
 				// value has expired
 				return null;
-			} else if( rawTTL <= -1 ) {
+			} else if (rawTTL <= -1) {
 				// has no expiry
 				// Note: 0 = no timestamp, hence valid value
 				return new MutablePair<String, Long>(value, 0L);

src/main/java/picoded/dstack/struct/simple/StructSimple_FileWorkspaceMap.java

@@ -627,7 +627,7 @@ public Set<String> backend_getFileAndFolderPathSet(final String oid, final Strin
 	public Set<String> keySet() {
 		return new HashSet<>(fileContentMap.keySet());
 	}
-
+	
 	//--------------------------------------------------------------------------
 	//
 	// Constructor and maintenance