Search Options

Results per page
Sort
Preferred Languages
Advance

Results 761 - 770 of 1,425 for Func (0.03 sec)

  1. 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)
  2. internal/disk/stat_linux_32bit.go

    }
    
    // getFSType returns the filesystem type of the underlying mounted filesystem
    func getFSType(ftype int32) string {
    	fsTypeHex := strconv.FormatInt(int64(ftype), 16)
    	fsTypeString, ok := fsType2StringMap[fsTypeHex]
    	if !ok {
    		return "UNKNOWN"
    	}
    	return fsTypeString
    }
    
    // GetInfo returns total and free bytes available in a directory, e.g. `/`.
    func GetInfo(path string, _ bool) (info Info, err error) {
    	s := syscall.Statfs_t{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 26 19:34:50 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  3. src/cmd/addr2line/main.go

    	"cmd/internal/objfile"
    	"cmd/internal/telemetry/counter"
    )
    
    func printUsage(w *os.File) {
    	fmt.Fprintf(w, "usage: addr2line binary\n")
    	fmt.Fprintf(w, "reads addresses from standard input and writes two lines for each:\n")
    	fmt.Fprintf(w, "\tfunction name\n")
    	fmt.Fprintf(w, "\tfile:line\n")
    }
    
    func usage() {
    	printUsage(os.Stderr)
    	os.Exit(2)
    }
    
    func main() {
    	log.SetFlags(0)
    	log.SetPrefix("addr2line: ")
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Jun 21 19:58:04 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  4. cni/pkg/plugin/cnieventclient.go

    type CNIEventClient struct {
    	client *http.Client
    	url    string
    }
    
    func buildClient(address, path string) CNIEventClient {
    	c := &http.Client{
    		Transport: &http.Transport{
    			DialContext: func(_ context.Context, _, _ string) (net.Conn, error) {
    				return net.Dial("unix", address)
    			},
    		},
    		Timeout: 5 * time.Second,
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Jul 02 18:48:50 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  5. 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)
  6. cmd/metacache-walk.go

    			if sterr == nil && st.Mode().IsRegular() {
    				return errFileNotFound
    			}
    		}
    	}
    
    	prefix := opts.FilterPrefix
    	var scanDir func(path string) error
    
    	scanDir = func(current string) error {
    		// Skip forward, if requested...
    		sb := bytebufferpool.Get()
    		defer func() {
    			sb.Reset()
    			bytebufferpool.Put(sb)
    		}()
    
    		forward := ""
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 01 05:17:37 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. tensorflow/c/c_api.h

    // between them if `func` does not already have a gradient. If `func` already
    // has a gradient different from `grad`, an error is returned.
    //
    // `func` must not be null.
    // If `grad` is null and `func` is not in `g`, `func` is added without a
    // gradient.
    // If `grad` is null and `func` is in `g`, TF_GraphCopyFunction is a noop.
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Thu Oct 26 21:08:15 UTC 2023
    - 82.3K bytes
    - Viewed (0)
Back to top