Search Options

Results per page
Sort
Preferred Languages
Advance

Results 621 - 630 of 1,384 for funcs (0.05 sec)

  1. cmd/admin-handlers-pools.go

    	errDecommissionRebalanceAlreadyRunning = errors.New("Decommission cannot be started, rebalance is already in progress")
    )
    
    func (a adminAPIHandlers) StartDecommission(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    	objectAPI, _ := validateAdminReq(ctx, w, r, policy.DecommissionAdminAction)
    	if objectAPI == nil {
    		return
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 00:22:30 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool-rebalance_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgrebalanceInfo(b *testing.B) {
    	v := rebalanceInfo{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgrebalanceInfo(b *testing.B) {
    	v := rebalanceInfo{}
    	bts := make([]byte, 0, v.Msgsize())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 25 19:36:57 UTC 2022
    - 11K bytes
    - Viewed (0)
  3. cmd/erasure-decode.go

    		stashBuffer:   b,
    	}
    }
    
    // Done will release any resources used by the parallelReader.
    func (p *parallelReader) Done() {
    	if p.stashBuffer != nil {
    		globalBytePoolCap.Load().Put(p.stashBuffer)
    		p.stashBuffer = nil
    	}
    }
    
    // preferReaders can mark readers as preferred.
    // These will be chosen before others.
    func (p *parallelReader) preferReaders(prefer []bool) {
    	if len(prefer) != len(p.orgReaders) {
    		return
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  4. cmd/bootstrap-messages.go

    	mu   sync.RWMutex
    	info []madmin.TraceInfo
    }
    
    var globalBootstrapTracer = &bootstrapTracer{}
    
    func (bs *bootstrapTracer) Record(info madmin.TraceInfo) {
    	bs.mu.Lock()
    	defer bs.mu.Unlock()
    
    	if len(bs.info) > bootstrapTraceLimit {
    		return
    	}
    	bs.info = append(bs.info, info)
    }
    
    func (bs *bootstrapTracer) Events() []madmin.TraceInfo {
    	traceInfo := make([]madmin.TraceInfo, 0, bootstrapTraceLimit)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 23 10:07:06 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  5. cmd/http-stats.go

    }
    
    // Increase internode total input bytes
    func (s *connStats) incInternodeInputBytes(n int64) {
    	atomic.AddUint64(&s.internodeInputBytes, uint64(n))
    }
    
    // Increase internode total output bytes
    func (s *connStats) incInternodeOutputBytes(n int64) {
    	atomic.AddUint64(&s.internodeOutputBytes, uint64(n))
    }
    
    // Return internode total input bytes
    func (s *connStats) getInternodeInputBytes() uint64 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  6. src/cmd/asm/internal/asm/asm.go

    		return false
    	}
    	return true
    }
    
    // evalInteger evaluates an integer constant for a pseudo-op.
    func (p *Parser) evalInteger(pseudo string, operands []lex.Token) int64 {
    	addr := p.address(operands)
    	return p.getConstantPseudo(pseudo, &addr)
    }
    
    // validImmediate checks that addr represents an immediate constant.
    func (p *Parser) validImmediate(pseudo string, addr *obj.Addr) bool {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Oct 21 14:11:44 UTC 2024
    - 25.5K bytes
    - Viewed (0)
  7. tests/transaction_test.go

    		t.Fatalf("Transaction should get error when using cancelled context")
    	}
    }
    
    func TestTransactionWithBlock(t *testing.T) {
    	assertPanic := func(f func()) {
    		defer func() {
    			if r := recover(); r == nil {
    				t.Fatalf("The code did not panic")
    			}
    		}()
    		f()
    	}
    
    	// rollback
    	err := DB.Transaction(func(tx *gorm.DB) error {
    		user := *GetUser("transaction-block", Config{})
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sat Sep 14 12:58:29 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  8. docs/debugging/xl-meta/main.go

    // afterVersion returns the payload after the version, if any.
    func (x xlMetaInlineData) afterVersion() []byte {
    	if len(x) == 0 {
    		return x
    	}
    	return x[1:]
    }
    
    // versionOK returns whether the version is ok.
    func (x xlMetaInlineData) versionOK() bool {
    	if len(x) == 0 {
    		return true
    	}
    	return x[0] > 0 && x[0] <= xlMetaInlineDataVer
    }
    
    func (x xlMetaInlineData) json(value bool) ([]byte, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 05 11:57:44 UTC 2024
    - 40.3K bytes
    - Viewed (0)
  9. internal/ringbuffer/ring_buffer_benchmark_test.go

    	buf := make([]byte, 512)
    
    	go func() {
    		for {
    			rb.Read(buf)
    		}
    	}()
    
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		rb.Write(data)
    	}
    }
    
    func BenchmarkRingBuffer_AsyncReadBlocking(b *testing.B) {
    	const sz = 512
    	const buffers = 10
    	rb := New(sz * buffers)
    	rb.SetBlocking(true)
    	data := []byte(strings.Repeat("a", sz))
    	buf := make([]byte, sz)
    
    	go func() {
    		for {
    			rb.Read(buf)
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  10. internal/s3select/sql/errors.go

    	cause      error
    }
    
    func (err *s3Error) Cause() error {
    	return err.cause
    }
    
    func (err *s3Error) ErrorCode() string {
    	return err.code
    }
    
    func (err *s3Error) ErrorMessage() string {
    	return err.message
    }
    
    func (err *s3Error) HTTPStatusCode() int {
    	return err.statusCode
    }
    
    func (err *s3Error) Error() string {
    	return err.message
    }
    
    func errInvalidDataType(err error) *s3Error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 2.6K bytes
    - Viewed (0)
Back to top