Cross Reference: /forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/ReplServerStartMsg.java

Lines Matching refs:in
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
116     headerLength = decodeHeader(allowedPduTypes, in);
119     // decode the body according to the protocol version read in the header
123         decodeBody_V1(in, headerLength);
129       /* The ReplServerStartMsg payload is stored in the form :
140       int length = getNextLength(in, pos);
141       baseDn = new String(in, pos, length, "UTF-8");
147       length = getNextLength(in, pos);
148       String serverIdString = new String(in, pos, length, "UTF-8");
155       length = getNextLength(in, pos);
156       serverURL = new String(in, pos, length, "UTF-8");
162       length = getNextLength(in, pos);
163       windowSize = Integer.valueOf(new String(in, pos, length, "UTF-8"));
169       length = getNextLength(in, pos);
170       sslEncryption = Boolean.valueOf(new String(in, pos, length, "UTF-8"));
176       length = getNextLength(in, pos);
178         Integer.valueOf(new String(in, pos, length, "UTF-8"));
188       serverState = new ServerState(in, pos, in.length - 1);
196    * Decodes the body of a just received ReplServerStartMsg. The body is in the
198    * encoded in V1 protocol version.
199    * @param in A byte array containing the body for the ReplServerStartMsg
200    * @param pos The position in the array where the decoding should start
201    * @throws DataFormatException If the in does not contain a properly
204   public void decodeBody_V1(byte[] in, int pos) throws DataFormatException
208       /* The ReplServerStartMsg payload is stored in the form :
216       int length = getNextLength(in, pos);
217       baseDn = new String(in, pos, length, "UTF-8");
223       length = getNextLength(in, pos);
224       String serverIdString = new String(in, pos, length, "UTF-8");
231       length = getNextLength(in, pos);
232       serverURL = new String(in, pos, length, "UTF-8");
238       length = getNextLength(in, pos);
239       windowSize = Integer.valueOf(new String(in, pos, length, "UTF-8"));
245       length = getNextLength(in, pos);
246       sslEncryption = Boolean.valueOf(new String(in, pos, length, "UTF-8"));
256       serverState = new ServerState(in, pos, in.length - 1);
307     // If an older version requested, encode in the requested way
314     /* The ReplServerStartMsg is stored in the form :
335     /* encode the header in a byte[] large enough */
436      * The ReplServerStartMessage is stored in the form :
453       /* encode the header in a byte[] large enough */