| /forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/ |
| H A D | InitializeRcvAckMsg.java | 52 * @param destination The destination server or servers of this message. 56 public InitializeRcvAckMsg(int sender, int destination, int numAck) argument 58 super(sender, destination); 86 // destination 89 destination = Integer.valueOf(serverIdString); 111 byte[] byteDestination = String.valueOf(destination).getBytes("UTF-8"); 127 // destination 148 " destination=" + this.destination [all...] |
| H A D | MonitorRequestMsg.java | 46 * @param destination The server or servers targeted by this message. 48 public MonitorRequestMsg(int serverID, int destination) argument 50 super(serverID, destination); 76 // destination 79 this.destination = Integer.valueOf(destinationString); 97 byte[] destinationBytes = String.valueOf(destination).getBytes("UTF-8"); 111 /* put the destination */
|
| H A D | RoutableMsg.java | 32 * send them and the destination servers to which they should be sent. 57 * The destination server or servers of this message. 59 protected int destination = UNKNOWN_SERVER; field in class:RoutableMsg 68 * @param destination replication server id 70 public RoutableMsg(int serverID, int destination) argument 73 this.destination = destination; 84 * Get the destination. The value is a serverId, or ALL_SERVERS dedicated 86 * @return the destination 90 return this.destination; [all...] |
| H A D | InitializeRequestMsg.java | 51 * @param destination destination of this message 55 public InitializeRequestMsg(String baseDn, int serverID, int destination, argument 58 super(serverID, destination); 93 // destination 96 destination = Integer.valueOf(destinationServerIdString); 144 byte[] destinationBytes = String.valueOf(destination).getBytes("UTF-8"); 168 // destination 192 " destination=" + destination [all...] |
| /forgerock/opendj2/src/server/org/opends/server/replication/protocol/ |
| H A D | InitializeRcvAckMsg.java | 48 * @param destination The destination server or servers of this message. 52 public InitializeRcvAckMsg(int sender, int destination, int numAck) argument 54 super(sender, destination); 75 destination = scanner.nextIntUTF8(); 86 builder.appendIntUTF8(destination); 97 " destination=" + this.destination +
|
| H A D | MonitorRequestMsg.java | 39 * The destination server or servers of this message. 41 private final int destination; field in class:MonitorRequestMsg 53 * @param destination 56 public MonitorRequestMsg(int serverID, int destination) argument 59 this.destination = destination; 80 this.destination = scanner.nextIntUTF8(); 90 builder.appendIntUTF8(destination); 95 * Get the destination. 97 * @return the destination [all...] |
| H A D | RoutableMsg.java | 32 * destination servers to which they should be sent. 62 * The destination server or servers of this message. 64 protected int destination = UNKNOWN_SERVER; field in class:RoutableMsg 73 * @param destination replication server id 75 public RoutableMsg(int serverID, int destination) argument 78 this.destination = destination; 89 * Get the destination. The value is a serverId, or ALL_SERVERS dedicated 91 * @return the destination 95 return this.destination; [all...] |
| H A D | EntryMsg.java | 47 * @param destination The destination of this message. 51 public EntryMsg(int serverID, int destination, byte[] entryBytes, int msgId) argument 53 this(serverID, destination, entryBytes, 0, entryBytes.length, msgId); 60 * @param destination The destination of this message. 66 public EntryMsg(int serverID, int destination, byte[] entryBytes, int startPos, argument 69 super(serverID, destination); 93 this.destination = scanner.nextIntUTF8(); 117 builder.appendIntUTF8(destination); [all...] |
| H A D | InitializeRequestMsg.java | 48 * @param destination destination of this message 52 public InitializeRequestMsg(DN baseDN, int serverID, int destination, argument 55 super(serverID, destination); 78 destination = scanner.nextIntUTF8(); 108 builder.appendIntUTF8(destination); 124 + senderID + " destination=" + destination + " initWindow=" + initWindow;
|
| H A D | InitializeTargetMsg.java | 59 * @param destination The destination of this message. 65 int destination, int requestorID, long entryCount, int initWindow) 67 super(serverID, destination); 90 destination = scanner.nextIntUTF8(); 153 builder.appendIntUTF8(destination); 64 InitializeTargetMsg(DN baseDN, int serverID, int destination, int requestorID, long entryCount, int initWindow) argument
|
| /forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/ |
| H A D | InitializeRcvAckMsg.java | 52 * @param destination The destination server or servers of this message. 56 public InitializeRcvAckMsg(int sender, int destination, int numAck) argument 58 super(sender, destination); 86 // destination 89 destination = Integer.valueOf(serverIdString); 111 byte[] byteDestination = String.valueOf(destination).getBytes("UTF-8"); 127 // destination 148 " destination=" + this.destination [all...] |
| H A D | MonitorRequestMsg.java | 41 * The destination server or servers of this message. 43 private final int destination; field in class:MonitorRequestMsg 57 * @param destination 60 public MonitorRequestMsg(int serverID, int destination) argument 63 this.destination = destination; 90 // destination 93 this.destination = Integer.valueOf(destinationString); 112 byte[] destinationBytes = String.valueOf(destination).getBytes("UTF-8"); 125 /* put the destination */ [all...] |
| H A D | RoutableMsg.java | 33 * destination servers to which they should be sent. 63 * The destination server or servers of this message. 65 protected int destination = UNKNOWN_SERVER; field in class:RoutableMsg 74 * @param destination replication server id 76 public RoutableMsg(int serverID, int destination) argument 79 this.destination = destination; 90 * Get the destination. The value is a serverId, or ALL_SERVERS dedicated 92 * @return the destination 96 return this.destination; [all...] |
| H A D | InitializeRequestMsg.java | 51 * @param destination destination of this message 55 public InitializeRequestMsg(String baseDn, int serverID, int destination, argument 58 super(serverID, destination); 93 // destination 96 destination = Integer.valueOf(destinationServerIdString); 144 byte[] destinationBytes = String.valueOf(destination).getBytes("UTF-8"); 168 // destination 192 " destination=" + destination [all...] |
| /forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/ |
| H A D | InitializeRcvAckMsg.java | 52 * @param destination The destination server or servers of this message. 56 public InitializeRcvAckMsg(int sender, int destination, int numAck) argument 58 super(sender, destination); 86 // destination 89 destination = Integer.valueOf(serverIdString); 111 byte[] byteDestination = String.valueOf(destination).getBytes("UTF-8"); 127 // destination 148 " destination=" + this.destination [all...] |
| H A D | MonitorRequestMsg.java | 46 * @param destination The server or servers targeted by this message. 48 public MonitorRequestMsg(int serverID, int destination) argument 50 super(serverID, destination); 76 // destination 79 this.destination = Integer.valueOf(destinationString); 97 byte[] destinationBytes = String.valueOf(destination).getBytes("UTF-8"); 111 /* put the destination */
|
| H A D | RoutableMsg.java | 32 * send them and the destination servers to which they should be sent. 57 * The destination server or servers of this message. 59 protected int destination = UNKNOWN_SERVER; field in class:RoutableMsg 68 * @param destination replication server id 70 public RoutableMsg(int serverID, int destination) argument 73 this.destination = destination; 84 * Get the destination. The value is a serverId, or ALL_SERVERS dedicated 86 * @return the destination 90 return this.destination; [all...] |
| H A D | InitializeRequestMsg.java | 51 * @param destination destination of this message 55 public InitializeRequestMsg(String baseDn, int serverID, int destination, argument 58 super(serverID, destination); 93 // destination 96 destination = Integer.valueOf(destinationServerIdString); 144 byte[] destinationBytes = String.valueOf(destination).getBytes("UTF-8"); 168 // destination 192 " destination=" + destination [all...] |
| /forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/ |
| H A D | InitializeRcvAckMsg.java | 48 * @param destination The destination server or servers of this message. 52 public InitializeRcvAckMsg(int sender, int destination, int numAck) argument 54 super(sender, destination); 75 destination = scanner.nextIntUTF8(); 86 builder.appendIntUTF8(destination); 97 " destination=" + this.destination +
|
| H A D | MonitorRequestMsg.java | 39 * The destination server or servers of this message. 41 private final int destination; field in class:MonitorRequestMsg 53 * @param destination 56 public MonitorRequestMsg(int serverID, int destination) argument 59 this.destination = destination; 80 this.destination = scanner.nextIntUTF8(); 90 builder.appendIntUTF8(destination); 95 * Get the destination. 97 * @return the destination [all...] |
| H A D | RoutableMsg.java | 32 * destination servers to which they should be sent. 62 * The destination server or servers of this message. 64 protected int destination = UNKNOWN_SERVER; field in class:RoutableMsg 73 * @param destination replication server id 75 public RoutableMsg(int serverID, int destination) argument 78 this.destination = destination; 89 * Get the destination. The value is a serverId, or ALL_SERVERS dedicated 91 * @return the destination 95 return this.destination; [all...] |
| /forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/ |
| H A D | InitializeRcvAckMsg.java | 48 * @param destination The destination server or servers of this message. 52 public InitializeRcvAckMsg(int sender, int destination, int numAck) argument 54 super(sender, destination); 75 destination = scanner.nextIntUTF8(); 86 builder.appendIntUTF8(destination); 97 " destination=" + this.destination +
|
| H A D | MonitorRequestMsg.java | 39 * The destination server or servers of this message. 41 private final int destination; field in class:MonitorRequestMsg 53 * @param destination 56 public MonitorRequestMsg(int serverID, int destination) argument 59 this.destination = destination; 82 this.destination = scanner.nextIntUTF8(); 92 builder.appendIntUTF8(destination); 97 * Get the destination. 99 * @return the destination [all...] |
| H A D | RoutableMsg.java | 34 * destination servers to which they should be sent. 64 * The destination server or servers of this message. 66 protected int destination = UNKNOWN_SERVER; field in class:RoutableMsg 75 * @param destination replication server id 77 public RoutableMsg(int serverID, int destination) argument 80 this.destination = destination; 91 * Get the destination. The value is a serverId, or ALL_SERVERS dedicated 93 * @return the destination 97 return this.destination; [all...] |
| /forgerock/openam/openam-core/src/main/java/org/forgerock/openam/setup/ |
| H A D | ZipUtils.java | 47 * @param destination The destination path where the zip file will be created. 50 public void zipDirectory(File directory, File destination) throws IOException { argument 55 try (ZipOutputStream outputStream = new ZipOutputStream(new FileOutputStream(destination))) {
|