wangzhengquan
2020-06-30 9b2d472b92665ab6afac8dcca9683c759b3fbb8a
service/netdisk_service.c
@@ -97,18 +97,6 @@
  }
 
  // Json::Value response;
  // Json::Value payload;
  // response["code"] = rv;
  // response["msg"] = rmsg;
  // Json::Value filelist;
  // for(std::string f : files) {
  //   filelist.append(f);
  // }
  // payload["filelist"] = filelist;
  // response["payload"] = payload;
  Json::Value request;
  request["method"] = "downloadByTimeCallBack";
  Json::Value arguments;
@@ -122,8 +110,7 @@
  request["arguments"] = arguments;
  std::string str = request.toStyledString();
  std::cout << "download finished, call back" << std::endl;
  std::cout << str << std::endl;
  std::cout << "SENDING download finished\n" << str << std::endl;
  connectAndSend(remoteUrl.c_str(), strdup(str.c_str()) );
  
  return 0;
@@ -214,11 +201,11 @@
    char *buf = NULL;
    size_t sz;
    if ((rv = nng_recv(sock, &buf, &sz, NNG_FLAG_ALLOC)) == 0) {
printf("CLIENT (%s): RECEIVED \"%s\" SURVEY REQUEST\n", name, buf);
//printf("CLIENT (%s): RECEIVED \"%s\" SURVEY REQUEST\n", name, buf);
      nng_free(buf, sz);
      char response[1024];
      sprintf(response, "%s-%d", name, getpid());
printf("CLIENT (%s): SENDING SURVEY RESPONSE:%s\n", name, response);
//printf("CLIENT (%s): SENDING SURVEY RESPONSE:%s\n", name, response);
      if ((rv = nng_send(sock, response, strlen(response) + 1, 0)) != 0) {
        fatal("nng_send", rv);
      }