update

wangzhengquan

2020-11-27 a856e56b3943041d64a22285c550f6dbb9d2e193

 src/socket/net_mod_server_socket.c

@@ -43,7 +43,7 @@
   socklen_t clientlen;
  struct sockaddr_storage clientaddr;
  char portstr[32];
  if (signal(SIGPIPE, SIG_IGN) == SIG_ERR)    err_msg(errno, "signal");
  if (Signal(SIGPIPE, SIG_IGN) == SIG_ERR)    err_msg(errno, "signal");

  //shmModSocket = new ShmModSocket;
  sprintf(portstr, "%d", port);
@@ -134,6 +134,7 @@
  }

  request_head = NetModSocket::decode_request_head(request_head_bs);
// printf("server received request from host = %s:%d\n", request_head.host, request_head.port);

  if(request_head.content_length > max_buf) {
   
@@ -150,18 +151,19 @@
  }

  if(request_head.mod == REQ_REP) {
// printf("server response===========\n");
 
    memcpy(response_head.host, request_head.host, NI_MAXHOST);
    response_head.port = request_head.port;
    response_head.key = request_head.key;
    if(shmModSocket.sendandrecv_unsafe(buf, request_head.content_length, request_head.key, &recv_buf, &recv_size) != 0) {

      // 没有对应的key
      response_head.code = 1;
      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 )
        return -1;
      //Rio_writen(connfd, recv_buf, recv_size);
    } else {
      // 发送成功
      response_head.code = 0;
      response_head.content_length = recv_size;