- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 69 for nerrs (0.02 sec)
-
cmd/metrics-v3-system-network.go
connStats := globalConnStats.toServerConnStats() rpcStats := rest.GetRPCStats() if globalIsDistErasure { m.Set(internodeErrorsTotal, float64(rpcStats.Errs)) m.Set(internodeDialErrorsTotal, float64(rpcStats.DialErrs)) m.Set(internodeDialAvgTimeNanos, float64(rpcStats.DialAvgDuration)) m.Set(internodeSentBytesTotal, float64(connStats.internodeOutputBytes))
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Mar 10 09:15:15 UTC 2024 - 2.4K bytes - Viewed (0) -
cmd/batch-expire.go
for { count := len(objsToDel) if count == 0 { break } if count > maxDeleteList { count = maxDeleteList } _, errs := api.DeleteObjects(ctx, r.Bucket, objsToDel[:count], opts) allErrs = append(allErrs, errs...) // Next batch of deletion objsToDel = objsToDel[count:] } return allErrs } const ( batchExpireName = "batch-expire.bin"Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Apr 22 11:16:32 UTC 2025 - 23K bytes - Viewed (0) -
internal/event/target/amqp.go
var err error var conn *amqp091.Connection var ch *amqp091.Channel isAMQPClosedErr := func(err error) bool { if err == amqp091.ErrClosed { return true } if nerr, ok := err.(*net.OpError); ok { return (nerr.Err.Error() == "use of closed network connection") } return false } target.connMutex.Lock() defer target.connMutex.Unlock() if target.conn != nil {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Thu Aug 21 04:25:07 UTC 2025 - 10K bytes - Viewed (0) -
cmd/erasure-multipart.go
if write { quorum = writeQuorum } // List all online disks. _, modTime, etag := listOnlineDisks(storageDisks, partsMetadata, errs, quorum) if write { err = reduceWriteQuorumErrs(ctx, errs, objectOpIgnoredErrs, writeQuorum) } else { err = reduceReadQuorumErrs(ctx, errs, objectOpIgnoredErrs, readQuorum) } if err != nil { return fi, nil, err } // Pick one from the first valid metadata.Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Oct 24 04:05:31 UTC 2025 - 47.1K bytes - Viewed (0) -
internal/rest/client.go
r.errorStatus(err) return err } func (r *respBodyMonitor) errorStatus(err error) { if xnet.IsNetworkOrHostDown(err, r.expectTimeouts) { r.errorStatusOnce.Do(func() { atomic.AddUint64(&globalStats.errs, 1) }) } } // dumpHTTP - dump HTTP request and response. func (c *Client) dumpHTTP(req *http.Request, resp *http.Response) { // Starts http dump.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 14.7K bytes - Viewed (0) -
cmd/storage-datatypes_gen.go
if err != nil { err = msgp.WrapError(err, "Errs") return } if cap(z.Errs) >= int(zb0002) { z.Errs = (z.Errs)[:zb0002] } else { z.Errs = make([]string, zb0002) } for za0001 := range z.Errs { z.Errs[za0001], err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "Errs", za0001) return } } default:Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 151.7K bytes - Viewed (0) -
impl/maven-cli/src/test/java/org/apache/maven/cling/invoker/mvn/MavenInvokerTestSupport.java
logs.put(goal, stdout.toString()); if (exception != null) { throw exception; } else { assertEquals(0, exitCode, "OUT:" + stdout + "\nERR:" + stderr); } } } return logs; } protected ClassWorld createClassWorld() {Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Tue Oct 21 12:17:55 UTC 2025 - 6.8K bytes - Viewed (0) -
docs/en/docs/advanced/events.md
Because of that, it's now recommended to instead use the `lifespan` as explained above. ## Technical Details { #technical-details } Just a technical detail for the curious nerds. 🤓
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Wed Dec 17 20:41:43 UTC 2025 - 7.9K bytes - Viewed (0) -
docs/pt/docs/advanced/events.md
Por causa disso, agora é recomendado usar o `lifespan`, como explicado acima. ## Detalhes técnicos { #technical-details } Apenas um detalhe técnico para nerds curiosos. 🤓Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Wed Dec 17 20:41:43 UTC 2025 - 8.8K bytes - Viewed (0) -
cmd/bucket-policy-handlers_test.go
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 32.9K bytes - Viewed (0)