gCubeSystem
/
storage-manager-trigger
16
0
Fork 0
Code Issues Releases Wiki Activity

added folderAccountingConsumer but disabled for this release (3.5) 

git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/content-management/storage-manager-trigger@101031 82a268e6-3cf1-43bd-a215-b396298e98cf
This commit is contained in:
roberto.cirillo 2014-10-27 14:48:59 +00:00
parent 1cac8ba8e6
commit b912d4dca9
2 changed files with 16 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/java/org/gcube/contentmanager/storageserver/data/ReadingMongoOplog.java
View File

@ -88,12 +88,20 @@ public class ReadingMongoOplog extends Thread{
}else{
logger.debug("record discarded: \t"+x);
}
try {
Thread.sleep(20000);
} catch (InterruptedException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
}
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
} catch (InterruptedException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
}
}

12
src/main/java/org/gcube/contentmanager/storageserver/startup/Startup.java
View File

@ -55,14 +55,14 @@ public class Startup {
ssConsumer=new UserAccountingConsumer(server, c1, 1, dtsHosts);
else
ssConsumer=new UserAccountingConsumer(server, args[1], args[2], c1, 1, dtsHosts);
FolderAccountingConsumer fsConsumer=null;
if(args.length == 3)
fsConsumer=new FolderAccountingConsumer(server, c2, 1);
else
fsConsumer=new FolderAccountingConsumer(server, args[1], args[2], c2, 1);
// FolderAccountingConsumer fsConsumer=null;
// if(args.length == 3)
// fsConsumer=new FolderAccountingConsumer(server, c2, 1);
// else
// fsConsumer=new FolderAccountingConsumer(server, args[1], args[2], c2, 1);
producer.start();
ssConsumer.start();
fsConsumer.start();
// fsConsumer.start();
}
private static String[] retrieveServerConfiguration(Configuration c) {