Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 69 for nerrs (0.01 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. cmd/bucket-policy-handlers_test.go

    					return
    				}
    				mu.Lock()
    				errs++
    				mu.Unlock()
    				return
    			}
    			mu.Lock()
    			ok++
    			mu.Unlock()
    		}()
    	}
    	close(start)
    	wg.Wait()
    	if ok != 1 {
    		t.Fatalf("want 1 ok, got %d", ok)
    	}
    	if errs != n-1 {
    		t.Fatalf("want %d errors, got %d", n-1, errs)
    	}
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 32.9K bytes
    - Viewed (0)
Back to top