Search Options

Results per page
Sort
Preferred Languages
Advance

Results 221 - 230 of 1,214 for Func (0.03 sec)

  1. 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())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 2.3K bytes
    - Viewed (0)
  2. 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) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  3. 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]{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  4. 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()
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 19 23:33:30 UTC 2023
    - 3.2K bytes
    - Viewed (0)
  5. internal/logger/logonce.go

    )
    
    // LogOnce provides the function type for logger.LogOnceIf() function
    type LogOnce func(ctx context.Context, err error, id string, errKind ...interface{})
    
    type onceErr struct {
    	Err   error
    	Count int
    }
    
    // Holds a map of recently logged errors.
    type logOnceType struct {
    	IDMap map[string]onceErr
    	sync.Mutex
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  6. internal/logger/reqinfo.go

    		ObjectName:   object,
    	}
    }
    
    // AppendTags - appends key/val to ReqInfo.tags
    func (r *ReqInfo) AppendTags(key, val string) *ReqInfo {
    	if r == nil {
    		return nil
    	}
    	r.Lock()
    	defer r.Unlock()
    	r.tags = append(r.tags, KeyVal{key, val})
    	return r
    }
    
    // SetTags - sets key/val to ReqInfo.tags
    func (r *ReqInfo) SetTags(key, val string) *ReqInfo {
    	if r == nil {
    		return nil
    	}
    	r.Lock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  7. cmd/untar.go

    	r  io.Reader
    	mu sync.Mutex
    }
    
    func (d *disconnectReader) Read(p []byte) (n int, err error) {
    	d.mu.Lock()
    	defer d.mu.Unlock()
    	if d.r != nil {
    		return d.r.Read(p)
    	}
    	return 0, errors.New("reader closed")
    }
    
    func (d *disconnectReader) Close() error {
    	d.mu.Lock()
    	d.r = nil
    	d.mu.Unlock()
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 6K bytes
    - Viewed (0)
  8. internal/bucket/replication/destination.go

    }
    
    func (d Destination) isValidStorageClass() bool {
    	if d.StorageClass == "" {
    		return true
    	}
    	return d.StorageClass == "STANDARD" || d.StorageClass == "REDUCED_REDUNDANCY"
    }
    
    // IsValid - checks whether Destination is valid or not.
    func (d Destination) IsValid() bool {
    	return d.Bucket != "" || !d.isValidStorageClass()
    }
    
    func (d Destination) String() string {
    	return d.ARN
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4K bytes
    - Viewed (0)
  9. callbacks/preload.go

    //		},
    //		"k1": {},
    //		"k2": {
    //			"k3": {"arg3"},
    //		},
    //		"k4": {
    //			"k5.k6": {"arg4"},
    //		},
    //	}
    func parsePreloadMap(s *schema.Schema, preloads map[string][]interface{}) map[string]map[string][]interface{} {
    	preloadMap := map[string]map[string][]interface{}{}
    	setPreloadMap := func(name, value string, args []interface{}) {
    		if _, ok := preloadMap[name]; !ok {
    			preloadMap[name] = map[string][]interface{}{}
    		}
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Jun 12 10:52:33 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  10. cmd/admin-handlers-site-replication.go

    	}
    
    	writeSuccessResponseJSON(w, body)
    }
    
    func getSRAddOptions(r *http.Request) (opts madmin.SRAddOptions) {
    	opts.ReplicateILMExpiry = r.Form.Get("replicateILMExpiry") == "true"
    	return
    }
    
    // SRPeerJoin - PUT /minio/admin/v3/site-replication/join
    //
    // used internally to tell current cluster to enable SR with
    // the provided peer clusters and service account.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 19.4K bytes
    - Viewed (0)
Back to top