| /libmctp-latest/utils/ |
| D | mctp-demux-daemon.c | 62 struct ctx { struct
82 static void tx_message(struct ctx *ctx, mctp_eid_t eid, void *msg, size_t len) in tx_message() argument
86 rc = mctp_message_tx(ctx->mctp, eid, MCTP_MESSAGE_TO_SRC, 0, msg, len); in tx_message()
91 static void client_remove_inactive(struct ctx *ctx) in client_remove_inactive() argument
95 for (i = 0; i < ctx->n_clients; i++) { in client_remove_inactive()
96 struct client *client = &ctx->clients[i]; in client_remove_inactive()
101 ctx->n_clients--; in client_remove_inactive()
102 memmove(&ctx->clients[i], &ctx->clients[i + 1], in client_remove_inactive()
103 (ctx->n_clients - i) * sizeof(*ctx->clients)); in client_remove_inactive()
104 ctx->clients = realloc(ctx->clients, in client_remove_inactive()
[all …]
|
| D | mctp-astlpc-daemon.c | 20 struct ctx { struct
24 static void tx_message(struct ctx *ctx, mctp_eid_t eid, void *msg, size_t len) in tx_message() argument
32 mctp_message_tx(ctx->mctp, eid, 0, MCTP_MESSAGE_TO_SRC, msg, len); in tx_message()
38 struct ctx *ctx = data; in rx_message() local
48 tx_message(ctx, eid, msg, len); in rx_message()
56 struct ctx *ctx, _ctx; in main() local
67 ctx = &_ctx; in main()
68 ctx->mctp = mctp; in main()
70 mctp_set_rx_all(mctp, rx_message, ctx); in main()
93 tx_message(ctx, remote_eid, buf, rc); in main()
|
| /libmctp-latest/tests/ |
| D | test_astlpc.c | 201 static void network_init(struct astlpc_test *ctx) in network_init() argument
205 ctx->lpc_mem = calloc(1, 1 * 1024 * 1024); in network_init()
206 assert(ctx->lpc_mem); in network_init()
209 rc = endpoint_init(&ctx->bmc, 8, MCTP_BINDING_ASTLPC_MODE_BMC, MCTP_BTU, in network_init()
210 &ctx->kcs, ctx->lpc_mem); in network_init()
212 assert(ctx->kcs[MCTP_ASTLPC_KCS_REG_STATUS] & KCS_STATUS_BMC_READY); in network_init()
215 rc = endpoint_init(&ctx->host, 9, MCTP_BINDING_ASTLPC_MODE_HOST, in network_init()
216 MCTP_BTU, &ctx->kcs, ctx->lpc_mem); in network_init()
220 mctp_astlpc_poll(ctx->bmc.astlpc); in network_init()
221 assert(ctx->kcs[MCTP_ASTLPC_KCS_REG_STATUS] & in network_init()
[all …]
|
| D | test_seq.c | 31 struct test_ctx *ctx = data; in test_rx() local
33 ctx->rx_count++; in test_rx()
36 assert(len <= sizeof(ctx->rx_data)); in test_rx()
37 assert(ctx->rx_len + len <= sizeof(ctx->rx_data)); in test_rx()
39 memcpy(ctx->rx_data + ctx->rx_len, msg, len); in test_rx()
40 ctx->rx_len += len; in test_rx()
103 static void run_one_test(struct test_ctx *ctx, struct test *test) in run_one_test() argument
113 ctx->rx_count = 0; in run_one_test()
114 ctx->rx_len = 0; in run_one_test()
116 mctp_test_stack_init(&ctx->mctp, &ctx->binding, local_eid); in run_one_test()
[all …]
|
| D | test_eid.c | 27 struct test_ctx *ctx = data; in test_rx() local
32 ctx->rx_count++; in test_rx()
33 ctx->src_eid = eid; in test_rx()
46 struct test_ctx _ctx, *ctx = &_ctx; in main() local
55 mctp_test_stack_init(&ctx->mctp, &ctx->binding, local_eid); in main()
57 mctp_set_rx_all(ctx->mctp, test_rx, ctx); in main()
60 ctx->rx_count = 0; in main()
64 mctp_binding_test_rx_raw(ctx->binding, &pktbuf, sizeof(pktbuf)); in main()
66 assert(ctx->rx_count == 1); in main()
67 assert(ctx->src_eid == remote_eid); in main()
[all …]
|
| D | test_bridge.c | 83 struct test_ctx _ctx, *ctx = &_ctx; in main() local
84 ctx->mctp = mctp_init(); in main()
86 ctx->bindings[0] = mctp_binding_bridge_init("binding0"); in main()
87 ctx->bindings[1] = mctp_binding_bridge_init("binding1"); in main()
88 mctp_bridge_busses(ctx->mctp, &ctx->bindings[0]->binding, in main()
89 &ctx->bindings[1]->binding); in main()
91 mctp_binding_set_tx_enabled(&ctx->bindings[0]->binding, true); in main()
92 mctp_binding_set_tx_enabled(&ctx->bindings[1]->binding, true); in main()
94 mctp_binding_bridge_rx(ctx->bindings[0], 0xaa); in main()
95 assert(ctx->bindings[0]->tx_count == 0); in main()
[all …]
|
| D | test_cmds.c | 40 struct callback_data *ctx = data; in control_message_transport_callback() local
44 ctx->invoked++; in control_message_transport_callback()
45 assert(msg_hdr->command_code == ctx->command_code); in control_message_transport_callback()
80 struct callback_data ctx; in send_transport_control_message() local
94 memset(&ctx, 0, sizeof(ctx)); in send_transport_control_message()
95 setup_test_binding(&binding, endpoint, &ctx); in send_transport_control_message()
96 ctx.command_code = send_control_message_payload.ctrl_hdr.command_code; in send_transport_control_message()
101 assert(ctx.invoked == 1); in send_transport_control_message()
|
| D | test_serial.c | 34 struct mctp_binding_serial_pipe *ctx = data; in mctp_binding_serial_pipe_tx() local
37 rc = write(ctx->egress, buf, len); in mctp_binding_serial_pipe_tx()
|
| /libmctp-latest/ |
| D | core.c | 191 struct mctp_msg_ctx *ctx = &mctp->msg_ctxs[i]; in mctp_msg_ctx_lookup() local
192 if (ctx->src == src && ctx->dest == dest && ctx->tag == tag) in mctp_msg_ctx_lookup()
193 return ctx; in mctp_msg_ctx_lookup()
202 struct mctp_msg_ctx *ctx = NULL; in mctp_msg_ctx_create() local
208 ctx = tmp; in mctp_msg_ctx_create()
213 if (!ctx) in mctp_msg_ctx_create()
216 ctx->src = src; in mctp_msg_ctx_create()
217 ctx->dest = dest; in mctp_msg_ctx_create()
218 ctx->tag = tag; in mctp_msg_ctx_create()
219 ctx->buf_size = 0; in mctp_msg_ctx_create()
[all …]
|
| D | astlpc.c | 144 #define astlpc_prlog(ctx, lvl, fmt, ...) \ argument
146 bool __bmc = ((ctx)->mode == MCTP_BINDING_ASTLPC_MODE_BMC); \
151 #define astlpc_prerr(ctx, fmt, ...) \ argument
152 astlpc_prlog(ctx, MCTP_LOG_ERR, fmt, ##__VA_ARGS__)
153 #define astlpc_prwarn(ctx, fmt, ...) \ argument
154 astlpc_prlog(ctx, MCTP_LOG_WARNING, fmt, ##__VA_ARGS__)
155 #define astlpc_prnotice(ctx, fmt, ...) \ argument
156 astlpc_prlog(ctx, MCTP_LOG_NOTICE, fmt, ##__VA_ARGS__)
157 #define astlpc_prinfo(ctx, fmt, ...) \ argument
158 astlpc_prlog(ctx, MCTP_LOG_INFO, fmt, ##__VA_ARGS__)
[all …]
|
