FastDFS分块上传，返回错误22，请大侠帮忙?

曾昭强

在使用FastDFS API“storage_modify_by_filebuff1”上传文件时，返回错误22，即无效的参数。现将部分代码贴出来，请各位大侠帮忙指正？另外： FastDFS版本是5.05

1. void FileServiceFastDfs::AsyncWriteFile(::google::protobuf::RpcController* controller,
   
2.                        const ::FileChunk* request,
   
3.                        ::WriteResponse* response,
   
4.                        ::google::protobuf::Closure* done)
   
5. {
   
6.         ConnectionInfo *pTrackerServer;
   
7.         ConnectionInfo *pStorageServer;
   
8.         ConnectionInfo storageServer;
   
9.         ConnectionInfo trackerServer;
   
10.         int result;
    
11.         char group_name[FDFS_GROUP_NAME_MAX_LEN + 1];
    
12.         char remote_filename[256];
    
13.         FDFSMetaData meta_list[32];
    
14.         int meta_count;
    
15.         char file_id[128];
    
16.         int store_path_index;
    
17.         FDFSFileInfo file_info;
    
18.         const char *file_ext_name;
    
19. 
    
20. 
    
21.         pTrackerServer = tracker_get_connection_r(&trackerServer, &result);
    
22.         if (pTrackerServer == NULL)
    
23.         {
    
24.                 response->set_error(-1);
    
25.                 return;
    
26.         }
    
27. 
    
28.         // 第一个分块（上传没有问题，成功返回file_id）
    
29.         if (request->offset() == 0)
    
30.          {
    
31.                 *group_name = '\0';
    
32.                  store_path_index = 0;
    
33.                 if ((result = tracker_query_storage_store(pTrackerServer, &storageServer, group_name, &store_path_index)) != 0)
    
34.                  {
    
35.                         printf("tracker_query_storage fail, " \
    
36.                                  "error no: %d, error info: %s\n", \
    
37.                                 result, STRERROR(result));
    
38.                         response->set_error(-1);
    
39.                          tracker_disconnect_server_ex(pTrackerServer, true);
    
40.                         return;
    
41.                  }
    
42. 
    
43.                 if ((pStorageServer = tracker_connect_server(&storageServer, &result)) == NULL)
    
44.                  {
    
45.                         response->set_error(-1);
    
46.                          tracker_disconnect_server_ex(pTrackerServer, true);
    
47.                         return;
    
48.                 }
    
49. 
    
50.                 file_ext_name = fdfs_get_file_ext_name(request->uuid().c_str());
    
51.                 memset(&meta_list, 0, sizeof(meta_list));
    
52.                 meta_count = 0;
    
53. 
    
54.                 if (file_ext_name)
    
55.                 {
    
56.                         strcpy(meta_list[meta_count].name, "ext_name");
    
57.                         strcpy(meta_list[meta_count].value, file_ext_name);
    
58.                         meta_count++;
    
59.                 }
    
60. 
    
61.                 result = storage_upload_appender_by_filebuff1(
    
62.                                 pTrackerServer, pStorageServer,
    
63.                                 store_path_index, request->data().c_str(),
    
64.                                 request->data_size(), file_ext_name,
    
65.                                 meta_list, meta_count,
    
66.                                 group_name, file_id);
    
67.                 if (result != 0)
    
68.                 {
    
69.                         tracker_disconnect_server_ex(pStorageServer, true);
    
70.                         tracker_disconnect_server_ex(pTrackerServer, true);
    
71.                         response->set_error(-1);
    
72.                         return;
    
73.                 }
    
74.                 response->set_error(0);
    
75.                 response->set_uuid(remote_filename);
    
76.         }
    
77.         // 其他分块
    
78.         else
    
79.         {
    
80.                 // 根据第一个分块返回的file_id，得到组命和文件名
    
81.                 sscanf(request->uuid().c_str(), "%[^/]/%s", group_name, remote_filename);
    
82. 
    
83.                 // 根据组命和文件名查询原来的storage
    
84.                  result = tracker_query_storage_update(pTrackerServer, &storageServer, group_name, remote_filename);
    
85.                  if (result != 0)
    
86.                  {
    
87.                         response->set_error(-1);
    
88.                         tracker_disconnect_server_ex(pTrackerServer, true);
    
89.                         return;
    
90.                 }
    
91.                 // 连接storage
    
92.                  if ((pStorageServer = tracker_connect_server(&storageServer, &result)) == NULL)
    
93.                 {
    
94.                         response->set_error(-1);
    
95.                         tracker_disconnect_server_ex(pTrackerServer, true);
    
96.                         return;
    
97.                 }
    
98.                 // ------------------------------------------ 问题在此 -------------------------------------
    
99.                 // <<<<<<<  通过“storage_modify_by_filebuff1”继续上传其他分块，就是这里返回错误22 >>>>>>>>
    
100.                 // ---------------------------------------------------------------------------------------
     
101.                 result = storage_modify_by_filebuff1(pTrackerServer, pStorageServer, request->data().c_str(),
     
102.                                 request->offset(), request->data().size(), request->uuid().c_str());
     
103.                 if (result != 0)
     
104.                 {
     
105.                         response->set_error(-1);
     
106.                         tracker_disconnect_server_ex(pStorageServer, true);
     
107.                         tracker_disconnect_server_ex(pTrackerServer, true);
     
108.                         return;
     
109.                 }
     
110. 
     
111.                 response->set_error(0);
     
112.         }
     
113. 
     
114.         tracker_disconnect_server_ex(pStorageServer, true);
     
115.         tracker_disconnect_server_ex(pTrackerServer, true);
     
116. }

复制代码