IEC61850客户端代码

/*IEC61850客户端动态库源代码 /*12.07.11 去掉互斥机制 */ /*10.08.28 解决自动获取数据集中元素信息函数内存分配出错问题，解决静态解析模 */ /* 型慢的问题 */ /*10.08.05 加入自动获取数据集中元素的数据类型、长度、描述等信息的相关函数 */ /*10.05.26 加入静态解析模型文件的功能 */ /*09.05.03 对报告接收问题进行修改 */ /*08.12.17 对目录服务中对一个以上的逻辑设备不能建立报告控制块的错误进行修改 */ /*08.08.26 对报告接收问题进行修改 */ #include "client.h" #if defined(WIN32) || defined(_WIN32_WCE) #define MS_SLEEP(msec) { Sleep(msec); } #define S_SLEEP(sec) { Sleep(sec * 1000); } #else #define MS_SLEEP(msec) { usleep(msec * 1000); } #define S_SLEEP(sec) { sleep(sec); } #endif #ifdef DEBUG_SISCO SD_CONST static ST_CHAR *SD_CONST thisFileName = __FILE__; #endif typedef struct { ST_INT cmd_term_num_va; ST_CHAR oper_name [MAX_IDENT_LEN +1]; } MY_CONTROL_INFO; MY_CONTROL_INFO my_control_info; IDENT_RESP_INFO identify_response_info = { "SISCO", MMSLITE_NAME, MMSLITE_VERSION, 0, }; MVLU_RD_FUN_INFO mvluRdFunInfoTbl[] = { {"", NULL} }; MVLU_WR_FUN_INFO mvluWrFunInfoTbl[] = { {"", NULL} }; ST_INT mvluNumRdFunEntries = sizeof(mvluRdFunInfoTbl)/sizeof(MVLU_RD_FUN_INFO); ST_INT mvluNumWrFunEntries = sizeof(mvluWrFunInfoTbl)/sizeof(MVLU_WR_FUN_INFO); MVL_CFG_INFO mvlCfg; //存放配置文件信息的结构体 INIT_INFO callingInitInfo; //存放远程调用服务端初始化信息的结构体 INIT_INFO initRespInfo; //存放远程调用服务端回应信息的结构体 ST_INT timeOut = 60; //连接超时时间 RPT_TYPEIDS rpt_typeids; //报告数据类型变量 ST_BOOLEAN init_flag = 0; HANDLE hThread; //客户端服务线程句柄 DWORD ThreadID; ST_BOOLEAN init_quitFlag = 1; //yhc /*******************************************************/ /************************************************************************/ /* client_server */ /* 客户端服务线程，用于接收报告及服务器断开等信息 */ /************************************************************************/ void client_server(LPVOID pParam) { while(init_quitFlag) { doCommService(); } } /************************************************************************/ /*函数名： mms_init */ /*输入参数：无 */ /*返回值： 0：成功；1：失败 */ /*函数功能：mms初始化,包括读入配置信息、应用关联初始化及启动客户端服务 */ /* 线程 */ /************************************************************************/ unsigned int mms_init() { ST_RET ret; /*判断是否已进行了初始化操作，若已进行了初始化，则退出*/ if (init_flag == 1) return 1; mvl_max_dyn.types = 1000000; /* 动态分配的数据类型最大数目*/ mvl_max_dyn.doms = 500; /* vmd域中动态分配的逻辑设备（域）最大数目*/ mvl_max_dyn.journals = 10; /* vmd域中动态分配的日志的最大数目*/ mvl_max_dyn.vmd_nvls = 10; /* vmd域中动态分配的数据集（有名变量表）最大数目*/ mvl_max_dyn.vmd_vars = 10; /* vmd域中动态分配的逻辑节点（有名变量）最大数目*/ mvl_max_dyn.dom_nvls = 500; /* dom域中动态分配的数据集（有名变量表）最大数目*/ mvl_max_dyn.dom_vars = 2000; /* dom域中动态分配的逻辑节点（有名变量）最大数目*/ mvl_max_dyn.aa_nvls = 10; /* AA域中动态分配的数据集（有名变量表）最大数目*/ mvl_max_dyn.aa_vars = 10; /* AA域中动态分配的逻辑节点（有名变量）最大数目*/ init_quitFlag = 1; //yhc /*SISCO调试日志初始化，若不需记录SISCO调试信息，此段代码可删除*/ setbuf (stdout, NULL); setbuf (stderr, NULL); init_mem (); init_log_cfg (); ret = osicfgx ("osicfg.xml", &mvlCfg); /*将osicfg.xml中的数据读入mvlCfg结构体中，osicfg.xml为网络信息配置文件*/ if (ret != SD_SUCCESS) return 1; ret = mvl_start_acse (&mvlCfg); /*进行应用服务关联初始化*/ if (ret != SD_SUCCESS) return 1; /*初始化报告数据类型，这一步必须成功，否则不能正确接收报告*/ if((ret = rpt_typeids_find (&rpt_typeids)) != SD_SUCCESS) return 1; /*注册断开连接指示原语函数（该函数在服务器正常或异常断开时自动调用）*/ u_mvl_disc_ind_fun = disc_ind_fun; /*创建客户端服务线程*/ hThread = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE) client_server, NULL, 0, &ThreadID); init_flag = 1; return 0; } unsigned int mms_load_OsiCfg() { ST_RET ret; mvl_max_dyn.types = 100000; /* 动态分配的数据类型最大数目*/ mvl_max_dyn.doms = 500; /* vmd域中动态分配的逻辑设备（域）最大数目*/ mvl_max_dyn.journals = 10; /* vmd域中动态分配的日志的最大数目*/ mvl_max_dyn.vmd_nvls = 10; /* vmd域中动态分配的数据集（有名变量表）最大数目*/ mvl_max_dyn.vmd_vars = 10; /* vmd域中动态分配的逻辑节点（有名变量）最大数目*/ mvl_max_dyn.dom_nvls = 500; /* dom域中动态分配的数据集（有名变量表）最大数目*/ mvl_max_dyn.dom_vars = 2000; /* dom域中动态分配的逻辑节点（有名变量）最大数目*/ mvl_max_dyn.aa_nvls = 10; /* AA域中动态分配的数据集（有名变量表）最大数目*/ mvl_max_dyn.aa_vars = 10; /* AA域中动态分配的逻辑节点（有名变量）最大数目*/ mvl_end_acse(); ret = osicfgx ("osicfg.xml", &mvlCfg); /*将osicfg.xml中的数据读入mvlCfg结构体中，osicfg.xml为网络信息配置文件*/ if (ret != SD_SUCCESS) return 1; ret = mvl_start_acse (&mvlCfg); /*进行应用服务关联初始化*/ if (ret != SD_SUCCESS) return 1; return 0; } /************************************************************************/ /*函数名： mms_quit */ /*输入参数：无 */ /*返回值： 0：成功；1：失败 */ /*函数功能：停止客户端服务线程，释放各种资源，退出mms环境 */ /************************************************************************/ unsigned int mms_quit() { CLIENT_CTRL *client_ctrl; MVL_NET_INFO *clientNetInfo; ALL_RCB_INFO *all_rcb_info; RCB_INFO *rcb_info; /*如果没有进行mms初始化，则不进行退出mms环境操作*/ if (init_flag == 0) return 1; init_quitFlag = 0; //yhc MS_SLEEP(500); /*释放链表中所有还未断开连接的服务器控制体client_ctrl中的虚拟设备控制体client_vmd资源和报告控制块链表资源*/ for (client_ctrl = (CLIENT_CTRL *) list_find_last ((DBL_LNK *) head_client_ctrl_list); client_ctrl != NULL; client_ctrl = (CLIENT_CTRL *) list_find_prev ((DBL_LNK *) head_client_ctrl_list, (DBL_LNK *) client_ctrl )) { clientNetInfo = client_ctrl->clientNetInfo; if ((all_rcb_info = (ALL_RCB_INFO *) clientNetInfo->user_info) != NULL) { while ((rcb_info = (RCB_INFO *) list_get_first (&all_rcb_info->rcb_info_list)) != NULL) { rcb_info_destroy (rcb_info); } chk_free (all_rcb_info); clientNetInfo->user_info = NULL; } if (client_ctrl->client_vmd != NULL) { mvl_vmd_destroy (client_ctrl->client_vmd); } } /*将所有还未断开连接的服务器的控制体client_ctrl从链表中退出，同时释放资源*/ client_ctrl = (CLIENT_CTRL *) list_get_first (&head_client_ctrl_list); while(client_ctrl) { chk_free (client_ctrl); client_ctrl = (CLIENT_CTRL *) list_get_first (&head_client_ctrl_list); } mvl_vmd_destroy (&mvl_vmd); /* 释放mvl_vmd结构体占用的资源*/ mvl_end_acse (); /* 结束客户端的关联应用服务*/ free_mem(); /* 释放一些残存的动态分配的资源*/ #if defined(DEBUG_SISCO) slog_end (sLogCtrl); #endif CloseHandle(hThread); init_flag = 0; return 0; } /*************************************************************