List of socket() Examples

Examples of socket()

com.ibm.io.async.AsyncServerSocketChannel.socket()
java.nio.channels.DatagramChannel.socket()
Return the related datagram socket of this channel, which won't declare public methods that not declared in DatagramSocket. @return The related DatagramSocket instance.
java.nio.channels.ServerSocketChannel.socket()
Retrieves a server socket associated with this channel.
The returned object will not declare any public methods that are not declared in the {@link java.net.ServerSocket} class.
@return A server socket associated with this channel
java.nio.channels.SocketChannel.socket()
Return the related socket of this channel, which won't declare public methods that not declared in Socket. @return The related Socket instance.
jnr.unixsocket.UnixServerSocketChannel.socket()
org.apache.yoko.orb.OCI.IIOP.TransportInfo_impl.socket()
org.jeromq.ZMQ.Context.socket()
org.zeromq.ZMQ.Context.socket()

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

            ch.configureBlocking(blocking);
        } catch (IOException e) {
            LOG.error("Failed to open SocketChannel.", e);
            throw new IllegalStateException(e);
        }
        final Socket sock = ch.socket();
        if(rcvbufSize != -1) {
            try {
                sock.setReceiveBufferSize(rcvbufSize);
            } catch (SocketException e) {
                LOG.error("Failed to setReceiveBufferSize.", e);

View Full Code Here

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

    writeBuffer.clear();
    readBuffer.clear();
    readBuffer.flip();
    try {
      SocketChannel socketChannel = selector.provider().openSocketChannel();
      Socket socket = socketChannel.socket();
      socket.setTcpNoDelay(true);
      socket.setTrafficClass(IPTOS_LOWDELAY);
      socket.connect(remoteAddress, timeout); // Connect using blocking mode for simplicity.
      socketChannel.configureBlocking(false);
      this.socketChannel = socketChannel;

View Full Code Here

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


      selectionKey = socketChannel.register(selector, SelectionKey.OP_READ);
      selectionKey.attach(this);


      if (DEBUG) {
        debug("kryonet", "Port " + socketChannel.socket().getLocalPort() + "/TCP connected to: "
          + socketChannel.socket().getRemoteSocketAddress());
      }


      lastReadTime = lastWriteTime = System.currentTimeMillis();
    } catch (IOException ex) {

View Full Code Here

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

      selectionKey = socketChannel.register(selector, SelectionKey.OP_READ);
      selectionKey.attach(this);


      if (DEBUG) {
        debug("kryonet", "Port " + socketChannel.socket().getLocalPort() + "/TCP connected to: "
          + socketChannel.socket().getRemoteSocketAddress());
      }


      lastReadTime = lastWriteTime = System.currentTimeMillis();
    } catch (IOException ex) {
      close();

View Full Code Here

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

    SocketChannel  channel = ((TCPTransportHelper)filter.getHelper()).getSocketChannel();
       
    //set advanced socket options
    try {
      int so_sndbuf_size = COConfigurationManager.getIntParameter( "network.tcp.socket.SO_SNDBUF" );
      if( so_sndbuf_size > 0 )  channel.socket().setSendBufferSize( so_sndbuf_size );
      
      String ip_tos = COConfigurationManager.getStringParameter( "network.tcp.socket.IPDiffServ" );
      if( ip_tos.length() > 0 )  channel.socket().setTrafficClass( Integer.decode( ip_tos ).intValue() );
    }
    catch( Throwable t ) {

View Full Code Here

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

    try {
      int so_sndbuf_size = COConfigurationManager.getIntParameter( "network.tcp.socket.SO_SNDBUF" );
      if( so_sndbuf_size > 0 )  channel.socket().setSendBufferSize( so_sndbuf_size );
      
      String ip_tos = COConfigurationManager.getStringParameter( "network.tcp.socket.IPDiffServ" );
      if( ip_tos.length() > 0 )  channel.socket().setTrafficClass( Integer.decode( ip_tos ).intValue() );
    }
    catch( Throwable t ) {
      t.printStackTrace();
    }

View Full Code Here

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

    }
    catch( Throwable t ) {
      t.printStackTrace();
    }
    
  InetSocketAddress tcp_address = new InetSocketAddress( channel.socket().getInetAddress(), channel.socket().getPort());


  ConnectionEndpoint  co_ep = new ConnectionEndpoint(tcp_address);


  ProtocolEndpointTCP  pe_tcp = (ProtocolEndpointTCP)ProtocolEndpointFactory.createEndpoint( ProtocolEndpoint.PROTOCOL_TCP, co_ep, tcp_address );

View Full Code Here

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

    }
    catch( Throwable t ) {
      t.printStackTrace();
    }
    
  InetSocketAddress tcp_address = new InetSocketAddress( channel.socket().getInetAddress(), channel.socket().getPort());


  ConnectionEndpoint  co_ep = new ConnectionEndpoint(tcp_address);


  ProtocolEndpointTCP  pe_tcp = (ProtocolEndpointTCP)ProtocolEndpointFactory.createEndpoint( ProtocolEndpoint.PROTOCOL_TCP, co_ep, tcp_address );

View Full Code Here

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

    }
    
    try{
      SocketChannel  channel = getSocketChannel();
      
      channel.socket().setSendBufferSize( size_in_bytes );
      channel.socket().setReceiveBufferSize( size_in_bytes );
      
      int snd_real = channel.socket().getSendBufferSize();
      int rcv_real = channel.socket().getReceiveBufferSize();

View Full Code Here

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

    
    try{
      SocketChannel  channel = getSocketChannel();
      
      channel.socket().setSendBufferSize( size_in_bytes );
      channel.socket().setReceiveBufferSize( size_in_bytes );
      
      int snd_real = channel.socket().getSendBufferSize();
      int rcv_real = channel.socket().getReceiveBufferSize();
      
      if (Logger.isEnabled())

View Full Code Here

0 1 2 3 4 5

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.