Fix return code check for Semaphore operations #47 (#48)

* Fix take and give semaphore operations in RTI Perftest #47 * Add CR changes * CR Changes and documentation
rticommunity · Apr 4, 2018 · f84bcf9 · f84bcf9
1 parent 6974e75
commit f84bcf9
Show file tree

Hide file tree

Showing 2 changed files with 30 additions and 24 deletions.
diff --git a/srcCpp/RTIDDSImpl.cxx b/srcCpp/RTIDDSImpl.cxx
@@ -99,8 +99,8 @@ void RTIDDSImpl<T>::Shutdown()
     }
 
     if(_pongSemaphore != NULL) {
-	RTIOsapiSemaphore_delete(_pongSemaphore);
-	_pongSemaphore = NULL;
+        RTIOsapiSemaphore_delete(_pongSemaphore);
+        _pongSemaphore = NULL;
     }
 
     DDSDomainParticipantFactory::finalize_instance();
@@ -885,42 +885,38 @@ class RTIPublisher : public IMessagingWriter
         }
     }
 
-    bool waitForPingResponse() 
-    {
-        if(_pongSemaphore != NULL)
-        {
-            if(!RTIOsapiSemaphore_take(_pongSemaphore, NULL))
-            {
-                fprintf(stderr,"Unexpected error taking semaphore\n");
+    bool waitForPingResponse() {
+        if(_pongSemaphore != NULL) {
+            if(RTIOsapiSemaphore_take(_pongSemaphore, NULL)
+                    == RTI_OSAPI_SEMAPHORE_STATUS_ERROR) {
+                fprintf(stderr, "Unexpected error taking semaphore\n");
                 return false;
             }
         }
         return true;
     }
 
     /* time out in milliseconds */
-    bool waitForPingResponse(int timeout) 
+    bool waitForPingResponse(int timeout)
     {
         struct RTINtpTime blockDurationIn;
         RTINtpTime_packFromMillisec(blockDurationIn, 0, timeout);
 
-        if(_pongSemaphore != NULL)
-        {
-        if(!RTIOsapiSemaphore_take(_pongSemaphore, &blockDurationIn))
-            {
-                fprintf(stderr,"Unexpected error taking semaphore\n");
+        if(_pongSemaphore != NULL) {
+            if (RTIOsapiSemaphore_take(_pongSemaphore, &blockDurationIn)
+                    == RTI_OSAPI_SEMAPHORE_STATUS_ERROR) {
+                fprintf(stderr, "Unexpected error taking semaphore\n");
                 return false;
             }
         }
         return true;
-    }    
+    }
 
-    bool notifyPingResponse() 
+    bool notifyPingResponse()
     {
-        if(_pongSemaphore != NULL)
-        {
-            if(!RTIOsapiSemaphore_give(_pongSemaphore))
-            {
+        if(_pongSemaphore != NULL) {
+            if(RTIOsapiSemaphore_give(_pongSemaphore)
+                    != RTI_OSAPI_SEMAPHORE_STATUS_OK) {
                 fprintf(stderr,"Unexpected error giving semaphore\n");
                 return false;
             }
@@ -1134,7 +1130,8 @@ class RTIDynamicDataPublisher : public IMessagingWriter
 
     bool waitForPingResponse() {
         if (_pongSemaphore != NULL) {
-            if (!RTIOsapiSemaphore_take(_pongSemaphore, NULL)) {
+            if (RTIOsapiSemaphore_take(_pongSemaphore, NULL)
+                    == RTI_OSAPI_SEMAPHORE_STATUS_ERROR) {
                 fprintf(stderr, "Unexpected error taking semaphore\n");
                 return false;
             }
@@ -1148,7 +1145,8 @@ class RTIDynamicDataPublisher : public IMessagingWriter
         RTINtpTime_packFromMillisec(blockDuration, 0, timeout);
 
         if (_pongSemaphore != NULL) {
-            if (!RTIOsapiSemaphore_take(_pongSemaphore, &blockDuration)) {
+            if (RTIOsapiSemaphore_take(_pongSemaphore, &blockDuration)
+                    == RTI_OSAPI_SEMAPHORE_STATUS_ERROR) {
                 fprintf(stderr, "Unexpected error taking semaphore\n");
                 return false;
             }
@@ -1158,7 +1156,8 @@ class RTIDynamicDataPublisher : public IMessagingWriter
 
     bool notifyPingResponse() {
         if (_pongSemaphore != NULL) {
-            if (!RTIOsapiSemaphore_give(_pongSemaphore)) {
+            if (RTIOsapiSemaphore_give(_pongSemaphore)
+                    != RTI_OSAPI_SEMAPHORE_STATUS_OK) {
                 fprintf(stderr, "Unexpected error giving semaphore\n");
                 return false;
             }

diff --git a/srcDoc/release_notes.rst b/srcDoc/release_notes.rst
@@ -51,6 +51,13 @@ Release Notes 2.3.2
 What's Fixed in 2.3.2
 ~~~~~~~~~~~~~~~~~~~~~~
 
+Classic C++ Semaphore Take() and Give() operations not checking for errors properly (#47)
+^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
+
+In previous versions, the semaphore Take() and Give() operations
+were not being checked for error in a correct way in the Classic C++ API implementation.
+This has been fixed.
+
 Update Security Certificates and Governance files (#49)
 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^