fec_manager.h 3.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172
  1. /*
  2. * fec_manager.h
  3. *
  4. * Created on: Sep 27, 2017
  5. * Author: root
  6. */
  7. #ifndef FEC_MANAGER_H_
  8. #define FEC_MANAGER_H_
  9. #include "common.h"
  10. #include "log.h"
  11. #include "lib/rs.h"
  12. const int max_fec_pending_packet_num=1000;
  13. const int max_fec_packet_num=255;
  14. const u32_t anti_replay_buff_size=10000;
  15. const u32_t fec_buff_num=1000;
  16. struct anti_replay_t
  17. {
  18. u64_t replay_buffer[anti_replay_buff_size];
  19. unordered_set<u32_t> st;
  20. int index;
  21. anti_replay_t()
  22. {
  23. memset(replay_buffer,-1,sizeof(replay_buffer));
  24. st.rehash(anti_replay_buff_size*3);
  25. index=0;
  26. }
  27. void set_invaild(u32_t seq)
  28. {
  29. if(st.find(seq)!=st.end() )
  30. {
  31. mylog(log_trace,"seq %u exist\n",seq);
  32. return;
  33. //return 0;
  34. }
  35. if(replay_buffer[index]!=u64_t(i64_t(-1)))
  36. {
  37. assert(st.find(replay_buffer[index])!=st.end());
  38. st.erase(replay_buffer[index]);
  39. }
  40. replay_buffer[index]=seq;
  41. st.insert(seq);
  42. index++;
  43. if(index==int(anti_replay_buff_size)) index=0;
  44. //return 1; //for complier check
  45. }
  46. int is_vaild(u32_t seq)
  47. {
  48. return st.find(seq)==st.end();
  49. }
  50. };
  51. struct blob_encode_t
  52. {
  53. char buf[(max_fec_packet_num+5)*buf_len];
  54. int current_len;
  55. int counter;
  56. char *output_arr[max_fec_packet_num+100];
  57. blob_encode_t();
  58. int clear();
  59. int get_num();
  60. int get_shard_len(int n);
  61. int get_shard_len(int n,int next_packet_len);
  62. int input(char *s,int len); //len=use len=0 for second and following packet
  63. int output(int n,char ** &s_arr,int & len);
  64. };
  65. struct blob_decode_t
  66. {
  67. char buf[(max_fec_packet_num+5)*buf_len];
  68. int current_len;
  69. int last_len;
  70. int counter;
  71. char *s_buf[max_fec_pending_packet_num+100];
  72. int len_buf[max_fec_pending_packet_num+100];
  73. blob_decode_t();
  74. int clear();
  75. int input(char *input,int len);
  76. int output(int &n,char ** &output,int *&len_arr);
  77. };
  78. class fec_encode_manager_t
  79. {
  80. private:
  81. u32_t seq;
  82. int type;
  83. int fec_data_num,fec_redundant_num;
  84. int fec_mtu;
  85. int fec_pending_num;
  86. int fec_pending_time;
  87. char input_buf[max_fec_packet_num+5][buf_len];
  88. int input_len[max_fec_packet_num+5];
  89. char *output_buf[max_fec_packet_num+5];
  90. int output_len[max_fec_packet_num+5];
  91. int counter;
  92. int timer_fd;
  93. u64_t timer_fd64;
  94. int ready_for_output;
  95. u32_t output_n;
  96. blob_encode_t blob_encode;
  97. int append(char *s,int len);
  98. public:
  99. fec_encode_manager_t();
  100. ~fec_encode_manager_t();
  101. u64_t get_timer_fd64();
  102. int re_init(int data_num,int redundant_num,int mtu,int pending_num,int pending_time,int type);
  103. int input(char *s,int len/*,int &is_first_packet*/);
  104. int output(int &n,char ** &s_arr,int *&len);
  105. };
  106. struct fec_data_t
  107. {
  108. int used;
  109. u32_t seq;
  110. int type;
  111. int data_num;
  112. int redundant_num;
  113. int idx;
  114. char buf[buf_len];
  115. int len;
  116. };
  117. struct fec_group_t
  118. {
  119. int type=-1;
  120. int data_num=-1;
  121. int redundant_num=-1;
  122. int len=-1;
  123. int data_counter=0;
  124. map<int,int> group_mp;
  125. };
  126. class fec_decode_manager_t
  127. {
  128. anti_replay_t anti_replay;
  129. fec_data_t fec_data[fec_buff_num];
  130. int index;
  131. unordered_map<u32_t, fec_group_t> mp;
  132. blob_decode_t blob_decode;
  133. int output_n;
  134. char ** output_s_arr;
  135. int * output_len_arr;
  136. char *output_s_arr_buf[max_fec_pending_packet_num+100];
  137. int output_len_arr_buf[max_fec_pending_packet_num+100];
  138. int ready_for_output;
  139. public:
  140. fec_decode_manager_t();
  141. int re_init();
  142. int input(char *s,int len);
  143. int output(int &n,char ** &s_arr,int* &len_arr);
  144. };
  145. #endif /* FEC_MANAGER_H_ */