Search Options

Results per page
Sort
Preferred Languages
Advance

Results 281 - 290 of 566 for decodes (0.66 sec)

  1. cmd/bootstrap-peer-server_gen_test.go

    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    
    	m := v.Msgsize()
    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodeServerSystemConfig Msgsize() is inaccurate")
    	}
    
    	vn := ServerSystemConfig{}
    	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)
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Jan 24 21:36:44 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  2. cmd/bucket-metadata_gen_test.go

    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    
    	m := v.Msgsize()
    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodeBucketMetadata Msgsize() is inaccurate")
    	}
    
    	vn := BucketMetadata{}
    	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)
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 2.3K bytes
    - Viewed (0)
  3. docs/debugging/inspect/export.go

    	"strings"
    	"time"
    
    	json "github.com/minio/colorjson"
    
    	"github.com/klauspost/compress/zip"
    	"github.com/tinylib/msgp/msgp"
    )
    
    func inspectToExportType(downloadPath string, datajson bool) error {
    	decode := func(r io.Reader, file string) ([]byte, error) {
    		b, e := io.ReadAll(r)
    		if e != nil {
    			return nil, e
    		}
    		b, _, minor, e := checkXL2V1(b)
    		if e != nil {
    			return nil, e
    		}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jan 17 19:38:44 UTC 2025
    - 9.1K bytes
    - Viewed (0)
  4. src/main/java/jcifs/dcerpc/ndr/NdrShort.java

            this.value = value & 0xFF;
        }
    
        @Override
        public void encode(final NdrBuffer dst) throws NdrException {
            dst.enc_ndr_short(this.value);
        }
    
        @Override
        public void decode(final NdrBuffer src) throws NdrException {
            this.value = src.dec_ndr_short();
        }
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 1.5K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb1/dcerpc/ndr/NdrShort.java

            this.value = value & 0xFF;
        }
    
        @Override
        public void encode(final NdrBuffer dst) throws NdrException {
            dst.enc_ndr_short(value);
        }
    
        @Override
        public void decode(final NdrBuffer src) throws NdrException {
            value = src.dec_ndr_short();
        }
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 1.5K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Interceptor.kt

     * includes both natural exceptions such as unreachable servers, as well as synthetic exceptions
     * when responses are of an unexpected type or cannot be decoded.
     *
     * Other exception types cancel the current call:
     *
     *  * For synchronous calls made with [Call.execute], the exception is propagated to the caller.
     *
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  7. okhttp-hpacktests/src/test/java/okhttp3/internal/http2/HpackRoundTripTest.kt

    /**
     * Tests for round-tripping headers through hpack.
     *
     * TODO: update hpack-test-case with the output of our encoder.
     * This test will hide complementary bugs in the encoder and decoder,
     * We should test that the encoder is producing responses that are
     */
    class HpackRoundTripTest : HpackDecodeTestBase() {
      internal class StoriesTestProvider : SimpleProvider() {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2K bytes
    - Viewed (0)
  8. cmd/shared-lock.go

    	ctx, cancel := context.WithCancel(context.Background())
    	go func() {
    		select {
    		case <-ctx1.Done():
    		case <-ctx2.Done():
    		// The lock acquirer decides to cancel, exit this goroutine
    		case <-ctx.Done():
    		}
    
    		cancel()
    	}()
    	return ctx, cancel
    }
    
    func (ld sharedLock) GetLock(ctx context.Context) (context.Context, context.CancelFunc) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Feb 13 09:26:38 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/RegularImmutableMap.java

        if (tableSize <= BYTE_MAX_SIZE) {
          /*
           * Use 8 bits per entry. The value is unsigned to allow use up to a size of 2^8.
           *
           * The absent indicator of -1 signed becomes 2^8 - 1 unsigned, which reduces the actual max
           * size to 2^8 - 1. However, due to a load factor < 1 the limit is never approached.
           */
          byte[] hashTable = new byte[tableSize];
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 22.5K bytes
    - Viewed (0)
  10. okhttp-dnsoverhttps/src/main/kotlin/okhttp3/dnsoverhttps/DnsRecordCodec.kt

    import java.io.EOFException
    import java.net.InetAddress
    import java.net.UnknownHostException
    import okio.Buffer
    import okio.ByteString
    import okio.utf8Size
    
    /**
     * Trivial Dns Encoder/Decoder, basically ripped from Netty full implementation.
     */
    internal object DnsRecordCodec {
      private const val SERVFAIL = 2
      private const val NXDOMAIN = 3
      const val TYPE_A = 0x0001
      const val TYPE_AAAA = 0x001c
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 3.9K bytes
    - Viewed (0)
Back to top