Searched refs:channel (Results 1 - 25 of 90) sorted by relevance

1234

/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/openidm-v4/openidm-util/src/main/java/org/forgerock/openidm/util/
H A DFileUtil.java56 FileChannel channel = new FileInputStream(file).getChannel();
57 ByteBuffer buffer = ByteBuffer.allocate((int) channel.size());
58 channel.read(buffer);
59 channel.close();
/forgerock/opendj-b2.6/src/server/org/opends/server/core/
H A DLockFileManager.java143 // Open the file for reading and get the corresponding file channel.
144 FileChannel channel = null;
149 channel = raf.getChannel();
165 // Try to obtain a shared lock on the file channel.
169 fileLock = channel.tryLock(0L, Long.MAX_VALUE, true);
181 close(channel, raf);
192 close(channel, raf);
265 // Open the file read+write and get the corresponding file channel.
266 FileChannel channel = null;
271 channel
[all...]
/forgerock/opendj2/src/server/org/opends/server/core/
H A DLockFileManager.java137 // Open the file for reading and get the corresponding file channel.
138 FileChannel channel = null;
143 channel = raf.getChannel();
159 // Try to obtain a shared lock on the file channel.
163 fileLock = channel.tryLock(0L, Long.MAX_VALUE, true);
175 close(channel, raf);
186 close(channel, raf);
259 // Open the file read+write and get the corresponding file channel.
260 FileChannel channel = null;
265 channel
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/core/
H A DLockFileManager.java143 // Open the file for reading and get the corresponding file channel.
144 FileChannel channel = null;
149 channel = raf.getChannel();
165 // Try to obtain a shared lock on the file channel.
169 fileLock = channel.tryLock(0L, Long.MAX_VALUE, true);
181 close(channel, raf);
192 close(channel, raf);
265 // Open the file read+write and get the corresponding file channel.
266 FileChannel channel = null;
271 channel
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/core/
H A DLockFileManager.java143 // Open the file for reading and get the corresponding file channel.
144 FileChannel channel = null;
149 channel = raf.getChannel();
165 // Try to obtain a shared lock on the file channel.
169 fileLock = channel.tryLock(0L, Long.MAX_VALUE, true);
181 close(channel, raf);
192 close(channel, raf);
265 // Open the file read+write and get the corresponding file channel.
266 FileChannel channel = null;
271 channel
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/core/
H A DLockFileManager.java137 // Open the file for reading and get the corresponding file channel.
138 FileChannel channel = null;
143 channel = raf.getChannel();
159 // Try to obtain a shared lock on the file channel.
163 fileLock = channel.tryLock(0L, Long.MAX_VALUE, true);
175 close(channel, raf);
186 close(channel, raf);
259 // Open the file read+write and get the corresponding file channel.
260 FileChannel channel = null;
265 channel
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/core/
H A DLockFileManager.java122 // Open the file for reading and get the corresponding file channel.
123 FileChannel channel = null;
128 channel = raf.getChannel();
141 // Try to obtain a shared lock on the file channel.
145 fileLock = channel.tryLock(0L, Long.MAX_VALUE, true);
154 close(channel, raf);
165 close(channel, raf);
235 // Open the file read+write and get the corresponding file channel.
236 FileChannel channel = null;
241 channel
[all...]
/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/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/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/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-v3/opendj-server-legacy/src/main/java/org/opends/server/extensions/
H A DSASLByteChannel.java37 * This class implements a SASL byte channel that can be used during
56 channel.close();
160 channel.write(sendWrappedBuffer);
173 // data is available on the underlying channel.
179 // The channel read may only partially fill the buffer due to
180 // buffering in the underlying channel layer (e.g. SSL layer), so
185 final int read = channel.read(recvWrappedLengthBuffer);
222 // The channel read may only partially fill the buffer due to
223 // buffering in the underlying channel layer (e.g. SSL layer), so
228 final int read = channel
275 private final ByteChannel channel; field in class:SASLByteChannel
[all...]
H A DTLSByteChannel.java52 * A class that provides a TLS byte channel implementation.
104 channel.close();
252 // Synchronize SSL unwrap with channel reads.
256 // data is available on the underlying channel.
303 // Read wrapped data from underlying channel.
305 final int read = channel.read(recvWrappedBuffer);
310 // channel closed.
342 // Synchronize SSL wrap with channel writes.
385 channel.write(sendWrappedBuffer);
444 private final ByteChannel channel; field in class:TLSByteChannel
470 TLSByteChannel(final ByteChannel channel, final SSLEngine sslEngine) 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...]

Completed in 140 milliseconds

1234