update

wangzhengquan

2020-06-30 9b2d472b92665ab6afac8dcca9683c759b3fbb8a

update

 data/config.txt

@@ -1,9 +1,9 @@
# nng本地服务地址
# server_url=tcp://192.168.20.104:8801
server_url=tcp://192.168.20.104:7701
server_url=tcp://192.168.20.104:8801
#server_url=tcp://192.168.20.104:7701
# nng远程调用地址地址
client_url=tcp://192.168.20.104:7702
# client_url=tcp://192.168.20.10:8802
#client_url=tcp://192.168.20.104:7702
client_url=tcp://192.168.20.10:8802

# 心跳服务器
heart_server=tcp://192.168.20.10:5006

 device/hcnetdisk.c

@@ -247,7 +247,7 @@
    printf("Be downloading...%d %%\n", nPos);
    sleep(1);
  }
  printf("have got %d\n", nPos);
  // printf("have got %d\n", nPos);
//停止下载
  if (!NET_DVR_StopGetFile(hPlayback))
  {
@@ -255,7 +255,7 @@
    bRes = -1;
    return bRes;
  }
  printf("%s\n", srcfile);
  // printf("%s\n", srcfile);
  if (nPos < 0 || nPos > 100)
  {
    printf("download err [%d]\n", NET_DVR_GetLastError());

 service/netdisk_service

Binary files differ

 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);
      }

 service/test_client

Binary files differ

 service/test_client.c

@@ -113,7 +113,7 @@
    end["mon"] = 4;
    end["day"] = 10;
    end["hour"] = 14;
    end["min"] = 30;
    end["min"] = 40;
    end["sec"] = 0;
    arguments["end"] = end;