| 118 | } |
| 119 | |
| 120 | static void* localServerRespThread(void *args) { |
| 121 | pdbg("localServerRespThread run pid:%d tid:%d", getpid(), gettid()); |
| 122 | LocalSocketServer *server = (LocalSocketServer *) args; |
| 123 | while (server->running) { |
| 124 | ServerDataWorker<int> *pp = server->respQueue.pop(); |
| 125 | int ret = server->sendData(pp->getRemote(), pp->getResp(), pp->getResLen()); |
| 126 | delete pp; |
| 127 | |
| 128 | pdbg("processResp sendRet:%d tid:%d queueSize:%d", ret, gettid(), server->respQueue.size()); |
| 129 | } |
| 130 | pwrn("processResp loop QUIT now."); |
| 131 | return NULL; |
| 132 | } |
| 133 | |
| 134 | int start(const char *path, HardCoder *hardCoder) { |
| 135 | inst = hardCoder; |