Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for getMaxTimeout (0.07 sec)

  1. internal/config/drive/drive.go

    // Update - updates the config with latest values
    func (c *Config) Update(new Config) error {
    	configLk.Lock()
    	defer configLk.Unlock()
    	c.MaxTimeout = getMaxTimeout(new.MaxTimeout)
    	return nil
    }
    
    // GetMaxTimeout - returns the per call drive operation timeout
    func (c *Config) GetMaxTimeout() time.Duration {
    	return c.GetOPTimeout()
    }
    
    // GetOPTimeout - returns the per call drive operation timeout
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 3K bytes
    - Viewed (0)
  2. cmd/bitrot-streaming.go

    	buf := globalBytePoolCap.Load().Get()
    	rb := ringbuffer.NewBuffer(buf[:cap(buf)]).SetBlocking(true)
    
    	bw := &streamingBitrotWriter{
    		iow:          ioutil.NewDeadlineWriter(rb.WriteCloser(), globalDriveConfig.GetMaxTimeout()),
    		closeWithErr: rb.CloseWithError,
    		h:            h,
    		shardSize:    shardSize,
    		canClose:     &sync.WaitGroup{},
    		byteBuf:      buf,
    	}
    	bw.canClose.Add(1)
    	go func() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 21 12:20:54 UTC 2024
    - 6K bytes
    - Viewed (0)
Back to top