mikesu / fastdfsclient Goto Github PK

private String getDownloadHostPort(String storageAddr) throws Exception{
String downloadHostPort = storageIpMap.get(storageAddr);
if(downloadHostPort==null){
updateStorageIpMap();
downloadHostPort = storageIpMap.get(storageAddr);
}
return downloadHostPort;
}

@OverRide
public Result<List> exec(Socket socket) throws IOException {
request(socket.getOutputStream());
Response response = response(socket.getInputStream());
if(response.isSuccess()){
byte[] data = response.getData();
int dataLength = data.length;
if(dataLength%StorageInfo.BYTE_SIZE!=0){
throw new IOException("recv body length: " + data.length + " is not correct");
}
List storageInfos = new ArrayList();
int offset = 0;
while(offset<dataLength){
StorageInfo storageInfo = new StorageInfo(data,offset);
storageInfos.add(storageInfo);
offset += StorageInfo.BYTE_SIZE;
}
return new Result<List>(response.getCode(), storageInfos);
}else{
return new Result<List>(response.getCode(), "Error");
}
}