- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 529 for pselect (0.15 sec)
-
pkg/xds/server.go
// initialization is complete. <-con.initialized for { // Go select{} statements are not ordered; the same channel can be chosen many times. // For requests, these are higher priority (client may be blocked on startup until these are done) // and often very cheap to handle (simple ACK), so we check it first. select { case req, ok := <-con.reqChan: if ok { if err := ctx.Process(req); err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0) -
platforms/software/build-init/src/main/java/org/gradle/buildinit/tasks/InitBuild.java
} private BuildInitDsl getBuildInitDsl(UserQuestions userQuestions, BuildInitializer initializer) { BuildInitDsl dsl; if (isNullOrEmpty(this.dsl)) { dsl = userQuestions.selectOption("Select build script DSL", initializer.getDsls(), initializer.getDefaultDsl()); } else { dsl = BuildInitDsl.fromName(getDsl()); if (!initializer.getDsls().contains(dsl)) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri May 10 12:58:10 UTC 2024 - 24.9K bytes - Viewed (0) -
cmd/listen-notification-handlers.go
go func() { buf := bytes.NewBuffer(grid.GetByteBuffer()[:0]) enc := json.NewEncoder(buf) tmpEvt := struct{ Records []event.Event }{[]event.Event{{}}} for { select { case ev := <-localCh: buf.Reset() tmpEvt.Records[0] = ev if err := enc.Encode(tmpEvt); err != nil { bugLogIf(ctx, err, "event: Encode failed") continue }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/stablehlo/tests/composite-lowering.mlir
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Jun 06 18:45:51 UTC 2024 - 32.6K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/tf_tfl_translate.cc
specs.upgrade_legacy = upgrade_legacy; specs.prune_unused_nodes = true; if (!select_user_tf_ops.empty() && !emit_select_tf_ops) { llvm::errs() << "You must specify `emit-select-tf-ops=true` when passing " "`select-user-tf-ops` flag."; return kTrFailure; } std::unique_ptr<tensorflow::SavedModelBundle> bundle;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri May 03 18:01:23 UTC 2024 - 14K bytes - Viewed (0) -
cmd/admin-heal-ops.go
// even if we aren't listening. task.respCh = make(chan healResult, 1) select { case globalBackgroundHealRoutine.tasks <- task: if serverDebugLog { fmt.Printf("Task in the queue: %#v\n", task) } case <-h.ctx.Done(): return nil } // task queued, now wait for the response. select { case res := <-task.respCh: if res.err == nil { h.countHealed(healType) } else {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 09 18:04:41 UTC 2024 - 25.1K bytes - Viewed (0) -
src/os/exec_test.go
defer signal.Stop(c) p := &os.Process{Pid: os.Getpid()} if err := p.Signal(os.Interrupt); err != nil { t.Fatalf("Signal got err %v, want nil", err) } // Verify we actually received the signal. select { case <-time.After(1 * time.Second): t.Error("timeout waiting for signal") case <-c: // Good } } func TestProcessReleaseTwice(t *testing.T) { testenv.MustHaveGoBuild(t) t.Parallel()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 18:08:44 UTC 2024 - 1.8K bytes - Viewed (0) -
src/cmd/trace/pprof.go
// first, we sort based on the start time // and then scan through to select only the outermost regions. slices.SortFunc(intervals, func(a, b interval) int { if c := cmp.Compare(a.start, b.start); c != 0 { return c } return cmp.Compare(a.end, b.end) }) var lastTimestamp trace.Time var n int // Select only the outermost regions. for _, i := range intervals { if lastTimestamp <= i.start {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 10.1K bytes - Viewed (0) -
tensorflow/compiler/aot/tfcompile.bzl
flags = " ".join([ "'" + arg.replace("'", "'\\''") + "'" for arg in (tfcompile_flags or []) ]) # Do this before we append the `select` into `flags`, because doing so # transforms `flags` into a variable of type `select`, and we can't call # `find` on such an object. need_xla_data_proto = flags and flags.find("--gen_program_shape") != -1 if enable_xla_hlo_profiling:
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu May 02 19:18:08 UTC 2024 - 21.8K bytes - Viewed (0) -
cmd/erasure.go
updateTime := 30*time.Second + time.Duration(float64(10*time.Second)*rand.Float64()) t := time.NewTicker(updateTime) defer t.Stop() defer saverWg.Done() var lastSave time.Time for { select { case <-t.C: if cache.Info.LastUpdate.Equal(lastSave) { continue } scannerLogOnceIf(ctx, cache.save(ctx, er, dataUsageCacheName), "nsscanner-cache-update") updates <- cache.clone()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 16K bytes - Viewed (0)