Skip to main content
aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorslewis2010-09-03 00:09:34 -0400
committerslewis2010-09-03 00:09:34 -0400
commit9b7e0cebbcf7394a42c0ee23026b663536b8b35f (patch)
tree0bdc38723c0e6f2d32e2912b2720990d7912c28e
parent871242b70e3202e0f57db8b119baa910a2e66705 (diff)
downloadorg.eclipse.ecf-9b7e0cebbcf7394a42c0ee23026b663536b8b35f.tar.gz
org.eclipse.ecf-9b7e0cebbcf7394a42c0ee23026b663536b8b35f.tar.xz
org.eclipse.ecf-9b7e0cebbcf7394a42c0ee23026b663536b8b35f.zip
Extension to use concurrent API for remote service executionR-Release_3_3-sdk_feature-16-2010_09_03
-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