| | |
| | | // - to update the task with the server(s) where this test failed |
| | | |
| | | if (serverToInitialize == RoutableMsg.ALL_SERVERS) |
| | | { |
| | | for (DSInfo dsi : getReplicasList()) |
| | | ieContext.startList.add(dsi.getDsId()); |
| | | else |
| | | ieContext.startList.add(serverToInitialize); |
| | | |
| | | // We manage the list of servers with which a flow control can be enabled |
| | | for (DSInfo dsi : getReplicasList()) |
| | |
| | | if (dsi.getProtocolVersion()>= ProtocolVersion.REPLICATION_PROTOCOL_V4) |
| | | ieContext.setAckVal(dsi.getDsId(), 0); |
| | | } |
| | | } |
| | | else |
| | | { |
| | | ieContext.startList.add(serverToInitialize); |
| | | |
| | | // We manage the list of servers with which a flow control can be enabled |
| | | for (DSInfo dsi : getReplicasList()) |
| | | { |
| | | if (dsi.getDsId() == serverToInitialize) |
| | | if (dsi.getProtocolVersion()>= ProtocolVersion.REPLICATION_PROTOCOL_V4) |
| | | ieContext.setAckVal(dsi.getDsId(), 0); |
| | | } |
| | | } |
| | | |
| | | // loop for the case where the exporter is the initiator |
| | | int attempt = 0; |