- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 214 for pselect (0.73 sec)
-
internal/bucket/bandwidth/monitor.go
if !ok { tm = &bucketMeasurement{} } tm.incrementBytes(bytes) m.bucketsMeasurement[opts] = tm } // SelectionFunction for buckets type SelectionFunction func(bucket string) bool // SelectBuckets will select all the buckets passed in. func SelectBuckets(buckets ...string) SelectionFunction { if len(buckets) == 0 { return func(bucket string) bool { return true } } return func(bucket string) bool {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Feb 19 22:54:46 UTC 2024 - 6K bytes - Viewed (0) -
pkg/kube/krt/filter.go
} if f.selects != nil { attrs = append(attrs, fmt.Sprintf("selects=%v", f.selects)) } if f.labels != nil { attrs = append(attrs, fmt.Sprintf("labels=%v", f.labels)) } if f.generic != nil { attrs = append(attrs, "generic") } res := strings.Join(attrs, ",") return fmt.Sprintf("{%s}", res) } // FilterObjectName selects a Kubernetes object by name.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 4.8K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/experimental/tac/py_wrapper/BUILD
"@com_google_absl//absl/status", ], ) pybind_extension( name = "_pywrap_tac_wrapper", srcs = [ "tac_wrapper_pybind11.cc", ], hdrs = ["tac_wrapper.h"], dynamic_deps = select({ "//tensorflow:macos": ["//tensorflow:libtensorflow_framework.%s.dylib" % VERSION], "//tensorflow:windows": [], "//conditions:default": ["//tensorflow:libtensorflow_framework.so.%s" % VERSION], }),
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Mar 27 18:00:18 UTC 2024 - 4.2K bytes - Viewed (0) -
pkg/kube/krt/sync.go
name string synced <-chan struct{} } func (c channelSyncer) WaitUntilSynced(stop <-chan struct{}) bool { return waitForCacheSync(c.name, stop, c.synced) } func (c channelSyncer) HasSynced() bool { select { case <-c.synced: return true default: return false } } type pollSyncer struct { name string f func() bool } func (c pollSyncer) WaitUntilSynced(stop <-chan struct{}) bool {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 03 14:25:07 UTC 2024 - 1.8K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/BUILD
deps = [":gcs_filesystem_impl"], ) # The real implementation of the filesystem. cc_library( name = "gcs_filesystem_impl", srcs = ["gcs_filesystem.cc"], hdrs = ["gcs_filesystem.h"], copts = select({ "//conditions:default": [], "//tensorflow:windows": get_win_copts(), }), deps = [ ":expiring_lru_cache", ":gcs_helper", ":ram_file_block_cache",
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Mar 27 18:00:18 UTC 2024 - 3.4K bytes - Viewed (0) -
pkg/util/filesystem/watcher.go
if err != nil { return err } w.eventHandler = eventHandler w.errorHandler = errorHandler return nil } func (w *fsnotifyWatcher) Run() { go func() { defer w.watcher.Close() for { select { case event := <-w.watcher.Events: if w.eventHandler != nil { w.eventHandler(event) } case err := <-w.watcher.Errors: if w.errorHandler != nil { w.errorHandler(err) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 14 23:09:15 UTC 2024 - 5.7K bytes - Viewed (0) -
testing/internal-performance-testing/src/main/resources/org/gradle/reporting/performanceReport.js
}); $('.section-sign').click(function () { var $temp = $("<input>"); $("body").append($temp); $temp.val(window.location.href.split('#')[0] + $(this).attr('href')).select(); document.execCommand("copy"); $temp.remove(); }); } function refreshCards(selectedTags) { $('.card').each(function (index, row) { var currentTags = $(row).attr('tag');
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 3.2K 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) -
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) -
subprojects/core/src/main/java/org/gradle/execution/selection/BuildTaskSelector.java
BuildSpecificSelector relativeToBuild(BuildState target); /** * A selector that is contextualized to select tasks relative to some build. */ interface BuildSpecificSelector { TaskSelection resolveTaskName(String taskName); } class Filter { private final BuildState build;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 2.2K bytes - Viewed (0)