svn commit: r1679587 - /etch/trunk/binding-cpp/runtime/include/support/EtchStubBase.h

[veithm]

Author: veithm
Date: Fri May 15 15:06:30 2015
New Revision: 1679587

URL: http://svn.apache.org/r1679587
Log:
Add sessionDown notification in EtchStubBase

In case an exception occurs during the execution of an execution
helper, the session down event gets send to the user.

Change-Id: I74e91fecf664f129c2edd4767175f0e9d975f4d6

Modified:
    etch/trunk/binding-cpp/runtime/include/support/EtchStubBase.h

Modified: etch/trunk/binding-cpp/runtime/include/support/EtchStubBase.h
URL: 
http://svn.apache.org/viewvc/etch/trunk/binding-cpp/runtime/include/support/EtchStubBase.h?rev=1679587&r1=1679586&r2=1679587&view=diff
==============================================================================
--- etch/trunk/binding-cpp/runtime/include/support/EtchStubBase.h (original)
+++ etch/trunk/binding-cpp/runtime/include/support/EtchStubBase.h Fri May 15 
15:06:30 2015
@@ -154,7 +154,7 @@ status_t EtchStubBase<T>::sessionMessage
       res = mQueuedPool->add(runnable);
       if (res != ETCH_OK) {
         //CAPU_LOG_ERROR(mRuntime->getLogger(), "EtchStubBase", "Error while 
adding runnable to pool");
-        sessionNotify(NULL); //TODO Exception Handling
+        sessionNotify(new EtchString(EtchSession::DOWN())); //TODO Exception 
Handling
       }
       return res;
     case FREE:
@@ -163,7 +163,7 @@ status_t EtchStubBase<T>::sessionMessage
       res = mFreePool->add(runnable);
       if (res != ETCH_OK) {
         //CAPU_LOG_ERROR(mRuntime->getLogger(), "EtchStubBase", "Error while 
adding runnable to pool");
-        sessionNotify(NULL); //TODO Exception Handling
+        sessionNotify(new EtchString(EtchSession::DOWN())); //TODO Exception 
Handling
       }
       return res;
     case NONE:
@@ -171,12 +171,12 @@ status_t EtchStubBase<T>::sessionMessage
       res = helper->run(this, mSvc, mObj, sender, msg);
       if (res != ETCH_OK) {
         //CAPU_LOG_ERROR(mRuntime->getLogger(), "EtchStubBase", "Error while 
executing function");
-        sessionNotify(NULL); //TODO Exception Handling
+        sessionNotify(new EtchString(EtchSession::DOWN())); //TODO Exception 
Handling
       }
       return res;
     default:
       //  throw new IllegalArgumentException("unknown async mode 
"+type.getAsyncMode());
-      sessionNotify(NULL); //TODO Exception Handling
+      sessionNotify(new EtchString(EtchSession::DOWN())); //TODO Exception 
Handling
       return ETCH_OK;
   }
 }