Home
last modified time | relevance | path

Searched refs:msg (Results 1 – 25 of 31) sorted by relevance

12

/spdk/test/unit/lib/nvmf/auth.c/
H A Dauth_ut.c268 struct spdk_nvmf_auth_negotiate *msg; in test_auth_negotiate() local
273 msg = (void *)msgbuf; in test_auth_negotiate()
276 ut_prep_send_cmd(&req, &cmd, msgbuf, sizeof(*msg) + sizeof(*desc)); in test_auth_negotiate()
282 msg->auth_type = SPDK_NVMF_AUTH_TYPE_COMMON_MESSAGE; in test_auth_negotiate()
283 msg->auth_id = SPDK_NVMF_AUTH_ID_NEGOTIATE; in test_auth_negotiate()
284 msg->sc_c = SPDK_NVMF_AUTH_SCC_DISABLED; in test_auth_negotiate()
285 msg->napd = 1; in test_auth_negotiate()
286 desc = &msg->descriptors[0]; in test_auth_negotiate()
320 msg->sc_c = SPDK_NVMF_AUTH_SCC_TLS; in test_auth_negotiate()
327 msg in test_auth_negotiate()
529 struct spdk_nvmf_auth_negotiate *msg; test_auth_timeout() local
615 struct spdk_nvmf_auth_failure *msg; test_auth_failure1() local
694 struct spdk_nvmf_dhchap_challenge *msg; test_auth_challenge() local
847 struct spdk_nvmf_dhchap_reply *msg; test_auth_reply() local
1070 struct spdk_nvmf_dhchap_success1 *msg; test_auth_success1() local
[all...]
/spdk/lib/virtio/
H A Dvirtio_vhost_user.c87 vhost_user_read(int fd, struct vhost_user_msg *msg) in vhost_user_read() argument
93 ret = recv(fd, (void *)msg, sz_hdr, 0); in vhost_user_read()
95 SPDK_WARNLOG("Failed to recv msg hdr: %zd instead of %zu.\n", in vhost_user_read()
104 /* validate msg flags */ in vhost_user_read()
105 if (msg->flags != (valid_flags)) { in vhost_user_read()
106 SPDK_WARNLOG("Failed to recv msg: flags %"PRIx32" instead of %"PRIx32".\n", in vhost_user_read()
107 msg->flags, valid_flags); in vhost_user_read()
111 sz_payload = msg->size; in vhost_user_read()
114 SPDK_WARNLOG("Received oversized msg: payload size %zu > available space %zu\n", in vhost_user_read()
120 ret = recv(fd, (void *)((char *)msg in vhost_user_read()
231 prepare_vhost_memory_user(struct vhost_user_msg * msg,int fds[]) prepare_vhost_memory_user() argument
282 struct vhost_user_msg msg; vhost_user_sock() local
[all...]
/spdk/lib/nvmf/
H A Dauth.c29 #define AUTH_LOGDUMP(msg, buf, len) \
30 SPDK_LOGDUMP(nvmf_auth, msg, buf, len)
223 nvmf_auth_negotiate_exec(struct spdk_nvmf_request *req, struct spdk_nvmf_auth_negotiate *msg) in nvmf_auth_negotiate_exec()
253 auth->tid = msg->t_id; in nvmf_auth_negotiate_exec()
254 if (req->length < sizeof(*msg) || req->length != sizeof(*msg) + msg->napd * sizeof(*desc)) { in nvmf_auth_negotiate_exec()
260 if (msg->sc_c != SPDK_NVMF_AUTH_SCC_DISABLED) { in nvmf_auth_negotiate_exec()
266 for (i = 0; i < msg->napd; ++i) { in nvmf_auth_negotiate_exec()
267 if (msg in nvmf_auth_negotiate_exec()
28 AUTH_LOGDUMP(msg,buf,len) global() argument
216 nvmf_auth_negotiate_exec(struct spdk_nvmf_request * req,struct spdk_nvmf_auth_negotiate * msg) nvmf_auth_negotiate_exec() argument
335 nvmf_auth_reply_exec(struct spdk_nvmf_request * req,struct spdk_nvmf_dhchap_reply * msg) nvmf_auth_reply_exec() argument
470 nvmf_auth_success2_exec(struct spdk_nvmf_request * req,struct spdk_nvmf_dhchap_success2 * msg) nvmf_auth_success2_exec() argument
499 nvmf_auth_failure2_exec(struct spdk_nvmf_request * req,struct spdk_nvmf_auth_failure * msg) nvmf_auth_failure2_exec() argument
[all...]
H A Dtcp.c1598 struct spdk_nvmf_tcp_control_msg *msg; in nvmf_tcp_get_optimal_poll_group()
1619 msg = (struct spdk_nvmf_tcp_control_msg *)((char *)list->msg_buf + i * in nvmf_tcp_poll_group_destroy()
1621 STAILQ_INSERT_TAIL(&list->free_msgs, msg, link); in nvmf_tcp_poll_group_destroy()
2651 struct spdk_nvmf_tcp_control_msg *msg; in nvmf_tcp_req_parse_sgl()
2655 msg = STAILQ_FIRST(&list->free_msgs); in nvmf_tcp_req_parse_sgl()
2656 if (!msg) { in nvmf_tcp_req_parse_sgl()
2662 return msg; in nvmf_tcp_req_parse_sgl()
2668 struct spdk_nvmf_tcp_control_msg *msg = _msg; in nvmf_tcp_req_parse_sgl()
2673 STAILQ_INSERT_HEAD(&list->free_msgs, msg, link); in nvmf_tcp_req_parse_sgl()
2782 SPDK_DEBUGLOG(nvmf_tcp, "Getting a buffer from control msg lis in _nvmf_tcp_send_c2h_data()
1480 struct spdk_nvmf_tcp_control_msg *msg; nvmf_tcp_control_msg_list_create() local
2519 struct spdk_nvmf_tcp_control_msg *msg; nvmf_tcp_control_msg_get() local
2535 struct spdk_nvmf_tcp_control_msg *msg = _msg; nvmf_tcp_control_msg_put() local
[all...]
/spdk/python/spdk/sma/
H A Dqmp.py101 QMP sends greetings msg and enters capabilities negotiation mode.
158 msg = json.loads(data)
166 if 'error' in msg:
167 return msg, None
168 elif 'return' in msg:
170 return msg, None
171 response = msg
173 elif 'QMP' in msg:
176 return msg, None
177 elif self._check_event(event, msg)
[all...]
/spdk/lib/nvme/
H A Dnvme_auth.c42 #define AUTH_LOGDUMP(msg, buf, len) \ argument
43 SPDK_LOGDUMP(nvme_auth, msg, buf, len)
180 nvme_auth_print_cpl(struct spdk_nvme_qpair *qpair, const char *msg) in nvme_auth_print_cpl() argument
184 AUTH_ERRLOG(qpair, "%s failed: sc=%d, sct=%d (timed out: %s)\n", msg, status->cpl.status.sc, in nvme_auth_print_cpl()
717 struct spdk_nvmf_auth_failure *msg = qpair->poll_status->dma_data; in nvme_auth_send_failure2() local
721 msg->auth_type = SPDK_NVMF_AUTH_TYPE_COMMON_MESSAGE; in nvme_auth_send_failure2()
722 msg->auth_id = SPDK_NVMF_AUTH_ID_FAILURE2; in nvme_auth_send_failure2()
723 msg->t_id = auth->tid; in nvme_auth_send_failure2()
724 msg->rc = SPDK_NVMF_AUTH_FAILURE; in nvme_auth_send_failure2()
725 msg in nvme_auth_send_failure2()
734 struct spdk_nvmf_auth_failure *msg = qpair->poll_status->dma_data; nvme_auth_check_message() local
783 struct spdk_nvmf_auth_negotiate *msg = qpair->poll_status->dma_data; nvme_auth_send_negotiate() local
1008 struct spdk_nvmf_dhchap_success1 *msg = qpair->poll_status->dma_data; nvme_auth_check_success1() local
1059 struct spdk_nvmf_dhchap_success2 *msg = qpair->poll_status->dma_data; nvme_auth_send_success2() local
[all...]
/spdk/lib/ut_mock/
H A Dmock.c17 DEFINE_WRAPPER(recvmsg, ssize_t, (int sockfd, struct msghdr *msg, int flags), (sockfd, msg, flags))
19 DEFINE_WRAPPER(sendmsg, ssize_t, (int sockfd, const struct msghdr *msg, int flags), (sockfd, msg,
/spdk/include/spdk/
H A Dassert.h20 #define SPDK_STATIC_ASSERT(cond, msg) static_assert(cond, msg) argument
30 #define SPDK_STATIC_ASSERT(cond, msg)
H A Djsonrpc.h194 int error_code, const char *msg);
/spdk/test/unit/lib/log/log.c/
H A Dlog_ut.c80 char *msg; in log_deprecations() local
94 msg = spdk_vsprintf_alloc(format, args); in log_deprecations()
95 SPDK_CU_ASSERT_FATAL(msg != NULL); in log_deprecations()
96 CU_ASSERT(strncmp(g_ut_dep_expect_msg, msg, strlen(g_ut_dep_expect_msg)) == 0) in log_deprecations()
98 free(msg); in log_deprecations()
/spdk/lib/jsonrpc/
H A Djsonrpc_server_tcp.c238 const char *msg; in jsonrpc_server_handle_error() local
242 msg = "Parse error"; in jsonrpc_server_handle_error()
246 msg = "Invalid request"; in jsonrpc_server_handle_error()
250 msg = "Method not found"; in jsonrpc_server_handle_error()
254 msg = "Invalid parameters"; in jsonrpc_server_handle_error()
258 msg = "Internal error"; in jsonrpc_server_handle_error()
262 msg = "Error"; in jsonrpc_server_handle_error()
266 spdk_jsonrpc_send_error_response(request, error, msg); in jsonrpc_server_handle_error()
H A Djsonrpc_server.c396 int error_code, const char *msg) in spdk_jsonrpc_send_error_response() argument
402 spdk_json_write_named_string(w, "message", msg); in spdk_jsonrpc_send_error_response()
/spdk/test/dd/
H A Dposix.sh121 msg[0]=", using AIO"
122 msg[1]=", liburing in use"
123 msg[2]=", disabling liburing, forcing AIO"
/spdk/test/app/match/
H A Dmatch72 my $msg = shift;
74 warn "$Me: $msg\n" if $msg;
/spdk/lib/thread/
H A Dthread.c390 struct spdk_msg *msg; in _free_thread()
428 msg = SLIST_FIRST(&thread->msg_cache); in spdk_thread_lib_init()
429 while (msg != NULL) { in spdk_thread_lib_init()
434 spdk_mempool_put(g_spdk_msg_mempool, msg); in spdk_thread_lib_init()
436 msg = SLIST_FIRST(&thread->msg_cache); in spdk_thread_lib_init()
877 struct spdk_msg *msg = messages[i]; in poller_insert_timer()
879 assert(msg != NULL); in poller_insert_timer()
881 SPDK_DTRACE_PROBE2(msg_exec, msg->fn, msg->arg); in poller_insert_timer()
883 msg in poller_insert_timer()
367 struct spdk_msg *msg; _free_thread() local
852 struct spdk_msg *msg = messages[i]; msg_queue_run_batch() local
1362 struct spdk_msg *msg; spdk_thread_send_msg() local
[all...]
/spdk/module/sock/uring/
H A During.c63 struct msghdr msg;
832 struct msghdr msg = { in uring_sock_read()
837 return recvmsg(fd, &msg, MSG_DONTWAIT); in uring_sock_read()
1042 struct msghdr msg = { in sock_request_advance_offset()
1052 return sendmsg(sock->fd, &msg, MSG_DONTWAIT); in sock_request_advance_offset()
1163 cm = CMSG_FIRSTHDR(&sock->errqueue_task.msg); in _sock_check_zcopy()
1226 io_uring_prep_recvmsg(sqe, sock->fd, &task->msg, MSG_ERRQUEUE); in _sock_flush()
1262 task->msg.msg_iov = task->iovs; in _sock_prep_read()
1263 task->msg.msg_iovlen = task->iov_cnt; in _sock_prep_read()
1270 io_uring_prep_sendmsg(sqe, sock->fd, &sock->write_task.msg, flag in _sock_prep_read()
62 struct msghdr msg; global() member
816 struct msghdr msg = { sock_readv() local
1026 struct msghdr msg = { uring_sock_writev() local
1957 struct msghdr msg = {}; uring_sock_flush() local
[all...]
/spdk/python/spdk/rpc/
H A Dclient.py203 msg = "\n".join(["request:", "%s" % json.dumps(params, indent=2),
207 raise JSONRPCException(msg)
275 msg = "\n".join(["request:", "%s" % json.dumps(params, indent=2),
279 raise JSONRPCException(msg)
/spdk/lib/vfu_tgt/
H A Dtgt_endpoint.c183 tgt_log_cb(vfu_ctx_t *vfu_ctx, int level, char const *msg) in tgt_log_cb()
188 SPDK_DEBUGLOG(vfu, "%s: %s\n", spdk_vfu_get_endpoint_id(endpoint), msg); in tgt_log_cb()
190 SPDK_INFOLOG(vfu, "%s: %s\n", spdk_vfu_get_endpoint_id(endpoint), msg); in tgt_log_cb()
192 SPDK_NOTICELOG("%s: %s\n", spdk_vfu_get_endpoint_id(endpoint), msg); in tgt_log_cb()
194 SPDK_WARNLOG("%s: %s\n", spdk_vfu_get_endpoint_id(endpoint), msg); in tgt_log_cb()
196 SPDK_ERRLOG("%s: %s\n", spdk_vfu_get_endpoint_id(endpoint), msg); in tgt_log_cb()
181 tgt_log_cb(vfu_ctx_t * vfu_ctx,int level,char const * msg) tgt_log_cb() argument
/spdk/scripts/
H A Dbackport.sh66 git show -s --format="%B" "$hash" > $SPDK_DIR/msg
68 sed -i '/Reviewed-on/ s/$/ (master)/' $SPDK_DIR/msg
71 sed -i '/^Reviewed-by/d' "$SPDK_DIR/msg"
72 sed -i '/^Community-CI/d' "$SPDK_DIR/msg"
73 sed -i '/^Tested-by/d' "$SPDK_DIR/msg"
74 echo "(cherry picked from commit $hash)" >> "$SPDK_DIR/msg"
75 grep "^Change-Id" "$SPDK_DIR/msg" > "$SPDK_DIR/id"
76 sed -i '/^Change-Id/d' "$SPDK_DIR/msg"
77 cat "$SPDK_DIR/id" >> "$SPDK_DIR/msg"
78 git commit -s --amend -m "$(cat $SPDK_DIR/msg)"
[all...]
H A Dposix.txt55 <sys/msg.h>
/spdk/lib/vhost/
H A Drte_vhost_user.c1445 struct vhost_user_msg *msg = _msg; local
1457 switch (msg->request) {
1484 msg->payload.cfg.region, msg->payload.cfg.size);
1486 msg->size = 0;
1499 msg->payload.cfg.region, msg->payload.cfg.offset,
1500 msg->payload.cfg.size, msg->payload.cfg.flags);
1516 struct vhost_user_msg *msg local
[all...]
/spdk/test/iscsi_tgt/rpc_config/
H A Drpc_config.py52 def __init__(self, retval, msg):
53 super(RpcException, self).__init__(msg)
55 self.message = msg
72 def verify(expr, retcode, msg):
74 raise RpcException(retcode, msg) argument
54 __init__(self, retval, msg) global() argument
/spdk/lib/event/
H A Dapp.c143 {"msg-mempool-size", required_argument, NULL, MSG_MEMPOOL_SIZE_OPT_IDX},
1123 printf(" --msg-mempool-size <size> global message memory pool size in count (default: %d)\n", in usage()
1576 char msg[128]; in rpc_framework_disable_cpumask_locks()
1589 snprintf(msg, sizeof(msg), "Failed to unclaim CPU core: %" PRIu32, failed_core); in rpc_framework_enable_cpumask_locks()
1590 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, msg); in rpc_framework_enable_cpumask_locks()
1603 char msg[128]; in rpc_framework_enable_cpumask_locks()
1616 snprintf(msg, sizeof(msg), "Failed to claim CPU core: %" PRIu32, failed_core);
1617 spdk_jsonrpc_send_error_response(request, SPDK_JSONRPC_ERROR_INTERNAL_ERROR, msg);
1561 char msg[128]; rpc_framework_disable_cpumask_locks() local
1588 char msg[128]; rpc_framework_enable_cpumask_locks() local
[all...]
/spdk/examples/blob/hello_world/
H A Dhello_blob.c63 unload_bs(struct hello_context_t *hello_context, char *msg, int bserrno) in unload_bs() argument
66 SPDK_ERRLOG("%s (err %d)\n", msg, bserrno); in unload_bs()
/spdk/test/unit/lib/rpc/rpc.c/
H A Drpc_ut.c69 int error_code, const char *msg) in spdk_jsonrpc_send_error_response() argument

12