#ifndef _IEC104_QUEUE_H #define _IEC104_QUEUE_H #include "iec104_conf.h" #include "iec104_types.h" #include #include /* * IEC104配置 * */ #define IEC104LOCK #define PRIO_QUEUE #define IEC10X_PRIO_MAX 7 #define IEC10X_HEADER_LENGTH 1 /* * PRIO * */ #define IEC10X_PRIO_INITLINK 0 #define IEC10X_PRIO_CALLALL 1 #define IEC10X_PRIO_CALLGROUP 2 #define IEC10X_PRIO_CLOCK 3 #define IEC10X_PRIO_DELAY 3 #define IEC10X_PRIO_PULSE 0 #define IEC10X_PRIO_SPON 0 /* * Transmission Priority Queue. */ typedef struct iec104_callback_arg { iec_8u *value; iec_32u pic_sn; iec_32u FramSerialNum; } iec104_callback_arg_t; typedef struct iec104_node { iec_16u Length; struct iec104_node *Next; void (*CallBack)(iec104_callback_arg_t *Arg); iec104_callback_arg_t CallBackArg; iec_8u value[1]; } iec104_prio_node_t; typedef struct iec104_queue { struct iec104_node *header; struct iec104_node *tail; unsigned char element_num; } iec104_prio_queue_t; /* ********************************************************************************************************* * BLOCK SIZE AND NUMBER * * if add part, please change OS_MAX_MEM_PART in ucosii.h. ********************************************************************************************************* */ /* IEC10X_PARTITION 1 size==256*8 */ #define IEC10X_PARTITION_NUM_1 5 #define IEC10X_PARTITION_SIZE_1 512 #define IEC10X_PARTITION_1 (IEC10X_PARTITION_SIZE_1 - 16) /* IEC10X_PARTITION 2 size==(1300+16)*1 */ #define IEC10X_PARTITION_NUM_2 20 #define IEC10X_PARTITION_2 128 #define IEC10X_PARTITION_SIZE_2 (IEC10X_PARTITION_2 + sizeof(Iec10x_PrioNode_T)) /* IEC10X_PARTITION 1 size==64*20 */ #define IEC10X_PARTITION_NUM_3 10 #define IEC10X_PARTITION_3 32 #define IEC10X_PARTITION_SIZE_3 (IEC10X_PARTITION_3 + sizeof(Iec10x_PrioNode_T)) /* ********************************************************************************************************* * ASDU ********************************************************************************************************* */ /* * ASDU TYPE * */ #define Iec10x_M_EI_NA_1 0X46 #define IEC10X_C_IC_NA_1 0X64 /*CALL*/ #define IEC10X_C_CS_NA_1 103 #define IEC10X_C_CD_NA_1 106 /*CALL*/ /*Set data*/ #define IEC10X_C_SE_NA_1 48 #define IEC10X_C_SE_NC_1 50 /* * ASDU REASON * */ #define IEC10X_ASDU_REASON_INIT 0X04 #define IEC10X_ASDU_REASON_ACT 0X06 #define IEC10X_ASDU_REASON_ACTCON 0X07 /*CALL*/ #define IEC10X_ASDU_REASON_ACTFIN 0X08 /*CALL FINISH*/ #define IEC10X_ASDU_REASON_ACTTERM 0X0a /*CALL Terminal*/ #define IEC10X_ASDU_COT_UNKNOW 45 /* * INFO addr * */ #define IEC10X_INFO_addr_NONE 0X00 /* ********************************************************************************************************* * REMOTE SIGNAL ********************************************************************************************************* */ /* * Asdu type (TI) * */ #define IEC10X_M_SP_NA_1 0X01 #define IEC10X_M_DP_NA_1 0X03 #define IEC10X_M_SP_TB_1 30 #define IEC10X_M_DP_TB_1 31 /* * Asdu reason (COT) * */ #define IEC10X_COT_BACK 2 #define IEC10X_COT_SPONT 3 #define IEC10X_COT_ACT 6 #define IEC10X_COT_ACTCON 7 #define IEC10X_COT_REQ 5 #define IEC10X_COT_RETREM 11 #define IEC10X_COT_RETLOC 12 #define IEC10X_COT_INTROGEN 20 #define IEC10X_COT_INTRO1 21 #define IEC10X_COT_INTRO2 22 /* * Asdu addr * */ #define IEC10X_INFO_ADDR_SIG_BASE 0X0001 #define IEC10X_INFO_ADDR_SIG_TEMP_HX_OFF 0x1000 /* ********************************************************************************************************* * REMOTE DECTET ********************************************************************************************************* */ /* * Asdu type (TI) * */ #define IEC10X_M_ME_NA_1 9 #define IEC10X_M_ME_NC_1 13 #define IEC10X_M_ME_TD_1 34 #define IEC10X_M_ME_TF_1 36 /* * Asdu reason (COT) * */ #define IEC10X_COT_PER_CYC 1 #define IEC10X_COT_BACK 2 #define IEC10X_COT_SPONT 3 #define IEC10X_COT_REQ 5 #define IEC10X_COT_INTROGEN 20 #define IEC10X_COT_INTRO9 29 #define IEC10X_COT_INTRO10 30 /* * Asdu addr * */ #define IEC10X_INFO_addr_DET 0X4001 #define IEC10X_INFO_addr_DET_TEMP_HX_OFF 0x1000 /* ********************************************************************************************************* * CALL QOI ********************************************************************************************************* */ #define IEC10X_CALL_QOI_TOTAL 20 #define IEC10X_CALL_QOI_GROUP1 21 #define IEC10X_CALL_QOI_GROUP2 22 #define IEC10X_CALL_QOI_GROUP9 29 #define IEC10X_CALL_QOI_GROUP10 30 /* ********************************************************************************************************* * INFO addrEST * TD -- temprature device * PD -- pullotion device ********************************************************************************************************* */ #define IEC10X_SET_TD_UPCYCLE 0X100001 #define IEC10X_SET_TD_MAXIMUM 0X100002 #define IEC10X_SET_TD_MINIMUM 0X100003 #define IEC10X_SET_TD_DETCYCLE 0X100004 #define IEC10X_SET_TD_TEMPRISE 0X100005 #define IEC10X_SET_PD_DETCYCLE 0X100006 #define IEC10X_SET_PD_PULPSE 0X100007 #define IEC10X_SET_PD_SELFDETCYCLE 0X100008 /* ********************************************************************************************************* * Fujian Huixing Add ********************************************************************************************************* */ /* TI. */ #define IEC10X_TI_FIRM_UPDATE 128 #define IEC10X_TI_AP_FIRM_BACKOFF 129 #define IEC10X_TI_AP_BASE_INFO 130 /* COT. */ #define IEC10X_COT_ACT_TERMINAL 8 #define IEC10X_COT_ACT_TERMINAL_ACK 9 #define IEC10X_COT_DATA 14 #define IEC10X_COT_DATA_ACK 15 #define IEC10X_COT_DATA_FIN 16 #define IEC10X_COT_DATA_FIN_ACK 17 #define IEC10X_COT_DATA_NEEDACK 0X100E #pragma pack(1) /* * asdu number * */ typedef struct { iec_8u _num : 7; iec_8u _sq : 1; } ASDU_NUM_T; /* * asdu reason * */ typedef struct { iec_16u _reason : 14; iec_16u _pn : 1; iec_16u _test : 1; } ASDU_REASON_T; /* * asdu * */ typedef struct { iec_8u _type; ASDU_NUM_T _num; ASDU_REASON_T _reason; iec_16u _addr; iec_8u _info[1]; } iec10x_asdu_t, *p_iec10x_asdu_t; /* * asdu info * */ typedef struct { iec_8u _addr[3]; iec_8u _element[1]; } asdu_info_t, *p_asdu_info_t; /* * asdu info remote signal with time flag * */ typedef struct { iec_8u _signal; iec_8u _time; } SIGNAL_TIME_T, *PSIGNAL_TIME_T; /* * asdu info remote detect with time flag * */ /*int */ typedef struct { iec_16s _detect; iec_8u _qds; } IEC10X_DETECT_T, *PIEC10X_DETECT_T; /*float*/ typedef struct { float _detect; iec_8u _qds; } IEC10X_DETECT_F_T, *PIEC10X_DETECT_F_T; /*int sq=0 */ typedef struct { iec_8u _addr[3]; iec_16s _detect; iec_8u _qds; } IEC10X_DETECT_SQ0_T, *PIEC10X_DETECT_SQ0_T; /*float sq=0*/ typedef struct { iec_8u _addr[3]; float _detect; iec_8u _qds; } IEC10X_DETECT_SQ0_F_T, *PIEC10X_DETECT_SQ0_F_T; /* * asdu info CP56Time2a * */ typedef struct { iec_8u _minutes : 6; iec_8u _res : 1; iec_8u _iv : 1; } iec10x_time_min_t, *p_iec10x_time_min_t; typedef struct { iec_8u _hours : 5; iec_8u _res : 2; iec_8u _su : 1; } iec10x_time_hour_t, *p_iec10x_time_hour_t; typedef struct { iec_8u _dayofmonth : 5; iec_8u _dayofweek : 3; } IEC10X_Time_Day_T, *PIEC10X_Time_Day_T; typedef struct { iec_8u _month : 4; iec_8u _res : 3; } IEC10X_Time_Month_T, *PIEC10X_Time_Month_T; typedef struct { iec_8u _year : 7; iec_8u _res : 1; } IEC10X_Time_Year_T, *PIEC10X_Time_Year_T; typedef struct { iec_16u _milliseconds; iec10x_time_min_t _min; iec10x_time_hour_t _hour; IEC10X_Time_Day_T _day; IEC10X_Time_Month_T _month; IEC10X_Time_Year_T _year; } CP56Time2a_T, *PCP56Time2a_T; /* * asdu info remote detect with time flag * */ typedef struct { iec_16u _detect; iec_8u _qds; CP56Time2a_T _time; } DETECT_TIME_T, *PDETECT_TIME_T; #pragma pack() /* * Iec10x init */ typedef struct _iec104 { char *name; int (*init)(void); void (*delay_ms)(iec_16u); void (*close_link)(void); void *(*malloc)(iec_8u nbyte); void (*free)(void *buffer); iec_8u (*enqueue)(iec104_prio_queue_t *queue_hdr, iec104_prio_node_t *newnode); iec104_prio_node_t *(*dequeue)(iec104_prio_queue_t *queue_hdr); iec104_prio_node_t *(*find_qhead)(iec104_prio_queue_t *queue_hdr); iec_8u (*get_prio)(void); void (*queue_init)(iec104_prio_queue_t *PrioQueue); void (*queue_clear)(iec104_prio_queue_t *queue_hdr); iec_8u (*send)(int socketfd, char *data, int len); iec_32u (*set_time)(PCP56Time2a_T time); iec_32u (*get_time)(PCP56Time2a_T time); iec_8s (*get_station_state)(iec_16u addr, iec_8u dev_type); float (*get_sta_value)(iec_16u addr, iec_8u dev_type); iec_16u (*get_link_addr)(void); iec_8s (*get_info_num)(iec_8u *info_num, iec_8u dev_type); iec_8s (*set_config)(long value, iec_32u addr); iec_8s (*save_firmware)(iec_8u firm_len, iec_8u *buf, iec_32u firmware_type, iec_32u iec104_update_seek_addr); iec_8s (*check_firmware)(iec_32u firmware_type, iec_32u total_len); iec_8s (*update_firmware)(iec_32u firmware_type); iec_8s (*backoff_firmware)(iec_32u firmware_type); #ifdef IEC104LOCK void (*lock)(void); void (*unlock)(void); #endif } *p_iec104_t, iec104_t; /* * BIG ENDIAN * */ #ifdef BIG_ENDIAN #define n2hs(x) (x) #define h2ns(x) (x) #define n2hl(x) (x) #define h2nl(x) (x) /* LITTLE ENDIAN */ #else #define n2hs(x) ((((x) >> 8) & 0xFF) | (((x)&0xFF) << 8)) #define h2ns(x) ((((x) >> 8) & 0xFF) | (((x)&0xFF) << 8)) #define n2hl(x) ((((x) >> 24) & 0xFF) | (((x) >> 8) & 0xFF00) | \ (((x)&0xFF00) << 8) | (((x)&0xFF) << 24)) #define h2nl(x) ((((x) >> 24) & 0xFF) | (((x) >> 8) & 0xFF00) | \ (((x)&0xFF00) << 8) | (((x)&0xFF) << 24)) #endif /* BIG_ENDIAN */ /* ********************************************************************************************************* * EXTERN VARIABLE ********************************************************************************************************* */ extern p_iec104_t iec104; extern iec_16u iec104_state_addr; extern iec_32s iec104_build_send_sn; extern iec_32s iec104_build_recv_sn; extern iec_16u IEC10X_Cp16time2a; extern iec_16u IEC10X_Cp16time2a_V; extern CP56Time2a_T IEC10X_Cp56time2a; extern iec_8u Iec10x_FirmwareUpdateFlag; /* * Prio * */ iec_8u iec104_prio_enqueue(iec104_prio_queue_t *queue_hdr, iec104_prio_node_t *new_p); iec104_prio_node_t *iec104_prio_dequeue(iec104_prio_queue_t *queue_hdr); iec_8u iec10x_prio_highest(void); void iec104_prio_queue_init(iec104_prio_queue_t *PrioQueue); void iec104_prio_queue_clear(iec104_prio_queue_t *queue_hdr); iec104_prio_node_t *iec104_prio_queue_find_head(iec104_prio_queue_t *queue_hdr); /* * iec104 队列 * */ void iec104_queue_init(void); void iec104_queue_clear(void); iec_8u iec104_prio_get(iec_8u State); void iec104_enqueue(iec_8u *enq_buf, iec_16u Length, iec_8u Prio, void (*IEC10XCallBack)(iec104_callback_arg_t *Arg), iec104_callback_arg_t *CallbackArg); void iec104_scheduled(int socketfd); iec104_prio_node_t *iec104_dequeue(void); iec_32s iec104_module_register(void *p_iec10x); void iec104_lock(void); void iec104_unlock(void); #endif /*_IEC10X_H*/