Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for writeAll (0.17 sec)

  1. cmd/naughty-disk_test.go

    		return FileInfo{}, err
    	}
    	return d.disk.ReadVersion(ctx, origvolume, volume, path, versionID, opts)
    }
    
    func (d *naughtyDisk) WriteAll(ctx context.Context, volume string, path string, b []byte) (err error) {
    	if err := d.calcError(); err != nil {
    		return err
    	}
    	return d.disk.WriteAll(ctx, volume, path, b)
    }
    
    func (d *naughtyDisk) ReadAll(ctx context.Context, volume string, path string) (buf []byte, err error) {
    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)
  2. cmd/xl-storage.go

    	lastVersion := len(xlMeta.versions) == 0
    	if !lastVersion {
    		buf, err = xlMeta.AppendTo(metaDataPoolGet())
    		defer metaDataPoolPut(buf)
    		if err != nil {
    			return err
    		}
    
    		return s.WriteAll(ctx, volume, pathJoin(path, xlStorageFormatFile), buf)
    	}
    
    	return s.deleteFile(volumeDir, pathJoin(volumeDir, path, xlStorageFormatFile), true, false)
    }
    
    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)
  3. cmd/xl-storage-disk-id-check.go

    }
    
    func (p *xlStorageDiskIDCheck) WriteAll(ctx context.Context, volume string, path string, b []byte) (err error) {
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricWriteAll, volume, path)
    	if err != nil {
    		return err
    	}
    	defer done(&err)
    
    	w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout())
    	return w.Run(func() error { return p.storage.WriteAll(ctx, volume, path, b) })
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  4. cmd/storage-rest-client.go

    		FilePath:       path,
    		ForceDelMarker: forceDelMarker,
    		FI:             fi,
    		Opts:           opts,
    	})
    	return toStorageErr(err)
    }
    
    // WriteAll - write all data to a file.
    func (client *storageRESTClient) WriteAll(ctx context.Context, volume string, path string, b []byte) error {
    	_, err := storageWriteAllRPC.Call(ctx, client.gridConn, &WriteAllHandlerParams{
    		DiskID:   *client.diskID.Load(),
    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)
  5. cmd/storage-rest-common.go

    )
    
    const (
    	storageRESTMethodHealth = "/health"
    
    	storageRESTMethodAppendFile     = "/appendfile"
    	storageRESTMethodCreateFile     = "/createfile"
    	storageRESTMethodWriteAll       = "/writeall"
    	storageRESTMethodReadVersion    = "/readversion"
    	storageRESTMethodReadXL         = "/readxl"
    	storageRESTMethodReadAll        = "/readall"
    	storageRESTMethodReadFile       = "/readfile"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 12 21:00:20 GMT 2024
    - 2.9K bytes
    - Viewed (0)
  6. cmd/storage-interface.go

    	CleanAbandonedData(ctx context.Context, volume string, path string) error
    
    	// Write all data, syncs the data to disk.
    	// Should be used for smaller payloads.
    	WriteAll(ctx context.Context, volume string, path string, b []byte) (err error)
    
    	// Read all.
    	ReadAll(ctx context.Context, volume string, path string) (buf []byte, err 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)
  7. cmd/format-erasure.go

    	defer disk.Delete(context.TODO(), minioMetaBucket, tmpFormat, DeleteOptions{
    		Recursive: false,
    		Immediate: false,
    	})
    
    	// write to unique file.
    	if err = disk.WriteAll(context.TODO(), minioMetaBucket, tmpFormat, formatData); err != nil {
    		return err
    	}
    
    	// Rename file `uuid.json` --> `format.json`.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  8. cmd/erasure-healing_test.go

    		Recursive: false,
    		Immediate: false,
    	})
    	if err != nil {
    		t.Errorf("Failure during deleting part.1 - %v", err)
    	}
    
    	err = firstDisk.WriteAll(context.Background(), bucket, pathJoin(object, fi.DataDir, "part.1"), []byte{})
    	if err != nil {
    		t.Errorf("Failure during creating part.1 - %v", err)
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Mar 27 15:10:40 GMT 2024
    - 47.6K bytes
    - Viewed (0)
  9. cmd/storage-rest-server.go

    	if !s.checkID(p.DiskID) {
    		return grid.NewNPErr(errDiskNotFound)
    	}
    
    	volume := p.Volume
    	filePath := p.FilePath
    
    	return grid.NewNPErr(s.getStorage().WriteAll(context.Background(), volume, filePath, p.Buf))
    }
    
    // ReadAllHandler - read all the contents of a file.
    func (s *storageRESTServer) ReadAllHandler(p *ReadAllHandlerParams) (*grid.Bytes, *grid.RemoteErr) {
    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)
  10. cmd/background-newdisks-heal-ops.go

    			}
    		}
    	}
    	h.LastUpdate = time.Now().UTC()
    	htrackerBytes, err := h.MarshalMsg(nil)
    	h.mu.Unlock()
    	if err != nil {
    		return err
    	}
    	globalBackgroundHealState.updateHealStatus(h)
    	return h.disk.WriteAll(ctx, minioMetaBucket,
    		pathJoin(bucketMetaPrefix, healingTrackerFilename),
    		htrackerBytes)
    }
    
    // delete the tracker on disk.
    func (h *healingTracker) delete(ctx context.Context) error {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.7K bytes
    - Viewed (0)
Back to top