Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 57 for Signalfd (0.16 sec)

  1. src/cmd/vendor/golang.org/x/sys/unix/mkerrors.sh

    #include <sys/ioctl.h>
    #include <sys/mman.h>
    #include <sys/mount.h>
    #include <sys/prctl.h>
    #include <sys/stat.h>
    #include <sys/types.h>
    #include <sys/time.h>
    #include <sys/select.h>
    #include <sys/signalfd.h>
    #include <sys/socket.h>
    #include <sys/timerfd.h>
    #include <sys/uio.h>
    #include <sys/xattr.h>
    #include <netinet/udp.h>
    #include <linux/audit.h>
    #include <linux/bpf.h>
    #include <linux/can.h>
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 20.2K bytes
    - Viewed (0)
  2. src/cmd/vendor/golang.org/x/sys/unix/syscall_linux.go

    	_, err := setfsuid(uid)
    	return err
    }
    
    func Signalfd(fd int, sigmask *Sigset_t, flags int) (newfd int, err error) {
    	return signalfd(fd, sigmask, _C__NSIG/8, flags)
    }
    
    //sys	Setpriority(which int, who int, prio int) (err error)
    //sys	Setxattr(path string, attr string, data []byte, flags int) (err error)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Mar 07 05:26:45 UTC 2024
    - 77.5K bytes
    - Viewed (0)
  3. src/cmd/vendor/golang.org/x/sys/unix/zsyscall_linux.go

    	if e1 != 0 {
    		err = errnoErr(e1)
    	}
    	return
    }
    
    // THIS FILE IS GENERATED BY THE COMMAND AT THE TOP; DO NOT EDIT
    
    func signalfd(fd int, sigmask *Sigset_t, maskSize uintptr, flags int) (newfd int, err error) {
    	r0, _, e1 := Syscall6(SYS_SIGNALFD4, uintptr(fd), uintptr(unsafe.Pointer(sigmask)), uintptr(maskSize), uintptr(flags), 0, 0)
    	newfd = int(r0)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Mar 07 05:26:45 UTC 2024
    - 54.6K bytes
    - Viewed (0)
  4. platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/DefaultFileLockManagerAwaitableFileLockReleasedSignalTest.groovy

        def "can reuse signal"() {
            given:
            def signalCount = new AtomicInteger()
    
            when:
            start {
                while (signalCount.get() < 2) {
                    def signaled = signal.await(10000)
                    if (signaled) {
                        signalCount.incrementAndGet()
                    }
                }
            }
    
            then:
            poll {
                assert signal.waiting
            }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:08:47 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  5. platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/locklistener/DefaultFileLockContentionHandlerTest.groovy

        def "client receives signal when lock is released"() {
            def signaled = new AtomicBoolean()
    
            when:
            int port = handler.reservePort()
            handler.start(10) { signal ->
                signal.trigger()
            }
    
            client.reservePort()
            client.start(11) {}
            client.maybePingOwner(port, 10, "lock 1", 50000) {
                signaled.set(true)
            }
    
            then:
            poll {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 16 15:49:49 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  6. src/runtime/netpoll_windows.go

    		// so we still need to use a timeout with GetQueuedCompletionStatusEx.
    		// TODO: Improve the Go scheduler to support non-blocking timers.
    		signaled := netpollQueueTimer(delay)
    		if signaled {
    			// There is a small window between the SetWaitableTimer and the NtAssociateWaitCompletionPacket
    			// where the timer can expire. We can return immediately in this case.
    			return gList{}, 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)
  7. platforms/core-runtime/time/src/main/java/org/gradle/internal/time/ExponentialBackoff.java

            Result<T> result;
            while (!(result = query.run()).isSuccessful()) {
                if (timer.hasExpired()) {
                    break;
                }
                boolean signaled = signal.await(backoffPeriodFor(++iteration));
                if (signaled) {
                    iteration = 0;
                }
            }
            return result.getValue();
        }
    
        long backoffPeriodFor(int iteration) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Apr 12 08:49:35 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/server/genericapiserver_graceful_termination_test.go

    	waitForAPIServerStarted(t, doer)
    
    	// act
    	if isChanClosed(s.lifecycleSignals.MuxAndDiscoveryComplete.Signaled(), 1*time.Second) {
    		t.Fatalf("%s is closed whereas the TestSignal is still open", s.lifecycleSignals.MuxAndDiscoveryComplete.Name())
    	}
    
    	close(testSignal1)
    	if isChanClosed(s.lifecycleSignals.MuxAndDiscoveryComplete.Signaled(), 1*time.Second) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 18:59:21 UTC 2024
    - 38.3K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/server/genericapiserver.go

    	go func() {
    		defer stopHTTPServer(errors.New("time to stop HTTP server"))
    
    		timeToStopHttpServerCh := notAcceptingNewRequestCh.Signaled()
    		if s.ShutdownSendRetryAfter {
    			timeToStopHttpServerCh = drainedCh.Signaled()
    		}
    
    		<-timeToStopHttpServerCh
    	}()
    
    	// Start the audit backend before any request comes in. This means we must call Backend.Run
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 18:59:21 UTC 2024
    - 42.9K bytes
    - Viewed (0)
  10. src/iter/iter.go

    // or after calling stop. These calls will continue
    // to return the zero V and false.
    //
    // Stop ends the iteration. It must be called when the caller is
    // no longer interested in next values and next has not yet
    // signaled that the sequence is over (with a false boolean return).
    // It is valid to call stop multiple times and when next has
    // already returned false.
    //
    // It is an error to call next or stop from multiple goroutines
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 19:09:28 UTC 2024
    - 6.6K bytes
    - Viewed (0)
Back to top