Skip to main content
summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorslewis2010-09-03 04:08:21 +0000
committerslewis2010-09-03 04:08:21 +0000
commit0e9a97e6e47e0f2456b323beeeda6372c9027afd (patch)
treeea407ee286cb5320042d58b1ddaa56ea4213116f /providers/bundles
parent25ed94b75ff7ed2941d0ecf778d4e2e8874ddf29 (diff)
downloadorg.eclipse.ecf-0e9a97e6e47e0f2456b323beeeda6372c9027afd.tar.gz
org.eclipse.ecf-0e9a97e6e47e0f2456b323beeeda6372c9027afd.tar.xz
org.eclipse.ecf-0e9a97e6e47e0f2456b323beeeda6372c9027afd.zip
Extension to use concurrent API for remote service execution
Diffstat (limited to 'providers/bundles')
-rw-r--r--providers/bundles/org.eclipse.ecf.provider.remoteservice/src/org/eclipse/ecf/provider/remoteservice/generic/RegistrySharedObject.java14
1 files changed, 11 insertions, 3 deletions
diff --git a/providers/bundles/org.eclipse.ecf.provider.remoteservice/src/org/eclipse/ecf/provider/remoteservice/generic/RegistrySharedObject.java b/providers/bundles/org.eclipse.ecf.provider.remoteservice/src/org/eclipse/ecf/provider/remoteservice/generic/RegistrySharedObject.java
index 686cb43d7..0f93e2049 100644
--- a/providers/bundles/org.eclipse.ecf.provider.remoteservice/src/org/eclipse/ecf/provider/remoteservice/generic/RegistrySharedObject.java
+++ b/providers/bundles/org.eclipse.ecf.provider.remoteservice/src/org/eclipse/ecf/provider/remoteservice/generic/RegistrySharedObject.java
@@ -1100,14 +1100,22 @@ public class RegistrySharedObject extends BaseSharedObject implements IRemoteSer
return requestExecutor;
}
- private IExecutor createRequestExecutor(Request request) {
+ private IExecutor createRequestExecutor(final Request request) {
IExecutor executor = null;
if (DEFAULT_EXECUTOR_TYPE.equals("jobs")) { //$NON-NLS-1$
- executor = new JobsExecutor("Remote Request Handler"); //$NON-NLS-1$
+ executor = new JobsExecutor("Remote Request Handler") { //$NON-NLS-1$
+ protected String createJobName(String executorName, int jobCounter, IProgressRunnable runnable) {
+ return executorName + " - " + request.getCall().getMethod() + ":" + request.getRequestId(); //$NON-NLS-1$ //$NON-NLS-2$
+ }
+ };
} else if (DEFAULT_EXECUTOR_TYPE.equals("immediate")) { //$NON-NLS-1$
executor = new ImmediateExecutor();
} else {
- executor = new ThreadsExecutor();
+ executor = new ThreadsExecutor() {
+ protected String createThreadName(IProgressRunnable runnable) {
+ return "Remote Request Handler - " + request.getCall().getMethod() + ":" + request.getRequestId(); //$NON-NLS-1$ //$NON-NLS-2$
+ }
+ };
}
return executor;
}

Back to the top