|
@@ -151,10 +151,10 @@ public class MDO0039Service extends MDO0039BaseModel implements ExecProcessFlow
|
|
|
sc.andPidEqualTo(pid);
|
|
|
comvalDao.deleteByExample(sb);
|
|
|
|
|
|
-// FileMonitor surrMonitor = new FileMonitor(1000);
|
|
|
-// SurromdaoFileListener t= new SurromdaoFileListener(pid);
|
|
|
-// surrMonitor.monitor("/cephfs/mdo/"+pid+"/in/myid_0", t);
|
|
|
-// surrMonitor.start();
|
|
|
+ FileMonitor surrMonitor = new FileMonitor(1000);
|
|
|
+ SurromdaoFileListener t= new SurromdaoFileListener(pid);
|
|
|
+ surrMonitor.monitor("/cephfs/mdo/"+pid+"/in/myid_0", t);
|
|
|
+ surrMonitor.start();
|
|
|
//
|
|
|
// FileMonitor aifoilMonitor = new FileMonitor(1000);
|
|
|
// AirfoilFileListener airfoilFileListener= new AirfoilFileListener(pid);
|
|
@@ -210,8 +210,8 @@ public class MDO0039Service extends MDO0039BaseModel implements ExecProcessFlow
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
try {
|
|
|
-// surrMonitor.stop();
|
|
|
-// SurromdaoFileRead.readFile(new File("/cephfs/mdo/"+pid+"/in/myid_0/surromdao_history_all.dat"),pid);
|
|
|
+ surrMonitor.stop();
|
|
|
+ SurromdaoFileRead.readFile(new File("/cephfs/mdo/"+pid+"/in/myid_0/surromdao_history_all.dat"),pid);
|
|
|
// aifoilMonitor.stop();
|
|
|
// AirfoilFileRead.readFile(new File("/cephfs/mdo/"+pid+"/in/myid_0/xfoil/airfoil.dat"),pid);
|
|
|
// cpMonitor.stop();
|