Search Options

Results per page
Sort
Preferred Languages
Advance

Results 191 - 200 of 269 for sockso (0.12 sec)

  1. cmd/admin-handlers.go

    	toEntry := func(lri lockRequesterInfo) string {
    		return fmt.Sprintf("%s/%s", lri.Name, lri.UID)
    	}
    	for _, peerLock := range peerLocks {
    		if peerLock == nil {
    			continue
    		}
    		for k, v := range peerLock.Locks {
    			for _, lockReqInfo := range v {
    				if val, ok := entryMap[toEntry(lockReqInfo)]; ok {
    					val.ServerList = append(val.ServerList, peerLock.Addr)
    				} else {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  2. cmd/tier.go

    // name tierName, otherwise returns madmin.Unsupported and false. N B this
    // function is meant for internal use, where the caller is expected to take
    // appropriate locks.
    func (config *TierConfigMgr) isTierNameInUse(tierName string) (madmin.TierType, bool) {
    	if t, ok := config.Tiers[tierName]; ok {
    		return t.Type, true
    	}
    	return madmin.Unsupported, false
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:44:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  3. internal/grid/manager.go

    type Manager struct {
    	// ID is an instance ID, that will change whenever the server restarts.
    	// This allows remotes to keep track of whether state is preserved.
    	ID uuid.UUID
    
    	// Immutable after creation, so no locks.
    	targets map[string]*Connection
    
    	// serverside handlers.
    	handlers handlers
    
    	// local host name.
    	local string
    
    	// authToken is a function that will validate a token.
    	authToken ValidateTokenFn
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/collect/ConcurrentHashMultisetTest.java

        assertEquals(0, cms.count("a"));
        assertTrue(cms.removeExactly("b", 2));
        assertEquals(1, cms.count("b"));
      }
    
      public void testIteratorRemove_actualMap() {
        // Override to avoid using mocks.
        multiset = ConcurrentHashMultiset.create();
    
        multiset.add(KEY);
        multiset.add(KEY + "_2");
        multiset.add(KEY);
    
        int mutations = 0;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 14.2K bytes
    - Viewed (0)
  5. android/guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java

            this.runnable = runnable;
            this.executor = executor;
          }
        }
      }
    
      // A version of the list that uses compare and swap to manage the stack without locks.
      @SuppressWarnings({"SunApi", "removal"}) // b/345822163
      private static final class ExecutionListCAS {
        static final Logger log = Logger.getLogger(ExecutionListCAS.class.getName());
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 20.5K bytes
    - Viewed (0)
  6. cmd/metrics-v2.go

    				Namespace: minioNamespace,
    				Subsystem: "locks",
    				Name:      "total",
    				Help:      "Number of current locks on this peer",
    				Type:      gaugeMetric,
    			},
    			Value: float64(st.Total),
    		})
    		metrics = append(metrics, MetricV2{
    			Description: MetricDescription{
    				Namespace: minioNamespace,
    				Subsystem: "locks",
    				Name:      "write_total",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 131.9K bytes
    - Viewed (0)
  7. CHANGELOG/CHANGELOG-1.24.md

    
    ## Dependencies
    
    ### Added
    - github.com/armon/go-socks5: [e753329](https://github.com/armon/go-socks5/tree/e753329)
    - github.com/blang/semver/v4: [v4.0.0](https://github.com/blang/semver/v4/tree/v4.0.0)
    - github.com/google/gnostic: [v0.5.7-v3refs](https://github.com/google/gnostic/tree/v0.5.7-v3refs)
    
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Thu Aug 24 00:02:43 UTC 2023
    - 473.4K bytes
    - Viewed (0)
  8. doc/go_mem.html

    var limit = make(chan int, 3)
    
    func main() {
    	for _, w := range work {
    		go func(w func()) {
    			limit <- 1
    			w()
    			<-limit
    		}(w)
    	}
    	select{}
    }
    </pre>
    
    <h3 id="locks">Locks</h3>
    
    <p>
    The <code>sync</code> package implements two lock data types,
    <code>sync.Mutex</code> and <code>sync.RWMutex</code>.
    </p>
    
    <p class="rule">
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Mar 04 15:54:42 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  9. okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt

        Thread.sleep(500)
        server.send("Hello, WebSockets!")
        clientListener.assertTextMessage("Hello, WebSockets!")
        closeWebSockets(webSocket, server)
      }
    
      /**
       * We had a bug where web socket connections were leaked if the HTTP connection upgrade was not
       * successful. This test confirms that connections are released back to the connection pool!
       * https://github.com/square/okhttp/issues/4258
       */
      @Test
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 35.2K bytes
    - Viewed (0)
  10. cmd/metrics-v3-types.go

    	promMetrics := metricValues.ToPromMetrics(mg.CollectorPath.metricPrefix(),
    		mg.ExtraLabels)
    	for _, metric := range promMetrics {
    		ch <- metric
    	}
    }
    
    // LockAndSetBuckets - locks the buckets and sets the given buckets. It returns
    // a function to unlock the buckets.
    func (mg *MetricsGroup) LockAndSetBuckets(buckets []string) func() {
    	mg.bucketsLock.Lock()
    	mg.buckets = buckets
    	return func() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 30 22:28:46 UTC 2024
    - 15.6K bytes
    - Viewed (0)
Back to top