File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -418,18 +418,17 @@ int main (int pid,char** av)try{
418418 assert (!requests.empty ());
419419 auto & req=requests.front ();
420420 try {
421+ ring->recv9 ();
421422 cmwBuf.decompress ();
422423 if (giveBool (cmwBuf)){
423424 req.saveOutput ();
424425 ring->sendto (s2ind,req.frnt );
425426 }else ring->sendto (s2ind,req.frnt ," CMW:" ,cmwBuf.giveStringView ());
426- requests.pop_front ();
427427 }catch (::std::exception& e){
428428 ::syslog (LOG_ERR," %d Reply from CMW %s" ,pid,e.what());
429429 ring->sendto (s2ind,req.frnt ,e.what ());
430- requests.pop_front ();
431430 }
432- ring-> recv9 ();
431+ requests. pop_front ();
433432 break ;
434433 }
435434 default : ::bail (" Unknown user_data %llu" ,cq->user_data );
Original file line number Diff line number Diff line change @@ -418,18 +418,17 @@ int main (int pid,char** av)try{
418418 assert (!requests.empty ());
419419 auto & req=requests.front ();
420420 try {
421+ ring->recv9 ();
421422 cmwBuf.decompress ();
422423 if (giveBool (cmwBuf)){
423424 req.saveOutput ();
424425 ring->sendto (s2ind,req.frnt );
425426 }else ring->sendto (s2ind,req.frnt ," CMW:" ,cmwBuf.giveStringView ());
426- requests.pop_front ();
427427 }catch (::std::exception& e){
428428 ::syslog (LOG_ERR," %d Reply from CMW %s" ,pid,e.what());
429429 ring->sendto (s2ind,req.frnt ,e.what ());
430- requests.pop_front ();
431430 }
432- ring-> recv9 ();
431+ requests. pop_front ();
433432 break ;
434433 }
435434 default : ::bail (" Unknown user_data %llu" ,cq->user_data );
You can’t perform that action at this time.
0 commit comments