Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 113 for signalM (0.13 sec)

  1. platforms/core-runtime/build-operations/src/main/java/org/gradle/internal/operations/BuildOperationListener.java

     *
     * Unlike ListenerManager bound listeners, build operation listener signalling is not synchronized.
     * Implementations must take care to be threadsafe.
     *
     * Related signals are guaranteed to be serialized.
     * That is, a listener will not concurrently be notified of the same operation starting and finishing.
     *
     * @since 3.5
     */
    @EventScope(Global.class)
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Mar 12 02:21:10 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  2. src/os/pidfd_other.go

    	return 0, syscall.ENOSYS
    }
    
    func (p *Process) pidfdRelease() {}
    
    func (_ *Process) pidfdWait() (*ProcessState, error) {
    	panic("unreachable")
    }
    
    func (_ *Process) pidfdSendSignal(_ syscall.Signal) error {
    	panic("unreachable")
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 10 22:06:47 UTC 2024
    - 692 bytes
    - Viewed (0)
  3. pkg/scheduler/framework/runtime/waiting_pods_map.go

    // If this is the last remaining plugin to allow, then a success signal is delivered
    // to unblock the pod.
    func (w *waitingPod) Allow(pluginName string) {
    	w.mu.Lock()
    	defer w.mu.Unlock()
    	if timer, exist := w.pendingPlugins[pluginName]; exist {
    		timer.Stop()
    		delete(w.pendingPlugins, pluginName)
    	}
    
    	// Only signal success status after all plugins have allowed
    	if len(w.pendingPlugins) != 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  4. src/runtime/debug.go

    //
    // Ensure mayMoreStackPreempt can be called for all ABIs.
    //
    //go:nosplit
    //go:linkname mayMoreStackPreempt
    func mayMoreStackPreempt() {
    	// Don't do anything on the g0 or gsignal stack.
    	gp := getg()
    	if gp == gp.m.g0 || gp == gp.m.gsignal {
    		return
    	}
    	// Force a preemption, unless the stack is already poisoned.
    	if gp.stackguard0 < stackPoisonMin {
    		gp.stackguard0 = stackPreempt
    	}
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sat May 11 20:38:24 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  5. src/os/exec_windows.go

    	if e != nil {
    		return nil, NewSyscallError("GetProcessTimes", e)
    	}
    	defer p.Release()
    	return &ProcessState{p.Pid, syscall.WaitStatus{ExitCode: ec}, &u}, nil
    }
    
    func (p *Process) signal(sig Signal) error {
    	handle, status := p.handleTransientAcquire()
    	switch status {
    	case statusDone:
    		return ErrProcessDone
    	case statusReleased:
    		return syscall.EINVAL
    	}
    	defer p.handleTransientRelease()
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 10 22:06:47 UTC 2024
    - 5K bytes
    - Viewed (0)
  6. src/internal/syscall/unix/siginfo_linux_test.go

    	"internal/syscall/unix"
    	"runtime"
    	"strings"
    	"testing"
    	"unsafe"
    )
    
    // TestSiginfoChildLayout validates SiginfoChild layout. Modelled after
    // static assertions in linux kernel's arch/*/kernel/signal*.c.
    func TestSiginfoChildLayout(t *testing.T) {
    	var si unix.SiginfoChild
    
    	const host64bit = goarch.PtrSize == 8
    
    	if v := unsafe.Sizeof(si); v != 128 {
    		t.Fatalf("sizeof: got %d, want 128", v)
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 01:23:00 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  7. platforms/enterprise/enterprise/src/main/java/org/gradle/internal/enterprise/GradleEnterprisePluginEndOfBuildListener.java

     */
    
    package org.gradle.internal.enterprise;
    
    import org.gradle.api.problems.internal.Problem;
    
    import javax.annotation.Nullable;
    import java.util.Collection;
    
    /**
     * Used to signal the end of build to the plugin.
     *
     * Uses a specific listener to guarantee being invoked after user buildFinished callbacks.
     * Expected to be invoked once for a build tree.
     *
     * Implemented by the Enterprise plugin.
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 21 11:17:11 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/Dispatcher.kt

          }
        }
    
        return isRunning
      }
    
      /** Used by [Call.execute] to signal it is in-flight. */
      internal fun executed(call: RealCall) =
        this.withLock {
          runningSyncCalls.add(call)
        }
    
      /** Used by [AsyncCall.run] to signal completion. */
      internal fun finished(call: AsyncCall) {
        call.callsPerHost.decrementAndGet()
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 9K bytes
    - Viewed (0)
  9. cmd/peer-rest-common.go

    	peerRESTUserTemp        = "user-temp"
    	peerRESTPolicy          = "policy"
    	peerRESTUserOrGroup     = "user-or-group"
    	peerRESTUserType        = "user-type"
    	peerRESTIsGroup         = "is-group"
    	peerRESTSignal          = "signal"
    	peerRESTSubSys          = "sub-sys"
    	peerRESTProfiler        = "profiler"
    	peerRESTSize            = "size"
    	peerRESTConcurrent      = "concurrent"
    	peerRESTDuration        = "duration"
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon May 06 09:45:10 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  10. platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/locklistener/FileLockContentionHandler.java

         *
         * @return true if the owner was pinged in this call
         */
        boolean maybePingOwner(int port, long lockId, String displayName, long timeElapsed, @Nullable FileLockReleasedSignal signal);
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 18 01:28:02 UTC 2024
    - 1.6K bytes
    - Viewed (0)
Back to top