Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for createFile (0.17 sec)

  1. maven-compat/src/test/java/org/apache/maven/artifact/testutils/TestFileManager.java

        protected void finalize() throws Throwable {
            maybeWarnAboutCleanUp();
    
            super.finalize();
        }
    
        public File createFile(String filename, String content, String encoding) throws IOException {
            File dir = createTempDir();
            return createFile(dir, filename, content, encoding);
        }
    Java
    - Registered: Sun May 05 03:35:11 GMT 2024
    - Last Modified: Thu Apr 25 05:46:50 GMT 2024
    - 4.7K bytes
    - Viewed (0)
  2. cmd/naughty-disk_test.go

    		return nil, err
    	}
    	return d.disk.ReadFileStream(ctx, volume, path, offset, length)
    }
    
    func (d *naughtyDisk) CreateFile(ctx context.Context, origvolume, volume, path string, size int64, reader io.Reader) error {
    	if err := d.calcError(); err != nil {
    		return err
    	}
    	return d.disk.CreateFile(ctx, origvolume, volume, path, size, reader)
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 9.3K bytes
    - Viewed (0)
  3. 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)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 4.9K bytes
    - Viewed (0)
  4. cmd/xl-storage-disk-id-check.go

    	})
    }
    
    func (p *xlStorageDiskIDCheck) CreateFile(ctx context.Context, origvolume, volume, path string, size int64, reader io.Reader) (err error) {
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricCreateFile, volume, path)
    	if err != nil {
    		return err
    	}
    	defer done(&err)
    
    	return p.storage.CreateFile(ctx, origvolume, volume, path, size, io.NopCloser(reader))
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  5. cmd/storage-rest-client.go

    	reader := bytes.NewReader(buf)
    	respBody, err := client.call(ctx, storageRESTMethodAppendFile, values, reader, -1)
    	defer xhttp.DrainBody(respBody)
    	return err
    }
    
    func (client *storageRESTClient) CreateFile(ctx context.Context, origvolume, volume, path string, size int64, reader io.Reader) error {
    	values := make(url.Values)
    	values.Set(storageRESTVolume, volume)
    	values.Set(storageRESTFilePath, path)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
  6. cmd/erasure-multipart.go

    			// prematurely closed and we do not find any xl.meta or
    			// part.1's - in such a scenario we must return as if client
    			// disconnected. This means that erasure.Encode() CreateFile()
    			// did not do anything.
    			return pi, IncompleteBody{Bucket: bucket, Object: object}
    		}
    
    		return pi, toObjectErr(err, minioMetaMultipartBucket, partPath)
    	}
    
    	md5hex := r.MD5CurrentHexString()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
  7. cmd/xl-storage.go

    type closeWrapper func() error
    
    // Close calls the wrapped function.
    func (c closeWrapper) Close() error {
    	return c()
    }
    
    // CreateFile - creates the file.
    func (s *xlStorage) CreateFile(ctx context.Context, origvolume, volume, path string, fileSize int64, r io.Reader) (err error) {
    	if origvolume != "" {
    		origvolumeDir, err := s.getVolDir(origvolume)
    		if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  8. cmd/storage-rest-server.go

    	fileSize, err := strconv.Atoi(fileSizeStr)
    	if err != nil {
    		s.writeErrorResponse(w, err)
    		return
    	}
    
    	done, body := keepHTTPReqResponseAlive(w, r)
    	done(s.getStorage().CreateFile(r.Context(), origvolume, volume, filePath, int64(fileSize), body))
    }
    
    // DeleteVersionHandler delete updated metadata.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 44.8K bytes
    - Viewed (0)
  9. cmd/erasure-object.go

    			// prematurely closed and we do not find any xl.meta or
    			// part.1's - in such a scenario we must return as if client
    			// disconnected. This means that erasure.Encode() CreateFile()
    			// did not do anything.
    			return ObjectInfo{}, IncompleteBody{Bucket: bucket, Object: object}
    		}
    		return ObjectInfo{}, toObjectErr(err, bucket, object)
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  10. cmd/bucket-replication.go

    	}
    
    	globalLocalDrivesMu.RLock()
    	localDrives := cloneDrives(globalLocalDrives)
    	globalLocalDrivesMu.RUnlock()
    
    	for _, localDrive := range localDrives {
    		r := newReader()
    		err := localDrive.CreateFile(ctx, "", minioMetaBucket, pathJoin(replicationMRFDir, globalLocalNodeNameHex+".bin"), -1, r)
    		r.Close()
    		if err == nil {
    			break
    		}
    	}
    }
    
    // save mrf entries to nodenamehex.bin
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
Back to top