求5.01版本tracker_get_connection_r的正確用法。

toniz

conn = tracker_get_connection_r(&TrackerServer, &result);

這個TrackerServer  和  conn 是啥關(guān)系， 關(guān)閉的時候要如何才能正確關(guān)閉連接。

toniz

這個問題已經(jīng)決解。

我為了重用，把connect和disconnect部分單獨拆成一個方法。
但其實TrackerServer不能在方法里面定義，要在使用的地方定義，作為參數(shù)帶進去才行。
不然調(diào)用close后，這個鏈接會一直存在(實際上沒有close這個socket)。
如果連接數(shù)滿了之后，服務(wù)端會發(fā)起fin，這個時候會造成客戶端大量close_wait.

正確代碼如下：

1. 
   
2. ConnectionInfo* FdfsClient::connectFastDFS(ConnectionInfo &trackerServer,
   
3.                                            ConnectionInfo &storageServer,
   
4.                                            int &store_path_index, char group_name[])
   
5. {
   
6.     int result;
   
7.     ConnectionInfo *conn;
   
8.     conn = tracker_get_connection_r(&trackerServer, &result);
   
9.     if ( result != 0 )
   
10.     {   
    
11.         MYLOG_WARN(logger, "tracker_get_connection fail, error no: %d, error info: %s\n", errno , STRERROR(errno));
    
12.         return NULL;
    
13.     }   
    
14. 
    
15.     *group_name = '\0';
    
16.     store_path_index = 0;
    
17.     result = 0;
    
18.     if ((result=tracker_query_storage_store(conn, &storageServer, group_name, &store_path_index)) != 0)
    
19.     {   
    
20.         fdfs_quit(conn);
    
21.         tracker_disconnect_server(conn);
    
22.         MYLOG_WARN(logger, "tracker_query_storage fail, error no: %d, error info: %s\n", result, STRERROR(result));
    
23.         return NULL;
    
24.     }   
    
25. 
    
26.     return conn;
    
27. }

復(fù)制代碼

錯誤代碼如下：

1. ConnectionInfo* FdfsClient::connectFastDFS(ConnectionInfo &storageServer, int &store_path_index, char group_name[])
   
2. {
   
3.     int result;
   
4.     ConnectionInfo TrackerServer;
   
5.     ConnectionInfo *conn;
   
6.     conn = tracker_get_connection_r(&TrackerServer, &result);
   
7.     if ( result != 0 )
   
8.     {
   
9.         MYLOG_WARN(logger, "tracker_get_connection fail, error no: %d, error info: %s\n", errno , STRERROR(errno));
   
10.         return NULL;
    
11.     }
    
12. 
    
13.     *group_name = '\0';
    
14.     store_path_index = 0;
    
15.     result = 0;
    
16.     if ((result=tracker_query_storage_store(conn, &storageServer, group_name, &store_path_index)) != 0)
    
17.     {
    
18.         fdfs_quit(conn);
    
19.         tracker_disconnect_server(conn);
    
20.         MYLOG_WARN(logger, "tracker_query_storage fail, error no: %d, error info: %s\n", result, STRERROR(result));
    
21.         return NULL;
    
22.     }
    
23.     return conn;
    
24. }

復(fù)制代碼

調(diào)用的代碼如下：

1. int FdfsClient::uploadAppenderByBuff(const char *file_content, int content_len, const char *file_ext_name, char file_id[])               
   
2. {                                                                                                                                       
   
3.     int store_path_index;                                                                                                               
   
4.     ConnectionInfo trackerServer;                                                                                                        
   
5.     ConnectionInfo storageServer;                                                                                                        
   
6.     char group_name[FDFS_GROUP_NAME_MAX_LEN + 1];                                                                                       
   
7.                                                                                                                                          
   
8.     int result;                                                                                                                          
   
9.     ConnectionInfo *pTrackerServer;                                                                                                      
   
10.     pTrackerServer = connectFastDFS(trackerServer, storageServer, store_path_index, group_name);                                         
    
11.                                                                                                                                          
    
12.     if( pTrackerServer == NULL )                                                                                                         
    
13.     {                                                                                                                                    
    
14.         return RETURN_GET_CONNECTION_FAIL;                                                                                               
    
15.     }                                                                                                                                    
    
16.                                                                                                                                          
    
17.     result = storage_upload_appender_by_filebuff1(pTrackerServer, &storageServer, store_path_index, \                                    
    
18.                             file_content, content_len, file_ext_name, NULL, 0, group_name, file_id);                                    
    
19.                                                                                                                                          
    
20.     if (result != 0)                                                                                                                     
    
21.     {                                                                                                                                    
    
22.         MYLOG_WARN(logger, "upload file fail, error no: %d, error info: %s\n", result, STRERROR(result));                                
    
23.         disConnectFastDFS(pTrackerServer, storageServer);                                                                                
    
24.         return RETURN_UPLOAD_APPENDER_FAIL;                                                                                             
    
25.     }                                                                                                                                    
    
26.     disConnectFastDFS(pTrackerServer, storageServer);                                                                                    
    
27.     return RETURN_SUCCESS;                                                                                                               
    
28. }

復(fù)制代碼

disconnect代碼如下：

1. int FdfsClient::disConnectFastDFS(ConnectionInfo *pTrackerServer, ConnectionInfo &storageServer)
   
2. {
   
3.     fdfs_quit(&storageServer);
   
4.     tracker_disconnect_server(&storageServer);
   
5.     fdfs_quit(pTrackerServer);
   
6.     tracker_disconnect_server(pTrackerServer);
   
7.     return RETURN_SUCCESS;                                                                                                               
   
8. }

復(fù)制代碼