Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 1,609 for dwrite (0.08 sec)

  1. doc/next/6-stdlib/99-minor/archive/66831.md

    The `(*Writer).AddFS` implementations in both `archive/zip` and `archive/tar`
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Sep 23 14:32:33 UTC 2024
    - 131 bytes
    - Viewed (0)
  2. internal/lsync/lrwmutex_test.go

    	lrwm := NewLRWMutex()
    
    	// fmt.Println("Getting initial write lock")
    	if !lrwm.GetLock(ctx, "", "", time.Second) {
    		panic("Failed to acquire initial write lock")
    	}
    
    	go func() {
    		time.Sleep(2 * time.Second)
    		lrwm.Unlock()
    		// fmt.Println("Initial write lock released, waiting...")
    	}()
    
    	// fmt.Println("Trying to acquire 2nd write lock, waiting...")
    	locked = lrwm.GetLock(ctx, "", "", duration)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 05 04:57:35 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  3. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/BasicDerAdapter.kt

        }
    
        return result
      }
    
      override fun toDer(
        writer: DerWriter,
        value: T,
      ) {
        if (typeHint) {
          writer.typeHint = value
        }
    
        if (isOptional && value == defaultValue) {
          // Nothing to write!
          return
        }
    
        writer.write(name, tagClass, tag) {
          codec.encode(writer, value)
        }
      }
    
      /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  4. internal/grid/msg_gen.go

    }
    
    // EncodeMsg implements msgp.Encodable
    func (z *connectReq) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 4
    	// write "ID"
    	err = en.Append(0x84, 0xa2, 0x49, 0x44)
    	if err != nil {
    		return
    	}
    	err = en.WriteBytes((z.ID)[:])
    	if err != nil {
    		err = msgp.WrapError(err, "ID")
    		return
    	}
    	// write "Host"
    	err = en.Append(0xa4, 0x48, 0x6f, 0x73, 0x74)
    	if err != nil {
    		return
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jul 25 21:07:21 UTC 2024
    - 22.4K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/io/SourceSinkFactories.java

        public CharSink createSink() throws IOException {
          File file = createFile();
          if (initialString != null) {
            Writer writer = new OutputStreamWriter(new FileOutputStream(file), UTF_8);
            try {
              writer.write(initialString);
            } finally {
              writer.close();
            }
            return Files.asCharSink(file, UTF_8, FileWriteMode.APPEND);
          }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 12.6K bytes
    - Viewed (0)
  6. cmd/tier-last-day-stats_gen.go

    func (z DailyAllTierStats) EncodeMsg(en *msgp.Writer) (err error) {
    	err = en.WriteMapHeader(uint32(len(z)))
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0007, zb0008 := range z {
    		err = en.WriteString(zb0007)
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		// map header, size 2
    		// write "Bins"
    		err = en.Append(0x82, 0xa4, 0x42, 0x69, 0x6e, 0x73)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 21 17:21:35 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  7. cni/pkg/install/install.go

    	// so we are good to simply write it out if our watched svcacct token changes.
    	if err := writeKubeConfigFile(in.cfg); err != nil {
    		cniInstalls.With(resultLabel.Value(resultCreateKubeConfigFailure)).Increment()
    		return copiedFiles, fmt.Errorf("write kubeconfig: %v", err)
    	}
    
    	// Install CNI netdir config (if needed) - we write/update this in the shared node CNI netdir,
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Aug 09 21:33:51 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  8. compat/maven-model-builder/src/test/java/org/apache/maven/model/inheritance/DefaultInheritanceAssemblerTest.java

            Model assembled = assembler.assembleModelInheritance(child, parent, null, problems);
    
            // write baseName + "-actual"
            File actual = new File(
                    "target/test-classes/poms/inheritance/" + baseName + (fromRepo ? "-build" : "-repo") + "-actual.xml");
            writer.write(actual, null, assembled);
    
            // check with getPom( baseName + "-expected" )
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  9. cmd/batch-rotate_gen.go

    // EncodeMsg implements msgp.Encodable
    func (z BatchJobKeyRotateEncryption) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 3
    	// write "Type"
    	err = en.Append(0x83, 0xa4, 0x54, 0x79, 0x70, 0x65)
    	if err != nil {
    		return
    	}
    	err = en.WriteString(string(z.Type))
    	if err != nil {
    		err = msgp.WrapError(err, "Type")
    		return
    	}
    	// write "Key"
    	err = en.Append(0xa3, 0x4b, 0x65, 0x79)
    	if err != nil {
    		return
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 02 10:51:33 UTC 2023
    - 27.1K bytes
    - Viewed (0)
  10. src/main/java/jcifs/smb1/smb1/SmbNamedPipe.java

         * Pipe instance although this is not a requirement (e.g. a
         * read-only named pipe would write data to this stream on
         * connection). Reading from this stream may block. Therefore it
         * may be necessary that an addition thread be used to read and
         * write to a Named Pipe.
         */
    
        public InputStream getNamedPipeInputStream() throws IOException {
            if( pipeIn == null ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 7.3K bytes
    - Viewed (0)
Back to top