- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 343 for notifyCh (0.2 sec)
-
src/cmd/vendor/golang.org/x/tools/go/analysis/passes/sigchanyzer/doc.go
// Package sigchanyzer defines an Analyzer that detects // misuse of unbuffered signal as argument to signal.Notify. // // # Analyzer sigchanyzer // // sigchanyzer: check for unbuffered channel of os.Signal // // This checker reports call expression of the form // // signal.Notify(c <-chan os.Signal, sig ...os.Signal), // // where c is an unbuffered channel, which can be at risk of missing the signal.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 09 01:28:01 UTC 2023 - 585 bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/plugin/internal/ValidatingConfigurationListener.java
if (mojo == target) { notify(fieldName, value); } } public void notifyFieldChangeUsingReflection(String fieldName, Object value, Object target) { delegate.notifyFieldChangeUsingReflection(fieldName, value, target); if (mojo == target) { notify(fieldName, value); } } private void notify(String fieldName, Object value) {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Sep 06 08:39:32 UTC 2023 - 2.7K bytes - Viewed (0) -
cmd/batch-replicate.go
} // BatchJobReplicateFlags various configurations for replication job definition currently includes // - filter // - notify // - retry type BatchJobReplicateFlags struct { Filter BatchReplicateFilter `yaml:"filter" json:"filter"` Notify BatchJobNotification `yaml:"notify" json:"notify"` Retry BatchJobRetry `yaml:"retry" json:"retry"` } // BatchJobReplicateResourceType defines the type of batch jobs
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Nov 22 18:51:46 UTC 2023 - 6.3K bytes - Viewed (0) -
testing/internal-integ-testing/src/test/groovy/org/gradle/integtests/fixtures/BuildOperationNotificationsFixtureTest.groovy
package org.gradle.integtests.fixtures import org.gradle.api.GradleException import org.gradle.internal.operations.notify.BuildOperationFinishedNotification import org.gradle.internal.operations.notify.BuildOperationNotificationListener import org.gradle.internal.operations.notify.BuildOperationProgressNotification import org.gradle.internal.operations.notify.BuildOperationStartedNotification import org.gradle.internal.reflect.JavaReflectionUtil
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 5K bytes - Viewed (0) -
src/cmd/cgo/internal/test/sigprocmask.go
"os/signal" "syscall" "testing" ) var blocked bool //export IntoGoAndBack func IntoGoAndBack() { // Verify that SIGIO stays blocked on the C thread // even when unblocked for signal.Notify(). signal.Notify(make(chan os.Signal), syscall.SIGIO) blocked = C.CheckBlocked() != 0 } func testSigprocmask(t *testing.T) { if r := C.RunSigThread(); r != 0 { t.Errorf("pthread_create/pthread_join failed: %d", r) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 12:00:02 UTC 2023 - 808 bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/go/analysis/passes/sigchanyzer/sigchanyzer.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. // Package sigchanyzer defines an Analyzer that detects // misuse of unbuffered signal as argument to signal.Notify. package sigchanyzer import ( "bytes" _ "embed" "go/ast" "go/format" "go/token" "go/types" "golang.org/x/tools/go/analysis" "golang.org/x/tools/go/analysis/passes/inspect"
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 09 01:28:01 UTC 2023 - 3.8K bytes - Viewed (0) -
src/os/signal/signal_test.go
} func testCancel(t *testing.T, ignore bool) { // Ask to be notified on c1 when a SIGWINCH is received. c1 := make(chan os.Signal, 1) Notify(c1, syscall.SIGWINCH) defer Stop(c1) // Ask to be notified on c2 when a SIGHUP is received. c2 := make(chan os.Signal, 1) Notify(c2, syscall.SIGHUP) defer Stop(c2) // Send this process a SIGWINCH and wait for notification on c1.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 09 15:34:56 UTC 2023 - 27.2K bytes - Viewed (0) -
src/os/signal/signal_plan9_test.go
func TestSignal(t *testing.T) { // Ask for hangup c := make(chan os.Signal, 1) Notify(c, syscall.Note("hangup")) defer Stop(c) // Send this process a hangup t.Logf("hangup...") postNote(syscall.Getpid(), "hangup") waitSig(t, c, syscall.Note("hangup")) // Ask for everything we can get. c1 := make(chan os.Signal, 1) Notify(c1) // Send this process an alarm t.Logf("alarm...")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Mar 14 17:56:50 UTC 2021 - 3.6K bytes - Viewed (0) -
cmd/batch-replicate_gen.go
case "Filter": err = z.Filter.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "Filter") return } case "Notify": err = z.Notify.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "Notify") return } case "Retry": err = z.Retry.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "Retry") return }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Nov 22 18:51:46 UTC 2023 - 40.6K bytes - Viewed (0) -
platforms/core-runtime/build-operations/src/main/java/org/gradle/internal/operations/notify/package-info.java
* can be made to these types. * * It can be assumed that only Gradle implements these interfaces, * except for {@link org.gradle.internal.operations.notify.BuildOperationNotificationListener} * which is implemented by the build scan plugin. */ @NonNullApi package org.gradle.internal.operations.notify;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 24 14:19:43 UTC 2023 - 1.2K bytes - Viewed (0)