- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 227 for unpack (0.11 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)