uupdate

wangzhengquan

2020-06-11 981244e52c0d474df04d8b2ee6a2d57561c1a2f0

 service/netdisk_service.c

@@ -13,17 +13,15 @@



int work(Netdisk_DownloadRequest drequest);


PropertiesConfig config("../data/config.txt");
static int work(Netdisk_DownloadRequest drequest);
static int connectAndSend(const char *url, char * str);


int  WORKERS ;
std::string localUrl;
std::string remoteUrl;


PropertiesConfig config("../data/config.txt");

SafeQueue<Netdisk_DownloadRequest> task_queue(10);

@@ -68,17 +66,6 @@
  nng_close(sock);
  return 0;

}

void *worker(void *vargp)
{
  pthread_detach(pthread_self());
  while (1)
  {
    Netdisk_DownloadRequest  request;
    task_queue.pop(request);
    work(request);
  }
}

int work(Netdisk_DownloadRequest drequest) {
@@ -130,6 +117,19 @@
  return 0;
}

void *worker(void *vargp)
{
  pthread_detach(pthread_self());
  while (1)
  {
    Netdisk_DownloadRequest  request;
    task_queue.pop(request);
    work(request);
  }
}



void startServer(const char *url) {
  Json::Reader jsonreader;
  Json::Value request;