- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 47 for ping (0.45 sec)
-
cmd/metacache-server-pool.go
// 3) Returning, with ID, stream from list. // // If we don't have a list id we must ask the server if it has a cache or create a new. if o.ID != "" && !o.Transient { // Create or ping with handout... rpc := globalNotificationSys.restClientFromHash(pathJoin(o.Bucket, o.Prefix)) var c *metacache if rpc == nil { resp := localMetacacheMgr.getBucket(ctx, o.Bucket).findCache(*o) c = &resp
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.8K bytes - Viewed (0) -
internal/event/target/redis.go
return false, err } return target.isActive() } func (target *RedisTarget) isActive() (bool, error) { conn := target.pool.Get() defer conn.Close() _, pingErr := conn.Do("PING") if pingErr != nil { if xnet.IsConnRefusedErr(pingErr) { return false, store.ErrNotConnected } return false, pingErr } return true, nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 9.1K bytes - Viewed (0) -
cmd/testdata/undeleteable-object.tgz
","value":""},{"key":"password","value":""},{"key":"token","value":""},{"key":"tls","value":"off"},{"key":"tls_skip_verify","value":"off"},{"key":"cert_authority","value":""},{"key":"client_cert","value":""},{"key":"client_key","value":""},{"key":"ping_interval","value":"0"},{"key":"jetstream","value":"off"},{"key":"streaming","value":"off"},{"key":"streaming_async","value":"off"},{"key":"streaming_max_pub_acks_in_flight","value":"0"},{"key":"streaming_cluster_id","value":""},{"key":"queue_dir",...
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 00:31:12 GMT 2024 - 8.7M bytes - Viewed (0) -
internal/crypto/error.go
errInvalidInternalSealAlgorithm = Errorf("The internal seal algorithm is invalid and not supported") ) // errOutOfEntropy indicates that the a source of randomness (PRNG) wasn't able // to produce enough random data. This is fatal error and should cause a panic.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 4.4K bytes - Viewed (0) -
cmd/erasure-object.go
// Prefer local disks prefer[index] = disk.Hostname() == "" } written, err := erasure.Decode(ctx, writer, readers, partOffset, partLength, partSize, prefer) // Note: we should not be defer'ing the following closeBitrotReaders() call as // we are inside a for loop i.e if we use defer, we would accumulate a lot of open files by the time // we return from this function. closeBitrotReaders(readers)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
internal/event/target/mysql.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 11.5K bytes - Viewed (0) -
internal/grid/grid.go
biggerBufMin = 32 << 10 // This is the maximum size of bigger buffers. biggerBufMax = maxBufferSize // If there is a queue, merge up to this many messages. maxMergeMessages = 30 // clientPingInterval will ping the remote handler every 15 seconds. // Clients disconnect when we exceed 2 intervals. clientPingInterval = 15 * time.Second // Deadline for single (non-streaming) requests to complete.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 15:56:18 GMT 2024 - 4.8K bytes - Viewed (0) -
docs/screenshots/pic1.png
pic1.png...
PNG Image - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Jun 18 03:27:04 GMT 2021 - 314K bytes - Viewed (0) -
docs/screenshots/pic2.png
pic2.png...
PNG Image - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Jun 18 03:27:04 GMT 2021 - 1.6M bytes - Viewed (0) -
internal/grid/muxserver.go
if m.outBlock == nil { // Closed return } select { case m.outBlock <- struct{}{}: default: gridLogIf(m.ctx, errors.New("output unblocked overflow")) } } func (m *muxServer) ping(seq uint32) pongMsg { if !m.checkSeq(seq) { msg := fmt.Sprintf("receive sequence number mismatch. want %d, got %d", m.RecvSeq, seq) return pongMsg{Err: &msg} } select { case <-m.ctx.Done():
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.1K bytes - Viewed (0)