| | |
|---|
| | | sprintf(portstr, "%d", port); |
|---|
| | | listenfd = open_listenfd(portstr); |
|---|
| | | if(listenfd < 0) { |
|---|
| | | LoggerFactory::getLogger()->error(errno, "NetModServerSocket::start . errno=%d", errno); |
|---|
| | | LoggerFactory::getLogger()->error(errno, "NetModServerSocket::start . errno=%d ", errno); |
|---|
| | | return -1; |
|---|
| | | } |
|---|
| | | init_pool(listenfd); |
|---|
| | |
|---|
| | | else if(request_head.timeout == -1) { |
|---|
| | | ret = shmModSocket.pub((char*)topic_buf, request_head.topic_length, buf, request_head.content_length, BUS_KEY); |
|---|
| | | } |
|---|
| | | printf("bus server pub ret=%d\n", ret); |
|---|
| | | response_head.code = ret; |
|---|
| | | response_head.content_length = 0; |
|---|
| | | if( rio_writen(connfd, NetModSocket::encode_response_head(response_head), NET_MODE_RESPONSE_HEAD_LENGTH) != NET_MODE_RESPONSE_HEAD_LENGTH ) |
|---|
