- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 43 for readAt (0.23 sec)
-
cmd/xl-storage.go
return nil, time.Time{}, err } return nil, time.Time{}, errFileNotFound } return buf, dmTime, nil } // ReadXL reads from path/xl.meta, does not interpret the data it read. This // is a raw call equivalent of ReadVersion(). func (s *xlStorage) ReadXL(ctx context.Context, volume, path string, readData bool) (RawFileInfo, error) { volumeDir, err := s.getVolDir(volume) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 85.3K bytes - Viewed (0) -
CHANGELOG/README.md
Kubernetes Release Robot <******@****.***> 1718206304 +0000
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 20:34:14 UTC 2024 - 1.3K bytes - Viewed (0) -
maven-plugin-api/src/main/java/org/apache/maven/plugin/descriptor/PluginDescriptorBuilder.java
} public interface ReaderSupplier { Reader open() throws IOException; } /** * @deprecated use {@link #build(ReaderSupplier)} */ @Deprecated public PluginDescriptor build(Reader reader) throws PlexusConfigurationException { return build(reader, null); } /** * @deprecated use {@link #build(ReaderSupplier, String)} */
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 07:23:04 UTC 2024 - 17.6K bytes - Viewed (0) -
cmd/storage-rest-client.go
// where we keep old *Readers var readMsgpReaderPool = sync.Pool{New: func() interface{} { return &msgp.Reader{} }} // mspNewReader returns a *Reader that reads from the provided reader. // The reader will be buffered. // Return with readMsgpReaderPoolPut when done. func msgpNewReader(r io.Reader) *msgp.Reader { p := readMsgpReaderPool.Get().(*msgp.Reader) if p.R == nil { p.R = xbufio.NewReaderSize(r, 4<<10) } else { p.R.Reset(r)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 27.4K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
if isCompressed { wantEncryption := crypto.Requested(r.Header) || isEncrypted s2c, cb := newS2CompressReader(reader, actualPartSize, wantEncryption) idxCb = cb defer s2c.Close() reader = etag.Wrap(s2c, reader) length = -1 } srcInfo.Reader, err = hash.NewReader(ctx, reader, length, "", "", actualPartSize) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 38.8K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/models/BuildTreeModelSideEffectStore.kt
val writer = ValueStore.Writer<BuildTreeModelSideEffect> { encoder, value -> write(encoder, value) } val reader = ValueStore.Reader { decoder -> read(decoder) } store.createValueStore(StateType.ModelSideEffects, writer, reader) } fun collectSideEffects(): List<BlockAddress> = entries.toList() fun write(sideEffect: BuildTreeModelSideEffect) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:30 UTC 2024 - 3.3K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/ConfigurationCacheStateStore.kt
/** * Creates a new [ValueStore] that can be used to load and store multiple values. */ fun <T> createValueStore( stateType: StateType, writer: ValueStore.Writer<T>, reader: ValueStore.Reader<T> ): ValueStore<T>
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 1.6K bytes - Viewed (0) -
cmd/object-handlers.go
compressMetadata[ReservedMetadataPrefix+"actual-size"] = strconv.FormatInt(actualSize, 10) reader = etag.NewReader(ctx, reader, nil, nil) wantEncryption := crypto.Requested(r.Header) s2c, cb := newS2CompressReader(reader, actualSize, wantEncryption) dstOpts.IndexCB = cb defer s2c.Close() reader = etag.Wrap(s2c, reader) length = -1 } else { delete(srcInfo.UserDefined, ReservedMetadataPrefix+"compression")
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 124.2K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/models/ProjectStateStore.kt
val valuesStore by lazy { val writer = ValueStore.Writer<V> { encoder, value -> write(encoder, value) } val reader = ValueStore.Reader { decoder -> read(decoder) } store.createValueStore(stateType, writer, reader) } private val previousValues = ConcurrentHashMap<K, BlockAddress>() private
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 6.3K bytes - Viewed (0) -
cmd/storage-interface.go
AppendFile(ctx context.Context, volume string, path string, buf []byte) (err error) CreateFile(ctx context.Context, origvolume, olume, path string, size int64, reader io.Reader) error ReadFileStream(ctx context.Context, volume, path string, offset, length int64) (io.ReadCloser, error) RenameFile(ctx context.Context, srcVolume, srcPath, dstVolume, dstPath string) error
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 5K bytes - Viewed (0)