Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 251 - 260 of 562 for buffers (0.04 seconds)

  1. cmd/erasure_test.go

    	}
    	for i, test := range erasureEncodeDecodeTests {
    		buffer := make([]byte, len(data), 2*len(data))
    		copy(buffer, data)
    
    		erasure, err := NewErasure(t.Context(), test.dataBlocks, test.parityBlocks, blockSizeV2)
    		if err != nil {
    			t.Fatalf("Test %d: failed to create erasure: %v", i, err)
    		}
    		encoded, err := erasure.EncodeData(t.Context(), buffer)
    		if err != nil {
    			t.Fatalf("Test %d: failed to encode data: %v", i, err)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 4.8K bytes
    - Click Count (0)
  2. build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/BasicJavadocLexer.java

            }
        }
    
        private void parseHtmlEntity(StringBuilder buffer) {
            scanner.next();
            scanner.mark();
            scanner.find(';');
            String value = ENTITIES.get(scanner.region().toLowerCase(Locale.ROOT));
            buffer.append(value);
            scanner.next();
        }
    
        private void parseHtmlEncodedChar(StringBuilder buffer) {
            scanner.next(2);
            scanner.mark();
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Mon Aug 19 15:07:24 GMT 2024
    - 7.1K bytes
    - Click Count (0)
  3. cmd/mrf_gen_test.go

    	v := PartialOperation{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	en := msgp.NewWriter(msgp.Nowhere)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.EncodeMsg(en)
    	}
    	en.Flush()
    }
    
    func BenchmarkDecodePartialOperation(b *testing.B) {
    	v := PartialOperation{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 2.4K bytes
    - Click Count (0)
  4. cmd/metacache-set_gen_test.go

    	v := listPathOptions{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	en := msgp.NewWriter(msgp.Nowhere)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.EncodeMsg(en)
    	}
    	en.Flush()
    }
    
    func BenchmarkDecodelistPathOptions(b *testing.B) {
    	v := listPathOptions{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 2.4K bytes
    - Click Count (0)
  5. cmd/metacache-walk_gen_test.go

    	v := WalkDirOptions{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	en := msgp.NewWriter(msgp.Nowhere)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.EncodeMsg(en)
    	}
    	en.Flush()
    }
    
    func BenchmarkDecodeWalkDirOptions(b *testing.B) {
    	v := WalkDirOptions{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 2.3K bytes
    - Click Count (0)
  6. cmd/site-replication-utils_gen_test.go

    	v := SiteResyncStatus{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	en := msgp.NewWriter(msgp.Nowhere)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.EncodeMsg(en)
    	}
    	en.Flush()
    }
    
    func BenchmarkDecodeSiteResyncStatus(b *testing.B) {
    	v := SiteResyncStatus{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 2.4K bytes
    - Click Count (0)
  7. cmd/tier_gen_test.go

    	v := TierConfigMgr{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	en := msgp.NewWriter(msgp.Nowhere)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.EncodeMsg(en)
    	}
    	en.Flush()
    }
    
    func BenchmarkDecodeTierConfigMgr(b *testing.B) {
    	v := TierConfigMgr{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 2.3K bytes
    - Click Count (0)
  8. docs/pt/docs/async.md

    ### Hambúrgueres concorrentes { #concurrent-burgers }
    
    Você vai com seu _crush_ na lanchonete, e fica na fila enquanto o caixa pega os pedidos das pessoas na sua frente. 😍
    
    <img src="/img/async/concurrent-burgers/concurrent-burgers-01.png" class="illustration">
    
    Então chega a sua vez, você pede dois saborosos hambúrgueres para você e seu _crush_.  🍔🍔
    
    <img src="/img/async/concurrent-burgers/concurrent-burgers-02.png" class="illustration">
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Nov 12 16:23:57 GMT 2025
    - 25.8K bytes
    - Click Count (0)
  9. impl/maven-core/src/main/java/org/apache/maven/plugin/MojoExecution.java

        }
    
        @Override
        public String toString() {
            StringBuilder buffer = new StringBuilder(128);
            if (mojoDescriptor != null) {
                buffer.append(mojoDescriptor.getId());
            }
            buffer.append(" {execution: ").append(executionId).append('}');
            return buffer.toString();
        }
    
        public String getGroupId() {
            if (mojoDescriptor != null) {
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 6.2K bytes
    - Click Count (0)
  10. okhttp-hpacktests/src/test/java/okhttp3/internal/http2/hpackjson/HpackJsonUtil.kt

    import java.io.IOException
    import okio.BufferedSource
    import okio.ByteString
    import okio.ByteString.Companion.decodeHex
    import okio.FileSystem
    import okio.Path
    import okio.Path.Companion.toOkioPath
    import okio.buffer
    import okio.source
    
    /**
     * Utilities for reading HPACK tests.
     */
    object HpackJsonUtil {
      @Suppress("unused")
      private val MOSHI =
        Moshi
          .Builder()
          .add(
            object : Any() {
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 3.3K bytes
    - Click Count (0)
Back to Top