Sensix Wireless Sensor Network Middleware    Home    Project Page    Download    CVS  Hosted by

/home/brennan/Software/sensix/source/discovery_service.h Go to the documentation of this file. /* * Copyright 2008. Los Alamos National Security, LLC. This material * was produced under U.S. Government contract DE-AC52-06NA25396 for * Los Alamos National Laboratory (LANL), which is operated by Los * Alamos National Security, LLC, for the Department of Energy. The * U.S. Government has rights to use, reproduce, and distribute this * software. NEITHER THE GOVERNMENT NOR LOS ALAMOS NATIONAL SECURITY, * LLC, MAKES ANY WARRANTY, EXPRESS OR IMPLIED, OR ASSUMES ANY LEGAL * LIABILITY FOR THE USE OF THIS SOFTWARE. If software is modified to * produce derivative works, such modified software should be clearly * marked, so as not to confuse it with the version available from LANL. * * Additionally, this program is free software; you can redistribute * it and/or modify it under the terms of the GNU General Public * License as published by the Free Software Foundation; version 2 of * the License. Accordingly, this program is distributed in the hope * it will be useful, but WITHOUT ANY WARRANTY; without even the * implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR * PURPOSE. See the GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program; if not, write to the Free Software * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA. */ #ifndef _DISCOVERY_SERVICE_H_ #define _DISCOVERY_SERVICE_H_ #ifdef __cplusplus extern "C" { #endif enum DiscoveryError { RegistryFull, AlreadyRegistered, BadORB, InvalidObject, NoNode, NoNetwork, NoCapability }; #ifndef IDL #define DISCOVERY_PORT 2999 #define MCAST_ADDR_IPv6 "FF18::178" #define MCAST_ADDR_IPv4 "224.0.0.178" #ifdef IPV6 #define MCAST_ADDR MCAST_ADDR_IPv6 #else #define MCAST_ADDR MCAST_ADDR_IPv4 #endif // NB: the following are for wired networking, adjust as needed #define TX_TIMEOUT 12 // max ms between hdr & body #define RETRY_ITVL 4 // tx retry buffer time (ms) #define EMPTY_TIMEOUT 1000 // ms block on recv #define DISCOVERY_HEADER_SIZE 8 #define TOO_SMALL -100 #define REGISTRY_FULL (0 - RegistryFull) #define ALREADY_REGISTERED (0 - AlreadyRegistered) #define INVALID_OBJECT (0 - InvalidObject) #define NO_NODE (0 - NoNode) #define NO_NETWORK (0 - NoNetwork) #define NO_CAPABILITY (0 - NoCapability) #include <stdint.h> #include "sense_impl.h" #define OBJ_REF_SIZE 2048 typedef struct _obj_ref { uint32_t id; uint8_t type; char ior[OBJ_REF_SIZE]; bool_t valid; } object_reference_t; #define ANNOUNCE_SIZE 5 typedef struct _announce { uint32_t nodeIdent; uint8_t hLevel; } Announce; #define REPORT_SIZE 6 typedef struct _report { uint32_t nodeIdent; uint8_t hLevel; uint8_t cType; } Report; #define REQUIRE_SIZE 10 typedef struct _require { uint32_t nodeIdent; uint8_t hLevel; uint8_t cType; uint32_t targetIdent; } Require; typedef struct _share { uint32_t nodeIdent; uint8_t hLevel; uint8_t cType; unsigned char ior[OBJ_REF_SIZE + 1]; } Share; void announceHeader(uint8_t *hdr); void reportHeader(uint8_t *hdr); void requireHeader(uint8_t *hdr); void shareHeader(uint8_t *hdr, Share *shr); void loadAnnounce(uint8_t *msg, Announce *ann); void loadReport(uint8_t *msg, Report *rpt); void loadRequire(uint8_t *msg, Require *req); void loadShare(uint8_t *msg, Share *shr); typedef struct _discoverhdr { bool_t little_endian; uint8_t announceType; size_t announceSize; } DiscoverHeader; typedef struct _discovermsg { uint32_t nodeIdent; uint8_t hLevel; uint8_t cType; uint32_t targetIdent; unsigned char ior[OBJ_REF_SIZE + 1]; } DiscoverMessage; int parseDiscoverHeader(DiscoverHeader *hdr, unsigned char *bytes); int parseDiscoverMessage(DiscoverMessage *dm, DiscoverHeader *hdr, unsigned char *bytes); uint8_t self_level(); uint32_t self_identifier(); int self_capabilities(uint8_t *caps, size_t *size); int self_register_object(uint8_t capability, object_reference_t *obj, bool_t override); bool_t descendants_findNode(uint32_t id); int descendants_queryNetwork(object_reference_t *objrefs, size_t *num, uint8_t capability); int descendants_queryNode(object_reference_t *objref, uint32_t id, uint8_t capability); int descendants_capabilities(uint8_t *caps, size_t *num); int descendants_nodes(uint32_t *ids, size_t *num); bool_t siblings_findNode(uint32_t id); int siblings_queryNetwork(object_reference_t *objrefs, size_t *num, uint8_t capability); int siblings_queryNode(object_reference_t *objref, uint32_t id, uint8_t capability); int siblings_capabilities(uint8_t *caps, size_t *num); int siblings_nodes(uint32_t *ids, size_t *num); bool_t ancestors_findNode(uint32_t id); int ancestors_nodes(uint32_t *ids, size_t *num); bool_t family_findNode(uint32_t id); int family_queryNetwork(object_reference_t *objrefs, size_t *num, uint8_t capability); int family_queryNode(object_reference_t *objref, uint32_t id, uint8_t capability); typedef struct _disc_args { uint32_t node_id; uint8_t h_level; uint32_t service_port; } discovery_args_t; void *discovery_service(void *args); #endif // IDL #ifdef __cplusplus } #endif #endif // _DISCOVERY_SERVICE_H_

© 2008, Los Alamos National Security, LLC.