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