Transformer SDK For C  7.1.9.29929-d422075
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 16
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 
70 
71 #define EXIT_CODE_NML 0
72 #define EXIT_CODE_CFG 1
73 #define EXIT_CODE_LOG 2
74 #define EXIT_CODE_NET 3
75 #define EXIT_CODE_SYS 4
76 #define EXIT_CODE_LIC 5
77 #define EXIT_CODE_SIG 6
78 #define EXIT_CODE_SVC 7
79 #define EXIT_CODE_SSL 8
80 #define EXIT_CODE_JVM 9
81 
82 /* Reserve codes for binary start-up issues */
83 #define EXIT_CODE_BIN_MISSING 10
84 #define EXIT_CODE_BIN_NOT_EXEC 11
85 #define EXIT_CODE_BIN_EXIT AFTER_FORK 12
86 #define EXIT_CODE_BIN_BAD_ARCH 126
87 
88 /* Reserve an exit code for Java DataSource blade errors */
89 #define EXIT_CODE_JAVA_DATASOURCE_ERROR 201
90 
91 #define EXIT_CODE_GRACEFUL 202
92 
93 #ifndef WIN32
94 #ifndef DATASRCAPI
95 #define DATASRCAPI
96 #endif
97 #else /* WIN32 */
98 #ifndef DATASRCAPI
99 #ifndef DATASRC_EXPORT
100 #define DATASRCAPI _declspec(dllimport)
101 #else
102 #define DATASRCAPI _declspec(dllexport)
103 #endif
104 #endif
105 #endif /* WIN32 */
106 
107 
108 /* Provide some protection for variadic arguments */
109 #ifdef __GNUC__
110 #define PRINTF(fmt,arg) __attribute__ ((__format__ (__printf__, (fmt), (arg))))
111 #else
112 #define PRINTF(fmt,arg)
113 #endif
114 
115 
121 /* Types */
122 
127 #ifndef WIN32
128 typedef int sock_t;
129 
136 #define INVALID_SOCKET -1
137 
143 #define SOCKET_ERROR -1
144 #else /* WIN32 */
145 
146 typedef SOCKET sock_t;
147 #include <inttypes.h>
148 #endif /* WIN32 */
149 
153 typedef struct _ds_peer_set ds_set_t;
154 
155 typedef uint64_t ds_bitfield_t;
156 
157 typedef struct _ds_data ds_data_t;
158 
159 typedef struct _ds_field ds_field_t;
160 
164 typedef struct _ds_delay ds_delay_t;
165 
166 
170 typedef struct _config_ctx ds_config_ctx_t;
171 
175 typedef struct _ds_log ds_log_t;
176 
191 typedef void (*recv_update_t)(int peer, ds_data_t *pkt);
192 
209 typedef void (*recv_replay_t)(int peer, ds_data_t *pkt, time_t tm);
210 
229 typedef void (*recv_nodata_t)(int peer, char *subject, unsigned short flags);
230 
253 typedef void (*recv_peer_status_t)(int peer, int status, int val, void *data);
254 
273 typedef void (*recv_request_t)(int peer, int count, char **subjects, unsigned short flags);
274 
293 typedef void (*recv_discard_t)(int peer, int count, char **subjects, unsigned short flags);
294 
314 typedef void (*recv_object_status_t)(int peer, char *subject, int status, unsigned short code, char *msgstr);
315 
325 typedef void (*recv_service_status_t)(char *service, int status);
326 
327 
337 typedef void (*recv_map_t)(int peer, char *from, char *to);
338 
339 
357 typedef struct
358  {
359  char *application_name;
360  char *application_root;
361  char *log_root;
362  unsigned short flags;
363  unsigned short type;
364  recv_request_t recv_request;
365  recv_discard_t recv_discard;
366  recv_update_t recv_update;
367  recv_nodata_t recv_nodata;
368  recv_peer_status_t recv_peer_status;
372  recv_object_status_t recv_object_status;
377  recv_service_status_t recv_service_status;
378  recv_map_t recv_map;
379  void (*exit_func)(int exit_code, char *msg);
381  char *logfile;
382  ds_log_t *log;
383  }
384 ds_init_t;
385 
390 #define DS_INITIALISER \
391  { \
392  NULL, /* application_name */ \
393  NULL, /* application_root */ \
394  NULL, /* log_root */ \
395  0, /* flags */ \
396  0, /* type */ \
397  NULL, /* recv_request */ \
398  NULL, /* recv_discard */ \
399  NULL, /* recv_update */ \
400  NULL, /* recv_nodata */ \
401  NULL, /* recv_peer_status */ \
402  NULL, /* recv_object_status */ \
403  NULL, /* recv_service_status */ \
404  NULL, /* recv_map */ \
405  NULL, /* exit_func */ \
406  NULL, /* logfile */ \
407  NULL, /* log */ \
408  }
409 
410 
411 /* datasrc */
412 
413 DATASRCAPI void ds_reserve_std_fds(void);
414 DATASRCAPI void ds_config_init(const char *file, int argc, char **argv);
415 DATASRCAPI int ds_init(ds_init_t *init, int argc, char **argv);
416 DATASRCAPI void ds_thread_init(int event_module, int flags);
417 DATASRCAPI char *ds_filename_expand(const char *format, char *buffer, size_t bufsize);
418 DATASRCAPI ds_log_t *ds_get_event_log(void);
419 
420 
421 /* ds5 */
422 
423 
427 typedef struct _ds5_namespace_s ds5_namespace_t;
428 
432 struct _ds5_namespace_s
433  {
439  void (*free)(ds5_namespace_t *nspace);
440 
449  int (*match)(ds5_namespace_t *nspace, const char *subject);
450 
451 
460  char *(*describe)(ds5_namespace_t *nspace, char *buf, size_t buflen);
461 
462  };
463 
464 
465 DATASRCAPI ds5_namespace_t *ds5_create_prefix_namespace(const char *prefix);
466 
467 DATASRCAPI ds5_namespace_t *ds5_create_globbed_namespace(const char *globbed);
468 DATASRCAPI ds5_namespace_t *ds5_create_regex_namespace(const char *expr);
469 DATASRCAPI int ds5_regex_namespace_add_expr(ds5_namespace_t *nspace, const char *expr, int exclude);
470 
471 
472 /* Macros for convenience */
473 
481 #define ds5_namespace_match(nspace, subject) nspace->match(nspace, subject)
482 
487 #define ds5_namespace_free(nspace) nspace->free(nspace)
488 
489 
490 
491 
492 
501 typedef struct _ds5_publisher_s ds5_publisher_t;
502 
503 
504 
505 
506 
507 
508 
519 typedef struct
520  {
539  void (*receive_request)(void *context, int peer, const char *subject);
540 
561  void (*receive_discard)(void *context, int peer, const char *subject);
562  }
563 ds5_dataprovider_t;
564 
565 
566 DATASRCAPI ds5_publisher_t *ds5_create_active_publisher(ds5_namespace_t *nspace, ds5_dataprovider_t *provider, void *context);
567 DATASRCAPI ds5_publisher_t *ds5_create_compatibility_publisher(ds5_namespace_t *nspace, ds5_dataprovider_t *provider, void *context);
568 DATASRCAPI ds5_publisher_t *ds5_create_broadcast_publisher(ds5_namespace_t *nspace);
569 
570 DATASRCAPI void ds5_publish_to_subscribed_peers_no_free(ds5_publisher_t *pub, ds_data_t *dsdata);
571 DATASRCAPI void ds5_publish_to_subscribed_peers(ds5_publisher_t *pub, ds_data_t *dsdata);
572 DATASRCAPI void ds5_publish_response(ds5_publisher_t *pub, ds_data_t *dsdata);
573 DATASRCAPI void ds5_publish_response_no_free(ds5_publisher_t *pub, ds_data_t *dsdata);
574 DATASRCAPI void ds5_publish_status(ds5_publisher_t *pub, const char *subject, int status, const char *message);
575 DATASRCAPI void ds5_publish_status_all(ds5_publisher_t *pub, int status, const char *message);
576 DATASRCAPI void ds5_publish_subject_error(ds5_publisher_t *publisher, const char *subject, int flags);
577 DATASRCAPI void ds5_publish_to_peer(ds5_publisher_t *publisher, int peernum, ds_data_t *dsdata);
578 DATASRCAPI void ds5_publish_to_peer_no_free(ds5_publisher_t *publisher, int peernum, ds_data_t *dsdata);
579 DATASRCAPI void ds5_publish_subject_map(ds5_publisher_t *publisher, const char *subject, const char *mapped_to, int flags);
580 
581 
595 typedef struct
596  {
607  void (*service_status)(void *context, const char *service_name, int state);
608 
620  void (*peer_status)(void *context, int peer_index, const char *peer_name, int state);
621  }
622 ds5_connectionlistener_t;
623 
624 
634 typedef struct _ds5_subscription_s ds5_subscription_t;
635 
636 
649 typedef struct
650  {
660  void (*record_updated)(void *context, ds5_subscription_t *sub, int peer, ds_data_t *dsdata);
661 
671  void (*record_type2_updated)(void *context, ds5_subscription_t *sub, int peer, ds_data_t *dsdata);
672 
682  void (*record_type3_updated)(void *context, ds5_subscription_t *sub, int peer, ds_data_t *dsdata);
683 
693  void (*container_updated)(void *context, ds5_subscription_t *sub, int peer, ds_data_t *dsdata);
694 
704  void (*permission_updated)(void *context, ds5_subscription_t *sub, int peer, ds_data_t *dsdata);
705 
715  void (*news_updated)(void *context, ds5_subscription_t *sub, int peer, ds_data_t *dsdata);
716 
726  void (*news_story_updated)(void *context, ds5_subscription_t *sub, int peer, ds_data_t *dsdata);
727 
737  void (*page_updated)(void *context, ds5_subscription_t *sub, int peer, ds_data_t *dsdata);
738 
751  void (*unknown_subject_type_updated)(void *context, ds5_subscription_t *sub, int peer, ds_data_t *dsdata);
752 
753 
764  void (*subscription_error)(void *context, ds5_subscription_t *sub, int peer, const char *subject, short flags);
765 
777  void (*subscription_status)(void *context, ds5_subscription_t *sub, int peer, const char *subject, int status, const char *message);
778  }
779 ds5_subscriptionlistener_t;
780 
781 
782 
783 
784 
785 DATASRCAPI void ds5_config_init(const char *configfile, int argc, char **argv);
786 DATASRCAPI int ds5_init(int argc, char **argv);
787 DATASRCAPI void ds5_add_connectionlistener(ds5_connectionlistener_t *connection_listener, void *context);
788 
789 
790 
791 
792 DATASRCAPI ds5_subscription_t *ds5_create_broadcast_subscription(ds5_namespace_t *nspace, ds5_subscriptionlistener_t *listener, void *context);
793 DATASRCAPI ds5_subscription_t *ds5_create_active_subscription(const char *subject, ds5_subscriptionlistener_t *listener, void *context);
794 DATASRCAPI void ds5_unsubscribe(ds5_subscription_t *sub);
795 
796 
797 
798 /* config */
799 
800 
809 #define DS_OFFSET(t,m) ((void *)&((t *)0)->m)
810 
814 #define DS_CONFIG_BOOL 0x0001
815 
820 #define DS_CONFIG_INT 0x0002
821 
825 #define DS_CONFIG_FLOAT 0x0003
826 
830 #define DS_CONFIG_STR 0x0004
831 
835 #define DS_CONFIG_CHAR 0x0005
836 
840 #define DS_CONFIG_FUNC 0x0006
841 
845 #define DS_CONFIG_FILE 0x0007
846 
849 #define DS_CONFIG_GROUP 0x0010
850 #define DS_CONFIG_GROUP_END 0x0011
851 #define DS_CONFIG_SECTION 0x0020
852 #define DS_CONFIG_SECTION_END 0x0021
853 
857 #define DS_CONFIG_JAVA 0x0080
858 
862 #define DS_CONFIG_ARRAY 0x0100
863 
868 #define DS_CONFIG_INT_ARRAY (DS_CONFIG_ARRAY|DS_CONFIG_INT)
869 
873 #define DS_CONFIG_FLOAT_ARRAY (DS_CONFIG_ARRAY|DS_CONFIG_FLOAT)
874 
875 
879 #define DS_CONFIG_STR_ARRAY (DS_CONFIG_ARRAY|DS_CONFIG_STR)
880 
884 #define DS_CONFIG_CHAR_ARRAY (DS_CONFIG_ARRAY|DS_CONFIG_CHAR)
885 
889 #define DS_CONFIG_STRICT 0x0200
890 
895 #define DS_CONFIG_DEPRECATED 0x0400
896 
897 
919 typedef struct
920  {
921  char *name;
922  double value;
923  char *docstring;
924  }
925 ds_config_enum_t;
926 
927 
940 typedef void (*ds_config_func)(char *name, int num, char **values);
941 
942 
943 DATASRCAPI ds_config_ctx_t *ds_config_new_ctx(void);
944 DATASRCAPI void ds_config_free_ctx(ds_config_ctx_t *ctx);
945 DATASRCAPI ds_config_ctx_t *ds_config_set_ctx(ds_config_ctx_t *ctx);
946 DATASRCAPI void ds_config_add_search(const char *path);
947 DATASRCAPI void ds_config_add_file(const char *file);
948 DATASRCAPI void ds_config_add_optional_file(const char *file);
949 DATASRCAPI void ds_config_add_option(char opt, const char *longopt, const char *help, int type, void *value);
950 DATASRCAPI void ds_config_add_bounded_option(char sopt,const char *longopt, const char *help, int type, void *value, void *min, void *max);
951 DATASRCAPI void ds_config_add_option_enum(char opt,const char *longopt, const char *help, int type, void *value, ds_config_enum_t *enums);
952 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);
953 DATASRCAPI void ds_config_add_array_option(const char *longopt, const char *help, int type, void *value, int *num);
954 DATASRCAPI void ds_config_add_bounded_array_option(const char *longopt,const char *help, int type, void *value, int *num, void *min, void *max);
955 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);
956 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);
957 DATASRCAPI void ds_config_del_option(const char *longopt);
958 DATASRCAPI void ds_config_add_group(const char *longopt, const char *help, void *base, void *def, size_t size, int *num);
959 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);
960 DATASRCAPI void ds_config_end_group(const char *longopt,const char *help);
961 DATASRCAPI void ds_config_add_section(const char *longopt,const char *help);
962 DATASRCAPI void ds_config_end_section(const char *longopt,const char *help);
963 DATASRCAPI void ds_config_parse_files(void);
964 DATASRCAPI void ds_config_parse_args(int argc, char **argv, int *retargc);
965 DATASRCAPI int ds_config_parse_file(const char *unresolved_filename);
966 DATASRCAPI void ds_config_list_options(void);
967 DATASRCAPI void ds_config_list_values(void);
968 DATASRCAPI int ds_config_get_enum(const char *value, ds_config_enum_t *enums);
969 DATASRCAPI void ds_config_add_error_message_fmt(const char *fmt,...) PRINTF(1,2);
970 DATASRCAPI void ds_config_add_config_reading_message_fmt(const char *fmt,...) PRINTF(1,2);
971 DATASRCAPI void ds_config_add_error_message(const char *msg);
972 DATASRCAPI char *ds_config_get_filename(void);
973 DATASRCAPI int ds_config_get_linenumber(void);
974 DATASRCAPI void ds_config_set_test(const char *tag, char **value);
975 DATASRCAPI void ds_config_del_test(const char *tag);
976 DATASRCAPI void ds_config_set_option(const char *name, const char *value);
977 
978 
979 /* event */
980 
981 
982 typedef unsigned long ds_reltime_t;
983 
988 typedef struct _ds_timed_event ds_timed_event_t;
989 
990 
995 typedef struct _ds_io_event ds_except_event_t;
996 
997 
998 
1003 typedef struct _ds_io_event ds_read_event_t;
1004 
1005 
1010 typedef struct _ds_io_event ds_write_event_t;
1011 
1012 
1017 typedef struct _ds_io_event ds_generic_event_t;
1018 
1019 
1030 typedef int (*ds_io_event_cb)(sock_t sock, int val, void *data);
1031 
1042 typedef int (*ds_timed_event_cb)(int id, int val, void *data);
1043 
1044 
1045 #define DOUBLE_TO_RELTIME(r,d) r = ((int)(d) << 9) + ((int)(((d) - (int)(d)) * 1000000) >> 11);
1046 #define TIMEVAL_TO_RELTIME(r,tv) r = ((tv).tv_sec << 9) + ((tv).tv_usec >> 11);
1047 
1048 
1049 DATASRCAPI ds_timed_event_t *ds_add_timed_event(int id, double delay, ds_timed_event_cb cb, int val, void *data);
1050 DATASRCAPI ds_read_event_t *ds_add_read_event(sock_t fd, ds_io_event_cb cb, int val, void *data);
1051 DATASRCAPI ds_write_event_t *ds_add_write_event(sock_t fd, ds_io_event_cb cb, int val, void *data);
1052 DATASRCAPI ds_except_event_t *ds_add_except_event(sock_t fd, ds_io_event_cb cb, int val, void *data);
1053 
1054 DATASRCAPI int ds_del_timed_event(ds_timed_event_t *ev);
1055 DATASRCAPI int ds_del_read_event(ds_read_event_t *ev);
1056 DATASRCAPI int ds_del_write_event(ds_write_event_t *ev);
1057 DATASRCAPI int ds_del_except_event(ds_except_event_t *ev);
1058 
1059 DATASRCAPI int ds_del_timed_event_free_data(ds_timed_event_t *ev, void (*free_data)(int, void *));
1060 DATASRCAPI int ds_del_read_event_free_data(ds_read_event_t *ev, void (*free_data)(int, void *));
1061 DATASRCAPI int ds_del_write_event_free_data(ds_write_event_t *ev, void (*free_data)(int, void *));
1062 DATASRCAPI int ds_del_except_event_free_data(ds_except_event_t *ev, void (*free_data)(int, void *));
1063 
1064 DATASRCAPI void ds_timed_event_set_callback(ds_timed_event_t *ev, ds_timed_event_cb cb, int val, void *data);
1065 DATASRCAPI double ds_timed_event_get_fire_time(ds_timed_event_t *ev);
1066 DATASRCAPI void ds_read_event_set_callback(ds_read_event_t *ev, ds_io_event_cb cb, int val, void *data);
1067 DATASRCAPI void ds_write_event_set_callback(ds_write_event_t *ev, ds_io_event_cb cb, int val, void *data);
1068 
1069 DATASRCAPI void ds_set_timed_delay(ds_timed_event_t *ev, double delay);
1070 DATASRCAPI void ds_set_timed_delay_next(ds_timed_event_t *ev, double delay);
1071 
1072 DATASRCAPI void ds_loop(void);
1073 DATASRCAPI void ds_stop(void);
1074 
1075 DATASRCAPI ds_reltime_t ds_get_relative_time(void);
1076 DATASRCAPI time_t ds_get_time(void);
1077 DATASRCAPI struct tm *ds_gmtime(void);
1078 DATASRCAPI struct tm *ds_localtime(void);
1079 DATASRCAPI int ds_get_gmt_offset(time_t t);
1080 DATASRCAPI char *ds_get_timezone(char *buf, int len);
1081 
1082 DATASRCAPI ds_timed_event_t *ds_add_periodic_event(int starttime, int period, int id, ds_timed_event_cb cb, int val, void *data);
1083 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);
1084 DATASRCAPI int ds_check_periodic_event(int period, ds_timed_event_t **tev);
1085 
1086 
1087 /* cache */
1088 
1093 #define DS_CACHE_DATASRC -1
1094 
1095 DATASRCAPI void ds_cache_add_object(char *subject);
1096 
1097 
1098 /* daemon */
1099 
1100 
1101 DATASRCAPI void ds_daemon_redirect(void);
1102 DATASRCAPI int ds_daemon_disabled(void);
1103 
1104 
1105 /* fields */
1106 
1107 
1115 #define DS_FIELDS_SEPARATOR -65536
1116 
1122 #define DS_FIELDS_NOT_DEFINED (-2147483647 - 1)
1123 
1124 DATASRCAPI int ds_fields_max(void);
1125 DATASRCAPI int ds_fields_add(int num, const char *name, int flags, int dp, const char *fmt);
1126 DATASRCAPI int ds_fields_numbyname(const char *name);
1127 DATASRCAPI char *ds_fields_namebynum(int num);
1128 DATASRCAPI int ds_fields_indexbyname(const char *name);
1129 DATASRCAPI int ds_fields_indexbynum(int num);
1130 DATASRCAPI int ds_fields_numbyindex(int index);
1131 DATASRCAPI char *ds_fields_namebyindex(int index);
1132 DATASRCAPI char *ds_fields_rttpnumbyindex(int index);
1133 DATASRCAPI int ds_fields_getflags(int index);
1134 DATASRCAPI int ds_fields_getdp(int index);
1135 
1136 
1137 
1138 /* log */
1139 
1143 #define DS_LOG_CONFIG 0
1144 #define DS_LOG_ALWAYS 1
1145 
1148 #define DS_LOG_CRIT 2
1149 
1152 #define DS_LOG_ERROR 3
1153 
1156 #define DS_LOG_NOTIFY 4
1157 
1160 #define DS_LOG_WARN 5
1161 
1164 #define DS_LOG_INFO 6
1165 
1168 #define DS_LOG_DEBUG 7
1169 
1172 #define DS_LOG_FINER 8
1173 
1176 #define DS_LOG_FINEST 9
1177 
1180 #define DS_LOG_MONITOR 128
1181 
1184 #define DS_LOG_TERMINAL 256
1185 
1188 #define DS_LOG_SYSLOG 512
1189 #define DS_LOG_FILEONLY 1024
1190 #define DS_LOG_NO_MONITOR 2048
1191 
1199 typedef void (*ds_loglevelchange_t)(ds_log_t *log, int new_level);
1200 
1207 typedef void (*ds_logcycled_t)(ds_log_t *log);
1208 
1209 
1210 
1211 
1212 DATASRCAPI ds_log_t *ds_new_log(const char *name,const char *logname);
1213 DATASRCAPI ds_log_t *ds_new_level_log(const char *name, const char *logname, ds_loglevelchange_t change_cb);
1214 DATASRCAPI ds_log_t *ds_new_headed_log(const char *name, const char *logname, const char *header);
1215 DATASRCAPI void ds_free_log(ds_log_t *log);
1216 DATASRCAPI void ds_write(ds_log_t *log, void *data, size_t len);
1217 #ifndef WIN32
1218 DATASRCAPI void ds_writev(ds_log_t *log, struct iovec *vector, int count);
1219 #endif
1220 DATASRCAPI void ds_printf(ds_log_t *log, const char *fmt, ...) PRINTF(2,3);
1221 DATASRCAPI void ds_printf_time(ds_log_t *log, const char *fmt, ...) PRINTF(2,3);
1222 DATASRCAPI void ds_printf_time_ap(ds_log_t *log, const char *extra, const char *fmt, va_list ap);
1223 DATASRCAPI void ds_syslog(ds_log_t *log, int priority, const char *fmt, ...) PRINTF(3,4);
1224 DATASRCAPI void ds_cycle_all_logs(const char *suffix, long maxsize);
1225 DATASRCAPI int ds_cycle_log(ds_log_t *log, const char *suffix, long maxsize);
1226 DATASRCAPI int ds_debug_level(const char *text);
1227 DATASRCAPI char *ds_debug_string(int level);
1228 DATASRCAPI char *ds_debug_config_string(int level);
1229 DATASRCAPI void ds_log(ds_log_t *log, int level, const char *fmt,...) PRINTF(3,4);
1230 DATASRCAPI int ds_log_set_log_level(ds_log_t *log, const char *level);
1231 DATASRCAPI void ds_log_change_level_callback(ds_log_t *log, ds_loglevelchange_t change_cb);
1232 DATASRCAPI ds_logcycled_t ds_log_cycled_callback(ds_log_t *log, ds_logcycled_t cycle_cb);
1233 DATASRCAPI char *ds_log_getfilename(ds_log_t *log);
1234 DATASRCAPI char *ds_log_getname(ds_log_t *log);
1235 DATASRCAPI int ds_log_get_level(ds_log_t *log);
1236 DATASRCAPI int ds_log_flush(ds_log_t *log);
1237 
1238 
1239 /* lty_chain */
1240 
1241 
1251 DATASRCAPI void ds_add_latency_chain(ds_data_t *dsdata, char suffix, struct timespec *tp);
1252 
1264 DATASRCAPI void ds_add_latency_chain2(ds_data_t *dsdata, char suffix, struct timespec tp, char suffix2, struct timespec *tp2);
1265 
1270 DATASRCAPI void ds_add_latency_initial_timestamp(ds_data_t *dsdata);
1271 
1272 /* monitor */
1273 
1274 
1278 #define TYPE_NONE 0
1279 
1283 #define TYPE_BINARY 1
1284 
1287 #define TYPE_STRING 2
1288 
1291 #define TYPE_SHORT 3
1292 
1295 #define TYPE_USHORT 4
1296 
1299 #define TYPE_LONG 5
1300 
1303 #define TYPE_ULONG 6
1304 
1307 #define TYPE_LLONG 7
1308 
1311 #define TYPE_ULLONG 8
1312 
1315 #define TYPE_DOUBLE 9
1316 
1321 #define TYPE_TIMESTAMP 10
1322 
1327 #define TYPE_BOOLEAN 11
1328 
1332 #define TYPE_RELATION 20
1333 
1337 #define TYPE_SUBSCRIPTION 21
1338 
1339 
1343 #define TYPE_PRIMITIVE_MASK 31
1344 
1348 #define TYPE_ARRAY 32
1349 
1352 #define TYPE_ACTIVE 64
1353 
1363 #define TYPE_ACTIVE2 128
1364 
1367 #define TYPE_METHOD 256
1368 
1371 #define TYPE_KEY 512
1372 
1375 #define TYPE_HIERARCHY 1024
1376 
1382 #define TYPE_OPTIONAL 2048
1383 
1384 
1390 typedef struct {
1391  size_t size;
1392  union _ds_mondata_value {
1393  void *b;
1394  char **c;
1395  int16_t *s;
1396  uint16_t *us;
1397  int32_t *l;
1398  uint32_t *ul;
1399  int64_t *ll;
1400  uint64_t *ull;
1401  double *d;
1402  } data;
1403  }
1404 ds_array_t;
1405 
1411 typedef struct
1412  {
1413  char *propertyname;
1414  int datatype;
1415  union _ds_mondata_value2
1416  {
1417  void *active_ptr; /* Do not set used by monitoring API */
1418  char *c;
1419  int16_t s;
1420  uint16_t us; /* Also used for TYPE_BOOLEAN */
1421  int32_t l;
1422  uint32_t ul; /* Also used for TYPE_TIMESTAMP */
1423  int64_t ll;
1424  uint64_t ull;
1425  double d;
1426  ds_array_t array;
1427  }
1428  data;
1429  }
1430 ds_monitor_t;
1431 
1432 
1436 typedef struct
1437  {
1438  int typeflags;
1439  char *name;
1440  char *description;
1441  char *docstring;
1442  }
1443 ds_arguments_t;
1444 
1445 
1460 typedef ds_monitor_t *(*ds_monitor_method_cb)(char *templatename, char *key, char *property, int argc, char *argv[]);
1461 
1471 typedef ds_monitor_t *(*ds_monitor_active_cb)(char *templatename, char *key, char *propertyname);
1472 
1473 
1474 
1479 typedef struct
1480  {
1481  char *username;
1482  char *password;
1483  char *ipaddress;
1484  }
1485 ds_monauth_t;
1486 
1496 typedef int (*ds_monitor_authenticator_t)(ds_monauth_t *credentials);
1497 
1498 
1499 
1500 DATASRCAPI char *ds_monitor_module_name(void);
1501 
1502 
1503 DATASRCAPI void ds_monitor_add_server_type(const char *type, const char *root);
1504 DATASRCAPI void ds_monitor_start_template(const char *templatename, const char *description);
1505 DATASRCAPI void ds_monitor_add_template_member(const char *templatename, const char *propertyname, const char *description, int typeflags, ds_arguments_t *args, void *ptr);
1506 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);
1507 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);
1508 
1509 
1510 DATASRCAPI void ds_monitor_add_relation(const char *templatename, const char *key, const char *propertyname, const char *targetkey);
1511 DATASRCAPI void ds_monitor_del_relation(const char *templatename, const char *key, const char *propertyname, const char *targetkey);
1512 
1513 DATASRCAPI void ds_monitor_add_subscription(const char *templatename, const char *key, const char *propertyname, const char *value);
1514 DATASRCAPI void ds_monitor_del_subscription(const char *templatename, const char *key, const char *propertyname, const char *value);
1515 
1516 DATASRCAPI void ds_monitor_end_template(const char *templatename);
1517 
1518 DATASRCAPI void ds_monitor_create_group(const char *templatename, const char *key, const char *brief, const char *description);
1519 DATASRCAPI void ds_monitor_delete_group(const char *templatename, const char *key);
1520 
1521 
1522 
1523 DATASRCAPI void ds_monitor_update(const char *templatename, const char *key, ds_monitor_t *mondata);
1524 DATASRCAPI void ds_monitor_update_string(const char *templatename, const char *key, const char *propertyname, const char *value);
1525 DATASRCAPI void ds_monitor_update_ushort(const char *templatename, const char *key, const char *propertyname, uint16_t);
1526 DATASRCAPI void ds_monitor_update_short(const char *templatename, const char *key, const char *propertyname, int16_t value);
1527 DATASRCAPI void ds_monitor_update_ulong(const char *templatename, const char *key, const char *propertyname, uint32_t value);
1528 DATASRCAPI void ds_monitor_update_long(const char *templatename,const char *key, const char *propertyname, int32_t value);
1529 DATASRCAPI void ds_monitor_update_ullong(const char *templatename, const char *key, const char *propertyname, uint64_t value);
1530 DATASRCAPI void ds_monitor_update_llong(const char *templatename, const char *key, const char *propertyname, int64_t value);
1531 DATASRCAPI void ds_monitor_update_double(const char *templatename, const char *key, const char *propertyname, double value);
1532 DATASRCAPI void ds_monitor_update_timestamp(const char *templatename, const char *key, const char *propertyname, int64_t value);
1533 DATASRCAPI void ds_monitor_update_boolean(const char *templatename, const char *key, const char *propertyname, uint8_t value);
1534 
1535 
1536 
1537 DATASRCAPI ds_monitor_t *ds_monitor_new(const char *propertyname, int type, int datasize, const void *datum);
1538 DATASRCAPI ds_monitor_t *ds_monitor_new_array(const char *propertyname, int type);
1539 DATASRCAPI void ds_monitor_add_data(ds_monitor_t *data, const void *datum);
1540 DATASRCAPI void ds_monitor_free(ds_monitor_t *data); /* Needed by plugin */
1541 
1542 DATASRCAPI void ds_monitor_free_data(ds_monitor_t *data);
1543 
1544 
1545 DATASRCAPI ds_monitor_t *ds_monitor_new_string(const char *templatename, const char *key, const char *propertyname, const char *value);
1546 DATASRCAPI ds_monitor_t *ds_monitor_new_ushort(const char *templatename, const char *key, const char *propertyname, uint16_t value);
1547 DATASRCAPI ds_monitor_t *ds_monitor_new_short(const char *templatename, const char *key, const char *propertyname, int16_t value);
1548 DATASRCAPI ds_monitor_t *ds_monitor_new_ulong(const char *templatename, const char *key, const char *propertyname, uint32_t value);
1549 DATASRCAPI ds_monitor_t *ds_monitor_new_long(const char *templatename,const char *key, const char *propertyname, int32_t value);
1550 DATASRCAPI ds_monitor_t *ds_monitor_new_ullong(const char *templatename, const char *key, const char *propertyname, uint64_t value);
1551 DATASRCAPI ds_monitor_t *ds_monitor_new_llong(const char *templatename, const char *key, const char *propertyname, int64_t value);
1552 DATASRCAPI ds_monitor_t *ds_monitor_new_double(const char *templatename, const char *key, const char *propertyname, double value);
1553 DATASRCAPI ds_monitor_t *ds_monitor_new_timestamp(const char *templatename, const char *key, const char *propertyname, int64_t value);
1554 DATASRCAPI ds_monitor_t *ds_monitor_new_boolean(const char *templatename, const char *key, const char *propertyname, uint8_t value);
1555 
1556 
1557 DATASRCAPI ds_monitor_authenticator_t ds_monitor_set_auth(ds_monitor_authenticator_t authenticator);
1558 
1559 
1560 /* net */
1561 
1562 
1563 DATASRCAPI sock_t ds_listen_socket(const char *addr, int port, int backlog);
1564 DATASRCAPI sock_t ds_accept_socket(sock_t fd);
1565 DATASRCAPI sock_t ds_multicast_listen_socket(const char *p_interface, const char *addr, int port);
1566 DATASRCAPI sock_t ds_udp_listen_socket(const char *p_interface, int port);
1567 DATASRCAPI sock_t ds_client_socket(const char *serv, unsigned short port);
1568 DATASRCAPI sock_t ds_client_socket_nonblocking(const char *serv, unsigned short port);
1569 DATASRCAPI int ds_udp_send(const char *data, int len, const char *addr, int port);
1570 DATASRCAPI int ds_udp_sendto(const char *data, int len, struct sockaddr_storage *serv_addr);
1571 DATASRCAPI sock_t ds_udp_client_socket(const char *addr, int port, struct sockaddr_storage *serv_addr);
1572 DATASRCAPI int ds_udp_bind_client_socket(sock_t sock, const char *addr, int port);
1573 DATASRCAPI char *ds_interface_address(const char *ifname);
1574 DATASRCAPI void ds_setnonblocking(sock_t fd);
1575 DATASRCAPI char *ds_getnameinfo(const struct sockaddr_storage *addr, char *buf, size_t buflen);
1576 DATASRCAPI int ds_compare_sockaddr(struct sockaddr_storage *sa, struct sockaddr_storage *sb);
1577 DATASRCAPI int ds_pipe(sock_t fds[2]);
1578 DATASRCAPI int ds_check_subnet(const char *s_address, const char *s_network, const char *s_netmask);
1579 DATASRCAPI struct sockaddr_storage *ds_gethostsockaddr(const char *name, struct sockaddr_storage *populate);
1580 DATASRCAPI struct addrinfo *ds_gethostsockaddrs(const char *name);
1581 
1582 
1583 
1584 /* Message Types */
1585 
1593 #define DS_MSG_CONNECT 0x0100
1594 
1602 #define DS_MSG_DISCONNECT 0x0200
1603 #define DS_MSG_STATUS 0x0400
1604 
1605 
1606 /* Peer Types */
1607 
1608 #define DS_T_USERMASK 0x00ff
1609 
1619 #define DS_T_ACTIVE 0x0001
1620 
1631 #define DS_T_CONTRIB 0x0002
1632 
1633 #define DS_T_MSG 0x0100
1634 
1635 
1636 /* Peer Flags */
1637 
1638 #define DS_F_USERMASK 0x00ff
1639 
1655 #define F_SENDFROMSEQ 0x0001
1656 
1657 #define F_SENDFROMFIELD 0x0002
1658 
1659 
1673 #define F_RECVAUTOREPLAY 0x0004
1674 
1675 
1690 #define F_NOCONNECT 0x0008
1691 
1692 #define F_RECONNECT 0x0100
1693 #define F_FAILOVER 0x0200
1694 
1695 
1696 /* No Data Flags */
1697 
1698 #define F_NODATAMASK 0x000f
1699 
1709 #define F_NOTFOUND 0x0001
1710 
1719 #define F_READDENY 0x0002
1720 
1729 #define F_WRITEDENY 0x0003
1730 
1739 #define F_DELETEOBJECT 0x0004
1740 
1749 #define F_UNAVAILABLE 0x0005
1750 #define F_STATUS 0x0006
1751 
1752 
1753 
1759 #define F_IGNOREREQTIMEOUT 0x0008
1760 
1761 /* Object Types */
1762 
1766 #define DS_PAGE_TYPE 221
1767 
1770 #define DS_RECORD_TYPE 222
1771 
1774 #define DS_RECORD_TYPE2 225
1775 
1778 #define DS_RECORD_TYPE3 226
1779 
1782 #define DS_NEWS_TYPE 223
1783 
1786 #define DS_STORY_TYPE 224
1787 
1790 #define DS_CONTAINER_TYPE 228
1791 
1794 #define DS_PERMISSION_TYPE 230
1795 
1802 #define DS_GENERIC_TYPE 231
1803 
1807 #define DS_JSON_TYPE 232
1808 
1809 
1810 /* Data Flags */
1811 
1815 #define F_CREATEOBJECT 0x0010
1816 
1819 #define F_CREATEPARENT 0x0020
1820 #define F_PERSISTENT 0x0040
1821 #define F_CREATEDATA 0x0080
1822 
1826 #define F_CLEAR_PERM 0x0400
1827 
1838 #define F_FILTER_PERM 0x0800
1839 
1844 #define F_AUTHGLOBAL 0x0100
1845 
1849 #define F_CLEAR_TYPE3 0x0100
1850 
1854 #define F_FILTER_TYPE3 0x0200
1855 
1858 #define F_CLEAR_TYPE2 0x0400
1859 
1873 #define F_FILTER_TYPE2 0x0800
1874 
1880 #ifdef __DARWIN_NULL
1881 #undef F_NOCACHE
1882 #endif
1883 #define F_NOCACHE 0x0400
1884 
1891 #define F_DELETE_HEADLINE 0x0100
1892 
1900 #define F_CHANGE_HEADLINE 0x0200
1901 
1906 #define F_IMAGE 0x1000
1907 
1911 #define F_NONACTIVE 0x2000
1912 
1915 #define F_AUTHUPDATE 0x4000
1916 
1917 
1925 #define F_CONSTITUENT_NOAUTH 0x4000
1926 
1933 #define F_CHANGEDFIELDS 0x8000
1934 
1935 /* Field Data Types */
1936 
1937 #define FLOAT32_TYPE 1
1938 #define FLOAT64_TYPE 2
1939 #define INT8_TYPE 3
1940 #define INT16_TYPE 4
1941 #define INT32_TYPE 5
1942 #define INT64_TYPE 6
1943 #define UINT8_TYPE 7
1944 #define UINT16_TYPE 8
1945 #define UINT32_TYPE 9
1946 #define UINT64_TYPE 10
1947 
1948 
1949 /* Object request flags */
1950 
1960 #define DS_REQUEST_FAILOVER 1
1961 
1970 #define DS_REQUEST_CACHE 4
1971 
1972 
1973 
1974 /* Object Status Flags */
1975 
1985 #define S_INFO 0x0000
1986 
1995 #define S_STALE 0x0001
1996 
2005 #define S_NOTSTALE 0x0004
2006 
2018 #define S_UPDCLR 0x0100
2019 
2030 #define S_FAILOVER 0x1101 /* Failover implies S_STALE|S_UPDCLR */
2031 
2032 
2045 #define OBJ_STATUS_INFO 0x0000
2046 
2059 #define OBJ_STATUS_OK 0x0001
2060 
2075 #define OBJ_STATUS_STALE 0x0002
2076 
2077 
2093 #define OBJ_STATUS_LIMITED 0x0008
2094 
2095 
2096 #define OBJ_STATUS_NOTMAPPED 0x0010
2097 
2106 #define SVC_STATUS_OK 0x0001
2107 
2116 #define SVC_STATUS_DOWN 0x0002
2117 
2126 #define SVC_STATUS_LIMITED 0x0008
2127 
2128 
2129 /* Field Macros */
2130 #define DS_MAX_BITFIELD (sizeof(ds_bitfield_t)*8)
2131 
2132 #define DS_BITFIELD_SET(n,p) *(p) |= (1ULL << (n))
2133 #define DS_BITFIELD_CLR(n,p) *(p) &= ~(1ULL << (n))
2134 #define DS_BITFIELD_ISSET(n,p) (*(p) & (1ULL << (n)))
2135 #define DS_BITFIELD_ZERO(p) *(p) = 0
2136 #define DS_BITFIELD_NONZERO(p) memset((char *)(p), 0xffffffff, sizeof(*(p)))
2137 
2138 /* Peer set functions and macros */
2139 
2140 DATASRCAPI int ds_iszero(ds_set_t *p);
2141 DATASRCAPI void ds_or(ds_set_t *p1, ds_set_t *p2, ds_set_t *o);
2142 DATASRCAPI void ds_and(ds_set_t *p1, ds_set_t *p2, ds_set_t *a);
2143 DATASRCAPI int ds_and_iszero(ds_set_t *p1, ds_set_t *p2);
2144 DATASRCAPI int ds_and3_iszero(ds_set_t *p1, ds_set_t *p2, ds_set_t *p3);
2145 DATASRCAPI int ds_isequal(ds_set_t *p1, ds_set_t *p2);
2146 
2151 #define DS_MAX_PEERS 1024
2152 
2157 #define DS_MIN_PEER 0
2158 
2163 #define DS_INTERNAL_DATASRC 1023
2164 
2165 typedef uint32_t dsset_element_t;
2166 
2167 #define DS_NUMBITS (sizeof(dsset_element_t) * 8)
2168 #define DS_NUM_ELEMS (DS_MAX_PEERS+DS_NUMBITS-1)/DS_NUMBITS
2169 #define DS_NUM_BYTES (DS_NUM_ELEMS * sizeof(dsset_element_t))
2170 
2171 struct _ds_peer_set
2172  {
2173  dsset_element_t bits[DS_NUM_ELEMS];
2174  };
2175 
2180 #define DS_SET(n,p) ((p)->bits[(n)/DS_NUMBITS] |= ((unsigned)1 << ((n) % DS_NUMBITS)))
2181 
2186 #define DS_CLR(n,p) ((p)->bits[(n)/DS_NUMBITS] &= ~((unsigned)1 << ((n) % DS_NUMBITS)))
2187 
2192 #define DS_ISSET(n,p) ((p)->bits[(n)/DS_NUMBITS] & ((unsigned)1 << ((n) % DS_NUMBITS)))
2193 
2198 #define DS_ZERO(p) memset((char *)(p)->bits, 0, DS_NUM_BYTES)
2199 
2204 #define DS_NONZERO(p) memset((char *)(p)->bits, 0xff, DS_NUM_BYTES)
2205 
2210 #define DS_ISZERO(p) ds_iszero(p)
2211 
2216 #define DS_AND(p1, p2, a) ds_and(p1, p2, a)
2217 
2222 #define DS_OR(p1, p2, o) ds_or(p1, p2, o)
2223 
2228 #define DS_AND_ISZERO(p1, p2) ds_and_iszero(p1, p2)
2229 
2234 #define DS_AND3_ISZERO(p1, p2, p3) ds_and3_iszero(p1, p2, p3)
2235 
2240 #define DS_ISEQUAL(p1, p2) ds_isequal(p1, p2)
2241 
2242 DATASRCAPI ds_data_t *ds_init_data(const char *subject, unsigned short type, unsigned short flags);
2243 DATASRCAPI void ds_set_subject(ds_data_t *data, const char *subject);
2244 
2245 DATASRCAPI void ds_add_data(ds_data_t *data, int32_t fieldnum, const char *value);
2246 DATASRCAPI void ds_add_data_fmt(ds_data_t *data, int32_t fieldnum, const char *fmt, ...);
2247 DATASRCAPI void ds_add_data_str(ds_data_t *data, int32_t fieldnum, const char *value);
2248 DATASRCAPI void ds_add_data_float32(ds_data_t *data, int32_t fieldnum, float value);
2249 DATASRCAPI void ds_add_data_float64(ds_data_t *data, int32_t fieldnum, double value);
2250 DATASRCAPI void ds_add_data_int8(ds_data_t *data, int32_t fieldnum, int8_t value);
2251 DATASRCAPI void ds_add_data_int16(ds_data_t *data, int32_t fieldnum, int16_t value);
2252 DATASRCAPI void ds_add_data_int32(ds_data_t *data, int32_t fieldnum, int32_t value);
2253 DATASRCAPI void ds_add_data_int64(ds_data_t *data, int32_t fieldnum, int64_t value);
2254 DATASRCAPI void ds_add_data_uint8(ds_data_t *data, int32_t fieldnum, uint8_t value);
2255 DATASRCAPI void ds_add_data_uint16(ds_data_t *data, int32_t fieldnum, uint16_t value);
2256 DATASRCAPI void ds_add_data_uint32(ds_data_t *data, int32_t fieldnum, uint32_t value);
2257 DATASRCAPI void ds_add_data_uint64(ds_data_t *data, int32_t fieldnum, uint64_t value);
2258 DATASRCAPI void ds_add_data_char(ds_data_t *data, int32_t fieldnum, char value);
2259 
2260 DATASRCAPI ds_data_t *ds_clone_data(ds_data_t *data);
2261 
2262 #define ds_add_data_short(d,f,v) ds_add_data_int16(d,f,v)
2263 #define ds_add_data_int(d,f,v) ds_add_data_int32(d,f,v)
2264 #define ds_add_data_long(d,f,v) ds_add_data_int32(d,f,v)
2265 #define ds_add_data_float(d,f,v) ds_add_data_float32(d,f,v)
2266 #define ds_add_data_double(d,f,v) ds_add_data_float64(d,f,v)
2267 
2268 DATASRCAPI void ds_send_data(ds_data_t *data);
2269 DATASRCAPI void ds_send_data_to_peer(int peer, ds_data_t *data);
2270 DATASRCAPI void ds_send_data_no_free(ds_data_t *data);
2271 DATASRCAPI void ds_send_data_to_peer_no_free(int peer, ds_data_t *data);
2272 DATASRCAPI void ds_send_nodata(const char *subject, unsigned short flags);
2273 DATASRCAPI void ds_send_nodata_to_peer(int peer, const char *subject, unsigned short flags);
2274 DATASRCAPI void ds_free_data(ds_data_t *data);
2275 DATASRCAPI void ds_send_status(const char *subject, unsigned short flags, unsigned short code, const char *msgstr);
2276 DATASRCAPI void ds_send_status_to_peer(int peer,const char *subject, unsigned short flags, unsigned short code, const char *msgstr);
2277 DATASRCAPI void ds_send_data_direct(ds_data_t *data);
2278 DATASRCAPI void ds_send_nodata_direct(const char *subject, unsigned short flags);
2279 DATASRCAPI void ds_send_status_direct(const char *subject, unsigned short flags, unsigned short code, const char *msgstr);
2280 
2281 DATASRCAPI void ds_send_map_to_peer(int peer, const char *subject, const char *mapped, unsigned short flags);
2282 DATASRCAPI void ds_send_map(const char *subject, const char *mapped, unsigned short flags);
2283 
2284 
2295 typedef void (*ds_delay_send_cb)(void *context, ds_data_t *dsdata);
2296 
2297 DATASRCAPI ds_delay_t *ds_new_delay(double delay_time, char *prefix, double batch_time);
2298 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);
2299 DATASRCAPI void ds_delay_data(ds_delay_t *delay, ds_data_t *dsdata);
2300 
2301 DATASRCAPI int32_t ds_add_record_str(ds_data_t *data, const char *field, const char *value);
2302 DATASRCAPI int32_t ds_add_record_int(ds_data_t *data,const char *field, int value);
2303 DATASRCAPI int32_t ds_add_record_char(ds_data_t *data,const char *field, char value);
2304 DATASRCAPI int32_t ds_add_record_float(ds_data_t *data,const char *field, double value);
2305 DATASRCAPI int32_t ds_add_record_fmt(ds_data_t *data,const char *field, const char *fmt, ...);
2306 
2307 DATASRCAPI ds_data_t *ds_init_page(const char *subject, int rows, int cols, const char *type, unsigned short flags);
2308 DATASRCAPI void ds_add_page_row(ds_data_t *data, int row, int col, const char *str);
2309 DATASRCAPI void ds_add_page_field(ds_data_t *data, int32_t fieldnum, const char *value);
2310 DATASRCAPI void ds_add_page_field_by_name(ds_data_t *data, const char *field, const char *value);
2311 
2312 DATASRCAPI ds_data_t *ds_init_news(const char *subject, unsigned short flags);
2313 DATASRCAPI void ds_add_news_headline(ds_data_t *data, const char *headline);
2314 DATASRCAPI void ds_add_news_storycode(ds_data_t *data, const char *story);
2315 DATASRCAPI void ds_add_news_datetime(ds_data_t *data, const char *datestr);
2316 DATASRCAPI void ds_add_news_authstr(ds_data_t *data, const char *authstr);
2317 DATASRCAPI void ds_add_news_product_code(ds_data_t *data, const char *code);
2318 DATASRCAPI void ds_add_news_topic_code(ds_data_t *data, const char *code);
2319 DATASRCAPI void ds_add_news_company_code(ds_data_t *data, const char *code);
2320 DATASRCAPI void ds_add_news_user_code(ds_data_t *data, int codenum, const char *code);
2321 DATASRCAPI void ds_add_news_field(ds_data_t *dsdata, const char *fieldname, const char *value);
2322 
2323 DATASRCAPI ds_data_t *ds_init_container(const char *subject, const unsigned short flags);
2324 DATASRCAPI void ds_add_container_symbol_and_request(ds_data_t *data, const char *symbol, const int request);
2325 DATASRCAPI void ds_add_container_symbol(ds_data_t *data, const char *symbol);
2326 DATASRCAPI void ds_add_container_symbol_at_position(ds_data_t *data, int position, const char *symbol);
2327 DATASRCAPI void ds_remove_container_symbol(ds_data_t *data, const char *symbol);
2328 DATASRCAPI void ds_cleardown_container_with_prefix(ds_data_t *data, const char *prefix);
2329 
2330 DATASRCAPI ds_data_t *ds_init_permission(const char *subject, const char *key, unsigned short flags);
2331 DATASRCAPI void ds_add_permission_key(ds_data_t *data, const char *key);
2332 
2333 DATASRCAPI void ds_add_binary(ds_data_t *data, int32_t fieldnum, char *value, int len, char type);
2334 DATASRCAPI void ds_add_binary_float32(ds_data_t *data, int32_t fieldnum, float value);
2335 DATASRCAPI void ds_add_binary_float64(ds_data_t *data, int32_t fieldnum, double value);
2336 DATASRCAPI void ds_add_binary_int8(ds_data_t *data, int32_t fieldnum, int8_t value);
2337 DATASRCAPI void ds_add_binary_int16(ds_data_t *data, int32_t fieldnum, int16_t value);
2338 DATASRCAPI void ds_add_binary_int32(ds_data_t *data, int32_t fieldnum, int32_t value);
2339 DATASRCAPI void ds_add_binary_int64(ds_data_t *data, int32_t fieldnum, int64_t value);
2340 DATASRCAPI void ds_add_binary_uint8(ds_data_t *data, int32_t fieldnum, uint8_t value);
2341 DATASRCAPI void ds_add_binary_uint16(ds_data_t *data, int32_t fieldnum, uint16_t value);
2342 DATASRCAPI void ds_add_binary_uint32(ds_data_t *data, int32_t fieldnum, uint32_t value);
2343 DATASRCAPI void ds_add_binary_uint64(ds_data_t *data, int32_t fieldnum, uint64_t value);
2344 DATASRCAPI void ds_add_binary_string(ds_data_t *data, int32_t fieldnum, char *value);
2345 DATASRCAPI void ds_add_binary_opaque(ds_data_t *data, int32_t fieldnum, char *value, int len);
2346 DATASRCAPI void ds_add_binary_time(ds_data_t *data, int32_t fieldnum, time_t value);
2347 DATASRCAPI void ds_add_binary_time_millis(ds_data_t *data, int32_t fieldnum, int64_t value);
2348 DATASRCAPI void ds_add_binary_timeval(ds_data_t *data, int32_t fieldnum, struct timeval value);
2349 DATASRCAPI void ds_add_binary_timespec(ds_data_t *data, int32_t fieldnum, struct timespec value);
2350 
2351 #define ds_add_binary_char(d,f,v) ds_add_binary_int8(d,f,v);
2352 #define ds_add_binary_short(d,f,v) ds_add_binary_int16(d,f,v);
2353 #define ds_add_binary_int(d,f,v) ds_add_binary_int32(d,f,v);
2354 #define ds_add_binary_long(d,f,v) ds_add_binary_int32(d,f,v);
2355 #define ds_add_binary_float(d,f,v) ds_add_binary_float32(d,f,v);
2356 #define ds_add_binary_double(d,f,v) ds_add_binary_float64(d,f,v);
2357 #define ds_add_binary_time_micros(d,f,v) ds_add_binary_timeval(d,f,v);
2358 #define ds_add_binary_time_nanos(d,f,v) ds_add_binary_timespec(d,f,v);
2359 
2360 
2364 #define NEWS_HEADLINE_FIELDNUM 0
2365 
2368 #define NEWS_STORYCODE_FIELDNUM 1
2369 
2372 #define NEWS_DATETIME_FIELDNUM 2
2373 
2376 #define NEWS_AUTHSTR_FIELDNUM 5
2377 
2380 #define NEWS_PRODUCT_CODE_FIELDNUM 100
2381 
2384 #define NEWS_TOPIC_CODE_FIELDNUM 101
2385 
2388 #define NEWS_COMPANY_CODE_FIELDNUM 102
2389 
2392 #define NEWS_USER_CODE_FIELDNUM 200
2393 
2396 #define NEWS_USER_CODE_MAX 10
2397 
2398 #define NEWS_SIZE_FIELDNUM 300
2399 #define NEWS_REASON_FIELDNUM 301
2400 
2401 #define NEWS_REQ_SEARCH 1000
2402 #define NEWS_REQ_STORYCODE 1001
2403 #define NEWS_REQ_DATE_TO 1002
2404 #define NEWS_REQ_DATE_FROM 1003
2405 #define NEWS_REQ_FLAGS 1004
2406 
2407 #define NEWS_GENERIC_FIELDNUM 1024
2408 
2409 /* peer */
2410 
2411 
2412 DATASRCAPI extern int ds_num_peers;
2413 
2414 
2415 DATASRCAPI int ds_peer_details(int peer, char **name);
2416 DATASRCAPI int ds_peer_host_details(int peer, char **addr);
2417 DATASRCAPI int ds_peer_id(int peer);
2418 DATASRCAPI char *ds_peer_name(int peer);
2419 DATASRCAPI int ds_peer_flags(int peer);
2420 DATASRCAPI int ds_peer_local_type(int peer);
2421 DATASRCAPI int ds_peer_type(int peer);
2422 DATASRCAPI int ds_peer_up(int peer);
2423 DATASRCAPI void ds_peer_add_extra_handshake_data(int peer, const char *data);
2424 DATASRCAPI int ds_peer_all_type(int flag);
2425 
2426 DATASRCAPI void ds_set_status_down(void);
2427 DATASRCAPI void ds_set_status_down_to_peer(int peer);
2428 DATASRCAPI void ds_set_status_msg(unsigned short msgid, const char *msgstr);
2429 DATASRCAPI void ds_set_status_msg_to_peer(int peer, unsigned short msgid, const char *msgstr);
2430 DATASRCAPI void ds_set_status_up(void);
2431 DATASRCAPI void ds_set_status_up_to_peer(int peer);
2432 DATASRCAPI int ds_peer_by_label(const char *label);
2433 DATASRCAPI int ds_peer_by_local_label(const char *label);
2434 DATASRCAPI char *ds_peer_label_byindex(int index);
2435 DATASRCAPI int ds_peer_enabled_state(int peer);
2436 
2437 /* pkt */
2438 
2445 struct _ds_data
2446  {
2447  unsigned short seq;
2448  unsigned short flags;
2449  unsigned short type;
2450  char *subject;
2451  unsigned short count;
2452  ds_field_t *fields;
2453  time_t time;
2454  };
2455 
2462 struct _ds_field
2463  {
2464  int32_t fieldnum;
2465  int32_t len;
2466  char *value;
2467  unsigned short flags;
2468  };
2469 
2470 
2471 /* replay */
2472 
2473 
2474 DATASRCAPI void ds_replay(recv_replay_t callback);
2475 DATASRCAPI int ds_replay_from_file(recv_replay_t callback, char *filename);
2476 DATASRCAPI void ds_replay_from_log(recv_replay_t callback, ds_log_t *log);
2477 DATASRCAPI void ds_replay_by_time(time_t t, recv_replay_t callback);
2478 DATASRCAPI int ds_replay_by_time_from_file(time_t t, recv_replay_t callback, char *filename);
2479 DATASRCAPI void ds_replay_by_time_from_log(time_t t, recv_replay_t callback, ds_log_t *log);
2480 DATASRCAPI void ds_replay_by_field(int fieldnum, char *value, recv_replay_t callback);
2481 DATASRCAPI int ds_replay_by_field_from_file(int fieldnum, char *value, recv_replay_t callback, char *filename);
2482 DATASRCAPI void ds_replay_by_field_from_log(int fieldnum, char *value, recv_replay_t callback, ds_log_t *log);
2483 
2484 
2485 /* udp */
2486 
2487 
2492 typedef struct _ds_udp_event ds_udp_event_t;
2493 
2505 typedef int (*ds_udp_event_cb)(int argc, char *argv[], int val, void *data);
2506 
2507 
2508 DATASRCAPI ds_udp_event_t *ds_add_udp_event(const char *command, ds_udp_event_cb cb, int val, void *data);
2509 DATASRCAPI void ds_del_udp_event(ds_udp_event_t *event);
2510 
2511 DATASRCAPI void ds_udpsignal_send(const char *message);
2512 DATASRCAPI void ds_udpsignal_send_argv(const char *message, char *argv[]);
2513 
2514 /* Deprecated methods of handling udp commands */
2515 DATASRCAPI int ds_udpsignal_addjob(const char *cmd,void (*fn)(int argc,char *argv[]), const char *description);
2516 DATASRCAPI int ds_udpsignal_deljob(const char *cmd, void (*fn)(int argc, char *argv[]));
2517 
2518 
2519 /* misc */
2520 
2521 DATASRCAPI void ds_set_productname(const char *name);
2522 
2523 /* advmap */
2524 
2525 DATASRCAPI char *ds_request_object(const char *name);
2526 DATASRCAPI char *ds_request_object_with_flags(const char *name,int flags);
2527 DATASRCAPI int ds_request_objects(int count, char **obs, char ***services);
2528 DATASRCAPI int ds_request_objects_with_flags(int count, char **obs, int flags, char ***services);
2529 DATASRCAPI void ds_discard_object(const char *name);
2530 DATASRCAPI void ds_discard_objects(int count, char **obs);
2531 DATASRCAPI char * ds_get_service(const char *name);
2532 DATASRCAPI int ds_send_contribution(ds_data_t *dsdata);
2533 DATASRCAPI int ds_get_num_services(void);
2534 DATASRCAPI int ds_get_service_by_index(int index, char **name_ptr);
2535 DATASRCAPI int ds_object_available(const char *name);
2536 DATASRCAPI int ds_object_can_contrib(const char *name);
2537 DATASRCAPI void ds_purge_object(const char *name);
2538 DATASRCAPI int ds_required_services_status(char *buf, size_t buflen);
2539 DATASRCAPI int ds_get_service_type(const char *servicename);
2540 DATASRCAPI int ds_get_is_contrib_source(const char *name, int peer);
2541 
2543 DATASRCAPI int ds_set_request_hint(const char *name, int num, char **hints);
2544 DATASRCAPI char **ds_get_request_hints(const char *name, int *ret);
2545 DATASRCAPI void ds_set_object_data(const char *name, void *data);
2546 DATASRCAPI void *ds_get_object_data(const char *name);
2547 
2548 /* signature */
2549 DATASRCAPI int ds_signature_check(char *key_id, char *token);
2550 
2551 /* page */
2552 
2553 #define DS_BIGPAGE_R 25
2554 #define DS_BIGPAGE_C 80
2555 #define DS_BIGPAGE_TYPE "25"
2556 #define DS_SMALLPAGE_R 14
2557 #define DS_SMALLPAGE_C 64
2558 #define DS_SMALLPAGE_TYPE "218"
2559 
2560 typedef void (*ds_discovery_peer_cb)(int peer, int added, void *data);
2561 DATASRCAPI void ds_discovery_register_peer_callback(ds_discovery_peer_cb cb);
2562 
2563 
2564 DATASRCAPI int ds_signature_verify_username(char *expected_username, char *token);
2565 
2572 #define DS_SIGNATURE_OK 0
2573 
2579 #define DS_SIGNATURE_INVALID_TOKEN 1
2580 
2586 #define DS_SIGNATURE_UNKNOWN_KEYID 2
2587 
2593 #define DS_SIGNATURE_ALREADY_USED 3
2594 #endif /* __DATASRC_H__ */
2595 
2596 #ifdef __cplusplus
2597 } /* extern "C" */
2598 #endif
2599 
ds_init_t::recv_update
recv_update_t recv_update
Definition: datasrc.h:366
ds_init_t::log_root
char * log_root
Definition: datasrc.h:361
_ds_field::flags
unsigned short flags
Definition: datasrc.h:2467
ds_init_t
Definition: datasrc.h:357
ds_monitor_authenticator_t
int(* ds_monitor_authenticator_t)(ds_monauth_t *credentials)
Definition of the function type used for monitoring authentication callback.
Definition: datasrc.h:1496
ds_loglevelchange_t
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:1199
ds_init_t::application_root
char * application_root
Definition: datasrc.h:360
_ds_data::subject
char * subject
Definition: datasrc.h:2450
ds_delay_t
struct _ds_delay ds_delay_t
The delay channel object type.
Definition: datasrc.h:164
_ds_data::seq
unsigned short seq
Definition: datasrc.h:2447
ds_monitor_active_cb
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:1471
ds_config_enum_t
Enumerated types structure.
Definition: datasrc.h:919
_ds_field
A field within a data update.
Definition: datasrc.h:2462
ds_init_t::application_name
char * application_name
Definition: datasrc.h:359
recv_update_t
void(* recv_update_t)(int peer, ds_data_t *pkt)
Definition: datasrc.h:191
ds_timed_event_cb
int(* ds_timed_event_cb)(int id, int val, void *data)
Definition of the callback for use with timed events.
Definition: datasrc.h:1042
ds_array_t
The container object for monitoring array types.
Definition: datasrc.h:1390
ds_set_request_hint
DATASRCAPI int ds_set_request_hint(const char *name, int num, char **hints)
ds_logcycled_t
void(* ds_logcycled_t)(ds_log_t *log)
Callback used when the log has cycled.
Definition: datasrc.h:1207
ds_arguments_t::typeflags
int typeflags
Definition: datasrc.h:1438
recv_object_status_t
void(* recv_object_status_t)(int peer, char *subject, int status, unsigned short code, char *msgstr)
Definition: datasrc.h:314
ds_monauth_t
Monitoring credentials object.
Definition: datasrc.h:1479
ds5_subscriptionlistener_t
Definition: datasrc.h:649
_ds_data::count
unsigned short count
Definition: datasrc.h:2451
ds_init_t::recv_object_status
recv_object_status_t recv_object_status
Definition: datasrc.h:372
ds_config_enum_t::name
char * name
Definition: datasrc.h:921
ds_arguments_t::docstring
char * docstring
Definition: datasrc.h:1441
ds_init_t::recv_service_status
recv_service_status_t recv_service_status
Definition: datasrc.h:377
ds_config_enum_t::docstring
char * docstring
Definition: datasrc.h:923
sock_t
int sock_t
The network socket datatype.
Definition: datasrc.h:128
ds5_subscription_t
struct _ds5_subscription_s ds5_subscription_t
Definition: datasrc.h:634
ds_arguments_t::description
char * description
Definition: datasrc.h:1440
ds5_connectionlistener_t
Definition: datasrc.h:595
ds_add_latency_chain2
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.
_ds_data::fields
ds_field_t * fields
Definition: datasrc.h:2452
ds_init_t::flags
unsigned short flags
Definition: datasrc.h:362
recv_discard_t
void(* recv_discard_t)(int peer, int count, char **subjects, unsigned short flags)
Definition: datasrc.h:293
ds_arguments_t::name
char * name
Definition: datasrc.h:1439
_ds5_namespace_s
Definition of the interface that you should implement if you require custom subject matching logic...
Definition: datasrc.h:432
ds5_publisher_t
struct _ds5_publisher_s ds5_publisher_t
Definition: datasrc.h:501
ds_udp_event_t
struct _ds_udp_event ds_udp_event_t
Opaque type defining a udp event.
Definition: datasrc.h:2492
ds_monitor_t::propertyname
char * propertyname
Definition: datasrc.h:1413
ds_monitor_t
The container object for all monitoring values.
Definition: datasrc.h:1411
_ds_data::flags
unsigned short flags
Definition: datasrc.h:2448
recv_replay_t
void(* recv_replay_t)(int peer, ds_data_t *pkt, time_t tm)
Definition: datasrc.h:209
ds_arguments_t
Structure defining the arguments for Monitoring methods.
Definition: datasrc.h:1436
ds_log_t
struct _ds_log ds_log_t
The log file object.
Definition: datasrc.h:175
ds_init_t::type
unsigned short type
Definition: datasrc.h:363
_ds5_namespace_s::free
void(* free)(ds5_namespace_t *nspace)
Invoked when the namespace should be deleted.
Definition: datasrc.h:439
ds_set_t
struct _ds_peer_set ds_set_t
Defines a set of DataSource peers.
Definition: datasrc.h:153
recv_peer_status_t
void(* recv_peer_status_t)(int peer, int status, int val, void *data)
Definition: datasrc.h:253
ds_timed_event_t
struct _ds_timed_event ds_timed_event_t
Opaque type defining a timed event.
Definition: datasrc.h:988
ds_array_t::size
size_t size
Definition: datasrc.h:1391
_ds_data
A data update object.
Definition: datasrc.h:2445
_ds_field::value
char * value
Definition: datasrc.h:2466
ds_monauth_t::username
char * username
Definition: datasrc.h:1481
ds_io_event_cb
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:1030
recv_request_t
void(* recv_request_t)(int peer, int count, char **subjects, unsigned short flags)
Definition: datasrc.h:273
_ds_data::type
unsigned short type
Definition: datasrc.h:2449
ds_write_event_t
struct _ds_io_event ds_write_event_t
Opaque type defining a write event.
Definition: datasrc.h:1010
ds_config_enum_t::value
double value
Definition: datasrc.h:922
ds_init_t::recv_request
recv_request_t recv_request
Definition: datasrc.h:364
ds_monauth_t::password
char * password
Definition: datasrc.h:1482
ds_config_ctx_t
struct _config_ctx ds_config_ctx_t
The configuration context data type.
Definition: datasrc.h:170
ds_init_t::recv_map
recv_map_t recv_map
Definition: datasrc.h:378
ds5_dataprovider_t
Definition: datasrc.h:519
_ds_field::fieldnum
int32_t fieldnum
Definition: datasrc.h:2464
ds_init_t::recv_peer_status
recv_peer_status_t recv_peer_status
Definition: datasrc.h:368
ds_init_t::logfile
char * logfile
Definition: datasrc.h:381
ds_init_t::log
ds_log_t * log
Definition: datasrc.h:382
ds_except_event_t
struct _ds_io_event ds_except_event_t
Opaque type defining an exception event.
Definition: datasrc.h:995
ds_read_event_t
struct _ds_io_event ds_read_event_t
Opaque type defining a read event.
Definition: datasrc.h:1003
ds_add_latency_initial_timestamp
DATASRCAPI void ds_add_latency_initial_timestamp(ds_data_t *dsdata)
Sets the initial time for latency chaining.
ds_add_latency_chain
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
ds_delay_send_cb
void(* ds_delay_send_cb)(void *context, ds_data_t *dsdata)
Definition: datasrc.h:2295
ds_config_func
void(* ds_config_func)(char *name, int num, char **values)
Definition of function type used for configuration callbacks.
Definition: datasrc.h:940
_ds_field::len
int32_t len
Definition: datasrc.h:2465
ds_generic_event_t
struct _ds_io_event ds_generic_event_t
Opaque type defining a generic read/write event.
Definition: datasrc.h:1017
ds_init_t::recv_nodata
recv_nodata_t recv_nodata
Definition: datasrc.h:367
recv_nodata_t
void(* recv_nodata_t)(int peer, char *subject, unsigned short flags)
Definition: datasrc.h:229
ds_monauth_t::ipaddress
char * ipaddress
Definition: datasrc.h:1483
recv_map_t
void(* recv_map_t)(int peer, char *from, char *to)
Definition: datasrc.h:337
recv_service_status_t
void(* recv_service_status_t)(char *service, int status)
Definition: datasrc.h:325
ds_udp_event_cb
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:2505
_ds5_namespace_s::match
int(* match)(ds5_namespace_t *nspace, const char *subject)
Tests a subject to see if it falls within this namespace.
Definition: datasrc.h:449
ds_monitor_t::datatype
int datatype
Definition: datasrc.h:1414
ds_init_t::recv_discard
recv_discard_t recv_discard
Definition: datasrc.h:365
Generated on Mon Jul 20 2020 19:17:22 for Transformer SDK For C