List of blockingLock() Examples

Examples of blockingLock()

java.nio.channels.DatagramChannel.blockingLock()
java.nio.channels.SelectableChannel.blockingLock()
Retrieves the object upon which the {@link #configureBlocking configureBlocking} and {@link #register register} methods synchronize.This is often useful in the implementation of adaptors that require a specific blocking mode to be maintained for a short period of time.
@return The blocking-mode lock object
java.nio.channels.ServerSocketChannel.blockingLock()
java.nio.channels.SocketChannel.blockingLock()

Examples of java.nio.channels.SelectableChannel.blockingLock()

    public int ready() throws IOException {
        if (descriptor.getChannel() instanceof SelectableChannel) {
            int ready_stat = 0;
            java.nio.channels.Selector sel = SelectorFactory.openWithRetryFrom(null, ((SelectableChannel) descriptor.getChannel()).provider());
            SelectableChannel selchan = (SelectableChannel)descriptor.getChannel();
            synchronized (selchan.blockingLock()) {
                boolean is_block = selchan.isBlocking();
                try {
                    selchan.configureBlocking(false);
                    selchan.register(sel, java.nio.channels.SelectionKey.OP_READ);
                    ready_stat = sel.selectNow();

View Full Code Here

Examples of java.nio.channels.SelectableChannel.blockingLock()


        if (buffer.position() != 0 && !flushWrite(false)) return 0;


        if (descriptor.getChannel() instanceof SelectableChannel) {
            SelectableChannel selectableChannel = (SelectableChannel)descriptor.getChannel();
            synchronized (selectableChannel.blockingLock()) {
                boolean oldBlocking = selectableChannel.isBlocking();
                try {
                    if (oldBlocking) {
                        selectableChannel.configureBlocking(false);
                    }

View Full Code Here

Examples of java.nio.channels.SelectableChannel.blockingLock()

            return null;
        }


        if (descriptor.getChannel() instanceof SelectableChannel) {
            SelectableChannel selectableChannel = (SelectableChannel)descriptor.getChannel();
            synchronized (selectableChannel.blockingLock()) {
                boolean oldBlocking = selectableChannel.isBlocking();
                try {
                    selectableChannel.configureBlocking(false);
                    return readpartial(number);
                } finally {

View Full Code Here

Examples of java.nio.channels.SelectableChannel.blockingLock()

                    final int available = stream.bufferedInputBytesRemaining();
                     if (available >= len) {
                        return stream.copyBufferedBytes(bytes, off, len);
                    } else if (stream.getDescriptor().getChannel() instanceof SelectableChannel) {
                        SelectableChannel ch = (SelectableChannel) stream.getDescriptor().getChannel();
                        synchronized (ch.blockingLock()) {
                            boolean oldBlocking = ch.isBlocking();
                            try {
                                if (!oldBlocking) {
                                    ch.configureBlocking(true);
                                }

View Full Code Here

Examples of java.nio.channels.SelectableChannel.blockingLock()

                    if (!stream.isSync() && stream.bufferedOutputSpaceRemaining() >= len) {
                        stream.buffer.put(bytes, off, len);


                    } else if (stream.getDescriptor().getChannel() instanceof SelectableChannel) {
                        SelectableChannel ch = (SelectableChannel) stream.getDescriptor().getChannel();
                        synchronized (ch.blockingLock()) {
                            boolean oldBlocking = ch.isBlocking();
                            try {
                                if (!oldBlocking) {
                                    ch.configureBlocking(true);
                                }

View Full Code Here

Examples of java.nio.channels.ServerSocketChannel.blockingLock()

        Ruby runtime = context.runtime;
        RubyTCPSocket socket = new RubyTCPSocket(runtime, runtime.getClass("TCPSocket"));
        Selector selector = null;
        ServerSocketChannel ssc = getServerSocketChannel();


        synchronized (ssc.blockingLock()) {
            boolean oldBlocking = ssc.isBlocking();


            try {
                ssc.configureBlocking(false);
                selector = SelectorFactory.openWithRetryFrom(runtime, SelectorProvider.provider());

View Full Code Here

Examples of java.nio.channels.SocketChannel.blockingLock()

                        connected.finishConnect();
                        
                        //
                        // Force the client socket to be blocking
                        //
                        synchronized (connected.blockingLock()) {
                            connected.configureBlocking(false);
                            connected.configureBlocking(true);
                        }
        
                        // otherwise one key has been selected (ours) so we get the channel and hand it off

View Full Code Here

Examples of java.nio.channels.SocketChannel.blockingLock()

                        connected.finishConnect();


                        //
                        // Force the client socket to be blocking
                        //
                        synchronized (connected.blockingLock()) {
                            connected.configureBlocking(false);
                            connected.configureBlocking(true);
                        }


                        // otherwise one key has been selected (ours) so we get the channel and hand it off

View Full Code Here

Examples of java.nio.channels.SocketChannel.blockingLock()

                    if (connected == null) continue;


                    connected.finishConnect();


                    // Force the client socket to be blocking
                    synchronized (connected.blockingLock()) {
                        connected.configureBlocking(false);
                        connected.configureBlocking(true);
                    }


                    // otherwise one key has been selected (ours) so we get the channel and hand it off

View Full Code Here

Examples of java.nio.channels.SocketChannel.blockingLock()

                    if (connected == null) continue;


                    connected.finishConnect();


                    // Force the client socket to be blocking
                    synchronized (connected.blockingLock()) {
                        connected.configureBlocking(false);
                        connected.configureBlocking(true);
                    }


                    // otherwise one key has been selected (ours) so we get the channel and hand it off

View Full Code Here

0 1 2 3

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.