Search Options

Results per page
Sort
Preferred Languages
Advance

Results 321 - 330 of 1,387 for funcs (0.03 sec)

  1. cmd/main.go

    	return strings.NewReader(banner.String())
    }
    
    func printMinIOVersion(c *cli.Context) {
    	io.Copy(c.App.Writer, versionBanner(c))
    }
    
    var debugNoExit = env.Get("_MINIO_DEBUG_NO_EXIT", "") != ""
    
    // Main main for minio server.
    func Main(args []string) {
    	// Set the minio app name.
    	appName := filepath.Base(args[0])
    
    	if debugNoExit {
    		freeze := func(_ int) {
    			// Infinite blocking op
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 30 22:59:48 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  2. cmd/bitrot-streaming.go

    // The output is written to the supplied writer w.
    func newStreamingBitrotWriterBuffer(w io.Writer, algo BitrotAlgorithm, shardSize int64) io.Writer {
    	return &streamingBitrotWriter{iow: ioutil.NopCloser(w), h: algo.New(), shardSize: shardSize, canClose: nil, closeWithErr: func(err error) {}}
    }
    
    // Returns streaming bitrot writer implementation.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 21 12:20:54 UTC 2024
    - 6K bytes
    - Viewed (0)
  3. cmd/xl-storage-format-v2_test.go

    		},
    	}
    	for _, test := range testCases {
    		t.Run(test.name, func(t *testing.T) {
    			// Run multiple times, shuffling the input order.
    			for i := int64(0); i < 50; i++ {
    				t.Run(fmt.Sprint(i), func(t *testing.T) {
    					rng := rand.New(rand.NewSource(i))
    					rng.Shuffle(len(test.input), func(i, j int) {
    						test.input[i], test.input[j] = test.input[j], test.input[i]
    					})
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Mar 08 17:50:48 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  4. internal/logger/logonce.go

    )
    
    // LogOnce provides the function type for logger.LogOnceIf() function
    type LogOnce func(ctx context.Context, err error, id string, errKind ...interface{})
    
    type onceErr struct {
    	Err   error
    	Count int
    }
    
    // Holds a map of recently logged errors.
    type logOnceType struct {
    	IDMap map[string]onceErr
    	sync.Mutex
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  5. internal/logger/reqinfo.go

    		ObjectName:   object,
    	}
    }
    
    // AppendTags - appends key/val to ReqInfo.tags
    func (r *ReqInfo) AppendTags(key, val string) *ReqInfo {
    	if r == nil {
    		return nil
    	}
    	r.Lock()
    	defer r.Unlock()
    	r.tags = append(r.tags, KeyVal{key, val})
    	return r
    }
    
    // SetTags - sets key/val to ReqInfo.tags
    func (r *ReqInfo) SetTags(key, val string) *ReqInfo {
    	if r == nil {
    		return nil
    	}
    	r.Lock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  6. cni/pkg/ipset/ipset.go

    		err = errors.Join(err, v6err)
    	}
    	return set, err
    }
    
    func (m *IPSet) DestroySet() error {
    	var err error
    	err = m.Deps.destroySet(m.V4Name)
    
    	if m.V6Name != "" {
    		v6err := m.Deps.destroySet(m.V6Name)
    		err = errors.Join(err, v6err)
    	}
    	return err
    }
    
    func (m *IPSet) AddIP(ip netip.Addr, ipProto uint8, comment string, replace bool) error {
    	ipToInsert := ip.Unmap()
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Apr 30 22:24:38 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  7. src/bytes/boundary_test.go

    		t.Fatalf("mprotect high failed %s\n", err)
    	}
    	return b[pagesize : 2*pagesize]
    }
    
    func TestEqualNearPageBoundary(t *testing.T) {
    	t.Parallel()
    	b := dangerousSlice(t)
    	for i := range b {
    		b[i] = 'A'
    	}
    	for i := 0; i <= len(b); i++ {
    		Equal(b[:i], b[len(b)-i:])
    		Equal(b[len(b)-i:], b[:i])
    	}
    }
    
    func TestIndexByteNearPageBoundary(t *testing.T) {
    	t.Parallel()
    	b := dangerousSlice(t)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Nov 30 20:05:58 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  8. src/cmd/addr2line/addr2line_test.go

    // GO_ADDR2LINETEST_IS_ADDR2LINE is set, and runs the tests otherwise.
    func TestMain(m *testing.M) {
    	if os.Getenv("GO_ADDR2LINETEST_IS_ADDR2LINE") != "" {
    		main()
    		os.Exit(0)
    	}
    
    	os.Setenv("GO_ADDR2LINETEST_IS_ADDR2LINE", "1") // Set for subprocesses to inherit.
    	os.Exit(m.Run())
    }
    
    func loadSyms(t *testing.T, dbgExePath string) map[string]string {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Sep 06 13:23:48 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/hash/ChecksumHashFunctionTest.java

        checksum.update(bytes, 0, bytes.length);
        long value = checksum.getValue();
    
        String toString = "name";
        HashFunction func = new ChecksumHashFunction(supplier, 32, toString);
        assertEquals(toString, func.toString());
        assertEquals(value, func.hashBytes(bytes).padToLong());
      }
    
      private static void assertHash32(
          int expected, ImmutableSupplier<Checksum> supplier, String input) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jan 30 14:33:12 UTC 2018
    - 3.1K bytes
    - Viewed (0)
  10. src/bufio/scan_test.go

    type endlessZeros struct{}
    
    func (endlessZeros) Read(p []byte) (int, error) {
    	return 0, nil
    }
    
    func TestBadReader(t *testing.T) {
    	scanner := NewScanner(endlessZeros{})
    	for scanner.Scan() {
    		t.Fatal("read should fail")
    	}
    	err := scanner.Err()
    	if err != io.ErrNoProgress {
    		t.Errorf("unexpected error: %v", err)
    	}
    }
    
    func TestScanWordsExcessiveWhiteSpace(t *testing.T) {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Sep 22 16:22:42 UTC 2023
    - 14.3K bytes
    - Viewed (0)
Back to top