recver.h

升级协议接受方教程阿达洒洒萨法萨达洒洒洒洒嗒嗒嗒萨

#ifndef _RECEIVER_H_
#define _RECERVER_H_

#define SENDER_PORT       2001/*发送方端口*/
#define RECVER_PORT       2002/*接收方端口*/

#define SIZE_SEQNUM       1   /*序号字段长度*/
#define SIZE_TYPE         1   /*类型字段长度*/
#define SIZE_LENTH        4   /*信息字段长度*/
#define SIZE_MSG_MAX      100 /*信息长度*/
#define SIZE_FCS          4 
#define SIZE_CMD          1

#define PKT_SIZE          SIZE_SEQNUM+SIZE_TYPE+SIZE_MSG_MAX+SIZE_FCS

#define PKT_TYPE_CTRL     0x1 /*控制报文*/
#define PKT_TYPE_DATA     0x2 /*数据报文*/
#define CMD_CREATE        0x00/*开始传送文件，分配空间通知*/
#define CMD_CLOSE         0x01/*文件传送完毕通知*/
#define CMD_RUN           0x02/*运行模块通知*/

#define NUM_SPACE         2   /*发送窗口大小*/
#define NAME_SIZE         60  

#define NO_ENOUGH_MEMORY  0x01/*接受方内存不足，无法分配内存空间*/
#define NO_ENOUGH_DISK    0x02/*接受方磁盘空间不足，无法写入文件*/
#define NO_ERROR_1          0x03

#define INT_ERROR         3
#define PKT_BACK_SIZE     SIZE_SEQNUM+SIZE_TYPE+SIZE_FCS
#define NEED_RESEND       -1
#define NEED_STOP         -2

SOCKET hostInit(u_short port);
void   hostShutDown(SOCKET sockfd);
void   recver(SOCKET sockfd);

unsigned char getType(unsigned char *pkt);
int  getSeqNum( unsigned char *pkt );
void extractMsg(unsigned char *msg,unsigned char *pkt);
int  corrupted(unsigned char *pkt);
void makeSendBackPkt(int seq,unsigned char type,unsigned char *pkt);

#ifdef VXWORKS
STATUS fsInit();
void loadNewModule(char* name);
void runModule(char* name);
#endif

#endif