- Sort Score
- Num 10 results
- Language All
Results 321 - 330 of 398 for readDir (0.09 seconds)
-
cmd/data-usage-cache.go
d.replaceHashed(dataUsageHash(key), &eHash, existing) } } type objectIO interface { GetObjectNInfo(ctx context.Context, bucket, object string, rs *HTTPRangeSpec, h http.Header, opts ObjectOptions) (reader *GetObjectReader, err error) PutObject(ctx context.Context, bucket, object string, data *PutObjReader, opts ObjectOptions) (objInfo ObjectInfo, err error) }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 34.7K bytes - Click Count (0) -
api/go1.10.txt
pkg encoding/asn1, const TagNumericString ideal-int pkg encoding/asn1, func MarshalWithParams(interface{}, string) ([]uint8, error) pkg encoding/csv, type ParseError struct, StartLine int pkg encoding/hex, func NewDecoder(io.Reader) io.Reader pkg encoding/hex, func NewEncoder(io.Writer) io.Writer pkg encoding/json, method (*Decoder) DisallowUnknownFields() pkg encoding/xml, func NewTokenDecoder(TokenReader) *Decoder
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Tue Feb 06 05:00:01 GMT 2018 - 30.1K bytes - Click Count (0) -
cmd/auth-handler.go
} // Verify 'Content-Md5' and/or 'X-Amz-Content-Sha256' if present. // The verification happens implicit during reading. reader, err := hash.NewReader(ctx, r.Body, -1, clientETag.String(), hex.EncodeToString(contentSHA256), -1) if err != nil { return toAPIErrorCode(ctx, err) } r.Body = reader return ErrNone } // List of all support S3 auth types. var supportedS3AuthTypes = map[authType]struct{}{
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 25.4K bytes - Click Count (0) -
cmd/ftp-server-driver.go
if err != nil { return 0, nil, err } n = info.Size - offset return n, obj, nil } // PutFile implements ftpDriver func (driver *ftpDriver) PutFile(ctx *ftp.Context, objPath string, data io.Reader, offset int64) (n int64, err error) { stopFn := globalFtpMetrics.log(ctx, objPath) defer stopFn(n, err) bucket, object := path2BucketObject(objPath) if bucket == "" {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 14.3K bytes - Click Count (0) -
cmd/sftp-server-driver.go
return f.permissions.CriticalOptions["AccessKey"] } func (f *sftpDriver) Fileread(r *sftp.Request) (ra io.ReaderAt, err error) { // This is not timing the actual read operation, but the time it takes to prepare the reader. stopFn := globalSftpMetrics.log(r, f.AccessKey()) defer stopFn(0, err) flags := r.Pflags() if !flags.Read { // sanity check return nil, os.ErrInvalid }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Feb 10 16:35:49 GMT 2025 - 11.6K bytes - Click Count (0) -
compat/maven-resolver-provider/src/main/java/org/apache/maven/repository/internal/DefaultArtifactDescriptorReader.java
import org.eclipse.aether.resolution.VersionResult; import org.eclipse.aether.transfer.ArtifactNotFoundException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Default artifact descriptor reader. * * @deprecated since 4.0.0, use {@code maven-api-impl} jar instead */ @Named @Singleton @Deprecated(since = "4.0.0") public class DefaultArtifactDescriptorReader implements ArtifactDescriptorReader {Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Jan 10 08:42:00 GMT 2025 - 17.1K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/testing/FreshValueGenerator.java
import com.google.common.reflect.Reflection; import com.google.common.reflect.TypeToken; import java.io.ByteArrayInputStream; import java.io.File; import java.io.InputStream; import java.io.Reader; import java.io.StringReader; import java.lang.annotation.ElementType; import java.lang.annotation.Retention; import java.lang.annotation.RetentionPolicy; import java.lang.annotation.Target;
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue May 13 17:27:14 GMT 2025 - 28.1K bytes - Click Count (0) -
src/bytes/buffer_test.go
if err != nil { t.Fatal(err) } if i != 0 { t.Fatalf("unexpected return from bytes.ReadFrom (1): got: %d, want %d", i, 0) } check(t, "TestReadFromPanicReader (1)", &buf, "") // Confirm that when Reader panics, the empty buffer remains empty var buf2 Buffer defer func() { recover() check(t, "TestReadFromPanicReader (2)", &buf2, "") }() buf2.ReadFrom(panicReader{panic: true}) }Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Fri Nov 14 19:01:17 GMT 2025 - 19.4K bytes - Click Count (0) -
src/archive/tar/tar_test.go
} if err := tw.Close(); err != nil { b.Errorf("unexpected Close error: %v", err) } } }) } }) b.Run("Reader", func(b *testing.B) { for _, v := range vectors { var buf bytes.Buffer var r bytes.Reader // Write the archive to a byte buffer. tw := NewWriter(&buf) for _, file := range v.files { tw.WriteHeader(file.hdr) tw.Write(file.body)
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Thu Jul 25 00:25:45 GMT 2024 - 23.9K bytes - Click Count (0) -
guava-testlib/src/com/google/common/testing/FreshValueGenerator.java
import com.google.common.reflect.Reflection; import com.google.common.reflect.TypeToken; import java.io.ByteArrayInputStream; import java.io.File; import java.io.InputStream; import java.io.Reader; import java.io.StringReader; import java.lang.annotation.ElementType; import java.lang.annotation.Retention; import java.lang.annotation.RetentionPolicy; import java.lang.annotation.Target;
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue May 13 17:27:14 GMT 2025 - 28.7K bytes - Click Count (0)