- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 395 for resch (0.06 sec)
-
src/cmd/go/internal/cache/prog.go
resc := make(chan *ProgResponse, 1) if err := c.writeToChild(req, resc); err != nil { return nil, err } select { case res := <-resc: if res.Err != "" { return nil, errors.New(res.Err) } return res, nil case <-ctx.Done(): return nil, ctx.Err() } } func (c *ProgCache) writeToChild(req *ProgRequest, resc chan<- *ProgResponse) (err error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Aug 14 19:23:25 UTC 2023 - 11.8K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/daemon/LegacyDaemon.groovy
lastLogState = logFileProbe.currentState } if (lastLogState == state) { return } throw new AssertionError("""Timeout waiting for daemon with pid ${context.pid} to reach state ${state}. Current state is ${lastLogState}.""") } @Override protected void assertHasState(State state) { assert logFileProbe.currentState == state } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 15:22:16 UTC 2024 - 2.3K bytes - Viewed (0) -
platforms/core-runtime/process-services/src/main/java/org/gradle/process/internal/StreamsHandler.java
*/ void connectStreams(Process process, String processName, Executor executor); /** * Starts reading/writing/whatever the process' streams. May block until the streams reach some particular state, e.g. indicate that the process has started successfully. */ void start(); /** * Remove any context associated with tracking the startup of the process. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:10:02 UTC 2023 - 1.6K bytes - Viewed (0) -
src/runtime/internal/wasitest/testdata/tcpecho.go
func findListener() (net.Listener, error) { // We start looking for pre-opened sockets at fd=3 because 0, 1, and 2 // are reserved for stdio. Pre-opened directors also start at fd=3, so // we skip fds that aren't sockets. Once we reach EBADF we know there // are no more pre-opens. for preopenFd := uintptr(3); ; preopenFd++ { f := os.NewFile(preopenFd, "") l, err := net.FileListener(f) f.Close() var se syscall.Errno
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 25 00:12:41 UTC 2023 - 1.4K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/main/java/org/gradle/internal/metaobject/BeanDynamicObject.java
} @Nullable private MetaMethod findGetPropertyMissingMethod(MetaClass metaClass) { if (metaClass instanceof MetaClassImpl) { // Reach into meta class to avoid lookup try { return (MetaMethod) MISSING_PROPERTY_GET_METHOD.get(metaClass); } catch (IllegalAccessException e) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri May 24 13:45:02 UTC 2024 - 29.3K bytes - Viewed (0) -
src/syscall/getdirentries_test.go
if err != nil { t.Fatalf("Getdirentries: %v", err) } if n == 0 { break } data := buf[:n] for len(data) > 0 { // If multiple Dirents are written into buf, sometimes when we reach the final one, // we have cap(buf) < Sizeof(Dirent). So use an appropriate slice to copy from data. var dirent syscall.Dirent copy((*[unsafe.Sizeof(dirent)]byte)(unsafe.Pointer(&dirent))[:], data)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 2.1K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/DerivedCollectionGenerators.java
// should never reach here! throw new UnsupportedOperationException(); } @Override public Entry<K, V> belowSamplesGreater() { // should never reach here! throw new UnsupportedOperationException(); } @Override public Entry<K, V> aboveSamplesLesser() { // should never reach here! throw new UnsupportedOperationException();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Feb 21 16:49:06 UTC 2024 - 18.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/policy_decision.go
case metav1.StatusReasonRequestEntityTooLarge: return http.StatusRequestEntityTooLarge case metav1.StatusReasonInvalid: return http.StatusUnprocessableEntity default: // It should not reach here since we only allow above reason to be set from API level return http.StatusUnprocessableEntity }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 2.6K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/shape_inference_pass.cc
if (failed(failure_or_converged)) return signalPassFailure(); if (!failure_or_converged.value()) { getOperation().emitError() << "shape inference pass did not reach convergence after " << max_iterations_; return signalPassFailure(); } } private: ArrayRef<ArrayRef<int64_t>> input_shapes_; }; } // namespace
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Apr 24 12:49:45 UTC 2024 - 3K bytes - Viewed (0) -
src/net/ipsock_plan9.go
defer func() { fixErr(err) }() type res struct { fd *netFD err error } resc := make(chan res) go func() { fd, err := dialPlan9Blocking(ctx, net, laddr, raddr) select { case resc <- res{fd, err}: case <-ctx.Done(): if fd != nil { fd.Close() } } }() select { case res := <-resc: return res.fd, res.err case <-ctx.Done(): return nil, mapErr(ctx.Err()) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Aug 29 20:38:53 UTC 2023 - 7.5K bytes - Viewed (0)