Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for setUrl (0.18 sec)

  1. internal/disk/directio_unix.go

    func DisableDirectIO(f *os.File) error {
    	fd := f.Fd()
    	flag, err := unix.FcntlInt(fd, unix.F_GETFL, 0)
    	if err != nil {
    		return err
    	}
    	flag &= ^(syscall.O_DIRECT)
    	_, err = unix.FcntlInt(fd, unix.F_SETFL, flag)
    	return err
    }
    
    // AlignedBlock - pass through to directio implementation.
    func AlignedBlock(blockSize int) []byte {
    	return directio.AlignedBlock(blockSize)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Jun 17 14:31:36 GMT 2023
    - 1.6K bytes
    - Viewed (0)
  2. cmd/server_test.go

    		c.Assert(err, nil)
    
    		response, err = s.client.Do(request)
    		c.Assert(err, nil)
    		c.Assert(response.StatusCode, http.StatusOK)
    	}
    
    	testCases := []struct {
    		getURL          string
    		expectedStrings []string
    	}{
    		{getListObjectsV1URL(s.endPoint, bucketName, "", "1000", ""), []string{"<Key>foo bar 1</Key>", "<Key>foo bar 2</Key>"}},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 108K bytes
    - Viewed (0)
  3. cmd/metacache-server-pool.go

    	// Save listing...
    	go func() {
    		if err := saver.saveMetaCacheStream(listCtx, &meta, saveCh); err != nil {
    			meta.setErr(err.Error())
    		}
    		cancel()
    	}()
    
    	// Do listing...
    	go func(o listPathOptions) {
    		err := z.listMerged(listCtx, o, inCh)
    		if err != nil {
    			meta.setErr(err.Error())
    		}
    		o.debugln("listAndSave: listing", o.ID, "finished with ", err)
    	}(*o)
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 12.8K bytes
    - Viewed (0)
  4. cmd/metacache-set.go

    //msgp:ignore metaCacheRPC
    type metaCacheRPC struct {
    	o      listPathOptions
    	mu     sync.Mutex
    	meta   *metacache
    	rpc    *peerRESTClient
    	cancel context.CancelFunc
    }
    
    func (m *metaCacheRPC) setErr(err string) {
    	m.mu.Lock()
    	defer m.mu.Unlock()
    	meta := *m.meta
    	if meta.status != scanStateError {
    		meta.error = err
    		meta.status = scanStateError
    	} else {
    		// An error is already set.
    		return
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:59:08 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  5. cmd/utils.go

    		return xfix
    	}
    	// compare first to rest
    	for _, str := range strs[1:] {
    		xfixl := len(xfix)
    		strl := len(str)
    		// short-circuit empty strings
    		if xfixl == 0 || strl == 0 {
    			return ""
    		}
    		// maximum possible length
    		maxl := xfixl
    		if strl < maxl {
    			maxl = strl
    		}
    		// compare letters
    		if pre {
    			// prefix, iterate left to right
    			for i := 0; i < maxl; i++ {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 15:18:21 GMT 2024
    - 31.4K bytes
    - Viewed (0)
  6. cmd/metrics-v3-cluster-erasure-set.go

    		m.Set(erasureSetReadQuorum, float64(h.ReadQuorum),
    			poolIDL, poolLV, setIDL, setLV)
    		m.Set(erasureSetWriteQuorum, float64(h.WriteQuorum),
    			poolIDL, poolLV, setIDL, setLV)
    		m.Set(erasureSetOnlineDrivesCount, float64(h.HealthyDrives),
    			poolIDL, poolLV, setIDL, setLV)
    		m.Set(erasureSetHealingDrivesCount, float64(h.HealingDrives),
    			poolIDL, poolLV, setIDL, setLV)
    		m.Set(erasureSetHealth, b2f(h.Healthy),
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 10 09:15:15 GMT 2024
    - 3.1K bytes
    - Viewed (0)
Back to top