- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 262 for Unblock (2.4 sec)
-
src/cmd/go/internal/par/queue_test.go
t.Errorf("NewQueue(1) is not initially idle.") } started := make(chan struct{}) unblock := make(chan struct{}) q.Add(func() { close(started) <-unblock }) <-started idle := q.Idle() select { case <-idle: t.Errorf("NewQueue(1) is marked idle while processing work.") default: } close(unblock) <-idle // Should be closed as soon as the Add callback returns. }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Aug 24 21:08:46 UTC 2020 - 1.4K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/daemon/StoppingDaemonIntegrationSpec.groovy
BlockingHttpServer server = new BlockingHttpServer() private static final String UNBLOCK = 'unblock' def setup() { server.start() } def "daemon process exits and client logs nice error message when daemon stopped"() { buildFile << """ task block { doLast { ${server.callFromBuild(UNBLOCK)} } } """ when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 3.6K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/wait-on-pipe.go
// but it is generally enough in stress mode. time.Sleep(100 * time.Millisecond) // Write to the pipe to unblock it. if _, err := syscall.Write(wfd, []byte{10}); err != nil { log.Fatalf("failed to write to pipe: %v", err) } // Wait for the goroutine to unblock and start running. // This is helpful to catch incorrect information written // down for the syscall-blocked goroutine, since it'll start
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 1.6K bytes - Viewed (0) -
src/cmd/trace/gstate.go
Ts: ctx.elapsed(ts), Resource: trace.SyscallP, Stack: ctx.Stack(viewerFrames(stack)), }) } // unblock indicates that the goroutine gs represents has been unblocked. func (gs *gState[R]) unblock(ts trace.Time, stack trace.Stack, resource R, ctx *traceContext) { name := "unblock" viewerResource := uint64(resource) if gs.startBlockReason != "" { name = fmt.Sprintf("%s (%s)", name, gs.startBlockReason) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 11.9K bytes - Viewed (0) -
tensorflow/c/experimental/saved_model/core/concrete_function.h
// are loaded from, since they retain pointers to the TensorHandles owned by the // SavedModel, and the FunctionDef of the SavedModel. // // Note(bmzhao): This class is only TEMPORARILY virtual, as a way to unblock // TFRT integration with TF Serving. Do not add more virtual implementations of // this class. Eventually we want to remove this virtual base class indirection // and have only a single implementation. class ConcreteFunction {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 29 15:50:58 UTC 2021 - 2.4K bytes - Viewed (0) -
tensorflow/c/experimental/saved_model/core/saved_model_api.h
#include "tensorflow/cc/saved_model/bundle_v2.h" #include "tensorflow/core/platform/status.h" namespace tensorflow { // Note(bmzhao): This class is only TEMPORARILY virtual, as a way to unblock // TFRT integration with TF Serving. Do not add more virtual implementations of // this class. Eventually we want to remove this virtual base class indirection // and have only a single implementation. class SavedModelAPI {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Jun 04 17:05:58 UTC 2021 - 2.6K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/stress.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 2.5K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/stress-start-stop.go
if err != nil { log.Fatalf("dial failed: %v", err) return } var tmp [1]byte c.Read(tmp[:]) c.Close() go func() { runtime.Gosched() select {} }() // Unblock helper goroutines and wait them to finish. wp.Write(tmp[:]) wp.Write(tmp[:]) close(done) wg.Wait() }() const iters = 5 for i := 0; i < iters; i++ { var w io.Writer
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 2.7K bytes - Viewed (0) -
src/cmd/trace/jsontrace_test.go
var netBlockEv *format.Event for _, e := range data.Events { if e.TID == trace.NetpollP && e.Name == "unblock (network)" && e.Phase == "I" && e.Scope == "t" { count++ netBlockEv = e } } if netBlockEv == nil { t.Error("failed to find a network unblock") } if count == 0 { t.Errorf("found zero network block events, want at least one") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 7.8K bytes - Viewed (0) -
src/runtime/netpoll_solaris.go
} } } // netpoll checks for ready network connections. // Returns list of goroutines that become runnable. // delay < 0: blocks indefinitely // delay == 0: does not block, just polls // delay > 0: block for up to that many nanoseconds func netpoll(delay int64) (gList, int32) { if portfd == -1 { return gList{}, 0 } var wait *timespec var ts timespec if delay < 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 11.2K bytes - Viewed (0)