Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for remotePeer (0.18 sec)

  1. internal/grid/handlers.go

    func NewRemoteErrString(msg string) *RemoteErr {
    	r := RemoteErr(msg)
    	return &r
    }
    
    func (r RemoteErr) Error() string {
    	return string(r)
    }
    
    // Is returns if the string representation matches.
    func (r *RemoteErr) Is(other error) bool {
    	if r == nil || other == nil {
    		return r == other
    	}
    	var o RemoteErr
    	if errors.As(other, &o) {
    		return r == &o
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 27.1K bytes
    - Viewed (0)
  2. internal/grid/grid_test.go

    	errFatal(local.RegisterSingleHandler(handlerTest, func(payload []byte) ([]byte, *RemoteErr) {
    		t.Log("1: server payload: ", len(payload), "bytes.")
    		return append([]byte{}, payload...), nil
    	}))
    	// 2: Return as error
    	errFatal(local.RegisterSingleHandler(handlerTest2, func(payload []byte) ([]byte, *RemoteErr) {
    		t.Log("2: server payload: ", len(payload), "bytes.")
    		err := RemoteErr(payload)
    		return nil, &err
    	}))
    
    	remote := grid.Managers[1]
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 30 15:03:35 GMT 2024
    - 30.1K bytes
    - Viewed (0)
  3. 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().CheckParts(context.Background(), volume, filePath, p.FI))
    }
    
    func (s *storageRESTServer) WriteAllHandler(p *WriteAllHandlerParams) (grid.NoPayload, *grid.RemoteErr) {
    	if !s.checkID(p.DiskID) {
    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)
  4. cmd/metacache-walk.go

    }
    
    // WalkDirHandler - remote caller to list files and folders in a requested directory path.
    func (s *storageRESTServer) WalkDirHandler(ctx context.Context, payload []byte, _ <-chan []byte, out chan<- []byte) (gerr *grid.RemoteErr) {
    	var opts WalkDirOptions
    	_, err := opts.UnmarshalMsg(payload)
    	if err != nil {
    		return grid.NewRemoteErr(err)
    	}
    
    	if !s.checkID(opts.DiskID) {
    		return grid.NewRemoteErr(errDiskNotFound)
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 12.4K bytes
    - Viewed (0)
Back to top