- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 163 for peng (0.15 sec)
-
docs/screenshots/erasure-code.png
erasure-code.png...
PNG Image - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 21 04:12:21 GMT 2017 - 220.7K bytes - Viewed (0) -
internal/grid/muxclient.go
case m.outBlock <- struct{}{}: default: gridLogIf(m.ctx, errors.New("output unblocked overflow")) } } func (m *muxClient) pong(msg pongMsg) { if msg.NotFound || msg.Err != nil { err := errors.New("remote terminated call") if msg.Err != nil { err = fmt.Errorf("remove pong failed: %v", &msg.Err) } m.addResponse(Response{Err: err}) return } atomic.StoreInt64(&m.LastPong, time.Now().Unix()) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
docs/bucket/versioning/versioning_GET_versionEnabled.png
versioning_GET_versionEnabled.png...
PNG Image - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Jun 27 17:27:23 GMT 2020 - 134.3K bytes - Viewed (0) -
docs/metrics/prometheus/grafana/replication/grafana-replication-node.png
grafana-replication-node.png...
PNG Image - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:15:39 GMT 2024 - 229.7K bytes - Viewed (0) -
internal/http/transports.go
// // ReadIdleTimeout is the timeout after which a health check using ping // // frame will be carried out if no frame is received on the // // connection. 5 minutes is sufficient time for any idle connection. // trhttp2.ReadIdleTimeout = 5 * time.Minute // // PingTimeout is the timeout after which the connection will be closed // // if a response to Ping is not received. // trhttp2.PingTimeout = dialTimeout
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.9K bytes - Viewed (0) -
docs/bucket/versioning/versioning_DELETE_versionEnabled_id.png
versioning_DELETE_versionEnabled_id.png...
PNG Image - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Jun 27 17:27:23 GMT 2020 - 122.6K bytes - Viewed (0) -
docs/screenshots/Architecture-diagram_distributed_8.png
Architecture-diagram_distributed_8.png...
PNG Image - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Oct 23 05:20:38 GMT 2018 - 89.7K bytes - Viewed (0) -
internal/grid/msg.go
const ( // OpConnect is a connect request. OpConnect Op = iota + 1 // OpConnectResponse is a response to a connect request. OpConnectResponse // OpPing is a ping request. // If a mux id is specified that mux is pinged. // Clients send ping requests. OpPing // OpPong is a OpPing response returned by the server. OpPong // OpConnectMux will connect a new mux with optional payload. OpConnectMux
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 28 19:22:29 GMT 2023 - 7.3K bytes - Viewed (0) -
cmd/object-api-listobjects_test.go
var err error testObjects := []struct { parentBucket string name string content string meta map[string]string }{ {testBuckets[0], "Asia-maps.png", "asis-maps", map[string]string{"content-type": "image/png"}}, {testBuckets[0], "Asia/India/India-summer-photos-1", "contentstring", nil}, {testBuckets[0], "Asia/India/Karnataka/Bangalore/Koramangala/pics", "contentstring", nil},
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 11:07:40 GMT 2024 - 73.1K bytes - Viewed (0) -
internal/grid/connection.go
return } // Single calls do not support pinging. if v, ok := c.inStream.Load(m.MuxID); ok { pong := v.ping(m.Seq) gridLogIf(ctx, c.queueMsg(m, &pong)) } else { pong := pongMsg{NotFound: true} gridLogIf(ctx, c.queueMsg(m, &pong)) } return } func (c *Connection) handleDisconnectClientMux(m message) { if v, ok := c.outgoing.Load(m.MuxID); ok {
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)