FourElementsPublic/scheduler4e
0
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

* project/bldb/src/main/java/com/fe/client/SchedulerMgmt.java

Browse Source 
Added: for the new cpython engine
This commit is contained in:
bernarto
2021-12-16 15:53:49 +08:00
parent adf29ba998
commit 13d9beb52c
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
project/bldb/src/main/java/com/fe/client/SchedulerMgmt.java
+6
View File
@@ -84,6 +84,7 @@ import com.fourelementscapital.scheduler.error.ClientError;
import com.fourelementscapital.scheduler.group.DirectRServeExecuteRUnix; import com.fourelementscapital.scheduler.group.DirectRServeExecuteRUnix;
import com.fourelementscapital.scheduler.group.REngineScriptTask; import com.fourelementscapital.scheduler.group.REngineScriptTask;
import com.fourelementscapital.scheduler.group.RServeUnixTask; import com.fourelementscapital.scheduler.group.RServeUnixTask;
import com.fourelementscapital.scheduler.group.PythonScriptTask;
import com.fourelementscapital.scheduler.p2p.P2PService; import com.fourelementscapital.scheduler.p2p.P2PService;
import com.fourelementscapital.scheduler.p2p.listener.IncomingMessage; import com.fourelementscapital.scheduler.p2p.listener.IncomingMessage;
import com.fourelementscapital.scheduler.p2p.listener.P2PTransportMessage; import com.fourelementscapital.scheduler.p2p.listener.P2PTransportMessage;
@@ -2716,6 +2717,11 @@ public class SchedulerMgmt extends AbstractTeamOrgMgmt {
rserve_p.add(RServeUnixTask.ENGINE_NAME); rserve_p.add(RServeUnixTask.ENGINE_NAME);
rserve_p.add(RServeUnixTask.ENGINE_EXECUTER_UNIX_NAME); // rserve_p.add(RServeUnixTask.ENGINE_EXECUTER_UNIX_NAME); //
rtn.put("rserve_unix_peers", sdb.getPeersList4Engine(rserve_p)); rtn.put("rserve_unix_peers", sdb.getPeersList4Engine(rserve_p));
ArrayList python_p = new ArrayList();
python_p.add( PythonScriptTask.ENGINE_NAME );
rtn.put("python_peers", sdb.getPeersList4Engine(python_p));
rtn.put("peernotes", sdb.getPeersData()); rtn.put("peernotes", sdb.getPeersData());
int last10sec=10000; int last10sec=10000;