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