Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for MakeOp (0.13 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/runtime/netpoll_solaris.go

    	default:
    		throw("runtime: bad mode")
    	}
    	unlock(&pd.lock)
    }
    
    // netpollBreak interrupts a port_getn wait.
    func netpollBreak() {
    	// Failing to cas indicates there is an in-flight wakeup, so we're done here.
    	if !netpollWakeSig.CompareAndSwap(0, 1) {
    		return
    	}
    
    	// Use port_alert to put portfd into alert mode.
    	// This will wake up all threads sleeping in port_getn on portfd,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  5. src/runtime/HACKING.md

    For one-shot notifications, use `note`, which provides `notesleep` and
    `notewakeup`. Unlike traditional UNIX `sleep`/`wakeup`, `note`s are
    race-free, so `notesleep` returns immediately if the `notewakeup` has
    already happened. A `note` can be reset after use with `noteclear`,
    which must not race with a sleep or wakeup. Like `mutex`, blocking on
    a `note` blocks the M. However, there are different ways to sleep on a
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top