Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 21 for Writer (0.04 sec)

  1. cmd/bucket-stats_gen.go

    func (z *BucketReplicationStat) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 14
    	// write "ReplicatedSize"
    	err = en.Append(0x8e, 0xae, 0x52, 0x65, 0x70, 0x6c, 0x69, 0x63, 0x61, 0x74, 0x65, 0x64, 0x53, 0x69, 0x7a, 0x65)
    	if err != nil {
    		return
    	}
    	err = en.WriteInt64(z.ReplicatedSize)
    	if err != nil {
    		err = msgp.WrapError(err, "ReplicatedSize")
    		return
    	}
    	// write "ReplicaSize"
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 06 06:00:45 UTC 2024
    - 57.5K bytes
    - Viewed (0)
  2. src/bufio/bufio_test.go

    			t.Errorf("r.WriteTo(errorWriterToTests[%d]) = _, %v, want _,%v", i, err, rw.expected)
    		}
    	}
    }
    
    func TestWriterReadFrom(t *testing.T) {
    	ws := []func(io.Writer) io.Writer{
    		func(w io.Writer) io.Writer { return onlyWriter{w} },
    		func(w io.Writer) io.Writer { return w },
    	}
    
    	rs := []func(io.Reader) io.Reader{
    		iotest.DataErrReader,
    		func(r io.Reader) io.Reader { return r },
    	}
    
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Feb 07 01:08:54 UTC 2025
    - 51.6K bytes
    - Viewed (0)
  3. cmd/xl-storage-format-v2_gen.go

    	if err != nil {
    		return
    	}
    	if (zb0001Mask & 0x1) == 0 { // if not omitted
    		// write "V2Obj"
    		err = en.Append(0xa5, 0x56, 0x32, 0x4f, 0x62, 0x6a)
    		if err != nil {
    			return
    		}
    		if z.ObjectV2 == nil {
    			err = en.WriteNil()
    			if err != nil {
    				return
    			}
    		} else {
    			// map header, size 1
    			// write "DDir"
    			err = en.Append(0x81, 0xa4, 0x44, 0x44, 0x69, 0x72)
    			if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Dec 15 22:50:12 UTC 2024
    - 56K bytes
    - Viewed (0)
  4. cmd/bucket-replication-utils_gen.go

    // EncodeMsg implements msgp.Encodable
    func (z *BucketReplicationResyncStatus) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 4
    	// write "v"
    	err = en.Append(0x84, 0xa1, 0x76)
    	if err != nil {
    		return
    	}
    	err = en.WriteInt(z.Version)
    	if err != nil {
    		err = msgp.WrapError(err, "Version")
    		return
    	}
    	// write "brs"
    	err = en.Append(0xa3, 0x62, 0x72, 0x73)
    	if err != nil {
    		return
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Apr 03 06:45:06 UTC 2025
    - 59.8K bytes
    - Viewed (0)
  5. fess-crawler-lasta/src/main/resources/crawler/extractor.xml

    				"application/vnd.sun.xml.impress",
    				"application/vnd.sun.xml.impress.template",
    				"application/vnd.sun.xml.math",
    				"application/vnd.sun.xml.writer",
    				"application/vnd.sun.xml.writer.global",
    				"application/vnd.sun.xml.writer.template",
    				"application/vnd.sun.wadl+xml",
    				"application/vnd.sus-calendar",
    				"application/vnd.svd",
    				"application/vnd.swiftview-ics",
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Aug 01 21:40:30 UTC 2020
    - 49K bytes
    - Viewed (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt

        // Verify the peer's settings were read and applied.
        assertThat(connection.peerSettings.headerTableSize).isEqualTo(0)
        val writer = connection.writer
        assertThat(writer.hpackWriter.dynamicTableByteCount).isEqualTo(0)
        assertThat(writer.hpackWriter.headerTableSizeSetting).isEqualTo(0)
      }
    
      @Test fun peerHttp2ClientDisablesPush() {
        val client = false // Peer is client, so we are server.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 75.5K bytes
    - Viewed (0)
  7. cmd/data-usage-cache_gen.go

    // EncodeMsg implements msgp.Encodable
    func (z *dataUsageCache) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 2
    	// write "Info"
    	err = en.Append(0x82, 0xa4, 0x49, 0x6e, 0x66, 0x6f)
    	if err != nil {
    		return
    	}
    	err = z.Info.EncodeMsg(en)
    	if err != nil {
    		err = msgp.WrapError(err, "Info")
    		return
    	}
    	// write "Cache"
    	err = en.Append(0xa5, 0x43, 0x61, 0x63, 0x68, 0x65)
    	if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Dec 15 22:50:12 UTC 2024
    - 86.4K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

            .isTrue();
        if (!failures.isEmpty()) {
          StringWriter message = new StringWriter();
          PrintWriter writer = new PrintWriter(message);
          writer.println("Expected no failures, but found:");
          for (AssertionError failure : failures) {
            failure.printStackTrace(writer);
          }
          failures.clear();
          assertWithMessage(message.toString()).fail();
        }
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 75.4K bytes
    - Viewed (0)
  9. cmd/erasure-object.go

    			inlineBuffers[i] = bytes.NewBuffer(buf[:0])
    			defer grid.PutByteBuffer(buf)
    			writers[i] = newStreamingBitrotWriterBuffer(inlineBuffers[i], DefaultBitrotAlgorithm, erasure.ShardSize())
    		}
    	}
    
    	n, erasureErr := erasure.Encode(ctx, data, writers, buffer, writeQuorum)
    	closeErrs := closeBitrotWriters(writers)
    	if erasureErr != nil {
    		return ObjectInfo{}, toObjectErr(erasureErr, minioMetaBucket, key)
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  10. .teamcity/.mvn/wrapper/maven-wrapper.jar

    java.util.Map optionsByString; private boolean allowMixedOptions; private boolean allowUnknownOptions; private final java.io.PrintWriter deprecationPrinter; static void <clinit>(); public void CommandLineParser(); public void CommandLineParser(java.io.Writer); public transient ParsedCommandLine parse(String[]) throws CommandLineArgumentE; public ParsedCommandLine parse(Iterable) throws CommandLineArgumentE; public CommandLineParser allowMixedSubcommand(); public CommandLineParser allowUnknownOptions();...
    Registered: Wed Sep 10 11:36:15 UTC 2025
    - Last Modified: Wed Feb 26 01:48:39 UTC 2020
    - 49.5K bytes
    - Viewed (0)
Back to top