client.cpp 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035
  1. #include "common.h"
  2. #include "network.h"
  3. #include "connection.h"
  4. #include "misc.h"
  5. #include "log.h"
  6. #include "lib/md5.h"
  7. #include "encrypt.h"
  8. #include "fd_manager.h"
  9. u32_t detect_interval=1500;
  10. u64_t laste_detect_time=0;
  11. int use_udp_for_detection=0;
  12. int use_tcp_for_detection=1;
  13. extern pcap_t *pcap_handle;
  14. extern int pcap_captured_full_len;
  15. int client_on_timer(conn_info_t &conn_info) //for client. called when a timer is ready in epoll
  16. {
  17. packet_info_t &send_info=conn_info.raw_info.send_info;
  18. packet_info_t &recv_info=conn_info.raw_info.recv_info;
  19. raw_info_t &raw_info=conn_info.raw_info;
  20. conn_info.blob->conv_manager.c.clear_inactive();
  21. mylog(log_trace,"timer!\n");
  22. mylog(log_trace,"roller my %d,oppsite %d,%lld\n",int(conn_info.my_roller),int(conn_info.oppsite_roller),conn_info.last_oppsite_roller_time);
  23. mylog(log_trace,"<client_on_timer,send_info.ts_ack= %u>\n",send_info.ts_ack);
  24. //mylog(log_debug,"pcap cnt :%d\n",pcap_cnt);
  25. if(send_with_pcap&&!pcap_header_captured)
  26. {
  27. if(get_current_time()-laste_detect_time>detect_interval)
  28. {
  29. laste_detect_time=get_current_time();
  30. }
  31. else
  32. {
  33. return 0;
  34. }
  35. /*
  36. struct sockaddr_in remote_addr_in={0};
  37. socklen_t slen = sizeof(sockaddr_in);
  38. int port=get_true_random_number()%65534+1;
  39. remote_addr_in.sin_family = AF_INET;
  40. remote_addr_in.sin_port = htons(port);
  41. remote_addr_in.sin_addr.s_addr = remote_ip_uint32;*/
  42. int port=get_true_random_number()%65534+1;
  43. address_t tmp_addr=remote_addr;
  44. tmp_addr.set_port(port);
  45. if(use_udp_for_detection)
  46. {
  47. int new_udp_fd=socket(tmp_addr.get_type(), SOCK_DGRAM, IPPROTO_UDP);
  48. if(new_udp_fd<0)
  49. {
  50. mylog(log_warn,"create new_udp_fd error\n");
  51. return -1;
  52. }
  53. setnonblocking(new_udp_fd);
  54. u64_t tmp=get_true_random_number();
  55. int ret=sendto(new_udp_fd,(char*)(&tmp),sizeof(tmp),0,(struct sockaddr *)&tmp_addr.inner,tmp_addr.get_len());
  56. if(ret==-1)
  57. {
  58. mylog(log_warn,"sendto() failed\n");
  59. }
  60. sock_close(new_udp_fd);
  61. }
  62. if(use_tcp_for_detection)
  63. {
  64. static int last_tcp_fd=-1;
  65. int new_tcp_fd=socket(tmp_addr.get_type(), SOCK_STREAM, IPPROTO_TCP);
  66. if(new_tcp_fd<0)
  67. {
  68. mylog(log_warn,"create new_tcp_fd error\n");
  69. return -1;
  70. }
  71. setnonblocking(new_tcp_fd);
  72. connect(new_tcp_fd,(struct sockaddr *)&tmp_addr.inner,tmp_addr.get_len());
  73. if(last_tcp_fd!=-1)
  74. sock_close(last_tcp_fd);
  75. last_tcp_fd=new_tcp_fd;
  76. //close(new_tcp_fd);
  77. }
  78. mylog(log_info,"waiting for a use-able packet to be captured\n");
  79. return 0;
  80. }
  81. if(raw_info.disabled)
  82. {
  83. conn_info.state.client_current_state=client_idle;
  84. conn_info.my_id=get_true_random_number_nz();
  85. mylog(log_info,"state back to client_idle\n");
  86. }
  87. if(conn_info.state.client_current_state==client_idle)
  88. {
  89. raw_info.rst_received=0;
  90. raw_info.disabled=0;
  91. fail_time_counter++;
  92. if(max_fail_time>0&&fail_time_counter>max_fail_time)
  93. {
  94. mylog(log_fatal,"max_fail_time exceed\n");
  95. myexit(-1);
  96. }
  97. conn_info.blob->anti_replay.re_init();
  98. conn_info.my_id = get_true_random_number_nz(); ///todo no need to do this everytime
  99. address_t tmp_addr;
  100. //u32_t new_ip=0;
  101. if(!force_source_ip)
  102. {
  103. if(get_src_adress2(tmp_addr,remote_addr)!=0)
  104. {
  105. mylog(log_warn,"get_src_adress() failed\n");
  106. return -1;
  107. }
  108. //source_addr=new_addr;
  109. //source_addr.set_port(0);
  110. mylog(log_info,"source_addr is now %s\n",tmp_addr.get_ip());
  111. /*
  112. if(new_ip!=source_ip_uint32)
  113. {
  114. mylog(log_info,"source ip changed from %s to ",my_ntoa(source_ip_uint32));
  115. log_bare(log_info,"%s\n",my_ntoa(new_ip));
  116. source_ip_uint32=new_ip;
  117. send_info.src_ip=new_ip;
  118. }*/
  119. }
  120. else
  121. {
  122. tmp_addr=source_addr;
  123. }
  124. send_info.new_src_ip.from_address_t(tmp_addr);
  125. if (force_source_port == 0)
  126. {
  127. send_info.src_port = client_bind_to_a_new_port2(bind_fd,tmp_addr);
  128. }
  129. else
  130. {
  131. send_info.src_port = source_port;
  132. }
  133. if (raw_mode == mode_icmp)
  134. {
  135. send_info.dst_port = send_info.src_port;
  136. }
  137. mylog(log_info, "using port %d\n", send_info.src_port);
  138. init_filter(send_info.src_port);
  139. if(raw_mode==mode_icmp||raw_mode==mode_udp)
  140. {
  141. conn_info.state.client_current_state=client_handshake1;
  142. mylog(log_info,"state changed from client_idle to client_pre_handshake\n");
  143. }
  144. if(raw_mode==mode_faketcp)
  145. {
  146. if(use_tcp_dummy_socket)
  147. {
  148. setnonblocking(bind_fd);
  149. int ret=connect(bind_fd,(struct sockaddr *)&remote_addr.inner,remote_addr.get_len());
  150. mylog(log_debug,"ret=%d,errno=%s, %d %s\n",ret,get_sock_error(),bind_fd,remote_addr.get_str());
  151. //mylog(log_info,"ret=%d,errno=,%d %s\n",ret,bind_fd,remote_addr.get_str());
  152. conn_info.state.client_current_state=client_tcp_handshake_dummy;
  153. mylog(log_info,"state changed from client_idle to client_tcp_handshake_dummy\n");
  154. }
  155. else
  156. {
  157. conn_info.state.client_current_state=client_tcp_handshake;
  158. mylog(log_info,"state changed from client_idle to client_tcp_handshake\n");
  159. }
  160. }
  161. conn_info.last_state_time=get_current_time();
  162. conn_info.last_hb_sent_time=0;
  163. //dont return;
  164. }
  165. if(conn_info.state.client_current_state==client_tcp_handshake) //send and resend syn
  166. {
  167. assert(raw_mode==mode_faketcp);
  168. if (get_current_time() - conn_info.last_state_time > client_handshake_timeout)
  169. {
  170. conn_info.state.client_current_state = client_idle;
  171. mylog(log_info, "state back to client_idle from client_tcp_handshake\n");
  172. return 0;
  173. }
  174. else if (get_current_time() - conn_info.last_hb_sent_time > client_retry_interval)
  175. {
  176. if (raw_mode == mode_faketcp)
  177. {
  178. if (conn_info.last_hb_sent_time == 0)
  179. {
  180. send_info.psh = 0;
  181. send_info.syn = 1;
  182. send_info.ack = 0;
  183. send_info.ts_ack =0;
  184. send_info.seq=get_true_random_number();
  185. send_info.ack_seq=get_true_random_number();
  186. }
  187. }
  188. send_raw0(raw_info, 0, 0);
  189. conn_info.last_hb_sent_time = get_current_time();
  190. mylog(log_info, "(re)sent tcp syn\n");
  191. return 0;
  192. }
  193. else
  194. {
  195. return 0;
  196. }
  197. return 0;
  198. }
  199. else if(conn_info.state.client_current_state==client_tcp_handshake_dummy)
  200. {
  201. assert(raw_mode==mode_faketcp);
  202. if (get_current_time() - conn_info.last_state_time > client_handshake_timeout)
  203. {
  204. conn_info.state.client_current_state = client_idle;
  205. mylog(log_info, "state back to client_idle from client_tcp_handshake_dummy\n");
  206. return 0;
  207. }
  208. }
  209. else if(conn_info.state.client_current_state==client_handshake1)//send and resend handshake1
  210. {
  211. if(get_current_time()-conn_info.last_state_time>client_handshake_timeout)
  212. {
  213. conn_info.state.client_current_state=client_idle;
  214. mylog(log_info,"state back to client_idle from client_handshake1\n");
  215. return 0;
  216. }
  217. else if(get_current_time()-conn_info.last_hb_sent_time>client_retry_interval)
  218. {
  219. if(raw_mode==mode_faketcp)
  220. {
  221. if(conn_info.last_hb_sent_time==0)
  222. {
  223. send_info.seq++;
  224. send_info.ack_seq=recv_info.seq+1;
  225. send_info.ts_ack=recv_info.ts;
  226. raw_info.reserved_send_seq=send_info.seq;
  227. }
  228. send_info.seq=raw_info.reserved_send_seq;
  229. send_info.psh = 0;
  230. send_info.syn = 0;
  231. send_info.ack = 1;
  232. if(!use_tcp_dummy_socket)
  233. send_raw0(raw_info, 0, 0);
  234. send_handshake(raw_info,conn_info.my_id,0,const_id);
  235. send_info.seq+=raw_info.send_info.data_len;
  236. }
  237. else
  238. {
  239. send_handshake(raw_info,conn_info.my_id,0,const_id);
  240. if(raw_mode==mode_icmp)
  241. send_info.my_icmp_seq++;
  242. }
  243. conn_info.last_hb_sent_time=get_current_time();
  244. mylog(log_info,"(re)sent handshake1\n");
  245. return 0;
  246. }
  247. else
  248. {
  249. return 0;
  250. }
  251. return 0;
  252. }
  253. else if(conn_info.state.client_current_state==client_handshake2)
  254. {
  255. if(get_current_time()-conn_info.last_state_time>client_handshake_timeout)
  256. {
  257. conn_info.state.client_current_state=client_idle;
  258. mylog(log_info,"state back to client_idle from client_handshake2\n");
  259. return 0;
  260. }
  261. else if(get_current_time()-conn_info.last_hb_sent_time>client_retry_interval)
  262. {
  263. if(raw_mode==mode_faketcp)
  264. {
  265. if(conn_info.last_hb_sent_time==0)
  266. {
  267. send_info.ack_seq=recv_info.seq+raw_info.recv_info.data_len;
  268. send_info.ts_ack=recv_info.ts;
  269. raw_info.reserved_send_seq=send_info.seq;
  270. }
  271. send_info.seq=raw_info.reserved_send_seq;
  272. send_handshake(raw_info,conn_info.my_id,conn_info.oppsite_id,const_id);
  273. send_info.seq+=raw_info.send_info.data_len;
  274. }
  275. else
  276. {
  277. send_handshake(raw_info,conn_info.my_id,conn_info.oppsite_id,const_id);
  278. if(raw_mode==mode_icmp)
  279. send_info.my_icmp_seq++;
  280. }
  281. conn_info.last_hb_sent_time=get_current_time();
  282. mylog(log_info,"(re)sent handshake2\n");
  283. return 0;
  284. }
  285. else
  286. {
  287. return 0;
  288. }
  289. return 0;
  290. }
  291. else if(conn_info.state.client_current_state==client_ready)
  292. {
  293. fail_time_counter=0;
  294. mylog(log_trace,"time %llu,%llu\n",get_current_time(),conn_info.last_state_time);
  295. if(get_current_time()-conn_info.last_hb_recv_time>client_conn_timeout)
  296. {
  297. conn_info.state.client_current_state=client_idle;
  298. conn_info.my_id=get_true_random_number_nz();
  299. mylog(log_info,"state back to client_idle from client_ready bc of server-->client direction timeout\n");
  300. return 0;
  301. }
  302. if(get_current_time()- conn_info.last_oppsite_roller_time>client_conn_uplink_timeout)
  303. {
  304. conn_info.state.client_current_state=client_idle;
  305. conn_info.my_id=get_true_random_number_nz();
  306. mylog(log_info,"state back to client_idle from client_ready bc of client-->server direction timeout\n");
  307. }
  308. if(get_current_time()-conn_info.last_hb_sent_time<heartbeat_interval)
  309. {
  310. return 0;
  311. }
  312. mylog(log_debug,"heartbeat sent <%x,%x>\n",conn_info.oppsite_id,conn_info.my_id);
  313. if(hb_mode==0)
  314. send_safer(conn_info,'h',hb_buf,0);/////////////send
  315. else
  316. send_safer(conn_info,'h',hb_buf,hb_len);
  317. conn_info.last_hb_sent_time=get_current_time();
  318. return 0;
  319. }
  320. else
  321. {
  322. mylog(log_fatal,"unknown state,this shouldnt happen.\n");
  323. myexit(-1);
  324. }
  325. return 0;
  326. }
  327. int client_on_raw_recv(conn_info_t &conn_info) //called when raw fd received a packet.
  328. {
  329. char* data;int data_len;
  330. packet_info_t &send_info=conn_info.raw_info.send_info;
  331. packet_info_t &recv_info=conn_info.raw_info.recv_info;
  332. raw_info_t &raw_info=conn_info.raw_info;
  333. mylog(log_trace,"<client_on_raw_recv,send_info.ts_ack= %u>\n",send_info.ts_ack);
  334. //if(pre_recv_raw_packet()<0) return -1;
  335. //no pre_recv_raw_packet() in mp version
  336. if(conn_info.state.client_current_state==client_idle )
  337. {
  338. discard_raw_packet();
  339. //recv(raw_recv_fd, 0,0, 0 );
  340. }
  341. else if(conn_info.state.client_current_state==client_tcp_handshake||conn_info.state.client_current_state==client_tcp_handshake_dummy)//received syn ack
  342. {
  343. assert(raw_mode==mode_faketcp);
  344. if(recv_raw0(raw_info,data,data_len)<0)
  345. {
  346. return -1;
  347. }
  348. if(!recv_info.new_src_ip.equal(send_info.new_dst_ip)||recv_info.src_port!=send_info.dst_port)
  349. {
  350. mylog(log_debug,"unexpected adress %s %s %d %d\n",recv_info.new_src_ip.get_str1(),send_info.new_dst_ip.get_str2(),recv_info.src_port,send_info.dst_port);
  351. return -1;
  352. }
  353. if(data_len==0&&raw_info.recv_info.syn==1&&raw_info.recv_info.ack==1)
  354. {
  355. if(conn_info.state.client_current_state==client_tcp_handshake)
  356. {
  357. if(recv_info.ack_seq!=send_info.seq+1)
  358. {
  359. mylog(log_debug,"seq ack_seq mis match\n");
  360. return -1;
  361. }
  362. mylog(log_info,"state changed from client_tcp_handshake to client_handshake1\n");
  363. }
  364. else
  365. {
  366. send_info.seq=recv_info.ack_seq-1;
  367. mylog(log_info,"state changed from client_tcp_dummy to client_handshake1\n");
  368. //send_info.ack_seq=recv_info.seq+1;
  369. }
  370. conn_info.state.client_current_state = client_handshake1;
  371. conn_info.last_state_time = get_current_time();
  372. conn_info.last_hb_sent_time=0;
  373. client_on_timer(conn_info);
  374. return 0;
  375. }
  376. else
  377. {
  378. mylog(log_debug,"unexpected packet type,expected:syn ack\n");
  379. return -1;
  380. }
  381. }
  382. else if(conn_info.state.client_current_state==client_handshake1)//recevied respond of handshake1
  383. {
  384. if(recv_bare(raw_info,data,data_len)!=0)
  385. {
  386. mylog(log_debug,"recv_bare failed!\n");
  387. return -1;
  388. }
  389. if(!recv_info.new_src_ip.equal(send_info.new_dst_ip)||recv_info.src_port!=send_info.dst_port)
  390. {
  391. mylog(log_debug,"unexpected adress %s %s %d %d\n",recv_info.new_src_ip.get_str1(),send_info.new_dst_ip.get_str2(),recv_info.src_port,send_info.dst_port);
  392. return -1;
  393. }
  394. if(data_len<int( 3*sizeof(my_id_t)))
  395. {
  396. mylog(log_debug,"too short to be a handshake\n");
  397. return -1;
  398. }
  399. my_id_t tmp_oppsite_id;
  400. memcpy(&tmp_oppsite_id,&data[0],sizeof(tmp_oppsite_id));
  401. tmp_oppsite_id=ntohl(tmp_oppsite_id);
  402. my_id_t tmp_my_id;
  403. memcpy(&tmp_my_id,&data[sizeof(my_id_t)],sizeof(tmp_my_id));
  404. tmp_my_id=ntohl(tmp_my_id);
  405. my_id_t tmp_oppsite_const_id;
  406. memcpy(&tmp_oppsite_const_id,&data[sizeof(my_id_t)*2],sizeof(tmp_oppsite_const_id));
  407. tmp_oppsite_const_id=ntohl(tmp_oppsite_const_id);
  408. if(tmp_my_id!=conn_info.my_id)
  409. {
  410. mylog(log_debug,"tmp_my_id doesnt match\n");
  411. return -1;
  412. }
  413. if(raw_mode==mode_faketcp)
  414. {
  415. if(recv_info.ack_seq!=send_info.seq)
  416. {
  417. mylog(log_debug,"seq ack_seq mis match\n");
  418. return -1;
  419. }
  420. if(recv_info.seq!=send_info.ack_seq)
  421. {
  422. mylog(log_debug,"seq ack_seq mis match\n");
  423. return -1;
  424. }
  425. }
  426. conn_info.oppsite_id=tmp_oppsite_id;
  427. mylog(log_info,"changed state from to client_handshake1 to client_handshake2,my_id is %x,oppsite id is %x\n",conn_info.my_id,conn_info.oppsite_id);
  428. conn_info.state.client_current_state = client_handshake2;
  429. conn_info.last_state_time = get_current_time();
  430. conn_info.last_hb_sent_time=0;
  431. client_on_timer(conn_info);
  432. return 0;
  433. }
  434. else if(conn_info.state.client_current_state==client_handshake2||conn_info.state.client_current_state==client_ready)//received heartbeat or data
  435. {
  436. char type;
  437. if(recv_safer(conn_info,type,data,data_len)!=0)
  438. {
  439. mylog(log_debug,"recv_safer failed!\n");
  440. return -1;
  441. }
  442. if(!recv_info.new_src_ip.equal(send_info.new_dst_ip)||recv_info.src_port!=send_info.dst_port)
  443. {
  444. mylog(log_warn,"unexpected adress %s %s %d %d,this shouldnt happen.\n",recv_info.new_src_ip.get_str1(),send_info.new_dst_ip.get_str2(),recv_info.src_port,send_info.dst_port);
  445. return -1;
  446. }
  447. if(conn_info.state.client_current_state==client_handshake2)
  448. {
  449. mylog(log_info,"changed state from to client_handshake2 to client_ready\n");
  450. conn_info.state.client_current_state=client_ready;
  451. conn_info.last_hb_sent_time=0;
  452. conn_info.last_hb_recv_time=get_current_time();
  453. conn_info.last_oppsite_roller_time=conn_info.last_hb_recv_time;
  454. client_on_timer(conn_info);
  455. }
  456. if(data_len>=0&&type=='h')
  457. {
  458. mylog(log_debug,"[hb]heart beat received,oppsite_roller=%d\n",int(conn_info.oppsite_roller));
  459. conn_info.last_hb_recv_time=get_current_time();
  460. return 0;
  461. }
  462. else if(data_len>= int( sizeof(u32_t))&&type=='d')
  463. {
  464. mylog(log_trace,"received a data from fake tcp,len:%d\n",data_len);
  465. if(hb_mode==0)
  466. conn_info.last_hb_recv_time=get_current_time();
  467. u32_t tmp_conv_id;
  468. memcpy(&tmp_conv_id,&data[0],sizeof(tmp_conv_id));
  469. tmp_conv_id=ntohl(tmp_conv_id);
  470. if(!conn_info.blob->conv_manager.c.is_conv_used(tmp_conv_id))
  471. {
  472. mylog(log_info,"unknow conv %d,ignore\n",tmp_conv_id);
  473. return 0;
  474. }
  475. conn_info.blob->conv_manager.c.update_active_time(tmp_conv_id);
  476. //u64_t u64=conn_info.blob->conv_manager.c.find_data_by_conv(tmp_conv_id);
  477. address_t tmp_addr=conn_info.blob->conv_manager.c.find_data_by_conv(tmp_conv_id);
  478. //sockaddr_in tmp_sockaddr={0};
  479. //tmp_sockaddr.sin_family = AF_INET;
  480. //tmp_sockaddr.sin_addr.s_addr=(u64>>32u);
  481. //tmp_sockaddr.sin_port= htons(uint16_t((u64<<32u)>>32u));
  482. int ret=sendto(udp_fd,data+sizeof(u32_t),data_len -(sizeof(u32_t)),0,(struct sockaddr *)&tmp_addr.inner,tmp_addr.get_len());
  483. if(ret<0)
  484. {
  485. mylog(log_warn,"sento returned %d,%s,%02x,%s\n",ret,get_sock_error(),int(tmp_addr.get_type()),tmp_addr.get_str());
  486. //perror("ret<0");
  487. }
  488. }
  489. else
  490. {
  491. mylog(log_warn,"unknown packet,this shouldnt happen.\n");
  492. return -1;
  493. }
  494. return 0;
  495. }
  496. else
  497. {
  498. mylog(log_fatal,"unknown state,this shouldnt happen.\n");
  499. myexit(-1);
  500. }
  501. return 0;
  502. }
  503. int client_on_udp_recv(conn_info_t &conn_info)
  504. {
  505. int recv_len;
  506. char buf[buf_len];
  507. address_t::storage_t udp_new_addr_in={0};
  508. socklen_t udp_new_addr_len = sizeof(address_t::storage_t);
  509. if ((recv_len = recvfrom(udp_fd, buf, max_data_len+1, 0,
  510. (struct sockaddr *) &udp_new_addr_in, &udp_new_addr_len)) == -1) {
  511. mylog(log_debug,"recv_from error,%s\n",get_sock_error());
  512. return -1;
  513. //myexit(1);
  514. };
  515. if(recv_len==max_data_len+1)
  516. {
  517. mylog(log_warn,"huge packet, data_len > %d,dropped\n",max_data_len);
  518. return -1;
  519. }
  520. if(recv_len>=mtu_warn)
  521. {
  522. mylog(log_warn,"huge packet,data len=%d (>=%d).strongly suggested to set a smaller mtu at upper level,to get rid of this warn\n ",recv_len,mtu_warn);
  523. }
  524. address_t tmp_addr;
  525. tmp_addr.from_sockaddr((sockaddr *)&udp_new_addr_in,udp_new_addr_len);
  526. u32_t conv;
  527. if(!conn_info.blob->conv_manager.c.is_data_used(tmp_addr))
  528. {
  529. if(conn_info.blob->conv_manager.c.get_size() >=max_conv_num)
  530. {
  531. mylog(log_warn,"ignored new udp connect bc max_conv_num exceed\n");
  532. return -1;
  533. }
  534. conv=conn_info.blob->conv_manager.c.get_new_conv();
  535. conn_info.blob->conv_manager.c.insert_conv(conv,tmp_addr);
  536. mylog(log_info,"new packet from %s,conv_id=%x\n",tmp_addr.get_str(),conv);
  537. }
  538. else
  539. {
  540. conv=conn_info.blob->conv_manager.c.find_conv_by_data(tmp_addr);
  541. }
  542. conn_info.blob->conv_manager.c.update_active_time(conv);
  543. if(conn_info.state.client_current_state==client_ready)
  544. {
  545. send_data_safer(conn_info,buf,recv_len,conv);
  546. }
  547. return 0;
  548. }
  549. void udp_accept_cb(struct ev_loop *loop, struct ev_io *watcher, int revents)
  550. {
  551. conn_info_t & conn_info= *((conn_info_t*)watcher->data);
  552. client_on_udp_recv(conn_info);
  553. }
  554. void raw_recv_cb(struct ev_loop *loop, struct ev_io *watcher, int revents)
  555. {
  556. assert(0==1);
  557. conn_info_t & conn_info= *((conn_info_t*)watcher->data);
  558. client_on_raw_recv(conn_info);
  559. }
  560. void async_cb(struct ev_loop *loop, struct ev_async *watcher, int revents)
  561. {
  562. conn_info_t & conn_info= *((conn_info_t*)watcher->data);
  563. if(send_with_pcap&&!pcap_header_captured)
  564. {
  565. int empty=0;char *p;int len;
  566. pthread_mutex_lock(&queue_mutex);
  567. empty=my_queue.empty();
  568. if(!empty)
  569. {
  570. my_queue.peek_front(p,len);
  571. my_queue.pop_front();
  572. }
  573. pthread_mutex_unlock(&queue_mutex);
  574. if(empty) return;
  575. pcap_header_captured=1;
  576. assert(pcap_link_header_len!=-1);
  577. memcpy(pcap_header_buf,p,max_data_len);
  578. log_bare(log_info,"link level header captured:\n");
  579. unsigned char *tmp=(unsigned char*)pcap_header_buf;
  580. pcap_captured_full_len=len;
  581. for(int i=0;i<pcap_link_header_len;i++)
  582. log_bare(log_info,"<%x>",(u32_t)tmp[i]);
  583. log_bare(log_info,"\n");
  584. return ;
  585. }
  586. //mylog(log_info,"async_cb called\n");
  587. while(1)
  588. {
  589. int empty=0;char *p;int len;
  590. pthread_mutex_lock(&queue_mutex);
  591. empty=my_queue.empty();
  592. if(!empty)
  593. {
  594. my_queue.peek_front(p,len);
  595. my_queue.pop_front();
  596. }
  597. pthread_mutex_unlock(&queue_mutex);
  598. if(empty) break;
  599. int new_len=len-pcap_link_header_len;
  600. memcpy(g_packet_buf,p+pcap_link_header_len,new_len);
  601. g_packet_buf_len=new_len;
  602. assert(g_packet_buf_cnt==0);
  603. g_packet_buf_cnt++;
  604. client_on_raw_recv(conn_info);
  605. }
  606. }
  607. void clear_timer_cb(struct ev_loop *loop, struct ev_timer *watcher, int revents)
  608. {
  609. conn_info_t & conn_info= *((conn_info_t*)watcher->data);
  610. client_on_timer(conn_info);
  611. }
  612. void fifo_cb(struct ev_loop *loop, struct ev_io *watcher, int revents)
  613. {
  614. conn_info_t & conn_info= *((conn_info_t*)watcher->data);
  615. char buf[buf_len];
  616. int fifo_fd=watcher->fd;
  617. int len=read (fifo_fd, buf, sizeof (buf));
  618. if(len<0)
  619. {
  620. mylog(log_warn,"fifo read failed len=%d,errno=%s\n",len,get_sock_error());
  621. return;
  622. }
  623. buf[len]=0;
  624. while(len>=1&&buf[len-1]=='\n')
  625. buf[len-1]=0;
  626. mylog(log_info,"got data from fifo,len=%d,s=[%s]\n",len,buf);
  627. if(strcmp(buf,"reconnect")==0)
  628. {
  629. mylog(log_info,"received command: reconnect\n");
  630. conn_info.state.client_current_state=client_idle;
  631. conn_info.my_id=get_true_random_number_nz();
  632. }
  633. else
  634. {
  635. mylog(log_info,"unknown command\n");
  636. }
  637. }
  638. int client_event_loop()
  639. {
  640. char buf[buf_len];
  641. conn_info_t conn_info;
  642. conn_info.my_id=get_true_random_number_nz();
  643. conn_info.prepare();
  644. packet_info_t &send_info=conn_info.raw_info.send_info;
  645. packet_info_t &recv_info=conn_info.raw_info.recv_info;
  646. /*
  647. if(lower_level)
  648. {
  649. if(lower_level_manual)
  650. {
  651. int index;
  652. init_ifindex(if_name,raw_send_fd,index);
  653. //init_ifindex(if_name);
  654. memset(&send_info.addr_ll, 0, sizeof(send_info.addr_ll));
  655. send_info.addr_ll.sll_family = AF_PACKET;
  656. send_info.addr_ll.sll_ifindex =index;
  657. send_info.addr_ll.sll_halen = ETHER_ADDR_LEN;
  658. send_info.addr_ll.sll_protocol = htons(ETH_P_IP);
  659. memcpy(&send_info.addr_ll.sll_addr, dest_hw_addr, ETHER_ADDR_LEN);
  660. mylog(log_info,"we are running at lower-level (manual) mode\n");
  661. }
  662. else
  663. {
  664. u32_t dest_ip;
  665. string if_name_string;
  666. string hw_string;
  667. assert(remote_addr.get_type()==AF_INET);
  668. if(retry_on_error==0)
  669. {
  670. if(find_lower_level_info(remote_addr.inner.ipv4.sin_addr.s_addr,dest_ip,if_name_string,hw_string)!=0)
  671. {
  672. mylog(log_fatal,"auto detect lower-level info failed for %s,specific it manually\n",remote_addr.get_ip());
  673. myexit(-1);
  674. }
  675. }
  676. else
  677. {
  678. int ok=0;
  679. while(!ok)
  680. {
  681. if(find_lower_level_info(remote_addr.inner.ipv4.sin_addr.s_addr,dest_ip,if_name_string,hw_string)!=0)
  682. {
  683. mylog(log_warn,"auto detect lower-level info failed for %s,retry in %d seconds\n",remote_addr.get_ip(),retry_on_error_interval);
  684. sleep(retry_on_error_interval);
  685. }
  686. else
  687. {
  688. ok=1;
  689. }
  690. }
  691. }
  692. mylog(log_info,"we are running at lower-level (auto) mode,%s %s %s\n",my_ntoa(dest_ip),if_name_string.c_str(),hw_string.c_str());
  693. u32_t hw[6];
  694. memset(hw, 0, sizeof(hw));
  695. sscanf(hw_string.c_str(), "%x:%x:%x:%x:%x:%x",&hw[0], &hw[1], &hw[2],
  696. &hw[3], &hw[4], &hw[5]);
  697. mylog(log_warn,
  698. "make sure this is correct: if_name=<%s> dest_mac_adress=<%02x:%02x:%02x:%02x:%02x:%02x> \n",
  699. if_name_string.c_str(), hw[0], hw[1], hw[2], hw[3], hw[4], hw[5]);
  700. for (int i = 0; i < 6; i++) {
  701. dest_hw_addr[i] = uint8_t(hw[i]);
  702. }
  703. //mylog(log_fatal,"--lower-level auto for client hasnt been implemented\n");
  704. int index;
  705. init_ifindex(if_name_string.c_str(),raw_send_fd,index);
  706. memset(&send_info.addr_ll, 0, sizeof(send_info.addr_ll));
  707. send_info.addr_ll.sll_family = AF_PACKET;
  708. send_info.addr_ll.sll_ifindex = index;
  709. send_info.addr_ll.sll_halen = ETHER_ADDR_LEN;
  710. send_info.addr_ll.sll_protocol = htons(ETH_P_IP);
  711. memcpy(&send_info.addr_ll.sll_addr, dest_hw_addr, ETHER_ADDR_LEN);
  712. //mylog(log_info,"we are running at lower-level (manual) mode\n");
  713. }
  714. }
  715. */
  716. address_t tmp_addr;
  717. if(get_src_adress2(tmp_addr,remote_addr)!=0)
  718. {
  719. mylog(log_error,"get_src_adress() failed\n");
  720. myexit(-1);
  721. }
  722. if(strcmp(dev,"")==0)
  723. {
  724. mylog(log_info,"--dev have not been set, trying to detect automatically, avaliable deives:\n");
  725. mylog(log_info,"avaliable deives(device name: ip address ; description):\n");
  726. char errbuf[PCAP_ERRBUF_SIZE];
  727. int found=0;
  728. pcap_if_t *interfaces,*d;
  729. if(pcap_findalldevs(&interfaces,errbuf)==-1)
  730. {
  731. mylog(log_fatal,"error in pcap_findalldevs(),%s\n",errbuf);
  732. myexit(-1);
  733. }
  734. for(pcap_if_t *d=interfaces; d!=NULL; d=d->next) {
  735. log_bare(log_warn,"%s:", d->name);
  736. int cnt=0;
  737. for(pcap_addr_t *a=d->addresses; a!=NULL; a=a->next) {
  738. if(a->addr==NULL)
  739. {
  740. log_bare(log_debug," [a->addr==NULL]");
  741. continue;
  742. }
  743. if(a->addr->sa_family == AF_INET||a->addr->sa_family == AF_INET6)
  744. {
  745. cnt++;
  746. if(a->addr->sa_family ==AF_INET)
  747. {
  748. char s[max_addr_len];
  749. inet_ntop(AF_INET, &((struct sockaddr_in*)a->addr)->sin_addr, s,max_addr_len);
  750. log_bare(log_warn," [%s]", s);
  751. if(a->addr->sa_family==raw_ip_version)
  752. {
  753. if(((struct sockaddr_in*)a->addr)->sin_addr.s_addr ==tmp_addr.inner.ipv4.sin_addr.s_addr)
  754. {
  755. found++;
  756. strcpy(dev,d->name);
  757. }
  758. }
  759. }
  760. else
  761. {
  762. assert(a->addr->sa_family ==AF_INET6);
  763. char s[max_addr_len];
  764. inet_ntop(AF_INET6, &((struct sockaddr_in6*)a->addr)->sin6_addr, s,max_addr_len);
  765. log_bare(log_warn," [%s]", s);
  766. if(a->addr->sa_family==raw_ip_version)
  767. {
  768. if( memcmp( &((struct sockaddr_in6*)a->addr)->sin6_addr,&tmp_addr.inner.ipv6.sin6_addr,sizeof(struct in6_addr))==0 )
  769. {
  770. found++;
  771. strcpy(dev,d->name);
  772. }
  773. }
  774. }
  775. }
  776. else
  777. {
  778. log_bare(log_debug," [unknow:%d]",int(a->addr->sa_family));
  779. }
  780. }
  781. if(cnt==0) log_bare(log_warn," [no ip found]");
  782. if(d->description==0)
  783. {
  784. log_bare(log_warn,"; (no description avaliable)");
  785. }
  786. else
  787. {
  788. log_bare(log_warn,"; %s", d->description);
  789. }
  790. log_bare(log_warn,"\n");
  791. }
  792. if(found==0)
  793. {
  794. mylog(log_fatal,"no matched device found for ip: [%s]\n",tmp_addr.get_ip());
  795. myexit(-1);
  796. }
  797. else if(found==1)
  798. {
  799. mylog(log_info,"using device:[%s], ip: [%s]\n",dev,tmp_addr.get_ip());
  800. }
  801. else
  802. {
  803. mylog(log_fatal,"more than one devices found for ip: [%s] , you need to use --dev manually\n",tmp_addr.get_ip());
  804. myexit(-1);
  805. }
  806. }
  807. else
  808. {
  809. mylog(log_info,"--dev has been manually set, using device:[%s]\n",dev);
  810. }
  811. send_info.src_port=0;
  812. memset(&send_info.new_src_ip,0,sizeof(send_info.new_src_ip));
  813. int i, j, k;int ret;
  814. send_info.new_dst_ip.from_address_t(remote_addr);
  815. send_info.dst_port=remote_addr.get_port();
  816. udp_fd=socket(local_addr.get_type(), SOCK_DGRAM, IPPROTO_UDP);
  817. set_buf_size(udp_fd,socket_buf_size);
  818. if (::bind(udp_fd, (struct sockaddr*) &local_addr.inner, local_addr.get_len()) == -1) {
  819. mylog(log_fatal,"socket bind error\n");
  820. //perror("socket bind error");
  821. myexit(1);
  822. }
  823. setnonblocking(udp_fd);
  824. //epollfd = epoll_create1(0);
  825. //const int max_events = 4096;
  826. //struct epoll_event ev, events[max_events];
  827. //if (epollfd < 0) {
  828. // mylog(log_fatal,"epoll return %d\n", epollfd);
  829. // myexit(-1);
  830. //}
  831. struct ev_loop * loop= ev_default_loop(0);
  832. assert(loop != NULL);
  833. //ev.events = EPOLLIN;
  834. //ev.data.u64 = udp_fd;
  835. //ret = epoll_ctl(epollfd, EPOLL_CTL_ADD, udp_fd, &ev);
  836. //if (ret!=0) {
  837. // mylog(log_fatal,"add udp_listen_fd error\n");
  838. // myexit(-1);
  839. //}
  840. struct ev_io udp_accept_watcher;
  841. udp_accept_watcher.data=&conn_info;
  842. ev_io_init(&udp_accept_watcher, udp_accept_cb, udp_fd, EV_READ);
  843. ev_io_start(loop, &udp_accept_watcher);
  844. //ev.events = EPOLLIN;
  845. //ev.data.u64 = raw_recv_fd;
  846. //ret = epoll_ctl(epollfd, EPOLL_CTL_ADD, raw_recv_fd, &ev);
  847. //if (ret!= 0) {
  848. // mylog(log_fatal,"add raw_fd error\n");
  849. // myexit(-1);
  850. //}
  851. /*
  852. struct ev_io raw_recv_watcher;
  853. raw_recv_watcher.data=&conn_info;
  854. ev_io_init(&raw_recv_watcher, raw_recv_cb, raw_recv_fd, EV_READ);
  855. ev_io_start(loop, &raw_recv_watcher);
  856. */
  857. g_default_loop=loop;
  858. async_watcher.data=&conn_info;
  859. ev_async_init(&async_watcher,async_cb);
  860. ev_async_start(loop,&async_watcher);
  861. init_raw_socket();//must be put after dev detection
  862. //set_timer(epollfd,timer_fd);
  863. struct ev_timer clear_timer;
  864. clear_timer.data=&conn_info;
  865. ev_timer_init(&clear_timer, clear_timer_cb, 0, timer_interval/1000.0);
  866. ev_timer_start(loop, &clear_timer);
  867. mylog(log_debug,"send_raw : from %s %d to %s %d\n",send_info.new_src_ip.get_str1(),send_info.src_port,send_info.new_dst_ip.get_str2(),send_info.dst_port);
  868. int fifo_fd=-1;
  869. struct ev_io fifo_watcher;
  870. fifo_watcher.data=&conn_info;
  871. if(fifo_file[0]!=0)
  872. {
  873. fifo_fd=create_fifo(fifo_file);
  874. ev_io_init(&fifo_watcher, fifo_cb, fifo_fd, EV_READ);
  875. ev_io_start(loop, &fifo_watcher);
  876. mylog(log_info,"fifo_file=%s\n",fifo_file);
  877. }
  878. ev_run(loop, 0);
  879. return 0;
  880. }