Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 81 - 90 of 397 for cbuf (0.03 seconds)

  1. cmd/site-replication-metrics_gen_test.go

    func TestEncodeDecodeRStat(t *testing.T) {
    	v := RStat{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    
    	m := v.Msgsize()
    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodeRStat Msgsize() is inaccurate")
    	}
    
    	vn := RStat{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    	}
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 12.9K bytes
    - Click Count (0)
  2. internal/grid/msg_gen_test.go

    	v := connectReq{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    
    	m := v.Msgsize()
    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodeconnectReq Msgsize() is inaccurate")
    	}
    
    	vn := connectReq{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    	}
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 12.9K bytes
    - Click Count (0)
  3. src/main/java/jcifs/internal/witness/WitnessAsyncNotifyMessage.java

            int maxCount = buf.dec_ndr_long();
            int offset = buf.dec_ndr_long();
            int actualCount = buf.dec_ndr_long();
    
            if (actualCount <= 0) {
                return "";
            }
    
            // Read wide string data (UTF-16LE)
            int byteCount = (actualCount - 1) * 2; // Exclude null terminator
            byte[] wideBytes = new byte[byteCount];
            buf.readOctetArray(wideBytes, 0, byteCount);
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 24 00:12:28 GMT 2025
    - 16.4K bytes
    - Click Count (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/form/Hc5FormScheme.java

                    final StringBuilder buf = new StringBuilder(100);
                    buf.append(tokenUrl);
                    if (StringUtil.isNotBlank(tokenReqParams)) {
                        if (tokenUrl.indexOf('?') >= 0) {
                            buf.append('&');
                        } else {
                            buf.append('?');
                        }
                        buf.append(tokenReqParams);
                    }
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Sun Jan 04 13:09:59 GMT 2026
    - 15.1K bytes
    - Click Count (0)
  5. internal/jwt/parser.go

    	}
    	headerDec := buf[:n]
    	buf = buf[n:]
    
    	alg, _, _, err := jsonparser.Get(headerDec, "alg")
    	if err != nil {
    		return nil, &jwtgo.ValidationError{Inner: err, Errors: jwtgo.ValidationErrorMalformed}
    	}
    
    	n, err = base64DecodeBytes(token[i+1:j], buf)
    	if err != nil {
    		return nil, &jwtgo.ValidationError{Inner: err, Errors: jwtgo.ValidationErrorMalformed}
    	}
    
    	if err = claims.UnmarshalJSON(buf[:n]); err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 14.1K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/core/convert/TimestampConversionUtil.java

                }
            }
            if (buf.indexOf("MM") == -1) {
                final int pos = buf.indexOf("M");
                if (pos != -1) {
                    buf.replace(pos, pos + 1, "MM");
                }
            }
            if (buf.indexOf("dd") == -1) {
                final int pos = buf.indexOf("d");
                if (pos != -1) {
                    buf.replace(pos, pos + 1, "dd");
                }
    Created: Fri Apr 03 20:58:12 GMT 2026
    - Last Modified: Thu Jul 31 08:16:49 GMT 2025
    - 20.6K bytes
    - Click Count (0)
  7. src/test/java/jcifs/internal/smb2/session/Smb2SessionSetupResponseTest.java

         */
        private void buildHeader(byte[] buf, int start, int status, int command, long sessionId) {
            System.arraycopy(SMBUtil.SMB2_HEADER, 0, buf, start, SMBUtil.SMB2_HEADER.length);
            // Status at +8
            SMBUtil.writeInt4(status, buf, start + 8);
            // Command at +12
            SMBUtil.writeInt2(command, buf, start + 12);
            // Flags at +16: server-to-redirector
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 9.7K bytes
    - Click Count (0)
  8. src/bytes/reader_test.go

    		}
    	}
    }
    
    func TestReaderDoubleUnreadRune(t *testing.T) {
    	buf := NewBuffer([]byte("groucho"))
    	if _, _, err := buf.ReadRune(); err != nil {
    		// should not happen
    		t.Fatal(err)
    	}
    	if err := buf.UnreadByte(); err != nil {
    		// should not happen
    		t.Fatal(err)
    	}
    	if err := buf.UnreadByte(); err == nil {
    		t.Fatal("UnreadByte: expected error, got nil")
    	}
    }
    
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Dec 13 18:45:54 GMT 2021
    - 8K bytes
    - Click Count (0)
  9. internal/s3select/message.go

    	buf := new(bytes.Buffer)
    	binary.Write(buf, binary.BigEndian, uint32(totalLength))
    	binary.Write(buf, binary.BigEndian, uint32(headerLength))
    	prelude := buf.Bytes()
    	binary.Write(buf, binary.BigEndian, crc32.ChecksumIEEE(prelude))
    	buf.Write(header)
    	if payload != nil {
    		buf.Write(payload)
    	}
    	message := buf.Bytes()
    	binary.Write(buf, binary.BigEndian, crc32.ChecksumIEEE(message))
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 15.3K bytes
    - Click Count (0)
  10. cmd/background-newdisks-heal-ops_gen_test.go

    	v := healingTracker{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    
    	m := v.Msgsize()
    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodehealingTracker Msgsize() is inaccurate")
    	}
    
    	vn := healingTracker{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    	}
    }
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 2.3K bytes
    - Click Count (0)
Back to Top