Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 165 for adjust (4.17 sec)

  1. docs/config/README.md

    settings allow for more staggered delay in terms of usage calculation. The scanner adapts to the system speed and completely pauses when the system is under load. It is possible to adjust the speed of the scanner and thereby the latency of updates being reflected. The delays between each operation of the scanner can be adjusted by the `mc admin config set alias/ delay=15.0`. By default the value is `10.0`. This means the scanner will sleep *10x* the time each operation takes.
    
    In most setups...
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 11 21:48:54 GMT 2023
    - 17.7K bytes
    - Viewed (0)
  2. cmd/object-multipart-handlers.go

    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	// We have to adjust the size of encrypted parts since encrypted parts
    	// are slightly larger due to encryption overhead.
    	// Further, we have to adjust the ETags of parts when using SSE-S3.
    	// Due to AWS S3, SSE-S3 encrypted parts return the plaintext ETag
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 39K bytes
    - Viewed (0)
  3. cmd/encryption-v1.go

    				names = append(names, object.Name)
    			}
    		}
    
    		// If there are no SSE-S3 single-part objects
    		// we can skip the decryption process. However,
    		// we still have to adjust the size and ETag
    		// of SSE-C and SSE-KMS objects.
    		if len(SSES3SinglePartObjects) == 0 {
    			for i := range batch {
    				size, err := batch[i].GetActualSize()
    				if err != nil {
    					return err
    				}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 36.5K bytes
    - Viewed (0)
  4. cmd/dynamic-timeouts.go

    			// Make copy on stack in order to call adjust()
    			logCopy := [dynamicTimeoutLogSize]time.Duration{}
    			copy(logCopy[:], dt.log[:])
    
    			// reset log entries
    			atomic.StoreInt64(&dt.entries, 0)
    			dt.mutex.Unlock()
    
    			dt.adjust(logCopy)
    			return
    		}
    		dt.mutex.Unlock()
    	}
    }
    
    // adjust changes the value of the dynamic timeout based on the
    // previous results
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Aug 19 23:21:05 GMT 2022
    - 4.5K bytes
    - Viewed (0)
  5. cmd/os-rename_nolinux.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"os"
    )
    
    // RenameSys is low level call in case of non-Linux this just uses os.Rename()
    func RenameSys(src, dst string) (err error) {
    	return os.Rename(src, dst)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 15 01:09:38 GMT 2024
    - 985 bytes
    - Viewed (0)
  6. internal/logger/target/kafka/kafka_scram_client_contrib.go

    	if err != nil {
    		return err
    	}
    	x.ClientConversation = x.Client.NewConversation()
    	return nil
    }
    
    // Step takes a string provided from a server (or just an empty string for the
    // very first conversation step) and attempts to move the authentication
    // conversation forward.  It returns a string to be sent to the server or an
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 09 04:04:01 GMT 2023
    - 3.3K bytes
    - Viewed (1)
  7. cmd/xl-storage-meta-inline.go

    			keys = append(keys, foundKey)
    			plSize += len(foundKey)
    		} else {
    			keys = append(keys, []byte(newKey))
    			plSize += len(newKey)
    			found = true
    		}
    	}
    	// If not found, just return.
    	if !found {
    		return false
    	}
    
    	// Reserialize...
    	x.serialize(plSize, keys, vals)
    	return true
    }
    
    // remove will remove one or more keys.
    // Returns true if any key was found.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.5K bytes
    - Viewed (0)
  8. internal/s3select/parquet/reader.go

    		// binary arrays) - perhaps we need to check the annotation to
    		// ensure it's UTF8 encoded.
    		value = string(val)
    	case [12]byte:
    		// TODO: This is returned for the parquet INT96 type. We just
    		// treat it same as []byte (but AWS S3 treats it as a large int)
    		// - fix this later.
    		value = string(val[:])
    	case int32:
    		value = int64(val)
    		if logicalType := se.GetLogicalType(); logicalType != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 14 13:54:47 GMT 2022
    - 4.5K bytes
    - Viewed (0)
  9. internal/logger/console.go

    	// to use some ANSI control escapes to cursor color state
    	// and freely move in the screen.
    	for _, line := range strings.Split(errMsg, "\n") {
    		if len(line) == 0 {
    			// No more text to print, just quit.
    			break
    		}
    
    		for {
    			// Save the attributes of the current cursor helps
    			// us save the text color of the passed error message
    			ansiSaveAttributes()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:57:52 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  10. cmd/untar.go

    			wg.Wait()
    			extra := ""
    			if n > 0 {
    				extra = fmt.Sprintf(" after %d successful object(s)", n)
    			}
    			return fmt.Errorf("tar file error: %w%s", err, extra)
    
    		// if the header is nil, just skip it (not sure how this happens)
    		case header == nil:
    			continue
    		}
    
    		name := header.Name
    		switch path.Clean(name) {
    		case ".", slashSeparator:
    			continue
    		}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6K bytes
    - Viewed (0)
Back to top