Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 129 for next (0.14 sec)

  1. cmd/kms-handlers.go

    	}
    
    	pattern := r.Form.Get("pattern")
    	if !strings.Contains(pattern, "*") {
    		pattern += "*"
    	}
    
    	var values []kes.KeyInfo
    	for name, err := keys.SeekTo(ctx, pattern); err != io.EOF; name, err = keys.Next(ctx) {
    		if err != nil {
    			writeCustomErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInternalError), err.Error(), r.URL)
    			return
    		}
    		values = append(values, kes.KeyInfo{
    			Name: name,
    		})
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 01 21:09:42 GMT 2024
    - 20.7K bytes
    - Viewed (0)
  2. cmd/encryption-v1_test.go

    				t.Errorf("Case %d: test failed: %d %d %d %d %d", i, o, l, skip, sn, ps)
    			}
    		}
    
    		kb32 := int64(32) * humanize.KiByte
    		if test.decSz >= (64+32)*humanize.KiByte {
    			// Skip the first 32Kib, and read the next 64Kib
    			o, l, skip, sn, ps, err := test.oi.GetDecryptedRange(&HTTPRangeSpec{false, kb32, 3*kb32 - 1})
    			if err != nil {
    				t.Errorf("Case %d: unexpected err: %v", i, err)
    			}
    			rLen := (pkgSz + 32) * 2
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Sep 24 04:17:08 GMT 2022
    - 19.9K bytes
    - Viewed (0)
  3. internal/dsync/dsync_test.go

    		mu := PaddedMutex{NewDRWMutex(ds, "")}
    		for pb.Next() {
    			mu.Lock(id, source)
    			mu.Unlock(context.Background())
    		}
    	})
    }
    
    func benchmarkMutex(b *testing.B, slack, work bool) {
    	b.ResetTimer()
    	b.ReportAllocs()
    
    	mu := NewDRWMutex(ds, "")
    	if slack {
    		b.SetParallelism(10)
    	}
    	b.RunParallel(func(pb *testing.PB) {
    		foo := 0
    		for pb.Next() {
    			mu.Lock(id, source)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Dec 24 03:49:07 GMT 2022
    - 11K bytes
    - Viewed (0)
  4. internal/s3select/message.go

    				writer.write(endMessage)
    			} else {
    				for payload.Len() > 0 {
    					copiedLen := copy(writer.payloadBuffer[writer.payloadBufferIndex:], payload.Bytes())
    					writer.payloadBufferIndex += copiedLen
    					payload.Next(copiedLen)
    
    					// If buffer is filled, flush it now!
    					freeSpace := bufLength - writer.payloadBufferIndex
    					if freeSpace == 0 {
    						if !writer.flushRecords() {
    							quitFlag = true
    							break
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Aug 30 15:26:43 GMT 2022
    - 15.2K bytes
    - Viewed (0)
  5. cmd/object-api-datatypes.go

    	// A character used to truncate the object prefixes.
    	// NOTE: only supported delimiter is '/'.
    	Delimiter string
    
    	// CommonPrefixes contains all (if there are any) keys between Prefix and the
    	// next occurrence of the string specified by delimiter.
    	CommonPrefixes []string
    
    	EncodingType string // Not supported yet.
    }
    
    // TransitionedObject transitioned object tier and status.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 20.8K bytes
    - Viewed (0)
  6. internal/grid/benchmark_test.go

    				b.RunParallel(func(pb *testing.PB) {
    					rng := rand.New(rand.NewSource(time.Now().UnixNano()))
    					n := 0
    					var latency int64
    					managers := grid.Managers
    					hosts := grid.Hosts
    					for pb.Next() {
    						// Pick a random manager.
    						src, dst := rng.Intn(len(managers)), rng.Intn(len(managers))
    						if src == dst {
    							dst = (dst + 1) % len(managers)
    						}
    						local := managers[src]
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 12.2K bytes
    - Viewed (0)
  7. internal/grid/connection.go

    					cancel(ErrDisconnected)
    					return
    				}
    				var next []byte
    				next, remain, err = msgp.ReadBytesZC(remain)
    				if err != nil {
    					gridLogIf(ctx, fmt.Errorf("ws read merged: %w", err))
    					cancel(ErrDisconnected)
    					return
    				}
    
    				m.Payload = nil
    				subID, _, err = m.parse(next)
    				if err != nil {
    					gridLogIf(ctx, fmt.Errorf("ws parse merged: %w", err))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
  8. cmd/api-response.go

    	// request to get next set of objects. Server lists objects in alphabetical
    	// order Note: This element is returned only if you have delimiter request parameter
    	// specified. If response does not include the NextMaker and it is truncated,
    	// you can use the value of the last Key in the response as the marker in the
    	// subsequent request to get the next set of object keys.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 33.3K bytes
    - Viewed (2)
  9. cmd/object_api_suite_test.go

    func newTestReaderNoEOF(data []byte) io.Reader {
    	return &testOneByteReadNoEOF{false, data}
    }
    
    // testOneByteReadNoEOF - implements io.Reader which returns 1 byte and nil error, but
    // returns io.EOF on the next Read().
    type testOneByteReadNoEOF struct {
    	eof  bool
    	data []byte
    }
    
    func (r *testOneByteReadNoEOF) Read(p []byte) (n int, err error) {
    	if r.eof {
    		return 0, io.EOF
    	}
    	n = copy(p, r.data)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 32.3K bytes
    - Viewed (0)
  10. cmd/metacache-stream_test.go

    shifts.wb.expect-noinput", "src/compress/flate/testdata/huffman-text-shift.dyn.expect", "src/compress/flate/testdata/huffman-text-shift.dyn.expect-noinput", "src/compress/flate/testdata/huffman-text-shift.golden", "src/compress/flate/testdata/huffman-text-shift.in", "src/compress/flate/testdata/huffman-text-shift.wb.expect", "src/compress/flate/testdata/huffman-text-shift.wb.expect-noinput", "src/compress/flate/testdata/huffman-text.dyn.expect", "src/compress/flate/testdata/huffman-text.dyn.expect-noinput",...
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 15K bytes
    - Viewed (0)
Back to top