Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for socketio (0.24 sec)

  1. samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/UnixDomainServerSocketFactory.java

    import java.net.ServerSocket;
    import java.net.Socket;
    import java.net.SocketAddress;
    import java.net.SocketException;
    import java.nio.channels.ClosedChannelException;
    import javax.net.ServerSocketFactory;
    import jnr.unixsocket.UnixServerSocketChannel;
    import jnr.unixsocket.UnixSocketAddress;
    import jnr.unixsocket.UnixSocketChannel;
    
    /** Impersonate TCP-style ServerSocketFactory over UNIX domain sockets. */
    Java
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Tue Feb 12 16:33:52 GMT 2019
    - 3.1K bytes
    - Viewed (0)
  2. samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/TunnelingUnixSocket.java

    import java.net.SocketAddress;
    import jnr.unixsocket.UnixSocket;
    import jnr.unixsocket.UnixSocketAddress;
    import jnr.unixsocket.UnixSocketChannel;
    
    /**
     * Subtype UNIX socket for a higher-fidelity impersonation of TCP sockets. This is named "tunneling"
     * because it assumes the ultimate destination has a hostname and port.
     */
    final class TunnelingUnixSocket extends UnixSocket {
      private final File path;
    Java
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Tue Feb 12 16:33:52 GMT 2019
    - 1.9K bytes
    - Viewed (0)
  3. samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/ClientAndServer.java

    import okhttp3.Request;
    import okhttp3.Response;
    import okhttp3.mockwebserver.MockResponse;
    import okhttp3.mockwebserver.MockWebServer;
    
    /**
     * Create UNIX domain sockets for MockWebServer and OkHttp and connect 'em together. Note that we
     * cannot do TLS over domain sockets.
     */
    public class ClientAndServer {
      public void run() throws Exception {
        File socketFile = new File("/tmp/ClientAndServer.sock");
    Java
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Mon Dec 24 03:46:30 GMT 2018
    - 2.1K bytes
    - Viewed (0)
  4. src/main/java/jcifs/util/transport/Transport.java

                    boolean closed = msg != null && msg.equals("Socket closed");
    
                    if ( closed ) {
                        log.trace("Remote closed connection");
                    }
                    else if ( timeout ) {
                        log.debug("socket timeout in non peek state", ex);
                    }
                    else {
    Java
    - Registered: Sun Apr 21 00:10:10 GMT 2024
    - Last Modified: Sun Nov 01 18:12:21 GMT 2020
    - 24.1K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/net/InetAddresses.java

     *
     * <p>"IPv4 mapped" addresses were originally a representation of IPv4 addresses for use on an IPv6
     * socket that could receive both IPv4 and IPv6 connections (by disabling the {@code IPV6_V6ONLY}
     * socket option on an IPv6 socket). Yes, it's confusing. Nevertheless, these "mapped" addresses
     * were never supposed to be seen on the wire. That assumption was dropped, some say mistakenly, in
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri Dec 15 19:31:54 GMT 2023
    - 44K bytes
    - Viewed (1)
  6. android/guava/src/com/google/common/io/ByteStreams.java

       * <ol>
       *   <li>Use sendfile(2) or equivalent. Requires that both the input channel and the output
       *       channel have their own file descriptors. Generally this only happens when both channels
       *       are files or sockets. This performs zero copies - the bytes never enter userspace.
       *   <li>Use mmap(2) or equivalent. Requires that either the input channel or the output channel
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Jan 17 18:59:58 GMT 2024
    - 29.7K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/netbios/NameServiceClient.java

                 * because we might close the socket during a
                 * request. However the chances are slim and the
                 * retry code should ensure the overall request
                 * is serviced. The alternative complicates things
                 * more than I think is worth it.
                 */
    
                if( socket != null ) {
                    socket.close();
                    socket = null;
                }
    Java
    - Registered: Sun Apr 21 00:10:10 GMT 2024
    - Last Modified: Fri Mar 22 20:39:42 GMT 2019
    - 17.4K bytes
    - Viewed (0)
  8. src/main/java/jcifs/netbios/NameServiceClientImpl.java

                this.closeTimeout = Math.max(this.transportContext.getConfig().getNetbiosSoTimeout(), timeout);
            }
            // If socket is still good, the new closeTimeout will
            // be ignored; see tryClose comment.
            if ( this.socket == null ) {
                this.socket = new DatagramSocket(this.lport, this.laddr);
                this.thread = new Thread(this, "JCIFS-NameServiceClient");
    Java
    - Registered: Sun Apr 21 00:10:10 GMT 2024
    - Last Modified: Sun Aug 14 14:26:22 GMT 2022
    - 38.2K bytes
    - Viewed (0)
  9. samples/guide/src/main/java/okhttp3/recipes/CustomCipherSuites.java

          return delegate.getSupportedCipherSuites();
        }
    
        @Override public Socket createSocket(
            Socket socket, String host, int port, boolean autoClose) throws IOException {
          return configureSocket((SSLSocket) delegate.createSocket(socket, host, port, autoClose));
        }
    
        @Override public Socket createSocket(String host, int port) throws IOException {
    Java
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Thu Mar 14 21:57:42 GMT 2019
    - 6.5K bytes
    - Viewed (0)
  10. src/main/java/jcifs/smb1/netbios/NbtAddress.java

        /* Construct the shared static client object that will
         * conduct all encoding and decoding of NetBIOS name service
         * messages as well as socket IO in a synchronized fashon.
         */
    
        private static final NameServiceClient CLIENT = new NameServiceClient();
    
        private static final int DEFAULT_CACHE_POLICY = 30;
    Java
    - Registered: Sun Apr 21 00:10:10 GMT 2024
    - Last Modified: Fri Mar 22 20:39:42 GMT 2019
    - 30.1K bytes
    - Viewed (0)
Back to top