Searched defs:channel (Results 1 - 25 of 68) sorted by relevance

123

/forgerock/opendj-b2.6/src/server/org/opends/server/protocols/asn1/
H A DASN1.java190 * Gets an ASN.1 byte channel reader whose source is the provided
191 * readable byte channel, uses 4KB buffer, and having an unlimited
194 * @param channel
195 * The readable byte channel to use.
196 * @return The new ASN.1 byte channel reader.
198 public static ASN1ByteChannelReader getReader(ReadableByteChannel channel) argument
200 return getReader(channel, 4096, 0);
206 * Gets an ASN.1 byte channel reader whose source is the provided
207 * readable byte channel, having a user defined buffer size, and
210 * @param channel
219 getReader(ReadableByteChannel channel, int bufferSize, int maxElementSize) argument
[all...]
/forgerock/opendj2/src/server/org/opends/server/protocols/asn1/
H A DASN1.java189 * Gets an ASN.1 byte channel reader whose source is the provided
190 * readable byte channel, uses 4KB buffer, and having an unlimited
193 * @param channel
194 * The readable byte channel to use.
195 * @return The new ASN.1 byte channel reader.
197 public static ASN1ByteChannelReader getReader(ReadableByteChannel channel) argument
199 return getReader(channel, 4096, 0);
205 * Gets an ASN.1 byte channel reader whose source is the provided
206 * readable byte channel, having a user defined buffer size, and
209 * @param channel
218 getReader(ReadableByteChannel channel, int bufferSize, int maxElementSize) argument
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/protocols/asn1/
H A DASN1.java190 * Gets an ASN.1 byte channel reader whose source is the provided
191 * readable byte channel, uses 4KB buffer, and having an unlimited
194 * @param channel
195 * The readable byte channel to use.
196 * @return The new ASN.1 byte channel reader.
198 public static ASN1ByteChannelReader getReader(ReadableByteChannel channel) argument
200 return getReader(channel, 4096, 0);
206 * Gets an ASN.1 byte channel reader whose source is the provided
207 * readable byte channel, having a user defined buffer size, and
210 * @param channel
219 getReader(ReadableByteChannel channel, int bufferSize, int maxElementSize) argument
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/protocols/asn1/
H A DASN1.java190 * Gets an ASN.1 byte channel reader whose source is the provided
191 * readable byte channel, uses 4KB buffer, and having an unlimited
194 * @param channel
195 * The readable byte channel to use.
196 * @return The new ASN.1 byte channel reader.
198 public static ASN1ByteChannelReader getReader(ReadableByteChannel channel) argument
200 return getReader(channel, 4096, 0);
206 * Gets an ASN.1 byte channel reader whose source is the provided
207 * readable byte channel, having a user defined buffer size, and
210 * @param channel
219 getReader(ReadableByteChannel channel, int bufferSize, int maxElementSize) argument
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/protocols/asn1/
H A DASN1.java189 * Gets an ASN.1 byte channel reader whose source is the provided
190 * readable byte channel, uses 4KB buffer, and having an unlimited
193 * @param channel
194 * The readable byte channel to use.
195 * @return The new ASN.1 byte channel reader.
197 public static ASN1ByteChannelReader getReader(ReadableByteChannel channel) argument
199 return getReader(channel, 4096, 0);
205 * Gets an ASN.1 byte channel reader whose source is the provided
206 * readable byte channel, having a user defined buffer size, and
209 * @param channel
218 getReader(ReadableByteChannel channel, int bufferSize, int maxElementSize) argument
[all...]
/forgerock/openam-v13/openam-radius/openam-radius-server/src/main/java/org/forgerock/openam/radius/server/
H A DRadiusRequestListener.java46 * through the backing channel. Then it closes the channel and exits.
74 * The datagram channel of this listener.
76 private DatagramChannel channel = null; field in class:RadiusRequestListener
121 // lets get our inbound channel opened and bound
123 this.channel = DatagramChannel.open();
125 this.channel.setOption(StandardSocketOptions.SO_REUSEADDR, true);
128 throw new RadiusLifecycleException("RADIUS listener unable to open datagram channel.", e);
134 this.channel.socket().bind(new InetSocketAddress(radiusPort));
181 * must wait for the pool to empty before interrupting the listener thread since that closes the channel i
[all...]
/forgerock/openam/openam-radius/openam-radius-server/src/main/java/org/forgerock/openam/radius/server/
H A DRadiusRequestListener.java48 * through the backing channel. Then it closes the channel and exits.
76 * The datagram channel of this listener.
78 private DatagramChannel channel = null; field in class:RadiusRequestListener
123 // lets get our inbound channel opened and bound
125 this.channel = DatagramChannel.open();
127 this.channel.setOption(StandardSocketOptions.SO_REUSEADDR, true);
130 throw new RadiusLifecycleException("RADIUS listener unable to open datagram channel.", e);
136 this.channel.socket().bind(new InetSocketAddress(radiusPort));
203 * must wait for the pool to empty before interrupting the listener thread since that closes the channel i
[all...]
/forgerock/opendj-b2.6/src/server/org/opends/server/types/
H A DByteSequence.java239 * @param channel
246 int copyTo(WritableByteChannel channel) throws IOException; argument
/forgerock/opendj2/src/server/org/opends/server/types/
H A DByteSequence.java238 * @param channel
245 int copyTo(WritableByteChannel channel) throws IOException; argument
/forgerock/opendj2.6.2/src/server/org/opends/server/types/
H A DByteSequence.java239 * @param channel
246 int copyTo(WritableByteChannel channel) throws IOException; argument
/forgerock/opendj2-jel-hg/src/server/org/opends/server/types/
H A DByteSequence.java239 * @param channel
246 int copyTo(WritableByteChannel channel) throws IOException; argument
/forgerock/opendj2-hg/src/server/org/opends/server/types/
H A DByteSequence.java238 * @param channel
245 int copyTo(WritableByteChannel channel) throws IOException; argument
/forgerock/opendj-b2.6/src/server/org/opends/server/extensions/
H A DSASLByteChannel.java43 * This class implements a SASL byte channel that can be used during
66 channel.close();
176 channel.write(sendWrappedBuffer);
189 // data is available on the underlying channel.
195 // The channel read may only partially fill the buffer due to
196 // buffering in the underlying channel layer (e.g. SSL layer), so
201 final int read = channel.read(recvWrappedLengthBuffer);
238 // The channel read may only partially fill the buffer due to
239 // buffering in the underlying channel layer (e.g. SSL layer), so
244 final int read = channel
291 private final ByteChannel channel; field in class:SASLByteChannel
[all...]
H A DTLSByteChannel.java56 * A class that provides a TLS byte channel implementation.
110 channel.close();
262 // Synchronize SSL unwrap with channel reads.
266 // data is available on the underlying channel.
313 // Read wrapped data from underlying channel.
315 final int read = channel.read(recvWrappedBuffer);
320 // channel closed.
352 // Synchronize SSL wrap with channel writes.
395 channel.write(sendWrappedBuffer);
454 private final ByteChannel channel; field in class:TLSByteChannel
480 TLSByteChannel(final ByteChannel channel, final SSLEngine sslEngine) argument
[all...]
/forgerock/opendj2/src/server/org/opends/server/backends/jeb/importLDIF/
H A DIndexInputBuffer.java53 private final FileChannel channel; field in class:IndexInputBuffer
84 * @param channel
85 * The index file channel.
97 public IndexInputBuffer(IndexManager indexMgr, FileChannel channel, argument
101 this.channel = channel;
117 channel.position(begin + offset);
132 bytesRead += channel.read(cache);
/forgerock/opendj2/src/server/org/opends/server/extensions/
H A DSASLByteChannel.java42 * This class implements a SASL byte channel that can be used during
65 channel.close();
175 channel.write(sendWrappedBuffer);
188 // data is available on the underlying channel.
194 // The channel read may only partially fill the buffer due to
195 // buffering in the underlying channel layer (e.g. SSL layer), so
200 final int read = channel.read(recvWrappedLengthBuffer);
237 // The channel read may only partially fill the buffer due to
238 // buffering in the underlying channel layer (e.g. SSL layer), so
243 final int read = channel
290 private final ByteChannel channel; field in class:SASLByteChannel
[all...]
H A DTLSByteChannel.java55 * A class that provides a TLS byte channel implementation.
109 channel.close();
261 // Synchronize SSL unwrap with channel reads.
265 // data is available on the underlying channel.
312 // Read wrapped data from underlying channel.
314 final int read = channel.read(recvWrappedBuffer);
319 // channel closed.
351 // Synchronize SSL wrap with channel writes.
394 channel.write(sendWrappedBuffer);
453 private final ByteChannel channel; field in class:TLSByteChannel
479 TLSByteChannel(final ByteChannel channel, final SSLEngine sslEngine) argument
[all...]
/forgerock/opendj-b2.6/src/server/org/opends/server/backends/jeb/importLDIF/
H A DIndexInputBuffer.java54 private final FileChannel channel; field in class:IndexInputBuffer
85 * @param channel
86 * The index file channel.
98 public IndexInputBuffer(IndexManager indexMgr, FileChannel channel, argument
102 this.channel = channel;
118 channel.position(begin + offset);
133 bytesRead += channel.read(cache);
/forgerock/opendj2.6.2/src/server/org/opends/server/backends/jeb/importLDIF/
H A DIndexInputBuffer.java54 private final FileChannel channel; field in class:IndexInputBuffer
85 * @param channel
86 * The index file channel.
98 public IndexInputBuffer(IndexManager indexMgr, FileChannel channel, argument
102 this.channel = channel;
118 channel.position(begin + offset);
133 bytesRead += channel.read(cache);
/forgerock/opendj2.6.2/src/server/org/opends/server/extensions/
H A DSASLByteChannel.java43 * This class implements a SASL byte channel that can be used during
66 channel.close();
176 channel.write(sendWrappedBuffer);
189 // data is available on the underlying channel.
195 // The channel read may only partially fill the buffer due to
196 // buffering in the underlying channel layer (e.g. SSL layer), so
201 final int read = channel.read(recvWrappedLengthBuffer);
238 // The channel read may only partially fill the buffer due to
239 // buffering in the underlying channel layer (e.g. SSL layer), so
244 final int read = channel
291 private final ByteChannel channel; field in class:SASLByteChannel
[all...]
H A DTLSByteChannel.java56 * A class that provides a TLS byte channel implementation.
110 channel.close();
262 // Synchronize SSL unwrap with channel reads.
266 // data is available on the underlying channel.
313 // Read wrapped data from underlying channel.
315 final int read = channel.read(recvWrappedBuffer);
320 // channel closed.
352 // Synchronize SSL wrap with channel writes.
395 channel.write(sendWrappedBuffer);
454 private final ByteChannel channel; field in class:TLSByteChannel
480 TLSByteChannel(final ByteChannel channel, final SSLEngine sslEngine) argument
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/extensions/
H A DSASLByteChannel.java43 * This class implements a SASL byte channel that can be used during
66 channel.close();
176 channel.write(sendWrappedBuffer);
189 // data is available on the underlying channel.
195 // The channel read may only partially fill the buffer due to
196 // buffering in the underlying channel layer (e.g. SSL layer), so
201 final int read = channel.read(recvWrappedLengthBuffer);
238 // The channel read may only partially fill the buffer due to
239 // buffering in the underlying channel layer (e.g. SSL layer), so
244 final int read = channel
291 private final ByteChannel channel; field in class:SASLByteChannel
[all...]
H A DTLSByteChannel.java56 * A class that provides a TLS byte channel implementation.
110 channel.close();
262 // Synchronize SSL unwrap with channel reads.
266 // data is available on the underlying channel.
313 // Read wrapped data from underlying channel.
315 final int read = channel.read(recvWrappedBuffer);
320 // channel closed.
352 // Synchronize SSL wrap with channel writes.
395 channel.write(sendWrappedBuffer);
454 private final ByteChannel channel; field in class:TLSByteChannel
480 TLSByteChannel(final ByteChannel channel, final SSLEngine sslEngine) argument
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/backends/jeb/importLDIF/
H A DIndexInputBuffer.java53 private final FileChannel channel; field in class:IndexInputBuffer
84 * @param channel
85 * The index file channel.
97 public IndexInputBuffer(IndexManager indexMgr, FileChannel channel, argument
101 this.channel = channel;
117 channel.position(begin + offset);
132 bytesRead += channel.read(cache);
/forgerock/opendj2-hg/src/server/org/opends/server/extensions/
H A DSASLByteChannel.java42 * This class implements a SASL byte channel that can be used during
65 channel.close();
175 channel.write(sendWrappedBuffer);
188 // data is available on the underlying channel.
194 // The channel read may only partially fill the buffer due to
195 // buffering in the underlying channel layer (e.g. SSL layer), so
200 final int read = channel.read(recvWrappedLengthBuffer);
237 // The channel read may only partially fill the buffer due to
238 // buffering in the underlying channel layer (e.g. SSL layer), so
243 final int read = channel
290 private final ByteChannel channel; field in class:SASLByteChannel
[all...]

Completed in 194 milliseconds

123