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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 多媒体 > IP电话/视频会议 > 查看源码
callcb.cpp
资源名称：h323.zip　[点击查看]
上传用户：hnnddl
上传日期：2007-01-06
资源大小：3580k
文件大小：13k
源码类别：

IP电话/视频会议

开发平台：

WINDOWS

callcb.cpp：源码内容
  1. /*
  2.  * $Revision: 1.8 $
  3.  * $Date: 1998/11/03 18:32:54 $
  4.  */
  6. ////////////////////////////////////////////////////////////////
  7. //               Copyright (c) 1996-98 Lucent Technologies    //
  8. //                       All Rights Reserved                  //
  9. //                                                            //
  10. //                       THIS IS UNPUBLISHED                  //
  11. //                       PROPRIETARY SOURCE                   //
  12. //                   CODE OF Lucent Technologies              //
  13. // AND elemedia   //
  14. //                                                            //
  15. ////////////////////////////////////////////////////////////////
  16. //
  17. ////////////////////////////////////////////////////////////////
  18. // Example programs are provided soley to demonstrate one     //
  19. // possible use of the stack libraries and are included for   //
  20. // instructional purposes only.  You are free to use, modify  //
  21. // and/or redistribute any portion of code in the example     //
  22. // programs.  However, such examples are not intended to      //
  23. // represent production quality code.                         //
  24. //                                                            //
  25. // THE COPYRIGHT HOLDERS PROVIDE THESE EXAMPLE PROGRAMS       //
  26. // "AS IS" WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESSED     //
  27. // OR IMPLIED, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED     //
  28. // WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A            //
  29. // PARTICULAR PURPOSE.                                        //
  30. ////////////////////////////////////////////////////////////////
  32. #include "api/h225csp.h"
  33. #include "api/h245sig.h"
  34. #include "api/h4501suppserv.h"
  36. #include "exchange.h"
  37. #include "call.h"
  38. #include "msg.h"
  39. #include <assert.h>
  41. #if (defined(ENABLE_BENCHMARKS))
  42. #include "perf.h"
  43. #endif
  45. void 
  46. H323Call::QueueIt(unsigned int arg1, unsigned long arg2)
  47. {
  48. USER_MESSAGE msg;
  50. msg.message = PROT_CALL_MSG;
  51. msg.wParam = arg1;
  52. msg.lParam = arg2;
  54. QueueMessage(&msg);
  55. }
  57. void 
  58. H323Call::NotifyEvent(int old_state, int new_state, 
  59. Q931Event* event, H225CSUUIE* ie)
  60. {
  61. #if (defined(ENABLE_BENCHMARKS))
  62. UPDATE_STACK_SIZE();
  63. #endif
  65. LOG("H323Call::NotifyEvent - ");
  66. Q931Evt *msg;
  67. UUIEItemFastStartList *fslist;
  68. int incoming_fs_present = 0;
  70. LOG("old_state = %d, new_state = %d,"
  71. " event = %p, ie = %pn",  
  72. old_state, new_state, event, ie);
  74. msg = new Q931Evt;
  76. msg->old_state = old_state;
  77. msg->new_state = new_state;
  79. if (event)
  80. {
  81. msg->event_type = event->GetEventType();
  83. LOG("event type = %dn", msg->event_type);
  85. if (event->GetEventType() == Q931EVENT_MESSAGE)
  86. {
  87. Q931Message *message = (Q931Message *)event;
  89. if (message)
  90. {
  91. int type;
  93. message->GetType(type);
  94. LOG("Got Message Type 0x%x, uuie = 0x%lxn", type, ie);
  96. msg->message = new Q931Message(type);
  97. *(msg->message) = *message;
  99. if (ie)
  100. {
  101. switch(type)
  102. {
  103. case MESSAGE_SETUP:
  104. msg->ie = new H225CSSetupUUIE(*this);
  105. *((H225CSSetupUUIE*)msg->ie) = 
  106. *(H225CSSetupUUIE*)ie;
  107. // Check if faststart is set.
  108. if (((H225CSSetupUUIE*)ie)->IsFastStartPresent())
  109. {
  110. incoming_fs_present = 1;
  111. fslist = (UUIEItemFastStartList *)
  112. (H225CSSetupUUIE*)ie;
  113. }
  114. break;
  115. case MESSAGE_ALERTING:
  116. msg->ie = new H225CSAlertingUUIE(*this);
  117. *((H225CSAlertingUUIE*)msg->ie) = 
  118. *(H225CSAlertingUUIE*)ie;
  119. // Check if faststart is set.
  120. if (((H225CSAlertingUUIE*)ie)->IsFastStartPresent())
  121. {
  122. incoming_fs_present = 1;
  123. fslist = (UUIEItemFastStartList *)
  124. (H225CSAlertingUUIE*)ie;
  125. }
  126. break;
  127. case MESSAGE_RELEASE_COMPLETE:
  128. msg->ie = new H225CSReleaseCompleteUUIE(*this);
  129. *((H225CSReleaseCompleteUUIE*)msg->ie) = 
  130. *(H225CSReleaseCompleteUUIE*)ie;
  131. break;
  132. case MESSAGE_CALL_PROCEEDING:
  133. msg->ie = new H225CSCallProceedingUUIE(*this);
  134. *((H225CSCallProceedingUUIE*)msg->ie) = 
  135. *(H225CSCallProceedingUUIE*)ie;
  136. // Check if faststart is set.
  137. if (((H225CSCallProceedingUUIE*)ie)->IsFastStartPresent())
  138. {
  139. incoming_fs_present = 1;
  140. fslist = (UUIEItemFastStartList *)
  141. (H225CSCallProceedingUUIE*)ie;
  142. }
  143. break;
  144. case MESSAGE_CONNECT:
  145. msg->ie = new H225CSConnectUUIE(*this);
  146. *((H225CSConnectUUIE*)msg->ie) = 
  147. *(H225CSConnectUUIE*)ie;
  148. // Check if faststart is set.
  149. if (((H225CSConnectUUIE*)ie)->IsFastStartPresent())
  150. {
  151. incoming_fs_present = 1;
  152. fslist = (UUIEItemFastStartList *)
  153. (H225CSConnectUUIE*)ie;
  154. }
  155. break;
  156. case MESSAGE_Q932_FACILITY:
  157. {
  158. msg->ie = new H225CSFacilityUUIE(*this);
  159. *((H225CSFacilityUUIE*)msg->ie) =
  160. *(H225CSFacilityUUIE*)ie;
  161. }
  162. break;
  164. default:
  166. break;
  167. }
  168. }
  169. else
  170. {
  171. msg->ie = NULL;
  172. }
  173. }
  174. }
  175. else if (event->GetEventType() == Q931EVENT_ERROR)
  176. {
  177. msg->err = new Q931Error(0);
  179. *(msg->err) = *(Q931Error *)event;
  180. }
  181. else
  182. {
  183. assert(0);
  184. }
  185. }
  187. if (do_faststart && incoming_fs_present)
  188. {
  189. if (is_outgoing_call && faststart_state == FAST_START_STATE_PENDING)
  190. {
  191. LOG("interpreting a faststart reply messagen");
  192. if (InterpretFastStartReply((UUIEItemFastStartList *) fslist) == 0)
  193. {
  194. faststart_state = FAST_START_STATE_ENABLED;
  195. audio_session_flag = 1;
  196. #if defined (ENABLE_BENCHMARKS)
  197. get_current_time(end_sec,end_msec);
  198. #endif
  199. StartAudio();
  201. }
  202. else
  203. {
  204. LOG("ERROR, interpreting the faststart reply messagen");
  205. }
  206. }
  207. else
  208. {
  209. LOG("Creating a faststart reply messagen");
  210. if (InitFastStartReply((H225CSSetupUUIE  *)ie) == 0)
  211. {
  212. faststart_state = FAST_START_STATE_PENDING;
  213. }
  214. else
  215. {
  216. LOG("ERROR, creating a faststart reply messagen");
  217. }
  218. }
  219. LOG("faststart state= %dn", faststart_state);
  220. }
  222. QueueIt(CB_Q931_EVENT,(unsigned long)msg);
  223. }
  225. // H.245 callbacks.
  228. void 
  229. H323Call::NotifyMSDError(int error)
  230.  {
  231. LOG("H323Call::NotifyMSDError");
  232. LOG("error = %dn", error);
  233. MSDError *msg;
  235. msg = new MSDError;
  236. msg->error = error;
  239. QueueIt(CB_MSD_ERROR,(unsigned long)msg);
  240. }
  242. void 
  243. H323Call::NotifyMSDConfirm(int decision)
  244. {
  245. #if (defined(ENABLE_BENCHMARKS))
  246. UPDATE_STACK_SIZE();
  247. #endif
  249. LOG("H323Call::NotifyMSDConfirm");
  250. LOG("decision = %dn", decision);
  251. MSDConfirm *msg;
  253. msg = new MSDConfirm;
  254. msg->decision = decision;
  256. QueueIt(CB_MSD_CONFIRM,(unsigned long)msg);
  257. }
  259. void 
  260. H323Call::NotifyRemoteTermCaps(H245SigMuxCap *mux_cap,
  261. H245SigCapTable *cap_table,
  262. H245SigCapDescs *cap_descriptors)
  263. {
  264. #if (defined(ENABLE_BENCHMARKS))
  265. UPDATE_STACK_SIZE();
  266. #endif
  268. LOG("H323Call::NotifyRemoteTermCaps");
  269. RemoteTermCaps *msg;
  271. msg = new RemoteTermCaps;
  274. if (mux_cap)
  275. {
  276. msg->mux_cap = &msg->_h225_mux_cap;
  277. msg->_h225_mux_cap = *(H245SigH225Cap*)mux_cap;
  278. }
  280. if (cap_table)
  281. {
  282. msg->cap_table = &(msg->_cap_table);
  283. *(msg->cap_table) = *cap_table;
  284. }
  286. if (cap_descriptors)
  287. {
  288. msg->cap_desc = &(msg->_cap_desc);
  289. *(msg->cap_desc) = *cap_descriptors;
  290. }
  293. QueueIt(CB_REMOTE_TERM_CAPS,(unsigned long)msg);
  294. }
  296. void 
  297. H323Call::NotifyTermCapsAck()
  298. {
  299. #if (defined(ENABLE_BENCHMARKS))
  300. UPDATE_STACK_SIZE();
  301. #endif
  303. TermCapsAck *msg;
  305. LOG("H323Call::NotifyTermCapsAck");
  307. msg = new TermCapsAck;
  308. QueueIt(CB_TERM_CAPS_ACK,(unsigned int) msg);
  309. }
  311. void 
  312. H323Call::NotifyTermCapsReject(int cause, boolean exeeded_type,  
  313. int max_entry, int direction)
  314. {
  315. #if (defined(ENABLE_BENCHMARKS))
  316. UPDATE_STACK_SIZE();
  317. #endif
  319. LOG("H323Call::NotifyTermCapsReject");
  320. LOG("cause = %d, direction = %dn", cause, direction);
  321. TermCapsReject *msg;
  323. msg = new TermCapsReject;
  324. msg->cause = cause;
  325. msg->direction = direction;
  326. QueueIt(CB_TERM_CAPS_REJECT,(unsigned long)msg);
  327. }
  329. void 
  330. H323Call::NotifyOutLCError(int lc_num, int errorCode)
  331. {
  332. #if (defined(ENABLE_BENCHMARKS))
  333. UPDATE_STACK_SIZE();
  334. #endif
  336. LOG("H323Call::NotifyOutLCError");
  337. LOG("lc_num = %dn, errorCode = %dn", lc_num, errorCode);
  338. LCError *msg;
  340. msg = new LCError;
  341. msg->lc_num = lc_num;
  342. msg->error = errorCode;
  343. QueueIt(CB_OUT_LC_ERROR,(unsigned long)msg);
  344. }
  346. void 
  347. H323Call::NotifyInLCError(int lc_num, int error_code)
  348. {
  349. #if (defined(ENABLE_BENCHMARKS))
  350. UPDATE_STACK_SIZE();
  351. #endif
  353. LOG("H323Call::NotifyInLCError");
  354. LOG("lc_num = %dn errorCode = %dn", lc_num, error_code);
  355. LCError *msg;
  357. msg = new LCError;
  358. msg->lc_num = lc_num;
  359. msg->error = error_code;
  360. QueueIt(CB_IN_LC_ERROR,(unsigned long)msg);
  362. }
  364. void 
  365. H323Call::NotifyCommand(H245SigCommand &cmd)
  366. {
  367. #if (defined(ENABLE_BENCHMARKS))
  368. UPDATE_STACK_SIZE();
  369. #endif
  371. LOG("H323Call::NotifyCommandn");
  373. int type;
  374. cmd.GetCommandType(type);
  375. LOG("command type = %dn", type);
  377. H245CMD *msg;
  379. msg = new H245CMD;
  380. H245SigCommand::Factory(msg->cmd, type);
  382. *(msg->cmd) = cmd;
  384. QueueIt(CB_NOTIFY_CMD, (unsigned long)msg);
  385. }
  387. void 
  388. H323Call::NotifyIndication(H245SigIndication &ind)
  389. {
  390. #if (defined(ENABLE_BENCHMARKS))
  391. UPDATE_STACK_SIZE();
  392. #endif
  394. LOG("H323Call::NotifyIndicationn");
  396. int type;
  397. ind.GetIndicationType(type);
  398. LOG("indication type = %dn", type);
  400. H245IND *msg;
  402. msg = new H245IND;
  403. H245SigIndication::Factory(msg->ind, type);
  405. *(msg->ind) = ind;
  407. QueueIt(CB_NOTIFY_IND, (unsigned long)msg);
  408. }
  410. void 
  411. H323Call::NotifyOpenLCReq( int lc_num, unsigned short port_number,
  412. H245SigDataType& data_type, 
  413. H245SigMuxParams& lc_mux_params)
  414. {
  415. #if (defined(ENABLE_BENCHMARKS))
  416. UPDATE_STACK_SIZE();
  417. #endif
  419. LOG("H323Call::NotifyOpenLCReq");
  420. LOG("lc_num = %d, port = %dn", lc_num, port_number);
  421. OLCReq *msg;
  422. int type, captype, capsubtype;
  424. msg = new OLCReq;
  425. msg->port = port_number;
  426. msg->lc_num = lc_num;
  428. data_type.GetType(type,captype,capsubtype);
  429. switch(type)
  430. {
  431. case DT_AUDIO:
  432. msg->data_type = &msg->aud;
  433. msg->aud = *(H245SigAudDataType*)&data_type;
  434. break;
  435. case DT_VIDEO:
  436. msg->data_type = &msg->vid;
  437. msg->vid = *(H245SigVidDataType*)&data_type;
  438. break;
  439. }
  441. msg->h225_params = *(H245SigH225Params*)&lc_mux_params;
  442. msg->mux_params = &(msg->h225_params);
  444. QueueIt(CB_OLC_REQUEST,(unsigned long)msg);
  445. }
  447. void 
  448. H323Call::NotifyOpenLCReject(int lc_num, int reason)
  449. {
  450. #if (defined(ENABLE_BENCHMARKS))
  451. UPDATE_STACK_SIZE();
  452. #endif
  454. LOG("H323Call::NotifyOpenLCReject");
  455. LOG("lc_num = %d, reason = %dn", lc_num, reason);
  456. OLCReject *msg;
  458. msg = new OLCReject;
  459. msg->lc_num = lc_num;
  460. msg->reason = reason;
  462. QueueIt(CB_OLC_REJECT,(unsigned long)msg);
  463. }
  465. void 
  466. H323Call::NotifyOpenLCAck(int lc_num,
  467. H245SigH225AckParams *h225_lc_ack_params)
  468. {
  469. #if (defined(ENABLE_BENCHMARKS))
  470. UPDATE_STACK_SIZE();
  471. #endif
  473. LOG("H323Call::NotifyOpenLCAck");
  474. LOG("lc_num = %dn", lc_num);
  475. OLCAck *msg;
  477. msg = new OLCAck;
  478. msg->lc_num = lc_num;
  479. msg->ack_params = &msg->_ack_params;
  480. msg->_ack_params = *h225_lc_ack_params;
  482. QueueIt(CB_OLC_ACK,(unsigned long)msg);
  483. }
  485. void 
  486. H323Call::NotifyCloseOutLCReq(int lc_num)
  487. {
  488. #if (defined(ENABLE_BENCHMARKS))
  489. UPDATE_STACK_SIZE();
  490. #endif
  492. LOG("H323Call::NotifyCloseOutLCReq");
  493. LOG("lc_num = %dn", lc_num);
  494. CloseXXX *msg;
  496. msg = new CloseXXX;
  497. msg->lc_num = lc_num;
  499. QueueIt(CB_CLOSE_OUT_LC_REQUEST,(unsigned long)msg);
  500. }
  502. void 
  503. H323Call::NotifyCloseOutLCAck(int lc_num)
  504. {
  505. #if (defined(ENABLE_BENCHMARKS))
  506. UPDATE_STACK_SIZE();
  507. #endif
  509. LOG("H323Call::NotifyCloseOutLCAck");
  510. LOG("lc_num = %dn", lc_num);
  511. CloseXXX *msg;
  513. msg = new CloseXXX;
  514. msg->lc_num = lc_num;
  516. QueueIt(CB_CLOSE_OUT_LC_ACK,(unsigned long)msg);
  517. }
  519. void 
  520. H323Call::NotifyCloseInLC(int lc_num)
  521. {
  522. #if (defined(ENABLE_BENCHMARKS))
  523. UPDATE_STACK_SIZE();
  524. #endif
  526. LOG("H323Call::NotifyCloseInLC");
  527. LOG("lc_num = %dn", lc_num);
  528. CloseXXX *msg;
  530. msg = new CloseXXX;
  531. msg->lc_num = lc_num;
  532. QueueIt(CB_CLOSE_IN_LC,(unsigned long)msg);
  533. }
  535. void 
  536. H323Call::NotifyCloseInLCAck(int lc_num)
  537. {
  538. #if (defined(ENABLE_BENCHMARKS))
  539. UPDATE_STACK_SIZE();
  540. #endif
  542. LOG("H323Call::NotifyCloseInLCAck");
  543. LOG("lc_num = %dn", lc_num);
  544. CloseXXX *msg;
  546. msg = new CloseXXX;
  547. msg->lc_num = lc_num;
  548. QueueIt(CB_CLOSE_IN_LC_ACK,(unsigned long)msg);
  549. }
  551. void 
  552. H323Call::NotifyCloseInLCReject(int lc_num)
  553. {
  554. #if (defined(ENABLE_BENCHMARKS))
  555. UPDATE_STACK_SIZE();
  556. #endif
  558. LOG("H323Call::NotifyCloseInLCReject");
  559. LOG("lc_num = %dn", lc_num);
  560. CloseXXX *msg;
  562. msg = new CloseXXX;
  563. msg->lc_num = lc_num;
  564. QueueIt(CB_CLOSE_IN_LC_REJECT,(unsigned long)msg);
  565. }
  567. void
  568. H323Call::NotifyConfRequest(H245SigConfRequest &req)
  569. {
  570. #if (defined(ENABLE_BENCHMARKS))
  571. UPDATE_STACK_SIZE();
  572. #endif
  574. LOG("H323Call::NotifyConfRequestn");
  576. ConfRequest *msg;
  578. msg = new ConfRequest;
  580. msg->req = req;
  582. QueueIt(CB_CONF_REQ,(unsigned long)msg);
  583. }
  585. void
  586. H323Call::NotifyConfResponse(H245SigConfResponse &resp)
  587. {
  588. #if (defined(ENABLE_BENCHMARKS))
  589. UPDATE_STACK_SIZE();
  590. #endif
  592. LOG("H323Call::NotifyConfResponsen");
  594. ConfResponse *msg;
  596. msg = new ConfResponse;
  598. msg->resp = resp;
  600. QueueIt(CB_CONF_RESP,(unsigned long)msg);
  601. }