- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 29 for seq (2.56 sec)
-
internal/grid/muxclient.go
func (m *muxClient) response(seq uint32, r Response) { if debugReqs { fmt.Println(m.MuxID, m.parent.String(), "RESP") } if debugPrint { fmt.Printf("mux %d: got msg seqid %d, payload length: %d, err:%v\n", m.MuxID, seq, len(r.Msg), r.Err) } if !m.checkSeq(seq) { if debugReqs { fmt.Println(m.MuxID, m.parent.String(), "CHECKSEQ FAIL", m.RecvSeq, seq) } PutByteBuffer(r.Msg) r.Msg = nil
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 15.9K bytes - Viewed (0) -
cmd/endpoint-ellipses_test.go
} func getHexSequences(start int, number int, paddinglen int) (seq []string) { for i := start; i <= number; i++ { if paddinglen == 0 { seq = append(seq, fmt.Sprintf("%x", i)) } else { seq = append(seq, fmt.Sprintf(fmt.Sprintf("%%0%dx", paddinglen), i)) } } return seq } func getSequences(start int, number int, paddinglen int) (seq []string) { for i := start; i <= number; i++ {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 15.1K bytes - Viewed (0) -
src/test/java/jcifs/pac/kerberos/KerberosApRequestTest.java
} @Test @DisplayName("seq ctor: valid minimal sequence sets apOptions and leaves ticket null") void sequenceConstructor_minimal_valid_setsApOptions_noTicket() throws Exception { // Arrange byte ap = (byte) 0x7A; ASN1Sequence seq = buildMinimalApReqSeq(ap); // Act KerberosApRequest req = new KerberosApRequest(seq, null); // AssertRegistered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 10.3K bytes - Viewed (0) -
src/bytes/iter.go
func SplitAfterSeq(s, sep []byte) iter.Seq[[]byte] { return splitSeq(s, sep, len(sep)) } // FieldsSeq returns an iterator over subslices of s split around runs of // whitespace characters, as defined by [unicode.IsSpace]. // The iterator yields the same subslices that would be returned by [Fields](s), // but without constructing a new slice containing the subslices. func FieldsSeq(s []byte) iter.Seq[[]byte] {
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Wed Sep 03 14:04:47 UTC 2025 - 3.6K bytes - Viewed (0) -
android/guava/src/com/google/common/escape/UnicodeEscaper.java
* surrogate character at the end of the sequence */ protected static int codePointAt(CharSequence seq, int index, int end) { checkNotNull(seq); if (index < end) { char c1 = seq.charAt(index++); if (c1 < Character.MIN_HIGH_SURROGATE || c1 > Character.MAX_LOW_SURROGATE) { // Fast path (first test is probably all we need to do) return c1;
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Feb 13 15:45:16 UTC 2025 - 13.2K bytes - Viewed (0) -
src/main/java/jcifs/pac/kerberos/KerberosApRequest.java
* * @param seq the ASN.1 sequence containing the AP-REQ * @param keys the Kerberos keys for decryption * @throws PACDecodingException if the sequence cannot be decoded */ public KerberosApRequest(ASN1Sequence seq, KerberosKey[] keys) throws PACDecodingException { Enumeration<?> fields = seq.getObjects(); while (fields.hasMoreElements()) {Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 4.9K bytes - Viewed (0) -
internal/grid/muxserver.go
} // 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++ return true }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue May 27 15:19:03 UTC 2025 - 9.7K bytes - Viewed (0) -
src/test/java/org/codelibs/opensearch/extension/analysis/NGramSynonymTokenizer.java
Registered: Sat Dec 20 13:04:59 UTC 2025 - Last Modified: Sat Mar 15 06:51:20 UTC 2025 - 17K bytes - Viewed (0) -
android/guava/src/com/google/common/io/CharSource.java
final CharSequence seq; CharSequenceCharSource(CharSequence seq) { this.seq = checkNotNull(seq); } @Override public Reader openStream() { return new CharSequenceReader(seq); } @Override public String read() { return seq.toString(); } @Override public boolean isEmpty() {Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Sep 08 18:35:13 UTC 2025 - 25.7K bytes - Viewed (0) -
guava/src/com/google/common/io/CharSource.java
final CharSequence seq; CharSequenceCharSource(CharSequence seq) { this.seq = checkNotNull(seq); } @Override public Reader openStream() { return new CharSequenceReader(seq); } @Override public String read() { return seq.toString(); } @Override public boolean isEmpty() {Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Sep 08 18:35:13 UTC 2025 - 25.3K bytes - Viewed (0)