diff options
| author | luwenpeng <[email protected]> | 2024-09-19 16:29:17 +0800 |
|---|---|---|
| committer | luwenpeng <[email protected]> | 2024-09-20 16:59:19 +0800 |
| commit | aedc675c34c48278fbb8103af3927bb9077fa74e (patch) | |
| tree | 54882e0b03891b4f69bdeac27d1e0c6d3c5b126e /infra/stellar_core.c | |
| parent | b47c1a052f97318ab6997c660886f4f9a7bc706b (diff) | |
rename packet_io_input/output to packet_io_ingress/egress
Diffstat (limited to 'infra/stellar_core.c')
| -rw-r--r-- | infra/stellar_core.c | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/infra/stellar_core.c b/infra/stellar_core.c index c88d5ae..f2563a6 100644 --- a/infra/stellar_core.c +++ b/infra/stellar_core.c @@ -177,7 +177,7 @@ static void *worker_thread(void *arg) * Suggestion: After modifying the system time, restart the service to ensure consistent timing. */ now_ms = clock_get_real_time_ms(); - nr_pkt_received = packet_io_input(packet_io, thr_idx, packets, RX_BURST_MAX); + nr_pkt_received = packet_io_ingress(packet_io, thr_idx, packets, RX_BURST_MAX); if (nr_pkt_received == 0) { goto idle_tasks; @@ -260,12 +260,12 @@ static void *worker_thread(void *arg) { // TODO // copy meta from defraged_pkt to packets[i] - packet_io_output(packet_io, thr_idx, &packets[i], 1); + packet_io_egress(packet_io, thr_idx, &packets[i], 1); packet_free(defraged_pkt); } else { - packet_io_output(packet_io, thr_idx, pkt, 1); + packet_io_egress(packet_io, thr_idx, pkt, 1); } } } @@ -580,7 +580,7 @@ void stellar_send_build_packet(struct stellar *st, struct packet *pkt) { // TODO abort(); - packet_io_output(packet_io, thr_idx, pkt, 1); + packet_io_egress(packet_io, thr_idx, pkt, 1); } else { |