fs.c

来自「包括ＥＰＡ协议栈」· C语言 代码 · 共 108 行

#include "ucos_ii.h"
#define FS_GLOBALS
#include "fs_module.h"
#undef FS_GLOBALS
#include "epa_module.h"
#include "timer.h"

uint8 FSInput(PInSock pisock) {
	switch(pisock->srvid) {
		case EVS_READ:
			FS_Read_reqhandle(pisock);
			break;
		case EVS_READPOSITIVE:
			FS_Read_poshandle(pisock);
			break;
		case EVS_READNEGATIVE:
			FS_Read_neghandle(pisock);
			break;
		case EVS_WRITE:
			FS_Write_reqhandle(pisock);
			break;
		case EVS_WRITEPOSITIVE:
			FS_Write_poshandle(pisock);
			break;
		case EVS_WRITENEGATIVE:
			FS_Write_neghandle(pisock);
			break;
		case EVS_DISTRIBUTE:
			FS_Distribute_reqhandle(pisock);
			break;
		case FSID_UPDATE_KEY:
			// FS_UpdateRelationKey(pisock);
			break;
		case FSID_COM_OPEN:
			FS_ComOpen_reqhandle(pisock);
			break;
		case FSID_COM_OPEN_POS:
			FS_ComOpen_neghandle(pisock);
			break;
		case FSID_COM_OPEN_NEG:
			FS_ComOpen_neghandle(pisock);
			break;
		case FSID_COM_CLOSE:
			FS_ComClose_reqhandle(pisock);
			break;
		case FSID_COM_CLOSE_POS:
			FS_ComClose_poshandle(pisock);
			break;
		case FSID_COM_CLOSE_NEG:
			FS_ComClose_neghandle(pisock);
			break;
		case FSID_R_ACTIVE_ANN:
			FS_R_RemoteDeviceActiveAnnun(pisock);
			break;
		case FSID_R_DEV_CHANGE:
			FS_R_RemoteDeviceChange(pisock);
			break;
		case FSID_R_MAINTAIN:
			FS_R_RemoteMaintain(pisock);
			break;
		case FSID_R_MAINTAIN_REQ:
			FS_R_RemoteMaintainRequest(pisock);
			break;
		default:
			FreeInSock(pisock);
	}
	return (0);
}

uint8 FSOutput(POutSock posock) {
	switch(posock->srvid) {
		case EVS_READ:
			FS_Read_req(posock);
			break;
		case EVS_READPOSITIVE:
			FS_Read_pos(posock);
			break;
		case EVS_READNEGATIVE:
			FS_Read_neg(posock);
			break;
		case EVS_WRITE:
			FS_Write_req(posock);
			break; 						 		
		case EVS_WRITEPOSITIVE:
			FS_Write_pos(posock);
			break;
		case EVS_WRITENEGATIVE:
			FS_Write_neg(posock);
			break;
		case EVS_DISTRIBUTE:					
			FS_Distribute_req(posock);
			break;
		default:
			FreeOutSock(posock);
	}
	return (0);
}

uint8 FSInit(void) {
	Initfsmihead();
	Initfscfgobject();
	Initfscomobject();
	Initfscomfailure();
	Initfslinkobject();

	return (0);
}