- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for Peers (0.16 sec)
-
cmd/listen-notification-handlers.go
continue } mergeCh <- append(grid.GetByteBuffer()[:0], buf.Bytes()...) case <-ctx.Done(): grid.PutByteBuffer(buf.Bytes()) return } } }() peers, _ := newPeerRestClients(globalEndpoints) err := globalHTTPListen.Subscribe(mask, localCh, ctx.Done(), func(ev event.Event) bool { if ev.S3.Bucket.Name != "" && bucketName != "" { if ev.S3.Bucket.Name != bucketName {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
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)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 15 19:52:44 GMT 2024 - 7.5K bytes - Viewed (0) -
cmd/logging.go
func peersLogIf(ctx context.Context, err error, errKind ...interface{}) { logger.LogIf(ctx, "peers", err, errKind...) } func peersLogAlwaysIf(ctx context.Context, err error, errKind ...interface{}) { logger.LogAlwaysIf(ctx, "peers", err, errKind...) } func peersLogOnceIf(ctx context.Context, err error, id string, errKind ...interface{}) { logger.LogOnceIf(ctx, "peers", err, id, errKind...) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 16 15:43:39 GMT 2024 - 6.6K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/HandshakeCertificates.kt
import okhttp3.internal.toImmutableList import okhttp3.tls.internal.TlsUtil.newKeyManager import okhttp3.tls.internal.TlsUtil.newTrustManager /** * Certificates to identify which peers to trust and also to earn the trust of those peers in kind. * Client and server exchange these certificates during the handshake phase of a TLS connection. * * ### Server Authentication *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 8.5K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/WebSocketListener.kt
*/ open fun onClosing( webSocket: WebSocket, code: Int, reason: String, ) { } /** * Invoked when both peers have indicated that no more messages will be transmitted and the * connection has been successfully released. No further calls to this listener will be made. */ open fun onClosed( webSocket: WebSocket,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/WebSocket.kt
* * * **Open:** the web socket has been accepted by the remote peer and is fully operational. * Messages in either direction are enqueued for immediate transmission. * * * **Closing:** one of the peers on the web socket has initiated a graceful shutdown. The web * socket will continue to transmit already-enqueued messages but will refuse to enqueue new * ones. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.3K bytes - Viewed (0) -
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.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.5K bytes - Viewed (0) -
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 }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jan 23 16:46:37 GMT 2023 - 8.3K bytes - Viewed (0)