/forgerock/opendj-b2.6/src/server/org/opends/server/protocols/asn1/ |
H A D | ASN1.java | 190 * 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 D | ASN1.java | 189 * 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 D | ASN1.java | 190 * 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 D | ASN1.java | 190 * 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 D | ASN1.java | 189 * 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 D | FileUtil.java | 56 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 D | LockFileManager.java | 143 // 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 D | LockFileManager.java | 137 // 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 D | LockFileManager.java | 143 // 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 D | LockFileManager.java | 143 // 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 D | LockFileManager.java | 137 // 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 D | LockFileManager.java | 122 // 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 D | SASLByteChannel.java | 43 * 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 D | TLSByteChannel.java | 56 * 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 D | SASLByteChannel.java | 42 * 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 D | TLSByteChannel.java | 55 * 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 D | SASLByteChannel.java | 43 * 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 D | TLSByteChannel.java | 56 * 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 D | SASLByteChannel.java | 43 * 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 D | TLSByteChannel.java | 56 * 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 D | SASLByteChannel.java | 42 * 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 D | TLSByteChannel.java | 55 * 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 D | SASLByteChannel.java | 37 * 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 D | TLSByteChannel.java | 52 * 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 D | RadiusRequestListener.java | 46 * 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...] |