Searched refs:in (Results 26 - 50 of 1145) sorted by relevance

1234567891011>>

/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/
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...]
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 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");
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 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 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 DServerStartMsg.java6 * (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 DConsoleUser.java3 * 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 DConsoleUser.java3 * 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 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 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");
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 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 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 DServerStartMsg.java6 * (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 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 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");
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 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 DMonitorRequestMsg.java6 * (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 DServerStartMsg.java6 * (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 DIPSServerSocket.java8 * (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 DIPSServerSocket.java8 * (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 Drun.sh6 for i in ${LIB_DIR}/*.jar
/forgerock/openam/openam-federation/OpenFM/src/main/samples/EmbeddedOpenSSO/www/
H A Drun.sh6 for i in ${LIB_DIR}/*.jar

Completed in 154 milliseconds

1234567891011>>