|
Lines 87-95
Link Here
|
| 87 |
|
87 |
|
| 88 |
if (req_queue.size() != 0) |
88 |
if (req_queue.size() != 0) |
| 89 |
{ |
89 |
{ |
| 90 |
log->log("RRProc", Log::ERR, "threadMethod err 1"); |
90 |
log->log("RRProc", Log::ERR, "threadMethod startup with already queued packets"); |
| 91 |
threadUnlock(); |
91 |
while (req_queue.size()) |
| 92 |
return; |
92 |
{ |
|
|
93 |
//log->log("RRProc", Log::DEBUG, "thread while"); |
| 94 |
req = req_queue.front(); |
| 95 |
req_queue.pop(); |
| 96 |
|
| 97 |
threadUnlock(); // allow recvRequest to be queuing packets while we are working on this one |
| 98 |
|
| 99 |
if (!processPacket()) |
| 100 |
{ |
| 101 |
log->log("RRProc", Log::ERR, "processPacket exited with fail"); |
| 102 |
return; |
| 103 |
} |
| 104 |
|
| 105 |
threadLock(); |
| 106 |
} |
| 107 |
log->log("RRProc", Log::ERR, "threadMethod startup with already queued packets done."); |
| 108 |
|
| 93 |
} |
109 |
} |
| 94 |
|
110 |
|
| 95 |
while(1) |
111 |
while(1) |
