GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-29 15:09:11 +08:00
Code Issues Packages Projects Releases Wiki Activity

Use web UI to set OPC-UA connection parameters

Browse Source
This commit is contained in:
gc87
2021-12-13 11:28:09 +08:00
committed by Parker Liu
parent 6de377cc29
commit 4cfaf3fcd0
2 changed files with 52 additions and 39 deletions
Download Patch File Download Diff File Expand all files Collapse all files
plugins/opcua/open62541_client.c
+4
View File
@@ -543,6 +543,10 @@ int open62541_client_destroy(open62541_client_t *client)
int open62541_client_close(open62541_client_t *client)
{
if (NULL == client) {
return -1;
}
pthread_mutex_lock(&client->mutex);
client->running = false;
pthread_mutex_unlock(&client->mutex);
plugins/opcua/plugin_opcua.c
+48 -39
View File
@@ -57,10 +57,12 @@ static neu_plugin_t *opcua_plugin_open(neu_adapter_t * adapter,
return NULL;
}
memset(plugin, 0, sizeof(neu_plugin_t));
neu_plugin_common_init(&plugin->common);
plugin->common.adapter = adapter;
plugin->common.adapter_callbacks = callbacks;
plugin->common.link_state = NEU_PLUGIN_LINK_STATE_CONNECTING;
plugin->common.link_state = NEU_PLUGIN_LINK_STATE_DISCONNECTED;
log_info("Success to create plugin: %s", neu_plugin_module.module_name);
return plugin;
@@ -75,13 +77,6 @@ static int opcua_plugin_close(neu_plugin_t *plugin)
static int opcua_plugin_init(neu_plugin_t *plugin)
{
int rc = opcua_option_init(&plugin->option);
if (0 != rc) {
log_error("OPCUA option init fail:%d initialize plugin failed: %s", rc,
neu_plugin_module.module_name);
return -1;
}
plugin->handle_context = malloc(sizeof(opc_handle_context_t));
memset(plugin->handle_context, 0, sizeof(opc_handle_context_t));
plugin->handle_context->plugin = plugin;
@@ -90,6 +85,50 @@ static int opcua_plugin_init(neu_plugin_t *plugin)
NEU_LIST_INIT(&plugin->handle_context->subscribe_list,
opc_subscribe_tuple_t, node);
log_info("Initialize plugin: %s", neu_plugin_module.module_name);
return 0;
}
static int opcua_plugin_uninit(neu_plugin_t *plugin)
{
opcua_handle_stop(plugin->handle_context);
open62541_client_close(plugin->client);
plugin->client = NULL;
opcua_option_uninit(&plugin->option);
if (NULL != plugin->handle_context) {
free(plugin->handle_context);
}
plugin->common.link_state = NEU_PLUGIN_LINK_STATE_DISCONNECTED;
log_info("Uninitialize plugin: %s", neu_plugin_module.module_name);
return 0;
}
static int opcua_plugin_config(neu_plugin_t *plugin, neu_config_t *configs)
{
if (NULL == configs || NULL == configs->buf) {
return -1;
}
plugin->common.link_state = NEU_PLUGIN_LINK_STATE_CONNECTING;
// Close OPC-UA client
opcua_handle_stop(plugin->handle_context);
open62541_client_close(plugin->client);
plugin->client = NULL;
opcua_option_uninit(&plugin->option);
// OPC-UA client configuration
int rc = opcua_option_init_by_config(configs, &plugin->option);
if (0 != rc) {
log_error("OPCUA option init fail:%d, initialize plugin failed: %s", rc,
neu_plugin_module.module_name);
opcua_option_uninit(&plugin->option);
return -1;
}
// Open open62541 client
rc = open62541_client_open(&plugin->option, plugin, &plugin->client);
if (0 != rc) {
log_error("Can not connect to opc.tcp://%s:%d", plugin->option.host,
@@ -103,37 +142,7 @@ static int opcua_plugin_init(neu_plugin_t *plugin)
plugin->handle_context->client = plugin->client;
}
log_info("Initialize plugin: %s", neu_plugin_module.module_name);
return 0;
}
static int opcua_plugin_uninit(neu_plugin_t *plugin)
{
opcua_handle_stop(plugin->handle_context);
open62541_client_close(plugin->client);
opcua_option_uninit(&plugin->option);
free(plugin->handle_context);
log_info("Uninitialize plugin: %s", neu_plugin_module.module_name);
return 0;
}
static int opcua_plugin_config(neu_plugin_t *plugin, neu_config_t *configs)
{
if (NULL == configs || NULL == configs->buf) {
return -1;
}
int rc = opcua_option_init_by_config(configs, &plugin->option);
if (0 != rc) {
log_error("OPCUA option init fail:%d, initialize plugin failed: %s", rc,
neu_plugin_module.module_name);
opcua_option_uninit(&plugin->option);
return -1;
}
plugin->common.link_state = NEU_PLUGIN_LINK_STATE_CONNECTED;
log_info("Config plugin: %s", neu_plugin_module.module_name);
return 0;
}