client.cpp 27 KB

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