Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 220 for unpack (0.11 sec)

  1. 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)
  2. internal/config/subnet/config.go

    	}
    	os.Setenv("CONSOLE_SUBNET_URL", c.BaseURL)
    }
    
    // Update - in-place update with new license and registration information.
    func (c *Config) Update(ncfg Config, isDevEnv bool) {
    	configLock.Lock()
    	defer configLock.Unlock()
    
    	c.License = ncfg.License
    	c.APIKey = ncfg.APIKey
    	c.Proxy = ncfg.Proxy
    	c.transport = ncfg.transport
    	c.BaseURL = baseURL
    
    	if isDevEnv {
    		c.BaseURL = os.Getenv("_MINIO_SUBNET_URL")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  3. internal/config/browser/browser.go

    	ReferrerPolicy        string `json:"referrer_policy"`
    }
    
    // Update Updates browser with new config
    func (browseCfg *Config) Update(newCfg Config) {
    	configLock.Lock()
    	defer configLock.Unlock()
    	browseCfg.CSPPolicy = newCfg.CSPPolicy
    	browseCfg.HSTSSeconds = newCfg.HSTSSeconds
    	browseCfg.HSTSIncludeSubdomains = newCfg.HSTSIncludeSubdomains
    	browseCfg.HSTSPreload = newCfg.HSTSPreload
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 00:58:58 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  4. okhttp-android/src/main/baseline-prof.txt

    HSPLokhttp3/internal/http2/Hpack$Writer;-><init>(IZLokio/Buffer;I)V
    HSPLokhttp3/internal/http2/Hpack$Writer;->evictToRecoverBytes(I)I
    HSPLokhttp3/internal/http2/Hpack$Writer;->insertIntoDynamicTable(Lokhttp3/internal/http2/Header;)V
    HSPLokhttp3/internal/http2/Hpack$Writer;->writeByteString(Lokio/ByteString;)V
    HSPLokhttp3/internal/http2/Hpack$Writer;->writeHeaders(Ljava/util/List;)V
    HSPLokhttp3/internal/http2/Hpack$Writer;->writeInt(III)V
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Mar 21 11:22:00 UTC 2022
    - 127.9K bytes
    - Viewed (0)
  5. internal/config/heal/heal.go

    	configMutex.RLock()
    	defer configMutex.RUnlock()
    	return opts.DriveWorkers
    }
    
    // Update updates opts with nopts
    func (opts *Config) Update(nopts Config) {
    	configMutex.Lock()
    	defer configMutex.Unlock()
    
    	opts.Bitrot = nopts.Bitrot
    	opts.IOCount = nopts.IOCount
    	opts.Sleep = nopts.Sleep
    	opts.DriveWorkers = nopts.DriveWorkers
    
    	opts.cache.bitrotCycle, _ = parseBitrotConfig(nopts.Bitrot)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java

        GcFinalization.awaitClear(garbage);
        Lock writeLock = striped.get(key).writeLock();
        readLock.lock();
        assertFalse(writeLock.tryLock());
        readLock.unlock();
      }
    
      @AndroidIncompatible // Presumably GC doesn't trigger, despite our efforts.
      public void testStrongImplementations() {
        for (Striped<?> striped : strongImplementations()) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jun 26 12:58:35 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/StripedTest.java

        GcFinalization.awaitClear(garbage);
        Lock writeLock = striped.get(key).writeLock();
        readLock.lock();
        assertFalse(writeLock.tryLock());
        readLock.unlock();
      }
    
      @AndroidIncompatible // Presumably GC doesn't trigger, despite our efforts.
      public void testStrongImplementations() {
        for (Striped<?> striped : strongImplementations()) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jun 26 12:58:35 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  8. cmd/iam-etcd-store.go

    	return ies.iamCache
    }
    
    func (ies *IAMEtcdStore) runlock() {
    	ies.RUnlock()
    }
    
    func (ies *IAMEtcdStore) lock() *iamCache {
    	ies.Lock()
    	return ies.iamCache
    }
    
    func (ies *IAMEtcdStore) unlock() {
    	ies.Unlock()
    }
    
    func (ies *IAMEtcdStore) getUsersSysType() UsersSysType {
    	return ies.usersSysType
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 01:29:20 UTC 2024
    - 14K bytes
    - Viewed (0)
  9. cmd/bucket-lifecycle.go

    }
    
    func (es *expiryState) ResizeWorkers(n int) {
    	if n == 0 {
    		n = 100
    	}
    
    	// Lock to avoid multiple resizes to happen at the same time.
    	es.mu.Lock()
    	defer es.mu.Unlock()
    	var workers []chan expiryOp
    	if v := es.workers.Load(); v != nil {
    		// Copy to new array.
    		workers = append(workers, *v...)
    	}
    
    	if n == len(workers) || n < 1 {
    		return
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  10. doc/go_mem.html

    call <i>n</i> of <code>l.Unlock()</code> is synchronized before call <i>m</i> of <code>l.Lock()</code> returns.
    </p>
    
    <p>
    This program:
    </p>
    
    <pre>
    var l sync.Mutex
    var a string
    
    func f() {
    	a = "hello, world"
    	l.Unlock()
    }
    
    func main() {
    	l.Lock()
    	go f()
    	l.Lock()
    	print(a)
    }
    </pre>
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Mar 04 15:54:42 UTC 2024
    - 26.6K bytes
    - Viewed (0)
Back to top