Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 220 for unpack (0.1 sec)

  1. internal/grid/muxclient.go

    	}
    	if m.subroute != nil {
    		msg.Flags |= FlagSubroute
    	}
    	ch := make(chan Response, 1)
    	m.respMu.Lock()
    	if m.closed {
    		m.respMu.Unlock()
    		return nil, ErrDisconnected
    	}
    	m.respWait = ch
    	m.respMu.Unlock()
    	ctx := m.ctx
    
    	// Add deadline if none.
    	if msg.DeadlineMS == 0 {
    		msg.DeadlineMS = uint32(defaultSingleRequestTimeout / time.Millisecond)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  2. cmd/bucket-replication-stats.go

    	if r == nil {
    		return
    	}
    
    	r.Lock()
    	defer r.Unlock()
    	delete(r.Cache, bucket)
    }
    
    // UpdateReplicaStat updates in-memory replica statistics with new values.
    func (r *ReplicationStats) UpdateReplicaStat(bucket string, n int64) {
    	if r == nil {
    		return
    	}
    
    	r.Lock()
    	defer r.Unlock()
    	bs, ok := r.Cache[bucket]
    	if !ok {
    		bs = newBucketReplicationStats()
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  3. internal/grid/connection.go

    			}
    			if state == StateShutdown || state == StateConnectionError {
    				c.connChange.L.Unlock()
    				return
    			}
    			c.connChange.Wait()
    			select {
    			case <-ctx.Done():
    				c.connChange.L.Unlock()
    				return
    			default:
    			}
    		}
    		c.connChange.L.Unlock()
    		if len(queue) == 0 {
    			// Send single message without merging.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  4. internal/dsync/locked_rand.go

    func (r *lockedRandSource) Int63() (n int64) {
    	r.lk.Lock()
    	n = r.src.Int63()
    	r.lk.Unlock()
    	return
    }
    
    // Seed uses the provided seed value to initialize the generator to a
    // deterministic state.
    func (r *lockedRandSource) Seed(seed int64) {
    	r.lk.Lock()
    	r.src.Seed(seed)
    	r.lk.Unlock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Oct 18 15:39:59 UTC 2021
    - 1.3K bytes
    - Viewed (0)
  5. .gitmodules

    [submodule "okhttp-hpacktests/src/test/resources/hpack-test-case"]
    	path = okhttp-hpacktests/src/test/resources/hpack-test-case
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Dec 10 09:33:37 UTC 2022
    - 182 bytes
    - Viewed (0)
  6. cmd/perf-tests.go

    	activeConnections uint64
    	sync.RWMutex
    }
    
    func (n *netPerfRX) Connect() {
    	n.Lock()
    	defer n.Unlock()
    	n.activeConnections++
    	atomic.StoreUint64(&n.RX, 0)
    	n.lastToConnect = time.Now()
    }
    
    func (n *netPerfRX) Disconnect() {
    	n.Lock()
    	defer n.Unlock()
    	n.activeConnections--
    	if n.firstToDisconnect.IsZero() {
    		n.RXSample = atomic.LoadUint64(&n.RX)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  7. internal/logger/logonce.go

    		l.IDMap[id] = prev
    		shouldLog = false
    	}
    	l.Unlock()
    
    	if shouldLog {
    		logIf(ctx, subsystem, err, errKind...)
    	}
    }
    
    // Cleanup the map every one hour so that the log message is printed again for the user to notice.
    func (l *logOnceType) cleanupRoutine() {
    	for {
    		time.Sleep(time.Hour)
    
    		l.Lock()
    		l.IDMap = make(map[string]onceErr)
    		l.Unlock()
    	}
    }
    
    // Returns logOnceType
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  8. internal/dsync/dsync-client_test.go

    	return restClient.Call("/v1/runlock", args)
    }
    
    func (restClient *ReconnectRESTClient) Unlock(ctx context.Context, args LockArgs) (status bool, err error) {
    	return restClient.Call("/v1/unlock", args)
    }
    
    func (restClient *ReconnectRESTClient) Refresh(ctx context.Context, args LockArgs) (refreshed bool, err error) {
    	return restClient.Call("/v1/refresh", args)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 20 17:36:09 UTC 2022
    - 4.4K bytes
    - Viewed (0)
  9. okhttp-hpacktests/src/test/java/okhttp3/internal/http2/hpackjson/HpackJsonUtil.kt

        fileSystem.read(file) {
          return readStory(this)
        }
      }
    
      /** Iterate through the hpack-test-case resources, only picking stories for the current draft.  */
      fun storiesForCurrentDraft(): Array<String> {
        val resource =
          HpackJsonUtil::class.java.getResource("/hpack-test-case")
            ?: return arrayOf()
    
        val testCaseDirectory = File(resource.toURI()).toOkioPath()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  10. internal/lock/lock_test.go

    	if err = rlk.Close(); err != os.ErrInvalid {
    		t.Fatal(err)
    	}
    
    	_, err = newRLockedFile(nil)
    	if err != os.ErrInvalid {
    		t.Fatal("Unexpected error", err)
    	}
    }
    
    // Tests lock and unlock semantics.
    func TestLockAndUnlock(t *testing.T) {
    	f, err := os.CreateTemp("", "lock")
    	if err != nil {
    		t.Fatal(err)
    	}
    	f.Close()
    	defer func() {
    		err = os.Remove(f.Name())
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.6K bytes
    - Viewed (0)
Back to top