- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 76 for createFile (0.12 sec)
-
.github/workflows/mint.yml
${GITHUB_WORKSPACE}/.github/workflows/run-mint.sh "erasure" "minio" "minio123" "${{ steps.vars.outputs.sha_short }}" # FIXME: renable this back when we have a valid way to add deadlines for PUT()s (internode CreateFile) # - name: resiliency # run: | # ${GITHUB_WORKSPACE}/.github/workflows/run-mint.sh "resiliency" "minio" "minio123" "${{ steps.vars.outputs.sha_short }}" - name: The job must cleanup
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jun 04 15:12:57 UTC 2024 - 2.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/reflect/ClassPathTest.java
// /[sibling -> left] Path root = createTempDirectory("ClassPathTest"); try { Path left = createDirectory(root.resolve("left")); createFile(left.resolve("some.txt")); Path right = createDirectory(root.resolve("right")); createFile(right.resolve("another.txt")); createSymbolicLink(left.resolve("sibling"), right); createSymbolicLink(right.resolve("sibling"), left);
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Jul 24 22:09:38 UTC 2024 - 27.6K bytes - Viewed (0) -
cmd/erasure-encode.go
p.errs[i] = io.ErrShortWrite p.writers[i] = nil } } else { p.writers[i] = nil } } // If nilCount >= p.writeQuorum, we return nil. This is because HealFile() uses // CreateFile with p.writeQuorum=1 to accommodate healing of single disk. // i.e if we do no return here in such a case, reduceWriteQuorumErrs() would // return a quorum error to HealFile(). nilCount := countErrs(p.errs, nil)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 2.9K bytes - Viewed (0) -
cmd/storage-interface.go
ReadFile(ctx context.Context, volume string, path string, offset int64, buf []byte, verifier *BitrotVerifier) (n int64, err error) 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)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Aug 12 08:38:15 UTC 2024 - 5.2K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbComNTCreateAndX.java
*/ static final int FILE_OVERWRITE = 0x4; /* Open the file and overwrite it's contents or create it if it does not exist * aka CREATE_ALWAYS (according to the wire when calling CreateFile) */ static final int FILE_OVERWRITE_IF = 0x5; // create options static final int FILE_WRITE_THROUGH = 0x00000002; static final int FILE_SEQUENTIAL_ONLY = 0x00000004;
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 6.6K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/com/SmbComNTCreateAndX.java
*/ static final int FILE_OVERWRITE = 0x4; /* * Open the file and overwrite it's contents or create it if it does not exist * aka CREATE_ALWAYS (according to the wire when calling CreateFile) */ static final int FILE_OVERWRITE_IF = 0x5; // create options static final int FILE_WRITE_THROUGH = 0x00000002; static final int FILE_SEQUENTIAL_ONLY = 0x00000004;
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 8.2K bytes - Viewed (0) -
cmd/mrf.go
} globalLocalDrivesMu.RLock() localDrives := cloneDrives(globalLocalDrivesMap) globalLocalDrivesMu.RUnlock() for _, localDrive := range localDrives { r := newReader() err := localDrive.CreateFile(context.Background(), "", minioMetaBucket, pathJoin(healMRFDir, "list.bin"), -1, r) r.Close() if err == nil { break } } } func (m *mrfState) startMRFPersistence() {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 13 22:26:05 UTC 2024 - 6.5K bytes - Viewed (0) -
cmd/bitrot-streaming.go
if length != -1 { bitrotSumsTotalSize := ceilFrac(length, shardSize) * int64(h.Size()) // Size used for storing bitrot checksums. totalFileSize = bitrotSumsTotalSize + length } rb.CloseWithError(disk.CreateFile(context.TODO(), origvolume, volume, filePath, totalFileSize, rb)) }() return bw } // ReadAt() implementation which verifies the bitrot hash available as part of the stream. type streamingBitrotReader struct {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 21 12:20:54 UTC 2024 - 6K bytes - Viewed (0) -
cmd/erasure-encode_test.go
return errFaultyDisk } func (a badDisk) ReadFileStream(ctx context.Context, volume, path string, offset, length int64) (io.ReadCloser, error) { return nil, errFaultyDisk } func (a badDisk) CreateFile(ctx context.Context, origvolume, volume, path string, size int64, reader io.Reader) error { return errFaultyDisk } func (badDisk) Hostname() string { return "" } const oneMiByte = 1 * humanize.MiByte
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jan 30 20:43:25 UTC 2024 - 11.9K bytes - Viewed (0) -
internal/lock/lock_windows.go
} shareflag := uint32(syscall.FILE_SHARE_READ | syscall.FILE_SHARE_WRITE | syscall.FILE_SHARE_DELETE) accessAttr := uint32(syscall.FILE_ATTRIBUTE_NORMAL | 0x80000000) fd, err := syscall.CreateFile(pathp, access, shareflag, nil, createflag, accessAttr, 0) if err != nil { return nil, err } return os.NewFile(uintptr(fd), path), nil } func lockFile(fd syscall.Handle, flags uint32) error {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Oct 18 18:08:15 UTC 2023 - 7.9K bytes - Viewed (0)