ICE-4701 - AsyncResult::getCommunicator returns null

1 files changed, 5 insertions, 1 deletions

diff --git a/py/modules/IcePy/Operation.cpp b/py/modules/IcePy/Operation.cpp
index b8dfed5e909..8d8c1b8e6e2 100644
--- a/py/modules/IcePy/Operation.cpp
+++ b/py/modules/IcePy/Operation.cpp
@@ -11,6 +11,7 @@
 #   include <IceUtil/Config.h>
 #endif
 #include <Operation.h>
+#include <Communicator.h>
 #include <Current.h>
 #include <Proxy.h>
 #include <Types.h>
@@ -1810,7 +1811,8 @@ IcePy::AsyncTypedInvocation::invoke(PyObject* args, PyObject* /* kwds */)
     try
     {
         checkAsyncTwowayOnly(_prx);
-        pair<const Ice::Byte*, const Ice::Byte*> pparams(static_cast<const Ice::Byte*>(0),static_cast<const Ice::Byte*>(0));
+        pair<const Ice::Byte*, const Ice::Byte*> pparams(static_cast<const Ice::Byte*>(0),
+                                                         static_cast<const Ice::Byte*>(0));
         if(!params.empty())
         {
             pparams.first = &params[0];
@@ -1893,6 +1895,7 @@ IcePy::AsyncTypedInvocation::invoke(PyObject* args, PyObject* /* kwds */)
     obj->invocation = new InvocationPtr(this);
     obj->proxy = _pyProxy;
     Py_INCREF(obj->proxy);
+    obj->communicator = getCommunicatorWrapper(_communicator);
     return reinterpret_cast<PyObject*>(obj);
 }
 
@@ -2542,6 +2545,7 @@ IcePy::AsyncBlobjectInvocation::invoke(PyObject* args, PyObject* kwds)
     obj->invocation = new InvocationPtr(this);
     obj->proxy = _pyProxy;
     Py_INCREF(obj->proxy);
+    obj->communicator = getCommunicatorWrapper(_prx->ice_getCommunicator());
     return reinterpret_cast<PyObject*>(obj);
 }