/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/ |
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...] |
H A D | ResetGenerationIdMsg.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 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 D | WindowMsg.java | 6 * (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");
|
H A D | InitializeRcvAckMsg.java | 6 * (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 D | DoneMsg.java | 6 * (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 D | MonitorRequestMsg.java | 6 * (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 D | ServerStartMsg.java | 6 * (the "License"). You may not use this file except in compliance 15 * When distributing Covered Code, include this CDDL HEADER in each 53 * The time in milliseconds between heartbeats from the replication 105 * @param in The byte array containing the encoded form of the 110 public ServerStartMsg(byte[] in) throws DataFormatException argument 114 headerLength = decodeHeader(allowedPduTypes, in); 125 int length = getNextLength(in, pos); 126 baseDn = new String(in, pos, length, "UTF-8"); 132 length = getNextLength(in, pos); 133 String serverIdString = new String(in, po [all...] |
/forgerock/openam-v13/openam-tools/openam-license-manager-cli/src/main/java/org/forgerock/openam/license/ |
H A D | ConsoleUser.java | 3 * Distribution License (the License). You may not use this file except in compliance with the 9 * When distributing Covered Software, include this CDDL Header Notice in each file and include 36 private final BufferedReader in; field in class:ConsoleUser 44 * @param in the input stream to read responses from. 47 public ConsoleUser(Writer out, Reader in, ResourceBundle messages) { argument 51 if (in == null) { 58 this.in = new BufferedReader(in); 67 this(new PrintWriter(System.out), new InputStreamReader(System.in), 108 response = in [all...] |
/forgerock/openam/openam-tools/openam-license-manager-cli/src/main/java/org/forgerock/openam/license/ |
H A D | ConsoleUser.java | 3 * Distribution License (the License). You may not use this file except in compliance with the 9 * When distributing Covered Software, include this CDDL Header Notice in each file and include 36 private final BufferedReader in; field in class:ConsoleUser 44 * @param in the input stream to read responses from. 47 public ConsoleUser(Writer out, Reader in, ResourceBundle messages) { argument 51 if (in == null) { 58 this.in = new BufferedReader(in); 67 this(new PrintWriter(System.out), new InputStreamReader(System.in), 108 response = in [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/ |
H A D | ResetGenerationIdMsg.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 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 D | WindowMsg.java | 6 * (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");
|
H A D | InitializeRcvAckMsg.java | 6 * (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 D | DoneMsg.java | 6 * (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 D | MonitorRequestMsg.java | 6 * (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 D | ServerStartMsg.java | 6 * (the "License"). You may not use this file except in compliance 15 * When distributing Covered Code, include this CDDL HEADER in each 53 * The time in milliseconds between heartbeats from the replication 105 * @param in The byte array containing the encoded form of the 110 public ServerStartMsg(byte[] in) throws DataFormatException argument 114 headerLength = decodeHeader(allowedPduTypes, in); 125 int length = getNextLength(in, pos); 126 baseDn = new String(in, pos, length, "UTF-8"); 132 length = getNextLength(in, pos); 133 String serverIdString = new String(in, po [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/ |
H A D | ResetGenerationIdMsg.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 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 D | WindowMsg.java | 6 * (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");
|
H A D | InitializeRcvAckMsg.java | 6 * (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 D | DoneMsg.java | 6 * (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 D | MonitorRequestMsg.java | 6 * (the "License"). You may not use this file except in compliance 15 * When distributing Covered Code, include this CDDL HEADER in each 69 * @param in 72 * If the in does not contain a properly, encoded message. 74 public MonitorRequestMsg(byte[] in) throws DataFormatException argument 79 if (in[0] != MSG_TYPE_REPL_SERVER_MONITOR_REQUEST) 85 int length = getNextLength(in, pos); 86 String senderString = new String(in, pos, length, "UTF-8"); 91 length = getNextLength(in, pos); 92 String destinationString = new String(in, po [all...] |
H A D | ServerStartMsg.java | 6 * (the "License"). You may not use this file except in compliance 15 * When distributing Covered Code, include this CDDL HEADER in each 53 * The time in milliseconds between heartbeats from the replication 105 * @param in The byte array containing the encoded form of the 110 public ServerStartMsg(byte[] in) throws DataFormatException argument 114 headerLength = decodeHeader(allowedPduTypes, in); 125 int length = getNextLength(in, pos); 126 baseDn = new String(in, pos, length, "UTF-8"); 132 length = getNextLength(in, pos); 133 String serverIdString = new String(in, po [all...] |
/forgerock/openam-v13/openam-core/src/main/java/com/iplanet/am/util/ |
H A D | IPSServerSocket.java | 8 * (the License). You may not use this file except in 18 * Header Notice in each file and include the License file 57 private BufferedInputStream in; field in class:IPSServerSocket.IPSSocket 64 if (in == null) { 65 in = new BufferedInputStream(super.getInputStream()); 67 return in;
|
/forgerock/openam/openam-core/src/main/java/com/iplanet/am/util/ |
H A D | IPSServerSocket.java | 8 * (the License). You may not use this file except in 18 * Header Notice in each file and include the License file 57 private BufferedInputStream in; field in class:IPSServerSocket.IPSSocket 64 if (in == null) { 65 in = new BufferedInputStream(super.getInputStream()); 67 return in;
|
/forgerock/openam-v13/openam-federation/OpenFM/src/main/samples/EmbeddedOpenSSO/www/ |
H A D | run.sh | 6 for i in ${LIB_DIR}/*.jar
|
/forgerock/openam/openam-federation/OpenFM/src/main/samples/EmbeddedOpenSSO/www/ |
H A D | run.sh | 6 for i in ${LIB_DIR}/*.jar
|