summaryrefslogtreecommitdiff
path: root/include
diff options
context:
space:
mode:
authorluwenpeng <[email protected]>2024-09-19 17:26:34 +0800
committerluwenpeng <[email protected]>2024-09-20 16:59:19 +0800
commit60caf1bda19f8797b72ef93a9c18517c4ca9495c (patch)
tree624c56dd26a76dbc59dba8e567121e7b03e7c756 /include
parentaedc675c34c48278fbb8103af3927bb9077fa74e (diff)
refactor(packet manager): hide packet manager schema and packet manager runtime
Diffstat (limited to 'include')
-rw-r--r--include/stellar/packet_manager.h11
1 files changed, 3 insertions, 8 deletions
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
}