Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 227 for unpack (0.08 sec)

  1. cni/pkg/nodeagent/netns_linux.go

    		}
    		defer threadNS.Close()
    
    		// switch to target namespace
    		if err = NetnsSet(fdable); err != nil {
    			return err
    		}
    		defer func() {
    			err := threadNS.Set() // switch back
    			if err == nil {
    				// Unlock the current thread only when we successfully switched back
    				// to the original namespace; otherwise leave the thread locked which
    				// will force the runtime to scrap the current thread, that is maybe
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jan 31 10:05:36 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  2. internal/config/callhome/callhome.go

    	if c.Frequency == 0 {
    		return callhomeCycleDefault
    	}
    
    	return c.Frequency
    }
    
    // Update updates new callhome frequency
    func (c *Config) Update(ncfg Config) {
    	configLock.Lock()
    	defer configLock.Unlock()
    
    	c.Enable = ncfg.Enable
    	c.Frequency = ncfg.Frequency
    }
    
    // LookupConfig - lookup config and override with valid environment settings if any.
    func LookupConfig(kvs config.KVS) (cfg Config, err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt

      private val source: BufferedSource,
      private val client: Boolean,
    ) : Closeable {
      private val continuation: ContinuationSource = ContinuationSource(this.source)
      private val hpackReader: Hpack.Reader =
        Hpack.Reader(
          source = continuation,
          headerTableSizeSetting = 4096,
        )
    
      @Throws(IOException::class)
      fun readConnectionPreface(handler: Handler) {
        if (client) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  4. internal/config/drive/drive.go

    	MaxTimeout time.Duration `json:"maxTimeout"`
    }
    
    // Update - updates the config with latest values
    func (c *Config) Update(new Config) error {
    	configLk.Lock()
    	defer configLk.Unlock()
    	c.MaxTimeout = getMaxTimeout(new.MaxTimeout)
    	return nil
    }
    
    // GetMaxTimeout - returns the per call drive operation timeout
    func (c *Config) GetMaxTimeout() time.Duration {
    	return c.GetOPTimeout()
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 3K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/internal/http2/HuffmanTest.kt

    import okio.ByteString.Companion.toByteString
    import org.junit.jupiter.api.Assertions.assertEquals
    import org.junit.jupiter.api.Test
    
    /** Original version of this class was lifted from `com.twitter.hpack.HuffmanTest`.  */
    class HuffmanTest {
      @Test
      fun roundTripForRequestAndResponse() {
        val s = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789"
        for (i in s.indices) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Jan 04 05:32:07 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  6. cmd/callhome.go

    	if err != nil {
    		// lock timedout means some other node is the leader,
    		// cycle back return 'true'
    		return true
    	}
    
    	ctx = lkctx.Context()
    	defer locker.Unlock(lkctx)
    
    	// Perform callhome once and then keep running it at regular intervals.
    	performCallhome(ctx)
    
    	callhomeTimer := time.NewTimer(globalCallhomeConfig.FrequencyDur())
    	defer callhomeTimer.Stop()
    
    	for {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 17 16:53:34 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  7. cmd/config.go

    	// Override any values from ENVs.
    	lookupConfigs(srvCfg, objAPI)
    
    	// hold the mutex lock before a new config is assigned.
    	globalServerConfigMu.Lock()
    	globalServerConfig = srvCfg
    	globalServerConfigMu.Unlock()
    
    	return nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 23 10:07:06 UTC 2023
    - 6K bytes
    - Viewed (0)
  8. cmd/api-router.go

    	globalObjLayerMutex.Lock()
    	globalHTTPServer = h
    	globalObjLayerMutex.Unlock()
    }
    
    func newConsoleServerFn() *consoleapi.Server {
    	globalObjLayerMutex.RLock()
    	defer globalObjLayerMutex.RUnlock()
    	return globalConsoleSrv
    }
    
    func setConsoleSrv(srv *consoleapi.Server) {
    	globalObjLayerMutex.Lock()
    	globalConsoleSrv = srv
    	globalObjLayerMutex.Unlock()
    }
    
    func newObjectLayerFn() ObjectLayer {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 15:25:16 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  9. cmd/bucket-replication.go

    	}
    	p.priority = pri
    	p.maxWorkers = maxWorkers
    	p.mu.Unlock()
    	p.ResizeWorkers(workers, 0)
    	p.ResizeFailedWorkers(mrfWorkers)
    	p.ResizeLrgWorkers(maxLWorkers, 0)
    }
    
    // ResizeFailedWorkers sets replication failed workers pool size
    func (p *ReplicationPool) ResizeFailedWorkers(n int) {
    	p.mu.Lock()
    	defer p.mu.Unlock()
    
    	for p.mrfWorkerSize < n {
    		p.mrfWorkerSize++
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

        /** Cleanup collected entries when the lock is available. */
        void tryDrainReferenceQueues() {
          if (tryLock()) {
            try {
              maybeDrainReferenceQueues();
            } finally {
              unlock();
            }
          }
        }
    
        @GuardedBy("this")
        void drainKeyReferenceQueue(ReferenceQueue<K> keyReferenceQueue) {
          Reference<? extends K> ref;
          int i = 0;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 90.8K bytes
    - Viewed (0)
Back to top