Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for MakeOp (0.4 sec)

  1. src/runtime/trace.go

    // timer *and* nothing else will call wake concurrently.
    func (s *wakeableSleep) close() {
    	// Set wakeup to nil so that a late timer ends up being a no-op.
    	lock(&s.lock)
    	if raceenabled {
    		raceacquire(unsafe.Pointer(&s.lock))
    	}
    	wakeup := s.wakeup
    	s.wakeup = nil
    
    	// Close the channel.
    	close(wakeup)
    
    	if raceenabled {
    		racerelease(unsafe.Pointer(&s.lock))
    	}
    	unlock(&s.lock)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 21:17:41 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  2. src/runtime/sema.go

    // Intended use is provide a sleep and wakeup
    // primitive that can be used in the contended case
    // of other synchronization primitives.
    // Thus it targets the same goal as Linux's futex,
    // but it has much simpler semantics.
    //
    // That is, don't think of these as semaphores.
    // Think of them as a way to implement sleep and wakeup
    // such that every sleep is paired with a single wakeup,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 19K bytes
    - Viewed (0)
  3. src/internal/trace/trace_test.go

    				t.Logf("%d: %q", samples, stack)
    			}
    			t.Logf("CPU profile:\n%s", stderr)
    		}
    	})
    }
    
    func TestTraceFutileWakeup(t *testing.T) {
    	testTraceProg(t, "futile-wakeup.go", func(t *testing.T, tb, _ []byte, _ bool) {
    		// Check to make sure that no goroutine in the "special" trace region
    		// ends up blocking, unblocking, then immediately blocking again.
    		//
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  4. src/cmd/trace/main.go

    	mux.Handle("/", traceviewer.MainHandler([]traceviewer.View{
    		{Type: traceviewer.ViewProc, Ranges: ranges},
    		// N.B. Use the same ranges for threads. It takes a long time to compute
    		// the split a second time, but the makeup of the events are similar enough
    		// that this is still a good split.
    		{Type: traceviewer.ViewThread, Ranges: ranges},
    	}))
    
    	// Catapult handlers.
    	mux.Handle("/trace", traceviewer.TraceHandler())
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        waiter1.interrupt();
    
        waiter1.join();
        waiter2.awaitWaiting(); // should still be blocked
    
        LockSupport.unpark(waiter2); // spurious wakeup
        waiter2.awaitWaiting(); // should eventually re-park
    
        future.set(null);
        waiter2.join();
      }
    
      public void testRemoveWaiter_polling() throws Exception {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  10. src/runtime/chan.go

    	gp.param = nil
    	if mysg.releasetime > 0 {
    		blockevent(mysg.releasetime-t0, 2)
    	}
    	mysg.c = nil
    	releaseSudog(mysg)
    	if closed {
    		if c.closed == 0 {
    			throw("chansend: spurious wakeup")
    		}
    		panic(plainError("send on closed channel"))
    	}
    	return true
    }
    
    // send processes a send operation on an empty channel c.
    // The value ep sent by the sender is copied to the receiver sg.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:16:50 UTC 2024
    - 25.9K bytes
    - Viewed (0)
Back to top