Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for PutResponse (0.04 sec)

  1. cmd/lock-rest-client.go

    	r, err := h.Call(ctx, c.connection, args)
    	if err != nil {
    		return false, err
    	}
    	defer h.PutResponse(r)
    	ok = r.Code == dsync.RespOK
    	switch r.Code {
    	case dsync.RespLockConflict, dsync.RespLockNotFound, dsync.RespOK:
    	// no error
    	case dsync.RespLockNotInitialized:
    		err = errLockNotInitialized
    	default:
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  2. cmd/storage-rest-client.go

    		storageRESTDiskID: *client.diskID.Load(),
    		storageRESTVolume: volume,
    	}))
    	if err != nil {
    		return vol, toStorageErr(err)
    	}
    	vol = *v
    	// Performs shallow copy, so we can reuse.
    	storageStatVolRPC.PutResponse(v)
    	return vol, nil
    }
    
    // DeleteVol - Deletes a volume over the network.
    func (client *storageRESTClient) DeleteVol(ctx context.Context, volume string, forceDelete bool) (err error) {
    	return errInvalidArgument
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 08 02:38:41 UTC 2025
    - 30.4K bytes
    - Viewed (0)
  3. cmd/bootstrap-peer-server.go

    	}
    
    	recvCfg, err := serverVerifyHandler.Call(ctx, client.gridConn, grid.NewMSS())
    	if err != nil {
    		return err
    	}
    	// We do not need the response after returning.
    	defer serverVerifyHandler.PutResponse(recvCfg)
    
    	return srcCfg.Diff(recvCfg)
    }
    
    // Stringer provides a canonicalized representation of node.
    func (client *bootstrapRESTClient) String() string {
    	return client.gridConn.String()
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  4. cmd/peer-rest-client.go

    		peerRESTLogMask: strconv.Itoa(int(kind)),
    	}))
    	if err != nil {
    		return
    	}
    	st.Results(func(b *grid.Bytes) error {
    		select {
    		case logCh <- *b:
    		default:
    			consoleLogRPC.PutResponse(b)
    			// Do not block on slow receivers.
    		}
    		return nil
    	})
    }
    
    // ConsoleLog - sends request to peer nodes to get console logs
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
Back to top