/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/ |
H A D | HeartbeatMsg.java | 6 * (the "License"). You may not use this file except in compliance 15 * When distributing Covered Code, include this CDDL HEADER in each 52 * @param in The byte array containing the encoded form of the message. 56 public HeartbeatMsg(byte[] in) throws DataFormatException argument 58 /* The heartbeat message is encoded in the form : 63 if (in.length != 1 || in[0] != MSG_TYPE_HEARTBEAT)
|
H A D | StopMsg.java | 6 * (the "License"). You may not use this file except in compliance 15 * When distributing Covered Code, include this CDDL HEADER in each 48 * @param in A byte array containing the encoded information for the message, 49 * @throws DataFormatException If the in does not contain a properly, 52 public StopMsg(byte[] in) throws DataFormatException argument 55 if (in[0] != MSG_TYPE_STOP) 57 in[0]);
|
H A D | TopologyMsg.java | 6 * (the "License"). You may not use this file except in compliance 15 * When distributing Covered Code, include this CDDL HEADER in each 44 * - By a RS to the other RSs in the topology, containing: 45 * - the list of DSs directly connected to the RS in the DS list 46 * - only this RS in the RS list 49 * - the list of every DS the RS knows except the destinator DS in the DS list 50 * - the list of every connected RSs (including the sending RS) in the RS list 60 // Information for the DS known in the topology 62 // Information for the RS known in the topology 68 * @param in Th 73 TopologyMsg(byte[] in, short version) argument [all...] |
H A D | WindowProbeMsg.java | 6 * (the "License"). You may not use this file except in compliance 15 * When distributing Covered Code, include this CDDL HEADER in each 56 * @param in The byte array containing the encoded form of the 61 public WindowProbeMsg(byte[] in) throws DataFormatException argument 64 if (in[0] != MSG_TYPE_WINDOW_PROBE)
|
H A D | ReplServerStartMsg.java | 6 * (the "License"). You may not use this file except in compliance 15 * When distributing Covered Code, include this CDDL HEADER in each 58 * protocol, we prefer to let this variable also in this PDU but the one 59 * really used is in the ReplServerStartDSMsg PDU. This prevents from having 62 * Threshold value used by the RS to determine if a DS must be put in 106 * @param in A byte array containing the encoded information for the 108 * @throws DataFormatException If the in does not contain a properly 111 public ReplServerStartMsg(byte[] in) throws DataFormatException argument 116 headerLength = decodeHeader(allowedPduTypes, in); 119 // decode the body according to the protocol version read in th 204 decodeBody_V1(byte[] in, int pos) argument [all...] |
/forgerock/opendj2/src/server/org/opends/server/replication/protocol/ |
H A D | HeartbeatMsg.java | 6 * (the "License"). You may not use this file except in compliance 14 * When distributing Covered Code, include this CDDL HEADER in each 50 * @param in The byte array containing the encoded form of the message. 54 HeartbeatMsg(byte[] in) throws DataFormatException argument 56 /* The heartbeat message is encoded in the form : 59 if (in.length != 1 || in[0] != MSG_TYPE_HEARTBEAT)
|
H A D | StopMsg.java | 6 * (the "License"). You may not use this file except in compliance 14 * When distributing Covered Code, include this CDDL HEADER in each 47 * @param in A byte array containing the encoded information for the message, 48 * @throws DataFormatException If the in does not contain a properly, 51 public StopMsg(byte[] in) throws DataFormatException argument 54 if (in[0] != MSG_TYPE_STOP) 56 in[0]);
|
H A D | WindowProbeMsg.java | 6 * (the "License"). You may not use this file except in compliance 14 * When distributing Covered Code, include this CDDL HEADER in each 54 * @param in The byte array containing the encoded form of the 59 public WindowProbeMsg(byte[] in) throws DataFormatException argument 62 if (in[0] != MSG_TYPE_WINDOW_PROBE)
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/ |
H A D | HeartbeatMsg.java | 6 * (the "License"). You may not use this file except in compliance 15 * When distributing Covered Code, include this CDDL HEADER in each 52 * @param in The byte array containing the encoded form of the message. 56 public HeartbeatMsg(byte[] in) throws DataFormatException argument 58 /* The heartbeat message is encoded in the form : 63 if (in.length != 1 || in[0] != MSG_TYPE_HEARTBEAT)
|
H A D | StopMsg.java | 6 * (the "License"). You may not use this file except in compliance 15 * When distributing Covered Code, include this CDDL HEADER in each 48 * @param in A byte array containing the encoded information for the message, 49 * @throws DataFormatException If the in does not contain a properly, 52 public StopMsg(byte[] in) throws DataFormatException argument 55 if (in[0] != MSG_TYPE_STOP) 57 in[0]);
|
H A D | TopologyMsg.java | 6 * (the "License"). You may not use this file except in compliance 15 * When distributing Covered Code, include this CDDL HEADER in each 44 * - By a RS to the other RSs in the topology, containing: 45 * - the list of DSs directly connected to the RS in the DS list 46 * - only this RS in the RS list 49 * - the list of every DS the RS knows except the destinator DS in the DS list 50 * - the list of every connected RSs (including the sending RS) in the RS list 60 // Information for the DS known in the topology 62 // Information for the RS known in the topology 68 * @param in Th 73 TopologyMsg(byte[] in, short version) argument [all...] |
H A D | WindowProbeMsg.java | 6 * (the "License"). You may not use this file except in compliance 15 * When distributing Covered Code, include this CDDL HEADER in each 56 * @param in The byte array containing the encoded form of the 61 public WindowProbeMsg(byte[] in) throws DataFormatException argument 64 if (in[0] != MSG_TYPE_WINDOW_PROBE)
|
H A D | ReplServerStartMsg.java | 6 * (the "License"). You may not use this file except in compliance 15 * When distributing Covered Code, include this CDDL HEADER in each 58 * protocol, we prefer to let this variable also in this PDU but the one 59 * really used is in the ReplServerStartDSMsg PDU. This prevents from having 62 * Threshold value used by the RS to determine if a DS must be put in 106 * @param in A byte array containing the encoded information for the 108 * @throws DataFormatException If the in does not contain a properly 111 public ReplServerStartMsg(byte[] in) throws DataFormatException argument 116 headerLength = decodeHeader(allowedPduTypes, in); 119 // decode the body according to the protocol version read in th 204 decodeBody_V1(byte[] in, int pos) argument [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/ |
H A D | HeartbeatMsg.java | 6 * (the "License"). You may not use this file except in compliance 15 * When distributing Covered Code, include this CDDL HEADER in each 52 * @param in The byte array containing the encoded form of the message. 56 public HeartbeatMsg(byte[] in) throws DataFormatException argument 58 /* The heartbeat message is encoded in the form : 63 if (in.length != 1 || in[0] != MSG_TYPE_HEARTBEAT)
|
H A D | StopMsg.java | 6 * (the "License"). You may not use this file except in compliance 15 * When distributing Covered Code, include this CDDL HEADER in each 48 * @param in A byte array containing the encoded information for the message, 49 * @throws DataFormatException If the in does not contain a properly, 52 public StopMsg(byte[] in) throws DataFormatException argument 55 if (in[0] != MSG_TYPE_STOP) 57 in[0]);
|
H A D | TopologyMsg.java | 6 * (the "License"). You may not use this file except in compliance 15 * When distributing Covered Code, include this CDDL HEADER in each 44 * - By a RS to the other RSs in the topology, containing: 45 * - the list of DSs directly connected to the RS in the DS list 46 * - only this RS in the RS list 49 * - the list of every DS the RS knows except the destinator DS in the DS list 50 * - the list of every connected RSs (including the sending RS) in the RS list 60 // Information for the DS known in the topology 62 // Information for the RS known in the topology 68 * @param in Th 73 TopologyMsg(byte[] in, short version) argument [all...] |
H A D | WindowProbeMsg.java | 6 * (the "License"). You may not use this file except in compliance 15 * When distributing Covered Code, include this CDDL HEADER in each 56 * @param in The byte array containing the encoded form of the 61 public WindowProbeMsg(byte[] in) throws DataFormatException argument 64 if (in[0] != MSG_TYPE_WINDOW_PROBE)
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/ |
H A D | HeartbeatMsg.java | 6 * (the "License"). You may not use this file except in compliance 14 * When distributing Covered Code, include this CDDL HEADER in each 50 * @param in The byte array containing the encoded form of the message. 54 HeartbeatMsg(byte[] in) throws DataFormatException argument 56 /* The heartbeat message is encoded in the form : 59 if (in.length != 1 || in[0] != MSG_TYPE_HEARTBEAT)
|
H A D | StopMsg.java | 6 * (the "License"). You may not use this file except in compliance 14 * When distributing Covered Code, include this CDDL HEADER in each 47 * @param in A byte array containing the encoded information for the message, 48 * @throws DataFormatException If the in does not contain a properly, 51 public StopMsg(byte[] in) throws DataFormatException argument 54 if (in[0] != MSG_TYPE_STOP) 56 in[0]);
|
H A D | WindowProbeMsg.java | 6 * (the "License"). You may not use this file except in compliance 14 * When distributing Covered Code, include this CDDL HEADER in each 54 * @param in The byte array containing the encoded form of the 59 public WindowProbeMsg(byte[] in) throws DataFormatException argument 62 if (in[0] != MSG_TYPE_WINDOW_PROBE)
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/ |
H A D | HeartbeatMsg.java | 6 * (the "License"). You may not use this file except in compliance 14 * When distributing Covered Code, include this CDDL HEADER in each 50 * @param in The byte array containing the encoded form of the message. 54 HeartbeatMsg(byte[] in) throws DataFormatException argument 56 /* The heartbeat message is encoded in the form : 59 if (in.length != 1 || in[0] != MSG_TYPE_HEARTBEAT)
|
H A D | StopMsg.java | 6 * (the "License"). You may not use this file except in compliance 14 * When distributing Covered Code, include this CDDL HEADER in each 47 * @param in A byte array containing the encoded information for the message, 48 * @throws DataFormatException If the in does not contain a properly, 51 public StopMsg(byte[] in) throws DataFormatException argument 54 if (in[0] != MSG_TYPE_STOP) 56 throw new DataFormatException("input is not a valid Stop message: " + in[0]);
|
H A D | WindowProbeMsg.java | 6 * (the "License"). You may not use this file except in compliance 14 * When distributing Covered Code, include this CDDL HEADER in each 54 * @param in The byte array containing the encoded form of the 59 public WindowProbeMsg(byte[] in) throws DataFormatException argument 62 if (in[0] != MSG_TYPE_WINDOW_PROBE)
|
/forgerock/openam-v13/openam-test/src/test/java/com/sun/identity/test/common/ |
H A D | FileHelper.java | 8 * (the License). You may not use this file except in 18 * Header Notice in each file and include the License file 58 InputStream in = null; 61 in = new FileInputStream(fileName); 63 in.read(content); 65 if (in != null) { 66 in.close();
|
/forgerock/openam/openam-test/src/test/java/com/sun/identity/test/common/ |
H A D | FileHelper.java | 8 * (the License). You may not use this file except in 18 * Header Notice in each file and include the License file 58 InputStream in = null; 61 in = new FileInputStream(fileName); 63 in.read(content); 65 if (in != null) { 66 in.close();
|