Searched refs:in (Results 1 - 25 of 1145) sorted by relevance

1234567891011>>

/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/
H A DHeartbeatMsg.java6 * (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 DStopMsg.java6 * (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 DTopologyMsg.java6 * (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 DWindowProbeMsg.java6 * (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 DReplServerStartMsg.java6 * (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 DHeartbeatMsg.java6 * (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 DStopMsg.java6 * (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 DWindowProbeMsg.java6 * (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 DHeartbeatMsg.java6 * (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 DStopMsg.java6 * (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 DTopologyMsg.java6 * (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 DWindowProbeMsg.java6 * (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 DReplServerStartMsg.java6 * (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 DHeartbeatMsg.java6 * (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 DStopMsg.java6 * (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 DTopologyMsg.java6 * (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 DWindowProbeMsg.java6 * (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 DHeartbeatMsg.java6 * (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 DStopMsg.java6 * (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 DWindowProbeMsg.java6 * (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 DHeartbeatMsg.java6 * (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 DStopMsg.java6 * (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 DWindowProbeMsg.java6 * (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 DFileHelper.java8 * (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 DFileHelper.java8 * (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();

Completed in 161 milliseconds

1234567891011>>