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

源码开发语言/平台
当前位置：首页 > 源码/资料 > Windows编程 > 通讯编程 > 查看源码
p802_15_4transac.cc
资源名称：ns-allinone-2.33.tar.gz　[点击查看]
上传用户：rrhhcc
上传日期：2015-12-11
资源大小：54129k
文件大小：11k
源码类别：

通讯编程

开发平台：

Visual C++

p802_15_4transac.cc：源码内容
  1. /********************************************/
  2. /*     NS2 Simulator for IEEE 802.15.4      */
  3. /*           (per P802.15.4/D18)            */
  4. /*------------------------------------------*/
  5. /* by:        Jianliang Zheng               */
  6. /*        (zheng@ee.ccny.cuny.edu)          */
  7. /*              Myung J. Lee                */
  8. /*          (lee@ccny.cuny.edu)             */
  9. /*        ~~~~~~~~~~~~~~~~~~~~~~~~~         */
  10. /*           SAIT-CUNY Joint Lab            */
  11. /********************************************/
  13. // File:  p802_15_4transac.cc
  14. // Mode:  C++; c-basic-offset:8; tab-width:8; indent-tabs-mode:t
  16. // $Header: /cvsroot/nsnam/ns-2/wpan/p802_15_4transac.cc,v 1.2 2005/07/13 03:51:34 tomh Exp $
  18. /*
  19.  * Copyright (c) 2003-2004 Samsung Advanced Institute of Technology and
  20.  * The City University of New York. All rights reserved.
  21.  *
  22.  * Redistribution and use in source and binary forms, with or without
  23.  * modification, are permitted provided that the following conditions
  24.  * are met:
  25.  * 1. Redistributions of source code must retain the above copyright
  26.  *    notice, this list of conditions and the following disclaimer.
  27.  * 2. Redistributions in binary form must reproduce the above copyright
  28.  *    notice, this list of conditions and the following disclaimer in the
  29.  *    documentation and/or other materials provided with the distribution.
  30.  * 3. All advertising materials mentioning features or use of this software
  31.  *    must display the following acknowledgement:
  32.  * This product includes software developed by the Joint Lab of Samsung 
  33.  *      Advanced Institute of Technology and The City University of New York.
  34.  * 4. Neither the name of Samsung Advanced Institute of Technology nor of 
  35.  *    The City University of New York may be used to endorse or promote 
  36.  *    products derived from this software without specific prior written 
  37.  *    permission.
  38.  *
  39.  * THIS SOFTWARE IS PROVIDED BY THE JOINT LAB OF SAMSUNG ADVANCED INSTITUTE
  40.  * OF TECHNOLOGY AND THE CITY UNIVERSITY OF NEW YORK ``AS IS'' AND ANY EXPRESS 
  41.  * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES 
  42.  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN 
  43.  * NO EVENT SHALL SAMSUNG ADVANCED INSTITUTE OR THE CITY UNIVERSITY OF NEW YORK 
  44.  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR 
  45.  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE 
  46.  * GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 
  47.  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 
  48.  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT 
  49.  * OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  50.  */
  53. #include <scheduler.h>
  54. #include "p802_15_4transac.h"
  55. #include "p802_15_4pkt.h"
  58. int addDeviceLink(DEVICELINK **deviceLink1, DEVICELINK **deviceLink2, IE3ADDR addr, UINT_8 cap)
  59. {
  60. DEVICELINK *tmp;
  61. if(*deviceLink2 == NULL) //not exist yet
  62. {
  63. *deviceLink2 = new DEVICELINK(addr,cap);
  64. if (*deviceLink2 == NULL) return 1;
  65. *deviceLink1 = *deviceLink2;
  66. }
  67. else
  68. {
  69. tmp=new DEVICELINK(addr,cap);
  70. if (tmp == NULL) return 1;
  71. tmp->last = *deviceLink2;
  72. (*deviceLink2)->next = tmp;
  73. *deviceLink2 = tmp;
  74. }
  75. return 0;
  76. }
  78. int updateDeviceLink(int oper, DEVICELINK **deviceLink1, DEVICELINK **deviceLink2, IE3ADDR addr)
  79. {
  80. DEVICELINK *tmp;
  81. int rt;
  83. rt = 1;
  85. tmp = *deviceLink1;
  86. while(tmp != NULL)
  87. {
  88. if(tmp->addr64 == addr)
  89. {
  90. if (oper == tr_oper_del) //delete an element
  91. {
  92. if(tmp->last != NULL)
  93. {
  94. tmp->last->next = tmp->next;
  95. if(tmp->next != NULL)
  96. tmp->next->last = tmp->last;
  97. else
  98. *deviceLink2 = tmp->last;
  99. }
  100. else if (tmp->next != NULL)
  101. {
  102. *deviceLink1 = tmp->next;
  103. tmp->next->last = NULL;
  104. }
  105. else
  106. {
  107. *deviceLink1 = NULL;
  108. *deviceLink2 = NULL;
  109. }
  110. delete tmp;
  111. }
  112. rt = 0;
  113. break;
  114. }
  115. tmp = tmp->next;
  116. }
  117. return rt;
  118. }
  120. int numberDeviceLink(DEVICELINK **deviceLink1)
  121. {
  122. DEVICELINK *tmp;
  123. int num;
  125. num = 0;
  126. tmp = *deviceLink1;
  127. while(tmp != NULL)
  128. {
  129. num++;
  130. tmp = tmp->next;
  131. }
  132. return num;
  133. }
  135. int chkAddDeviceLink(DEVICELINK **deviceLink1, DEVICELINK **deviceLink2, IE3ADDR addr, UINT_8 cap)
  136. {
  137.         int i;
  139.         i = updateDeviceLink(tr_oper_est, deviceLink1, deviceLink2, addr);
  140.         if (i == 0) return 1;
  141.         i = addDeviceLink(deviceLink1, deviceLink2, addr, cap);
  142.         if (i == 0) return 0;
  143.         else return 2;
  144. }
  146. void emptyDeviceLink(DEVICELINK **deviceLink1, DEVICELINK **deviceLink2)
  147. {
  148. DEVICELINK *tmp, *tmp2;
  150. if(*deviceLink1 != NULL)
  151. {
  152. tmp = *deviceLink1;
  153. while(tmp != NULL)
  154. {
  155. tmp2 = tmp;
  156. tmp = tmp->next;
  157. delete tmp2;
  158. }
  159. *deviceLink1 = NULL;
  160. }
  161. *deviceLink2 = *deviceLink1;
  162. }
  164. void dumpDeviceLink(DEVICELINK *deviceLink1, IE3ADDR coorAddr)
  165. {
  166. DEVICELINK *tmp;
  167. int i;
  169. fprintf(stdout, "[%.2f] --- dump associated device list (by coordinator %d) ---n", Scheduler::instance().clock(), coorAddr);
  170. tmp = deviceLink1;
  171. i = 1;
  172. while(tmp != NULL)
  173. {
  174. fprintf(stdout, "t%d:taddress = 0x%xn", i,tmp->addr64);
  175. tmp = tmp->next;
  176. i++;
  177. }
  178. }
  180. //--------------------------------------------------------------------------------------
  182. void purgeTransacLink(TRANSACLINK **transacLink1, TRANSACLINK **transacLink2)
  183. {
  184. //purge expired transactions
  185. TRANSACLINK *tmp,*tmp2;
  187. tmp = *transacLink1;
  188. while(tmp != NULL)
  189. {
  190. if (CURRENT_TIME > tmp->expTime)
  191. {
  192. tmp2 = tmp;
  193. if (tmp->next != NULL)
  194. tmp = tmp->next->next;
  195. else
  196. tmp = NULL;
  197. //--- delete the transaction ---
  198. //don't try to call updateTransacLink() -- to avoid re-entries of functions
  199. if(tmp2->last != NULL)
  200. {
  201. tmp2->last->next = tmp2->next;
  202. if(tmp2->next != NULL)
  203. tmp2->next->last = tmp2->last;
  204. else
  205. *transacLink2 = tmp2->last;
  206. }
  207. else if (tmp2->next != NULL)
  208. {
  209. *transacLink1 = tmp2->next;
  210. tmp2->next->last = NULL;
  211. }
  212. else
  213. {
  214. *transacLink1 = NULL;
  215. *transacLink2 = NULL;
  216. }
  217. //free the packet first
  218. Packet::free(tmp2->pkt);
  219. delete tmp2;
  220. //--------------------------------
  221. }
  222. else
  223. tmp = tmp->next;
  224. }
  225. }
  227. int addTransacLink(TRANSACLINK **transacLink1, TRANSACLINK **transacLink2, UINT_8 pendAM, IE3ADDR pendAddr, Packet *p, UINT_8 msduH, double kpTime)
  228. {
  229. TRANSACLINK *tmp;
  230. if(*transacLink2 == NULL) //not exist yet
  231. {
  232. *transacLink2 = new TRANSACLINK(pendAM,pendAddr,p,msduH,kpTime);
  233. if (*transacLink2 == NULL) return 1;
  234. *transacLink1 = *transacLink2;
  235. }
  236. else
  237. {
  238. tmp=new TRANSACLINK(pendAM,pendAddr,p,msduH,kpTime);
  239. if (tmp == NULL) return 1;
  240. tmp->last = *transacLink2;
  241. (*transacLink2)->next = tmp;
  242. *transacLink2 = tmp;
  243. }
  244. return 0;
  245. }
  247. Packet *getPktFrTransacLink(TRANSACLINK **transacLink1, UINT_8 pendAM, IE3ADDR pendAddr)
  248. {
  249. TRANSACLINK *tmp;
  251. tmp = *transacLink1;
  253. while(tmp != NULL)
  254. {
  255. if((tmp->pendAddrMode == pendAM)
  256. && (((pendAM == defFrmCtrl_AddrMode16)&&((UINT_16)pendAddr == tmp->pendAddr16))
  257.  ||((pendAM == defFrmCtrl_AddrMode64)&&(pendAddr == tmp->pendAddr64))))
  258. {
  259. return tmp->pkt;
  260. }
  261. tmp = tmp->next;
  262. }
  263. return NULL;
  264. }
  266. int updateTransacLink(int oper, TRANSACLINK **transacLink1, TRANSACLINK **transacLink2, UINT_8 pendAM, IE3ADDR pendAddr)
  267. {
  268. TRANSACLINK *tmp;
  269. int rt;
  271. //purge first if (oper == tr_oper_est)
  272. if (oper == tr_oper_est)
  273. purgeTransacLink(transacLink1,transacLink2);
  275. rt = 1;
  277. tmp = *transacLink1;
  279. if (oper == tr_oper_EST)
  280. {
  281. while(tmp != NULL)
  282. {
  283. if((tmp->pendAddrMode == pendAM)
  284. && (((pendAM == defFrmCtrl_AddrMode16)&&((UINT_16)pendAddr == tmp->pendAddr16))
  285.   ||((pendAM == defFrmCtrl_AddrMode64)&&(pendAddr == tmp->pendAddr64))))
  286. {
  287. rt = 0;
  288. tmp = tmp->next;
  289. break;
  290. }
  291. tmp = tmp->next;
  292. }
  293. if (rt) return 1;
  294. }
  296. rt = 1;
  298. while(tmp != NULL)
  299. {
  300. if((tmp->pendAddrMode == pendAM)
  301. && (((pendAM == defFrmCtrl_AddrMode16)&&((UINT_16)pendAddr == tmp->pendAddr16))
  302.  ||((pendAM == defFrmCtrl_AddrMode64)&&(pendAddr == tmp->pendAddr64))))
  303. {
  304. if (oper == tr_oper_del) //delete an element
  305. {
  306. if(tmp->last != NULL)
  307. {
  308. tmp->last->next = tmp->next;
  309. if(tmp->next != NULL)
  310. tmp->next->last = tmp->last;
  311. else
  312. *transacLink2 = tmp->last;
  313. }
  314. else if (tmp->next != NULL)
  315. {
  316. *transacLink1 = tmp->next;
  317. tmp->next->last = NULL;
  318. }
  319. else
  320. {
  321. *transacLink1 = NULL;
  322. *transacLink2 = NULL;
  323. }
  324. //free the packet first
  325. Packet::free(tmp->pkt);
  326. delete tmp;
  327. }
  328. rt = 0;
  329. break;
  330. }
  331. tmp = tmp->next;
  332. }
  333. return rt;
  334. }
  336. int updateTransacLinkByPktOrHandle(int oper, TRANSACLINK **transacLink1, TRANSACLINK **transacLink2, Packet *pkt, UINT_8 msduH)
  337. {
  338. TRANSACLINK *tmp;
  339. int rt;
  341. //purge first if (oper == tr_oper_est)
  342. if (oper == tr_oper_est)
  343. purgeTransacLink(transacLink1,transacLink2);
  345. rt = 1;
  347. tmp = *transacLink1;
  349. while(tmp != NULL)
  350. {
  351. if(((pkt != NULL)&&(tmp->pkt == pkt))
  352.  ||((pkt == NULL)&&(tmp->msduHandle == msduH)))
  353. {
  354. if (oper == tr_oper_del) //delete an element
  355. {
  356. if(tmp->last != NULL)
  357. {
  358. tmp->last->next = tmp->next;
  359. if(tmp->next != NULL)
  360. tmp->next->last = tmp->last;
  361. else
  362. *transacLink2 = tmp->last;
  363. }
  364. else if (tmp->next != NULL)
  365. {
  366. *transacLink1 = tmp->next;
  367. tmp->next->last = NULL;
  368. }
  369. else
  370. {
  371. *transacLink1 = NULL;
  372. *transacLink2 = NULL;
  373. }
  374. //free the packet first
  375. Packet::free(tmp->pkt);
  376. delete tmp;
  377. }
  378. rt = 0;
  379. break;
  380. }
  381. tmp = tmp->next;
  382. }
  383. return rt;
  384. }
  386. int numberTransacLink(TRANSACLINK **transacLink1, TRANSACLINK **transacLink2)
  387. {
  388. //return the number of transactions in the link
  389. TRANSACLINK *tmp;
  390. int num;
  392. //purge first
  393. purgeTransacLink(transacLink1,transacLink2);
  395. num = 0;
  396. tmp = *transacLink1;
  397. while(tmp != NULL)
  398. {
  399. num++;
  400. tmp = tmp->next;
  401. }
  402. return num;
  403. }
  405. int chkAddTransacLink(TRANSACLINK **transacLink1, TRANSACLINK **transacLink2, UINT_8 pendAM, IE3ADDR pendAddr, Packet *p, UINT_8 msduH, double kpTime)
  406. {
  407. int i;
  409. //purge first
  410. purgeTransacLink(transacLink1,transacLink2);
  412. i = numberTransacLink(transacLink1,transacLink2);
  413. if (i >= maxNumTransactions) return 1;
  415. i = addTransacLink(transacLink1,transacLink2,pendAM,pendAddr,p,msduH,kpTime);
  416. if (i == 0) return 0;
  417. else return 2;
  418. }
  420. void emptyTransacLink(TRANSACLINK **transacLink1, TRANSACLINK **transacLink2)
  421. {
  422. TRANSACLINK *tmp, *tmp2;
  424. if(*transacLink1 != NULL)
  425. {
  426. tmp = *transacLink1;
  427. while(tmp != NULL)
  428. {
  429. tmp2 = tmp;
  430. tmp = tmp->next;
  431. //free the packet first
  432. Packet::free(tmp2->pkt);
  433. delete tmp2;
  434. }
  435. *transacLink1 = NULL;
  436. }
  437. *transacLink2 = *transacLink1;
  438. }
  440. void dumpTransacLink(TRANSACLINK *transacLink1, IE3ADDR coorAddr)
  441. {
  442. TRANSACLINK *tmp;
  443. int i;
  444. char tmpstr[121],tmpstr2[61];
  445. FrameCtrl frmCtrl;
  447. fprintf(stdout, "[%.2f] --- dump transaction list (by coordinator %d) ---n", Scheduler::instance().clock(), coorAddr);
  448. tmp = transacLink1;
  449. i = 1;
  450. while(tmp != NULL)
  451. {
  452. sprintf(tmpstr, "t%d:t",i);
  453. if (tmp->pendAddrMode == defFrmCtrl_AddrMode16)
  454. sprintf(tmpstr2,"pendAddrMode = 16-bittpendAddr = %dt",tmp->pendAddr16);
  455. else
  456. sprintf(tmpstr2,"pendAddrMode = 64-bittpendAddr = %dt",tmp->pendAddr64);
  457. strcat(tmpstr,tmpstr2);
  458. frmCtrl.FrmCtrl = HDR_LRWPAN(tmp->pkt)->MHR_FrmCtrl;
  459. frmCtrl.parse();
  460. if (frmCtrl.frmType == defFrmCtrl_Type_Data)
  461. strcat(tmpstr,"pktType = datat");
  462. else
  463. strcat(tmpstr,"pktType = commandt");
  464. sprintf(tmpstr2,"expTime = %fn",tmp->expTime);
  465. strcat(tmpstr,tmpstr2);
  466. fprintf(stdout, "%sn", tmpstr);
  467. tmp = tmp->next;
  468. i++;
  469. }
  470. }
  472. // End of file: p802_15_4transac.cc