Add null pointer check for getCallerThreadPoolExecutor() #1265

Author: lling

marklogic-client-api/src/main/java/com/marklogic/client/dataservices/impl/ExecEndpointImpl.java

@@ -192,7 +192,9 @@ private boolean processExec(CallContextImpl<I,O> callContext) {
                                 }
                                 break retry;
                             case STOP_ALL_CALLS:
-                                getCallerThreadPoolExecutor().shutdown();
+                                if (getCallerThreadPoolExecutor() != null) {
+                                    getCallerThreadPoolExecutor().shutdown();
+                                }
                                 break retry;
                         }
                     }

marklogic-client-api/src/main/java/com/marklogic/client/dataservices/impl/InputEndpointImpl.java

@@ -233,7 +233,9 @@ private void processInput(CallContextImpl<I,O> callContext, I[] inputBatch) {
 								return;
 
 							case STOP_ALL_CALLS:
-								getCallerThreadPoolExecutor().shutdown();
+								if (getCallerThreadPoolExecutor() != null) {
+									getCallerThreadPoolExecutor().shutdown();
+								}
 						}
 					}
 				}

marklogic-client-api/src/main/java/com/marklogic/client/dataservices/impl/InputOutputEndpointImpl.java

@@ -236,7 +236,9 @@ private void processInput(CallContextImpl<I,O> callContext, I[] inputBatch) {
                                 return;
 
                             case STOP_ALL_CALLS:
-                                getCallerThreadPoolExecutor().shutdown();
+                                if (getCallerThreadPoolExecutor() != null) {
+                                    getCallerThreadPoolExecutor().shutdown();
+                                }
                         }
                     // executing in the application thread
                     } else if (getCallContext() != null) {

marklogic-client-api/src/main/java/com/marklogic/client/dataservices/impl/OutputEndpointImpl.java

@@ -221,7 +221,9 @@ private O[] getOutputStream(CallContextImpl<I,O> callContext) {
                                 return getEndpoint().getCaller().getOutputHandle().newArray(0);
 
                             case STOP_ALL_CALLS:
-                                getCallerThreadPoolExecutor().shutdown();
+                                if (getCallerThreadPoolExecutor() != null) {
+                                    getCallerThreadPoolExecutor().shutdown();
+                                }
                         }
                     }
                 }
@@ -289,7 +291,7 @@ public Boolean call() {
                         bulkOutputCallerImpl.getCallContextQueue().put(callContext);
                         submitTask(this);
                     } else {
-                        if (aliveCallContextCount.decrementAndGet() == 0) {
+                        if (getCallerThreadPoolExecutor() != null && aliveCallContextCount.decrementAndGet() == 0) {
                             getCallerThreadPoolExecutor().shutdown();
                         }
                     }