Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for WriteAll (0.14 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) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  2. 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)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  3. 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)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  4. 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(int64(len(b)), &err)
    
    	w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout())
    	return w.Run(func() error { return p.storage.WriteAll(ctx, volume, path, b) })
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  5. 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 {
    	ctx, cancel := context.WithTimeout(ctx, globalDriveConfig.GetMaxTimeout())
    	defer cancel()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  6. 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)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  7. 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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  8. 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`.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  9. cmd/xl-storage_test.go

    	// Initialize a new xlStorage layer.
    	storage, err := newLocalXLStorageWithDiskIdx(diskPath, 3)
    	if err != nil {
    		return nil, "", err
    	}
    
    	// Create a sample format.json file
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 66.7K bytes
    - Viewed (0)
  10. 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) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
Back to top