Lines Matching defs:msg
390 struct spdk_msg *msg;
428 msg = SLIST_FIRST(&thread->msg_cache);
429 while (msg != NULL) {
434 spdk_mempool_put(g_spdk_msg_mempool, msg);
436 msg = SLIST_FIRST(&thread->msg_cache);
877 struct spdk_msg *msg = messages[i];
879 assert(msg != NULL);
881 SPDK_DTRACE_PROBE2(msg_exec, msg->fn, msg->arg);
883 msg->fn(msg->arg);
890 SLIST_INSERT_HEAD(&thread->msg_cache, msg, link);
893 spdk_mempool_put(g_spdk_msg_mempool, msg);
1225 * there is msg received without notification.
1388 * after sending thread msg, it is necessary to check whether target thread runs in
1406 struct spdk_msg *msg;
1418 msg = NULL;
1421 msg = SLIST_FIRST(&local_thread->msg_cache);
1422 assert(msg != NULL);
1428 if (msg == NULL) {
1429 msg = spdk_mempool_get(g_spdk_msg_mempool);
1430 if (!msg) {
1431 SPDK_ERRLOG("msg could not be allocated\n");
1436 msg->fn = fn;
1437 msg->arg = ctx;
1439 rc = spdk_ring_enqueue(thread->messages, (void **)&msg, 1, NULL);
1441 SPDK_ERRLOG("msg could not be enqueued\n");
1442 spdk_mempool_put(g_spdk_msg_mempool, msg);
2786 /* The thread transitioned to poll mode in a msg during the above processing.
2791 SPDK_ERRLOG("failed to acknowledge msg queue: %s.\n", spdk_strerror(errno));