From a569f6895e7ea624b869609a41ad4e39ea0f041a Mon Sep 17 00:00:00 2001
From: mrDarker <mr.darker@163.com>
Date: 星期五, 22 八月 2025 11:12:01 +0800
Subject: [PATCH] 1. NI添加计算Notch周长
---
EdgeInspector_App/WebSocket/WebSocketClientPool.h | 92 +++++++++++++++++++++++-----------------------
1 files changed, 46 insertions(+), 46 deletions(-)
diff --git a/EdgeInspector_App/WebSocket/WebSocketClientPool.h b/EdgeInspector_App/WebSocket/WebSocketClientPool.h
index 87b5e5f..464df79 100644
--- a/EdgeInspector_App/WebSocket/WebSocketClientPool.h
+++ b/EdgeInspector_App/WebSocket/WebSocketClientPool.h
@@ -1,50 +1,50 @@
-#ifndef WEBSOCKETCLIENTWITHPOOL_H
+锘�#ifndef WEBSOCKETCLIENTWITHPOOL_H
#define WEBSOCKETCLIENTWITHPOOL_H
-#include "WebSocketClient.h"
-#include "ThreadPool.h"
-
-class WebSocketClientPool {
-public:
- explicit WebSocketClientPool(size_t thread_count);
- ~WebSocketClientPool();
-
- // 初始化客户端
- void init_clients(const std::vector<std::string>& uris);
-
- // 退出所有客户端
- void exit_clients();
-
- // 使用线程池发送消息
- void post_to_all(const std::string& message);
- void post_binary_to_all(const std::vector<char>& binary_data);
-
- // 从池中选择一个空闲的客户端进行发送，不需要服务器响应
- bool post_to_idle_client(const std::string& message);
- bool post_binary_to_idle_client(const std::vector<char>& binary_data);
-
- // 从池中选择一个空闲的客户端进行发送，并需要服务器响应
- bool send_to_idle_client(const std::string& message, int timeout_ms);
- bool send_binary_to_idle_client(const std::vector<char>& binary_data, int timeout_ms);
-
- // 从池中选择一个空闲的客户端进行发送，并等待服务器响应
- bool send_to_idle_client_and_wait(const std::string& message, int timeout_ms);
- bool send_binary_to_idle_client_and_wait(const std::vector<char>& binary_data, int timeout_ms);
-
- // 从池中选择一个空闲的客户端进行发送，并等待服务器响应，如果超时则重试
- bool send_to_idle_client_with_retry(const std::string& message, int total_timeout_ms, int retry_interval_ms);
- bool send_binary_to_idle_client_with_retry(std::vector<char>&& binary_data, int total_timeout_ms, int retry_interval_ms);
-
- // 设置 WebSocket 客户端事件处理程序
- void set_open_handler(WebSocketClient::OpenHandler handler);
- void set_message_handler(WebSocketClient::MessageHandler handler);
- void set_close_handler(WebSocketClient::CloseHandler handler);
- void set_fail_handler(WebSocketClient::FailHandler handler);
- void set_pong_handler(WebSocketClient::PongHandler handler);
-
-private:
- std::vector<std::shared_ptr<WebSocketClient>> m_clients;
- ThreadPool m_thread_pool;
-};
+//#include "WebSocketClient.h"
+//#include "ThreadPool.h"
+//
+//class WebSocketClientPool {
+//public:
+// explicit WebSocketClientPool(size_t thread_count);
+// ~WebSocketClientPool();
+//
+// // 鍒濆鍖栧鎴风
+// void init_clients(const std::vector<std::string>& uris);
+//
+// // 閫�鍑烘墍鏈夊鎴风
+// void exit_clients();
+//
+// // 浣跨敤绾跨▼姹犲彂閫佹秷鎭�
+// void post_to_all(const std::string& message);
+// void post_binary_to_all(const std::vector<char>& binary_data);
+//
+// // 浠庢睜涓�夋嫨涓�涓┖闂茬殑瀹㈡埛绔繘琛屽彂閫侊紝涓嶉渶瑕佹湇鍔″櫒鍝嶅簲
+// bool post_to_idle_client(const std::string& message);
+// bool post_binary_to_idle_client(const std::vector<char>& binary_data);
+//
+// // 浠庢睜涓�夋嫨涓�涓┖闂茬殑瀹㈡埛绔繘琛屽彂閫侊紝骞堕渶瑕佹湇鍔″櫒鍝嶅簲
+// bool send_to_idle_client(const std::string& message, int timeout_ms);
+// bool send_binary_to_idle_client(const std::vector<char>& binary_data, int timeout_ms);
+//
+// // 浠庢睜涓�夋嫨涓�涓┖闂茬殑瀹㈡埛绔繘琛屽彂閫侊紝骞剁瓑寰呮湇鍔″櫒鍝嶅簲
+// bool send_to_idle_client_and_wait(const std::string& message, int timeout_ms);
+// bool send_binary_to_idle_client_and_wait(const std::vector<char>& binary_data, int timeout_ms);
+//
+// // 浠庢睜涓�夋嫨涓�涓┖闂茬殑瀹㈡埛绔繘琛屽彂閫侊紝骞剁瓑寰呮湇鍔″櫒鍝嶅簲锛屽鏋滆秴鏃跺垯閲嶈瘯
+// bool send_to_idle_client_with_retry(const std::string& message, int total_timeout_ms, int retry_interval_ms);
+// bool send_binary_to_idle_client_with_retry(std::vector<char>&& binary_data, int total_timeout_ms, int retry_interval_ms);
+//
+// // 璁剧疆 WebSocket 瀹㈡埛绔簨浠跺鐞嗙▼搴�
+// void set_open_handler(WebSocketClient::OpenHandler handler);
+// void set_message_handler(WebSocketClient::MessageHandler handler);
+// void set_close_handler(WebSocketClient::CloseHandler handler);
+// void set_fail_handler(WebSocketClient::FailHandler handler);
+// void set_pong_handler(WebSocketClient::PongHandler handler);
+//
+//private:
+// std::vector<std::shared_ptr<WebSocketClient>> m_clients;
+// ThreadPool m_thread_pool;
+//};
#endif // WEBSOCKETCLIENTWITHPOOL_H
\ No newline at end of file
--
Gitblit v1.9.3