Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 111 - 120 of 1,953 for Pwrite (0.06 seconds)

  1. 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
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 22.4K bytes
    - Click Count (0)
  2. internal/s3select/simdj/record.go

    	return sql.SelectFmtSIMDJSON, r.object
    }
    
    // WriteJSON - encodes to JSON data.
    func (r *Record) WriteJSON(writer io.Writer) error {
    	o := r.object
    	elems, err := o.Parse(nil)
    	if err != nil {
    		return err
    	}
    	b, err := elems.MarshalJSON()
    	if err != nil {
    		return err
    	}
    	n, err := writer.Write(b)
    	if err != nil {
    		return err
    	}
    	if n != len(b) {
    		return io.ErrShortWrite
    	}
    	return nil
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.4K bytes
    - Click Count (0)
  3. internal/grid/grid_types_msgp_test.go

    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z testRequest) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 2
    	// write "Num"
    	err = en.Append(0x82, 0xa3, 0x4e, 0x75, 0x6d)
    	if err != nil {
    		return
    	}
    	err = en.WriteInt(z.Num)
    	if err != nil {
    		err = msgp.WrapError(err, "Num")
    		return
    	}
    	// write "String"
    	err = en.Append(0xa6, 0x53, 0x74, 0x72, 0x69, 0x6e, 0x67)
    	if err != nil {
    		return
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 8.1K bytes
    - Click Count (0)
  4. cmd/bucket-replication-metrics_gen.go

    		return
    	}
    	// write "Bytes"
    	err = en.Append(0xa5, 0x42, 0x79, 0x74, 0x65, 0x73)
    	if err != nil {
    		return
    	}
    	err = en.WriteFloat64(z.Curr.Bytes)
    	if err != nil {
    		err = msgp.WrapError(err, "Curr", "Bytes")
    		return
    	}
    	// write "aq"
    	err = en.Append(0xa2, 0x61, 0x71)
    	if err != nil {
    		return
    	}
    	// map header, size 2
    	// write "Count"
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 33.3K bytes
    - Click Count (0)
  5. mockwebserver/src/main/kotlin/mockwebserver3/internal/ThrottledSink.kt

          bytesLeft -= toWrite
          delegate.write(source, toWrite)
        }
      }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jul 29 12:43:16 GMT 2025
    - 1.5K bytes
    - Click Count (0)
  6. cmd/metacache-stream.go

    		}
    		return nil
    	}
    	return &w
    }
    
    // write one or more objects to the stream in order.
    // It is favorable to send as many objects as possible in a single write,
    // but no more than math.MaxUint32
    func (w *metacacheWriter) write(objs ...metaCacheEntry) error {
    	if w == nil {
    		return errors.New("metacacheWriter: nil writer")
    	}
    	if len(objs) == 0 {
    		return nil
    	}
    	if w.creator != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed May 07 15:37:12 GMT 2025
    - 19.5K bytes
    - Click Count (0)
  7. src/test/java/org/codelibs/fess/dict/protwords/ProtwordsFileTest.java

            assertEquals("	tab	word	", list.get(3).getInput());
        }
    
        // Helper method to write content to test file
        private void writeTestFile(String content) throws Exception {
            java.io.FileWriter writer = new java.io.FileWriter(testFile);
            writer.write(content);
            writer.close();
        }
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Wed Jan 14 14:29:07 GMT 2026
    - 21.2K bytes
    - Click Count (0)
  8. 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);
          }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jul 16 17:42:14 GMT 2025
    - 12.7K bytes
    - Click Count (0)
  9. compat/maven-model-builder/src/test/java/org/apache/maven/model/inheritance/DefaultInheritanceAssemblerTest.java

            assembler.assembleModelInheritance(assembled, 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" )
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Sep 17 10:01:14 GMT 2025
    - 8.2K bytes
    - Click Count (0)
  10. cmd/storage-datatypes_gen.go

    // EncodeMsg implements msgp.Encodable
    func (z *CheckPartsHandlerParams) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 4
    	// write "id"
    	err = en.Append(0x84, 0xa2, 0x69, 0x64)
    	if err != nil {
    		return
    	}
    	err = en.WriteString(z.DiskID)
    	if err != nil {
    		err = msgp.WrapError(err, "DiskID")
    		return
    	}
    	// write "v"
    	err = en.Append(0xa1, 0x76)
    	if err != nil {
    		return
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 151.7K bytes
    - Click Count (0)
Back to Top