- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for writeRaw (0.43 sec)
-
src/io/io.go
// WriteAt should not affect nor be affected by the underlying // seek offset. // // Clients of WriteAt can execute parallel WriteAt calls on the same // destination if the ranges do not overlap. // // Implementations must not retain p. type WriterAt interface { WriteAt(p []byte, off int64) (n int, err error) } // ByteReader is the interface that wraps the ReadByte method. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 17:34:10 UTC 2024 - 21.6K bytes - Viewed (0) -
cmd/sftp-server-driver.go
for i := range w.buffer { delete(w.buffer, i) } w.wg.Wait() return err } type writerAt struct { w *io.PipeWriter r *io.PipeReader wg *sync.WaitGroup buffer map[int64][]byte err error nextOffset int64 m sync.Mutex } func (w *writerAt) WriteAt(b []byte, offset int64) (n int, err error) { w.m.Lock() defer w.m.Unlock()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jun 05 07:51:13 UTC 2024 - 11.1K bytes - Viewed (0) -
platforms/core-configuration/guava-serialization-codecs/src/main/kotlin/org/gradle/internal/serialize/codecs/guava/ImmutableMapCodec.kt
import org.gradle.internal.serialize.graph.WriteContext import org.gradle.internal.serialize.graph.writeMap object ImmutableMapCodec : Codec<ImmutableMap<Any, Any>> { override suspend fun WriteContext.encode(value: ImmutableMap<Any, Any>) { writeMap(value) } override suspend fun ReadContext.decode(): ImmutableMap<Any, Any>? { val size = readSmallInt()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat May 25 20:43:52 UTC 2024 - 1.4K bytes - Viewed (0) -
platforms/core-configuration/stdlib-serialization-codecs/src/main/kotlin/org/gradle/internal/serialize/codecs/stdlib/CollectionCodecs.kt
{ write(it.comparator()) writeMap(it) }, { @Suppress("unchecked_cast") val comparator = read() as Comparator<Any?>? readMapInto { TreeMap(comparator) } } ) fun <T : MutableMap<Any?, Any?>> mapCodec(factory: (Int) -> T): Codec<T> = codec( { writeMap(it) }, { readMapInto(factory) }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat May 25 20:43:52 UTC 2024 - 3.7K bytes - Viewed (0) -
src/cmd/link/internal/ld/macho_combine_dwarf.go
func (r loadCmdReader) ReadAt(offset int64, data interface{}) error { if _, err := r.f.Seek(r.offset+offset, 0); err != nil { return err } return binary.Read(r.f, r.order, data) } func (r loadCmdReader) WriteAt(offset int64, data interface{}) error { if _, err := r.f.Seek(r.offset+offset, 0); err != nil { return err } return binary.Write(r.f, r.order, data) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 21 18:45:27 UTC 2024 - 13.3K bytes - Viewed (0) -
src/net/tcpsockopt_plan9.go
} // Set keep alive period. func setKeepAliveIdle(fd *netFD, d time.Duration) error { if d < 0 { return nil } cmd := "keepalive " + itoa.Itoa(int(d/time.Millisecond)) _, e := fd.ctl.WriteAt([]byte(cmd), 0) return e } func setKeepAliveInterval(_ *netFD, d time.Duration) error { if d < 0 { return nil } return syscall.EPLAN9 } func setKeepAliveCount(_ *netFD, n int) error {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 762 bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/query/StoredLtrQueryBuilder.java
} @Override protected void doWriteTo(final StreamOutput out) throws IOException { out.writeOptionalString(modelName); out.writeOptionalString(featureSetName); out.writeMap(params); out.writeOptionalStringArray(activeFeatures != null ? activeFeatures.toArray(new String[0]) : null); out.writeOptionalString(storeName); } @Override
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 5.8K bytes - Viewed (0) -
src/os/file.go
var errWriteAtInAppendMode = errors.New("os: invalid use of WriteAt on file opened with O_APPEND") // WriteAt writes len(b) bytes to the File starting at byte offset off. // It returns the number of bytes written and an error, if any. // WriteAt returns a non-nil error when n != len(b). // // If file was opened with the O_APPEND flag, WriteAt returns an error. func (f *File) WriteAt(b []byte, off int64) (n int, err error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 23:07:37 UTC 2024 - 25.4K bytes - Viewed (0) -
src/cmd/link/internal/ld/macho_update_uuid.go
return err } if cmd.Cmd == LC_UUID { var u uuidCmd if err := reader.ReadAt(0, &u); err != nil { return err } copy(u.Uuid[:], uuidFromGoBuildId(*flagBuildid)) if err := reader.WriteAt(0, &u); err != nil { return err } break } } // We're done return nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 21 18:45:27 UTC 2024 - 3.3K bytes - Viewed (0) -
platforms/core-configuration/graph-serialization/src/main/kotlin/org/gradle/internal/serialize/graph/Combinators.kt
} suspend fun <T : MutableCollection<Any?>> ReadContext.readCollectionInto(factory: (Int) -> T): T = readCollectionInto(factory) { read() } suspend fun WriteContext.writeMap(value: Map<*, *>) { writeSmallInt(value.size) writeMapEntries(value) } suspend fun WriteContext.writeMapEntries(value: Map<*, *>) { for (entry in value.entries) { write(entry.key)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:59:39 UTC 2024 - 8.4K bytes - Viewed (0)