Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 227 for unpack (0.06 sec)

  1. cni/pkg/nodeagent/ztunnelserver.go

    func (c *connMgr) addConn(conn *ZtunnelConnection) {
    	log.Debug("ztunnel connected")
    	c.mu.Lock()
    	defer c.mu.Unlock()
    	c.connectionSet[conn] = struct{}{}
    	c.latestConn = conn
    	ztunnelConnected.RecordInt(int64(len(c.connectionSet)))
    }
    
    func (c *connMgr) LatestConn() *ZtunnelConnection {
    	c.mu.Lock()
    	defer c.mu.Unlock()
    	return c.latestConn
    }
    
    func (c *connMgr) deleteConn(conn *ZtunnelConnection) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 29 16:08:35 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  2. internal/cachevalue/cache.go

    		if t.updating.TryLock() {
    			go func() {
    				defer t.updating.Unlock()
    				t.update(context.Background())
    			}()
    		}
    		return *v, nil
    	}
    
    	// Get lock. Either we get it or we wait for it.
    	t.updating.Lock()
    	defer t.updating.Unlock()
    
    	if time.Since(time.UnixMilli(t.lastUpdateMs.Load())) < ttl {
    		// There is a new value, release lock and return it.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 12:50:46 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/internal/http2/HpackTest.kt

    import org.junit.jupiter.api.Test
    
    class HpackTest {
      private val bytesIn = Buffer()
      private var hpackReader: Hpack.Reader? = null
      private val bytesOut = Buffer()
      private var hpackWriter: Hpack.Writer? = null
    
      @BeforeEach
      fun reset() {
        hpackReader = newReader(bytesIn)
        hpackWriter = Hpack.Writer(4096, false, bytesOut)
      }
    
      /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 38.2K bytes
    - Viewed (0)
  4. cmd/erasure-object_test.go

    	xl.getDisks = func() []StorageAPI {
    		for i := range erasureDisks[:6] {
    			erasureDisks[i] = newNaughtyDisk(erasureDisks[i], nil, errFaultyDisk)
    		}
    		return erasureDisks
    	}
    
    	z.serverPools[0].erasureDisksMu.Unlock()
    	_, err = obj.DeleteObject(ctx, bucket, object, ObjectOptions{})
    	if !errors.Is(err, errErasureWriteQuorum) {
    		t.Fatal(err)
    	}
    
    	// Create "obj" under "bucket".
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/http2/Huffman.kt

    import okio.ByteString
    
    /**
     * This class was originally composed from the following classes in
     * [Twitter Hpack][twitter_hpack].
     *
     *  * `com.twitter.hpack.HuffmanEncoder`
     *  * `com.twitter.hpack.HuffmanDecoder`
     *  * `com.twitter.hpack.HpackUtil`
     *
     * [twitter_hpack]: https://github.com/twitter/hpack
     */
    object Huffman {
      // Appendix C: Huffman Codes
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  6. internal/s3select/json/reader.go

    	// This allows another goroutine to close the reader.
    	pr.mu.Lock()
    	defer pr.mu.Unlock()
    	if pr.rc == nil {
    		return 0, io.EOF
    	}
    	return pr.rc.Read(p)
    }
    
    func (pr *syncReadCloser) Close() error {
    	pr.mu.Lock()
    	defer pr.mu.Unlock()
    	if pr.rc != nil {
    		err := pr.rc.Close()
    		pr.rc = nil
    		return err
    	}
    	return nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  7. internal/logger/targets.go

    	tl.mu.RLock()
    	defer tl.mu.RUnlock()
    
    	return tl.list
    }
    
    func (tl *targetsList) add(t Target) {
    	tl.mu.Lock()
    	defer tl.mu.Unlock()
    
    	tl.list = append(tl.list, t)
    }
    
    func (tl *targetsList) set(tgts []Target) {
    	tl.mu.Lock()
    	defer tl.mu.Unlock()
    
    	tl.list = tgts
    }
    
    var (
    
    	// systemTargets is the set of enabled loggers.
    	systemTargets = newTargetsList()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 03 15:44:50 UTC 2024
    - 6K bytes
    - Viewed (0)
  8. src/test/resources/plugin/repo1/index.html

    <a href="fess-suggest/" title="fess-suggest/">fess-suggest/</a>                                                    -         -      
    <a href="fess-xpack/" title="fess-xpack/">fess-xpack/</a>                                                      -         -      
    		</pre>
    	</main>
    	<hr/>
    </body>
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Tue Aug 13 07:34:14 UTC 2019
    - 3.3K bytes
    - Viewed (0)
  9. internal/logger/reqinfo.go

    	if r == nil {
    		return nil
    	}
    	r.Lock()
    	defer r.Unlock()
    	r.tags = append(r.tags, KeyVal{key, val})
    	return r
    }
    
    // SetTags - sets key/val to ReqInfo.tags
    func (r *ReqInfo) SetTags(key, val string) *ReqInfo {
    	if r == nil {
    		return nil
    	}
    	r.Lock()
    	defer r.Unlock()
    	// Search of tag key already exists in tags
    	var updated bool
    	for _, tag := range r.tags {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  10. internal/config/identity/plugin/config.go

    	currentMinute    serviceRTTMinuteStats
    }
    
    func (h *metrics) setConnSuccess(reqStartTime time.Time) {
    	h.Lock()
    	defer h.Unlock()
    	h.LastCheckSuccess = reqStartTime
    }
    
    func (h *metrics) setConnFailure(reqStartTime time.Time) {
    	h.Lock()
    	defer h.Unlock()
    	h.LastCheckFailure = reqStartTime
    }
    
    func (h *metrics) updateLastFullMinute(currReqMinute time.Time) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 13.3K bytes
    - Viewed (0)
Back to top