Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 610 for checkSeq (0.06 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  2. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  3. cmd/dummy-data-generator_test.go

    		b, _ := io.ReadAll(r)
    		return string(b)
    	}
    	checkEq := func(a, b string) {
    		if a != b {
    			t.Fatalf("Unexpected equality failure")
    		}
    	}
    
    	checkEq(readAll(NewDummyDataGen(0, 0)), "")
    
    	checkEq(readAll(NewDummyDataGen(10, 0)), readAll(NewDummyDataGen(10, int64(len(alphabets)))))
    
    	checkEq(readAll(NewDummyDataGen(100, 0)), readAll(NewDummyDataGen(50, 0))+readAll(NewDummyDataGen(50, 50)))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 02 15:13:05 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  4. 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: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 14 20:35:03 UTC 2023
    - 3.5K bytes
    - Viewed (0)
  5. 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: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Mar 07 17:52:19 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  6. docs/em/docs/advanced/advanced-dependencies.md

    {!../../docs_src/dependencies/tutorial011.py!}
    ```
    
    &amp; πŸ‘ˆ 🌌 πŸ‘₯ πŸ’ͺ "πŸ”—" πŸ‘† πŸ”—, πŸ‘ˆ πŸ”œ βœ”οΈ `"bar"` πŸ”˜ ⚫️, πŸ”’ `checker.fixed_content`.
    
    ## βš™οΈ πŸ‘ πŸ”—
    
    ‴️, πŸ‘₯ πŸ’ͺ βš™οΈ πŸ‘‰ `checker` `Depends(checker)`, ↩️ `Depends(FixedContentQueryChecker)`, ↩️ πŸ”— πŸ‘, `checker`, 🚫 πŸŽ“ ⚫️.
    
    &amp; πŸ•β” ❎ πŸ”—, **FastAPI** πŸ”œ πŸ€™ πŸ‘‰ `checker` πŸ’–:
    
    ```Python
    checker(q="somequery")
    ```
    
    ...&amp; πŸšΆβ€β™€οΈ βš«οΈβ” πŸ‘ˆ πŸ“¨ πŸ’² πŸ”— πŸ‘† *➑ πŸ› οΈ πŸ”’* πŸ”’ `fixed_content_included`:
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 2K bytes
    - Viewed (0)
  7. docs/en/docs/advanced/advanced-dependencies.md

    ## Use the instance as a dependency
    
    Then, we could use this `checker` in a `Depends(checker)`, instead of `Depends(FixedContentQueryChecker)`, because the dependency is the instance, `checker`, not the class itself.
    
    And when solving the dependency, **FastAPI** will call this `checker` like:
    
    ```Python
    checker(q="somequery")
    ```
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 27 16:10:15 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

    import javax.annotation.CheckForNull;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /** Implementations of {@code Futures.transform*}. */
    @GwtCompatible
    @ElementTypesAreNonnullByDefault
    @SuppressWarnings({
      // Whenever both tests are cheap and functional, it's faster to use &, | instead of &&, ||
      "ShortCircuitBoolean",
      "nullness", // TODO(b/147136275): Remove once our checker understands & and |.
    })
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 11K bytes
    - Viewed (0)
  9. 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: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 14 20:35:03 UTC 2023
    - 3.5K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/io/Closer.java

       * IOException}, {@code RuntimeException}, {@code Error} or a checked exception of the given type.
       * Otherwise, it will be rethrown wrapped in a {@code RuntimeException}. <b>Note:</b> Be sure to
       * declare all of the checked exception types your try block can throw when calling an overload of
       * this method so as to avoid losing the original exception type.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue May 07 15:26:58 UTC 2024
    - 10.4K bytes
    - Viewed (0)
Back to top