| | |
| | | oStream.write(attr.getBytes("UTF-8")); |
| | | oStream.write(0); |
| | | } |
| | | oStream.write(dsInfo.getProtocolVersion()); |
| | | } |
| | | |
| | | } |
| | | |
| | | // Put number of following RS info entries |
| | |
| | | } |
| | | |
| | | Set<String> attrs = new HashSet<String>(); |
| | | short protocolVersion = -1; |
| | | if (version>=ProtocolVersion.REPLICATION_PROTOCOL_V4) |
| | | { |
| | | byte nAttrs = in[pos++]; |
| | |
| | | pos += length + 1; |
| | | nRead++; |
| | | } |
| | | /* Read Protocol version */ |
| | | protocolVersion = Short.valueOf(in[pos++]); |
| | | } |
| | | |
| | | /* Now create DSInfo and store it in list */ |
| | | |
| | | DSInfo dsInfo = new DSInfo(dsId, rsId, generationId, status, |
| | | assuredFlag, assuredMode, safeDataLevel, groupId, refUrls, attrs); |
| | | assuredFlag, assuredMode, safeDataLevel, groupId, refUrls, attrs, |
| | | protocolVersion); |
| | | dsList.add(dsInfo); |
| | | |
| | | nDsInfo--; |