From 60caf1bda19f8797b72ef93a9c18517c4ca9495c Mon Sep 17 00:00:00 2001 From: luwenpeng Date: Thu, 19 Sep 2024 17:26:34 +0800 Subject: refactor(packet manager): hide packet manager schema and packet manager runtime --- include/stellar/packet_manager.h | 11 +++-------- 1 file changed, 3 insertions(+), 8 deletions(-) (limited to 'include') diff --git a/include/stellar/packet_manager.h b/include/stellar/packet_manager.h index 5d78ec3..ebbff80 100644 --- a/include/stellar/packet_manager.h +++ b/include/stellar/packet_manager.h @@ -18,21 +18,16 @@ enum packet_stage }; struct packet_manager; -struct packet_manager_schema; -struct packet_manager_runtime; - -struct packet_manager_schema *packet_manager_get_schema(struct packet_manager *pkt_mgr); -struct packet_manager_runtime *packet_manager_get_runtime(struct packet_manager *pkt_mgr, uint16_t thr_idx); typedef void on_packet_stage_callback(enum packet_stage stage, struct packet *pkt, void *args); -int packet_manager_schema_add_subscriber(struct packet_manager_schema *pkt_mgr_schema, enum packet_stage stage, on_packet_stage_callback cb, void *args); +int packet_manager_subscribe(struct packet_manager *pkt_mgr, enum packet_stage stage, on_packet_stage_callback cb, void *args); // if two modules claim the same packet at the same stage, the second 'claim' fails. // return 0 on success // return -1 on failure typedef void on_packet_claimed_callback(struct packet *pkt, void *args); -int packet_manager_runtime_claim_packet(struct packet_manager_runtime *pkt_mgr_rt, struct packet *pkt, on_packet_claimed_callback cb, void *args); -void packet_manager_runtime_schedule_packet(struct packet_manager_runtime *pkt_mgr_rt, struct packet *pkt, enum packet_stage stage); +int packet_manager_claim_packet(struct packet_manager *pkt_mgr, uint16_t thread_id, struct packet *pkt, on_packet_claimed_callback cb, void *args); +void packet_manager_schedule_packet(struct packet_manager *pkt_mgr, uint16_t thread_id, struct packet *pkt, enum packet_stage stage); #ifdef __cplusplus } -- cgit v1.2.3