Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 255 for blocked (0.14 sec)

  1. src/internal/trace/event/go122/event.go

    	EvGoBlock             // goroutine blocks [timestamp, reason, stack ID]
    	EvGoUnblock           // goroutine is unblocked [timestamp, goroutine ID, goroutine seq, stack ID]
    	EvGoSyscallBegin      // syscall enter [timestamp, P seq, stack ID]
    	EvGoSyscallEnd        // syscall exit [timestamp]
    	EvGoSyscallEndBlocked // syscall exit and it blocked at some point [timestamp]
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  2. tensorflow/c/c_api_experimental.h

    // from a placeholder node "arg_tensor_enqueue_<tensor_id>".
    //
    // `tensor` is still owned by the caller. This call will be blocked if the queue
    // has reached its capacity, and will be unblocked when the queued tensors again
    // drop below the capacity due to dequeuing.
    //
    // Tensors are dequeued via the corresponding TF dequeue op.
    // TODO(hongm): Add support for `timeout_ms`.
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Apr 27 21:07:00 UTC 2023
    - 15.1K bytes
    - Viewed (0)
  3. src/runtime/os_windows.go

    				// Don't profile ourselves.
    				continue
    			}
    
    			lock(&mp.threadLock)
    			// Do not profile threads blocked on Notes,
    			// this includes idle worker threads,
    			// idle timer thread, idle heap scavenger, etc.
    			if mp.thread == 0 || mp.profilehz == 0 || mp.blocked {
    				unlock(&mp.threadLock)
    				continue
    			}
    			// Acquire our own handle to the thread.
    			var thread uintptr
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 26 22:55:25 UTC 2024
    - 41.5K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

        //            (__)\       )\/\
        //                ||----w |
        //                ||     ||
        Runnable state = get();
        Blocker blocker = null;
        while (state instanceof Blocker || state == PARKED) {
          if (state instanceof Blocker) {
            blocker = (Blocker) state;
          }
          spinCount++;
          if (spinCount > MAX_BUSY_WAIT_SPINS) {
            /*
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Sep 29 21:34:48 UTC 2023
    - 9.9K bytes
    - Viewed (0)
  5. src/os/signal/doc.go

    entirely.
    
    If the program is started with a non-empty signal mask, some signals
    will be explicitly unblocked as described above. If Notify is called
    for a blocked signal, it will be unblocked. If, later, Reset is
    called for that signal, or Stop is called on all channels passed to
    Notify for that signal, the signal will once again be blocked.
    
    # SIGPIPE
    
    When a Go program writes to a broken pipe, the kernel will raise a
    SIGPIPE signal.
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 18:11:00 UTC 2024
    - 11K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/InterruptibleTask.java

        //            (__)\       )\/\
        //                ||----w |
        //                ||     ||
        Runnable state = get();
        Blocker blocker = null;
        while (state instanceof Blocker || state == PARKED) {
          if (state instanceof Blocker) {
            blocker = (Blocker) state;
          }
          spinCount++;
          if (spinCount > MAX_BUSY_WAIT_SPINS) {
            /*
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Sep 29 21:34:48 UTC 2023
    - 9.9K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller_test.go

    	}()
    
    	// Start controller
    	wg.Add(1)
    	go func() {
    		defer wg.Done()
    		stopReason := myController.Run(testContext)
    		require.ErrorIs(t, stopReason, context.Canceled)
    	}()
    
    	// The controller is blocked because the reconcile function sends on an
    	// unbuffered channel.
    	require.False(t, myController.HasSynced())
    
    	// Wait for all enqueued reconciliations
    	require.NoError(t, waitForReconcile(initialObject))
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 12 18:58:24 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  8. src/runtime/pprof/pprof.go

    // the program began (including garbage-collected bytes).
    //
    // # Block profile
    //
    // The block profile tracks time spent blocked on synchronization primitives,
    // such as [sync.Mutex], [sync.RWMutex], [sync.WaitGroup], [sync.Cond], and
    // channel send/receive/select.
    //
    // Stack traces correspond to the location that blocked (for example,
    // [sync.Mutex.Lock]).
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:52:17 UTC 2024
    - 30.6K bytes
    - Viewed (0)
  9. api/maven-api-settings/src/main/mdo/settings.mdo

                @since Maven 3.
              </description>
            </field>
            <field>
              <name>blocked</name>
              <version>1.2.0+</version>
              <type>boolean</type>
              <defaultValue>false</defaultValue>
              <description>
                <![CDATA[
                Whether this mirror should be blocked from any download request but fail the download process, explaining why.
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Sat Feb 17 18:40:11 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  10. src/runtime/traceruntime.go

    	tl.eventWriter(traceGoRunning, traceProcRunning).commit(traceEvGCMarkAssistEnd)
    }
    
    // GoCreate emits a GoCreate event.
    func (tl traceLocker) GoCreate(newg *g, pc uintptr, blocked bool) {
    	newg.trace.setStatusTraced(tl.gen)
    	ev := traceEvGoCreate
    	if blocked {
    		ev = traceEvGoCreateBlocked
    	}
    	tl.eventWriter(traceGoRunning, traceProcRunning).commit(ev, traceArg(newg.goid), tl.startPC(pc), tl.stack(2))
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 22:31:00 UTC 2024
    - 25.7K bytes
    - Viewed (0)
Back to top