blob: bafe56697459d3458f051c4bb8bb9aa833eee765 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
|
package org.openslx.util;
import java.io.BufferedReader;
import java.io.IOException;
import java.nio.ByteBuffer;
import java.util.ArrayList;
import java.util.List;
import org.openslx.util.vm.VmwareConfig;
public class ThriftUtil {
public static List<byte[]> unwrapByteBufferList(List<ByteBuffer> blockHashes) {
if (blockHashes == null || blockHashes.isEmpty())
return null;
List<byte[]> hashList = new ArrayList<>(blockHashes.size());
for (ByteBuffer hash : blockHashes) {
byte[] buffer = new byte[hash.remaining()];
hash.mark();
hash.get(buffer);
hash.reset();
hashList.add(buffer);
}
return hashList;
}
public static byte[] unwrapByteBuffer(ByteBuffer buffer) {
byte[] byteArray = null;
if (buffer != null) {
byteArray = new byte[buffer.remaining()];
buffer.mark();
buffer.get(byteArray);
buffer.reset();
}
return byteArray;
}
public static String byteBufferToString(ByteBuffer buffer) {
byte[] bytes = unwrapByteBuffer(buffer);
BufferedReader reader;
StringBuffer content = new StringBuffer("");
try {
reader = VmwareConfig.getVmxReader(bytes, bytes.length);
String line="";
while ((line=reader.readLine()) != null) {
content.append(line + "\n");
}
reader.close();
} catch (IOException e) {
// swallow - shouldn't happen.
return null;
}
return content.toString();
}
}
|
