Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 227 for unpack (0.11 sec)

  1. 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)
  2. 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)
  3. 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)
  4. okhttp-hpacktests/src/test/java/okhttp3/internal/http2/HpackRoundTripTest.kt

    import org.junit.jupiter.api.Assumptions.assumeFalse
    import org.junit.jupiter.params.ParameterizedTest
    import org.junit.jupiter.params.provider.ArgumentsSource
    
    /**
     * Tests for round-tripping headers through hpack.
     *
     * TODO: update hpack-test-case with the output of our encoder.
     * This test will hide complementary bugs in the encoder and decoder,
     * We should test that the encoder is producing responses that are
     */
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2K bytes
    - Viewed (0)
  5. okhttp-hpacktests/src/test/java/okhttp3/internal/http2/HpackDecodeTestBase.kt

    import okhttp3.internal.http2.hpackjson.HpackJsonUtil
    import okhttp3.internal.http2.hpackjson.Story
    import okio.Buffer
    
    /**
     * Tests Hpack implementation using https://github.com/http2jp/hpack-test-case/
     */
    open class HpackDecodeTestBase {
      private val bytesIn = Buffer()
      private val hpackReader = Hpack.Reader(bytesIn, 4096)
    
      protected fun testDecoder(story: Story) {
        for (testCase in story.cases) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/pod_cache.go

    func (p *podNetnsCache) UpsertPodCacheWithNetns(uid string, workload WorkloadInfo) Netns {
    	// lock current snapshot pod map
    	p.mu.Lock()
    	defer p.mu.Unlock()
    	if existing := p.currentPodCache[uid]; existing.Netns != nil {
    		if existing.Netns.Inode() == workload.Netns.Inode() {
    			workload.Netns.Close()
    			// Replace the workload, but keep the old Netns
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri May 31 17:18:11 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  7. cmd/lock-rest-client_test.go

    	}
    
    	_, err = lkClient.RUnlock(context.Background(), dsync.LockArgs{})
    	if err == nil {
    		t.Fatal("Expected for RUnlock to fail")
    	}
    
    	_, err = lkClient.Unlock(context.Background(), dsync.LockArgs{})
    	if err == nil {
    		t.Fatal("Expected for Unlock to fail")
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 2K bytes
    - Viewed (0)
  8. cmd/erasure-server-pool-decom.go

    	if !update {
    		z.poolMetaMutex.Lock()
    		z.poolMeta = meta
    		z.poolMetaMutex.Unlock()
    	} else {
    		newMeta := newPoolMeta(z, meta)
    		if err = newMeta.save(ctx, z.serverPools); err != nil {
    			return err
    		}
    		z.poolMetaMutex.Lock()
    		z.poolMeta = newMeta
    		z.poolMetaMutex.Unlock()
    	}
    
    	pools := meta.returnResumablePools()
    	poolIndices := make([]int, 0, len(pools))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  9. cmd/erasure-server-pool-rebalance.go

    		return err
    	}
    	defer lock.Unlock(lkCtx)
    
    	ctx = lkCtx.Context()
    	noLockOpts := ObjectOptions{NoLock: true}
    	r := &rebalanceMeta{}
    	if err := r.loadWithOpts(ctx, z.serverPools[0], noLockOpts); err != nil {
    		return err
    	}
    
    	z.rebalMu.Lock()
    	defer z.rebalMu.Unlock()
    
    	switch opts {
    	case rebalSaveStoppedAt:
    		r.StoppedAt = time.Now()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  10. cmd/metacache-bucket.go

    		debug.PrintStack()
    		return metacache{}
    	}
    
    	// Grab a write lock, since we create one if we cannot find one.
    	b.mu.Lock()
    	defer b.mu.Unlock()
    
    	// Check if exists already.
    	if c, ok := b.caches[o.ID]; ok {
    		c.lastHandout = time.Now()
    		b.caches[o.ID] = c
    		b.debugf("returning existing %v", o.ID)
    		return c
    	}
    
    	if !o.Create {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6.6K bytes
    - Viewed (0)
Back to top