| 209 | } |
| 210 | |
| 211 | static void* udpServerThread(void *args) { |
| 212 | UdpServer *server = (UdpServer *) args; |
| 213 | while (server->running) { |
| 214 | |
| 215 | ServerDataWorker<sockaddr_in> *pp = server->respQueue.pop(); |
| 216 | int ret = server->send(pp->getRemote(), pp->getResp(), pp->getResLen()); |
| 217 | delete pp; |
| 218 | |
| 219 | pdbg("processResp sendRet:%d tid:%d queueSize:%d", ret, gettid(), server->respQueue.size()); |
| 220 | } |
| 221 | pwrn("processResp loop QUIT now."); |
| 222 | return NULL; |
| 223 | } |
| 224 | |
| 225 | |
| 226 | int start(const char *ip, int port, HardCoder *hardCoder) { |