updated email address - petr@smoliku.cz

[orte.git] / orte / liborte / ORTEAppRecvThread.c

diff --git a/orte/liborte/ORTEAppRecvThread.c b/orte/liborte/ORTEAppRecvThread.c
index c909027aa08cf4e2fb46b28df1e2c65eb4e0f6d3..72420f47aa161259157fda712930577625bc9691 100644 (file)
--- a/orte/liborte/ORTEAppRecvThread.c
+++ b/orte/liborte/ORTEAppRecvThread.c
@@ -12,7 +12,7 @@
  *                      http://dce.felk.cvut.cz                       
  *                      http://www.ocera.org                          
  *                                                                    
- *  Author:             Petr Smolik    petr.smolik@wo.cz             
+ *  Author:             Petr Smolik    petr@smoliku.cz             
  *  Advisor:            Pavel Pisa                                   
  *  Project Responsible: Zdenek Hanzalek                              
  *  --------------------------------------------------------------------
@@ -55,7 +55,7 @@ char* TK2S(TaskProp *tp)
 /*****************************************************************************/
 void ORTEAppRecvThread(TaskProp *tp) {
   struct sockaddr_in    des;
-  uint32_t             RTPS_Codec_len;
+  int32_t              RTPS_Codec_len;
   MessageInterpret      mi; 
   CDR_Codec            *cdrCodec=&tp->mb.cdrCodec;
   ORTEDomain           *d=tp->d;
@@ -74,6 +74,11 @@ void ORTEAppRecvThread(TaskProp *tp) {
                   cdrCodec->buf_len,            //max length of message
                   &des,sizeof(des));             //info from sending host
 
+    if (RTPS_Codec_len == -1) {
+           perror("ORTEAppRecvThread: sock_recvfrom");
+           return;
+    }
+
     debug(22,7) ("ORTEAppRecvThread %s: fired, msg_len: 0x%x\n",TK2S(tp),RTPS_Codec_len);
 
     //is it header of valid RTPS packet?