Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 76 for createFile (0.12 sec)

  1. .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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top