Home
last modified time | relevance | path

Searched refs:method (Results 1 – 25 of 53) sorted by relevance

123

/spdk/include/spdk/
H A Drpc.h97 void spdk_rpc_register_method(const char *method, spdk_rpc_method_handler func,
106 void spdk_rpc_register_alias_deprecated(const char *method, const char *alias);
117 int spdk_rpc_is_method_allowed(const char *method, uint32_t state_mask);
127 int spdk_rpc_get_method_state_mask(const char *method, uint32_t *state_mask);
138 #define SPDK_RPC_REGISTER(method, func, state_mask) \ argument
141 spdk_rpc_register_method(method, func, state_mask); \
144 #define SPDK_RPC_REGISTER_ALIAS_DEPRECATED(method, alias) \ argument
147 spdk_rpc_register_alias_deprecated(#method, #alias); \
/spdk/lib/scsi/
H A Dscsi.c38 uint64_t fmt_lun, method; in spdk_scsi_lun_id_int_to_fmt()
42 method = 0x00U; in spdk_scsi_lun_id_int_to_fmt()
43 fmt_lun = (method & 0x03U) << 62; in spdk_scsi_lun_id_int_to_fmt()
47 method = 0x01U; in spdk_scsi_lun_id_int_to_fmt()
48 fmt_lun = (method & 0x03U) << 62; in spdk_scsi_lun_id_int_to_fmt()
61 uint64_t method; in spdk_scsi_lun_id_fmt_to_int()
64 method = (fmt_lun >> 62) & 0x03U; in spdk_scsi_lun_id_fmt_to_int()
66 if (method == 0x00U) { in spdk_scsi_lun_id_fmt_to_int()
68 } else if (method == 0x01U) { in spdk_scsi_lun_id_fmt_to_int()
36 uint64_t fmt_lun, method; spdk_scsi_lun_id_int_to_fmt() local
59 uint64_t method; spdk_scsi_lun_id_fmt_to_int() local
/spdk/lib/rpc/
H A Drpc.c76 _get_rpc_method(const struct spdk_json_val *method) in _get_rpc_method() argument
81 if (spdk_json_strequal(method, m->name)) { in _get_rpc_method()
93 _get_rpc_method_raw(const char *method) in _get_rpc_method_raw() argument
98 method_val.len = strlen(method); in _get_rpc_method_raw()
99 method_val.start = (char *)method; in _get_rpc_method_raw()
106 const struct spdk_json_val *method, in jsonrpc_handler() argument
111 assert(method != NULL); in jsonrpc_handler()
113 m = _get_rpc_method(method); in jsonrpc_handler()
262 spdk_rpc_register_method(const char *method, spdk_rpc_method_handler func, uint32_t state_mask) in spdk_rpc_register_method() argument
266 m = _get_rpc_method_raw(method); in spdk_rpc_register_method()
[all …]
/spdk/test/unit/lib/rpc/rpc.c/
H A Drpc_ut.c92 struct spdk_json_val method = {}; in test_jsonrpc_handler() local
108 method.type = SPDK_JSON_VAL_INVALID; in test_jsonrpc_handler()
109 jsonrpc_handler(request, &method, &params); in test_jsonrpc_handler()
113 method.type = SPDK_JSON_VAL_STRING; in test_jsonrpc_handler()
114 method.start = str; in test_jsonrpc_handler()
115 method.len = 4; in test_jsonrpc_handler()
125 jsonrpc_handler(request, &method, &params); in test_jsonrpc_handler()
132 jsonrpc_handler(request, &method, &params); in test_jsonrpc_handler()
139 jsonrpc_handler(request, &method, &params); in test_jsonrpc_handler()
148 const char method[] = "test"; in test_spdk_rpc_is_method_allowed() local
[all …]
/spdk/go/rpc/mocks/
H A DIClient.go27 func (_m *IClient) Call(method string, params interface{}) (*client.Response, error) {
28 ret := _m.Called(method, params)
33 return rf(method, params)
36 r0 = rf(method, params)
44 r1 = rf(method, params)
60 func (_e *IClient_Expecter) Call(method interface{}, params interface{}) *IClient_Call_Call {
61 return &IClient_Call_Call{Call: _e.mock.On("Call", method, params)}
64 func (_c *IClient_Call_Call) Run(run func(method string, params interface{})) *IClient_Call_Call {
/spdk/go/rpc/client/
H A Dclient.go28 Call(method string, params any) (*Response, error)
41 func (c *Client) Call(method string, params any) (*Response, error) {
44 request, reqErr := createRequest(method, id, params)
47 method, reqErr)
53 method, encErr)
60 method, decErr)
65 method)
70 method, response.Error)
99 func createRequest(method string, requestId uint64, params any) (*Request, error) {
103 method, paramErr)
[all …]
H A Dclient_test.go50 const method = "some method"
52 gotRequest, err := createRequest(method, requestId, tt.params)
55 Method: method,
/spdk/python/spdk/rpc/
H A Dclient.py120 def add_request(self, method, params): argument
124 'method': method,
143 def send(self, method, params=None): argument
144 id = self.add_request(method, params)
184 def call(self, method, params=None): argument
185 self._logger.debug("call('%s')" % method)
189 req_id = self.send(method, params)
194 if not self.sock and method == "spdk_kill_instance":
195 … self._logger.info("Connection terminated but ignoring since method is '%s'" % method)
201 params["method"] = method
[all …]
/spdk/scripts/
H A Dsma-client.py34 method = self._service.methods_by_name.get(method_name)
35 return (self._get_message_type(method.input_type),
36 self._get_message_type(method.output_type))
38 def call(self, method, params): argument
41 func = getattr(stub, method)
42 input, output = self._get_method_types(method)
H A Dgen_nvme.sh44 "method": "bdev_nvme_attach_controller",
81 "method": "bdev_nvme_attach_controller",
/spdk/test/json_config/
H A Dconfig_filter.py61 m_name = config['method']
89 parser.add_argument('-method', dest='method', default=None,
102 if args.method == "delete_global_parameters":
104 elif args.method == "delete_configs":
106 elif args.method == "check_empty":
108 elif args.method == "sort":
110 like output from bdev_get_bdevs RPC method"""
114 raise ValueError("Invalid method '{}'\n\n{}".format(args.method, parse
[all...]
H A Dclear_config.py148 method = vhost['method']
149 if method in ['vhost_scsi_controller_add_target']:
153 elif method in ['vhost_create_scsi_controller']:
160 method = vhost['method']
161 if method in ['vhost_create_blk_controller']:
200 method = globals().get(f'clear_{args.subsystem}_subsystem')
201 if method is not None:
204 method(args, config)
H A Djson_diff.sh25 $rootdir/test/json_config/config_filter.py -method "sort" < $1 > $tmp_file_1
26 $rootdir/test/json_config/config_filter.py -method "sort" < $2 > $tmp_file_2
/spdk/scripts/bash-completion/
H A Dspdk18 # mandatory argument given method depends on, like bdev_name, etc.
28 local aliases method names
31 # Each method name seems to be prefixed with 20h x 4. Then it can
42 for method in "${names[@]}"; do
43 rpc_methods["$method"]=1
49 local method methods
59 for method in "${methods[@]}"; do
60 rpc_methods["$method"]=1
66 local method=$2
69 mapfile -t rpc_help < <(_get_help "$rpc" "$method")
[all...]
/spdk/test/dd/
H A Dcommon.sh34 local method methods
39 # around them. The assoc array should be the name of the rpc method
42 # should store names of the method's parameters - proper quoting
54 method=${ref_name#*method_} method=${method%_*} params=()
71 "method": "$method"
85 "method": "bdev_wait_for_examine"
/spdk/test/ocf/integrity/
H A Dflush.sh24 "method": "bdev_malloc_create",
32 "method": "bdev_malloc_create",
40 "method": "bdev_ocf_create",
H A Dfio-modes.sh45 "method": "bdev_split_create",
61 "method": "bdev_ocf_create",
78 "method": "bdev_wait_for_examine"
H A Dmallocs.conf12 "method": "bdev_malloc_create",
34 "method": "bdev_ocf_create",
/spdk/go/rpc/
H A DREADME.md58 Sends RPC call with specified method and parameters.
62 - `method`: Name of the method to be invoked.
63 - `params`: Set of parameters to be used during invocation of the method.
73 Close method closes connection with underlying stream.
98 This method creates a new JSON-RPC 2.0 client. Both Unix and TCP sockets are supported.
H A DclientIntegration.go51 method := jsonMap["method"].(string)
58 resp, err := rpcClient.Call(method, params)
60 log.Printf("error on JSON-RPC call, method: %s, params: %s, err: %s", method, params, err.Error())
/spdk/lib/init/
H A Djson_config.c31 * "method": "<< METHOD NAME >>", <<== *method
303 char *method; member
308 {"method", offsetof(struct config_entry, method), spdk_json_decode_string},
354 rc = spdk_rpc_get_method_state_mask(cfg.method, &state_mask); in app_json_config_load_subsystem_config_entry()
371 SPDK_NOTICELOG("Skipping method '%s' because its subsystem '%s' " in app_json_config_load_subsystem_config_entry()
373 cfg.method, ctx->subsystem_name_str); in app_json_config_load_subsystem_config_entry()
378 SPDK_ERRLOG("Method '%s' was not found\n", cfg.method); in app_json_config_load_subsystem_config_entry()
385 SPDK_DEBUG_APP_CFG("Method '%s' not allowed -> skipping\n", cfg.method); in app_json_config_load_subsystem_config_entry()
[all...]
/spdk/doc/
H A Djsonrpc_proxy.md4 objects from users. It uses HTTP POST method to receive JSON objects including methods and paramete…
25 Error 400 - wrong JSON syntax or incorrect JSON method
31 Below is a sample python script acting as a client side. It sends `bdev_get_bdevs` method with opti…
39 payload = {'id':1, 'method': 'bdev_get_bdevs', 'params': {'name': 'Malloc0'}}
H A Dsma.md28 The following sections provide a high-level description of each method. For
33 This method creates a device. If a device with given parameters already exists,
54 This method deletes a device. Volumes that are still attached to a device being
63 This method creates a volume and attaches it to a device exposing it to the
73 structure determines the method to create it (e.g. direct NVMe-oF connection,
83 This method detaches a volume from a device making it unavailable to the host.
93 This method configures QoS on a per-device or per-volume level.
109 This method queries supported QoS settings.
180 `own_device()` method returning a boolean value indicating whether a given
/spdk/lib/jsonrpc/
H A Djsonrpc_client.c166 const char *method) in spdk_jsonrpc_begin_request() argument
182 if (method) { in spdk_jsonrpc_begin_request()
183 spdk_json_write_named_string(w, "method", method); in spdk_jsonrpc_begin_request()
H A Djsonrpc_server.c15 const struct spdk_json_val *method; member
79 {"method", offsetof(struct jsonrpc_request, method), capture_val},
101 if (!req.method || req.method->type != SPDK_JSON_VAL_STRING) { in parse_single_request()
126 jsonrpc_server_handle_request(request, req.method, params); in parse_single_request()

123