Search Options

Results per page
Sort
Preferred Languages
Advance

Results 771 - 780 of 1,795 for func (4 sec)

  1. internal/hash/crc.go

    // Modified for hash/crc64 by Klaus Post, 2024.
    func gf2MatrixTimes(mat []uint64, vec uint64) uint64 {
    	var sum uint64
    
    	for vec != 0 {
    		if vec&1 != 0 {
    			sum ^= mat[0]
    		}
    		vec >>= 1
    		mat = mat[1:]
    	}
    	return sum
    }
    
    func gf2MatrixSquare(square, mat []uint64) {
    	if len(square) != len(mat) {
    		panic("square matrix size mismatch")
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Jan 20 14:49:07 UTC 2025
    - 5.8K bytes
    - Viewed (0)
  2. cmd/batch-expire.go

    )
    
    type objInfoCache map[string]*ObjectInfo
    
    func newObjInfoCache() objInfoCache {
    	return objInfoCache(make(map[string]*ObjectInfo))
    }
    
    func (oiCache objInfoCache) Add(toDel ObjectToDelete, oi *ObjectInfo) {
    	oiCache[fmt.Sprintf("%s-%s", toDel.ObjectName, toDel.VersionID)] = oi
    }
    
    func (oiCache objInfoCache) Get(toDel ObjectToDelete) (*ObjectInfo, bool) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Apr 22 11:16:32 UTC 2025
    - 23K bytes
    - Viewed (0)
  3. cmd/shared-lock.go

    				break keepLock
    			case ld.lockContext <- lkctx:
    				// Send the lock context to anyone asking for it
    			}
    		}
    	}
    }
    
    func mergeContext(ctx1, ctx2 context.Context) (context.Context, context.CancelFunc) {
    	ctx, cancel := context.WithCancel(context.Background())
    	go func() {
    		select {
    		case <-ctx1.Done():
    		case <-ctx2.Done():
    		// The lock acquirer decides to cancel, exit this goroutine
    		case <-ctx.Done():
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Feb 13 09:26:38 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  4. internal/grid/grid_types_test.go

    type testRequest struct {
    	Num    int
    	String string
    }
    
    type testResponse struct {
    	OrgNum    int
    	OrgString string
    	Embedded  testRequest
    }
    
    func newTestRequest() *testRequest {
    	return &testRequest{}
    }
    
    func newTestResponse() *testResponse {
    	return &testResponse{}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 1.1K bytes
    - Viewed (0)
  5. internal/disk/fdatasync_unix.go

    package disk
    
    import (
    	"os"
    	"syscall"
    )
    
    // Fdatasync is fsync on freebsd/darwin
    func Fdatasync(f *os.File) error {
    	return syscall.Fsync(int(f.Fd()))
    }
    
    // FadviseDontNeed is a no-op
    func FadviseDontNeed(f *os.File) error {
    	return nil
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Sep 29 23:40:28 UTC 2021
    - 1.1K bytes
    - Viewed (0)
  6. internal/disk/fdatasync_unsupported.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package disk
    
    import (
    	"os"
    )
    
    // Fdatasync is a no-op
    func Fdatasync(f *os.File) error {
    	return nil
    }
    
    // FadviseDontNeed is a no-op
    func FadviseDontNeed(f *os.File) error {
    	return nil
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Sep 29 23:40:28 UTC 2021
    - 1K bytes
    - Viewed (0)
  7. internal/ioutil/read_file.go

    // A successful call returns err == nil, not err == EOF.
    // Because ReadFile reads the whole file, it does not treat an EOF from Read
    // as an error to be reported.
    func ReadFileWithFileInfo(name string) ([]byte, fs.FileInfo, error) {
    	f, err := OsOpenFile(name, readMode, 0o666)
    	if err != nil {
    		return nil, nil, err
    	}
    	defer f.Close()
    
    	st, err := f.Stat()
    	if err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sat Dec 09 18:17:51 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  8. cmd/http-tracer.go

    // redact LDAP password if part of string
    func redactLDAPPwd(s string) string {
    	parts := ldapPwdRegex.FindStringSubmatch(s)
    	if len(parts) > 3 {
    		return parts[1] + "LDAPPassword=*REDACTED*" + parts[3]
    	}
    	return s
    }
    
    // getOpName sanitizes the operation name for mc
    func getOpName(name string) (op string) {
    	op = strings.TrimPrefix(name, "github.com/minio/minio/cmd.")
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 6K bytes
    - Viewed (0)
  9. cmd/namespace-lock_test.go

    // following test. Adding new code before this test or changing its
    // position will cause the line number to change and the test to FAIL
    // Tests getSource().
    func TestGetSource(t *testing.T) {
    	currentSource := func() string { return getSource(2) }
    	gotSource := currentSource()
    	// Hard coded line number, 34, in the "expectedSource" value
    	expectedSource := "[namespace-lock_test.go:34:TestGetSource()]"
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3K bytes
    - Viewed (0)
  10. internal/s3select/csv/reader.go

    // startReaders will read the header if needed and spin up a parser
    // and a number of workers based on GOMAXPROCS.
    // If an error is returned no goroutines have been started and r.err will have been set.
    func (r *Reader) startReaders(newReader func(io.Reader) *csv.Reader) error {
    	if r.args.FileHeaderInfo != none {
    		// Read column names
    		// Get one line.
    		b, err := r.nextSplit(0, nil)
    		if err != nil {
    			r.err = err
    			return err
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 8.8K bytes
    - Viewed (0)
Back to top