Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 50 of 71 for nerrs (0.03 seconds)

  1. cmd/bucket-handlers.go

    	deleteList := toNames(objectsToDelete)
    	dObjects, errs := deleteObjectsFn(ctx, bucket, deleteList, ObjectOptions{
    		PrefixEnabledFn:  vc.PrefixEnabled,
    		VersionSuspended: vc.Suspended(),
    	})
    
    	// Are all objects saying bucket not found?
    	if isAllBucketsNotFound(errs) {
    		writeErrorResponse(ctx, w, toAPIError(ctx, errs[0]), r.URL)
    		return
    	}
    
    	for i := range errs {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 63.9K bytes
    - Click Count (0)
  2. doc/README.md

    ## For the release team
    
    The `relnote` tool, at `golang.org/x/build/cmd/relnote`, operates on the files
    in `doc/next`.
    
    As a release cycle nears completion, run `relnote todo` to get a list of
    unfinished release note work.
    
    To prepare the release notes for a release, run `relnote generate`.
    That will merge the `.md` files in `next` into a single file.
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon Jul 22 17:55:04 GMT 2024
    - 3.1K bytes
    - Click Count (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 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Aug 21 04:25:07 GMT 2025
    - 10K bytes
    - Click Count (0)
  4. 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))
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 10 09:15:15 GMT 2024
    - 2.4K bytes
    - Click Count (0)
  5. 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.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 47.1K bytes
    - Click Count (0)
  6. 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.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 14.7K bytes
    - Click Count (0)
  7. src/bytes/reader_test.go

    // regardless of the presence of a WriteTo method.
    func TestReaderCopyNothing(t *testing.T) {
    	type nErr struct {
    		n   int64
    		err error
    	}
    	type justReader struct {
    		io.Reader
    	}
    	type justWriter struct {
    		io.Writer
    	}
    	discard := justWriter{io.Discard} // hide ReadFrom
    
    	var with, withOut nErr
    	with.n, with.err = io.Copy(discard, NewReader(nil))
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon Dec 13 18:45:54 GMT 2021
    - 8K bytes
    - Click Count (0)
  8. 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:
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 151.7K bytes
    - Click Count (0)
  9. 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)
    	}
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 32.9K bytes
    - Click Count (0)
  10. 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. 🤓
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 20:41:43 GMT 2025
    - 7.9K bytes
    - Click Count (0)
Back to Top