DataSource for C SDK  7.1.32.168791-9652659d
datasrc.h
Go to the documentation of this file.
1 /*
2  *
3  * Copyright CAPLIN Systems Ltd 2000-2007
4  *
5  *
6  * $Author$
7  * $DateTime$
8  * $Change$
9  * $Id$
10  *
11  *
12  */
13 
14 #ifdef __cplusplus
15 extern "C" {
16 #endif
17 
18 
19 #ifndef __DATASRC_H__
20 #define __DATASRC_H__
21 
22 
23 #undef DATASRC_MAJOR_VERSION
24 #undef DATASRC_MINOR_VERSION
25 #undef DATASRC_PATCH_VERSION
26 
27 #define DATASRC_MAJOR_VERSION 7
28 #define DATASRC_MINOR_VERSION 1
29 #define DATASRC_PATCH_VERSION 32
30 
31 
32 #include <stdio.h>
33 #include <stdlib.h>
34 
35 #ifdef WIN32
36 
37 #include <winsock2.h>
38 #include <windows.h>
39 #include <time.h>
40 #include <ws2tcpip.h>
41 #include <direct.h>
42 #include <io.h>
43 #include <mswsock.h>
44 
45 #else /* ! WIN32 */
46 
47 #include <sys/time.h>
48 #include <sys/types.h>
49 #include <unistd.h>
50 #include <netinet/in.h>
51 #include <sys/socket.h>
52 #include <arpa/inet.h>
53 #include <netdb.h>
54 #include <sys/ioctl.h>
55 #include <net/if.h>
56 #include <sys/uio.h>
57 #include <sys/timeb.h>
58 #include <utime.h>
59 
60 #endif /* ! WIN32 */
61 
62 #include <limits.h>
63 #include <sys/stat.h>
64 #include <string.h>
65 #include <fcntl.h>
66 #include <stdarg.h>
67 #include <errno.h>
68 
69 #define EXIT_CODE_NML 0
70 #define EXIT_CODE_CFG 1
71 #define EXIT_CODE_LOG 2
72 #define EXIT_CODE_NET 3
73 #define EXIT_CODE_SYS 4
74 #define EXIT_CODE_LIC 5
75 #define EXIT_CODE_SIG 6
76 #define EXIT_CODE_SVC 7
77 #define EXIT_CODE_SSL 8
78 #define EXIT_CODE_JVM 9
79 
80 /* Reserve codes for binary start-up issues */
81 #define EXIT_CODE_BIN_MISSING 10
82 #define EXIT_CODE_BIN_NOT_EXEC 11
83 #define EXIT_CODE_BIN_EXIT_AFTER_FORK 12
84 #define EXIT_CODE_BIN_BAD_ARCH 126
85 
86 /* Reserve an exit code for Java DataSource blade errors */
87 #define EXIT_CODE_JAVA_DATASOURCE_ERROR 201
88 
89 #define EXIT_CODE_GRACEFUL 202
90 
91 
92 #ifndef WIN32
93 #ifndef DATASRCAPI
94 #define DATASRCAPI
95 #endif
96 #else /* WIN32 */
97 #ifndef DATASRCAPI
98 #ifndef DATASRC_EXPORT
99 #define DATASRCAPI _declspec(dllimport)
100 #else
101 #define DATASRCAPI _declspec(dllexport)
102 #endif
103 #endif
104 #endif /* WIN32 */
105 
106 
107 /* Provide some protection for variadic arguments */
108 #ifdef __GNUC__
109 #define PRINTF(fmt,arg) __attribute__ ((__format__ (__printf__, (fmt), (arg))))
110 #else
111 #define PRINTF(fmt,arg)
112 #endif
113 
114 
120 /* Types */
121 
126 #ifndef WIN32
127 typedef int sock_t;
128 
135 #define INVALID_SOCKET -1
136 
142 #define SOCKET_ERROR -1
143 #else /* WIN32 */
144 
145 typedef SOCKET sock_t;
146 #include <inttypes.h>
147 #endif /* WIN32 */
148 
152 typedef struct _ds_peer_set ds_set_t;
153 
154 typedef uint64_t ds_bitfield_t;
155 
156 typedef struct _ds_data ds_data_t;
157 
158 typedef struct _ds_field ds_field_t;
159 
163 typedef struct _ds_delay ds_delay_t;
164 
165 
169 typedef struct _config_ctx ds_config_ctx_t;
170 
174 typedef struct _ds_log ds_log_t;
175 
190 typedef void (*recv_update_t)(int peer, ds_data_t *pkt);
191 
208 typedef void (*recv_replay_t)(int peer, ds_data_t *pkt, time_t tm);
209 
228 typedef void (*recv_nodata_t)(int peer, char *subject, unsigned short flags);
229 
252 typedef void (*recv_peer_status_t)(int peer, int status, int val, void *data);
253 
272 typedef void (*recv_request_t)(int peer, int count, char **subjects, unsigned short flags);
273 
292 typedef void (*recv_discard_t)(int peer, int count, char **subjects, unsigned short flags);
293 
313 typedef void (*recv_object_status_t)(int peer, char *subject, int status, unsigned short code, char *msgstr);
314 
324 typedef void (*recv_service_status_t)(char *service, int status);
325 
326 
336 typedef void (*recv_map_t)(int peer, char *from, char *to);
337 
338 
356 typedef struct
357  {
360  char *log_root;
361  unsigned short flags;
362  unsigned short type;
378  void (*exit_func)(int exit_code, char *msg);
380  char *logfile;
382  }
383 ds_init_t;
384 
389 #define DS_INITIALISER \
390  { \
391  NULL, /* application_name */ \
392  NULL, /* application_root */ \
393  NULL, /* log_root */ \
394  0, /* flags */ \
395  0, /* type */ \
396  NULL, /* recv_request */ \
397  NULL, /* recv_discard */ \
398  NULL, /* recv_update */ \
399  NULL, /* recv_nodata */ \
400  NULL, /* recv_peer_status */ \
401  NULL, /* recv_object_status */ \
402  NULL, /* recv_service_status */ \
403  NULL, /* recv_map */ \
404  NULL, /* exit_func */ \
405  NULL, /* logfile */ \
406  NULL, /* log */ \
407  }
408 
409 
410 /* datasrc */
411 
412 DATASRCAPI void ds_reserve_std_fds(void);
413 DATASRCAPI void ds_config_init(const char *file, int argc, char **argv);
414 DATASRCAPI int ds_init(ds_init_t *init, int argc, char **argv);
415 DATASRCAPI void ds_thread_init(int event_module, int flags);
416 DATASRCAPI char *ds_filename_expand(const char *format, char *buffer, size_t bufsize);
417 DATASRCAPI ds_log_t *ds_get_event_log(void);
418 
419 
420 /* ds5 */
421 
422 
427 
432  {
438  void (*free)(ds5_namespace_t *nspace);
439 
448  int (*match)(ds5_namespace_t *nspace, const char *subject);
449 
450 
459  char *(*describe)(ds5_namespace_t *nspace, char *buf, size_t buflen);
460 
461  };
462 
463 
464 DATASRCAPI ds5_namespace_t *ds5_create_prefix_namespace(const char *prefix);
465 
466 DATASRCAPI ds5_namespace_t *ds5_create_globbed_namespace(const char *globbed);
467 DATASRCAPI ds5_namespace_t *ds5_create_regex_namespace(const char *expr);
468 DATASRCAPI int ds5_regex_namespace_add_expr(ds5_namespace_t *nspace, const char *expr, int exclude);
469 
470 
471 /* Macros for convenience */
472 
480 #define ds5_namespace_match(nspace, subject) nspace->match(nspace, subject)
481 
486 #define ds5_namespace_free(nspace) nspace->free(nspace)
487 
488 
489 
490 
491 
500 typedef struct _ds5_publisher_s ds5_publisher_t;
501 
502 
503 
504 
505 
506 
507 
518 typedef struct
519  {
538  void (*receive_request)(void *context, int peer, const char *subject);
539 
560  void (*receive_discard)(void *context, int peer, const char *subject);
561  }
563 
564 
565 DATASRCAPI ds5_publisher_t *ds5_create_active_publisher(ds5_namespace_t *nspace, ds5_dataprovider_t *provider, void *context);
566 DATASRCAPI ds5_publisher_t *ds5_create_compatibility_publisher(ds5_namespace_t *nspace, ds5_dataprovider_t *provider, void *context);
568 
570 DATASRCAPI void ds5_publish_to_subscribed_peers(ds5_publisher_t *pub, ds_data_t *dsdata);
571 DATASRCAPI void ds5_publish_response(ds5_publisher_t *pub, ds_data_t *dsdata);
572 DATASRCAPI void ds5_publish_response_no_free(ds5_publisher_t *pub, ds_data_t *dsdata);
573 DATASRCAPI void ds5_publish_status(ds5_publisher_t *pub, const char *subject, int status, const char *message);
574 DATASRCAPI void ds5_publish_status_all(ds5_publisher_t *pub, int status, const char *message);
575 DATASRCAPI void ds5_publish_subject_error(ds5_publisher_t *publisher, const char *subject, int flags);
576 DATASRCAPI void ds5_publish_to_peer(ds5_publisher_t *publisher, int peernum, ds_data_t *dsdata);
577 DATASRCAPI void ds5_publish_to_peer_no_free(ds5_publisher_t *publisher, int peernum, ds_data_t *dsdata);
578 DATASRCAPI void ds5_publish_subject_map(ds5_publisher_t *publisher, const char *subject, const char *mapped_to, int flags);
579 
580 
594 typedef struct
595  {
606  void (*service_status)(void *context, const char *service_name, int state);
607 
619  void (*peer_status)(void *context, int peer_index, const char *peer_name, int state);
620  }
622 
623 
633 typedef struct _ds5_subscription_s ds5_subscription_t;
634 
635 
648 typedef struct
649  {
659  void (*record_updated)(void *context, ds5_subscription_t *sub, int peer, ds_data_t *dsdata);
660 
670  void (*record_type2_updated)(void *context, ds5_subscription_t *sub, int peer, ds_data_t *dsdata);
671 
681  void (*record_type3_updated)(void *context, ds5_subscription_t *sub, int peer, ds_data_t *dsdata);
682 
692  void (*container_updated)(void *context, ds5_subscription_t *sub, int peer, ds_data_t *dsdata);
693 
703  void (*permission_updated)(void *context, ds5_subscription_t *sub, int peer, ds_data_t *dsdata);
704 
714  void (*news_updated)(void *context, ds5_subscription_t *sub, int peer, ds_data_t *dsdata);
715 
725  void (*news_story_updated)(void *context, ds5_subscription_t *sub, int peer, ds_data_t *dsdata);
726 
736  void (*page_updated)(void *context, ds5_subscription_t *sub, int peer, ds_data_t *dsdata);
737 
750  void (*unknown_subject_type_updated)(void *context, ds5_subscription_t *sub, int peer, ds_data_t *dsdata);
751 
752 
763  void (*subscription_error)(void *context, ds5_subscription_t *sub, int peer, const char *subject, short flags);
764 
776  void (*subscription_status)(void *context, ds5_subscription_t *sub, int peer, const char *subject, int status, const char *message);
777  }
779 
780 
781 
782 
783 
784 DATASRCAPI void ds5_config_init(const char *configfile, int argc, char **argv);
785 DATASRCAPI int ds5_init(int argc, char **argv);
786 DATASRCAPI void ds5_add_connectionlistener(ds5_connectionlistener_t *connection_listener, void *context);
787 
788 
789 
790 
792 DATASRCAPI ds5_subscription_t *ds5_create_active_subscription(const char *subject, ds5_subscriptionlistener_t *listener, void *context);
793 DATASRCAPI void ds5_unsubscribe(ds5_subscription_t *sub);
794 
795 
796 
797 /* config */
798 
799 
808 #define DS_OFFSET(t,m) ((void *)&((t *)0)->m)
809 
813 #define DS_CONFIG_BOOL 0x0001
814 
819 #define DS_CONFIG_INT 0x0002
820 
824 #define DS_CONFIG_FLOAT 0x0003
825 
829 #define DS_CONFIG_STR 0x0004
830 
834 #define DS_CONFIG_CHAR 0x0005
835 
839 #define DS_CONFIG_FUNC 0x0006
840 
844 #define DS_CONFIG_FILE 0x0007
845 
849 #define DS_CONFIG_LONG 0x0008
850 
853 #define DS_CONFIG_GROUP 0x0010
854 #define DS_CONFIG_GROUP_END 0x0011
855 #define DS_CONFIG_SECTION 0x0020
856 #define DS_CONFIG_SECTION_END 0x0021
857 
861 #define DS_CONFIG_JAVA 0x0080
862 
866 #define DS_CONFIG_ARRAY 0x0100
867 
872 #define DS_CONFIG_INT_ARRAY (DS_CONFIG_ARRAY|DS_CONFIG_INT)
873 
877 #define DS_CONFIG_FLOAT_ARRAY (DS_CONFIG_ARRAY|DS_CONFIG_FLOAT)
878 
879 
883 #define DS_CONFIG_STR_ARRAY (DS_CONFIG_ARRAY|DS_CONFIG_STR)
884 
888 #define DS_CONFIG_CHAR_ARRAY (DS_CONFIG_ARRAY|DS_CONFIG_CHAR)
889 
893 #define DS_CONFIG_STRICT 0x0200
894 
899 #define DS_CONFIG_DEPRECATED 0x0400
900 
901 
923 typedef struct
924  {
925  char *name;
926  double value;
927  char *docstring;
928  }
930 
931 
944 typedef void (*ds_config_func)(char *name, int num, char **values);
945 
946 
947 DATASRCAPI ds_config_ctx_t *ds_config_new_ctx(void);
948 DATASRCAPI void ds_config_free_ctx(ds_config_ctx_t *ctx);
950 DATASRCAPI void ds_config_add_search(const char *path);
951 DATASRCAPI void ds_config_add_file(const char *file);
952 DATASRCAPI void ds_config_add_optional_file(const char *file);
953 DATASRCAPI void ds_config_add_option(char opt, const char *longopt, const char *help, int type, void *value);
954 DATASRCAPI void ds_config_add_bounded_option(char sopt,const char *longopt, const char *help, int type, void *value, void *min, void *max);
955 DATASRCAPI void ds_config_add_option_enum(char opt,const char *longopt, const char *help, int type, void *value, ds_config_enum_t *enums);
956 DATASRCAPI void ds_config_add_bounded_option_enum(char sopt,const char *longopt, const char *help, int type, void *value, ds_config_enum_t *enums, void *min, void *max);
957 DATASRCAPI void ds_config_add_array_option(const char *longopt, const char *help, int type, void *value, int *num);
958 DATASRCAPI void ds_config_add_bounded_array_option(const char *longopt,const char *help, int type, void *value, int *num, void *min, void *max);
959 DATASRCAPI void ds_config_add_array_option_enum(const char *longopt,const char *help, int type, void *value, int *num, ds_config_enum_t *enums);
960 DATASRCAPI void ds_config_add_bounded_array_option_enum(const char *longopt,const char *help, int type, void *value, int *num, ds_config_enum_t *enums, void *min, void *max);
961 DATASRCAPI void ds_config_del_option(const char *longopt);
962 DATASRCAPI void ds_config_add_group(const char *longopt, const char *help, void *base, void *def, size_t size, int *num);
963 DATASRCAPI void ds_config_add_group_with_info(const char *longopt, const char *help, void *base, void *def, size_t size, int *num, int file_offset, int line_offset);
964 DATASRCAPI void ds_config_end_group(const char *longopt,const char *help);
965 DATASRCAPI void ds_config_add_section(const char *longopt,const char *help);
966 DATASRCAPI void ds_config_end_section(const char *longopt,const char *help);
967 DATASRCAPI void ds_config_parse_files(void);
968 DATASRCAPI void ds_config_parse_args(int argc, char **argv, int *retargc);
969 DATASRCAPI int ds_config_parse_file(const char *unresolved_filename);
970 DATASRCAPI void ds_config_list_options(void);
971 DATASRCAPI void ds_config_list_values(void);
972 DATASRCAPI int ds_config_get_enum(const char *value, ds_config_enum_t *enums);
973 DATASRCAPI void ds_config_add_error_message_fmt(const char *fmt,...) PRINTF(1,2);
974 DATASRCAPI void ds_config_add_config_reading_message_fmt(const char *fmt,...) PRINTF(1,2);
975 DATASRCAPI void ds_config_add_error_message(const char *msg);
976 DATASRCAPI char *ds_config_get_filename(void);
977 DATASRCAPI int ds_config_get_linenumber(void);
978 DATASRCAPI void ds_config_set_test(const char *tag, char **value);
979 DATASRCAPI void ds_config_del_test(const char *tag);
980 DATASRCAPI void ds_config_set_option(const char *name, const char *value);
981 
982 
983 /* event */
984 
985 
986 typedef unsigned long ds_reltime_t;
987 
992 typedef struct _ds_timed_event ds_timed_event_t;
993 
994 
999 typedef struct _ds_io_event ds_except_event_t;
1000 
1001 
1002 
1007 typedef struct _ds_io_event ds_read_event_t;
1008 
1009 
1014 typedef struct _ds_io_event ds_write_event_t;
1015 
1016 
1021 typedef struct _ds_io_event ds_generic_event_t;
1022 
1023 
1034 typedef int (*ds_io_event_cb)(sock_t sock, int val, void *data);
1035 
1046 typedef int (*ds_timed_event_cb)(int id, int val, void *data);
1047 
1048 
1049 #define DOUBLE_TO_RELTIME(r,d) r = ((int)(d) << 9) + ((int)(((d) - (int)(d)) * 1000000) >> 11);
1050 #define TIMEVAL_TO_RELTIME(r,tv) r = ((tv).tv_sec << 9) + ((tv).tv_usec >> 11);
1051 
1052 
1053 DATASRCAPI ds_timed_event_t *ds_add_timed_event(int id, double delay, ds_timed_event_cb cb, int val, void *data);
1054 DATASRCAPI ds_read_event_t *ds_add_read_event(sock_t fd, ds_io_event_cb cb, int val, void *data);
1055 DATASRCAPI ds_write_event_t *ds_add_write_event(sock_t fd, ds_io_event_cb cb, int val, void *data);
1056 DATASRCAPI ds_except_event_t *ds_add_except_event(sock_t fd, ds_io_event_cb cb, int val, void *data);
1057 
1058 DATASRCAPI int ds_del_timed_event(ds_timed_event_t *ev);
1059 DATASRCAPI int ds_del_read_event(ds_read_event_t *ev);
1060 DATASRCAPI int ds_del_write_event(ds_write_event_t *ev);
1061 DATASRCAPI int ds_del_except_event(ds_except_event_t *ev);
1062 
1063 DATASRCAPI int ds_del_timed_event_free_data(ds_timed_event_t *ev, void (*free_data)(int, void *));
1064 DATASRCAPI int ds_del_read_event_free_data(ds_read_event_t *ev, void (*free_data)(int, void *));
1065 DATASRCAPI int ds_del_write_event_free_data(ds_write_event_t *ev, void (*free_data)(int, void *));
1066 DATASRCAPI int ds_del_except_event_free_data(ds_except_event_t *ev, void (*free_data)(int, void *));
1067 
1068 DATASRCAPI void ds_timed_event_set_callback(ds_timed_event_t *ev, ds_timed_event_cb cb, int val, void *data);
1069 DATASRCAPI double ds_timed_event_get_fire_time(ds_timed_event_t *ev);
1070 DATASRCAPI void ds_read_event_set_callback(ds_read_event_t *ev, ds_io_event_cb cb, int val, void *data);
1071 DATASRCAPI void ds_write_event_set_callback(ds_write_event_t *ev, ds_io_event_cb cb, int val, void *data);
1072 
1073 DATASRCAPI void ds_set_timed_delay(ds_timed_event_t *ev, double delay);
1074 DATASRCAPI void ds_set_timed_delay_next(ds_timed_event_t *ev, double delay);
1075 
1076 DATASRCAPI void ds_loop(void);
1077 DATASRCAPI void ds_stop(void);
1078 
1079 DATASRCAPI ds_reltime_t ds_get_relative_time(void);
1080 DATASRCAPI time_t ds_get_time(void);
1081 DATASRCAPI struct tm *ds_gmtime(void);
1082 DATASRCAPI struct tm *ds_localtime(void);
1083 DATASRCAPI int ds_get_gmt_offset(time_t t);
1084 DATASRCAPI char *ds_get_timezone(char *buf, int len);
1085 
1086 DATASRCAPI ds_timed_event_t *ds_add_periodic_event(int starttime, int period, int id, ds_timed_event_cb cb, int val, void *data);
1087 DATASRCAPI ds_timed_event_t *ds_add_periodic_event_from_time(time_t then, int starttime, int period, int id, ds_timed_event_cb cb, int val, void *data);
1088 DATASRCAPI int ds_check_periodic_event(int period, ds_timed_event_t **tev);
1089 
1090 
1091 /* cache */
1092 
1097 #define DS_CACHE_DATASRC -1
1098 
1099 DATASRCAPI void ds_cache_add_object(char *subject);
1100 
1101 
1102 /* daemon */
1103 
1104 
1105 DATASRCAPI void ds_daemon_redirect(void);
1106 DATASRCAPI int ds_daemon_disabled(void);
1107 
1108 
1109 /* fields */
1110 
1111 
1119 #define DS_FIELDS_SEPARATOR -65536
1120 
1126 #define DS_FIELDS_NOT_DEFINED (-2147483647 - 1)
1127 
1128 DATASRCAPI int ds_fields_max(void);
1129 DATASRCAPI int ds_fields_add(int num, const char *name, int flags, int dp, const char *fmt);
1130 DATASRCAPI int ds_fields_numbyname(const char *name);
1131 DATASRCAPI char *ds_fields_namebynum(int num);
1132 DATASRCAPI int ds_fields_indexbyname(const char *name);
1133 DATASRCAPI int ds_fields_indexbynum(int num);
1134 DATASRCAPI int ds_fields_numbyindex(int index);
1135 DATASRCAPI char *ds_fields_namebyindex(int index);
1136 DATASRCAPI char *ds_fields_rttpnumbyindex(int index);
1137 DATASRCAPI int ds_fields_getflags(int index);
1138 DATASRCAPI int ds_fields_getdp(int index);
1139 
1140 
1141 
1142 /* log */
1143 
1147 #define DS_LOG_CONFIG 0
1148 #define DS_LOG_ALWAYS 1
1149 
1152 #define DS_LOG_CRIT 2
1153 
1156 #define DS_LOG_ERROR 3
1157 
1160 #define DS_LOG_NOTIFY 4
1161 
1164 #define DS_LOG_WARN 5
1165 
1168 #define DS_LOG_INFO 6
1169 
1172 #define DS_LOG_DEBUG 7
1173 
1176 #define DS_LOG_FINER 8
1177 
1180 #define DS_LOG_FINEST 9
1181 
1184 #define DS_LOG_MONITOR 128
1185 
1188 #define DS_LOG_TERMINAL 256
1189 
1192 #define DS_LOG_SYSLOG 512
1193 #define DS_LOG_FILEONLY 1024
1194 #define DS_LOG_NO_MONITOR 2048
1195 
1203 typedef void (*ds_loglevelchange_t)(ds_log_t *log, int new_level);
1204 
1211 typedef void (*ds_logcycled_t)(ds_log_t *log);
1212 
1213 
1214 
1215 
1216 DATASRCAPI ds_log_t *ds_new_log(const char *name,const char *logname);
1217 DATASRCAPI ds_log_t *ds_new_level_log(const char *name, const char *logname, ds_loglevelchange_t change_cb);
1218 DATASRCAPI ds_log_t *ds_new_headed_log(const char *name, const char *logname, const char *header);
1219 DATASRCAPI void ds_free_log(ds_log_t *log);
1220 DATASRCAPI void ds_write(ds_log_t *log, void *data, size_t len);
1221 #ifndef WIN32
1222 DATASRCAPI void ds_writev(ds_log_t *log, struct iovec *vector, int count);
1223 #endif
1224 DATASRCAPI void ds_printf(ds_log_t *log, const char *fmt, ...) PRINTF(2,3);
1225 DATASRCAPI void ds_printf_time(ds_log_t *log, const char *fmt, ...) PRINTF(2,3);
1226 DATASRCAPI void ds_printf_time_ap(ds_log_t *log, const char *extra, const char *fmt, va_list ap);
1227 DATASRCAPI void ds_syslog(ds_log_t *log, int priority, const char *fmt, ...) PRINTF(3,4);
1228 DATASRCAPI void ds_cycle_all_logs(const char *suffix, long maxsize);
1229 DATASRCAPI int ds_cycle_log(ds_log_t *log, const char *suffix, long maxsize);
1230 DATASRCAPI int ds_debug_level(const char *text);
1231 DATASRCAPI char *ds_debug_string(int level);
1232 DATASRCAPI char *ds_debug_config_string(int level);
1233 DATASRCAPI void ds_log(ds_log_t *log, int level, const char *fmt,...) PRINTF(3,4);
1234 DATASRCAPI int ds_log_set_log_level(ds_log_t *log, const char *level);
1235 DATASRCAPI void ds_log_change_level_callback(ds_log_t *log, ds_loglevelchange_t change_cb);
1237 DATASRCAPI char *ds_log_getfilename(ds_log_t *log);
1238 DATASRCAPI char *ds_log_getname(ds_log_t *log);
1239 DATASRCAPI int ds_log_get_level(ds_log_t *log);
1240 DATASRCAPI int ds_log_flush(ds_log_t *log);
1241 
1242 
1243 /* lty_chain */
1244 
1245 
1255 DATASRCAPI void ds_add_latency_chain(ds_data_t *dsdata, char suffix, struct timespec *tp);
1256 
1268 DATASRCAPI void ds_add_latency_chain2(ds_data_t *dsdata, char suffix, struct timespec tp, char suffix2, struct timespec *tp2);
1269 
1274 DATASRCAPI void ds_add_latency_initial_timestamp(ds_data_t *dsdata);
1275 
1276 /* monitor */
1277 
1278 
1282 #define TYPE_NONE 0
1283 
1287 #define TYPE_BINARY 1
1288 
1291 #define TYPE_STRING 2
1292 
1295 #define TYPE_SHORT 3
1296 
1299 #define TYPE_USHORT 4
1300 
1303 #define TYPE_LONG 5
1304 
1307 #define TYPE_ULONG 6
1308 
1311 #define TYPE_LLONG 7
1312 
1315 #define TYPE_ULLONG 8
1316 
1319 #define TYPE_DOUBLE 9
1320 
1325 #define TYPE_TIMESTAMP 10
1326 
1331 #define TYPE_BOOLEAN 11
1332 
1336 #define TYPE_RELATION 20
1337 
1341 #define TYPE_SUBSCRIPTION 21
1342 
1343 
1347 #define TYPE_PRIMITIVE_MASK 31
1348 
1352 #define TYPE_ARRAY 32
1353 
1356 #define TYPE_ACTIVE 64
1357 
1367 #define TYPE_ACTIVE2 128
1368 
1371 #define TYPE_METHOD 256
1372 
1375 #define TYPE_KEY 512
1376 
1379 #define TYPE_HIERARCHY 1024
1380 
1386 #define TYPE_OPTIONAL 2048
1387 
1388 
1394 typedef struct {
1395  size_t size;
1396  union _ds_mondata_value {
1397  void *b;
1398  char **c;
1399  int16_t *s;
1400  uint16_t *us;
1401  int32_t *l;
1402  uint32_t *ul;
1403  int64_t *ll;
1404  uint64_t *ull;
1405  double *d;
1406  } data;
1407  }
1408 ds_array_t;
1409 
1415 typedef struct
1416  {
1418  int datatype;
1419  union _ds_mondata_value2
1420  {
1421  void *active_ptr; /* Do not set used by monitoring API */
1422  char *c;
1423  int16_t s;
1424  uint16_t us; /* Also used for TYPE_BOOLEAN */
1425  int32_t l;
1426  uint32_t ul; /* Also used for TYPE_TIMESTAMP */
1427  int64_t ll;
1428  uint64_t ull;
1429  double d;
1430  ds_array_t array;
1431  }
1432  data;
1433  }
1434 ds_monitor_t;
1435 
1436 
1440 typedef struct
1441  {
1443  char *name;
1444  char *description;
1445  char *docstring;
1446  }
1448 
1449 
1464 typedef ds_monitor_t *(*ds_monitor_method_cb)(char *templatename, char *key, char *property, int argc, char *argv[]);
1465 
1475 typedef ds_monitor_t *(*ds_monitor_active_cb)(char *templatename, char *key, char *propertyname);
1476 
1477 
1478 
1483 typedef struct
1484  {
1485  char *username;
1486  char *password;
1487  char *ipaddress;
1488  }
1489 ds_monauth_t;
1490 
1500 typedef int (*ds_monitor_authenticator_t)(ds_monauth_t *credentials);
1501 
1502 
1503 
1504 DATASRCAPI char *ds_monitor_module_name(void);
1505 
1506 
1507 DATASRCAPI void ds_monitor_add_server_type(const char *type, const char *root);
1508 DATASRCAPI void ds_monitor_start_template(const char *templatename, const char *description);
1509 DATASRCAPI void ds_monitor_add_template_member(const char *templatename, const char *propertyname, const char *description, int typeflags, ds_arguments_t *args, void *ptr);
1510 DATASRCAPI void ds_monitor_add_template_relation(const char *templatename, const char *propertyname, const char *targettemplate, const char *description, int thisend_multiple, int thatend_multiple);
1511 DATASRCAPI void ds_monitor_add_template_subscription(const char *templatename, const char *propertyname, const char *targettemplate, const char *description, const char *singleton, ds_monitor_active_cb callback_fn);
1512 
1513 
1514 DATASRCAPI void ds_monitor_add_relation(const char *templatename, const char *key, const char *propertyname, const char *targetkey);
1515 DATASRCAPI void ds_monitor_del_relation(const char *templatename, const char *key, const char *propertyname, const char *targetkey);
1516 
1517 DATASRCAPI void ds_monitor_add_subscription(const char *templatename, const char *key, const char *propertyname, const char *value);
1518 DATASRCAPI void ds_monitor_del_subscription(const char *templatename, const char *key, const char *propertyname, const char *value);
1519 
1520 DATASRCAPI void ds_monitor_end_template(const char *templatename);
1521 
1522 DATASRCAPI void ds_monitor_create_group(const char *templatename, const char *key, const char *brief, const char *description);
1523 DATASRCAPI void ds_monitor_delete_group(const char *templatename, const char *key);
1524 
1525 
1526 
1527 DATASRCAPI void ds_monitor_update(const char *templatename, const char *key, ds_monitor_t *mondata);
1528 DATASRCAPI void ds_monitor_update_string(const char *templatename, const char *key, const char *propertyname, const char *value);
1529 DATASRCAPI void ds_monitor_update_ushort(const char *templatename, const char *key, const char *propertyname, uint16_t);
1530 DATASRCAPI void ds_monitor_update_short(const char *templatename, const char *key, const char *propertyname, int16_t value);
1531 DATASRCAPI void ds_monitor_update_ulong(const char *templatename, const char *key, const char *propertyname, uint32_t value);
1532 DATASRCAPI void ds_monitor_update_long(const char *templatename,const char *key, const char *propertyname, int32_t value);
1533 DATASRCAPI void ds_monitor_update_ullong(const char *templatename, const char *key, const char *propertyname, uint64_t value);
1534 DATASRCAPI void ds_monitor_update_llong(const char *templatename, const char *key, const char *propertyname, int64_t value);
1535 DATASRCAPI void ds_monitor_update_double(const char *templatename, const char *key, const char *propertyname, double value);
1536 DATASRCAPI void ds_monitor_update_timestamp(const char *templatename, const char *key, const char *propertyname, int64_t value);
1537 DATASRCAPI void ds_monitor_update_boolean(const char *templatename, const char *key, const char *propertyname, uint8_t value);
1538 
1539 
1540 
1541 DATASRCAPI ds_monitor_t *ds_monitor_new(const char *propertyname, int type, int datasize, const void *datum);
1542 DATASRCAPI ds_monitor_t *ds_monitor_new_array(const char *propertyname, int type);
1543 DATASRCAPI void ds_monitor_add_data(ds_monitor_t *data, const void *datum);
1544 DATASRCAPI void ds_monitor_free(ds_monitor_t *data); /* Needed by plugin */
1545 
1546 DATASRCAPI void ds_monitor_free_data(ds_monitor_t *data);
1547 
1548 
1549 DATASRCAPI ds_monitor_t *ds_monitor_new_string(const char *templatename, const char *key, const char *propertyname, const char *value);
1550 DATASRCAPI ds_monitor_t *ds_monitor_new_ushort(const char *templatename, const char *key, const char *propertyname, uint16_t value);
1551 DATASRCAPI ds_monitor_t *ds_monitor_new_short(const char *templatename, const char *key, const char *propertyname, int16_t value);
1552 DATASRCAPI ds_monitor_t *ds_monitor_new_ulong(const char *templatename, const char *key, const char *propertyname, uint32_t value);
1553 DATASRCAPI ds_monitor_t *ds_monitor_new_long(const char *templatename,const char *key, const char *propertyname, int32_t value);
1554 DATASRCAPI ds_monitor_t *ds_monitor_new_ullong(const char *templatename, const char *key, const char *propertyname, uint64_t value);
1555 DATASRCAPI ds_monitor_t *ds_monitor_new_llong(const char *templatename, const char *key, const char *propertyname, int64_t value);
1556 DATASRCAPI ds_monitor_t *ds_monitor_new_double(const char *templatename, const char *key, const char *propertyname, double value);
1557 DATASRCAPI ds_monitor_t *ds_monitor_new_timestamp(const char *templatename, const char *key, const char *propertyname, int64_t value);
1558 DATASRCAPI ds_monitor_t *ds_monitor_new_boolean(const char *templatename, const char *key, const char *propertyname, uint8_t value);
1559 
1560 
1562 
1563 
1564 /* net */
1565 
1566 
1567 DATASRCAPI sock_t ds_listen_socket(const char *addr, int port, int backlog);
1568 DATASRCAPI sock_t ds_accept_socket(sock_t fd);
1569 DATASRCAPI sock_t ds_multicast_listen_socket(const char *p_interface, const char *addr, int port);
1570 DATASRCAPI sock_t ds_udp_listen_socket(const char *p_interface, int port);
1571 DATASRCAPI sock_t ds_client_socket(const char *serv, unsigned short port);
1572 DATASRCAPI sock_t ds_client_socket_nonblocking(const char *serv, unsigned short port);
1573 DATASRCAPI int ds_udp_send(const char *data, int len, const char *addr, int port);
1574 DATASRCAPI int ds_udp_sendto(const char *data, int len, struct sockaddr_storage *serv_addr);
1575 DATASRCAPI sock_t ds_udp_client_socket(const char *addr, int port, struct sockaddr_storage *serv_addr);
1576 DATASRCAPI int ds_udp_bind_client_socket(sock_t sock, const char *addr, int port);
1577 DATASRCAPI char *ds_interface_address(const char *ifname);
1578 DATASRCAPI void ds_setnonblocking(sock_t fd);
1579 DATASRCAPI char *ds_getnameinfo(const struct sockaddr_storage *addr, char *buf, size_t buflen);
1580 DATASRCAPI int ds_compare_sockaddr(struct sockaddr_storage *sa, struct sockaddr_storage *sb);
1581 DATASRCAPI int ds_pipe(sock_t fds[2]);
1582 DATASRCAPI int ds_check_subnet(const char *s_address, const char *s_network, const char *s_netmask);
1583 DATASRCAPI struct sockaddr_storage *ds_gethostsockaddr(const char *name, struct sockaddr_storage *populate);
1584 DATASRCAPI struct addrinfo *ds_gethostsockaddrs(const char *name);
1585 
1586 
1587 
1588 /* Message Types */
1589 
1597 #define DS_MSG_CONNECT 0x0100
1598 
1606 #define DS_MSG_DISCONNECT 0x0200
1607 #define DS_MSG_STATUS 0x0400
1608 
1613 #define DS_MSG_AFFINITY_REMOVED 0x0800
1614 
1615 
1616 /* Peer Types */
1617 
1618 #define DS_T_USERMASK 0x00ff
1619 
1629 #define DS_T_ACTIVE 0x0001
1630 
1641 #define DS_T_CONTRIB 0x0002
1642 
1643 #define DS_T_MSG 0x0100
1644 
1645 
1646 /* Peer Flags */
1647 
1648 #define DS_F_USERMASK 0x00ff
1649 
1665 #define F_SENDFROMSEQ 0x0001
1666 
1667 #define F_SENDFROMFIELD 0x0002
1668 
1669 
1683 #define F_RECVAUTOREPLAY 0x0004
1684 
1685 
1700 #define F_NOCONNECT 0x0008
1701 
1702 #define F_RECONNECT 0x0100
1703 #define F_FAILOVER 0x0200
1704 
1705 
1706 /* No Data Flags */
1707 
1708 #define F_NODATAMASK 0x000f
1709 
1719 #define F_NOTFOUND 0x0001
1720 
1729 #define F_READDENY 0x0002
1730 
1739 #define F_WRITEDENY 0x0003
1740 
1749 #define F_DELETEOBJECT 0x0004
1750 
1759 #define F_UNAVAILABLE 0x0005
1760 #define F_STATUS 0x0006
1761 
1762 
1763 
1769 #define F_IGNOREREQTIMEOUT 0x0008
1770 
1771 /* Object Types */
1772 
1776 #define DS_PAGE_TYPE 221
1777 
1780 #define DS_RECORD_TYPE 222
1781 
1784 #define DS_RECORD_TYPE2 225
1785 
1788 #define DS_RECORD_TYPE3 226
1789 
1792 #define DS_NEWS_TYPE 223
1793 
1796 #define DS_STORY_TYPE 224
1797 
1800 #define DS_CONTAINER_TYPE 228
1801 
1804 #define DS_PERMISSION_TYPE 230
1805 
1812 #define DS_GENERIC_TYPE 231
1813 
1817 #define DS_JSON_TYPE 232
1818 
1819 
1820 /* Data Flags */
1821 
1825 #define F_CREATEOBJECT 0x0010
1826 
1829 #define F_CREATEPARENT 0x0020
1830 #define F_PERSISTENT 0x0040
1831 #define F_CREATEDATA 0x0080
1832 
1836 #define F_CLEAR_PERM 0x0400
1837 
1848 #define F_FILTER_PERM 0x0800
1849 
1854 #define F_AUTHGLOBAL 0x0100
1855 
1859 #define F_CLEAR_TYPE3 0x0100
1860 
1864 #define F_FILTER_TYPE3 0x0200
1865 
1868 #define F_CLEAR_TYPE2 0x0400
1869 
1883 #define F_FILTER_TYPE2 0x0800
1884 
1890 #ifdef __DARWIN_NULL
1891 #undef F_NOCACHE
1892 #endif
1893 #define F_NOCACHE 0x0400
1894 
1901 #define F_DELETE_HEADLINE 0x0100
1902 
1910 #define F_CHANGE_HEADLINE 0x0200
1911 
1916 #define F_IMAGE 0x1000
1917 
1921 #define F_NONACTIVE 0x2000
1922 
1925 #define F_AUTHUPDATE 0x4000
1926 
1927 
1935 #define F_CONSTITUENT_NOAUTH 0x4000
1936 
1943 #define F_CHANGEDFIELDS 0x8000
1944 
1945 /* Field Data Types */
1946 
1947 #define FLOAT32_TYPE 1
1948 #define FLOAT64_TYPE 2
1949 #define INT8_TYPE 3
1950 #define INT16_TYPE 4
1951 #define INT32_TYPE 5
1952 #define INT64_TYPE 6
1953 #define UINT8_TYPE 7
1954 #define UINT16_TYPE 8
1955 #define UINT32_TYPE 9
1956 #define UINT64_TYPE 10
1957 
1958 
1959 /* Object request flags */
1960 
1970 #define DS_REQUEST_FAILOVER 1
1971 
1980 #define DS_REQUEST_CACHE 4
1981 
1982 
1983 
1984 /* Object Status Flags */
1985 
1995 #define S_INFO 0x0000
1996 
2005 #define S_STALE 0x0001
2006 
2015 #define S_NOTSTALE 0x0004
2016 
2028 #define S_UPDCLR 0x0100
2029 
2040 #define S_FAILOVER 0x1101 /* Failover implies S_STALE|S_UPDCLR */
2041 
2042 
2055 #define OBJ_STATUS_INFO 0x0000
2056 
2069 #define OBJ_STATUS_OK 0x0001
2070 
2085 #define OBJ_STATUS_STALE 0x0002
2086 
2087 
2103 #define OBJ_STATUS_LIMITED 0x0008
2104 
2105 
2106 #define OBJ_STATUS_NOTMAPPED 0x0010
2107 
2116 #define SVC_STATUS_OK 0x0001
2117 
2126 #define SVC_STATUS_DOWN 0x0002
2127 
2136 #define SVC_STATUS_LIMITED 0x0008
2137 
2138 
2139 /* Field Macros */
2140 #define DS_MAX_BITFIELD (sizeof(ds_bitfield_t)*8)
2141 
2142 #define DS_BITFIELD_SET(n,p) *(p) |= (1ULL << (n))
2143 #define DS_BITFIELD_CLR(n,p) *(p) &= ~(1ULL << (n))
2144 #define DS_BITFIELD_ISSET(n,p) (*(p) & (1ULL << (n)))
2145 #define DS_BITFIELD_ZERO(p) *(p) = 0
2146 #define DS_BITFIELD_NONZERO(p) memset((char *)(p), 0xffffffff, sizeof(*(p)))
2147 
2148 /* Peer set functions and macros */
2149 
2150 DATASRCAPI int ds_iszero(ds_set_t *p);
2151 DATASRCAPI void ds_not(ds_set_t *p);
2152 DATASRCAPI void ds_or(ds_set_t *p1, ds_set_t *p2, ds_set_t *o);
2153 DATASRCAPI void ds_and(ds_set_t *p1, ds_set_t *p2, ds_set_t *a);
2154 DATASRCAPI int ds_and_iszero(ds_set_t *p1, ds_set_t *p2);
2155 DATASRCAPI int ds_and3_iszero(ds_set_t *p1, ds_set_t *p2, ds_set_t *p3);
2156 DATASRCAPI int ds_isequal(ds_set_t *p1, ds_set_t *p2);
2157 
2162 #define DS_MAX_PEERS 1024
2163 
2168 #define DS_MIN_PEER 0
2169 
2174 #define DS_INTERNAL_DATASRC 1023
2175 
2176 typedef uint32_t dsset_element_t;
2177 
2178 #define DS_NUMBITS (sizeof(dsset_element_t) * 8)
2179 #define DS_NUM_ELEMS (DS_MAX_PEERS+DS_NUMBITS-1)/DS_NUMBITS
2180 #define DS_NUM_BYTES (DS_NUM_ELEMS * sizeof(dsset_element_t))
2181 
2182 struct _ds_peer_set
2183  {
2184  dsset_element_t bits[DS_NUM_ELEMS];
2185  };
2186 
2191 #define DS_SET(n,p) ((p)->bits[(n)/DS_NUMBITS] |= ((unsigned)1 << ((n) % DS_NUMBITS)))
2192 
2197 #define DS_CLR(n,p) ((p)->bits[(n)/DS_NUMBITS] &= ~((unsigned)1 << ((n) % DS_NUMBITS)))
2198 
2203 #define DS_ISSET(n,p) ((p)->bits[(n)/DS_NUMBITS] & ((unsigned)1 << ((n) % DS_NUMBITS)))
2204 
2209 #define DS_ZERO(p) memset((char *)(p)->bits, 0, DS_NUM_BYTES)
2210 
2215 #define DS_NONZERO(p) memset((char *)(p)->bits, 0xff, DS_NUM_BYTES)
2216 
2221 #define DS_NOT(p) ds_not(p)
2222 
2227 #define DS_ISZERO(p) ds_iszero(p)
2228 
2233 #define DS_AND(p1, p2, a) ds_and(p1, p2, a)
2234 
2239 #define DS_OR(p1, p2, o) ds_or(p1, p2, o)
2240 
2245 #define DS_AND_ISZERO(p1, p2) ds_and_iszero(p1, p2)
2246 
2251 #define DS_AND3_ISZERO(p1, p2, p3) ds_and3_iszero(p1, p2, p3)
2252 
2257 #define DS_ISEQUAL(p1, p2) ds_isequal(p1, p2)
2258 
2259 DATASRCAPI ds_data_t *ds_init_data(const char *subject, unsigned short type, unsigned short flags);
2260 DATASRCAPI void ds_set_subject(ds_data_t *data, const char *subject);
2261 
2262 DATASRCAPI void ds_add_data(ds_data_t *data, int32_t fieldnum, const char *value);
2263 DATASRCAPI void ds_add_data_fmt(ds_data_t *data, int32_t fieldnum, const char *fmt, ...);
2264 DATASRCAPI void ds_add_data_str(ds_data_t *data, int32_t fieldnum, const char *value);
2265 DATASRCAPI void ds_add_data_float32(ds_data_t *data, int32_t fieldnum, float value);
2266 DATASRCAPI void ds_add_data_float64(ds_data_t *data, int32_t fieldnum, double value);
2267 DATASRCAPI void ds_add_data_int8(ds_data_t *data, int32_t fieldnum, int8_t value);
2268 DATASRCAPI void ds_add_data_int16(ds_data_t *data, int32_t fieldnum, int16_t value);
2269 DATASRCAPI void ds_add_data_int32(ds_data_t *data, int32_t fieldnum, int32_t value);
2270 DATASRCAPI void ds_add_data_int64(ds_data_t *data, int32_t fieldnum, int64_t value);
2271 DATASRCAPI void ds_add_data_uint8(ds_data_t *data, int32_t fieldnum, uint8_t value);
2272 DATASRCAPI void ds_add_data_uint16(ds_data_t *data, int32_t fieldnum, uint16_t value);
2273 DATASRCAPI void ds_add_data_uint32(ds_data_t *data, int32_t fieldnum, uint32_t value);
2274 DATASRCAPI void ds_add_data_uint64(ds_data_t *data, int32_t fieldnum, uint64_t value);
2275 DATASRCAPI void ds_add_data_char(ds_data_t *data, int32_t fieldnum, char value);
2276 
2277 DATASRCAPI ds_data_t *ds_clone_data(ds_data_t *data);
2278 
2279 #define ds_add_data_short(d,f,v) ds_add_data_int16(d,f,v)
2280 #define ds_add_data_int(d,f,v) ds_add_data_int32(d,f,v)
2281 #define ds_add_data_long(d,f,v) ds_add_data_int32(d,f,v)
2282 #define ds_add_data_float(d,f,v) ds_add_data_float32(d,f,v)
2283 #define ds_add_data_double(d,f,v) ds_add_data_float64(d,f,v)
2284 
2285 DATASRCAPI void ds_send_data(ds_data_t *data);
2286 DATASRCAPI void ds_send_data_to_peer(int peer, ds_data_t *data);
2287 DATASRCAPI void ds_send_data_no_free(ds_data_t *data);
2288 DATASRCAPI void ds_send_data_to_peer_no_free(int peer, ds_data_t *data);
2289 DATASRCAPI void ds_send_nodata(const char *subject, unsigned short flags);
2290 DATASRCAPI void ds_send_nodata_to_peer(int peer, const char *subject, unsigned short flags);
2291 DATASRCAPI void ds_free_data(ds_data_t *data);
2292 DATASRCAPI void ds_send_status(const char *subject, unsigned short flags, unsigned short code, const char *msgstr);
2293 DATASRCAPI void ds_send_status_to_peer(int peer,const char *subject, unsigned short flags, unsigned short code, const char *msgstr);
2294 DATASRCAPI void ds_send_data_direct(ds_data_t *data);
2295 DATASRCAPI void ds_send_nodata_direct(const char *subject, unsigned short flags);
2296 DATASRCAPI void ds_send_status_direct(const char *subject, unsigned short flags, unsigned short code, const char *msgstr);
2297 
2298 DATASRCAPI void ds_send_map_to_peer(int peer, const char *subject, const char *mapped, unsigned short flags);
2299 DATASRCAPI void ds_send_map(const char *subject, const char *mapped, unsigned short flags);
2300 
2301 
2312 typedef void (*ds_delay_send_cb)(void *context, ds_data_t *dsdata);
2313 
2314 DATASRCAPI ds_delay_t *ds_new_delay(double delay_time, char *prefix, double batch_time);
2315 DATASRCAPI ds_delay_t *ds_new_delay_with_callback(double delay_time, char *prefix, double batch_time, void *callback_param, ds_delay_send_cb callback_func);
2316 DATASRCAPI void ds_delay_data(ds_delay_t *delay, ds_data_t *dsdata);
2317 
2318 DATASRCAPI int32_t ds_add_record_str(ds_data_t *data, const char *field, const char *value);
2319 DATASRCAPI int32_t ds_add_record_int(ds_data_t *data,const char *field, int value);
2320 DATASRCAPI int32_t ds_add_record_char(ds_data_t *data,const char *field, char value);
2321 DATASRCAPI int32_t ds_add_record_float(ds_data_t *data,const char *field, double value);
2322 DATASRCAPI int32_t ds_add_record_fmt(ds_data_t *data,const char *field, const char *fmt, ...);
2323 
2324 DATASRCAPI ds_data_t *ds_init_page(const char *subject, int rows, int cols, const char *type, unsigned short flags);
2325 DATASRCAPI void ds_add_page_row(ds_data_t *data, int row, int col, const char *str);
2326 DATASRCAPI void ds_add_page_field(ds_data_t *data, int32_t fieldnum, const char *value);
2327 DATASRCAPI void ds_add_page_field_by_name(ds_data_t *data, const char *field, const char *value);
2328 
2329 DATASRCAPI ds_data_t *ds_init_news(const char *subject, unsigned short flags);
2330 DATASRCAPI void ds_add_news_headline(ds_data_t *data, const char *headline);
2331 DATASRCAPI void ds_add_news_storycode(ds_data_t *data, const char *story);
2332 DATASRCAPI void ds_add_news_datetime(ds_data_t *data, const char *datestr);
2333 DATASRCAPI void ds_add_news_authstr(ds_data_t *data, const char *authstr);
2334 DATASRCAPI void ds_add_news_product_code(ds_data_t *data, const char *code);
2335 DATASRCAPI void ds_add_news_topic_code(ds_data_t *data, const char *code);
2336 DATASRCAPI void ds_add_news_company_code(ds_data_t *data, const char *code);
2337 DATASRCAPI void ds_add_news_user_code(ds_data_t *data, int codenum, const char *code);
2338 DATASRCAPI void ds_add_news_field(ds_data_t *dsdata, const char *fieldname, const char *value);
2339 
2340 DATASRCAPI ds_data_t *ds_init_container(const char *subject, const unsigned short flags);
2341 DATASRCAPI void ds_add_container_symbol_and_request(ds_data_t *data, const char *symbol, const int request);
2342 DATASRCAPI void ds_add_container_symbol(ds_data_t *data, const char *symbol);
2343 DATASRCAPI void ds_add_container_symbol_at_position(ds_data_t *data, int position, const char *symbol);
2344 DATASRCAPI void ds_remove_container_symbol(ds_data_t *data, const char *symbol);
2345 DATASRCAPI void ds_cleardown_container_with_prefix(ds_data_t *data, const char *prefix);
2346 
2347 DATASRCAPI ds_data_t *ds_init_permission(const char *subject, const char *key, unsigned short flags);
2348 DATASRCAPI void ds_add_permission_key(ds_data_t *data, const char *key);
2349 
2350 DATASRCAPI void ds_add_binary(ds_data_t *data, int32_t fieldnum, char *value, int len, char type);
2351 DATASRCAPI void ds_add_binary_float32(ds_data_t *data, int32_t fieldnum, float value);
2352 DATASRCAPI void ds_add_binary_float64(ds_data_t *data, int32_t fieldnum, double value);
2353 DATASRCAPI void ds_add_binary_int8(ds_data_t *data, int32_t fieldnum, int8_t value);
2354 DATASRCAPI void ds_add_binary_int16(ds_data_t *data, int32_t fieldnum, int16_t value);
2355 DATASRCAPI void ds_add_binary_int32(ds_data_t *data, int32_t fieldnum, int32_t value);
2356 DATASRCAPI void ds_add_binary_int64(ds_data_t *data, int32_t fieldnum, int64_t value);
2357 DATASRCAPI void ds_add_binary_uint8(ds_data_t *data, int32_t fieldnum, uint8_t value);
2358 DATASRCAPI void ds_add_binary_uint16(ds_data_t *data, int32_t fieldnum, uint16_t value);
2359 DATASRCAPI void ds_add_binary_uint32(ds_data_t *data, int32_t fieldnum, uint32_t value);
2360 DATASRCAPI void ds_add_binary_uint64(ds_data_t *data, int32_t fieldnum, uint64_t value);
2361 DATASRCAPI void ds_add_binary_string(ds_data_t *data, int32_t fieldnum, char *value);
2362 DATASRCAPI void ds_add_binary_opaque(ds_data_t *data, int32_t fieldnum, char *value, int len);
2363 DATASRCAPI void ds_add_binary_time(ds_data_t *data, int32_t fieldnum, time_t value);
2364 DATASRCAPI void ds_add_binary_time_millis(ds_data_t *data, int32_t fieldnum, int64_t value);
2365 DATASRCAPI void ds_add_binary_timeval(ds_data_t *data, int32_t fieldnum, struct timeval value);
2366 DATASRCAPI void ds_add_binary_timespec(ds_data_t *data, int32_t fieldnum, struct timespec value);
2367 
2368 #define ds_add_binary_char(d,f,v) ds_add_binary_int8(d,f,v);
2369 #define ds_add_binary_short(d,f,v) ds_add_binary_int16(d,f,v);
2370 #define ds_add_binary_int(d,f,v) ds_add_binary_int32(d,f,v);
2371 #define ds_add_binary_long(d,f,v) ds_add_binary_int32(d,f,v);
2372 #define ds_add_binary_float(d,f,v) ds_add_binary_float32(d,f,v);
2373 #define ds_add_binary_double(d,f,v) ds_add_binary_float64(d,f,v);
2374 #define ds_add_binary_time_micros(d,f,v) ds_add_binary_timeval(d,f,v);
2375 #define ds_add_binary_time_nanos(d,f,v) ds_add_binary_timespec(d,f,v);
2376 
2377 
2381 #define NEWS_HEADLINE_FIELDNUM 0
2382 
2385 #define NEWS_STORYCODE_FIELDNUM 1
2386 
2389 #define NEWS_DATETIME_FIELDNUM 2
2390 
2393 #define NEWS_AUTHSTR_FIELDNUM 5
2394 
2397 #define NEWS_PRODUCT_CODE_FIELDNUM 100
2398 
2401 #define NEWS_TOPIC_CODE_FIELDNUM 101
2402 
2405 #define NEWS_COMPANY_CODE_FIELDNUM 102
2406 
2409 #define NEWS_USER_CODE_FIELDNUM 200
2410 
2413 #define NEWS_USER_CODE_MAX 10
2414 
2415 #define NEWS_SIZE_FIELDNUM 300
2416 #define NEWS_REASON_FIELDNUM 301
2417 
2418 #define NEWS_REQ_SEARCH 1000
2419 #define NEWS_REQ_STORYCODE 1001
2420 #define NEWS_REQ_DATE_TO 1002
2421 #define NEWS_REQ_DATE_FROM 1003
2422 #define NEWS_REQ_FLAGS 1004
2423 
2424 #define NEWS_GENERIC_FIELDNUM 1024
2425 
2426 /* peer */
2427 
2428 
2429 DATASRCAPI extern int ds_num_peers;
2430 
2431 
2432 DATASRCAPI int ds_peer_details(int peer, char **name);
2433 DATASRCAPI int ds_peer_host_details(int peer, char **addr);
2434 DATASRCAPI int ds_peer_id(int peer);
2435 DATASRCAPI char *ds_peer_name(int peer);
2436 DATASRCAPI int ds_peer_flags(int peer);
2437 DATASRCAPI int ds_peer_local_type(int peer);
2438 DATASRCAPI int ds_peer_type(int peer);
2439 DATASRCAPI int ds_peer_up(int peer);
2440 DATASRCAPI void ds_peer_add_extra_handshake_data(int peer, const char *data);
2441 DATASRCAPI int ds_peer_all_type(int flag);
2442 
2443 DATASRCAPI void ds_set_status_down(void);
2444 DATASRCAPI void ds_set_status_down_to_peer(int peer);
2445 DATASRCAPI void ds_set_status_msg(unsigned short msgid, const char *msgstr);
2446 DATASRCAPI void ds_set_status_msg_to_peer(int peer, unsigned short msgid, const char *msgstr);
2447 DATASRCAPI void ds_set_status_up(void);
2448 DATASRCAPI void ds_set_status_up_to_peer(int peer);
2449 DATASRCAPI int ds_peer_by_label(const char *label);
2450 DATASRCAPI int ds_peer_by_local_label(const char *label);
2451 DATASRCAPI char *ds_peer_label_byindex(int index);
2452 DATASRCAPI int ds_peer_enabled_state(int peer);
2453 
2454 DATASRCAPI int ds_peer_details_r(int peer, char *buffer, size_t buflen);
2455 DATASRCAPI int ds_peer_host_details_r(int peer, char *buffer, size_t buflen);
2456 DATASRCAPI char *ds_peer_name_r(int peer, char *buffer, size_t buflen);
2457 DATASRCAPI char *ds_peer_label_byindex_r(int peer, char *buffer, size_t buflen);
2458 
2459 /* pkt */
2460 
2467 struct _ds_data
2468  {
2469  unsigned short seq;
2470  unsigned short flags;
2471  unsigned short type;
2472  char *subject;
2473  unsigned short count;
2475  time_t time;
2476  };
2477 
2485  {
2486  int32_t fieldnum;
2487  int32_t len;
2488  char *value;
2489  unsigned short flags;
2490  };
2491 
2492 
2493 /* replay */
2494 
2495 
2496 DATASRCAPI void ds_replay(recv_replay_t callback);
2497 DATASRCAPI int ds_replay_from_file(recv_replay_t callback, char *filename);
2498 DATASRCAPI void ds_replay_from_log(recv_replay_t callback, ds_log_t *log);
2499 DATASRCAPI void ds_replay_by_time(time_t t, recv_replay_t callback);
2500 DATASRCAPI int ds_replay_by_time_from_file(time_t t, recv_replay_t callback, char *filename);
2501 DATASRCAPI void ds_replay_by_time_from_log(time_t t, recv_replay_t callback, ds_log_t *log);
2502 DATASRCAPI void ds_replay_by_field(int fieldnum, char *value, recv_replay_t callback);
2503 DATASRCAPI int ds_replay_by_field_from_file(int fieldnum, char *value, recv_replay_t callback, char *filename);
2504 DATASRCAPI void ds_replay_by_field_from_log(int fieldnum, char *value, recv_replay_t callback, ds_log_t *log);
2505 
2506 
2507 /* udp */
2508 
2509 
2514 typedef struct _ds_udp_event ds_udp_event_t;
2515 
2527 typedef int (*ds_udp_event_cb)(int argc, char *argv[], int val, void *data);
2528 
2529 
2530 DATASRCAPI ds_udp_event_t *ds_add_udp_event(const char *command, ds_udp_event_cb cb, int val, void *data);
2531 DATASRCAPI void ds_del_udp_event(ds_udp_event_t *event);
2532 
2533 DATASRCAPI void ds_udpsignal_send(const char *message);
2534 DATASRCAPI void ds_udpsignal_send_argv(const char *message, char *argv[]);
2535 
2536 /* Deprecated methods of handling udp commands */
2537 DATASRCAPI int ds_udpsignal_addjob(const char *cmd,void (*fn)(int argc,char *argv[]), const char *description);
2538 DATASRCAPI int ds_udpsignal_deljob(const char *cmd, void (*fn)(int argc, char *argv[]));
2539 
2540 
2541 /* misc */
2542 
2543 DATASRCAPI void ds_set_productname(const char *name);
2544 
2545 /* advmap */
2546 
2547 DATASRCAPI char *ds_request_object(const char *name);
2548 DATASRCAPI char *ds_request_object_with_flags(const char *name,int flags);
2549 DATASRCAPI int ds_request_objects(int count, char **obs, char ***services);
2550 DATASRCAPI int ds_request_objects_with_flags(int count, char **obs, int flags, char ***services);
2551 DATASRCAPI void ds_discard_object(const char *name);
2552 DATASRCAPI void ds_discard_objects(int count, char **obs);
2553 DATASRCAPI char * ds_get_service(const char *name);
2554 DATASRCAPI int ds_send_contribution(ds_data_t *dsdata);
2555 DATASRCAPI int ds_get_num_services(void);
2556 DATASRCAPI int ds_get_service_by_index(int index, char **name_ptr);
2557 DATASRCAPI int ds_object_available(const char *name);
2558 DATASRCAPI int ds_object_can_contrib(const char *name);
2559 DATASRCAPI void ds_purge_object(const char *name);
2560 DATASRCAPI int ds_required_services_status(char *buf, size_t buflen);
2561 DATASRCAPI int ds_get_service_type(const char *servicename);
2562 DATASRCAPI int ds_get_is_contrib_source(const char *name, int peer);
2563 
2565 DATASRCAPI int ds_set_request_hint(const char *name, int num, char **hints);
2566 DATASRCAPI char **ds_get_request_hints(const char *name, int *ret);
2567 DATASRCAPI char **ds_get_request_hints_dynamic(const char *name, int *ret);
2568 DATASRCAPI void ds_set_object_data(const char *name, void *data);
2569 DATASRCAPI void *ds_get_object_data(const char *name);
2570 
2571 /* signature */
2572 DATASRCAPI int ds_signature_check(char *key_id, char *token);
2573 
2574 /* page */
2575 
2576 #define DS_BIGPAGE_R 25
2577 #define DS_BIGPAGE_C 80
2578 #define DS_BIGPAGE_TYPE "25"
2579 #define DS_SMALLPAGE_R 14
2580 #define DS_SMALLPAGE_C 64
2581 #define DS_SMALLPAGE_TYPE "218"
2582 
2583 
2584 DATASRCAPI int ds_signature_verify_username(char *expected_username, char *token);
2585 
2592 #define DS_SIGNATURE_OK 0
2593 
2599 #define DS_SIGNATURE_INVALID_TOKEN 1
2600 
2606 #define DS_SIGNATURE_UNKNOWN_KEYID 2
2607 
2613 #define DS_SIGNATURE_ALREADY_USED 3
2614 #endif /* __DATASRC_H__ */
2615 
2616 #ifdef __cplusplus
2617 } /* extern "C" */
2618 #endif
2619 
DATASRCAPI void ds_add_binary_time_millis(ds_data_t *data, int32_t fieldnum, int64_t value)
Add a value to a data object in the form of a timestamp.
Definition: binary.c:553
DATASRCAPI int ds_del_except_event(ds_except_event_t *ev)
Remove a socket except event.
Definition: event.c:769
DATASRCAPI char * ds_log_getfilename(ds_log_t *log)
Get the filename of a log object.
Definition: log.c:1569
DATASRCAPI void ds_add_binary_opaque(ds_data_t *data, int32_t fieldnum, char *value, int len)
Add a value to a data object in the form of an opaque value.
Definition: binary.c:510
recv_update_t recv_update
Definition: datasrc.h:365
DATASRCAPI void ds_monitor_update_long(const char *templatename, const char *key, const char *propertyname, int32_t value)
Post an update to the monitoring system for a long value.
Definition: monitor.c:1519
DATASRCAPI ds_data_t * ds_init_container(const char *subject, const unsigned short flags)
Initialise a container object.
Definition: container.c:35
char * log_root
Definition: datasrc.h:360
DATASRCAPI void ds_add_data_float32(ds_data_t *data, int32_t fieldnum, float value)
Add a value to a data object in the form of a floating point number.
Definition: api.c:173
DATASRCAPI void ds_add_page_field_by_name(ds_data_t *data, const char *field, const char *value)
Add an arbitrary field to a page.
Definition: page.c:153
DATASRCAPI void ds_add_data_int16(ds_data_t *data, int32_t fieldnum, int16_t value)
Add a value to a data object in the form of a 16 bit integer.
Definition: api.c:261
DATASRCAPI sock_t ds_client_socket_nonblocking(const char *serv, unsigned short port)
Creates a client socket with which to connect to a host.
Definition: net.c:816
DATASRCAPI ds5_subscription_t * ds5_create_active_subscription(const char *subject, ds5_subscriptionlistener_t *listener, void *context)
Create a subscription that matches a single subject.
Definition: dsv5_subscription.c:131
DATASRCAPI void ds_config_add_bounded_array_option_enum(const char *longopt, const char *help, int type, void *value, int *num, ds_config_enum_t *enums, void *min, void *max)
Add an enumerated option to the configuration context.
Definition: config.c:695
DATASRCAPI int ds_isequal(ds_set_t *p1, ds_set_t *p2)
Check 2 peersets are equal.
Definition: peerset.c:182
DATASRCAPI int ds_replay_by_field_from_file(int fieldnum, char *value, recv_replay_t callback, char *filename)
Replays all data in a file that arrived after an update with the specified value for the specified fi...
Definition: replay.c:416
DATASRCAPI void ds5_publish_status(ds5_publisher_t *pub, const char *subject, int status, const char *message)
Publishes a subscription status event for a subject.
Definition: dsv5_publisher.c:330
unsigned short flags
Definition: datasrc.h:2489
void ds_printf(ds_log_t *log, const char *fmt,...)
Write a formatted string to a log object.
Definition: log.c:1107
Defines the DataSource initialisation object.
Definition: datasrc.h:356
DATASRCAPI void ds_add_container_symbol(ds_data_t *data, const char *symbol)
Add an object to the container.
Definition: container.c:54
DATASRCAPI void ds_write(ds_log_t *log, void *data, size_t len)
Write binary data to a log object.
Definition: log.c:1060
DATASRCAPI int ds_and_iszero(ds_set_t *p1, ds_set_t *p2)
Check if the bitwise and of 2 peer sets is 0.
Definition: peerset.c:123
DATASRCAPI int ds_replay_from_file(recv_replay_t callback, char *filename)
Replays all data in a file.
Definition: replay.c:141
DATASRCAPI int ds_fields_add(int num, const char *name, int flags, int dp, const char *fmt)
Add a new field to the field list.
Definition: fields.c:377
DATASRCAPI ds_config_ctx_t * ds_config_new_ctx(void)
Create a new configuration context.
Definition: config.c:199
struct _ds5_publisher_s ds5_publisher_t
Represents a data publisher that publishers to remote DataSource peers on behalf of a ds5_dataprovide...
Definition: datasrc.h:500
void(* recv_request_t)(int peer, int count, char **subjects, unsigned short flags)
Definition of the function type used for handling data requests.
Definition: datasrc.h:272
DATASRCAPI void DATASRCAPI void DATASRCAPI void ds_config_add_error_message(const char *msg)
Add a configuration error to the logfile.
Definition: config.c:3502
DATASRCAPI int ds5_init(int argc, char **argv)
Parses the DataSource configuration files and initialises the DataSource library. The configuration i...
Definition: dsv5.c:108
DATASRCAPI void ds_monitor_update_string(const char *templatename, const char *key, const char *propertyname, const char *value)
Post an update to the monitoring system for a string value.
Definition: monitor.c:1420
DATASRCAPI void ds_monitor_free_data(ds_monitor_t *data)
Deallocate memory used by the contents of a ds_monitor_t object.
Definition: monitor.c:541
DATASRCAPI int32_t ds_add_record_char(ds_data_t *data, const char *field, char value)
Add a character value to a record object.
Definition: record.c:123
DATASRCAPI void ds_config_init(const char *file, int argc, char **argv)
Set up the configuration of the DataSource.
Definition: datasrc.c:236
int(* ds_monitor_authenticator_t)(ds_monauth_t *credentials)
Definition of the function type used for monitoring authentication callback.
Definition: datasrc.h:1500
void(* ds_loglevelchange_t)(ds_log_t *log, int new_level)
Callback used when the logging level of a log file is changed.
Definition: datasrc.h:1203
DATASRCAPI int ds_required_services_status(char *buf, size_t buflen)
Return whether all required services are ready.
Definition: advmap.c:5915
DATASRCAPI void ds_monitor_add_template_subscription(const char *templatename, const char *propertyname, const char *targettemplate, const char *description, const char *singleton, ds_monitor_active_cb callback_fn)
Add a subscription info into the template.
Definition: monitor.c:1175
DATASRCAPI ds_monitor_t * ds_monitor_new_double(const char *templatename, const char *key, const char *propertyname, double value)
Create a new ds_monitor_t object from an input double.
Definition: monitor.c:1823
char * application_root
Definition: datasrc.h:359
DATASRCAPI int ds_fields_max(void)
Return the number of fields that have been defined.
Definition: fields.c:359
DATASRCAPI void ds_send_data_to_peer(int peer, ds_data_t *data)
Send the data object to a specific peer.
Definition: api.c:589
DATASRCAPI int32_t ds_add_record_int(ds_data_t *data, const char *field, int value)
Add an integer value to a record object.
Definition: record.c:87
DATASRCAPI int ds_pipe(sock_t fds[2])
Creates a UNIX-style pipe.
Definition: net.c:1047
DATASRCAPI void ds_add_binary_float32(ds_data_t *data, int32_t fieldnum, float value)
Add a value to a data object in the form of a floating point number.
Definition: binary.c:223
DATASRCAPI double ds_timed_event_get_fire_time(ds_timed_event_t *ev)
Return the time the event is due to fire.
Definition: event.c:1379
DATASRCAPI ds_data_t * ds_clone_data(ds_data_t *data)
Create a clone of a data object.
Definition: api.c:1089
DATASRCAPI void ds_setnonblocking(sock_t fd)
Set a socket to be non-blocking.
Definition: net.c:1012
char * subject
Definition: datasrc.h:2472
DATASRCAPI void ds_monitor_add_template_relation(const char *templatename, const char *propertyname, const char *targettemplate, const char *description, int thisend_multiple, int thatend_multiple)
Add a relationship to a template.
Definition: monitor.c:1096
DATASRCAPI int ds_signature_check(char *key_id, char *token)
Provides a mechanism for validating a KeyMaster-generated encrypted single-use token.
Definition: signature.c:495
DATASRCAPI int32_t ds_add_record_str(ds_data_t *data, const char *field, const char *value)
Add a string value to a record object.
Definition: record.c:49
DATASRCAPI void ds5_publish_to_peer(ds5_publisher_t *publisher, int peernum, ds_data_t *dsdata)
Publish an update for a subject to the specified peer.
Definition: dsv5_publisher.c:263
DATASRCAPI void ds_set_status_down_to_peer(int peer)
Causes the DataSource to disconnect and not accept connections for this peer.
Definition: peer.c:4444
DATASRCAPI ds_data_t * ds_init_data(const char *subject, unsigned short type, unsigned short flags)
Initialise a data object for use.
Definition: api.c:60
DATASRCAPI void DATASRCAPI int ds_log_set_log_level(ds_log_t *log, const char *level)
Set the log level for a particular logfile.
Definition: log.c:2448
DATASRCAPI void ds_config_add_optional_file(const char *file)
Add an optional configuration file to the current configuration context.
Definition: config.c:354
DATASRCAPI void ds_config_add_section(const char *longopt, const char *help)
Adds a new configuration section to the current configuration context.
Definition: config.c:912
DATASRCAPI sock_t ds_listen_socket(const char *addr, int port, int backlog)
Creates a listen socket on the specified local address and TCP port.
Definition: net.c:517
DATASRCAPI void ds_config_add_array_option_enum(const char *longopt, const char *help, int type, void *value, int *num, ds_config_enum_t *enums)
Add an enumerated option to the configuration context.
Definition: config.c:659
unsigned short seq
Definition: datasrc.h:2469
DATASRCAPI ds_write_event_t * ds_add_write_event(sock_t fd, ds_io_event_cb cb, int val, void *data)
Add a socket write event.
Definition: event.c:514
DATASRCAPI ds_timed_event_t * ds_add_periodic_event(int starttime, int period, int id, ds_timed_event_cb cb, int val, void *data)
Add a timed event, starting at a particular time.
Definition: event.c:1888
DATASRCAPI int ds_del_timed_event(ds_timed_event_t *ev)
Remove a timed event.
Definition: event.c:1345
DATASRCAPI char * ds_peer_name_r(int peer, char *buffer, size_t buflen)
Gets the name of a peer.
Definition: peer.c:7675
DATASRCAPI char * ds_peer_label_byindex_r(int peer, char *buffer, size_t buflen)
Get the peer label for a peer index.
Definition: peer.c:7744
DATASRCAPI ds_read_event_t * ds_add_read_event(sock_t fd, ds_io_event_cb cb, int val, void *data)
Add a socket read event.
Definition: event.c:483
DATASRCAPI void ds_replay_by_time(time_t t, recv_replay_t callback)
Replays all data in the current packet log file that arrived after a specified time.
Definition: replay.c:297
DATASRCAPI void ds_and(ds_set_t *p1, ds_set_t *p2, ds_set_t *a)
Combine 2 peersets using bitwise and.
Definition: peerset.c:98
DATASRCAPI void ds_add_news_topic_code(ds_data_t *data, const char *code)
Add a topic code to the news headline message.
Definition: news.c:141
DATASRCAPI char * ds_config_get_filename(void)
Return the current line number being parsed in the configuration file.
Definition: config.c:3649
DATASRCAPI void ds5_publish_to_peer_no_free(ds5_publisher_t *publisher, int peernum, ds_data_t *dsdata)
Publish an update for a subject to the specified peer. The update will not be freed.
Definition: dsv5_publisher.c:281
DATASRCAPI int ds_object_can_contrib(const char *name)
Determine whether contributions can be sent for this object.
Definition: advmap.c:5638
ds_monitor_t *(* ds_monitor_active_cb)(char *templatename, char *key, char *propertyname)
Definition of the function type used for active request callbacks.
Definition: datasrc.h:1475
DATASRCAPI void ds_add_data_uint32(ds_data_t *data, int32_t fieldnum, uint32_t value)
Add a value to a data object in the form of a 32 bit unsigned integer.
Definition: api.c:411
DATASRCAPI void ds_add_container_symbol_and_request(ds_data_t *data, const char *symbol, const int request)
Add an object to the container, indicating whether it should then be requested.
Definition: container.c:73
DATASRCAPI void ds_config_set_option(const char *name, const char *value)
Set a particular configuration option.
Definition: config.c:2252
DATASRCAPI void ds_config_add_file(const char *file)
Add a mandatory configuration file to the current configuration context.
Definition: config.c:336
DATASRCAPI void ds_free_data(ds_data_t *data)
Deallocates the memory used by a data object.
Definition: api.c:887
void(* recv_update_t)(int peer, ds_data_t *pkt)
Definition of the function type used for receiving updates from a DataSource peer.
Definition: datasrc.h:190
DATASRCAPI ds_except_event_t * ds_add_except_event(sock_t fd, ds_io_event_cb cb, int val, void *data)
Add a socket exception event.
Definition: event.c:551
DATASRCAPI ds_data_t * ds_init_permission(const char *subject, const char *key, unsigned short flags)
Initialise a data object as a permission object.
Definition: permission.c:77
DATASRCAPI ds5_namespace_t * ds5_create_regex_namespace(const char *expr)
Creates a DataSource namespace which will match subject names using a regular expression.
Definition: dsv5_namespace.c:276
DATASRCAPI char * ds_get_service(const char *name)
Return the service for an object.
Definition: advmap.c:5392
DATASRCAPI void ds_udpsignal_send_argv(const char *message, char *argv[])
Send a UDP message.
Definition: udpsignal.c:384
DATASRCAPI void ds_monitor_update_double(const char *templatename, const char *key, const char *propertyname, double value)
Post an update to the monitoring system for a double value.
Definition: monitor.c:1600
DATASRCAPI struct tm * ds_gmtime(void)
Get the current time in GMT.
Definition: event.c:1229
DATASRCAPI void ds_add_binary_int8(ds_data_t *data, int32_t fieldnum, int8_t value)
Add a value to a data object in the form of an 8 bit integer.
Definition: binary.c:281
DATASRCAPI void ds_monitor_end_template(const char *templatename)
End the definition of a template.
Definition: monitor.c:1067
DATASRCAPI void ds_config_add_group(const char *longopt, const char *help, void *base, void *def, size_t size, int *num)
Add a configuration group to the current configuration context.
Definition: config.c:791
DATASRCAPI int ds_peer_by_label(const char *label)
Return the peer index for a label.
Definition: peer.c:5879
DATASRCAPI void ds_config_free_ctx(ds_config_ctx_t *ctx)
Free a configuration context.
Definition: config.c:225
Enumerated types structure.
Definition: datasrc.h:923
DATASRCAPI void ds5_config_init(const char *configfile, int argc, char **argv)
Sets up the configuration of the DataSource.
Definition: dsv5.c:79
DATASRCAPI void ds_add_binary_int32(ds_data_t *data, int32_t fieldnum, int32_t value)
Add a value to a data object in the form of a 32 bit integer.
Definition: binary.c:328
DATASRCAPI void ds_send_data_no_free(ds_data_t *data)
Send the data object to all connected DataSource peers.
Definition: api.c:652
DATASRCAPI ds_data_t * ds_init_news(const char *subject, unsigned short flags)
Create a news headline message.
Definition: news.c:35
A field within a data update.
Definition: datasrc.h:2484
DATASRCAPI void ds_add_binary_timespec(ds_data_t *data, int32_t fieldnum, struct timespec value)
Add a value to a data object in the form of a timestamp.
Definition: binary.c:605
DATASRCAPI int ds_config_get_enum(const char *value, ds_config_enum_t *enums)
Get the value of an enumerated member.
Definition: config.c:1490
char * application_name
Definition: datasrc.h:358
DATASRCAPI int ds_peer_flags(int peer)
Gets the flags of a peer.
Definition: peer.c:1459
DATASRCAPI void ds_write_event_set_callback(ds_write_event_t *ev, ds_io_event_cb cb, int val, void *data)
Change the callback and callback values for a socket write event.
Definition: event.c:847
DATASRCAPI int32_t ds_add_record_fmt(ds_data_t *data, const char *field, const char *fmt,...)
Add a formatted string to a record object.
Definition: record.c:197
DATASRCAPI ds_monitor_t * ds_monitor_new_long(const char *templatename, const char *key, const char *propertyname, int32_t value)
Create a new ds_monitor_t object from an input long.
Definition: monitor.c:1733
DATASRCAPI ds5_namespace_t * ds5_create_prefix_namespace(const char *prefix)
Creates a DataSource namespace which will match subject names based on their prefix.
Definition: dsv5_namespace.c:86
DATASRCAPI char * ds_fields_namebyindex(int index)
Return the field name of this index.
Definition: fields.c:622
DATASRCAPI void ds_monitor_create_group(const char *templatename, const char *key, const char *brief, const char *description)
Create a new monitoring group.
Definition: monitor.c:1348
DATASRCAPI void ds_add_data_uint64(ds_data_t *data, int32_t fieldnum, uint64_t value)
Add a value to a data object in the form of a 64 bit unsigned integer.
Definition: api.c:441
DATASRCAPI void DATASRCAPI void ds_cycle_all_logs(const char *suffix, long maxsize)
Cycle all log files in the application.
Definition: log.c:1392
DATASRCAPI int ds_udp_send(const char *data, int len, const char *addr, int port)
Sends data to a UDP address.
Definition: net.c:860
DATASRCAPI int ds_fields_getflags(int index)
Return the field flags of this index.
Definition: fields.c:662
DATASRCAPI void ds_monitor_start_template(const char *templatename, const char *description)
Start the defintion of a template.
Definition: monitor.c:976
DATASRCAPI void ds_add_permission_key(ds_data_t *data, const char *key)
Set the key for a permission object. Must be called either first, or immediately after inserting a se...
Definition: permission.c:101
DATASRCAPI void ds_config_add_bounded_option_enum(char sopt, const char *longopt, const char *help, int type, void *value, ds_config_enum_t *enums, void *min, void *max)
Add an enumerated option to the configuration context.
Definition: config.c:482
DATASRCAPI sock_t ds_udp_listen_socket(const char *p_interface, int port)
Creates a UDP listen socket.
Definition: net.c:691
DATASRCAPI void ds_config_add_option(char opt, const char *longopt, const char *help, int type, void *value)
Add a configuration option to the current configuration context.
Definition: config.c:387
DATASRCAPI void ds_add_binary_uint8(ds_data_t *data, int32_t fieldnum, uint8_t value)
Add a value to a data object in the form of an unsigned 8 bit integer.
Definition: binary.c:384
DATASRCAPI void ds_monitor_del_subscription(const char *templatename, const char *key, const char *propertyname, const char *value)
Delete a subscription between two groups.
Definition: monitor.c:1322
int(* ds_timed_event_cb)(int id, int val, void *data)
Definition of the callback for use with timed events.
Definition: datasrc.h:1046
DATASRCAPI void ds_add_news_datetime(ds_data_t *data, const char *datestr)
Add a date stamp to the news headline message.
Definition: news.c:87
The container object for monitoring array types.
Definition: datasrc.h:1394
DATASRCAPI void ds_monitor_delete_group(const char *templatename, const char *key)
Delete a group from the monitoring system.
Definition: monitor.c:1367
DATASRCAPI void ds_config_parse_args(int argc, char **argv, int *retargc)
Parse the configuration options from the command line arguments given.
Definition: config.c:2349
DATASRCAPI int ds_set_request_hint(const char *name, int num, char **hints)
Set the objects hint peers.
Definition: advmap.c:5719
DATASRCAPI void ds_config_set_test(const char *tag, char **value)
Adds a conditional test to the configuration file.
Definition: config.c:1043
DATASRCAPI void ds_config_list_options(void)
Print the options in the current configuration context to standard output.
Definition: config.c:3353
DATASRCAPI int ds_peer_local_type(int peer)
Gets the local type of a DataSource peer.
Definition: peer.c:1515
DATASRCAPI ds_udp_event_t * ds_add_udp_event(const char *command, ds_udp_event_cb cb, int val, void *data)
Add a udp event.
Definition: test_license.c:57
void(* recv_nodata_t)(int peer, char *subject, unsigned short flags)
Definition of the function type used for receiving "nodata" messages.
Definition: datasrc.h:228
DATASRCAPI char * ds_peer_name(int peer)
Gets the name of a peer.
Definition: peer.c:1431
DATASRCAPI void ds_set_subject(ds_data_t *data, const char *subject)
Sets a new name for the data object.
Definition: api.c:83
DATASRCAPI ds_log_t * ds_new_log(const char *name, const char *logname)
Create a new log object.
Definition: log.c:561
DATASRCAPI void ds5_add_connectionlistener(ds5_connectionlistener_t *connection_listener, void *context)
Adds a connection listener. The listener receives status events about the state of the DataSource app...
Definition: dsv5.c:274
void ds_config_add_config_reading_message_fmt(const char *fmt,...)
Handle a configuration loading message. Add a formatted message to the list of messages to be logged...
Definition: config.c:3452
void(* ds_logcycled_t)(ds_log_t *log)
Callback used when the log has cycled.
Definition: datasrc.h:1211
DATASRCAPI int ds_check_subnet(const char *s_address, const char *s_network, const char *s_netmask)
Check whether an address falls into a given network and netmask.
Definition: net.c:1153
int typeflags
Definition: datasrc.h:1442
DATASRCAPI ds5_namespace_t * ds5_create_globbed_namespace(const char *globbed)
Creates a DataSource namespace which will match subject names using globbing.
Definition: dsv5_namespace.c:138
DATASRCAPI void ds_monitor_del_relation(const char *templatename, const char *key, const char *propertyname, const char *targetkey)
Delete a relationship between two groups.
Definition: monitor.c:1263
void(* recv_peer_status_t)(int peer, int status, int val, void *data)
Definition of the function type used for receiving peer status messages.
Definition: datasrc.h:252
DATASRCAPI int ds_num_peers
The number of DataSource peers in your configuration. If discovery is enabled then this is set to be ...
Definition: peer.c:305
DATASRCAPI void ds_add_data_uint16(ds_data_t *data, int32_t fieldnum, uint16_t value)
Add a value to a data object in the form of a 16 bit unsigned integer.
Definition: api.c:381
DATASRCAPI void ds_add_binary_uint16(ds_data_t *data, int32_t fieldnum, uint16_t value)
Add a value to a data object in the form of an unsigned 16 bit integer.
Definition: binary.c:407
DATASRCAPI void ds_add_news_company_code(ds_data_t *data, const char *code)
Add a company code to the news headline message.
Definition: news.c:158
DATASRCAPI char * ds_debug_string(int level)
This function will convert a debug level into an appropriate string.
Definition: log.c:2053
DATASRCAPI void ds_add_data_uint8(ds_data_t *data, int32_t fieldnum, uint8_t value)
Add a value to a data object in the form of an 8 bit unsigned integer.
Definition: api.c:351
DATASRCAPI int ds_udp_sendto(const char *data, int len, struct sockaddr_storage *serv_addr)
Sends data to a UDP address.
Definition: net.c:892
DATASRCAPI int ds_object_available(const char *name)
Determine whether this object can theoretically be requested.
Definition: advmap.c:5546
DATASRCAPI int ds_fields_numbyname(const char *name)
Return the field number of this field.
Definition: fields.c:489
DATASRCAPI void ds_add_data_fmt(ds_data_t *data, int32_t fieldnum, const char *fmt,...)
Add a sprintf style format string to a data object.
Definition: api.c:127
DATASRCAPI void ds_set_timed_delay_next(ds_timed_event_t *ev, double delay)
Alter the next fire time for an existing timed event.
Definition: event.c:1491
DATASRCAPI int ds_request_objects(int count, char **obs, char ***services)
Request a number of objects in one go.
Definition: advmap.c:5075
DATASRCAPI char * ds_getnameinfo(const struct sockaddr_storage *addr, char *buf, size_t buflen)
return the string representation of the address passed in
Definition: net.c:295
DATASRCAPI int ds_peer_type(int peer)
Gets the type of a DataSource peer.
Definition: peer.c:1487
DATASRCAPI void ds_monitor_update_llong(const char *templatename, const char *key, const char *propertyname, int64_t value)
Post an update to the monitoring system for a long long value.
Definition: monitor.c:1558
DATASRCAPI void ds5_publish_subject_map(ds5_publisher_t *publisher, const char *subject, const char *mapped_to, int flags)
Publishes a subscription map event for a subject.
Definition: dsv5_publisher.c:361
DATASRCAPI void ds_add_data_int32(ds_data_t *data, int32_t fieldnum, int32_t value)
Add a value to a data object in the form of a 32 bit integer.
Definition: api.c:291
Monitoring credentials object.
Definition: datasrc.h:1483
An implementation of this interface allows applications to receive events raised for a ds5_subscripti...
Definition: datasrc.h:648
DATASRCAPI ds_monitor_t * ds_monitor_new(const char *propertyname, int type, int datasize, const void *datum)
Create a new ds_monitor_t object from input parameters.
Definition: monitor.c:591
DATASRCAPI void ds_add_binary_int64(ds_data_t *data, int32_t fieldnum, int64_t value)
Add a value to a data object in the form of a 64 bit integer.
Definition: binary.c:352
DATASRCAPI void ds_send_status_direct(const char *subject, unsigned short flags, unsigned short code, const char *msgstr)
Sends a user defined status message about a particular object.
Definition: api.c:939
DATASRCAPI void ds_add_binary(ds_data_t *data, int32_t fieldnum, char *value, int len, char type)
Adds a binary value to a data object.
Definition: binary.c:198
void ds_monitor_update_boolean(const char *templatename, const char *key, const char *propertyname, unsigned char value)
Post an update to the monitoring system for a boolean value.
Definition: monitor.c:1461
DATASRCAPI void ds_add_binary_int16(ds_data_t *data, int32_t fieldnum, int16_t value)
Add a value to a data object in the form of a 16 bit integer.
Definition: binary.c:304
DATASRCAPI int ds_peer_up(int peer)
Check to see if a peer is up.
Definition: peer.c:1576
DATASRCAPI void ds_add_data_char(ds_data_t *data, int32_t fieldnum, char value)
Add a value to a data object in the form of a character.
Definition: api.c:468
DATASRCAPI void ds_config_end_section(const char *longopt, const char *help)
Ends a configuration section.
Definition: config.c:954
DATASRCAPI ds_logcycled_t ds_log_cycled_callback(ds_log_t *log, ds_logcycled_t cycle_cb)
Set the cycle callback for a given logfile.
Definition: log.c:2572
unsigned short count
Definition: datasrc.h:2473
DATASRCAPI void ds_config_add_array_option(const char *longopt, const char *help, int type, void *value, int *num)
Adds a configuration option to the current configuration context.
Definition: config.c:590
DATASRCAPI char * ds_request_object(const char *name)
Request an object.
Definition: advmap.c:5019
DATASRCAPI void ds_monitor_add_server_type(const char *type, const char *root)
Define The Server Type.
Definition: monitor.c:930
DATASRCAPI int ds_config_get_linenumber(void)
Return the name of current configuration file being parsed.
Definition: config.c:3679
struct _ds5_subscription_s ds5_subscription_t
Represents a subscription to a DataSource subject (see ds_create_active_subscription()) or to a names...
Definition: datasrc.h:633
DATASRCAPI int ds_udp_bind_client_socket(sock_t sock, const char *addr, int port)
Binds a UDP socket to a local address.
Definition: net.c:969
DATASRCAPI void ds_monitor_add_subscription(const char *templatename, const char *key, const char *propertyname, const char *value)
Add a subscription between two groups.
Definition: monitor.c:1298
DATASRCAPI int ds_signature_verify_username(char *expected_username, char *token)
Verify that the supplied token is for the expected username.
Definition: signature.c:885
recv_object_status_t recv_object_status
Definition: datasrc.h:371
DATASRCAPI void ds_set_status_down(void)
Causes the DataSource to disconnect and stop listening for connections.
Definition: peer.c:4336
DATASRCAPI void ds_reserve_std_fds(void)
Reserves the standard sockets for the std streams.
Definition: datasrc.c:190
DATASRCAPI void ds_cache_add_object(char *subject)
Add a new object to the cache.
Definition: cache.c:293
char * name
Definition: datasrc.h:925
char * docstring
Definition: datasrc.h:1445
recv_service_status_t recv_service_status
Definition: datasrc.h:376
DATASRCAPI void ds_send_nodata_direct(const char *subject, unsigned short flags)
Send a "no data" message to all connected DataSource peers.
Definition: api.c:800
DATASRCAPI void DATASRCAPI void DATASRCAPI void ds_printf_time_ap(ds_log_t *log, const char *extra, const char *fmt, va_list ap)
Write a formatted string prefixed with a timestamp string to a log object.
Definition: log.c:1178
DATASRCAPI int ds_del_timed_event_free_data(ds_timed_event_t *ev, void(*free_data)(int, void *))
Remove a timed event.
Definition: event.c:1400
DATASRCAPI int ds_peer_by_local_label(const char *label)
Return the peer index for a local label.
Definition: peer.c:5899
DATASRCAPI void ds_add_binary_uint32(ds_data_t *data, int32_t fieldnum, uint32_t value)
Add a value to a data object in the form of an unsigned 32 bit integer.
Definition: binary.c:431
DATASRCAPI void ds_log_change_level_callback(ds_log_t *log, ds_loglevelchange_t change_cb)
Set the level change callback for a given logfile.
Definition: log.c:2556
DATASRCAPI void ds_monitor_add_template_member(const char *templatename, const char *propertyname, const char *description, int typeflags, ds_arguments_t *args, void *ptr)
Add a memeber to a template.
Definition: monitor.c:1012
char * docstring
Definition: datasrc.h:927
int sock_t
The network socket datatype.
Definition: datasrc.h:127
char * description
Definition: datasrc.h:1444
Implement this interface to receive connection status information when using the DSv5 API...
Definition: datasrc.h:594
DATASRCAPI int ds_fields_indexbynum(int num)
Return the index of this field.
Definition: fields.c:579
void(* recv_replay_t)(int peer, ds_data_t *pkt, time_t tm)
Definition of the function type used for receiving updates from a the DataSource library when calling...
Definition: datasrc.h:208
DATASRCAPI void ds_monitor_add_data(ds_monitor_t *data, const void *datum)
Add an element to an array within a ds_monitor_t.
Definition: monitor.c:453
DATASRCAPI sock_t ds_client_socket(const char *serv, unsigned short port)
Creates a client socket with which to connect to a host.
Definition: net.c:844
DATASRCAPI void ds_add_latency_chain2(ds_data_t *dsdata, char suffix, struct timespec tp, char suffix2, struct timespec *tp2)
Function used to add two measurement points to latency chain data.
Definition: lty_chain.c:299
ds_field_t * fields
Definition: datasrc.h:2474
DATASRCAPI void ds_discard_object(const char *name)
Discard an object.
Definition: advmap.c:5207
unsigned short flags
Definition: datasrc.h:361
DATASRCAPI void ds_replay(recv_replay_t callback)
Replays all data in the current packet log file.
Definition: replay.c:177
DATASRCAPI void ds_set_status_up_to_peer(int peer)
Causes the DataSource to connect and accept connections.
Definition: peer.c:4729
DATASRCAPI int ds_replay_by_time_from_file(time_t t, recv_replay_t callback, char *filename)
Replays all data in a file that arrived after a specified time.
Definition: replay.c:323
DATASRCAPI char * ds_peer_label_byindex(int index)
Return the peer label for a peer index.
Definition: peer.c:5942
DATASRCAPI void ds_monitor_update(const char *templatename, const char *key, ds_monitor_t *mondata)
Post an update to the monitoring system for a string value.
Definition: monitor.c:1392
DATASRCAPI void ds_config_end_group(const char *longopt, const char *help)
Ends a configuration group.
Definition: config.c:871
DATASRCAPI char * ds_fields_namebynum(int num)
Return the field name of this field number.
Definition: fields.c:519
DATASRCAPI void ds_send_nodata(const char *subject, unsigned short flags)
Send a "no data" message to all connected DataSource peers.
Definition: api.c:777
DATASRCAPI void ds_config_add_bounded_array_option(const char *longopt, const char *help, int type, void *value, int *num, void *min, void *max)
Adds a configuration option to the current configuration context.
Definition: config.c:624
DATASRCAPI void ds_monitor_add_relation(const char *templatename, const char *key, const char *propertyname, const char *targetkey)
Add a relationship between two groups.
Definition: monitor.c:1238
DATASRCAPI void ds_thread_init(int event_module, int flags)
Initialise the event loop for this thread.
Definition: datasrc.c:973
char * name
Definition: datasrc.h:1443
Definition of the interface that you should implement if you require custom subject matching logic...
Definition: datasrc.h:431
DATASRCAPI int ds_del_write_event_free_data(ds_write_event_t *ev, void(*free_data)(int, void *))
Remove a socket write event.
Definition: event.c:744
DATASRCAPI void ds5_publish_status_all(ds5_publisher_t *pub, int status, const char *message)
Publishes a subscription status event for all requested subjects.
Definition: dsv5_publisher.c:344
DATASRCAPI void ds_monitor_update_ullong(const char *templatename, const char *key, const char *propertyname, uint64_t value)
Post an update to the monitoring system for an unsigned long long value.
Definition: monitor.c:1539
DATASRCAPI void ds_set_timed_delay(ds_timed_event_t *ev, double delay)
Alter the delay for an existing timed event.
Definition: event.c:1471
DATASRCAPI void ds_config_del_test(const char *tag)
Delete a conditional test.
Definition: config.c:1077
DATASRCAPI void ds_add_news_headline(ds_data_t *data, const char *headline)
Add a news headline to the news headline message.
Definition: news.c:53
DATASRCAPI ds5_subscription_t * ds5_create_broadcast_subscription(ds5_namespace_t *nspace, ds5_subscriptionlistener_t *listener, void *context)
Create a subscription that matches multiple subjects.
Definition: dsv5_subscription.c:98
DATASRCAPI void ds_send_status(const char *subject, unsigned short flags, unsigned short code, const char *msgstr)
Sends a user defined status message about a particular object.
Definition: api.c:912
struct _ds_udp_event ds_udp_event_t
Opaque type defining a udp event.
Definition: datasrc.h:2514
DATASRCAPI void ds_delay_data(ds_delay_t *delay, ds_data_t *dsdata)
Add a data object to a delay channel.
Definition: delay.c:290
void(* recv_object_status_t)(int peer, char *subject, int status, unsigned short code, char *msgstr)
Definition of the function type used for handling objectstatus messages.
Definition: datasrc.h:313
DATASRCAPI ds_log_t * ds_new_level_log(const char *name, const char *logname, ds_loglevelchange_t change_cb)
Create a new log object.
Definition: log.c:584
DATASRCAPI void ds_add_news_storycode(ds_data_t *data, const char *story)
Add a story code to the news object.
Definition: news.c:70
DATASRCAPI void ds_send_data_direct(ds_data_t *data)
Send the data object to all connected DataSource peers.
Definition: api.c:524
DATASRCAPI void ds_add_data_float64(ds_data_t *data, int32_t fieldnum, double value)
Add a value to a data object in the form of a floating point number.
Definition: api.c:201
DATASRCAPI void ds_add_binary_time(ds_data_t *data, int32_t fieldnum, time_t value)
Add a value to a data object in the form of a timestamp.
Definition: binary.c:533
DATASRCAPI ds_monitor_t * ds_monitor_new_llong(const char *templatename, const char *key, const char *propertyname, int64_t value)
Create a new ds_monitor_t object from an input long long.
Definition: monitor.c:1777
DATASRCAPI void ds_config_del_option(const char *longopt)
Remove an option from the current configuration context.
Definition: config.c:732
char * propertyname
Definition: datasrc.h:1417
void(* recv_discard_t)(int peer, int count, char **subjects, unsigned short flags)
Definition of the function type used for handling data discard requests.
Definition: datasrc.h:292
The container object for all monitoring values.
Definition: datasrc.h:1415
DATASRCAPI void * ds_get_object_data(const char *name)
Get an objects user data.
Definition: advmap.c:5889
DATASRCAPI void ds5_publish_subject_error(ds5_publisher_t *publisher, const char *subject, int flags)
Publishes a subscription error event for a subject.
Definition: dsv5_publisher.c:377
DATASRCAPI void ds_read_event_set_callback(ds_read_event_t *ev, ds_io_event_cb cb, int val, void *data)
Change the callback and callback values for a socket read event.
Definition: event.c:830
DATASRCAPI void ds_add_news_field(ds_data_t *dsdata, const char *fieldname, const char *value)
Add a custom field to a news headline message.
Definition: news.c:200
unsigned short flags
Definition: datasrc.h:2470
DATASRCAPI char * ds_log_getname(ds_log_t *log)
Get the name of a log object.
Definition: log.c:1587
DATASRCAPI int ds_peer_host_details(int peer, char **addr)
Gets details of the remote side of a peer.
Definition: peer.c:1372
Structure defining the arguments for Monitoring methods.
Definition: datasrc.h:1440
void(* ds_delay_send_cb)(void *context, ds_data_t *dsdata)
Definition of the callback for sending delayed data.
Definition: datasrc.h:2312
DATASRCAPI int ds_cycle_log(ds_log_t *log, const char *suffix, long maxsize)
Cycle a specific log file.
Definition: log.c:1423
struct _ds_log ds_log_t
The log file object.
Definition: datasrc.h:174
unsigned short type
Definition: datasrc.h:362
DATASRCAPI void ds_add_news_authstr(ds_data_t *data, const char *authstr)
Add an authorisation string to the news headline message.
Definition: news.c:107
DATASRCAPI ds_monitor_t * ds_monitor_new_short(const char *templatename, const char *key, const char *propertyname, int16_t value)
Create a new ds_monitor_t object from an input short.
Definition: monitor.c:1689
DATASRCAPI void ds_add_data_str(ds_data_t *data, int32_t fieldnum, const char *value)
Adds a string value to a data object.
Definition: api.c:154
void(* free)(ds5_namespace_t *nspace)
Invoked when the namespace should be deleted.
Definition: datasrc.h:438
DATASRCAPI void ds_replay_by_field(int fieldnum, char *value, recv_replay_t callback)
Replays all data in the current packet log file that arrived after an update with the specified value...
Definition: replay.c:388
DATASRCAPI ds_timed_event_t * ds_add_timed_event(int id, double delay, ds_timed_event_cb cb, int val, void *data)
Add a timed event.
Definition: event.c:1276
DATASRCAPI void ds_send_data(ds_data_t *data)
Send the data object to all connected DataSource peers.
Definition: api.c:499
struct _ds_peer_set ds_set_t
Defines a set of DataSource peers.
Definition: datasrc.h:152
DATASRCAPI void ds_not(ds_set_t *p)
Apply logical not to each peer in group.
Definition: peerset.c:25
DATASRCAPI void ds_writev(ds_log_t *log, struct iovec *vector, int count)
Write binary data to a log object.
Definition: log.c:1087
DATASRCAPI void ds_send_data_to_peer_no_free(int peer, ds_data_t *data)
Send the data object to a specific peer.
Definition: api.c:716
DATASRCAPI void ds_stop(void)
Definition: event.c:1173
DATASRCAPI void ds_config_add_group_with_info(const char *longopt, const char *help, void *base, void *def, size_t size, int *num, int file_offset, int line_offset)
Add a configuration group to the current configuration context.
Definition: config.c:819
ds_monitor_t * ds_monitor_new_boolean(const char *templatename, const char *key, const char *propertyname, unsigned char value)
Create a new ds_monitor_t object from an input boolean value.
Definition: monitor.c:1667
DATASRCAPI int ds_fields_getdp(int index)
Return the decimal precision of this index.
Definition: fields.c:679
DATASRCAPI void ds_set_status_msg_to_peer(int peer, unsigned short msgid, const char *msgstr)
Send a user-defined status message to peer.
Definition: peer.c:4571
struct _ds_timed_event ds_timed_event_t
Opaque type defining a timed event.
Definition: datasrc.h:992
DATASRCAPI void ds_monitor_update_short(const char *templatename, const char *key, const char *propertyname, int16_t value)
Post an update to the monitoring system for a short value.
Definition: monitor.c:1480
void ds_config_add_error_message_fmt(const char *fmt,...)
Add a formatted error message to the logfile.
Definition: config.c:3420
DATASRCAPI sock_t ds_udp_client_socket(const char *addr, int port, struct sockaddr_storage *serv_addr)
Creates a UDP client socket.
Definition: net.c:925
DATASRCAPI void ds_monitor_free(ds_monitor_t *data)
Deallocate memory used by a ds_monitor_t object.
Definition: monitor.c:519
DATASRCAPI void ds_add_binary_timeval(ds_data_t *data, int32_t fieldnum, struct timeval value)
Add a value to a data object in the form of a timestamp.
Definition: binary.c:581
DATASRCAPI ds_log_t * ds_new_headed_log(const char *name, const char *logname, const char *header)
Create a new log object with a header.
Definition: log.c:945
DATASRCAPI void ds_send_status_to_peer(int peer, const char *subject, unsigned short flags, unsigned short code, const char *msgstr)
Sends a user defined status message about a particular object.
Definition: api.c:1000
DATASRCAPI int ds5_regex_namespace_add_expr(ds5_namespace_t *nspace, const char *expr, int exclude)
Adds a regular expression to a namespace.
Definition: dsv5_namespace.c:241
DATASRCAPI char ** ds_get_request_hints(const char *name, int *ret)
Return an objects request hints.
Definition: advmap.c:5798
DATASRCAPI ds_monitor_t * ds_monitor_new_ullong(const char *templatename, const char *key, const char *propertyname, uint64_t value)
Create a new ds_monitor_t object from an input unsigned long long.
Definition: monitor.c:1755
size_t size
Definition: datasrc.h:1395
DATASRCAPI void ds_set_status_up(void)
Causes the DataSource to connect and listen for connections.
Definition: peer.c:4678
DATASRCAPI int ds_check_periodic_event(int period, ds_timed_event_t **tev)
Check a periodic to ensure that it runs at the appropriate time regardless of summertime.
Definition: event.c:2169
DATASRCAPI void ds_loop(void)
Start the DataSource event loop.
Definition: event.c:1140
DATASRCAPI void ds_udpsignal_send(const char *message)
Send a udp message.
Definition: udpsignal.c:366
A data update object.
Definition: datasrc.h:2467
DATASRCAPI void ds_add_news_product_code(ds_data_t *data, const char *code)
Add a product code to the news headline message.
Definition: news.c:124
DATASRCAPI void ds5_unsubscribe(ds5_subscription_t *sub)
Unsubscribe from the DataSource subject or namespace of DataSource subjects.
Definition: dsv5_subscription.c:536
DATASRCAPI int ds_debug_level(const char *text)
This function will convert a string into an appropriate debug level.
Definition: log.c:2027
DATASRCAPI int ds_iszero(ds_set_t *p)
Check if any peer is set.
Definition: peerset.c:48
DATASRCAPI void ds5_publish_to_subscribed_peers_no_free(ds5_publisher_t *pub, ds_data_t *dsdata)
Publish an update for a subject to all peers that have subscribed. The update will not be freed...
Definition: dsv5_publisher.c:247
DATASRCAPI ds_delay_t * ds_new_delay(double delay_time, char *prefix, double batch_time)
Create a new delay channel.
Definition: delay.c:200
DATASRCAPI void ds_purge_object(const char *name)
Purge an object from our cache.
Definition: advmap.c:5687
DATASRCAPI int ds_log_flush(ds_log_t *log)
flush log buffers to disk
Definition: log.c:2419
DATASRCAPI int ds_request_objects_with_flags(int count, char **obs, int flags, char ***services)
Request a number of objects in one go.
Definition: advmap.c:5100
void(* recv_map_t)(int peer, char *from, char *to)
Definition of the function type used for handling map messages.
Definition: datasrc.h:336
DATASRCAPI int ds_peer_enabled_state(int peer)
Gets the enabled/disabled state of a DataSource peer.
Definition: peer.c:1547
void(* recv_service_status_t)(char *service, int status)
Definition of the function type used for handling service status messages.
Definition: datasrc.h:324
DATASRCAPI int ds_fields_indexbyname(const char *name)
Return the index of this field.
Definition: fields.c:546
DATASRCAPI void ds5_publish_to_subscribed_peers(ds5_publisher_t *pub, ds_data_t *dsdata)
Publish an update for a subject to all peers that have subscribed.
Definition: dsv5_publisher.c:230
DATASRCAPI ds_monitor_t * ds_monitor_new_string(const char *templatename, const char *key, const char *propertyname, const char *value)
Create a new ds_monitor_t object from an input string.
Definition: monitor.c:1623
DATASRCAPI void ds_add_news_user_code(ds_data_t *data, int codenum, const char *code)
Add a user defined code to the news headline message.
Definition: news.c:178
char * value
Definition: datasrc.h:2488
DATASRCAPI void ds_config_parse_files(void)
Parse all configuration files within the current configuration context.
Definition: config.c:2173
DATASRCAPI void ds_config_add_option_enum(char opt, const char *longopt, const char *help, int type, void *value, ds_config_enum_t *enums)
Add an enumerated option to the configuration context.
Definition: config.c:454
DATASRCAPI int ds_get_is_contrib_source(const char *name, int peer)
Check if the given peer is a contribution source for the symbol.
Definition: advmap.c:5445
DATASRCAPI void ds5_publish_response(ds5_publisher_t *pub, ds_data_t *dsdata)
Publish an initial response (for example, an image of the subject&#39;s data) following a request for a s...
Definition: dsv5_publisher.c:298
DATASRCAPI void ds_daemon_redirect(void)
Redirects the std* streams.
Definition: daemon.c:141
DATASRCAPI void ds_remove_container_symbol(ds_data_t *data, const char *symbol)
Remove an object from the container.
Definition: container.c:100
char * username
Definition: datasrc.h:1485
DATASRCAPI sock_t ds_accept_socket(sock_t fd)
Accepts a connection from a listen socket.
Definition: net.c:549
int(* ds_io_event_cb)(sock_t sock, int val, void *data)
Definition of the callback for use with read and write events.
Definition: datasrc.h:1034
DATASRCAPI ds5_publisher_t * ds5_create_broadcast_publisher(ds5_namespace_t *nspace)
Creates a data publisher that allows a DataSource application to broadcast updates to remote DataSour...
Definition: dsv5_publisher.c:806
DATASRCAPI void ds_add_data_int64(ds_data_t *data, int32_t fieldnum, int64_t value)
Add a value to a data object in the form of a 64 bit integer.
Definition: api.c:321
DATASRCAPI ds_monitor_t * ds_monitor_new_array(const char *propertyname, int type)
Create a new ds_monitor_t of an array type.
Definition: monitor.c:431
DATASRCAPI void ds5_publish_response_no_free(ds5_publisher_t *pub, ds_data_t *dsdata)
Publish an initial response (for example, an image of the subject&#39;s data) following a request for a s...
Definition: dsv5_publisher.c:314
DATASRCAPI void ds_config_add_search(const char *path)
Add a directory in which to search for configuration files.
Definition: config.c:279
unsigned short type
Definition: datasrc.h:2471
DATASRCAPI ds5_publisher_t * ds5_create_compatibility_publisher(ds5_namespace_t *nspace, ds5_dataprovider_t *provider, void *context)
Creates a data publisher that, for a given subject sends multiple subscription requests and multiple ...
Definition: dsv5_publisher.c:183
DATASRCAPI void ds_replay_by_time_from_log(time_t t, recv_replay_t callback, ds_log_t *log)
Replays all data in a log object that arrived after a specified time.
Definition: replay.c:342
DATASRCAPI void ds_replay_from_log(recv_replay_t callback, ds_log_t *log)
Replays all data in a packet log file.
Definition: replay.c:155
DATASRCAPI ds_monitor_t * ds_monitor_new_timestamp(const char *templatename, const char *key, const char *propertyname, int64_t value)
Create a new ds_monitor_t object from an input timestamp.
Definition: monitor.c:1799
DATASRCAPI void ds_set_status_msg(unsigned short msgid, const char *msgstr)
Send a user-defined status message to all connected peers.
Definition: peer.c:4500
struct _ds_io_event ds_write_event_t
Opaque type defining a write event.
Definition: datasrc.h:1014
DATASRCAPI char * ds_filename_expand(const char *format, char *buffer, size_t bufsize)
Expand a filename pattern into a fully qualified filename.
Definition: datasrc.c:1238
double value
Definition: datasrc.h:926
DATASRCAPI ds_log_t * ds_get_event_log(void)
Returns a handle to the event log used by Datasource for C.
Definition: datasrc.c:1420
recv_request_t recv_request
Definition: datasrc.h:363
DATASRCAPI ds_config_ctx_t * ds_config_set_ctx(ds_config_ctx_t *ctx)
Sets a configuration context as the current one.
Definition: config.c:258
char * password
Definition: datasrc.h:1486
struct _config_ctx ds_config_ctx_t
The configuration context data type.
Definition: datasrc.h:169
DATASRCAPI void ds_del_udp_event(ds_udp_event_t *event)
Remove a timed event.
Definition: udpsignal.c:189
DATASRCAPI int ds_send_contribution(ds_data_t *dsdata)
Contribute an object back to the peers that supplied it and support it.
Definition: advmap.c:5314
recv_map_t recv_map
Definition: datasrc.h:377
DATASRCAPI void ds_config_list_values(void)
Print the options and values in the current configuration context to standard output.
Definition: config.c:3367
Interface that must be implemented in order to receive subscirption request and subscription discard ...
Definition: datasrc.h:518
DATASRCAPI int ds_peer_all_type(int flag)
Checks if a DataSource peer of the given type is in your configuration file.
Definition: peer.c:1701
int32_t fieldnum
Definition: datasrc.h:2486
recv_peer_status_t recv_peer_status
Definition: datasrc.h:367
char * logfile
Definition: datasrc.h:380
DATASRCAPI void ds_monitor_update_ulong(const char *templatename, const char *key, const char *propertyname, uint32_t value)
Post an update to the monitoring system for an unsigned long value.
Definition: monitor.c:1500
ds_log_t * log
Definition: datasrc.h:381
DATASRCAPI ds_monitor_authenticator_t ds_monitor_set_auth(ds_monitor_authenticator_t authenticator)
Register a new authentication handler.
Definition: monitor.c:1844
struct _ds_io_event ds_except_event_t
Opaque type defining an exception event.
Definition: datasrc.h:999
DATASRCAPI char * ds_request_object_with_flags(const char *name, int flags)
Request an object.
Definition: advmap.c:5038
struct _ds_io_event ds_read_event_t
Opaque type defining a read event.
Definition: datasrc.h:1007
DATASRCAPI void ds_add_latency_initial_timestamp(ds_data_t *dsdata)
Sets the initial time for latency chaining.
Definition: lty_chain.c:352
DATASRCAPI void ds_add_data_int8(ds_data_t *data, int32_t fieldnum, int8_t value)
Add a value to a data object in the form of an 8 bit integer.
Definition: api.c:231
DATASRCAPI void ds_add_latency_chain(ds_data_t *dsdata, char suffix, struct timespec *tp)
function used to add a measurement point to latency chain data
Definition: lty_chain.c:247
DATASRCAPI ds_timed_event_t * ds_add_periodic_event_from_time(time_t then, int starttime, int period, int id, ds_timed_event_cb cb, int val, void *data)
Add a timed event, starting at a particular offset from a given time.
Definition: event.c:2074
DATASRCAPI void ds_add_binary_string(ds_data_t *data, int32_t fieldnum, char *value)
Add a value to a data object in the form of a string.
Definition: binary.c:484
DATASRCAPI char * ds_debug_config_string(int level)
This function will convert a debug level into an appropriate string.
Definition: log.c:2085
void(* ds_config_func)(char *name, int num, char **values)
Definition of function type used for configuration callbacks.
Definition: datasrc.h:944
DATASRCAPI int ds_config_parse_file(const char *unresolved_filename)
Parse a single configuration file within the configuration context.
Definition: config.c:2525
DATASRCAPI void ds_cleardown_container_with_prefix(ds_data_t *data, const char *prefix)
Remove a set of symbols from the container.
Definition: container.c:139
DATASRCAPI int ds_get_gmt_offset(time_t t)
Calculate offset between local time and gmt.
Definition: event.c:1909
DATASRCAPI void ds_add_binary_uint64(ds_data_t *data, int32_t fieldnum, uint64_t value)
Add a value to a data object in the form of an unsigned 64 bit integer.
Definition: binary.c:455
DATASRCAPI int ds_and3_iszero(ds_set_t *p1, ds_set_t *p2, ds_set_t *p3)
Check if the bitwise and of 3 peer sets is 0.
Definition: peerset.c:153
DATASRCAPI int ds_del_read_event(ds_read_event_t *ev)
Remove a socket read event.
Definition: event.c:649
int32_t len
Definition: datasrc.h:2487
DATASRCAPI int ds_log_get_level(ds_log_t *log)
Get the current loglevel for the given logfile.
Definition: log.c:2588
DATASRCAPI void ds_or(ds_set_t *p1, ds_set_t *p2, ds_set_t *o)
Combine 2 peersets using bitwise or.
Definition: peerset.c:75
struct _ds_io_event ds_generic_event_t
Opaque type defining a generic read/write event.
Definition: datasrc.h:1021
void ds_log(ds_log_t *log, int level, const char *fmt,...)
Write a formatted string prefixed with log level and timestamp to the log object. ...
Definition: log.c:2196
DATASRCAPI int ds_daemon_disabled(void)
Check whether the application is running in daemon mode.
Definition: daemon.c:161
recv_nodata_t recv_nodata
Definition: datasrc.h:366
DATASRCAPI int ds_peer_host_details_r(int peer, char *buffer, size_t buflen)
Gets details of the remote side of a peer. User must provide buffer for the address.
Definition: peer.c:7635
DATASRCAPI int ds_init(ds_init_t *init, int argc, char **argv)
Parse the configuration files and initialise the DataSource library.
Definition: datasrc.c:457
DATASRCAPI int ds_peer_details(int peer, char **name)
Gets the ID and name of a peer.
Definition: peer.c:1342
char * ipaddress
Definition: datasrc.h:1487
DATASRCAPI int32_t ds_add_record_float(ds_data_t *data, const char *field, double value)
Add a floating point value to a record object.
Definition: record.c:160
void ds_printf_time(ds_log_t *log, const char *fmt,...)
Write a formatted string prefixed with a timestamp string to a log object.
Definition: log.c:1153
DATASRCAPI void ds_send_nodata_to_peer(int peer, const char *subject, unsigned short flags)
Send a "no data" message to a specific DataSource pper.
Definition: api.c:848
DATASRCAPI void ds_discard_objects(int count, char **obs)
Discard a number of objects.
Definition: advmap.c:5249
DATASRCAPI int ds_del_write_event(ds_write_event_t *ev)
Remove a socket write event.
Definition: event.c:709
DATASRCAPI void ds_timed_event_set_callback(ds_timed_event_t *ev, ds_timed_event_cb cb, int val, void *data)
Change the callback and callback values for a timed eent.
Definition: event.c:1645
DATASRCAPI int ds_get_service_by_index(int index, char **name_ptr)
Return the name/state of a service by index.
Definition: advmap.c:5520
DATASRCAPI void ds_replay_by_field_from_log(int fieldnum, char *value, recv_replay_t callback, ds_log_t *log)
Replays all data in the log object that arrived after an update with the specified value for the spec...
Definition: replay.c:440
struct _ds_delay ds_delay_t
The delay channel object type.
Definition: datasrc.h:163
DATASRCAPI ds_monitor_t * ds_monitor_new_ushort(const char *templatename, const char *key, const char *propertyname, uint16_t value)
Create a new ds_monitor_t object from an input unsigned short.
Definition: monitor.c:1645
DATASRCAPI void ds_config_add_bounded_option(char sopt, const char *longopt, const char *help, int type, void *value, void *min, void *max)
Add a bounded configuration option to the current configuration context.
Definition: config.c:425
DATASRCAPI void ds_add_container_symbol_at_position(ds_data_t *data, int position, const char *symbol)
Insert an object within a container at a particular position.
Definition: container.c:119
int(* ds_udp_event_cb)(int argc, char *argv[], int val, void *data)
Definition of the callback for use with udp events.
Definition: datasrc.h:2527
DATASRCAPI struct sockaddr_storage * ds_gethostsockaddr(const char *name, struct sockaddr_storage *populate)
Return the socket address for a given hostname.
Definition: net.c:247
DATASRCAPI time_t ds_get_time(void)
Gets the current time in seconds.
Definition: event.c:1216
void ds_syslog(ds_log_t *log, int level, const char *fmt,...)
Write a formatted string to a log object and to the system log.
Definition: log.c:1251
DATASRCAPI int ds_del_except_event_free_data(ds_except_event_t *ev, void(*free_data)(int, void *))
Remove a socket except event.
Definition: event.c:803
int(* match)(ds5_namespace_t *nspace, const char *subject)
Tests a subject to see if it falls within this namespace.
Definition: datasrc.h:448
DATASRCAPI void ds_add_binary_float64(ds_data_t *data, int32_t fieldnum, double value)
Add a value to a data object in the form of a floating point number.
Definition: binary.c:249
DATASRCAPI ds5_publisher_t * ds5_create_active_publisher(ds5_namespace_t *nspace, ds5_dataprovider_t *provider, void *context)
Creates a data publisher that for a given subject sends multiple subscription requests and a single s...
Definition: dsv5_publisher.c:125
DATASRCAPI int ds_peer_details_r(int peer, char *buffer, size_t buflen)
Gets the ID and name of a peer. User must provide buffer for the name.
Definition: peer.c:7597
DATASRCAPI ds_delay_t * ds_new_delay_with_callback(double delay_time, char *prefix, double batch_time, void *callback_param, ds_delay_send_cb callback_func)
Create a new delay channel.
Definition: delay.c:238
DATASRCAPI ds_data_t * ds_init_page(const char *subject, int rows, int cols, const char *type, unsigned short flags)
Initialise a data object as a page.
Definition: page.c:62
DATASRCAPI void ds_add_page_field(ds_data_t *data, int32_t fieldnum, const char *value)
Add an arbitrary field to a page.
Definition: page.c:126
int datatype
Definition: datasrc.h:1418
DATASRCAPI void ds_monitor_update_timestamp(const char *templatename, const char *key, const char *propertyname, int64_t value)
Post an update to the monitoring system for a timestamp value.
Definition: monitor.c:1577
recv_discard_t recv_discard
Definition: datasrc.h:364
DATASRCAPI void ds_add_page_row(ds_data_t *data, int row, int col, const char *str)
Add a row of data to a page data object.
Definition: page.c:100
DATASRCAPI sock_t ds_multicast_listen_socket(const char *p_interface, const char *addr, int port)
Creates a multicast listen socket.
Definition: net.c:571
DATASRCAPI int ds_get_num_services(void)
Return the number of services.
Definition: advmap.c:5503
DATASRCAPI ds_monitor_t * ds_monitor_new_ulong(const char *templatename, const char *key, const char *propertyname, uint32_t value)
Create a new ds_monitor_t object from an input unsigned long.
Definition: monitor.c:1711
DATASRCAPI int ds_del_read_event_free_data(ds_read_event_t *ev, void(*free_data)(int, void *))
Remove a socket read event.
Definition: event.c:684
DATASRCAPI int ds_fields_numbyindex(int index)
Return the field number of this index.
Definition: fields.c:604
DATASRCAPI void ds_free_log(ds_log_t *log)
Destroy a log object.
Definition: log.c:975
DATASRCAPI void ds_monitor_update_ushort(const char *templatename, const char *key, const char *propertyname, uint16_t)
Post an update to the monitoring system for an unsigned short value.
Definition: monitor.c:1441
DATASRCAPI struct tm * ds_localtime(void)
Get the current time in the local timezone.
Definition: event.c:1242
DATASRCAPI void ds_set_object_data(const char *name, void *data)
Set an objects user data.
Definition: advmap.c:5845
DATASRCAPI int ds_peer_id(int peer)
Gets the ID of a peer.
Definition: peer.c:1400
DATASRCAPI void ds_add_data(ds_data_t *data, int32_t fieldnum, const char *value)
Adds a string value to a data object.
Definition: api.c:108

Generated on Wed Oct 18 2023 17:20:33 for DataSource for C SDK