- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 343 for notifyCh (0.22 sec)
-
src/cmd/go/internal/base/signal.go
// Interrupted is closed when the go command receives an interrupt signal. var Interrupted = make(chan struct{}) // processSignals setups signal handler. func processSignals() { sig := make(chan os.Signal, 1) signal.Notify(sig, signalsToIgnore...) go func() { <-sig close(Interrupted) }() } var onceProcessSignals sync.Once // StartSigHandlers starts the signal handlers. func StartSigHandlers() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Dec 02 16:43:58 UTC 2020 - 663 bytes - Viewed (0) -
src/net/textproto/pipeline.go
// // id := p.Next() // take a number // // p.StartRequest(id) // wait for turn to send request // «send request» // p.EndRequest(id) // notify Pipeline that request is sent // // p.StartResponse(id) // wait for turn to read response // «read response» // p.EndResponse(id) // notify Pipeline that response is read // // A pipelined server can use the same calls to ensure that
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 08 16:19:51 UTC 2020 - 3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/event/DefaultListenerManagerTest.groovy
def "can remove a listener which tries to notify a broadcaster itself trying to notify the same listener"() { given: def listener1 = { sleep 1000 // Try to get broadcaster, should not block def broadcaster = manager.getBroadcaster(TestBarListener) // Notify broadcaster, should not block broadcaster.bar(1) // today, deadlocks here
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 29.1K bytes - Viewed (0) -
cmd/kubeadm/app/phases/etcd/local_test.go
- --advertise-client-urls=https://:2379 - --cert-file=etcd/server.crt - --client-cert-auth=true - --data-dir=%s/etcd - --experimental-initial-corrupt-check=true - --experimental-watch-progress-notify-interval=5s - --initial-advertise-peer-urls=https://:2380 - --initial-cluster==https://:2380 - --key-file=etcd/server.key - --listen-client-urls=https://127.0.0.1:2379,https://:2379
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 23 14:07:27 UTC 2024 - 15.2K bytes - Viewed (0) -
src/cmd/cgo/internal/testsanitizers/testdata/tsan12.go
// invoke signal handlers. import ( "fmt" "os" "os/exec" "os/signal" "syscall" ) import "C" func main() { ch := make(chan os.Signal, 1) signal.Notify(ch, syscall.SIGUSR1) if err := exec.Command("true").Run(); err != nil { fmt.Fprintf(os.Stderr, "Unexpected error from `true`: %v", err) os.Exit(1) } syscall.Kill(syscall.Getpid(), syscall.SIGUSR1) <-ch
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 11:59:56 UTC 2023 - 929 bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/initialization/buildsrc/BuildSrcBuildOperationsIntegrationTest.groovy
graphNotifyOps.size() == 2 graphNotifyOps[0].displayName == 'Notify task graph whenReady listeners (:buildSrc)' graphNotifyOps[0].details.buildPath == ':buildSrc' graphNotifyOps[0].parentId == treeTaskGraphOps[0].id graphNotifyOps[1].displayName == "Notify task graph whenReady listeners" graphNotifyOps[1].details.buildPath == ":"
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 03 15:21:23 UTC 2024 - 6K bytes - Viewed (0) -
.github/workflows/slack-notifier.yml
name: IDE Experience team notifier run-name: Notify the IDE Experience team about relevant issues on: issues: types: - labeled permissions: {} jobs: send-slack-notification: if: ${{ github.event.label.name == 'in:ide' || github.event.label.name == 'in:eclipse-plugin' || github.event.label.name == 'in:idea-plugin' || github.event.label.name == 'in:tooling-api' }} runs-on: ubuntu-latest steps:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 02 09:13:16 UTC 2024 - 1.3K bytes - Viewed (0) -
src/cmd/cgo/internal/testcarchive/testdata/libgo4/libgo4.go
import ( "os" "os/signal" "sync/atomic" "syscall" ) var sigioCount int32 // Catch SIGIO. // //export GoCatchSIGIO func GoCatchSIGIO() { c := make(chan os.Signal, 1) signal.Notify(c, syscall.SIGIO) go func() { for range c { atomic.AddInt32(&sigioCount, 1) } }() } // Raise SIGIO. // //export GoRaiseSIGIO func GoRaiseSIGIO(p *C.pthread_t) { C.CRaiseSIGIO(p) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 11:59:56 UTC 2023 - 854 bytes - Viewed (0) -
src/cmd/cgo/internal/testsanitizers/testdata/tsan10.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 11:59:56 UTC 2023 - 798 bytes - Viewed (0) -
src/main/java/jcifs/internal/NotifyResponse.java
import java.util.List; import jcifs.FileNotifyInformation; /** * @author mbechler * */ public interface NotifyResponse extends CommonServerMessageBlockResponse { /** * @return notify information */ List<FileNotifyInformation> getNotifyInformation ();
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 1.1K bytes - Viewed (0)