Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 1,728 for write (0.13 sec)

  1. src/archive/tar/fuzz_test.go

    		for _, f := range files {
    			if err := w.WriteHeader(f.header); err != nil {
    				t.Fatalf("unable to write previously parsed header: %s", err)
    			}
    			if _, err := w.Write(f.content); err != nil {
    				t.Fatalf("unable to write previously parsed content: %s", err)
    			}
    		}
    		if err := w.Close(); err != nil {
    			t.Fatalf("Unable to write archive: %s", err)
    		}
    
    		// TODO: We may want to check if the archive roundtrips. This would require
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Thu Jan 13 18:06:33 GMT 2022
    - 2.2K bytes
    - Viewed (0)
  2. istioctl/pkg/writer/ztunnel/configdump/configdump.go

    	return nil
    }
    
    func (c *ConfigWriter) PrintFullSummary() error {
    	_, _ = c.Stdout.Write([]byte("\n"))
    	if err := c.PrintWorkloadSummary(WorkloadFilter{Verbose: true}); err != nil {
    		return err
    	}
    	_, _ = c.Stdout.Write([]byte("\n"))
    	if err := c.PrintServiceSummary(ServiceFilter{}); err != nil {
    		return err
    	}
    	_, _ = c.Stdout.Write([]byte("\n"))
    	if err := c.PrintPolicySummary(PolicyFilter{}); err != nil {
    		return err
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 23 21:30:30 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  3. internal/crypto/key.go

    		mac := hmac.New(sha256.New, extKey)
    		mac.Write(sealedKey.IV[:])
    		mac.Write([]byte(domain))
    		mac.Write([]byte(SealAlgorithm))
    		mac.Write([]byte(path.Join(bucket, object))) // use path.Join for canonical 'bucket/object'
    		unsealConfig = sio.Config{MinVersion: sio.Version20, Key: mac.Sum(nil), CipherSuites: fips.DARECiphers()}
    	case InsecureSealAlgorithm:
    		sha := sha256.New()
    		sha.Write(extKey)
    		sha.Write(sealedKey.IV[:])
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 19 20:28:10 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  4. maven-api-impl/src/main/java/org/apache/maven/internal/impl/DefaultToolchainsXmlFactory.java

            }
            try {
                if (writer != null) {
                    new MavenToolchainsStaxWriter().write(writer, content);
                } else {
                    new MavenToolchainsStaxWriter().write(outputStream, content);
                }
            } catch (Exception e) {
                throw new XmlWriterException("Unable to write toolchains: " + getMessage(e), getLocation(e), e);
            }
    Java
    - Registered: Sun May 05 03:35:11 GMT 2024
    - Last Modified: Mon Mar 25 10:50:01 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/io/CharSourceTest.java

        assertFalse(source.wasStreamClosed());
    
        StringWriter writer = new StringWriter();
        char[] buf = new char[64];
        int read;
        while ((read = reader.read(buf)) != -1) {
          writer.write(buf, 0, read);
        }
        reader.close();
        writer.close();
    
        assertTrue(source.wasStreamClosed());
        assertEquals(STRING, writer.toString());
      }
    
      public void testCopyTo_appendable() throws IOException {
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 12K bytes
    - Viewed (0)
  6. cmd/metacache-set_gen.go

    // EncodeMsg implements msgp.Encodable
    func (z *listPathOptions) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 19
    	// write "ID"
    	err = en.Append(0xde, 0x0, 0x13, 0xa2, 0x49, 0x44)
    	if err != nil {
    		return
    	}
    	err = en.WriteString(z.ID)
    	if err != nil {
    		err = msgp.WrapError(err, "ID")
    		return
    	}
    	// write "Bucket"
    	err = en.Append(0xa6, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 19 20:23:12 GMT 2024
    - 13.8K bytes
    - Viewed (0)
  7. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerAdapter.kt

      fun fromDer(byteString: ByteString): T {
        val buffer = Buffer().write(byteString)
        val reader = DerReader(buffer)
        return fromDer(reader)
      }
    
      /**
       * Writes [value] to this adapter, unless it is the default value and can be safely omitted.
       *
       * If this does write a value, it will write a tag and a length and a full value.
       */
      fun toDer(
        writer: DerWriter,
        value: T,
      )
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/io/ByteStreamsTest.java

        // create a null output stream
        OutputStream nos = ByteStreams.nullOutputStream();
        // write to the output stream
        nos.write('n');
        String test = "Test string for NullOutputStream";
        byte[] bytes = test.getBytes(Charsets.US_ASCII);
        nos.write(bytes);
        nos.write(bytes, 2, 10);
        nos.write(bytes, bytes.length - 5, 5);
        // nothing really to assert?
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 21.9K bytes
    - Viewed (1)
  9. cmd/site-replication-metrics_gen.go

    }
    
    // EncodeMsg implements msgp.Encodable
    func (z RStat) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 2
    	// write "Count"
    	err = en.Append(0x82, 0xa5, 0x43, 0x6f, 0x75, 0x6e, 0x74)
    	if err != nil {
    		return
    	}
    	err = en.WriteInt64(z.Count)
    	if err != nil {
    		err = msgp.WrapError(err, "Count")
    		return
    	}
    	// write "Bytes"
    	err = en.Append(0xa5, 0x42, 0x79, 0x74, 0x65, 0x73)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Feb 06 06:00:45 GMT 2024
    - 40.6K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/internal/ws/WebSocketReaderTest.kt

        val bytes = binaryData(200)
        data.write("0264".decodeHex()).write(bytes, 0, 100)
        data.write("8064".decodeHex()).write(bytes, 100, 100)
        clientReader.processNextFrame()
        callback.assertBinaryMessage(bytes)
      }
    
      @Test fun twoFrameNotContinuation() {
        val bytes = binaryData(200)
        data.write("0264".decodeHex()).write(bytes, 0, 100)
        data.write("8264".decodeHex()).write(bytes, 100, 100)
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 14.4K bytes
    - Viewed (0)
Back to top