Searched defs:in (Results 1 - 25 of 410) 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 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 DChangeTimeHeartbeatMsg.java6 * (the "License"). You may not use this file except in compliance
15 * When distributing Covered Code, include this CDDL HEADER in each
56 * value in a change number.
83 * @param in
90 public ChangeTimeHeartbeatMsg(byte[] in, short version) argument
93 final ByteSequenceReader reader = ByteString.wrap(in).asReader();
H A DDoneMsg.java6 * (the "License"). You may not use this file except in compliance
15 * When distributing Covered Code, include this CDDL HEADER in each
36 * last entry sent in the context of a total update and signals to the server
54 * @param in A byte array containing the encoded information for the message,
55 * @throws DataFormatException If the in does not contain a properly,
58 public DoneMsg(byte[] in) throws DataFormatException argument
64 if (in[0] != MSG_TYPE_DONE)
69 int length = getNextLength(in, pos);
70 String senderString = new String(in, pos, length, "UTF-8");
75 length = getNextLength(in, po
[all...]
H A DInitializeRcvAckMsg.java6 * (the "License"). You may not use this file except in compliance
15 * When distributing Covered Code, include this CDDL HEADER in each
65 * @param in The byte array containing the encoded form of the message.
69 public InitializeRcvAckMsg(byte[] in) throws DataFormatException argument
75 if (in[0] != MSG_TYPE_INITIALIZE_RCV_ACK)
81 int length = getNextLength(in, pos);
82 String senderString = new String(in, pos, length, "UTF-8");
87 length = getNextLength(in, pos);
88 String serverIdString = new String(in, pos, length, "UTF-8");
93 length = getNextLength(in, po
[all...]
H A DMonitorRequestMsg.java6 * (the "License"). You may not use this file except in compliance
15 * When distributing Covered Code, include this CDDL HEADER in each
55 * @param in A byte array containing the encoded information for the message,
56 * @throws DataFormatException If the in does not contain a properly,
59 public MonitorRequestMsg(byte[] in) throws DataFormatException argument
65 if (in[0] != MSG_TYPE_REPL_SERVER_MONITOR_REQUEST)
71 int length = getNextLength(in, pos);
72 String senderString = new String(in, pos, length, "UTF-8");
77 length = getNextLength(in, pos);
78 String destinationString = new String(in, po
[all...]
H A DResetGenerationIdMsg.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 ResetGenerationIdMsg(byte[] in) throws DataFormatException argument
65 if (in[0] != MSG_TYPE_RESET_GENERATION_ID)
72 int length = getNextLength(in, pos);
73 generationId = Long.valueOf(new String(in, pos, length,
110 * Returns the generation Id set in this message.
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 DWindowMsg.java6 * (the "License"). You may not use this file except in compliance
15 * When distributing Covered Code, include this CDDL HEADER in each
62 * @param in The byte array containing the encoded form of the
67 public WindowMsg(byte[] in) throws DataFormatException argument
69 /* The WindowMsg is encoded in the form :
75 if (in[0] != MSG_TYPE_WINDOW)
80 * read the number of acks contained in this message.
83 int length = getNextLength(in, pos);
84 String numAckStr = new String(in, pos, length, "UTF-8");
/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 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-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 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)

Completed in 428 milliseconds

1234567891011>>