myvtm/Other/libvideoframework/congestion_control/cc/sender_congestion_controller.h

#ifndef __sender_congestion_controller_h_
#define __sender_congestion_controller_h_

#include "../estimator/cc_feedback_adapter.h"
#include "../estimator/delay_base_bwe.h"
#include "../estimator/bitrate_controller.h"
#include "../pacing/pace_sender.h"
#include "../estimator/ack_bitrate_estimator.h"

#include "../cc/razor_api.h"

typedef struct
{
	razor_sender_t				sender;
	int							accepted_queue_ms;			/*视频报文在发送queue的最大延迟*/
	int							was_in_alr;
	int32_t						rtt;

	delay_base_bwe_t*			bwe;						/*基于延迟的带宽评估器*/
	bitrate_controller_t*		bitrate_controller;			/*码率控制器，会根据bwe、ack rate和loss进行综合码率调节*/
	ack_bitrate_estimator_t*	ack;						/*远端确认收到的数据带宽评估器*/
	pace_sender_t*				pacer;						/*发送端的步长控制器*/
	feedback_adapter_t			adapter;					/*处理反馈信息的适配器*/

	bin_stream_t				strm;

	void*						trigger;					/*码率改变后需要通知给通信层的trigger*/
	bitrate_changed_func		trigger_cb;					/*通知函数*/

}sender_cc_t;

sender_cc_t*					sender_cc_create(void* trigger, bitrate_changed_func bitrate_cb, void* handler, pace_send_func send_cb, int queue_ms);
void							sender_cc_destroy(sender_cc_t* cc);

void							sender_cc_heartbeat(sender_cc_t* cc);

/*packet_id是报文序号，相当于RTP的头中的SEQ*/
int								sender_cc_add_pace_packet(sender_cc_t* cc, uint32_t packet_id, int retrans, size_t size);
/*这里的seq是transport的自增长ID，即使包重发，这个ID也是不一样的*/
void							sender_on_send_packet(sender_cc_t* cc, uint16_t seq, size_t size);

void							sender_on_feedback(sender_cc_t* cc, uint8_t* feedback, int feedback_size);

void							sender_cc_update_rtt(sender_cc_t* cc, int32_t rtt);
void							sender_cc_set_bitrates(sender_cc_t* cc, uint32_t min_bitrate, uint32_t start_bitrate, uint32_t max_bitrate);

int64_t							sender_cc_get_pacer_queue_ms(sender_cc_t* cc);
int64_t							sender_cc_get_first_packet_ts(sender_cc_t* cc);


#endif