Search Options

Results per page
Sort
Preferred Languages
Advance

Results 771 - 780 of 1,384 for funcs (0.03 sec)

  1. src/bytes/buffer.go

    // b.Len() == len(b.Bytes()).
    func (b *Buffer) Len() int { return len(b.buf) - b.off }
    
    // Cap returns the capacity of the buffer's underlying byte slice, that is, the
    // total space allocated for the buffer's data.
    func (b *Buffer) Cap() int { return cap(b.buf) }
    
    // Available returns how many bytes are unused in the buffer.
    func (b *Buffer) Available() int { return cap(b.buf) - len(b.buf) }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Oct 29 16:47:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool-rebalance.go

    		Duration:  duration,
    		Path:      path,
    		Error:     errStr,
    		Bytes:     sz,
    	}
    }
    
    func (p *rebalanceMetrics) log(r rebalanceMetric, poolIdx int, paths ...string) func(sz int64, err error) {
    	startTime := time.Now()
    	return func(sz int64, err error) {
    		duration := time.Since(startTime)
    		if globalTrace.NumSubscribers(madmin.TraceRebalance) > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  3. cni/pkg/pluginlistener/listener_test.go

    	"google.golang.org/grpc/credentials/insecure"
    )
    
    func TestCNIListener(t *testing.T) {
    	f := filepath.Join(t.TempDir(), "test")
    	l, err := NewListener(f)
    	if err != nil {
    		t.Fatalf("unexpected error %v", err)
    	}
    	defer l.Close()
    	conn, err := connect(f)
    	if err != nil {
    		t.Fatalf("failed to connect %v", err)
    	}
    	conn.Close()
    }
    
    func connect(socket string) (*grpc.ClientConn, error) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Feb 08 21:58:32 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  4. cmd/metacache-set.go

    // or the context is canceled.
    func (o *listPathOptions) gatherResults(ctx context.Context, in <-chan metaCacheEntry) func() (metaCacheEntriesSorted, error) {
    	resultsDone := make(chan metaCacheEntriesSorted)
    	// Copy so we can mutate
    	resCh := resultsDone
    	var done bool
    	var mu sync.Mutex
    	resErr := io.EOF
    
    	go func() {
    		var results metaCacheEntriesSorted
    		var returned bool
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  5. cmd/ftp-server.go

    // minioLogger use an instance of this to log in a standard format
    type minioLogger struct{}
    
    // Print implement Logger
    func (log *minioLogger) Print(sessionID string, message interface{}) {
    	if serverDebugLog {
    		fmt.Printf("%s %s\n", sessionID, message)
    	}
    }
    
    // Printf implement Logger
    func (log *minioLogger) Printf(sessionID string, format string, v ...interface{}) {
    	if serverDebugLog {
    		if sessionID != "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Mar 09 03:07:08 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  6. internal/s3select/sql/timestampfuncs.go

    	layoutDay,
    	layoutMinute,
    	layoutSecond,
    	layoutNanosecond,
    }
    
    func parseSQLTimestamp(s string) (t time.Time, err error) {
    	for _, f := range tformats {
    		t, err = time.Parse(f, s)
    		if err == nil {
    			break
    		}
    	}
    	return
    }
    
    // FormatSQLTimestamp - returns the a string representation of the
    // timestamp as used in S3 Select
    func FormatSQLTimestamp(t time.Time) string {
    	_, zoneOffset := t.Zone()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 4.8K bytes
    - Viewed (0)
  7. cmd/local-locker_test.go

    	}
    }
    
    func Test_localLocker_expireOldLocksExpire(t *testing.T) {
    	rng := rand.New(rand.NewSource(0))
    	quorum := 0
    	// Numbers of unique locks
    	for _, locks := range []int{100, 1000, 1e6} {
    		if testing.Short() && locks > 100 {
    			continue
    		}
    		t.Run(fmt.Sprintf("%d-locks", locks), func(t *testing.T) {
    			// Number of readers per lock...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  8. internal/event/target/amqp.go

    func (target *AMQPTarget) IsActive() (bool, error) {
    	if err := target.init(); err != nil {
    		return false, err
    	}
    
    	return target.isActive()
    }
    
    func (target *AMQPTarget) isActive() (bool, error) {
    	ch, _, err := target.channel()
    	if err != nil {
    		return false, err
    	}
    	defer func() {
    		ch.Close()
    	}()
    	return true, nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
  9. internal/store/queuestore_test.go

    	testItemExt = ".test"
    )
    
    // Initialize the queue store.
    func setUpQueueStore(directory string, limit uint64) (Store[TestItem], error) {
    	queueStore := NewQueueStore[TestItem](queueDir, limit, testItemExt)
    	if oErr := queueStore.Open(); oErr != nil {
    		return nil, oErr
    	}
    	return queueStore, nil
    }
    
    // Tear down queue store.
    func tearDownQueueStore() error {
    	return os.RemoveAll(queueDir)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  10. cmd/net.go

    func mustSplitHostPort(hostPort string) (host, port string) {
    	xh, err := xnet.ParseHost(hostPort)
    	if err != nil {
    		logger.FatalIf(err, "Unable to split host port %s", hostPort)
    	}
    	return xh.Name, xh.Port.String()
    }
    
    // mustGetLocalIPs returns IPs of local interface
    func mustGetLocalIPs() (ipList []net.IP) {
    	ifs, err := net.Interfaces()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 14:34:00 UTC 2024
    - 9.6K bytes
    - Viewed (0)
Back to top