Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 55 for MakeOp (0.14 sec)

  1. src/runtime/netpoll_windows.go

    	// nothing to do
    	return 0
    }
    
    func netpollarm(pd *pollDesc, mode int) {
    	throw("runtime: unused")
    }
    
    func netpollBreak() {
    	// Failing to cas indicates there is an in-flight wakeup, so we're done here.
    	if !netpollWakeSig.CompareAndSwap(0, 1) {
    		return
    	}
    
    	key := packNetpollKey(netpollSourceBreak, nil)
    	if stdcall4(_PostQueuedCompletionStatus, iocphandle, 0, key, 0) == 0 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Mar 26 19:58:28 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  2. src/runtime/os_darwin.go

    	}
    }
    
    //go:nosplit
    func semasleep(ns int64) int32 {
    	var start int64
    	if ns >= 0 {
    		start = nanotime()
    	}
    	g := getg()
    	mp := g.m
    	if g == mp.gsignal {
    		// sema sleep/wakeup are implemented with pthreads, which are not async-signal-safe on Darwin.
    		throw("semasleep on Darwin signal stack")
    	}
    	pthread_mutex_lock(&mp.mutex)
    	for {
    		if mp.count > 0 {
    			mp.count--
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Dec 05 20:34:30 UTC 2023
    - 11.9K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/aggregate/controller_test.go

    			t.Fatal("Returned Instance is incorrect")
    		}
    	}
    
    	// Get Instances from mockAdapter2
    	instances = aggregateCtl.GetProxyServiceTargets(&model.Proxy{IPAddresses: []string{mock.MakeIP(mock.WorldService, 1)}})
    	if len(instances) != 6 {
    		t.Fatalf("Returned GetProxyServiceTargets' amount %d is not correct", len(instances))
    	}
    	for _, inst := range instances {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 06:28:11 UTC 2024
    - 14.5K bytes
    - Viewed (0)
  4. pkg/workloadapi/workload.proto

      // TODO: support this field
      string hostname = 21;
    
      // Network represents the network this workload is on. This may be elided for the default network.
      // A (network,address) pair makeup a unique key for a workload *at a point in time*.
      string network = 4;
    
      // Protocol that should be used to connect to this workload.
      TunnelProtocol tunnel_protocol = 5;
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 18:02:35 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  5. src/runtime/select.go

    			} else {
    				c.recvq.dequeueSudoG(sglist)
    			}
    		}
    		sgnext = sglist.waitlink
    		sglist.waitlink = nil
    		releaseSudog(sglist)
    		sglist = sgnext
    	}
    
    	if cas == nil {
    		throw("selectgo: bad wakeup")
    	}
    
    	c = cas.c
    
    	if debugSelect {
    		print("wait-return: cas0=", cas0, " c=", c, " cas=", cas, " send=", casi < nsends, "\n")
    	}
    
    	if casi < nsends {
    		if !caseSuccess {
    			goto sclose
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Mar 13 21:36:04 UTC 2024
    - 15K bytes
    - Viewed (0)
  6. src/internal/trace/internal/oldtrace/parser.go

    	EvTimerGoroutine    event.Type = 35 // denotes timer goroutine [timer goroutine id]
    	EvFutileWakeup      event.Type = 36 // denotes that the previous wakeup of this goroutine was futile [timestamp]
    	EvString            event.Type = 37 // string dictionary entry [ID, length, string]
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 24 21:15:28 UTC 2024
    - 46.8K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache.go

    	// As a result, the condition in the below for loop will never be
    	// satisfied (w.resourceVersion is never negative), this call will
    	// never hit the w.cond.Wait().
    	// As a result - we can optimize the code by not firing the wakeup
    	// function (and avoid starting a gorotuine), especially given that
    	// resourceVersion=0 is the most common case.
    	if resourceVersion > 0 {
    		go func() {
    			// Wake us up when the time limit has expired.  The docs
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 10:20:57 UTC 2024
    - 26.2K bytes
    - Viewed (0)
  8. src/time/sleep_test.go

    		samples += float64(s.count)
    	}
    	b.ReportMetric(0, "ns/op")
    	b.ReportMetric(total/samples, "avg-late-ns")
    	b.ReportMetric(float64(max.Nanoseconds()), "max-late-ns")
    }
    
    // Benchmark timer latency with staggered wakeup times and varying CPU bound
    // workloads. https://golang.org/issue/38860
    func BenchmarkStaggeredTickerLatency(b *testing.B) {
    	gmp := runtime.GOMAXPROCS(0)
    	if gmp < 2 || runtime.NumCPU() < gmp {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Mar 22 16:33:57 UTC 2024
    - 22.5K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

                    removeWaiter(node);
                    throw new InterruptedException();
                  }
    
                  // Otherwise re-read and check doneness. If we loop then it must have been a spurious
                  // wakeup
                  localValue = value;
                  if (localValue != null & !(localValue instanceof SetFuture)) {
                    return getDoneValue(localValue);
                  }
    
                  // timed out?
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 63.1K bytes
    - Viewed (1)
  10. guava/src/com/google/common/util/concurrent/AbstractFuture.java

                    removeWaiter(node);
                    throw new InterruptedException();
                  }
    
                  // Otherwise re-read and check doneness. If we loop then it must have been a spurious
                  // wakeup
                  localValue = value;
                  if (localValue != null & !(localValue instanceof SetFuture)) {
                    return getDoneValue(localValue);
                  }
    
                  // timed out?
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 62.8K bytes
    - Viewed (1)
Back to top