Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 233 for sequencer (0.11 sec)

  1. internal/grid/muxserver.go

    				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)
    		}
    		m.disconnect(fmt.Sprintf("receive sequence number mismatch. want %d, got %d", m.RecvSeq, seq), false)
    		return false
    	}
    	m.RecvSeq++
    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. fastapi/_compat.py

    from dataclasses import dataclass, is_dataclass
    from enum import Enum
    from functools import lru_cache
    from typing import (
        Any,
        Callable,
        Deque,
        Dict,
        FrozenSet,
        List,
        Mapping,
        Sequence,
        Set,
        Tuple,
        Type,
        Union,
    )
    
    from fastapi.exceptions import RequestErrorModel
    from fastapi.types import IncEx, ModelNameMap, UnionType
    from pydantic import BaseModel, create_model
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Oct 12 09:36:32 UTC 2024
    - 23.4K bytes
    - Viewed (0)
  3. src/main/java/jcifs/util/Encdec.java

                        throw new IOException("Invalid UTF-8 sequence");
                    }
                    uni[ ui ] |= ( ch & 0x3F ) << 6;
                    ch = src[ si++ ] & 0xFF;
                    uni[ ui ] |= ch & 0x3F;
                    if ( ( ch & 0xC0 ) != 0x80 || uni[ ui ] < 0x800 ) {
                        throw new IOException("Invalid UTF-8 sequence");
                    }
                }
                else {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 11K bytes
    - Viewed (0)
  4. src/main/java/jcifs/spnego/NegTokenTarg.java

            try ( ASN1InputStream der = new ASN1InputStream(token) ) {
                ASN1TaggedObject tagged = (ASN1TaggedObject) der.readObject();
                ASN1Sequence sequence = ASN1Sequence.getInstance(tagged, true);
                Enumeration<?> fields = sequence.getObjects();
                while ( fields.hasMoreElements() ) {
                    tagged = (ASN1TaggedObject) fields.nextElement();
                    switch ( tagged.getTagNo() ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Mon Jan 04 04:18:31 UTC 2021
    - 5.4K bytes
    - Viewed (0)
  5. cmd/global-heal.go

    	"github.com/minio/pkg/v3/console"
    	"github.com/minio/pkg/v3/wildcard"
    	"github.com/minio/pkg/v3/workers"
    )
    
    const (
    	bgHealingUUID = "0000-0000-0000-0000"
    )
    
    // NewBgHealSequence creates a background healing sequence
    // operation which scans all objects and heal them.
    func newBgHealSequence() *healSequence {
    	reqInfo := &logger.ReqInfo{API: "BackgroundHeal"}
    	ctx, cancelCtx := context.WithCancel(logger.SetReqInfo(GlobalContext, reqInfo))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  6. fastapi/openapi/utils.py

    def get_openapi(
        *,
        title: str,
        version: str,
        openapi_version: str = "3.1.0",
        summary: Optional[str] = None,
        description: Optional[str] = None,
        routes: Sequence[BaseRoute],
        webhooks: Optional[Sequence[BaseRoute]] = None,
        tags: Optional[List[Dict[str, Any]]] = None,
        servers: Optional[List[Dict[str, Union[str, Any]]]] = None,
        terms_of_service: Optional[str] = None,
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Sep 17 18:54:10 UTC 2024
    - 22.6K bytes
    - Viewed (0)
  7. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt

              return eventClass.cast(event)
            }
          }
        } catch (e: NoSuchElementException) {
          throw AssertionError("full event sequence: $fullEventSequence", e)
        }
      }
    
      /**
       * Remove and return the next event from the recorded sequence.
       *
       * @param eventClass a class to assert that the returned event is an instance of, or null to
       *     take any event class.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/AbstractIndexedListIterator.java

      /** Returns the element with the specified index. This method is called by {@link #next()}. */
      @ParametricNullness
      protected abstract E get(int index);
    
      /**
       * Constructs an iterator across a sequence of the given size whose initial position is 0. That
       * is, the first call to {@link #next()} will return the first element (or throw {@link
       * NoSuchElementException} if {@code size} is zero).
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jul 09 17:31:04 UTC 2021
    - 3.2K bytes
    - Viewed (0)
  9. doc/next/6-stdlib/99-minor/go/types/66626.md

    All `go/types` data structures that expose sequences using a pair of
    methods such as `Len() int` and `At(int) T` now also methods that
    return iterators, allowing you to simplify code such as this:
    
    ```go
    params := fn.Type.(*types.Signature).Params()
    for i := 0; i < params.Len(); i++ {
       use(params.At(i))
    }
    ```
    
    to this:
    
    ```go
    for param := range fn.Signature().Params().Variables() {
       use(param)
    }
    ```
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Jul 31 22:54:09 UTC 2024
    - 1K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/hash/HashFunction.java

     *   <li><b>block of data:</b> the input for a hash function is always, in concept, an ordered byte
     *       array. This hashing API accepts an arbitrary sequence of byte and multibyte values (via
     *       {@link Hasher}), but this is merely a convenience; these are always translated into raw
     *       byte sequences under the covers.
     *   <li><b>hash code:</b> each hash function always yields hash codes of the same fixed bit length
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue May 25 18:22:59 UTC 2021
    - 10.9K bytes
    - Viewed (0)
Back to top