开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 通讯/手机编程 > 手机WAP编程 > 查看源码
sockettest.c
资源名称：mtk_socket.rar　[点击查看]
上传用户：wdy0515
上传日期：2015-09-05
资源大小：5k
文件大小：27k
源码类别：

手机WAP编程

开发平台：

C/C++

sockettest.c：源码内容
  1. #include "MMI_features.h"
  2. /* MTK End */
  5. #if !defined(__MTK_TARGET__)
  6. #include <windows.h>
  7. #endif 
  9. /**********************/
  10. /*****  Header Files *****/
  11. /**********************/
  13. #ifdef FIRST_PASS
  14. #include "BuildCfg.h"
  15. #endif 
  17. #include "CustDataRes.h"
  18. #include "EventsGprot.h"
  19. #include "historyGprot.h"
  20. #include "ProtocolEvents.h"
  21. #include "CustMenuRes.h"
  22. #include "wgui_categories.h"
  23. #include "HardwareEvents.h"
  24. #include "Thrdosinterface.h"
  25. #include "OSThreadInterfaceGprot.h"
  27. #include "TimerEvents.h"
  28. #include "MainMenuDef.h"
  29. #include "EngineerModeDef.h"
  30. #include "EngineerModeType.h"
  31. #include "EngineerModeProt.h"
  32. #include "PixtelDataTypes.h"
  33. #include "CustomCfg.h"
  34. #include "Unicodexdcl.h"
  35. #include "audioInc.h"
  36. #include "IdleAppDef.h"
  37. #include "BootUp.h"
  38. #include "GlobalDefs.h"
  40. #include "soc_api.h"
  41. #include "app2soc_struct.h"
  42. #include "EngineerModeSocketApp.h"
  43. #include "EngineerModeSocketAppPing.h"
  45. #include "OrganizerDef.h"
  48. soc_demo_app_transaction_struct *test_soc_demo_transaction = NULL;
  51. void mmi_test_socket();
  52. int test_mmi_soc_demo_app_request(
  53. mmi_soc_demo_app_enum app_id,
  54. int account_id,
  55. char server_ip_address[4],
  56. char *url,
  57. int url_len,
  58. char *echo_text,
  59. int echo_text_len,
  60. mmi_soc_demo_app_rsp_t callback);
  61. void tst_EmSocketRsp(mmi_soc_demo_app_enum app_id_enum, int result, char *response, int response_len);
  62. kal_bool test_en_soc_demo_app_create_socket();
  63. int test_en_soc_demo_http_send_request(void);
  64. void test_em_soc_demo_app_socket_notify(void *inMsg);
  66. void tst_em_soc_demo_app_start_timer(void);
  67. void tst_em_soc_demo_app_timer_handler(void);
  70. void tst_en_soc_demo_tcp_app_recv_response(void);
  72. void tst_en_soc_output_result(int ret, char *out_str, int len);
  75. int tst_mmi_soc_demo_app_request_abort(void);
  77. void tst_em_soc_demo_app_stop_timer(void);
  79. extern void StartTimer(U16 timerid, U32 delay, FuncPtr funcPtr);
  80. extern void StopTimer(U16 timerid);
  85. void tst_EmSocketRsp(mmi_soc_demo_app_enum app_id_enum, int result, char *response, int response_len)
  86. {
  87. /*----------------------------------------------------------------*/
  88. /* Local Variables   */
  89. /*----------------------------------------------------------------*/
  90. U16 i,j,k;
  91. U16 databgin, namebgin,preClsbgin,curpricebgin;
  92. U16 pack_byte;
  93. U8 socknum;
  94. /*----------------------------------------------------------------*/
  95. /* Object   */
  96. /*----------------------------------------------------------------*/
  98. for(i = 0; i < response_len; i++)
  99. {
  100. if(response[i] == 0x20 && response[i+1] == 0x20 )
  101. {
  102. pack_byte = response[i-2];
  103. pack_byte = ((pack_byte & 0x00ff)<<8) + response[i -1];
  104. kal_prompt_trace(MOD_WAP,"##########pack_byte[%d]",pack_byte);
  105. break;
  106. }
  107. }
  109. databgin = i + 2;
  110. namebgin = databgin + 6;
  111. //curpricebgin = namebgin + 52;
  112. pack_byte -=2;
  113. socknum = pack_byte / 258;
  114. kal_prompt_trace(MOD_WAP,"##########socknum[%d]",socknum);
  116. for(j = 0; j < socknum; j++)
  117. {
  118.   U8 cur[10][4];
  119.   U8 preCls[10][4];
  120.   U8 stockname[10][24];
  121.   U16 index = 0;
  122.   float preprice[10];
  123.   float currentprice[10];
  124.   float updown[10];
  125.   ////////////////////////////////////name/////////////////////////////
  127.   for(k = namebgin + j*258; k <namebgin+ j*258 + 24; k++)
  128.   {
  129. stockname[j][index++] = response[k];
  130.   }
  131.   ////////////////////////////////////preprice////////////////////////////
  132.   {  
  133.   index = 0;
  134.   k = k;
  135.   preClsbgin =k;
  136.   }
  137.   for(;k <preClsbgin + 4;k++ )
  138.   {
  139.   preCls[j][index++] = response[k];
  140.   kal_prompt_trace(MOD_WAP,"#############preprice = %x",response[k]);
  142.   }
  143.   {
  144. U32 prevalue;
  145. prevalue = (preCls[j][0]<<24) + (preCls[j][1]<<16) +(preCls[j][2]<<8) + (preCls[j][3]);
  146. preprice[j] = ((float)prevalue) /10000;
  149.  kal_prompt_trace(MOD_WAP,"---------------------prevalue = %d",prevalue);
  151.   }
  152.   
  153.   ////////////////////////////////////current price/////////////////////////
  155.   {  
  156.   index = 0;
  157.   k = k + 24;
  158.   curpricebgin =k;
  159.   }
  160.   
  161.    for(; k < curpricebgin + 4; k++)
  162.   {
  163. cur[j][index++] = response[k];
  164.   }
  165.    
  166.  {
  167. U32 value;
  168. value = ( cur[j][0]<<24) + (cur[j][1]<<16) + (cur[j][2]<<8) + (cur[j][3]);
  169. currentprice[j] = ((float)value) /10000;
  170.  }
  171.   /////////////////////////////////////end///////////////////////////////
  173. }
  174.    
  175. }
  178. void mmi_test_socket(void)
  179. {
  180. /*----------------------------------------------------------------*/
  181. /* Local Variables   */
  182. /*----------------------------------------------------------------*/
  184. #ifdef MMI_ON_HARDWARE_P
  185. U8 emSocketAccountId = custom_get_csd_profile_num();
  186. #else 
  187. U8 emSocketAccountId = 5;
  188. #endif 
  189. mmi_soc_demo_app_result emSocketTmpResult = EN_SOC_SUCCESS;
  190. S8 AscTmp[16];
  192. kal_prompt_trace(MOD_WAP," mmi_test_socket __________________ emSocketAccountId=%d",emSocketAccountId);
  193. emSocketTmpResult = test_mmi_soc_demo_app_request(
  194. HTTP,
  195. 10,
  196. NULL,
  197. NULL,//emSocketInputdata,
  198. 0,//strlen(emSocketInputdata),
  199. NULL,
  200. 0,
  201.   tst_EmSocketRsp);
  202. }
  207. int test_mmi_soc_demo_app_request(
  208. mmi_soc_demo_app_enum app_id,
  209. int account_id,
  210. char server_ip_address[4],
  211. char *url,
  212. int url_len,
  213. char *echo_text,
  214. int echo_text_len,
  215. mmi_soc_demo_app_rsp_t callback)
  216. {
  217. /*----------------------------------------------------------------*/
  218. /* Local Variables   */
  219. /*----------------------------------------------------------------*/
  221. /*----------------------------------------------------------------*/
  222. /* Code Body   */
  223. /*----------------------------------------------------------------*/
  224. if (test_soc_demo_transaction)
  225. {
  226. kal_prompt_trace(MOD_WAP,"###########################Transaction existed");
  227. #ifdef MMI_ON_HARDWARE_P
  228. kal_print("Transaction existed!!");
  229. #endif 
  230. return EN_SOC_BUSY;
  231. }
  232. else
  233. {
  234. if ((test_soc_demo_transaction = OslMalloc(sizeof(soc_demo_app_transaction_struct))) == NULL)
  235. {
  236.     #ifdef MMI_ON_HARDWARE_P
  237. kal_print("No memory");
  238.     #endif 
  239. en_soc_output_result(EN_SOC_NO_MEMORY, NULL, 0);
  240. return EN_SOC_NO_MEMORY;
  241. }
  242. else
  243. {
  244. memset(test_soc_demo_transaction, 0, sizeof(soc_demo_app_transaction_struct));
  245. if ((test_soc_demo_transaction->rcvd_buffer = OslMalloc(MAX_RCV_BUFFER_SIZE)) == NULL)
  246. {
  247.         #ifdef MMI_ON_HARDWARE_P
  248. kal_print("No memory");
  249.         #endif 
  250. en_soc_output_result(EN_SOC_NO_MEMORY, NULL, 0);
  251. return EN_SOC_NO_MEMORY;
  252. }
  253. else
  254. {
  255. if ((test_soc_demo_transaction->snd_buffer = OslMalloc(MAX_SND_BUFFER_SIZE)) == NULL)
  256. {
  257.             #ifdef MMI_ON_HARDWARE_P
  258. kal_print("No memory");
  259.             #endif 
  260. en_soc_output_result(EN_SOC_NO_MEMORY, NULL, 0);
  261. return EN_SOC_NO_MEMORY;
  262. }
  263. else
  264. {
  265. /* Set initial values to test_soc_demo_transaction */
  266. memset((kal_int8*) test_soc_demo_transaction->rcvd_buffer, 0, MAX_RCV_BUFFER_SIZE);
  267. memset((kal_int8*) test_soc_demo_transaction->snd_buffer, 0, MAX_SND_BUFFER_SIZE);
  269. test_soc_demo_transaction->soc_demo_app_id = app_id;
  270. test_soc_demo_transaction->nwt_acount_id = account_id;
  271. if (server_ip_address)
  272. {
  273. memcpy(test_soc_demo_transaction->server_ip_addr.addr, server_ip_address, 4);
  274. test_soc_demo_transaction->server_ip_addr.addr_len = 4;
  275. }
  276. test_soc_demo_transaction->url = (kal_int8*) url;
  277. test_soc_demo_transaction->url_len = url_len;
  278. test_soc_demo_transaction->snd_counter = 0;
  279. test_soc_demo_transaction->rcvd_counter = 0;
  280. test_soc_demo_transaction->callback = callback;
  281. if (echo_text)
  282. {
  283. if (echo_text_len > MAX_SND_BUFFER_SIZE)
  284. {
  285. memcpy(test_soc_demo_transaction->snd_buffer, echo_text, MAX_SND_BUFFER_SIZE);
  286. test_soc_demo_transaction->snd_data_len = MAX_SND_BUFFER_SIZE;
  287. }
  288. else
  289. {
  290. memcpy(test_soc_demo_transaction->snd_buffer, echo_text, echo_text_len);
  291. test_soc_demo_transaction->snd_data_len = echo_text_len;
  292. }
  294. OslMfree(echo_text);
  295. }
  296. if (test_en_soc_demo_app_create_socket() == KAL_FALSE)
  297. {
  298. return EN_SOC_NO_MEMORY;
  299. }
  300. else
  301. kal_prompt_trace(MOD_WAP,"_________________________ CREATE SOCKET OK");
  302. switch (app_id)
  303. {
  304. case HTTP:
  305. {
  306. test_soc_demo_transaction->state = HTTP_DNS_QUERY;
  307. return test_en_soc_demo_http_send_request();
  308. }
  309. default:
  310. {
  311. return EN_SOC_UNKNOWN_APP;
  312. }
  314. }
  315. }
  317. }
  318. }
  319. }
  320. }
  323. kal_bool test_en_soc_demo_app_create_socket()
  324. {
  325. /*----------------------------------------------------------------*/
  326. /* Local Variables   */
  327. /*----------------------------------------------------------------*/
  328. kal_uint8 val = 1;
  330. /*----------------------------------------------------------------*/
  331. /* Code Body   */
  332. /*----------------------------------------------------------------*/
  333. if (test_soc_demo_transaction)
  334. {
  335. test_soc_demo_transaction->state = SOC_CREATING;
  336. switch (test_soc_demo_transaction->soc_demo_app_id)
  337. {
  338. case HTTP:
  339. {
  340. test_soc_demo_transaction->socket_id = soc_create(PF_INET, SOCK_STREAM, 0, MOD_MMI, test_soc_demo_transaction->nwt_acount_id);
  341. if (test_soc_demo_transaction->socket_id >= 0)
  342. {
  343. if (soc_setsockopt(test_soc_demo_transaction->socket_id, SOC_NBIO, &val, sizeof(val)) < 0)
  344. {
  345.                 #ifdef MMI_ON_HARDWARE_P
  346. kal_print("Set socket to nonblock mode error !!");
  347.                 #endif 
  348. return KAL_FALSE;
  349. }
  350. val = SOC_READ | SOC_WRITE | SOC_CLOSE | SOC_CONNECT;
  351. if (soc_setsockopt(test_soc_demo_transaction->socket_id, SOC_ASYNC, &val, sizeof(val)) < 0)
  352. {
  353.                 #ifdef MMI_ON_HARDWARE_P
  354. kal_print("Set socket to nonblock mode error !!");
  355.                 #endif 
  356. return KAL_FALSE;
  357. }
  358. test_soc_demo_transaction->state = SOC_CREATED;
  359. return KAL_TRUE;
  360. }
  361. else
  362. {
  363. return KAL_FALSE;
  364. }
  365. break;
  366. }
  367. default:
  368. return KAL_FALSE;
  369. }
  370. }
  371. else
  372. {
  373. return KAL_FALSE;
  374. }
  375. }
  377. int test_en_soc_demo_http_send_request(void)
  378. {
  379. /*----------------------------------------------------------------*/
  380. /* Local Variables   */
  381. /*----------------------------------------------------------------*/
  383. /*----------------------------------------------------------------*/
  384. /* Code Body   */
  385. /*----------------------------------------------------------------*/
  386. if (test_soc_demo_transaction)
  387. {
  388. if (test_soc_demo_transaction->state == HTTP_DNS_QUERY &&
  389. (soc_demo_app_http_url_struct*) test_soc_demo_transaction->url_parsed_info == NULL)
  390. {
  391. kal_prompt_trace(MOD_WAP," test_en_soc_demo_http_send_request __________________________________");
  392. test_soc_demo_transaction->server_ip_addr.addr[0] = 10;
  393. test_soc_demo_transaction->server_ip_addr.addr[1] = 0;
  394. test_soc_demo_transaction->server_ip_addr.addr[2] = 0;
  395. test_soc_demo_transaction->server_ip_addr.addr[3] = 172;
  396. test_soc_demo_transaction->server_ip_addr.port = 80;
  398. test_soc_demo_transaction->rcvd_counter = 0;
  399. test_soc_demo_transaction->server_ip_addr.addr_len = 4;
  400. test_soc_demo_transaction->state = HTTP_TCP_CON_CREATING;
  401. test_en_soc_demo_http_send_request();
  404. }
  405. else if (test_soc_demo_transaction->state == HTTP_TCP_CON_CREATING)
  406. {
  407. kal_int8 ret;
  408. char CRLF[3] = {0x0d, 0x0a, 0x00};
  410. test_soc_demo_transaction->state = HTTP_TCP_CON_CREATED;
  411. test_soc_demo_transaction->snd_data_len=0;
  413. strcat(test_soc_demo_transaction->snd_buffer,"GET ");
  414. test_soc_demo_transaction->snd_data_len+=4;
  417. strcat((char*)test_soc_demo_transaction->snd_buffer,"http://61.135.159.21/cgi-bin/weather?024 ");
  418. test_soc_demo_transaction->snd_data_len+=41; 
  420. strcat((char*)test_soc_demo_transaction->snd_buffer,"HTTP/1.1");
  421. test_soc_demo_transaction->snd_data_len+=8; 
  423. strcat((char*)test_soc_demo_transaction->snd_buffer,CRLF);
  424. test_soc_demo_transaction->snd_data_len+=2;
  426. strcat((char*)test_soc_demo_transaction->snd_buffer,"Host: 10.0.0.172:80");
  427. test_soc_demo_transaction->snd_data_len+=19;
  429. strcat((char*)test_soc_demo_transaction->snd_buffer,CRLF);
  430. test_soc_demo_transaction->snd_data_len+=2; 
  433. strcat((char*)test_soc_demo_transaction->snd_buffer,"User-Agent: */*");
  434. test_soc_demo_transaction->snd_data_len+=15;
  437. strcat((char*)test_soc_demo_transaction->snd_buffer,CRLF);
  438. test_soc_demo_transaction->snd_data_len+=2;
  441. strcat((char*)test_soc_demo_transaction->snd_buffer,"Accept: */*");
  442. test_soc_demo_transaction->snd_data_len+=11;
  444. strcat((char*)test_soc_demo_transaction->snd_buffer,CRLF);
  445. test_soc_demo_transaction->snd_data_len+=2;
  447. strcat((char*)test_soc_demo_transaction->snd_buffer,"X-Online-Host: 61.135.159.21");
  448. test_soc_demo_transaction->snd_data_len+=28;
  450. strcat((char*)test_soc_demo_transaction->snd_buffer,CRLF);
  451. test_soc_demo_transaction->snd_data_len+=2; 
  454. strcat((char*)test_soc_demo_transaction->snd_buffer,"Connection: Keep-Alive");
  455. test_soc_demo_transaction->snd_data_len+=22;
  457. strcat((char*)test_soc_demo_transaction->snd_buffer,CRLF);
  458. test_soc_demo_transaction->snd_data_len+=2;
  461. strcat((char*)test_soc_demo_transaction->snd_buffer,CRLF);
  462. test_soc_demo_transaction->snd_data_len+=2; 
  466. kal_prompt_trace(MOD_WAP, "test_soc_demo_transaction->snd_buffer:n %s", test_soc_demo_transaction->snd_buffer);
  467. kal_prompt_trace(MOD_WAP, "test_soc_demo_transaction->snd_buffer:n %s", &test_soc_demo_transaction->snd_buffer[60]);
  468. kal_prompt_trace(MOD_WAP, "test_soc_demo_transaction->snd_buffer:n %s", &test_soc_demo_transaction->snd_buffer[120]);
  470. #ifdef MMI_ON_HARDWARE_P
  471. kal_prompt_trace(MOD_WAP, "___________________ Http connect to %d.%d,%d,%d and port: %d",
  472. test_soc_demo_transaction->server_ip_addr.addr[0],
  473. test_soc_demo_transaction->server_ip_addr.addr[1],
  474. test_soc_demo_transaction->server_ip_addr.addr[2],
  475. test_soc_demo_transaction->server_ip_addr.addr[3],
  476. test_soc_demo_transaction->server_ip_addr.port);
  477.    
  478. ret = soc_connect(test_soc_demo_transaction->socket_id, &test_soc_demo_transaction->server_ip_addr);
  479.  
  480. kal_prompt_trace(MOD_WAP, "___________________ Http connect result is %d", ret);
  481. #endif 
  482. if (ret == SOC_SUCCESS)
  483. {
  484. test_en_soc_demo_http_send_request();
  485. return EN_SOC_SUCCESS;
  486. }
  487. else if (ret == SOC_WOULDBLOCK)
  488. {
  489. SetProtocolEventHandler(test_em_soc_demo_app_socket_notify, MSG_ID_APP_SOC_NOTIFY_IND);
  490. return EN_SOC_SUCCESS;
  491. }
  492. else
  493. {
  494. if (ret == SOC_ERROR)
  495. {
  496. return EN_SOC_PEER_NOT_REACHABLE;
  497. }
  498. else
  499. {
  500. return EN_SOC_ERROR;
  501. }
  502. }
  503. }
  504. else if (test_soc_demo_transaction->state == HTTP_TCP_CON_CREATED || test_soc_demo_transaction->state == REQ_SEND_RETRY ||
  505.  test_soc_demo_transaction->state == REQ_SENDING)
  506. {
  507. kal_int32 ret;
  509. if (test_soc_demo_transaction->state != REQ_SENDING)
  510. {
  511. test_soc_demo_transaction->snd_counter = 0;
  512. }
  513. test_soc_demo_transaction->state = REQ_SENDING;
  514. #ifdef MMI_ON_HARDWARE_P
  515. kal_prompt_trace(MOD_WAP, "___________________ Http send request to %d.%d,%d,%d and port: %d",
  516. test_soc_demo_transaction->server_ip_addr.addr[0],
  517. test_soc_demo_transaction->server_ip_addr.addr[1],
  518. test_soc_demo_transaction->server_ip_addr.addr[2],
  519. test_soc_demo_transaction->server_ip_addr.addr[3],
  520. test_soc_demo_transaction->server_ip_addr.port);
  521. #endif /* MMI_ON_HARDWARE_P */ 
  522. ret = soc_send(
  523. test_soc_demo_transaction->socket_id,
  524. (kal_uint8*) (test_soc_demo_transaction->snd_buffer + test_soc_demo_transaction->snd_counter),
  525. (test_soc_demo_transaction->snd_data_len - test_soc_demo_transaction->snd_counter),
  526. 0);
  527. #ifdef MMI_ON_HARDWARE_P
  528. kal_prompt_trace(MOD_WAP, "___________________ Http send request result, sent_bytes:%d", ret);
  529. #endif 
  530. if (ret > 0)
  531. {
  532. if (ret == (kal_int32) test_soc_demo_transaction->snd_data_len)
  533. {
  534. test_soc_demo_transaction->state = REQ_SENT;
  535. test_soc_demo_transaction->post_retry_counter++;
  536. tst_em_soc_demo_app_start_timer(); /* wait for servwer's response */
  537. tst_en_soc_demo_tcp_app_recv_response();
  538. return EN_SOC_SUCCESS;
  539. }
  540. else
  541. {
  542. test_soc_demo_transaction->snd_counter += ret;
  543. return EN_SOC_SUCCESS;
  544. }
  545. }
  546. else
  547. {
  548. if (ret == SOC_WOULDBLOCK)
  549. {
  550. /* waits for socket notify */
  551. SetProtocolEventHandler(test_em_soc_demo_app_socket_notify, MSG_ID_APP_SOC_NOTIFY_IND);
  552. return EN_SOC_SUCCESS;
  553. }
  554. else
  555. {
  556. if (ret == SOC_ERROR)
  557. {
  558. return EN_SOC_PEER_NOT_REACHABLE;
  559. }
  560. else
  561. {
  562. return EN_SOC_ERROR;
  563. }
  564. }
  565. }
  566. }
  567. else
  568. {
  569. return EN_SOC_ERROR;
  570. }
  571. }
  572. else
  573. {
  574. return EN_SOC_ERROR;
  575. }
  576. }
  580. void test_em_soc_demo_app_socket_notify(void *inMsg)
  581. {
  582. /*----------------------------------------------------------------*/
  583. /* Local Variables   */
  584. /*----------------------------------------------------------------*/
  585. app_soc_notify_ind_struct *soc_notify = (app_soc_notify_ind_struct*) inMsg;
  587. /*----------------------------------------------------------------*/
  588. /* Code Body   */
  589. /*----------------------------------------------------------------*/
  590. kal_prompt_trace(MOD_WAP," entry the function test_em_soc_demo_app_socket_notify");
  592. if (!test_soc_demo_transaction)
  593. {
  594. return;
  595. }
  596. #ifdef MMI_ON_HARDWARE_P
  597. kal_prompt_trace(MOD_WAP, "___________________ Got socket notify, event_type:%d", soc_notify->event_type);
  598. #endif 
  599. switch (soc_notify->event_type)
  600. {
  601. case SOC_WRITE:
  602. {
  603. switch (test_soc_demo_transaction->soc_demo_app_id)
  604. {
  605. case HTTP:
  606. test_en_soc_demo_http_send_request();
  607. break;
  608. case DAYTIME:
  609. case ECHO:
  610. break;
  611. case TRACERT:
  612. break;
  613. }
  614. break;
  615. }
  616. case SOC_READ:
  617. {
  618. switch (test_soc_demo_transaction->soc_demo_app_id)
  619. {
  620. case HTTP:
  621. tst_en_soc_demo_tcp_app_recv_response();
  622. break;
  623. case DAYTIME:
  624. case ECHO:
  625. break;
  626. case TRACERT:
  627. if ( test_soc_demo_transaction->state != REQ_SENT)
  628. {
  629. }
  630. else
  631. {
  632. }
  633. break;
  634. }
  635. break;
  636. }
  637. case SOC_CONNECT:
  638. {
  639. if (test_soc_demo_transaction->soc_demo_app_id == HTTP)
  640. {
  641. if (soc_notify->result == KAL_TRUE)
  642. {
  643. test_soc_demo_transaction->state = HTTP_TCP_CON_CREATED;
  644. test_en_soc_demo_http_send_request();
  645. }
  646. else
  647. {
  648. kal_prompt_trace(MOD_WAP," SOC_CONNECT ____________________ ERROR");
  649. }
  650. }
  651. break;
  652. }
  653. case SOC_CLOSE:
  654. {
  655. kal_prompt_trace(MOD_WAP,"soc_demo_transaction->rcvd_counter:%d",test_soc_demo_transaction->rcvd_counter);
  656. kal_prompt_trace(MOD_WAP,"test_soc_demo_transaction->rcvd_buffer:n%s",test_soc_demo_transaction->rcvd_buffer);
  657. }
  658. default:
  659. break;
  660. }
  661. }
  663. void tst_em_soc_demo_app_start_timer(void)
  664. {
  665. /*----------------------------------------------------------------*/
  666. /* Local Variables   */
  667. /*----------------------------------------------------------------*/
  669. /*----------------------------------------------------------------*/
  670. /* Code Body   */
  671. /*----------------------------------------------------------------*/
  672. StartTimer(EM_GPRS_SOC_DEMO_APP_TIMER, SOC_DEMO_APP_POST_TIMEOUT, tst_em_soc_demo_app_timer_handler);
  674. }
  676. void tst_em_soc_demo_app_timer_handler(void)
  677. {
  678. /*----------------------------------------------------------------*/
  679. /* Local Variables   */
  680. /*----------------------------------------------------------------*/
  682. /*----------------------------------------------------------------*/
  683. /* Code Body   */
  684. /*----------------------------------------------------------------*/
  685. if (test_soc_demo_transaction->post_retry_counter < MAX_POST_RETRY_NUM)
  686. {
  687. test_soc_demo_transaction->state = REQ_SEND_RETRY;
  688. switch (test_soc_demo_transaction->soc_demo_app_id)
  689. {
  690. case HTTP:
  691. test_en_soc_demo_http_send_request();
  692. break;
  693. case DAYTIME:
  694. case ECHO:
  695. break;
  696. default:
  697. break;
  698. }
  699. }
  700. else
  701. {
  702. }
  703. }
  706. void tst_en_soc_demo_tcp_app_recv_response(void)
  707. {
  708. /*----------------------------------------------------------------*/
  709. /* Local Variables   */
  710. /*----------------------------------------------------------------*/
  711.    int i = 0;
  712. /*----------------------------------------------------------------*/
  713. /* Code Body   */
  714. /*----------------------------------------------------------------*/
  715. if (test_soc_demo_transaction && test_soc_demo_transaction->state < RSP_RCVD)
  716. {
  717.         int ret_val = 0;
  719.         test_soc_demo_transaction->state = RSP_RCVING;
  720. do{
  722.   ret_val = soc_recv(
  723.                     test_soc_demo_transaction->socket_id,
  724.                     (kal_uint8*) (test_soc_demo_transaction->rcvd_buffer + test_soc_demo_transaction->rcvd_counter),
  725.                     (MAX_RCV_BUFFER_SIZE - test_soc_demo_transaction->rcvd_counter),
  726.                     0);
  727.    test_soc_demo_transaction->rcvd_counter += ret_val;
  728.    
  729.  kal_prompt_trace(MOD_WAP,"tst_en_soc_demo_tcp_app_recv_response--ret_val[%d]",ret_val);
  730.  kal_prompt_trace(MOD_WAP," test_soc_demo_transaction->rcvd_counter [%d]", test_soc_demo_transaction->rcvd_counter );
  731. }while(ret_val>0);
  733. if (ret_val == SOC_WOULDBLOCK)
  734.    {
  735.   SetProtocolEventHandler(test_em_soc_demo_app_socket_notify, MSG_ID_APP_SOC_NOTIFY_IND);
  736.   test_soc_demo_transaction->rcvd_counter += 2;
  737.   return;
  738.   }
  739. else
  740. tst_en_soc_output_result(
  741.                 EN_SOC_SUCCESS,
  742.                 (char*)test_soc_demo_transaction->rcvd_buffer,
  743.                 test_soc_demo_transaction->rcvd_counter);
  744.     }
  745. }
  747. void tst_en_soc_show_output_string()
  748. {
  751.     U8 *guiBuffer, *info;
  752.     U8 showbuff[1000];
  753.     memset(showbuff,0,sizeof(showbuff));
  755.     /*----------------------------------------------------------------*/
  756.     /* Code Body                                                      */
  757.     /*----------------------------------------------------------------*/
  758.     guiBuffer = GetCurrGuiBuffer(ORGANIZER_SOCKET_SHOW);
  759.     EntryNewScreen(ORGANIZER_SOCKET_SHOW, NULL,  tst_en_soc_show_output_string, NULL);
  763.      AnsiiToUnicodeString((S8 *)showbuff,(S8 *)test_soc_demo_transaction->rcvd_buffer);
  765.      kal_prompt_trace(MOD_WAP,"entry tst_en_soc_show_output_string");
  766.      kal_prompt_trace(MOD_WAP,"the vaule of showbuff is %s",test_soc_demo_transaction->rcvd_buffer);
  767.      kal_prompt_trace(MOD_WAP,"the length of showbuff is %d",test_soc_demo_transaction->rcvd_counter);
  770.     ShowCategory74Screen(
  771.         0,
  772.         0,
  773.         0,
  774.         0,
  775.         STR_GLOBAL_BACK,
  776.         IMG_GLOBAL_BACK,
  777.         (PU8) showbuff,
  778.         test_soc_demo_transaction->rcvd_counter * 2,
  779.         guiBuffer);
  780.     
  781.     SetKeyHandler(GoBackHistory, KEY_LEFT_ARROW, KEY_EVENT_DOWN);
  782.     SetRightSoftkeyFunction(GoBackHistory, KEY_EVENT_UP);
  786. }
  789. void tst_en_soc_output_result(int ret, char *out_str, int len)
  790. {
  791. /*----------------------------------------------------------------*/
  792. /* Local Variables   */
  793. /*----------------------------------------------------------------*/
  795. /*----------------------------------------------------------------*/
  796. /* Code Body   */
  797. /*----------------------------------------------------------------*/
  800. if (test_soc_demo_transaction)
  801. {
  802. #ifdef MMI_ON_HARDWARE_P
  803. kal_prompt_trace(MOD_WAP, "soc demp app result: %d", ret);
  804. kal_prompt_trace(MOD_WAP, "the value of out_str is %sn",out_str);
  807. kal_prompt_trace(MOD_WAP,"test_soc_demo_transaction 1 is %sn",(test_soc_demo_transaction->rcvd_buffer + 100));
  808. kal_prompt_trace(MOD_WAP,"test_soc_demo_transaction 2 is %sn",(test_soc_demo_transaction->rcvd_buffer + 200));
  810. kal_prompt_trace(MOD_WAP,"test_soc_demo_transaction 3 is %sn",(test_soc_demo_transaction->rcvd_buffer + 300));
  811. kal_prompt_trace(MOD_WAP,"test_soc_demo_transaction 4 is %sn",(test_soc_demo_transaction->rcvd_buffer + 400));
  813. kal_prompt_trace(MOD_WAP,"test_soc_demo_transaction 5 is %sn",(test_soc_demo_transaction->rcvd_buffer + 500));
  814. kal_prompt_trace(MOD_WAP,"test_soc_demo_transaction 6 is %sn",(test_soc_demo_transaction->rcvd_buffer + 600));
  816. kal_prompt_trace(MOD_WAP,"test_soc_demo_transaction 7 is %sn",(test_soc_demo_transaction->rcvd_buffer + 700));
  817. kal_prompt_trace(MOD_WAP,"test_soc_demo_transaction 8 is %sn",(test_soc_demo_transaction->rcvd_buffer + 800));
  820. // tst_en_soc_show_output_string();
  822. #endif 
  823. if(test_soc_demo_transaction->callback != NULL)//wangdecheng add
  824. {
  825. test_soc_demo_transaction->callback(test_soc_demo_transaction->soc_demo_app_id, ret, out_str, len);
  826. }
  827. if (ret != EN_SOC_SUCCESS)
  828. {
  829. test_soc_demo_transaction->state = SOC_CLOSING;
  830. }
  831. tst_mmi_soc_demo_app_request_abort();
  832. }
  833. }
  835. int tst_mmi_soc_demo_app_request_abort(void)
  836. {
  837. /*----------------------------------------------------------------*/
  838. /* Local Variables   */
  839. /*----------------------------------------------------------------*/
  841. /*----------------------------------------------------------------*/
  842. /* Code Body   */
  843. /*----------------------------------------------------------------*/
  844. if (test_soc_demo_transaction)
  845. {
  846. if (test_soc_demo_transaction->socket_id >= 0)
  847. {
  848.     #ifdef MMI_ON_HARDWARE_P
  849. ilm_struct *ilm_send = NULL;
  850.     #endif 
  851.     #ifndef MMI_ON_WIN32
  852. soc_close(test_soc_demo_transaction->socket_id);
  853. soc_close_nwk_account_by_id(MOD_MMI,test_soc_demo_transaction->nwt_acount_id);
  854.     #endif
  855.     #ifdef MMI_ON_HARDWARE_P
  856. /* close socket and disconnect bearer here */
  857. ilm_send = allocate_ilm(MOD_MMI);
  858. ilm_send->msg_id = MSG_ID_APP_SOC_DEACTIVATE_REQ;
  859. ilm_send->peer_buff_ptr = NULL;
  860. ilm_send->local_para_ptr = NULL;
  861. SEND_ILM(MOD_MMI, MOD_SOC, SOC_APP_SAP, ilm_send);
  862.     #endif /* MMI_ON_HARDWARE_P */ 
  863. }
  864. test_soc_demo_transaction->post_retry_counter = 0;
  865. if (test_soc_demo_transaction->url)
  866. {
  867. OslMfree(test_soc_demo_transaction->url);
  868. }
  869. /* We have to free recv_buffer. */
  870. if (test_soc_demo_transaction->rcvd_buffer)
  871. {
  872. OslMfree(test_soc_demo_transaction->rcvd_buffer);
  873. }
  874. if (test_soc_demo_transaction->snd_buffer)
  875. {
  876. OslMfree(test_soc_demo_transaction->snd_buffer);
  877. }
  878. if (test_soc_demo_transaction->url_parsed_info)
  879. {
  880. if (test_soc_demo_transaction->url_parsed_info->host_name)
  881. {
  882. OslMfree(test_soc_demo_transaction->url_parsed_info->host_name);
  883. }
  884. if (test_soc_demo_transaction->url_parsed_info->url_link)
  885. {
  886. OslMfree(test_soc_demo_transaction->url_parsed_info->url_link);
  887. }
  888. OslMfree(test_soc_demo_transaction->url_parsed_info);
  889. }
  890. tst_em_soc_demo_app_stop_timer();
  891. OslMfree(test_soc_demo_transaction);
  892. test_soc_demo_transaction = NULL;
  893.  kal_prompt_trace(MOD_WAP,"###########################Transaction have been destroy!!");
  894.  
  895. }
  896. return 0;
  897. }
  899. void tst_em_soc_demo_app_stop_timer(void)
  900. {
  901. /*----------------------------------------------------------------*/
  902. /* Local Variables   */
  903. /*----------------------------------------------------------------*/
  905. /*----------------------------------------------------------------*/
  906. /* Code Body   */
  907. /*----------------------------------------------------------------*/
  908. StopTimer(EM_GPRS_SOC_DEMO_APP_TIMER);
  909. }