Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 227 for unpack (0.08 sec)

  1. cmd/site-replication-utils.go

    						}()
    					}
    				}
    				wg.Wait()
    				sm.Unlock()
    			}
    			sTimer.Reset(siteResyncSaveInterval)
    		case <-ctx.Done():
    			return
    		}
    	}
    }
    
    // update overall site resync state
    func (sm *siteResyncMetrics) updateState(s SiteResyncStatus) error {
    	if !globalSiteReplicationSys.isEnabled() {
    		return nil
    	}
    	sm.Lock()
    	defer sm.Unlock()
    	switch s.Status {
    	case ResyncStarted:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/ForwardingLock.java

      }
    
      @Override
      public boolean tryLock(long time, TimeUnit unit) throws InterruptedException {
        return delegate().tryLock(time, unit);
      }
    
      @Override
      public void unlock() {
        delegate().unlock();
      }
    
      @Override
      public Condition newCondition() {
        return delegate().newCondition();
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 1.5K bytes
    - Viewed (0)
  3. internal/dsync/locked_rand.go

    func (r *lockedRandSource) Int63() (n int64) {
    	r.lk.Lock()
    	n = r.src.Int63()
    	r.lk.Unlock()
    	return
    }
    
    // Seed uses the provided seed value to initialize the generator to a
    // deterministic state.
    func (r *lockedRandSource) Seed(seed int64) {
    	r.lk.Lock()
    	r.src.Seed(seed)
    	r.lk.Unlock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Oct 18 15:39:59 UTC 2021
    - 1.3K bytes
    - Viewed (0)
  4. .gitmodules

    [submodule "okhttp-hpacktests/src/test/resources/hpack-test-case"]
    	path = okhttp-hpacktests/src/test/resources/hpack-test-case
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Dec 10 09:33:37 UTC 2022
    - 182 bytes
    - Viewed (0)
  5. internal/lock/lock.go

    // IsClosed - Check if the rlocked file is already closed.
    func (r *RLockedFile) IsClosed() bool {
    	r.mutex.Lock()
    	defer r.mutex.Unlock()
    	return r.refs == 0
    }
    
    // IncLockRef - is used by called to indicate lock refs.
    func (r *RLockedFile) IncLockRef() {
    	r.mutex.Lock()
    	r.refs++
    	r.mutex.Unlock()
    }
    
    // Close - this closer implements a special closer
    // closes the underlying fd only when the refs
    // reach zero.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 2.5K bytes
    - Viewed (0)
  6. internal/lock/lock_test.go

    	if err = rlk.Close(); err != os.ErrInvalid {
    		t.Fatal(err)
    	}
    
    	_, err = newRLockedFile(nil)
    	if err != os.ErrInvalid {
    		t.Fatal("Unexpected error", err)
    	}
    }
    
    // Tests lock and unlock semantics.
    func TestLockAndUnlock(t *testing.T) {
    	f, err := os.CreateTemp("", "lock")
    	if err != nil {
    		t.Fatal(err)
    	}
    	f.Close()
    	defer func() {
    		err = os.Remove(f.Name())
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.6K bytes
    - Viewed (0)
  7. cmd/background-newdisks-heal-ops.go

    }
    
    func (h *healingTracker) setBucket(bucket string) {
    	h.mu.Lock()
    	defer h.mu.Unlock()
    
    	h.Bucket = bucket
    }
    
    func (h *healingTracker) getObject() string {
    	h.mu.RLock()
    	defer h.mu.RUnlock()
    
    	return h.Object
    }
    
    func (h *healingTracker) setObject(object string) {
    	h.mu.Lock()
    	defer h.mu.Unlock()
    
    	h.Object = object
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  8. internal/grid/connection.go

    			}
    			if state == StateShutdown || state == StateConnectionError {
    				c.connChange.L.Unlock()
    				return
    			}
    			c.connChange.Wait()
    			select {
    			case <-ctx.Done():
    				c.connChange.L.Unlock()
    				return
    			default:
    			}
    		}
    		c.connChange.L.Unlock()
    		if len(queue) == 0 {
    			// Send single message without merging.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  9. okhttp-hpacktests/src/test/java/okhttp3/internal/http2/hpackjson/HpackJsonUtil.kt

        fileSystem.read(file) {
          return readStory(this)
        }
      }
    
      /** Iterate through the hpack-test-case resources, only picking stories for the current draft.  */
      fun storiesForCurrentDraft(): Array<String> {
        val resource =
          HpackJsonUtil::class.java.getResource("/hpack-test-case")
            ?: return arrayOf()
    
        val testCaseDirectory = File(resource.toURI()).toOkioPath()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  10. 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)
Back to top