| /libmctp-latest/ |
| D | serial.c | 20 static const size_t write(int fd, void *buf, size_t len) in write() argument
38 #define mctp_write_all(fn, dst, src, len) \ argument
42 while (len) { \
43 wrote = fn(dst, __src, len); \
47 len -= wrote; \
49 len ? wrote : 0; \
104 uint8_t len; member
145 size_t len; in mctp_binding_serial_tx() local
150 len = mctp_pktbuf_size(pkt); in mctp_binding_serial_tx()
155 hdr->len = len; in mctp_binding_serial_tx()
[all …]
|
| D | core.c | 96 struct mctp_pktbuf *mctp_pktbuf_alloc(struct mctp_binding *binding, size_t len) in mctp_pktbuf_alloc() argument
102 if (len > size) { in mctp_pktbuf_alloc()
114 buf->end = buf->start + len; in mctp_pktbuf_alloc()
158 int mctp_pktbuf_push(struct mctp_pktbuf *pkt, void *data, size_t len) in mctp_pktbuf_push() argument
162 if (pkt->end + len > pkt->size) in mctp_pktbuf_push()
167 pkt->end += len; in mctp_pktbuf_push()
168 memcpy(p, data, len); in mctp_pktbuf_push()
173 void *mctp_pktbuf_pop(struct mctp_pktbuf *pkt, size_t len) in mctp_pktbuf_pop() argument
175 if (len > mctp_pktbuf_size(pkt)) in mctp_pktbuf_pop()
178 pkt->end -= len; in mctp_pktbuf_pop()
[all …]
|
| D | crc32.c | 9 uint32_t crc32(const void *buf, size_t len) in crc32() argument
14 for (; len; len--) { in crc32()
|
| D | crc-16-ccitt.c | 46 uint16_t crc_16_ccitt(uint16_t fcs, const uint8_t *cp, uint32_t len) in crc_16_ccitt() argument
48 while (len--) in crc_16_ccitt()
|
| D | libmctp.h | 61 struct mctp_pktbuf *mctp_pktbuf_alloc(struct mctp_binding *hw, size_t len);
68 int mctp_pktbuf_push(struct mctp_pktbuf *pkt, void *data, size_t len);
69 void *mctp_pktbuf_pop(struct mctp_pktbuf *pkt, size_t len);
105 void *data, void *msg, size_t len);
|
| D | libmctp-serial.h | 29 typedef int (*mctp_serial_tx_fn)(void *data, void *buf, size_t len)
34 size_t len);
|
| D | libmctp-astlpc.h | 27 int (*lpc_read)(void *data, void *buf, long offset, size_t len);
28 int (*lpc_write)(void *data, const void *buf, long offset, size_t len);
|
| D | astlpc.c | 310 size_t len) in mctp_astlpc_lpc_write() argument
312 astlpc_prdebug(astlpc, "%s: %zu bytes to 0x%lx", __func__, len, offset); in mctp_astlpc_lpc_write()
320 return astlpc->ops.lpc_write(data, buf, offset, len); in mctp_astlpc_lpc_write()
325 memcpy(&((char *)astlpc->lpc_map)[offset], buf, len); in mctp_astlpc_lpc_write()
331 void *buf, long offset, size_t len) in mctp_astlpc_lpc_read() argument
333 astlpc_prdebug(astlpc, "%s: %zu bytes from 0x%lx", __func__, len, in mctp_astlpc_lpc_read()
342 return astlpc->ops.lpc_read(data, buf, offset, len); in mctp_astlpc_lpc_read()
347 memcpy(buf, &((char *)astlpc->lpc_map)[offset], len); in mctp_astlpc_lpc_read()
834 uint32_t len, len_be; in mctp_binding_astlpc_tx() local
839 len = mctp_pktbuf_size(pkt); in mctp_binding_astlpc_tx()
[all …]
|
| D | crc32.h | 7 uint32_t crc32(const void *buf, size_t len);
|
| D | crc-16-ccitt.h | 10 uint16_t crc_16_ccitt(uint16_t fcs, const uint8_t *cp, uint32_t len);
|
| D | README.md | 40 - `mctp_message_tx(mctp, message, len)`: Transmit a MCTP message
|
| /libmctp-latest/utils/ |
| D | mctp-astlpc-daemon.c | 24 static void tx_message(struct ctx *ctx, mctp_eid_t eid, void *msg, size_t len) in tx_message() argument
28 type = len > 0 ? *(uint8_t *)(msg) : 0x00; in tx_message()
31 eid, len, type); in tx_message()
32 mctp_message_tx(ctx->mctp, eid, 0, MCTP_MESSAGE_TO_SRC, msg, len); in tx_message()
36 void *msg, size_t len) in rx_message() argument
41 type = len > 0 ? *(uint8_t *)(msg) : 0x00; in rx_message()
44 eid, len, type); in rx_message()
48 tx_message(ctx, eid, msg, len); in rx_message()
|
| D | mctp-in.c | 17 size_t len) in rx_message() argument
21 rc = write(STDOUT_FILENO, msg, len); in rx_message()
24 else if ((size_t)rc < len) in rx_message()
25 warnx("Short write of length %zd, requested %zd", rc, len); in rx_message()
|
| D | mctp-capture.c | 88 hdr.len = size; in capture_binding()
94 void capture_socket(pcap_dumper_t *dumper, const void *buf, size_t len, in capture_socket() argument
106 size = sizeof(struct sll2_header) + sizeof(struct mctp_hdr) + len; in capture_socket()
138 buf + 1, len - 1); in capture_socket()
141 hdr.len = size; in capture_socket()
|
| D | mctp-pipe.c | 17 size_t len) in rx_message() argument
21 rc = write(STDOUT_FILENO, msg, len); in rx_message()
24 else if ((size_t)rc < len) in rx_message()
25 warnx("Short write of length %zd, requested %zd", rc, len); in rx_message()
|
| D | mctp-demux-daemon.c | 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()
111 size_t len) in rx_message() argument
120 if (len < 2) in rx_message()
127 len, type); in rx_message()
135 iov[1].iov_len = len; in rx_message()
147 if (rc != (ssize_t)(len + 1)) { in rx_message()
349 ssize_t len; in client_process_recv() local
370 len = recv(client->sock, NULL, 0, MSG_PEEK | MSG_TRUNC); in client_process_recv()
371 if (len < 0) { in client_process_recv()
[all …]
|
| D | mctp-capture.h | 34 void capture_socket(pcap_dumper_t *dumper, const void *buf, size_t len,
62 const void *buf __unused, size_t len __unused, in capture_socket()
|
| /libmctp-latest/tests/ |
| D | test_serial.c | 32 static int mctp_binding_serial_pipe_tx(void *data, void *buf, size_t len) in mctp_binding_serial_pipe_tx() argument
37 rc = write(ctx->egress, buf, len); in mctp_binding_serial_pipe_tx()
39 assert((size_t)rc == len); in mctp_binding_serial_pipe_tx()
51 void *data __unused, void *msg, size_t len) in rx_message() argument
57 mctp_prdebug("MCTP message received: len %zd, type %d, tag %d", len, in rx_message()
60 assert(sizeof(mctp_msg_src) == len); in rx_message()
61 assert(!memcmp(mctp_msg_src, msg, len)); in rx_message()
|
| D | test_seq.c | 29 uint8_t msg_tag __unused, void *data, void *msg, size_t len) in test_rx() argument
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()
|
| D | test_cmds.c | 38 size_t len __unused) in control_message_transport_callback()
48 static void rcv_ctrl_msg(struct mctp_binding *b, const void *buf, size_t len) in rcv_ctrl_msg() argument
50 struct mctp_pktbuf *pkt = mctp_pktbuf_alloc(b, len); in rcv_ctrl_msg()
51 memcpy(mctp_pktbuf_hdr(pkt), buf, len); in rcv_ctrl_msg()
|
| D | test-utils.c | 47 size_t len) in mctp_binding_test_rx_raw() argument
51 pkt = mctp_pktbuf_alloc(&test->binding, len); in mctp_binding_test_rx_raw()
53 memcpy(mctp_pktbuf_hdr(pkt), buf, len); in mctp_binding_test_rx_raw()
|
| D | test_eid.c | 25 size_t len __unused) in test_rx()
30 (void)len; in test_rx()
|
| D | test-utils.h | 19 size_t len);
|
| D | test_astlpc.c | 117 int mctp_astlpc_mmio_lpc_read(void *data, void *buf, long offset, size_t len) in mctp_astlpc_mmio_lpc_read() argument
121 mctp_prdebug("%s: %zu bytes from 0x%lx", __func__, len, offset); in mctp_astlpc_mmio_lpc_read()
124 assert(offset + len < mmio->lpc_size); in mctp_astlpc_mmio_lpc_read()
126 memcpy(buf, mmio->lpc + offset, len); in mctp_astlpc_mmio_lpc_read()
132 size_t len) in mctp_astlpc_mmio_lpc_write() argument
136 mctp_prdebug("%s: %zu bytes to 0x%lx", __func__, len, offset); in mctp_astlpc_mmio_lpc_write()
139 assert(offset + len < mmio->lpc_size); in mctp_astlpc_mmio_lpc_write()
141 memcpy(mmio->lpc + offset, buf, len); in mctp_astlpc_mmio_lpc_write()
156 void *data __unused, void *msg, size_t len) in astlpc_test_rx_message() argument
160 mctp_prdebug("MCTP message received: msg: %p, len %zd", msg, len); in astlpc_test_rx_message()
[all …]
|
| D | test_core.c | 52 void *data, void *msg __unused, size_t len) in rx_message() argument
56 mctp_prdebug("MCTP message received: len %zd, tag %u", len, msg_tag); in rx_message()
59 param->message_size = len; in rx_message()
87 const struct pktbuf *pktbuf, size_t len) in receive_ptkbuf() argument
89 size_t alloc_size = MIN((size_t)MCTP_BTU, len); in receive_ptkbuf()
96 rx_pkt->size = MCTP_PACKET_SIZE(len); in receive_ptkbuf()
98 rx_pkt->end = MCTP_PACKET_SIZE(len); in receive_ptkbuf()
|
