pdxx
/
fastdfs
mirror of https://github.com/happyfish100/fastdfs.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

client/test OK

pull/348/head
YuQing 2019-10-29 21:25:22 +08:00
parent 9cb1182776
commit 1a546865ac
4 changed files with 22 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
client/test/Makefile.in
View File

@ -1,7 +1,8 @@
.SUFFIXES: .c .o .SUFFIXES: .c .o
COMPILE = $(CC) $(CFLAGS) COMPILE = $(CC) $(CFLAGS)
INC_PATH = -I/usr/include/fastcommon -I/usr/include/fastdfs INC_PATH = -I/usr/include/fastcommon -I/usr/include/fastdfs \
-I/usr/local/include/fastcommon -I/usr/local/include/fastdfs
LIB_PATH = -L/usr/local/lib -lfastcommon -lfdfsclient $(LIBS) LIB_PATH = -L/usr/local/lib -lfastcommon -lfdfsclient $(LIBS)
TARGET_PATH = $(TARGET_PATH) TARGET_PATH = $(TARGET_PATH)

28
client/test/fdfs_monitor.c
View File

@ -12,6 +12,7 @@
#include <string.h> #include <string.h>
#include <errno.h> #include <errno.h>
#include <signal.h> #include <signal.h>
#include <netdb.h>
#include <sys/types.h> #include <sys/types.h>
#include "fastcommon/sockopt.h" #include "fastcommon/sockopt.h"
#include "fastcommon/logger.h" #include "fastcommon/logger.h"
@ -25,8 +26,11 @@ static int list_all_groups(const char *group_name);
static void usage(char *argv[]) static void usage(char *argv[])
{ {
printf("Usage: %s <config_file> [-h <tracker_server>] [list|delete|set_trunk_server <group_name> " \ printf("Usage: %s <config_file> [-h <tracker_server>] "
"[storage_id]]\n", argv[0]); "[list|delete|set_trunk_server <group_name> [storage_id]]\n"
"\tthe tracker server format: host[:port], "
"the tracker default port is %d\n\n",
argv[0], FDFS_TRACKER_SERVER_DEF_PORT);
} }
int main(int argc, char *argv[]) int main(int argc, char *argv[])
@ -115,21 +119,20 @@ int main(int argc, char *argv[])
else else
{ {
int i; int i;
char ip_addr[IP_ADDRESS_SIZE]; ConnectionInfo conn;
*ip_addr = '\0'; if ((result=conn_pool_parse_server_info(tracker_server, &conn,
if (getIpaddrByName(tracker_server, ip_addr, sizeof(ip_addr)) \ FDFS_TRACKER_SERVER_DEF_PORT)) != 0)
== INADDR_NONE)
{ {
printf("resolve ip address of tracker server: %s " \ printf("resolve ip address of tracker server: %s "
"fail!\n", tracker_server); "fail!, error info: %s\n", tracker_server, hstrerror(h_errno));
return 2; return result;
} }
for (i=0; i<g_tracker_group.server_count; i++) for (i=0; i<g_tracker_group.server_count; i++)
{ {
if (strcmp(g_tracker_group.servers[i].ip_addr, \ if (fdfs_server_contain1(g_tracker_group.servers + i,
ip_addr) == 0) &conn) == 0)
{ {
g_tracker_group.server_index = i; g_tracker_group.server_index = i;
break; break;
@ -143,7 +146,8 @@ int main(int argc, char *argv[])
} }
} }
printf("server_count=%d, server_index=%d\n", g_tracker_group.server_count, g_tracker_group.server_index); printf("server_count=%d, server_index=%d\n",
g_tracker_group.server_count, g_tracker_group.server_index);
pTrackerServer = tracker_get_connection(); pTrackerServer = tracker_get_connection();
if (pTrackerServer == NULL) if (pTrackerServer == NULL)

4
client/test/fdfs_test.c
View File

@ -194,7 +194,7 @@ int main(int argc, char *argv[])
group_name, storageServer.ip_addr, \ group_name, storageServer.ip_addr, \
storageServer.port); storageServer.port);
if ((pStorageServer=tracker_connect_server(&storageServer, \ if ((pStorageServer=tracker_make_connection(&storageServer, \
&result)) == NULL) &result)) == NULL)
{ {
fdfs_client_destroy(); fdfs_client_destroy();
@ -491,7 +491,7 @@ int main(int argc, char *argv[])
printf("storage=%s:%d\n", storageServer.ip_addr, \ printf("storage=%s:%d\n", storageServer.ip_addr, \
storageServer.port); storageServer.port);
if ((pStorageServer=tracker_connect_server(&storageServer, \ if ((pStorageServer=tracker_make_connection(&storageServer, \
&result)) == NULL) &result)) == NULL)
{ {
fdfs_client_destroy(); fdfs_client_destroy();

4
client/test/fdfs_test1.c
View File

@ -191,7 +191,7 @@ int main(int argc, char *argv[])
group_name, storageServer.ip_addr, \ group_name, storageServer.ip_addr, \
storageServer.port); storageServer.port);
if ((pStorageServer=tracker_connect_server(&storageServer, \ if ((pStorageServer=tracker_make_connection(&storageServer, \
&result)) == NULL) &result)) == NULL)
{ {
fdfs_client_destroy(); fdfs_client_destroy();
@ -458,7 +458,7 @@ int main(int argc, char *argv[])
printf("storage=%s:%d\n", storageServer.ip_addr, \ printf("storage=%s:%d\n", storageServer.ip_addr, \
storageServer.port); storageServer.port);
if ((pStorageServer=tracker_connect_server(&storageServer, \ if ((pStorageServer=tracker_make_connection(&storageServer, \
&result)) == NULL) &result)) == NULL)
{ {
fdfs_client_destroy(); fdfs_client_destroy();