Using shmem to provide consistency and allow the un-delivery of a user-specified...
[charm.git] / src / conv-ccs / conv-ccs.c
index ab82582ab2aaa4d6fe0f9fad6826195ef3efed24..0bc4b0845af6e308382b81e54c0abd4de2c15771 100644 (file)
@@ -248,13 +248,8 @@ void CcsHandleRequest(CcsImplHeader *hdr,const char *reqData)
       free(buf);
     } else {
       /* the pipe has been closed */
-      close(conditionalPipe[0]);
-      conditionalPipe[0] = 0;
-      close(conditionalPipe[1]);
-      conditionalPipe[1] = 0;
-      wait(NULL);
-      CcsSendReply(0,NULL);
-    }
+      CpdEndConditionalDeliver_master();
+   }
   }
   else {
     callHandlerRec(fn,reqLen,reqData);