【正文】 printf(\n)。 if (TRACE2) { printf( 向第五層發(fā)送信息 : 數(shù)據(jù)收到 )。 if (TRACE0) printf( 向第三層發(fā)送信息 : 包被敗壞 \n)。 if ( (x = jimsrand()) .75) mypktptrpayload[0]=39。amp。 qnext!=NULL。 /* 存儲(chǔ)指針復(fù)制的包 */ /* 最后，計(jì)算包到達(dá)另一端的時(shí)間 重新整理中媒體 , 以確定包到達(dá)是在 1 到 10 單元時(shí)間之間，之后， 最近到達(dá)的包能正確的到達(dá)目的地 */ lastime = time。 } /* 創(chuàng)建將來事件當(dāng)包到達(dá)另一端 */ evptr = (struct event *)malloc(sizeof(struct event))。 for (i=0。 for (i=0。 } /* make a copy of the packet student just gave me since he/she may decide */ /* to do something with the packet after we return back to him/her */ mypktptr = (struct pkt *)malloc(sizeof(struct pkt))。 /* 模擬丟失 : */ if (jimsrand() lossprob) { nlost++。 struct event *evptr,*q。 return。 evlist = qnext。amp。 q!=NULL 。 q!=NULL amp。 insertevent(evptr)。 } /* 創(chuàng)建事件當(dāng)超時(shí)發(fā)生 */ evptr = (struct event *)malloc(sizeof(struct event))。 q = qnext) if ( (qevtype==TIMER_INTERRUPT amp。amp。 struct event *evptr。 q!=NULL。 } } } //打印事件列表 void printevlist() { struct event *q。 } else /* 表中部 */ { pnext=q。 } else if (q==evlist)/* front of list */ { pnext=evlist。 q=qnext) qold=q。 } else { for (qold = q。 } q = evlist。 insertevent(evptr)。 evptrevtime = time + x。 int tempint。 /* x should be uniform in [0,1] */ return(x)。 /* initialize time to */ generate_next_arrival()。 ntolayer3 = 0。 printf(is different from what this emulator expects. Please take\n)。 i1000。 printf(\n\n)。 //fscanf(fp,%d,amp。lambda)。 scanf(%f,amp。lossprob)。 printf(\n 輸入包被丟失的可能性 [輸入 表示不丟失 ]: )。 //fscanf(fp,%d,amp。 fp = fopen (,r)。 } //初始化仿真器 void init() /* initialize the simulator */ { int i。 winfront = 0。 nextseqnum = 0。 i=pktnum。s timer goes off */ void B_timerinterrupt() { int i。 i=pktnum。 } } //A 計(jì)時(shí)器超時(shí) /* A 超時(shí)被調(diào)用 */ void A_timerinterrupt() { int i。039。 = NACK。 printf(B:expectedseqnum ( 期 待 下 一 次 的 發(fā) 送 序號(hào) )= %d\n,expectedseqnum)。 /* puter checksum */ ComputeChecksum (amp。 for ( i=0。amp。 } } else printf (A: 收到否定應(yīng)答，什么也沒有完成 !\n)。 winbuf[winrear] = sendpkt。 /*如果是滑動(dòng)窗口的第一個(gè)包，開始超時(shí)檢測 */ if ( base == nextseqnum ) //如果滑動(dòng)窗口最小的包等于下一次要發(fā)送的序號(hào) { //starttimer(A,RTT)。 i20 。 (nextseqnumbase+WINDOWSIZE) ) { /* 創(chuàng)建包 */ = nextseqnum。 if ( base nextseqnum) { //starttimer(A,RTT)。 /* 從窗口緩沖區(qū)刪去被確認(rèn)的包 */ winfront = (winfront+(+1base)) % WINDOWSIZE。 /* 如果收到?jīng)]有被破壞的包并且確認(rèn)包收到 */ if ( (CheckCorrupted(packet) == FALSE) amp。 i++) buffer[bufrear].data[i] = [i]。 } /* otherwise, buffer the message */ else { printf(緩沖區(qū)滿 !\n)。 // } /* update state variables */ nextseqnum = nextseqnum+1。 i20。 /* copy the packet to window packet buffer */ winrear = (winrear+1)%WINDOWSIZE。 /* puter checksum */ ComputeChecksum (amp。 = NOTUSED。 } } } //B 端向外發(fā)送數(shù)據(jù) /* 被第五層調(diào)用，發(fā)送數(shù)據(jù)到另一方 ,同 A 方相似 */ void B_output(struct msg message) { int i。 //擁塞控制 ,防止擁塞 ,減小緩沖區(qū) for (i=0。 /* 如果緩沖區(qū)滿，放棄并退出 */ if ( msgnum == MAXBUFSIZE) { printf ( 錯(cuò)誤：發(fā)送緩沖區(qū)已 滿 ?。?！ \n)。 starttimer(A,RTT)。 for (i=0。 /* 送出包 */ tolayer3 (A, sendpkt)。 i20 。 /* 如果的發(fā)送方下次使用序號(hào)小于滑動(dòng)窗口的最大序號(hào)，那么補(bǔ)發(fā)包 */ if ( nextseqnum base+WINDOWSIZE ) { printf(A：新的包到達(dá)，發(fā)送窗口不滿，新的包送往第 3 層！ \n)。 if ( (+checksum) == 0 )//檢查校檢和是否相加為 0 return (FALSE)。 checksum = checksum + 。//取反 packetchecksum = checksum。//求腳鏈 for ( i=0。 /* 事件清單 */ //相關(guān)接口函數(shù)的實(shí)現(xiàn) //計(jì)算校驗(yàn)和 ,即腳鏈和 1 的補(bǔ)碼和 void ComputeChecksum( struct pkt *packet) { int checksum。 //包發(fā)送 extern int packet_correct=0。 /* 緩沖區(qū)的頭尾指針 */ static int msgnum。 /* 窗口包緩沖區(qū) */ static int winfront,winrear。 /* 在網(wǎng)絡(luò)中被破壞的包 */ static int expectedseqnum = 0。 /* 包的數(shù)據(jù)位數(shù)丟失可能性 */ float lambda。 /* 當(dāng)前第 5 層到第 4 層的信息數(shù) */ extern int nsimmax = 0。//啟動(dòng)