- Sort Score
- Num 10 results
- Language All
Results 181 - 190 of 939 for func_ (0.02 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
internal/s3select/sql/value_test.go
// Values should match if type is the same. var valueBuilders = []func() *Value{ FromNull, func() *Value { return FromBool(true) }, func() *Value { return FromBytes([]byte("byte contents")) }, func() *Value { return FromFloat(math.Pi) }, func() *Value { return FromInt(0x1337) }, func() *Value { t, err := time.Parse(time.RFC3339, "2006-01-02T15:04:05Z") if err != nil {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 12.4K bytes - Click Count (0) -
internal/cachevalue/cache_test.go
"errors" "testing" "time" ) func slowCaller(ctx context.Context) error { sl := time.NewTimer(time.Second) defer sl.Stop() select { case <-sl.C: case <-ctx.Done(): return ctx.Err() } return nil } func TestCacheCtx(t *testing.T) { cache := New[time.Time]() t.Parallel() cache.InitOnce(2*time.Second, Opts{}, func(ctx context.Context) (time.Time, error) {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 2.7K bytes - Click Count (0) -
internal/store/batch.go
func (b *Batch[I]) Close() error { defer func() { close(b.quitCh) }() b.Lock() defer b.Unlock() return b.commit() } // NewBatch creates a new batch func NewBatch[I any](config BatchConfig[I]) *Batch[I] { if config.CommitTimeout == 0 { config.CommitTimeout = defaultCommitTimeout } quitCh := make(chan struct{}) batch := &Batch[I]{
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Sep 06 23:06:30 GMT 2024 - 2.9K bytes - Click Count (0) -
misc/ios/detect.go
matches++ } } } if matches == len(udids) { files = append(files, string(line)) } } return files } func parseMobileProvision(fname string) *exec.Cmd { return exec.Command("security", "cms", "-D", "-i", string(fname)) } func plistExtract(fname string, path string) ([]byte, error) { out, err := exec.Command("/usr/libexec/PlistBuddy", "-c", "Print "+path, fname).CombinedOutput()
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Thu Oct 19 23:33:30 GMT 2023 - 3.2K bytes - Click Count (0) -
internal/dsync/lock-args_gen_test.go
t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after Skip(): %q", len(left), left) } } func BenchmarkMarshalMsgLockArgs(b *testing.B) { v := LockArgs{} b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.MarshalMsg(nil) } } func BenchmarkAppendMsgLockArgs(b *testing.B) { v := LockArgs{} bts := make([]byte, 0, v.Msgsize()) bts, _ = v.MarshalMsg(bts[0:0])
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 4.4K bytes - Click Count (0) -
cmd/bucket-replication-utils.go
} // Empty returns true if no targets with resync decision present func (r ResyncDecision) Empty() bool { return r.targets == nil } func (r ResyncDecision) mustResync() bool { for _, v := range r.targets { if v.Replicate { return true } } return false } func (r ResyncDecision) mustResyncTarget(tgtArn string) bool { if r.targets == nil { return false }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 26.1K bytes - Click Count (0) -
internal/dsync/dsync-client_test.go
} } // Close closes the underlying socket file descriptor. func (restClient *ReconnectRESTClient) IsOnline() bool { // If rest client has not connected yet there is nothing to close. return restClient.rest != nil } func (restClient *ReconnectRESTClient) IsLocal() bool { return false } // Close closes the underlying socket file descriptor. func (restClient *ReconnectRESTClient) Close() error { return nil }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Jan 20 17:36:09 GMT 2022 - 4.4K bytes - Click Count (0) -
cmd/background-newdisks-heal-ops_gen_test.go
t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after Skip(): %q", len(left), left) } } func BenchmarkMarshalMsghealingTracker(b *testing.B) { v := healingTracker{} b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.MarshalMsg(nil) } } func BenchmarkAppendMsghealingTracker(b *testing.B) { v := healingTracker{} bts := make([]byte, 0, v.Msgsize())
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 2.3K bytes - Click Count (0) -
cmd/callhome.go
) var callhomeLeaderLockTimeout = newDynamicTimeout(30*time.Second, 10*time.Second) // initCallhome will start the callhome task in the background. func initCallhome(ctx context.Context, objAPI ObjectLayer) { if !globalCallhomeConfig.Enabled() { return } go func() { r := rand.New(rand.NewSource(time.Now().UnixNano())) // Leader node (that successfully acquires the lock inside runCallhome)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.3K bytes - Click Count (0) -
internal/logger/logger.go
// can be registered by RegisterError errorFmtFunc = func(introMsg string, err error, jsonFlag bool) string { return fmt.Sprintf("msg: %s\n err:%s", introMsg, err) } ) // EnableQuiet - turns quiet option on. func EnableQuiet() { color.TurnOff() // no colored outputs necessary in quiet mode. quietFlag = true } // EnableJSON - outputs logs in json format. func EnableJSON() {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 12.4K bytes - Click Count (0)