Search Options

Results per page
Sort
Preferred Languages
Advance

Results 181 - 190 of 227 for unpack (0.05 sec)

  1. cmd/bucket-policy-handlers_test.go

    				if _, ok := err.(BucketExists); !ok {
    					t.Logf("unexpected error: %T: %v", err, err)
    					return
    				}
    				mu.Lock()
    				errs++
    				mu.Unlock()
    				return
    			}
    			mu.Lock()
    			ok++
    			mu.Unlock()
    		}()
    	}
    	close(start)
    	wg.Wait()
    	if ok != 1 {
    		t.Fatalf("want 1 ok, got %d", ok)
    	}
    	if errs != n-1 {
    		t.Fatalf("want %d errors, got %d", n-1, errs)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 32.9K bytes
    - Viewed (0)
  2. cmd/erasure-healing_test.go

    		copy(disks, newDisks)
    		objLayer.(*erasureServerPools).serverPools[0].erasureDisksMu.Unlock()
    	}
    	getDisk := func(n int) StorageAPI {
    		objLayer.(*erasureServerPools).serverPools[0].erasureDisksMu.Lock()
    		disk := disks[n]
    		objLayer.(*erasureServerPools).serverPools[0].erasureDisksMu.Unlock()
    		return disk
    	}
    
    	// Remove 4 disks.
    	setDisks(nil, nil, nil, nil)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  3. cmd/utils.go

    // Returns current profile data, returns error if there is no active
    // profiling in progress. Stops an active profile.
    func getProfileData() (map[string][]byte, error) {
    	globalProfilerMu.Lock()
    	defer globalProfilerMu.Unlock()
    
    	if len(globalProfiler) == 0 {
    		return nil, errors.New("profiler not enabled")
    	}
    
    	dst := make(map[string][]byte, len(globalProfiler))
    	for typ, prof := range globalProfiler {
    		// Stop the profiler
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 31.9K bytes
    - Viewed (0)
  4. cmd/batch-rotate.go

    	lock := api.NewNSLock(r.Bucket, objInfo.Name)
    	lkctx, err := lock.GetLock(ctx, globalOperationTimeout)
    	if err != nil {
    		return err
    	}
    	ctx = lkctx.Context()
    	defer lock.Unlock(lkctx)
    
    	opts := ObjectOptions{
    		VersionID:        objInfo.VersionID,
    		Versioned:        versioned,
    		VersionSuspended: versionSuspended,
    		NoLock:           true,
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/Headers.kt

      /**
       * Returns the number of bytes required to encode these headers using HTTP/1.1. This is also the
       * approximate size of HTTP/2 headers before they are compressed with HPACK. This value is
       * intended to be used as a metric: smaller headers are more efficient to encode and transmit.
       */
      fun byteCount(): Long {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  6. go.mod

    	github.com/peterbourgon/diskv v2.0.1+incompatible // indirect
    	github.com/pkg/errors v0.9.1 // indirect
    	github.com/planetscale/vtprotobuf v0.6.1-0.20240409071808-615f978279ca // indirect
    	github.com/quic-go/qpack v0.5.1 // indirect
    	github.com/rivo/uniseg v0.4.6 // indirect
    	github.com/russross/blackfriday/v2 v2.1.0 // indirect
    	github.com/sagikazarmark/locafero v0.4.0 // indirect
    	github.com/sagikazarmark/slog-shim v0.1.0 // indirect
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Nov 06 06:23:25 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  7. cmd/xl-storage-disk-id-check.go

    			var a AccElem
    			a.Size = atomic.LoadInt64(&old.Size)
    			a.Total = atomic.LoadInt64(&old.Total)
    			a.N = atomic.LoadInt64(&old.N)
    			e.mu.Lock()
    			e.lastMinuteLatency.addAll(t-1, a)
    			e.mu.Unlock()
    			acc = newAcc
    		} else {
    			// We may be able to grab the new accumulator by yielding.
    			runtime.Gosched()
    			acc = e.cached.Load()
    		}
    	}
    	atomic.AddInt64(&acc.N, 1)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  8. src/main/webapp/css/admin/bootstrap.min.css.map

    1 !important;\n  flex-shrink: 1 !important;\n}\n\n.justify-content-start {\n  -ms-flex-pack: start !important;\n  justify-content: flex-start !important;\n}\n\n.justify-content-end {\n  -ms-flex-pack: end !important;\n  justify-content: flex-end !important;\n}\n\n.justify-content-center {\n  -ms-flex-pack: center !important;\n  justify-content: center !important;\n}\n\n.justify-content-between {\n  -ms-flex-pack: justify !important;\n  justify-content: space-between !important;\n}\n\n.justify-content-around...
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 26 01:49:09 UTC 2024
    - 639.3K bytes
    - Viewed (0)
  9. cmd/site-replication.go

    	buf, err := readConfig(ctx, objAPI, getSRStateFilePath())
    	if err != nil {
    		if errors.Is(err, errConfigNotFound) {
    			c.Lock()
    			defer c.Unlock()
    			c.state = srState{}
    			c.enabled = false
    		}
    		return err
    	}
    
    	// attempt to read just the version key in the state file to ensure we
    	// are reading a compatible version.
    	var ver struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
  10. internal/rest/client.go

    func (c *Client) MarkOffline(err error) bool {
    	c.Lock()
    	c.lastErr = err
    	c.lastErrTime = time.Now()
    	atomic.StoreInt64(&c.lastConn, time.Now().UnixNano())
    	c.Unlock()
    
    	return c.runHealthCheck()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
Back to top