From 8363843597053a37ad0c565af953ca11326e0129 Mon Sep 17 00:00:00 2001
From: YuQing <384681@qq.com>
Date: Tue, 24 Oct 2023 17:22:24 +0800
Subject: [PATCH] call conn_pool_connect_server with timeout_ms

---
 php_client/fastdfs_client.c | 2 +-
 storage/fdfs_storaged.c     | 2 +-
 test/dfs_func_pc.c          | 8 ++++----
 tracker/fdfs_trackerd.c     | 2 +-
 tracker/tracker_proto.c     | 6 +++---
 5 files changed, 10 insertions(+), 10 deletions(-)

diff --git a/php_client/fastdfs_client.c b/php_client/fastdfs_client.c
index 6469175..cd6212b 100644
--- a/php_client/fastdfs_client.c
+++ b/php_client/fastdfs_client.c
@@ -943,7 +943,7 @@ static void php_fdfs_connect_server_impl(INTERNAL_FUNCTION_PARAMETERS, \
 	server_info.sock = -1;
 
 	if ((pContext->err_no=conn_pool_connect_server(&server_info, \
-			SF_G_NETWORK_TIMEOUT)) == 0)
+			SF_G_NETWORK_TIMEOUT * 1000)) == 0)
 	{
 		array_init(return_value);
 		zend_add_assoc_stringl_ex(return_value, "ip_addr", \
diff --git a/storage/fdfs_storaged.c b/storage/fdfs_storaged.c
index e27c1a1..e0ab1a7 100644
--- a/storage/fdfs_storaged.c
+++ b/storage/fdfs_storaged.c
@@ -362,7 +362,7 @@ static void sigAlarmHandler(int sig)
 	server.port = SF_G_INNER_PORT;
 	server.sock = -1;
 
-	if (conn_pool_connect_server(&server, SF_G_CONNECT_TIMEOUT) != 0)
+	if (conn_pool_connect_server(&server, SF_G_CONNECT_TIMEOUT * 1000) != 0)
 	{
 		return;
 	}
diff --git a/test/dfs_func_pc.c b/test/dfs_func_pc.c
index bfe5185..8b76eba 100644
--- a/test/dfs_func_pc.c
+++ b/test/dfs_func_pc.c
@@ -27,8 +27,8 @@ static ConnectionInfo *getConnectedStorageServer(
 		{
 			if (pServer->sock < 0)
 			{
-				*err_no = conn_pool_connect_server(pServer, \
-					SF_G_CONNECT_TIMEOUT);
+				*err_no = conn_pool_connect_server(pServer,
+					SF_G_CONNECT_TIMEOUT * 1000);
 				if (*err_no != 0)
 				{
 					return NULL;
@@ -46,8 +46,8 @@ static ConnectionInfo *getConnectedStorageServer(
 	pServer = pEnd;
 	memcpy(pServer, pStorageServer, sizeof(ConnectionInfo));
 	pServer->sock = -1;
-	if ((*err_no=conn_pool_connect_server(pServer, \
-		SF_G_CONNECT_TIMEOUT)) != 0)
+	if ((*err_no=conn_pool_connect_server(pServer,
+		SF_G_CONNECT_TIMEOUT * 1000)) != 0)
 	{
 		return NULL;
 	}
diff --git a/tracker/fdfs_trackerd.c b/tracker/fdfs_trackerd.c
index 19701ea..37751db 100644
--- a/tracker/fdfs_trackerd.c
+++ b/tracker/fdfs_trackerd.c
@@ -434,7 +434,7 @@ static void sigAlarmHandler(int sig)
 	server.port = SF_G_INNER_PORT;
 	server.sock = -1;
 
-	if (conn_pool_connect_server(&server, SF_G_CONNECT_TIMEOUT) != 0)
+	if (conn_pool_connect_server(&server, SF_G_CONNECT_TIMEOUT * 1000) != 0)
 	{
 		return;
 	}
diff --git a/tracker/tracker_proto.c b/tracker/tracker_proto.c
index 3267f52..8208563 100644
--- a/tracker/tracker_proto.c
+++ b/tracker/tracker_proto.c
@@ -501,7 +501,7 @@ ConnectionInfo *tracker_connect_server_no_pool_ex(TrackerServerInfo *pServerInfo
 	}
 
 	*err_no = conn_pool_connect_server_ex(pServerInfo->connections
-            + pServerInfo->index, SF_G_CONNECT_TIMEOUT,
+            + pServerInfo->index, SF_G_CONNECT_TIMEOUT * 1000,
             bind_addr, log_connect_error);
     if (*err_no == 0)
     {
@@ -520,7 +520,7 @@ ConnectionInfo *tracker_connect_server_no_pool_ex(TrackerServerInfo *pServerInfo
         if (current_index != pServerInfo->index)
         {
             if ((*err_no=conn_pool_connect_server_ex(conn,
-                            SF_G_CONNECT_TIMEOUT, bind_addr,
+                            SF_G_CONNECT_TIMEOUT * 1000, bind_addr,
                             log_connect_error)) == 0)
             {
                 pServerInfo->index = current_index;
@@ -542,7 +542,7 @@ ConnectionInfo *tracker_make_connection_ex(ConnectionInfo *conn,
 	}
 	else
 	{
-		*err_no = conn_pool_connect_server(conn, connect_timeout);
+		*err_no = conn_pool_connect_server(conn, connect_timeout * 1000);
 		if (*err_no != 0)
 		{
 			return NULL;