oncrpcsvc: do not send request to execution if service not registered

reply 'program not registered' direct from selector thread. Acked-by: Paul Millar Target: master
kofemann · May 23, 2016 · cc24188 · cc24188
1 parent f605d29
commit cc24188
Showing 1 changed file with 12 additions and 12 deletions.
diff --git a/oncrpc4j-core/src/main/java/org/dcache/xdr/RpcDispatcher.java b/oncrpc4j-core/src/main/java/org/dcache/xdr/RpcDispatcher.java
@@ -85,12 +85,12 @@ public NextAction handleRead(final FilterChainContext ctx) throws IOException {
         _log.debug("processing request {}", call);
 
         final RpcDispatchable program = _programs.get(new OncRpcProgram(prog, vers));
-        _asyncExecutorService.execute(new Runnable() {
-            @Override
-            public void run() {
-                if (program == null) {
-                    call.failProgramUnavailable();
-                } else {
+        if (program == null) {
+            call.failProgramUnavailable();
+        } else {
+            _asyncExecutorService.execute(new Runnable() {
+                @Override
+                public void run() {
                     try {
                         if (_withSubjectPropagation) {
                             Subject subject = call.getCredential().getSubject();
@@ -127,13 +127,13 @@ public void run() {
                         throw e;
                     }
                 }
-            }
 
-            @Override
-            public String toString() {
-                return call.toString();
-            }
-        });
+                @Override
+                public String toString() {
+                    return call.toString();
+                }
+            });
+        }
         return ctx.getInvokeAction();
     }
 }