Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 108 for peers (0.39 sec)

  1. cmd/peer-rest-client.go

    	return &peerRESTClient{
    		host: peer, restClient: restClient, gridHost: gridHost,
    		gridConn: func() *grid.Connection {
    			// Lazy initialization of grid connection.
    			// When we create this peer client, the grid connection is likely not yet initialized.
    			if gridHost == "" {
    				bugLogIf(context.Background(), fmt.Errorf("gridHost is empty for peer %s", peer.String()), peer.String()+":gridHost")
    				return nil
    			}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 26.1K bytes
    - Viewed (0)
  2. cmd/tier-handlers.go

    	case storageclass.STANDARD, storageclass.RRS:
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, errTierReservedName), r.URL)
    		return
    	}
    
    	// Refresh from the disk in case we had missed notifications about edits from peers.
    	if err := globalTierConfigMgr.Reload(ctx, objAPI); err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	err = globalTierConfigMgr.Add(ctx, cfg, ignoreInUse)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Sep 12 20:44:05 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  3. cmd/admin-handlers_test.go

    	if err != nil {
    		t.Fatal("Failed to initialize a single node Erasure backend for admin handler tests.", err)
    	}
    	defer adminTestBed.TearDown()
    
    	// Initialize admin peers to make admin RPC calls. Note: In a
    	// single node setup, this degenerates to a simple function
    	// call under the hood.
    	globalMinioAddr = "127.0.0.1:9000"
    
    	var wg sync.WaitGroup
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.9K bytes
    - Viewed (1)
  4. cmd/iam.go

    		}
    	}
    
    	err := sys.store.DeletePolicy(ctx, policyName, !notifyPeers)
    	if err != nil {
    		return err
    	}
    
    	if !notifyPeers || sys.HasWatcher() {
    		return nil
    	}
    
    	// Notify all other MinIO peers to delete policy
    	for _, nerr := range globalNotificationSys.DeletePolicy(ctx, policyName) {
    		if nerr.Err != nil {
    			logger.GetReqInfo(ctx).SetTags("peerAddress", nerr.Host.String())
    			iamLogIf(ctx, nerr.Err)
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Oct 15 17:00:45 UTC 2025
    - 76.5K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/WebSocket.kt

     *    from the peer.
     *
     * Web sockets may fail due to HTTP upgrade problems, connectivity problems, or if either peer
     * chooses to short-circuit the graceful shutdown process:
     *
     *  * **Canceled:** the web socket connection failed. Messages that were successfully enqueued by
     *    either peer may not have been transmitted to the other.
     *
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  6. docs/site-replication/run-multi-site-minio-idp.sh

    site_enabled=$(./mc admin replicate info minio1)
    site_enabled_peer=$(./mc admin replicate info minio10)
    
    [[ $site_enabled =~ "is not enabled" ]] && {
    	echo "expected both peers to have same information"
    	exit_1
    }
    
    [[ $site_enabled_peer =~ "is not enabled" ]] && {
    	echo "expected both peers to have same information"
    	exit_1
    }
    
    ./mc admin user add minio1 foobar foo12345
    
    ## add foobar-g group with foobar
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Sep 24 08:03:58 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  7. cmd/consolelogger.go

    	if err != nil {
    		logger.FatalIf(err, "Unable to start console logging subsystem")
    	}
    
    	sys.nodeName = host.Name
    }
    
    // HasLogListeners returns true if console log listeners are registered
    // for this node or peers
    func (sys *HTTPConsoleLoggerSys) HasLogListeners() bool {
    	return sys != nil && sys.pubsub.Subscribers() > 0
    }
    
    // Subscribe starts console logging for this node.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 5.4K bytes
    - Viewed (0)
  8. internal/http/headers.go

    	// Response request id.
    	AmzRequestID     = "x-amz-request-id"
    	AmzRequestHostID = "x-amz-id-2"
    
    	// Deployment id.
    	MinioDeploymentID = "x-minio-deployment-id"
    
    	// Peer call
    	MinIOPeerCall = "x-minio-from-peer"
    
    	// Server-Status
    	MinIOServerStatus = "x-minio-server-status"
    
    	// Content Checksums
    	AmzChecksumAlgo           = "x-amz-checksum-algorithm"
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed May 07 15:37:12 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  9. internal/dsync/dsync-server_test.go

    	// and positive values indicating number of read locks
    	lockMap map[string]int64
    
    	// Refresh returns lock not found if set to true
    	lockNotFound bool
    
    	// Set to true if you want peers servers to do not respond
    	responseDelay int64
    }
    
    func (l *lockServer) setRefreshReply(refreshed bool) {
    	l.mutex.Lock()
    	defer l.mutex.Unlock()
    	l.lockNotFound = !refreshed
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.3K bytes
    - Viewed (0)
  10. okhttp-tls/src/main/kotlin/okhttp3/tls/HeldCertificate.kt

     * called certificate authorities (CAs).
     *
     * Browsers and other HTTP clients need a set of trusted root certificates to authenticate their
     * peers. Sets of root certificates are managed by either the HTTP client (like Firefox), or the
     * host platform (like Android). In July 2018 Android had 134 trusted root certificates for its HTTP
     * clients to trust.
     *
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 21.6K bytes
    - Viewed (0)
Back to top