Search Options

Results per page
Sort
Preferred Languages
Advance

Results 321 - 330 of 1,385 for _func (0.05 sec)

  1. cmd/object-handlers-common.go

    }
    
    // canonicalizeETag returns ETag with leading and trailing double-quotes removed,
    // if any present
    func canonicalizeETag(etag string) string {
    	return etagRegex.ReplaceAllString(etag, "$1")
    }
    
    // isETagEqual return true if the canonical representations of two ETag strings
    // are equal, false otherwise
    func isETagEqual(left, right string) bool {
    	if strings.TrimSpace(right) == "*" {
    		return true
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 06:33:53 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. cmd/batch-expire_gen.go

    package cmd
    
    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    import (
    	"time"
    
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *BatchJobExpire) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    		zb0001--
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 01 12:53:30 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  6. cmd/erasure-decode_test.go

    }
    
    func BenchmarkErasureDecode_4_64KB(b *testing.B) {
    	const size = 64 * 1024
    	b.Run(" 00|00 ", func(b *testing.B) { benchmarkErasureDecode(2, 2, 0, 0, size, b) })
    	b.Run(" 00|X0 ", func(b *testing.B) { benchmarkErasureDecode(2, 2, 0, 1, size, b) })
    	b.Run(" X0|00 ", func(b *testing.B) { benchmarkErasureDecode(2, 2, 1, 0, size, b) })
    	b.Run(" X0|X0 ", func(b *testing.B) { benchmarkErasureDecode(2, 2, 1, 1, size, b) })
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  7. 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)
  8. internal/bucket/bandwidth/measurement.go

    }
    
    // newBucketMeasurement creates a new instance of the measurement with the initial start time.
    func newBucketMeasurement(initTime time.Time) *bucketMeasurement {
    	return &bucketMeasurement{
    		startTime: initTime,
    	}
    }
    
    // incrementBytes add bytes reported for a bucket.
    func (m *bucketMeasurement) incrementBytes(bytes uint64) {
    	atomic.AddUint64(&m.bytesSinceLastWindow, bytes)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 03 20:41:51 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  9. cmd/data-usage-cache_gen.go

    func (z *allTierStats) Msgsize() (s int) {
    	s = 1 + 3 + msgp.MapHeaderSize
    	if z.Tiers != nil {
    		for za0001, za0002 := range z.Tiers {
    			_ = za0002
    			s += msgp.StringPrefixSize + len(za0001) + 1 + 3 + msgp.Uint64Size + 3 + msgp.IntSize + 3 + msgp.IntSize
    		}
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 75K bytes
    - Viewed (0)
  10. istioctl/pkg/cli/context.go

    	}
    	return f.clients[rev], nil
    }
    
    func (f *fakeInstance) CLIClient() (kube.CLIClient, error) {
    	return f.CLIClientWithRevision("")
    }
    
    func (f *fakeInstance) CLIClientsForContexts(contexts []string) ([]kube.CLIClient, error) {
    	c, err := f.CLIClientWithRevision("")
    	if err != nil {
    		return nil, err
    	}
    	return []kube.CLIClient{c}, nil
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 23 19:31:32 UTC 2024
    - 8.9K bytes
    - Viewed (0)
Back to top