Home
last modified time | relevance | path

Searched refs:response (Results 1 – 25 of 48) sorted by relevance

12

/spdk/test/iscsi_tgt/sock/
H A Dsock.sh70 response=$(echo "$message" | $HELLO_SOCK_APP -H $INITIATOR_IP -P $ISCSI_PORT -N "posix")
72 if ! echo "$response" | grep -q "$message"; then
78 response=$(echo "$message" | $HELLO_SOCK_APP -H $INITIATOR_IP -P $ISCSI_PORT -N "posix" -z)
80 if ! echo "$response" | grep -q "$message"; then
86 response=$(echo "$message" | $HELLO_SOCK_APP -H $INITIATOR_IP -P $ISCSI_PORT -N "posix" -Z)
88 if ! echo "$response" | grep -q "$message"; then
112 response=$(echo "$message" | $HELLO_SOCK_APP -H $TARGET_IP -P $ISCSI_PORT $PSK -m 0x2)
113 if ! echo "$response" | grep -q "$message"; then
119 response=$(echo "$message" | $HELLO_SOCK_APP -H $TARGET_IP -P $ISCSI_PORT $PSK -T 13 -m 0x2)
120 if ! echo "$response" | grep -q "$message"; then
[all …]
/spdk/python/spdk/sma/
H A Dsma.py67 response = pb2.CreateDeviceResponse()
77 response = manager.create_device(request)
81 self._volume_mgr.set_device(volume_id, response.handle)
90 return response
94 response = pb2.DeleteDeviceResponse()
113 return response
117 response = pb2.AttachVolumeResponse()
137 return response
141 response = pb2.DetachVolumeResponse()
151 return response
[all …]
H A Dqmp.py54 Exception Class for handling request response errors
150 response = None
165 if response is None:
171 response = msg
178 return response, msg
198 :return command exec response or optionally execute result event
199 :raise QMPRequestError: on response from QMP server being of error type
209 response, result = self._receive(event)
211 if response.get('id') != cmd_id:
213 elif 'error' in response
[all...]
/spdk/python/spdk/spdkcli/
H A Dui_root.py125 response = rpc.bdev.bdev_split_create(self.client, **kwargs)
126 return self.print_array(response)
134 response = rpc.bdev.bdev_malloc_create(self.client, **kwargs)
135 return response
143 response = rpc.bdev.bdev_iscsi_create(self.client, **kwargs)
144 return response
152 response = rpc.bdev.bdev_aio_create(self.client, **kwargs)
153 return response
161 response = rpc.lvol.bdev_lvol_create(self.client, **kwargs)
162 return response
[all...]
/spdk/lib/nvmf/
H A Dctrlr_bdev.c74 struct spdk_nvme_cpl *response = &req->rsp->nvme_cpl; in nvmf_bdev_ctrlr_complete_cmd() local
97 response->cdw0 = cdw0; in nvmf_bdev_ctrlr_complete_cmd()
98 response->status.sc = sc; in nvmf_bdev_ctrlr_complete_cmd()
99 response->status.sct = sct; in nvmf_bdev_ctrlr_complete_cmd()
614 struct spdk_nvme_cpl *response = &req->rsp->nvme_cpl; in nvmf_bdev_ctrlr_unmap_resubmit()
622 response->status.sct = SPDK_NVME_SCT_GENERIC; in nvmf_bdev_ctrlr_unmap()
623 response->status.sc = SPDK_NVME_SC_SUCCESS; in nvmf_bdev_ctrlr_unmap() local
634 response->status.sc = SPDK_NVME_SC_INTERNAL_DEVICE_ERROR; in nvmf_bdev_ctrlr_unmap()
655 struct spdk_nvme_cpl *response = &req->rsp->nvme_cpl; in nvmf_bdev_ctrlr_unmap()
661 if (response in nvmf_bdev_ctrlr_unmap()
539 struct spdk_nvme_cpl *response = &req->rsp->nvme_cpl; nvmf_bdev_ctrlr_flush_cmd() local
580 struct spdk_nvme_cpl *response = &req->rsp->nvme_cpl; nvmf_bdev_ctrlr_unmap_cpl() local
705 struct spdk_nvme_cpl *response = &req->rsp->nvme_cpl; nvmf_bdev_ctrlr_dsm_cmd() local
721 struct spdk_nvme_cpl *response = &req->rsp->nvme_cpl; nvmf_bdev_ctrlr_copy_cmd() local
922 struct spdk_nvme_cpl *response = &req->rsp->nvme_cpl; nvmf_bdev_ctrlr_zcopy_start_complete() local
1005 struct spdk_nvme_cpl *response = &req->rsp->nvme_cpl; nvmf_bdev_ctrlr_zcopy_end_complete() local
[all...]
H A Dctrlr.c266 SPDK_DEBUGLOG(nvmf, "connect capsule response: cntlid = 0x%04x\n", ctrlr->cntlid); in nvmf_ctrlr_send_connect_rsp()
1482 struct spdk_nvmf_fabric_prop_get_rsp *response = &req->rsp->prop_get_rsp; in nvmf_property_get()
1486 response->status.sc = 0; in nvmf_property_get()
1487 response->value.u64 = 0; in nvmf_property_get()
1501 response->status.sct = SPDK_NVME_SCT_COMMAND_SPECIFIC; in nvmf_property_get()
1502 response->status.sc = SPDK_NVMF_FABRIC_SC_INVALID_PARAM; in nvmf_property_get()
1508 response->status.sct = SPDK_NVME_SCT_COMMAND_SPECIFIC; in nvmf_property_get()
1509 response->status.sc = SPDK_NVMF_FABRIC_SC_INVALID_PARAM; in nvmf_property_get()
1515 response->value.u64 = prop->get_cb(ctrlr); in nvmf_property_get()
1524 response in nvmf_property_get()
1478 struct spdk_nvmf_fabric_prop_get_rsp *response = &req->rsp->prop_get_rsp; nvmf_property_get() local
1537 struct spdk_nvme_cpl *response = &req->rsp->nvme_cpl; nvmf_property_set() local
1780 struct spdk_nvme_cpl *response = &req->rsp->nvme_cpl; nvmf_ctrlr_set_features_host_identifier() local
1792 struct spdk_nvme_cpl *response = &req->rsp->nvme_cpl; nvmf_ctrlr_get_features_host_identifier() local
1878 struct spdk_nvme_cpl *response = &req->rsp->nvme_cpl; nvmf_ctrlr_get_features_reservation_persistence() local
1904 struct spdk_nvme_cpl *response = &req->rsp->nvme_cpl; nvmf_ctrlr_set_features_reservation_persistence() local
1939 struct spdk_nvme_cpl *response = &req->rsp->nvme_cpl; nvmf_ctrlr_get_features_host_behavior_support() local
1964 struct spdk_nvme_cpl *response = &req->rsp->nvme_cpl; nvmf_ctrlr_set_features_host_behavior_support() local
2620 struct spdk_nvme_cpl *response = &req->rsp->nvme_cpl; nvmf_ctrlr_get_log_page() local
3488 struct spdk_nvme_cpl *response = &req->rsp->nvme_cpl; nvmf_ctrlr_get_features() local
3576 struct spdk_nvme_cpl *response = &req->rsp->nvme_cpl; nvmf_ctrlr_set_features() local
3701 struct spdk_nvme_cpl *response = &req->rsp->nvme_cpl; nvmf_ctrlr_process_admin_cmd() local
4357 struct spdk_nvme_cpl *response = &req->rsp->nvme_cpl; nvmf_ctrlr_process_io_cmd() local
4869 struct spdk_nvme_cpl *response = spdk_nvmf_request_get_response(req); nvmf_passthru_admin_cmd_for_bdev_nsid() local
4899 struct spdk_nvme_cpl *response = spdk_nvmf_request_get_response(req); nvmf_passthru_admin_cmd_for_ctrlr() local
[all...]
H A Dauth.c66 struct spdk_nvme_cpl *response = &req->rsp->nvme_cpl; in nvmf_auth_request_complete()
68 response->status.sct = sct; in nvmf_auth_request_complete()
69 response->status.sc = sc; in nvmf_auth_request_complete()
70 response->status.dnr = dnr; in nvmf_auth_request_complete()
347 uint8_t response[NVMF_AUTH_DIGEST_MAX_SIZE]; in nvmf_auth_reply_exec()
419 assert(hl <= sizeof(response) && hl <= sizeof(auth->cval)); in nvmf_auth_reply_exec()
424 auth->cval, response); in nvmf_auth_reply_exec()
426 AUTH_ERRLOG(qpair, "failed to calculate challenge response: %s\n", in nvmf_auth_reply_exec()
432 if (memcmp(msg->rval, response, hl) != 0) { in nvmf_auth_reply_exec()
433 AUTH_ERRLOG(qpair, "challenge response mismatc in nvmf_auth_reply_exec()
65 struct spdk_nvme_cpl *response = &req->rsp->nvme_cpl; nvmf_auth_request_complete() local
340 uint8_t response[NVMF_AUTH_DIGEST_MAX_SIZE]; nvmf_auth_reply_exec() local
[all...]
/spdk/python/spdk/rpc/
H A Dclient.py161 response = self.decode_one_response()
162 while not response:
172 response = self.decode_one_response()
178 if not response:
181 self._logger.info("response:\n%s\n", json.dumps(response, indent=2))
182 return response
191 response = self.recv()
200 if 'error' in response:
206 json.dumps(response['error'], indent=2)])
209 return response['result']
[all …]
/spdk/scripts/
H A Drpc_http_proxy.py49 response = None
59 response = json.loads(buf)
66 if not response and len(buf) > 0:
119 response = rpc_call(data_string)
120 if response is not None:
122 self.wfile.write(bytes(response.encode(encoding='ascii')))
H A Dsma-client.py43 response = func(request=json_format.ParseDict(params, input()))
44 return json_format.MessageToDict(response,
/spdk/lib/jsonrpc/
H A Djsonrpc_server.c233 request->response = spdk_json_write_begin(jsonrpc_server_write_cb, request, 0); in jsonrpc_parse_request()
234 if (request->response == NULL) { in jsonrpc_parse_request()
285 struct spdk_json_write_ctx *w = request->response; in begin_response()
304 spdk_json_write_end(request->response); in skip_response()
305 request->response = NULL; in skip_response()
312 spdk_json_write_object_end(request->response); in end_response()
313 spdk_json_write_end(request->response); in end_response()
314 request->response = NULL; in end_response()
331 assert(request->response == NULL); in jsonrpc_free_request()
373 assert(w == request->response); in spdk_jsonrpc_end_result()
H A Djsonrpc_internal.h43 struct spdk_json_write_ctx *response; member
/spdk/go/rpc/client/
H A Dclient.go56 response := &Response{}
57 decErr := c.codec.decoder.Decode(response)
63 if request.ID != uint64(response.ID) {
68 if response.Error != nil {
70 method, response.Error)
73 return response, nil
/spdk/test/unit/lib/scsi/lun.c/
H A Dlun_ut.c87 task->response = SPDK_SCSI_TASK_MGMT_RESP_SUCCESS; in bdev_scsi_reset()
164 CU_ASSERT(mgmt_task.response == SPDK_SCSI_TASK_MGMT_RESP_REJECT_FUNC_NOT_SUPPORTED); in lun_task_mgmt_execute_abort_task_not_supported()
207 CU_ASSERT(mgmt_task.response == SPDK_SCSI_TASK_MGMT_RESP_REJECT_FUNC_NOT_SUPPORTED); in lun_task_mgmt_execute_abort_task_all_not_supported()
237 CU_ASSERT_EQUAL(mgmt_task.response, SPDK_SCSI_TASK_MGMT_RESP_SUCCESS); in lun_task_mgmt_execute_lun_reset()
262 CU_ASSERT_EQUAL(mgmt_task.response, SPDK_SCSI_TASK_MGMT_RESP_SUCCESS); in lun_task_mgmt_execute_target_reset()
286 CU_ASSERT_EQUAL(mgmt_task.response, SPDK_SCSI_TASK_MGMT_RESP_REJECT_FUNC_NOT_SUPPORTED); in lun_task_mgmt_execute_invalid_case()
557 CU_ASSERT_EQUAL(mgmt_task.response, SPDK_SCSI_TASK_MGMT_RESP_SUCCESS); in lun_reset_task_wait_scsi_task_complete()
601 CU_ASSERT_EQUAL(mgmt_task.response, SPDK_SCSI_TASK_MGMT_RESP_SUCCESS); in lun_reset_task_suspend_scsi_task()
712 CU_ASSERT(task1.response == SPDK_SCSI_TASK_MGMT_RESP_SUCCESS); in abort_pending_mgmt_tasks_when_lun_is_removed()
713 CU_ASSERT(task2.response == SPDK_SCSI_TASK_MGMT_RESP_SUCCESS); in abort_pending_mgmt_tasks_when_lun_is_removed()
[all …]
/spdk/include/linux/
H A Dvirtio_scsi.h71 __u8 response; /* Response values */ member
84 __u8 response; member
96 __u8 response; member
/spdk/proto/
H A Dsma.proto87 // Create device response
100 // Delete device response
111 // Attach volume response
122 // Detach volume response
158 // SetQos response
167 // Get QoS capabilities response
/spdk/lib/nvme/
H A Dnvme_fabric.c133 struct spdk_nvmf_fabric_prop_get_rsp *response; in nvme_fabric_prop_get_cmd_sync() local
156 response = (struct spdk_nvmf_fabric_prop_get_rsp *)&status->cpl; in nvme_fabric_prop_get_cmd_sync()
159 *value = response->value.u32.low; in nvme_fabric_prop_get_cmd_sync()
161 *value = response->value.u64; in nvme_fabric_prop_get_cmd_sync()
173 struct spdk_nvmf_fabric_prop_get_rsp *response; in nvme_fabric_prop_get_cmd_done() local
177 response = (struct spdk_nvmf_fabric_prop_get_rsp *)cpl; in nvme_fabric_prop_get_cmd_done()
181 value = response->value.u32.low; in nvme_fabric_prop_get_cmd_done()
184 value = response->value.u64; in nvme_fabric_prop_get_cmd_done()
/spdk/lib/iscsi/
H A Discsi.c782 const char *response; in iscsi_auth_params() local
867 response = iscsi_param_get_val(params, "CHAP_R"); in iscsi_auth_params()
868 if (response == NULL) { in iscsi_auth_params()
869 SPDK_ERRLOG("no response\n"); in iscsi_auth_params()
872 if (response[0] == '0' && in iscsi_auth_params()
873 (response[1] == 'x' || response[1] == 'X')) { in iscsi_auth_params()
874 rc = hex2bin(resmd5, SPDK_MD5DIGEST_LEN, response); in iscsi_auth_params()
876 SPDK_ERRLOG("response format error\n"); in iscsi_auth_params()
879 } else if (response[ in iscsi_auth_params()
2516 int response; iscsi_pdu_hdr_op_logout() local
[all...]
/spdk/include/spdk/
H A Discsi_spec.h200 uint8_t response; member
308 uint8_t response; member
399 uint8_t response; member
/spdk/lib/vhost/
H A Dvhost_scsi.c372 task->resp->response = VIRTIO_SCSI_S_OK; in task_submit()
379 task->tmf_resp->response = VIRTIO_SCSI_S_OK; in mgmt_task_submit()
394 task->resp ? task->resp->response : -1); in invalid_request()
461 SPDK_ERRLOG("%s: no response descriptor for controlq request %d.\n", in process_ctrl_request()
471 SPDK_ERRLOG("%s: TMF response descriptor at index %d points to invalid guest memory region\n", in process_ctrl_request()
478 task->tmf_resp->response = VIRTIO_SCSI_S_BAD_TARGET; in process_ctrl_request()
490 task->tmf_resp->response = VIRTIO_SCSI_S_ABORTED; in process_ctrl_request()
501 SPDK_WARNLOG("%s: asynchronous response descriptor points to invalid guest memory region\n", in process_ctrl_request()
506 an_resp->response = VIRTIO_SCSI_S_ABORTED; in process_ctrl_request()
556 /* Each request must have at least 2 descriptors (e.g. request and response) */ in task_data_setup()
[all...]
/spdk/module/vfu_device/
H A Dvfu_virtio_scsi.c380 scsi_req->cmd_resp->response = VIRTIO_SCSI_S_OK; in virtio_scsi_cmd_data_setup()
423 scsi_req->tmf_resp->response = VIRTIO_SCSI_S_BAD_TARGET; in virtio_scsi_tmf_cmd_req()
427 scsi_req->tmf_resp->response = VIRTIO_SCSI_S_OK; in virtio_scsi_tmf_cmd_req()
433 scsi_req->tmf_resp->response = VIRTIO_SCSI_S_FUNCTION_REJECTED; in virtio_scsi_tmf_cmd_req()
476 scsi_req->cmd_resp->response = VIRTIO_SCSI_S_BAD_TARGET; in virtio_scsi_cmd_req()
/spdk/test/app/fuzz/iscsi_fuzz/
H A DREADME.md13 Then iSCSI initiator will receive all kinds of response opcodes from iSCSI Target.
/spdk/doc/
H A Dvhost_processing.md140 struct virtio_scsi_cmd_resp *resp; // response data (write-only)
148 (request + response).
178 and response data to be contained within a single memory region. I/O buffers
182 completion. Once I/O completes, SPDK vhost fills the response buffer with
H A Dvirtio.md15 interrupts to check for an I/O response. If used inside a VM, it bypasses interrupt
/spdk/module/bdev/virtio/
H A Dbdev_virtio_scsi.c114 /** Start a full rescan after receiving next scan I/O response. */
153 /** Virtio response poller. */
841 if (io_ctx->tmf_resp.response == VIRTIO_SCSI_S_OK) { in bdev_virtio_tmf_cpl_cb()
1185 /* check response, get VPD if spun up otherwise send SSU */ in process_scan_test_unit_ready()
1188 } else if (resp->response == VIRTIO_SCSI_S_OK && in process_scan_test_unit_ready()
1388 if (resp->response != VIRTIO_SCSI_S_OK || resp->status != SPDK_SCSI_STATUS_GOOD) { in process_read_cap_10()
1419 if (resp->response != VIRTIO_SCSI_S_OK || resp->status != SPDK_SCSI_STATUS_GOOD) { in process_read_cap_16()
1452 if (resp->response == VIRTIO_SCSI_S_BAD_TARGET || in process_scan_resp()
1453 resp->response == VIRTIO_SCSI_S_INCORRECT_LUN) { in process_scan_resp()
1458 if (resp->response ! in process_scan_resp()
[all...]

12