Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for socketio (0.21 sec)

  1. internal/http/server.go

    }
    
    // UseCustomLogger use customized logger for this HTTP *Server
    func (srv *Server) UseCustomLogger(l *log.Logger) *Server {
    	srv.ErrorLog = l
    	return srv
    }
    
    // UseTCPOptions use custom TCP options on raw socket
    func (srv *Server) UseTCPOptions(opts TCPOptions) *Server {
    	srv.TCPOptions = opts
    	return srv
    }
    
    // NewServer - creates new HTTP server using given arguments.
    func NewServer(addrs []string) *Server {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Feb 09 21:25:16 GMT 2024
    - 7.7K bytes
    - Viewed (0)
  2. docs/bigdata/README.md

    fs.s3a.max.total.tasks=2048 # Maximum number of parallel tasks
    fs.s3a.multipart.size=512M # Size of each multipart chunk
    fs.s3a.multipart.threshold=512M # Size before using multipart uploads
    fs.s3a.socket.recv.buffer=65536 # Read socket buffer hint
    fs.s3a.socket.send.buffer=65536 # Write socket buffer hint
    fs.s3a.threads.max=2048 # Maximum number of threads for S3A
    ```
    
    The rest of the other optimization options are discussed in the links below
    
    Plain Text
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Sep 29 04:28:45 GMT 2022
    - 14.7K bytes
    - Viewed (0)
  3. internal/http/dial_linux.go

    			// with dead end because tcp-keepalive is not fired when there is data in the socket buffer.
    			//    https://blog.cloudflare.com/when-tcp-sockets-refuse-to-die/
    			// This is a sensitive configuration, it is better to set it to high values, > 60 secs since it can
    			// affect clients reading data with a very slow pace  (disappropriate with socket buffer sizes)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Jun 07 16:53:05 GMT 2023
    - 4.4K bytes
    - Viewed (3)
  4. internal/http/check_port_linux.go

    				if opts.Interface != "" {
    					// When interface is specified look for specifically port availability on
    					// the specified interface if any.
    					_ = syscall.SetsockoptString(int(fdPtr), syscall.SOL_SOCKET, syscall.SO_BINDTODEVICE, opts.Interface)
    				}
    			})
    			return nil
    		},
    	}
    
    	ctx, cancel := context.WithTimeout(context.Background(), time.Second)
    	defer cancel()
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed May 03 21:12:25 GMT 2023
    - 1.9K bytes
    - Viewed (0)
  5. internal/http/listener.go

    	for i := range listener.tcpListeners {
    		addrs = append(addrs, listener.tcpListeners[i].Addr())
    	}
    
    	return addrs
    }
    
    // TCPOptions specify customizable TCP optimizations on raw socket
    type TCPOptions struct {
    	UserTimeout        int              // this value is expected to be in milliseconds
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Mar 01 16:00:42 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  6. cmd/server-main.go

    		Hidden: true,
    		Value:  10 * time.Minute,
    		EnvVar: "MINIO_CONN_WRITE_DEADLINE",
    	},
    	cli.DurationFlag{
    		Name:   "conn-user-timeout",
    		Usage:  "custom TCP_USER_TIMEOUT for socket buffers",
    		Hidden: true,
    		Value:  10 * time.Minute,
    		EnvVar: "MINIO_CONN_USER_TIMEOUT",
    	},
    	cli.StringFlag{
    		Name:   "interface",
    		Usage:  "bind to right VRF device for MinIO services",
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 32.7K bytes
    - Viewed (1)
  7. internal/dsync/dsync-client_test.go

    	}
    }
    
    // Close closes the underlying socket file descriptor.
    func (restClient *ReconnectRESTClient) IsOnline() bool {
    	// If rest client has not connected yet there is nothing to close.
    	return restClient.rest != nil
    }
    
    func (restClient *ReconnectRESTClient) IsLocal() bool {
    	return false
    }
    
    // Close closes the underlying socket file descriptor.
    func (restClient *ReconnectRESTClient) Close() error {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Jan 20 17:36:09 GMT 2022
    - 4.4K bytes
    - Viewed (0)
Back to top