- Timestamp:
- Sep 30, 2010, 4:34:31 PM (14 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
source/ariba/utility/transport/tcpip/protlib/tp_over_tcp.cpp
r7040 r8606 253 253 if (newmsg) 254 254 { 255 newmsg->send_to(tpparam.source); 255 bool ret = newmsg->send_to(tpparam.source); 256 if(!ret) delete newmsg; 256 257 return assoc; 257 258 } … … 413 414 // both parameters will be freed after message was sent! 414 415 415 TPoverTCPMsg* internalmsg= new TPoverTCPMsg(netmsg,new appladdress(*addr)); 416 appladdress* apl=new appladdress(*addr); 417 TPoverTCPMsg* internalmsg= new TPoverTCPMsg(netmsg,apl); 416 418 if (internalmsg) 417 419 { 418 420 // send the internal message to the sender thread queue 419 internalmsg->send(tpparam.source,destqueue); 421 bool sent = internalmsg->send(tpparam.source,destqueue); 422 if (!sent) { 423 delete internalmsg->get_appladdr(); 424 delete internalmsg; 425 internalmsg = NULL; 426 } 420 427 } 421 428 } … … 659 666 if (internalmsg == 0) 660 667 { 661 ERRLog(tpparam.name, methodname << "received not an TPoverTCPMsg but a" << internal_thread_msg->get_type_name()); 668 ERRLog(tpparam.name, methodname << "received not an TPoverTCPMsg but a" << internal_thread_msg->get_type_name()); 662 669 } 663 670 else … … 694 701 { 695 702 terminate= true; 696 } 703 } 704 705 delete internalmsg; 697 706 } // end while 698 707 … … 929 938 if ( ret < 0 ) 930 939 { 940 delete netmsg; 931 941 if (errno!=EAGAIN && errno!=EWOULDBLOCK) 932 942 { … … 1106 1116 1107 1117 receiver_thread_argp->terminated= true; 1118 delete netmsg; 1108 1119 1109 1120 Log(DEBUG_LOG,LOG_NORMAL, tpparam.name, methodname << "Thread <" << pthread_self() << "> terminated"); … … 1701 1712 { 1702 1713 init= false; 1714 this->connmap.clear(); 1703 1715 1704 1716 Log(DEBUG_LOG,LOG_NORMAL, tpparam.name, "Destructor called");
Note:
See TracChangeset
for help on using the changeset viewer.