From 981244e52c0d474df04d8b2ee6a2d57561c1a2f0 Mon Sep 17 00:00:00 2001 From: wangzhengquan <wangzhengquan85@126.com> Date: 星期四, 11 六月 2020 19:22:59 +0800 Subject: [PATCH] uupdate --- service/netdisk_service.c | 32 ++++++++++++++++---------------- 1 files changed, 16 insertions(+), 16 deletions(-) diff --git a/service/netdisk_service.c b/service/netdisk_service.c index 8d31587..c71a014 100644 --- a/service/netdisk_service.c +++ b/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; -- Gitblit v1.8.0