Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 996 for checkSeq (0.17 sec)

  1. 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)
  2. pkg/test/framework/components/echo/checker.go

    //  limitations under the License.
    
    package echo
    
    var noChecker Checker = func(_ CallResult, err error) error {
    	return err
    }
    
    // Checker inspects echo call results for errors.
    type Checker func(CallResult, error) error
    
    func (c Checker) Check(result CallResult, err error) error {
    	return c(result, err)
    }
    
    // NoChecker provides a Checker that returns the original raw call error, unaltered.
    func NoChecker() Checker {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 12 22:50:35 UTC 2022
    - 1000 bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. android/guava/src/com/google/common/util/concurrent/ImmediateFuture.java

      }
    
      @Override
      @SuppressWarnings("CatchingUnchecked") // sneaky checked exception
      public void addListener(Runnable listener, Executor executor) {
        checkNotNull(listener, "Runnable was null.");
        checkNotNull(executor, "Executor was null.");
        try {
          executor.execute(listener);
        } catch (Exception e) { // sneaky checked exception
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Dec 13 19:45:20 UTC 2023
    - 3.5K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/UncheckedExecutionException.java

     * ExecutionException} when the exception thrown by a task is an unchecked exception. However, it
     * may also wrap a checked exception in some cases.
     *
     * <p>When wrapping an {@code Error} from another thread, prefer {@link ExecutionError}. When
     * wrapping a checked exception, prefer {@code ExecutionException}.
     *
     * @author Charles Fry
     * @since 10.0
     */
    @GwtCompatible
    @ElementTypesAreNonnullByDefault
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Thu Mar 07 17:52:19 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  10. android/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)
Back to top