/*該協議是搭載ack的回退n步協議*/
#include?
#include?“protocol.h“

#define?max_seq?7
#define?flag?126?????
#define?ESC?100
#define?wait_time?2700					//發送計時器等待的時間
#define?ack_wait_time?280

static?int?phl_ready?=?0;
unsigned?char?buf[max_seq+1][270];
unsigned?char?ack[8];????//發送空的ack幀

unsigned?char?in_buf[600]?last_buf[520];//接收時的緩沖區;去掉冗余之后的緩沖區為防備因誤碼兩幀合并為一幀而定義了很大一個數組
int?nbuffered=0;??????????????//發送的幀數
int?buf_size[max_seq+1];??????//記下以發送各幀的幀長
int?next_frame_to_send=0;?
int?frame_in_phl=0;???????????//用于成幀
int?frame_expected=0;
int?ack_expected=0;

int?between（int?aint?bint?c）
{
	if（?（（a<=b）&&（b		return?1;
	else?return?0;
}
//判斷幀尾防止出現誤判esc?esc?flag為數據的情況
int?end_flag（int?in_len）
{
	int?count=0;
	int?i;
	if（in_len<=0）
		return?1;
	for（i=in_len-1;in_buf[i]==ESC&&i>=0;i--）//記錄flag前的esc數目
		count++;
	return?count%2;????????????????????//若flag前的esc為偶數，則為幀尾
}//成幀函數--數據幀
void?send_frame（char?*my_bufint?len）
{				
	int?n;							
	buf[frame_in_phl][0]=（frame_expected+max_seq）%（max_seq+1）;	//ack
	buf[frame_in_phl][1]=frame_in_phl;					//發送幀的幀號
	for（n=0;n		buf[frame_in_phl][n+2]=my_buf[n];				//將處理過的新幀賦值到緩沖區中
	len=len+2;
	*（unsigned?int?*）（buf[frame_in_phl]+len）?=?crc32（buf[frame_in_phl]len）;		//在原始幀的基礎上加檢驗和
	buf_size[frame_in_phl]=len+4;						//記錄當前幀的長度包括3個幀頭，4個檢驗和
	nbuffered=nbuffered+1;				//緩沖區占用數加一
	frame_in_phl=（frame_in_phl+1）%（max_seq+1）;
}
//成幀函數--ack幀
void?send_ack（）									//ack幀的處理
{
	ack[0]=（frame_expected+max_seq）%（max_seq+1）;
	ack[1]=max_seq+10;					//ack幀的序號位，使ack[1]==frame_expected恒不成立
	*（unsigned?int?*）（ack+2）?=?crc32（ack2）;		//在原始幀的基礎上加檢驗和
}
//主函數
int?main（int?argc?char?**argv）
{
????int?event?arg?n??m??i??j??len?=?0?in_len?=?0;	
	unsigned?char?my_buf[260];
	int?phl_wait=0;????//在物理層中還沒有被發送的幀

????protocol_init（argc?argv）;?
????enable_network_layer（）;

????for?（;;）?{
????????event?=?wait_for_event（&arg）;

????????switch?（event）?{
????????case?NETWORK_layer_READY:
????????????len?=?get_packet（my_buf）;?
			phl_wait++;
			send_frame（my_buflen）;
			stop_ack_timer（）;

????????????if?（phl_ready）?{
????????????????for（j=0;j				{	
					//幀結構為?ack?seq?內容
					//每幀尾部加發送一個flag
					
					for?（i?=?0;?i?ame_to_send];?i++）{
						if?（（buf[next_frame_to_send][i]==flag）?||?（buf[next_frame_to_send][i]==ESC）?）
							send_byte（ESC）;
						send_byte（buf[next_frame_to_send][i]）;
					}
					send_byte（flag）;//幀尾

					start_timer（next_frame_to_sendwait_time）;	//發送完啟動相應的定時器
					next_frame_to_send=（next_frame_to_send+1）%（max_seq+1）;
				}
????????????????phl_ready??=?0;				//記錄物理層當前狀態為
				phl_wait?=?phl_wait-j;
????????????}
????????????break;

????????case?PHYSICAL_layer_READY:
????????????if?（phl_wait）?{					//若有未發送的幀便發送
				for（j=0;j				{
				
					for?（i?=?0;?i?ame_to_send];?i++）{
						if?（?（buf[next_fram