- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,590 for checkSeq (0.13 sec)
-
internal/grid/muxserver.go
gridLogIf(m.ctx, fmt.Errorf("canceling remote connection %s not seen for %v", m.parent, last)) m.close() return } } } } // checkSeq will check if sequence number is correct and increment it by 1. func (m *muxServer) checkSeq(seq uint32) (ok bool) { if seq != m.RecvSeq { if debugPrint { fmt.Printf("expected sequence %d, got %d\n", m.RecvSeq, seq) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 9.7K bytes - Viewed (0) -
internal/grid/muxclient.go
} m.addErrorNonBlockingClose(errResp, context.Cause(m.ctx)) return case <-pingTimer: errState = !m.doPing(errResp) } } } // checkSeq will check if sequence number is correct and increment it by 1. func (m *muxClient) checkSeq(seq uint32) (ok bool) { if seq != m.RecvSeq { if debugPrint { fmt.Printf("MuxID: %d client, expected sequence %d, got %d\n", m.MuxID, m.RecvSeq, seq) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/audit/policy/checker.go
Tim Allclair <******@****.***> 1667427828 -0700
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 02 22:24:14 UTC 2022 - 6.1K bytes - Viewed (0) -
src/go/types/check.go
// For debugging only. type actionDesc struct { pos positioner format string args []any } // A Checker maintains the state of the type checker. // It must be created with [NewChecker]. type Checker struct { // package information // (initialized by NewChecker, valid for the life-time of checker) conf *Config ctxt *Context // context for de-duplicating instances fset *token.FileSet pkg *Package *Info
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 19:19:55 UTC 2024 - 23.1K bytes - Viewed (0) -
platforms/core-execution/execution/src/testFixtures/groovy/org/gradle/internal/execution/WorkValidationExceptionChecker.groovy
assert exception instanceof WorkValidationException def checker = new WorkValidationExceptionChecker(exception, ignoreType) spec.delegate = checker spec.resolveStrategy = Closure.DELEGATE_FIRST spec() checker.done() } private WorkValidationExceptionChecker(WorkValidationException ex, boolean ignoreType) { error = ex
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:46:15 UTC 2023 - 2.6K bytes - Viewed (0) -
src/cmd/compile/internal/types2/check.go
// For debugging only. type actionDesc struct { pos poser format string args []interface{} } // A Checker maintains the state of the type checker. // It must be created with NewChecker. type Checker struct { // package information // (initialized by NewChecker, valid for the life-time of checker) conf *Config ctxt *Context // context for de-duplicating instances pkg *Package *Info
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 19:19:55 UTC 2024 - 23.3K bytes - Viewed (0) -
src/cmd/compile/internal/types2/api.go
// Package types2 declares the data types and implements // the algorithms for type-checking of Go packages. Use // Config.Check to invoke the type checker for a package. // Alternatively, create a new type checker with NewChecker // and invoke it incrementally by calling Checker.Files. // // Type-checking consists of several interdependent phases: // // Name resolution maps each identifier (syntax.Name) in the program to the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 13:48:53 UTC 2024 - 17.4K bytes - Viewed (0) -
src/go/types/format.go
) } // dump is only needed for debugging func (check *Checker) dump(format string, args ...any) { fmt.Println(sprintf(check.fset, check.qualifier, true, format, args...)) } func (check *Checker) qualifier(pkg *Package) string { // Qualify the package unless it's the package being type-checked. if pkg != check.pkg { if check.pkgPathMap == nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 19:19:55 UTC 2024 - 3.5K bytes - Viewed (0) -
src/cmd/compile/internal/types2/format.go
) } // dump is only needed for debugging func (check *Checker) dump(format string, args ...any) { fmt.Println(sprintf(check.qualifier, true, format, args...)) } func (check *Checker) qualifier(pkg *Package) string { // Qualify the package unless it's the package being type-checked. if pkg != check.pkg { if check.pkgPathMap == nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 19:19:55 UTC 2024 - 3.5K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/FakeTimeLimiter.java
} @Override @SuppressWarnings("CatchingUnchecked") // sneaky checked exception public void runWithTimeout(Runnable runnable, long timeoutDuration, TimeUnit timeoutUnit) { checkNotNull(runnable); checkNotNull(timeoutUnit); try { runnable.run(); } catch (Exception e) { // sneaky checked exception throw new UncheckedExecutionException(e); } catch (Error e) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Dec 14 20:35:03 UTC 2023 - 3.5K bytes - Viewed (0)