- Sort Score
- Result 10 results
- Languages All
Results 771 - 780 of 1,795 for func (4 sec)
-
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) -
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) -
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) -
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) -
internal/disk/fdatasync_unix.go
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Sep 29 23:40:28 UTC 2021 - 1.1K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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)