sockets - WSAWaitForMultipleEvents returns timeout when send() is succesful -


i working on application involves socket programming. trying implement reset functionality in application in case server closed or crashed reason. reset need reestablish communication between client , server after manual restart of server. able send request client server server process , send reply client. send() function @ server side returning success wsawaitformultipleevents() function @ client side returning wsa_time_out every time.

i restart socket @ client side so_reuseaddr true value on reset. new network programming not able understand why happening.

please help. thank you

here code @ client side. little messed please bear me

void socketlistner::run() { // std::cout << "thread id of socketlistener : " << qthread::currentthreadid() << "\n"; if(_isframegrabber) { _listenforframes(); } else { _listenforrequests(); } } void socketlistner::_listenforrequests() { dword eventval; unsigned int eventsock; wsanetworkevents networkevents; std::stringstream ss; int bufferlength = 500; char * msg = new char[bufferlength]; std::string msg = ""; int retcode; int diff; while(!_done) { // giving 1 second less condition wait time // openthreads::scopedlock<openthreads::mutex> lock(_destructormutex); if((eventval=wsawaitformultipleevents(_eventcnt, _socketevents, false, 3000, false)) == wsa_wait_failed) { ss.str(""); ss << "wsawaitformultipleevents() failed error : " << wsagetlasterror(); log_error(ss.str()); emit socketerrorsignal(eventval); break; } else if(eventval == wsa_wait_timeout) { //openthreads::scopedlock<openthreads::mutex> lock(_mutex); if(_done) { wsacloseevent(_socketevents[0]); if(_eventcnt==2) wsacloseevent(_socketevents[1]); break; } continue; } if( (diff=(eventval - wsa_wait_event_0)) == 0 ) eventsock = s_sock; else if(diff == 1) eventsock = c_sock; else continue; if((wsaenumnetworkevents(eventsock, _socketevents[eventval - wsa_wait_event_0], &networkevents)) == socket_error) { ss.str(""); ss << "wsaenumnetworkevents() failed error : " << wsagetlasterror(); log_error(ss.str()); // break; } if (networkevents.lnetworkevents & fd_accept) { if (networkevents.ierrorcode[fd_accept_bit] != 0) { ss.str(""); ss << "fd_accept failed error : " << networkevents.ierrorcode[fd_accept_bit]; log_error(ss.str()); break; } if ((c_sock = accept(eventsock, null, null)) == invalid_socket) { ss.str(""); ss << "accept() failed error : " << wsagetlasterror(); log_error(ss.str()); break; } if ((_socketevents[_eventcnt] = wsacreateevent()) == wsa_invalid_event) { std::stringstream ss; ss << "wsacreateevent() failed error : " << wsagetlasterror(); log_error(ss.str()); break; } if( wsaeventselect(c_sock, _socketevents[_eventcnt], fd_read | fd_close) == socket_error) { ss.str(""); ss << "wsaeventselect() failed error : " << wsagetlasterror(); log_error(ss.str()); break; } ++_eventcnt; } if(networkevents.lnetworkevents & fd_read) { if (networkevents.lnetworkevents & fd_read && networkevents.ierrorcode[fd_read_bit] != 0) { ss.str(""); ss << "fd_read failed error : " << networkevents.ierrorcode[fd_read_bit]; log_error(ss.str()); } if((retcode = recv(eventsock, msg, bufferlength, 0)) > 0) { int place = 0; while(place < retcode) { if(msg[place] == '\n' && msg.length() != 0) { openthreads::scopedlock<openthreads::mutex> lock(_mutex); //naresh: replacing std::vector std::queue _requests.push(msg); msg = ""; } else { if(msg[place] != '\0') msg.push_back(msg[place]); } ++place; } } //abhishek: testing complete else block else if(retcode == 0 || wsagetlasterror() == wsaeconnreset) { //abhishek shutdown(c_sock, sd_both); shutdown(s_sock, sd_both); closesocket(c_sock); closesocket(s_sock); int error = wsagetlasterror(); if(!_initialize()) { _done = true; return; } } else if(retcode == socket_error) { bool stoplistening=false; int errorcode = wsagetlasterror(); _processsocketerror(errorcode, stoplistening); if(stoplistening) { log_warning("connection partner lost."); emit socketerrorsignal(errorcode); break; } } } if(networkevents.lnetworkevents & fd_close) { if (networkevents.ierrorcode[fd_close_bit] != 0) { ss.str(""); ss << "fd_close failed error : " << networkevents.ierrorcode[fd_close_bit]; log_error(ss.str()); emit socketerrorsignal(networkevents.ierrorcode[fd_close_bit]); } else if(!_stopped) { log_error("lost connection wall."); emit socketerrorsignal(networkevents.ierrorcode[fd_close_bit]); } closesocket(eventsock); break; } //sleep(100); } //while delete[] msg; msg = null; // if failure occurs make _bdone variable true, thread no longer running _cleanupcondition.signal(); }

here _initialize function

bool socketlistner::_initialize() { if(_ip.length() <= 0) { log_error("host ip address : " + _ip + " invalid."); return false; } //naresh: replacing vector queue while(!_requests.empty()) { _requests.pop(); } wsadata wsadata; if(wsastartup(0x101,&wsadata) != 0) { log_error("failed wsastartup() call."); return false; } sockaddr_in sockaddr; sockaddr.sin_family = af_inet; sockaddr.sin_port = htons(_port); sockaddr.sin_addr.s_addr = inet_addr(_ip.c_str()); s_sock = socket(af_inet,sock_stream,0); //abhishek:bugfix reset enable address reuse else bind() fail bool addrreuse = true; setsockopt(s_sock, sol_socket, so_reuseaddr, (const char*) &addrreuse, sizeof(bool)); if(!_isframegrabber) { if ((_socketevents[_eventcnt] = wsacreateevent()) == wsa_invalid_event) { std::stringstream ss; ss << "wsacreateevent() failed error : " << wsagetlasterror(); log_error(ss.str()); return false; } if(wsaeventselect(s_sock, _socketevents[_eventcnt], fd_accept | fd_close)== socket_error) { std::stringstream ss; ss << "wsaeventselect() failed error : " << wsagetlasterror(); log_error(ss.str()); return false; } ++_eventcnt; } if(s_sock == invalid_socket) return false; int errorcode = bind(s_sock,(sockaddr*)&sockaddr,sizeof(sockaddr)); if(errorcode == socket_error) { bool stoplistening = false; _processsocketerror(wsagetlasterror(), stoplistening); return false; } if(listen(s_sock,10)!=0) { return false; } return true; }

if peer dies there won't events @ all. reliable way detect broken connection in tcp write it. first write broken connection succeed later 1 fail.


Comments

Post a Comment

Popular posts from this blog

javascript - backbone.js Collection.add() doesn't `construct` (`initialize`) an object -

<!doctype html public "-//w3c//dtd xhtml 1.0 strict//en" "http://www.w3.org/tr/xhtml1/dtd/xhtml1-strict.dtd"> <html> <head> <script src="https://ajax.googleapis.com/ajax/libs/jquery/1.7.2/jquery.min.js"></script> <script src="http://documentcloud.github.com/underscore/underscore-min.js"></script> <script src="http://documentcloud.github.com/backbone/backbone-min.js"></script> </head> <body> <button id="cmd_create_event" name="cmd_create_event" type="button">create new `event`</button> <script type="text/javascript"> var eventmodel = backbone.model.extend({ initialize : function() { console.log("`event` initialized. id: " + this.cid); this.bind("change:status", function() { console.log(this.get("status") + " value `status`"); }); this.bind("error", function(model, e...
Read more

php - Get uncommon values from two or more arrays -

is there function in php give array of uncommon values 2 or more arrays? for example: $array1 = array( "green", "red", "blue"); $array2 = array( "green", "yellow", "red"); .... $result = function_needed($array1, $array2,...); print_r($result); should give output: array("blue", "yellow", ...); use array_diff , array_merge : $result = array_merge(array_diff($array1, $array2), array_diff($array2, $array1)); here's demo. for multiple arrays, combine callback , array_reduce : function unique(&$a, $b) { return $a ? array_merge(array_diff($a, $b), array_diff($b, $a)) : $b; } $arrays = array( array('green', 'red', 'blue'), array('green', 'yellow', 'red') ); $result = array_reduce($arrays, 'unique'); and here's demo of that.
Read more

Adding duplicate array rows in Php -

i create function in php adds rows of array shared column value. so input. $test = array( array("c", 5, 6), array("c", 2, 3), array("test", 5, 6) ); and output. $testduplicatefree = array( array("c", 7, 9), array("test", 5, 6) ) ); i'm thinking function combine_duplicates($array,$col){ ... ... return $duplicatefreearray; } where $col duplicate free array. so, in case, combine_duplicates($test,0); would me desired output. this. <?php function combine_duplicates($array,$col) { $index = array(); foreach ($array $row) { $key = $row[$col]; if (!isset($index[$key])) { $index[$key] = $row; } else { ($i = 0; $i < count($row); ++$i) { if ($i != $col) { $index[$key][$i] += $row[$i]; } } } } return array_values($index); } $array = array( array("c", 5, 6), array("c", 2, 3), array("test", 5, 6) ); print_r(combine_duplicates($array, 0)); try here: http://codepad.org/mdhesqhi
Read more