Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for handlePing (0.28 sec)

  1. internal/grid/connection.go

    		c.handleUnblockClMux(m)
    	case OpDisconnectServerMux:
    		c.handleDisconnectServerMux(m)
    	case OpDisconnectClientMux:
    		c.handleDisconnectClientMux(m)
    	case OpPing:
    		c.handlePing(ctx, m)
    	case OpPong:
    		c.handlePong(ctx, m)
    	case OpRequest:
    		c.handleRequest(ctx, m, subID)
    	case OpAckMux:
    		c.handleAckMux(ctx, m)
    	case OpConnectMux:
    		c.handleConnectMux(ctx, m, subID)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
  2. internal/http/server.go

    	// DefaultMaxHeaderBytes - default maximum HTTP header size in bytes.
    	DefaultMaxHeaderBytes = 1 * humanize.MiByte
    )
    
    // Server - extended http.Server supports multiple addresses to serve and enhanced connection handling.
    type Server struct {
    	http.Server
    	Addrs           []string      // addresses on which the server listens for new connection.
    	TCPOptions      TCPOptions    // all the configurable TCP conn specific configurable options.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 09 21:25:16 GMT 2024
    - 7.7K bytes
    - Viewed (0)
  3. internal/grid/README.md

    The MinIO Grid is a package that provides two-way communication between servers.
    It uses a single two-way connection to send and receive messages between servers.
    
    It includes built in muxing of concurrent requests as well as congestion handling for streams.
    
    Requests can be "Single Payload" or "Streamed".
    
    Use the MinIO Grid for:
    
    * Small, frequent requests with low latency requirements.
    * Long-running requests with small/medium payloads.
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 9.4K bytes
    - Viewed (0)
  4. docs/sts/wso2.md

    1. The id_token is an identifier that is hard to guess. For example, a randomly generated string of sufficient length, that the server handling the protected resource can use to lookup the associated authorization information.
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Sep 29 04:28:45 GMT 2022
    - 8.7K bytes
    - Viewed (0)
  5. SECURITY.md

    should be reported by email to ******@****.***. Your email will be acknowledged within 48 hours,
    and you'll receive a more detailed response to your email within 72 hours indicating the next steps
    in handling your report.
    
    Please, provide a detailed explanation of the issue. In particular, outline the type of the security
    issue (DoS, authentication bypass, information disclose, ...) and the assumptions you're making (e.g. do
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Feb 12 00:51:25 GMT 2022
    - 2.2K bytes
    - Viewed (0)
  6. internal/http/listener.go

    	"net"
    	"syscall"
    	"time"
    
    	"github.com/minio/minio/internal/deadlineconn"
    )
    
    type acceptResult struct {
    	conn net.Conn
    	err  error
    	lidx int
    }
    
    // httpListener - HTTP listener capable of handling multiple server addresses.
    type httpListener struct {
    	opts        TCPOptions
    	listeners   []net.Listener    // underlying TCP listeners.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  7. cmd/metacache-manager.go

    		return errFileNotFound
    	}
    	if cache.status == scanStateSuccess || cache.status == scanStateStarted {
    		if time.Since(cache.lastUpdate) > metacacheMaxRunningAge {
    			// We got a stale entry, mark error on handling server.
    			err := fmt.Errorf("timeout: list %s not updated", cache.id)
    			cache.error = err.Error()
    			cache.status = scanStateError
    			rpc.UpdateMetacacheListing(ctx, cache)
    			return err
    		}
    		return nil
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Oct 25 00:44:15 GMT 2022
    - 5.2K bytes
    - Viewed (0)
  8. cmd/iam-store.go

    			// Delete this user account and its policy mapping
    			store.deleteMappedPolicy(ctx, user, userType, false)
    			cache.iamUserPolicyMap.Delete(user)
    
    			// we are only logging errors, not handling them.
    			err := store.deleteUserIdentity(ctx, user, userType)
    			iamLogIf(GlobalContext, err)
    			delete(cache.iamUsersMap, user)
    
    			deleted = true
    		}
    	}
    
    	if deleted {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Apr 27 10:04:10 GMT 2024
    - 75.2K bytes
    - Viewed (2)
  9. docs/metrics/v3.md

    ```
    /minio/metrics/v3
    ```
    
    however, a specific path under this is required.
    
    Metrics are organized into groups at paths **relative** to the top-level endpoint above.
    
    ## Metrics Request Handling
    
    Each endpoint below can be queried at different intervals as needed via a scrape configuration in Prometheus or a compatible metrics collection tool.
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 17:37:57 GMT 2024
    - 28.5K bytes
    - Viewed (0)
  10. cmd/object-api-utils.go

    // string.
    //
    // See:
    // http://docs.aws.amazon.com/AmazonS3/latest/dev/UsingMetadata.html
    //
    // You should avoid the following characters in a key name because of
    // significant special handling for consistency across all
    // applications.
    //
    // Rejects strings with following characters.
    //
    // - Backslash ("\")
    //
    // additionally minio does not support object names with trailing SlashSeparator.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 11 11:55:34 GMT 2024
    - 35.6K bytes
    - Viewed (1)
Back to top