forked from open62541/open62541
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Signed-off-by: Vasilij Strassheim <[email protected]>
- Loading branch information
1 parent
31cb119
commit c87ad5f
Showing
7 changed files
with
1,150 additions
and
663 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,198 @@ | ||
| /* This Source Code Form is subject to the terms of the Mozilla Public | ||
| * License, v. 2.0. If a copy of the MPL was not distributed with this | ||
| * file, You can obtain one at http://mozilla.org/MPL/2.0/. | ||
| * | ||
| * Copyright 2014-2018 (c) Fraunhofer IOSB (Author: Julius Pfrommer) | ||
| * Copyright 2014, 2017 (c) Florian Palm | ||
| * Copyright 2015-2016 (c) Sten Grüner | ||
| * Copyright 2015 (c) Chris Iatrou | ||
| * Copyright 2015-2016 (c) Oleksiy Vasylyev | ||
| * Copyright 2016-2017 (c) Stefan Profanter, fortiss GmbH | ||
| * Copyright 2017 (c) Julian Grothoff | ||
| */ | ||
|
|
||
| #ifndef SRC_SERVER_UA_DISCOVERY_AVAHI_INCLUDED | ||
| #define SRC_SERVER_UA_DISCOVERY_AVAHI_INCLUDED | ||
|
|
||
| #ifndef UA_DISCOVERY_MANAGER_H_ | ||
| #define UA_DISCOVERY_MANAGER_H_ | ||
|
|
||
| #include "ua_server_internal.h" | ||
|
|
||
| _UA_BEGIN_DECLS | ||
|
|
||
| #ifdef UA_ENABLE_DISCOVERY | ||
|
|
||
| #ifdef UA_ENABLE_DISCOVERY | ||
| struct UA_DiscoveryManager; | ||
| typedef struct UA_DiscoveryManager UA_DiscoveryManager; | ||
| #endif | ||
|
|
||
| typedef struct registeredServer { | ||
| LIST_ENTRY(registeredServer) pointers; | ||
| UA_RegisteredServer registeredServer; | ||
| UA_DateTime lastSeen; | ||
| } registeredServer; | ||
|
|
||
| /* Store async register service calls. So we can cancel outstanding requests | ||
| * during shutdown. */ | ||
| typedef struct { | ||
| UA_DelayedCallback cleanupCallback; /* delayed cleanup */ | ||
| UA_Server *server; | ||
| UA_DiscoveryManager *dm; | ||
| UA_Client *client; | ||
| UA_String semaphoreFilePath; | ||
| UA_Boolean unregister; | ||
|
|
||
| UA_Boolean register2; | ||
| UA_Boolean shutdown; | ||
| UA_Boolean connectSuccess; | ||
| } asyncRegisterRequest; | ||
| #define UA_MAXREGISTERREQUESTS 4 | ||
|
|
||
| #ifdef UA_ENABLE_DISCOVERY_MULTICAST | ||
|
|
||
| #include <avahi-client/client.h> | ||
| #include <avahi-client/lookup.h> | ||
| #include <avahi-client/publish.h> | ||
| #include <avahi-common/simple-watch.h> | ||
| #include <avahi-common/strlst.h> | ||
| #include <avahi-common/error.h> | ||
|
|
||
| typedef struct { | ||
| AvahiSimplePoll *simple_poll; | ||
| AvahiClient *client; | ||
| AvahiEntryGroup *group; | ||
| AvahiServiceBrowser *browser; | ||
| } AvahiServiceContext; | ||
|
|
||
| /** | ||
| * TXT record: | ||
| * [servername]-[hostname]._opcua-tcp._tcp.local. TXT path=/ caps=NA,DA,... | ||
| * | ||
| * A/AAAA record for all ip addresses: | ||
| * [servername]-[hostname]._opcua-tcp._tcp.local. A [ip]. | ||
| * [hostname]. A [ip]. | ||
| */ | ||
|
|
||
| typedef struct serverOnNetwork { | ||
| LIST_ENTRY(serverOnNetwork) pointers; | ||
| UA_ServerOnNetwork serverOnNetwork; | ||
| UA_DateTime created; | ||
| UA_DateTime lastSeen; | ||
| UA_Boolean txtSet; | ||
| UA_Boolean srvSet; | ||
| char* pathTmp; | ||
| } serverOnNetwork; | ||
|
|
||
| #define SERVER_ON_NETWORK_HASH_SIZE 1000 | ||
| typedef struct serverOnNetwork_hash_entry { | ||
| serverOnNetwork *entry; | ||
| struct serverOnNetwork_hash_entry* next; | ||
| } serverOnNetwork_hash_entry; | ||
|
|
||
| #endif | ||
|
|
||
| struct UA_DiscoveryManager { | ||
| UA_ServerComponent sc; | ||
|
|
||
| UA_UInt64 discoveryCallbackId; | ||
|
|
||
| /* Outstanding requests. So they can be cancelled during shutdown. */ | ||
| asyncRegisterRequest registerRequests[UA_MAXREGISTERREQUESTS]; | ||
|
|
||
| LIST_HEAD(, registeredServer) registeredServers; | ||
| size_t registeredServersSize; | ||
| UA_Server_registerServerCallback registerServerCallback; | ||
| void* registerServerCallbackData; | ||
|
|
||
| # ifdef UA_ENABLE_DISCOVERY_MULTICAST | ||
| AvahiServiceContext *ctx; | ||
| UA_Boolean mdnsMainSrvAdded; | ||
|
|
||
| /* Full Domain Name of server itself. Used to detect if received mDNS | ||
| * message was from itself */ | ||
| UA_String selfFqdnMdnsRecord; | ||
|
|
||
| LIST_HEAD(, serverOnNetwork) serverOnNetwork; | ||
|
|
||
| UA_UInt32 serverOnNetworkRecordIdCounter; | ||
| UA_DateTime serverOnNetworkRecordIdLastReset; | ||
|
|
||
| /* hash mapping domain name to serverOnNetwork list entry */ | ||
| struct serverOnNetwork_hash_entry* serverOnNetworkHash[SERVER_ON_NETWORK_HASH_SIZE]; | ||
|
|
||
| UA_Server_serverOnNetworkCallback serverOnNetworkCallback; | ||
| void *serverOnNetworkCallbackData; | ||
|
|
||
| UA_UInt64 mdnsCallbackId; | ||
| # endif /* UA_ENABLE_DISCOVERY_MULTICAST */ | ||
| }; | ||
|
|
||
| void | ||
| UA_DiscoveryManager_setState(UA_DiscoveryManager *dm, | ||
| UA_LifecycleState state); | ||
|
|
||
| #ifdef UA_ENABLE_DISCOVERY_MULTICAST | ||
|
|
||
|
|
||
| /** note: ua_discovery "internals" */ | ||
| void UA_DiscoveryManager_clearMulticast(UA_DiscoveryManager *dm); | ||
| void UA_DiscoveryManager_startMulticast(UA_DiscoveryManager *dm); | ||
| void UA_DiscoveryManager_stopMulticast(UA_DiscoveryManager *dm); | ||
|
|
||
|
|
||
| /** note: ua_services_discovery :*/ | ||
|
|
||
| /* Sends out a new mDNS package for the given server data. This Method is | ||
| * normally called when another server calls the RegisterServer Service on this | ||
| * server. Then this server is responsible to send out a new mDNS package to | ||
| * announce it. | ||
| * | ||
| * Additionally this method also adds the given server to the internal | ||
| * serversOnNetwork list so that a client finds it when calling | ||
| * FindServersOnNetwork. */ | ||
| void | ||
| UA_Discovery_updateMdnsForDiscoveryUrl(UA_DiscoveryManager *dm, const UA_String serverName, | ||
| const UA_MdnsDiscoveryConfiguration *mdnsConfig, | ||
| const UA_String discoveryUrl, UA_Boolean isOnline, | ||
| UA_Boolean updateTxt); | ||
|
|
||
|
|
||
|
|
||
|
|
||
|
|
||
| // UA_StatusCode | ||
| // UA_DiscoveryManager_addEntryToServersOnNetwork(UA_DiscoveryManager *dm, | ||
| // const char *fqdnMdnsRecord, | ||
| // UA_String serverName, | ||
| // struct serverOnNetwork **addedEntry); | ||
|
|
||
| // UA_StatusCode | ||
| // UA_DiscoveryManager_removeEntryFromServersOnNetwork(UA_DiscoveryManager *dm, | ||
| // const char *fqdnMdnsRecord, | ||
| // UA_String serverName); | ||
|
|
||
| // void mdns_record_received(const struct resource *r, void *data); | ||
|
|
||
| // void mdns_create_txt(UA_DiscoveryManager *dm, const char *fullServiceDomain, | ||
| // const char *path, const UA_String *capabilites, | ||
| // const size_t capabilitiesSize, | ||
| // void (*conflict)(char *host, int type, void *arg)); | ||
|
|
||
| // void mdns_set_address_record(UA_DiscoveryManager *dm, const char *fullServiceDomain, | ||
| // const char *localDomain); | ||
|
|
||
| // mdns_record_t * | ||
| // mdns_find_record(mdns_daemon_t *mdnsDaemon, unsigned short type, | ||
| // const char *host, const char *rdname); | ||
|
|
||
| #endif /* UA_ENABLE_DISCOVERY_MULTICAST */ | ||
|
|
||
| #endif /* UA_ENABLE_DISCOVERY */ | ||
|
|
||
| _UA_END_DECLS | ||
|
|
||
| #endif /* UA_DISCOVERY_MANAGER_H_ */ | ||
|
|
||
| #endif /* SRC_SERVER_UA_DISCOVERY_AVAHI_INCLUDED */ |
Oops, something went wrong.