UM C API 6.17.1

- Main Page
- Related Pages
- Modules
- Data Structures
- Files

- File List
- Globals

umedmonmsgs.h
Go to the documentation of this file.
1
10 /*
11 All of the documentation and software included in this and any
12 other Informatica Inc. Ultra Messaging Releases
13 Copyright (C) Informatica Inc. All rights reserved.
14
15 Redistribution and use in source and binary forms, with or without
16 modification, are permitted only as covered by the terms of a
17 valid software license agreement with Informatica Inc.
18
19 (C) Copyright 2007,2025 Informatica Inc. All Rights Reserved.
20
21 THE SOFTWARE IS PROVIDED "AS IS" AND INFORMATICA DISCLAIMS ALL WARRANTIES
22 EXPRESS OR IMPLIED, INCLUDING WITHOUT LIMITATION, ANY IMPLIED WARRANTIES OF
23 NON-INFRINGEMENT, MERCHANTABILITY OR FITNESS FOR A PARTICULAR
24 PURPOSE. INFORMATICA DOES NOT WARRANT THAT USE OF THE SOFTWARE WILL BE
25 UNINTERRUPTED OR ERROR-FREE. INFORMATICA SHALL NOT, UNDER ANY CIRCUMSTANCES, BE
26 LIABLE TO LICENSEE FOR LOST PROFITS, CONSEQUENTIAL, INCIDENTAL, SPECIAL OR
27 INDIRECT DAMAGES ARISING OUT OF OR RELATED TO THIS AGREEMENT OR THE
28 TRANSACTIONS CONTEMPLATED HEREUNDER, EVEN IF INFORMATICA HAS BEEN APPRISED OF
29 THE LIKELIHOOD OF SUCH DAMAGES.
30 */
31
32 #ifndef UME_DMON_MSGS_H
33 #define UME_DMON_MSGS_H
34
35 #define LBM_UMESTORE_DMON_VERSION_STRLEN 256
36 #define LBM_UMESTORE_DMON_STORE_NAME_STRLEN 256
37 #define LBM_UMESTORE_DMON_TOPIC_PATTERN_STRLEN 256
38 #define LBM_UMESTORE_DMON_FILENAME_MAX_STRLEN 256
39
43 #define LBM_UMESTORE_DMON_MPG_SMART_HEAP_STATS 1
44
47 #define LBM_UMESTORE_DMON_MPG_STORE_STATS 2
48
51 #define LBM_UMESTORE_DMON_MPG_REPO_STATS 3
52
55 #define LBM_UMESTORE_DMON_MPG_DISK_STATS 4
56
59 #define LBM_UMESTORE_DMON_MPG_RCV_STATS 5
60
63 #define LBM_UMESTORE_DMON_MPG_STORE_CONFIG 101
64
67 #define LBM_UMESTORE_DMON_MPG_STORE_PATTERN_CONFIG 102
68
71 #define LBM_UMESTORE_DMON_MPG_STORE_TOPIC_CONFIG 103
72
75 #define LBM_UMESTORE_DMON_MPG_REPO_CONFIG 104
76
79 #define LBM_UMESTORE_DMON_MPG_RCV_CONFIG 105
80
83 #define LBM_UMESTORE_DMON_MAGIC 0x4542
84
86 #define LBM_UMESTORE_DMON_ANTIMAGIC 0x4245
87
91 #define LBM_UMESTORE_DMON_VERSION 1
92
95 typedef struct umestore_dmon_msg_hdr_t_stct {
99 lbm_uint16_t magic;
105 lbm_uint16_t type;
109 lbm_uint16_t version;
112 lbm_uint16_t length;
116 lbm_uint32_t tv_sec;
121 lbm_uint32_t tv_usec;
122 } umestore_dmon_msg_hdr_t;
123 #define UMESTORE_DMON_MSG_HDR_T_SZ (offsetof(umestore_dmon_msg_hdr_t, tv_usec) + sizeof(lbm_uint32_t))
124
125 /* ************************************************************************************************** */
126 /* configuration messages */
127 /* ************************************************************************************************** */
128
136 typedef struct umestore_store_dmon_config_msg_t_stct {
138 umestore_dmon_msg_hdr_t hdr;
145 lbm_uint32_t store_iface;
148 lbm_uint32_t store_max_retransmission_processing_rate;
151 lbm_uint16_t store_idx;
153 lbm_uint16_t store_port;
157 lbm_uint16_t store_name_offset;
160 lbm_uint16_t disk_cache_dir_offset;
163 lbm_uint16_t disk_state_dir_offset;
172 char string_buffer[LBM_UMESTORE_DMON_STORE_NAME_STRLEN + (2 * LBM_UMESTORE_DMON_FILENAME_MAX_STRLEN)];
173 } umestore_store_dmon_config_msg_t;
174 #define UMESTORE_STORE_DMON_CONFIG_MSG_T_MIN_SZ (offsetof(umestore_store_dmon_config_msg_t, string_buffer) + 2)
175
183 typedef struct umestore_store_pattern_dmon_config_msg_t_stct {
185 umestore_dmon_msg_hdr_t hdr;
188 lbm_uint16_t store_idx;
194 lbm_uint16_t type;
201 char pattern_buffer[LBM_UMESTORE_DMON_TOPIC_PATTERN_STRLEN];
202 } umestore_store_pattern_dmon_config_msg_t;
203 #define UMESTORE_STORE_PATTERN_DMON_CONFIG_MSG_T_MIN_SZ (offsetof(umestore_store_pattern_dmon_config_msg_t, pattern_buffer) + 2)
204
207 #define UMESTORE_DMON_TOPIC_TYPE_DIRECT 0
208
211 #define UMESTORE_DMON_TOPIC_TYPE_PCRE 1
212
215 #define UMESTORE_DMON_TOPIC_TYPE_REGEXP 2
216
223 typedef struct umestore_topic_dmon_config_msg_t_stct {
225 umestore_dmon_msg_hdr_t hdr;
228 lbm_uint32_t dmon_topic_idx;
231 lbm_uint16_t store_idx;
238 char topic_name[LBM_UMESTORE_DMON_TOPIC_PATTERN_STRLEN];
239 } umestore_topic_dmon_config_msg_t;
240 #define UMESTORE_TOPIC_DMON_CONFIG_MSG_T_MIN_SZ (offsetof(umestore_topic_dmon_config_msg_t, topic_name) + 2)
241
252 typedef struct umestore_repo_dmon_config_msg_t_stct {
254 umestore_dmon_msg_hdr_t hdr;
258 lbm_uint64_t sid;
261 lbm_uint64_t disk_sz_limit;
264 lbm_uint64_t src_flightsz_bytes;
269 lbm_uint32_t dmon_topic_idx;
271 lbm_uint32_t regid;
274 lbm_uint32_t sz_threshold;
277 lbm_uint32_t sz_limit;
280 lbm_uint32_t age_threshold;
283 lbm_uint32_t disk_max_write_aiocbs;
286 lbm_uint32_t disk_max_read_aiocbs;
289 lbm_uint32_t disk_aio_buffer_len;
292 lbm_uint32_t write_delay;
295 lbm_uint16_t store_idx;
301 lbm_uint8_t type;
306 lbm_uint8_t allow_ack_on_reception;
307 } umestore_repo_dmon_config_msg_t;
308 #define UMESTORE_REPO_DMON_CONFIG_MSG_T_SZ (offsetof(umestore_repo_dmon_config_msg_t, allow_ack_on_reception) + sizeof(lbm_uint8_t))
309
312 #define UMESTORE_DMON_REPO_TYPE_NOCACHE 0
313
315 #define UMESTORE_DMON_REPO_TYPE_MEMORY 1
316
318 #define UMESTORE_DMON_REPO_TYPE_DISK 2
319
322 #define UMESTORE_DMON_REPO_DO_NOT_ACK_ON_RECEPTION 0
323
325 #define UMESTORE_DMON_REPO_ACK_ON_RECEPTION 1
326
334 typedef struct umestore_rcv_dmon_config_msg_t_stct {
336 umestore_dmon_msg_hdr_t hdr;
340 lbm_uint64_t sid;
345 lbm_uint32_t dmon_topic_idx;
347 lbm_uint32_t regid;
349 lbm_uint32_t transport_idx;
351 lbm_uint32_t topic_idx;
353 lbm_uint32_t domain_id;
359 lbm_uint32_t sin_addr;
362 lbm_uint16_t store_idx;
364 lbm_uint16_t sin_port;
365 } umestore_rcv_dmon_config_msg_t;
366 #define UMESTORE_RCV_DMON_CONFIG_MSG_T_SZ (offsetof(umestore_rcv_dmon_config_msg_t, sin_port) + sizeof(lbm_uint16_t))
367
368 /* ************************************************************************************************** */
369 /* statistics messages */
370 /* ************************************************************************************************** */
371
376 typedef struct umestore_smart_heap_dmon_stat_msg_t_stct {
378 umestore_dmon_msg_hdr_t hdr;
381 lbm_int64_t poolsize;
384 lbm_int64_t poolcount;
387 lbm_uint32_t smallBlockSize;
390 lbm_uint32_t pageSize;
392 lbm_uint16_t mem_major_version;
394 lbm_uint16_t mem_minor_version;
396 lbm_uint16_t mem_update_version;
399 char umestored_version_buffer[LBM_UMESTORE_DMON_VERSION_STRLEN];
400 } umestore_smart_heap_dmon_stat_msg_t;
401 #define UMESTORE_SMART_HEAP_DMON_STAT_MSG_T_MIN_SZ (offsetof(umestore_smart_heap_dmon_stat_msg_t, umestored_version_buffer) + 2)
402
407 typedef struct umestore_store_dmon_stat_msg_t_stct {
409 umestore_dmon_msg_hdr_t hdr;
411 lbm_uint32_t ume_retx_req_rcv_count;
413 lbm_uint32_t ume_retx_req_serviced_count;
415 lbm_uint32_t ume_retx_req_drop_count;
419 lbm_uint32_t ume_retx_stat_interval;
421 lbm_uint32_t ume_retx_req_total_dropped;
424 lbm_uint16_t store_idx;
425 } umestore_store_dmon_stat_msg_t;
426 #define UMESTORE_STORE_DMON_STAT_MSG_T_SZ (offsetof(umestore_store_dmon_stat_msg_t, store_idx) + sizeof(lbm_uint16_t))
427
432 typedef struct umestore_repo_dmon_stat_msg_t_stct {
434 umestore_dmon_msg_hdr_t hdr;
439 lbm_uint32_t dmon_topic_idx;
441 lbm_uint32_t regid;
444 lbm_uint32_t message_map_sz;
448 lbm_uint32_t memory_sz;
452 lbm_uint32_t rpp_memory_sz;
454 lbm_uint32_t lead_sqn;
458 lbm_uint32_t sync_sqn;
461 lbm_uint32_t sync_complete_sqn;
463 lbm_uint32_t trail_sqn;
465 lbm_uint32_t mem_trail_sqn;
468 lbm_uint32_t contig_sqn;
473 lbm_uint32_t high_ulb_sqn;
476 lbm_uint32_t map_intentional_drops;
479 lbm_uint32_t uls;
482 lbm_uint32_t ulbs;
485 lbm_uint32_t sz_limit_drops;
488 lbm_uint16_t store_idx;
497 lbm_uint8_t flags;
498 } umestore_repo_dmon_stat_msg_t;
499 #define UMESTORE_REPO_DMON_STAT_MSG_T_SZ (offsetof(umestore_repo_dmon_stat_msg_t, flags) + sizeof(lbm_uint8_t))
500
504 #define UMESTORE_DMON_REPO_FLAG_INTENTIONAL_DROPS 0x1
505
508 #define UMESTORE_DMON_REPO_FLAG_ISN_SET 0x2
509
512 #define UMESTORE_DMON_REPO_FLAG_DISK_CKSUM 0x4
513
515 #define UMESTORE_DMON_REPO_FLAG_SHUTTING_DOWN 0x8
516
519 #define UMESTORE_DMON_REPO_FLAG_RPP 0x10
520
523 #define UMESTORE_DMON_REPO_FLAG_DELAY_WRITE 0x20
524
529 typedef struct umestore_disk_dmon_stat_msg_t_stct {
531 umestore_dmon_msg_hdr_t hdr;
534 lbm_int64_t max_offset;
537 lbm_int64_t num_ios_pending;
540 lbm_int64_t num_read_ios_pending;
543 lbm_int64_t offset;
546 lbm_int64_t start_offset;
551 lbm_uint32_t dmon_topic_idx;
553 lbm_uint32_t regid;
556 lbm_uint16_t store_idx;
557 } umestore_disk_dmon_stat_msg_t;
558 #define UMESTORE_DISK_DMON_STAT_MSG_T_SZ (offsetof(umestore_disk_dmon_stat_msg_t, store_idx) + sizeof(lbm_uint16_t))
559
564 typedef struct umestore_rcv_dmon_stat_msg_t_stct {
566 umestore_dmon_msg_hdr_t hdr;
571 lbm_uint32_t dmon_topic_idx;
573 lbm_uint32_t regid;
575 lbm_uint32_t high_ack_sqn;
578 lbm_uint16_t store_idx;
590 lbm_uint16_t flags;
591 } umestore_rcv_dmon_stat_msg_t;
592 #define UMESTORE_RCV_DMON_STAT_MSG_T_SZ (offsetof(umestore_rcv_dmon_stat_msg_t, flags) + sizeof(lbm_uint16_t))
593
596 #define UMESTORE_DMON_RCV_FLAG_FIRST_ACK 0x1
597
599 #define UMESTORE_DMON_RCV_FLAG_OOD 0x2
600
602 #define UMESTORE_DMON_RCV_FLAG_CAPABILITY_QC 0x4
603
606 #define UMESTORE_DMON_RCV_FLAG_SHUTTING_DOWN 0x8
607
609 #define UMESTORE_DMON_RCV_FLAG_DEREGISTERING 0x10
610
612 #define UMESTORE_DMON_RCV_FLAG_RPP 0x20
613
615 #define UMESTORE_DMON_RCV_FLAG_RPP_IS_NON_BLOCKING 0x40
616
619 #define UMESTORE_DMON_RCV_FLAG_KEEPALIVES_DISABLED 0x80
620
621 #endif /* UME_DMON_MSGS_H */
umestore_topic_dmon_config_msg_t
struct umestore_topic_dmon_config_msg_t_stct umestore_topic_dmon_config_msg_t
Message containing topic name of one or more registered sources. ( umestore_dmon_msg_hdr_t_stct::typ...
umestore_smart_heap_dmon_stat_msg_t_stct::hdr
umestore_dmon_msg_hdr_t hdr
Standard header common to all messages.
Definition: umedmonmsgs.h:378
umestore_repo_dmon_config_msg_t_stct::age_threshold
lbm_uint32_t age_threshold
Value configured for the Store&#39;s option repository-age-threshold.
Definition: umedmonmsgs.h:280
umestore_repo_dmon_stat_msg_t_stct::map_intentional_drops
lbm_uint32_t map_intentional_drops
Number of messages in the process of being dropped due to reaching the repository-size-limit.
Definition: umedmonmsgs.h:476
umestore_store_dmon_stat_msg_t_stct::ume_retx_req_drop_count
lbm_uint32_t ume_retx_req_drop_count
Retransmission Request Drop count.
Definition: umedmonmsgs.h:415
umestore_repo_dmon_stat_msg_t_stct::trail_sqn
lbm_uint32_t trail_sqn
Trail sequence number: oldest sequence number in the Store.
Definition: umedmonmsgs.h:463
umestore_dmon_msg_hdr_t_stct
Common message header structure included at the start of all messages.
Definition: umedmonmsgs.h:95
umestore_repo_dmon_config_msg_t_stct::regid
lbm_uint32_t regid
Registration ID used by the source to register.
Definition: umedmonmsgs.h:271
umestore_disk_dmon_stat_msg_t
struct umestore_disk_dmon_stat_msg_t_stct umestore_disk_dmon_stat_msg_t
Message containing Store disk statistics. ( umestore_dmon_msg_hdr_t_stct::type == LBM_UMESTORE_DMON_...
umestore_smart_heap_dmon_stat_msg_t_stct::mem_major_version
lbm_uint16_t mem_major_version
SmartHeap major version number.
Definition: umedmonmsgs.h:392
umestore_repo_dmon_config_msg_t_stct::type
lbm_uint8_t type
Value configured for the Store&#39;s option repository-type. Possible values: UMESTORE_DMON_REPO_TYPE_NOC...
Definition: umedmonmsgs.h:301
umestore_store_dmon_config_msg_t_stct::store_port
lbm_uint16_t store_port
Value configured for the <store> element&#39;s port attribute.
Definition: umedmonmsgs.h:153
umestore_rcv_dmon_config_msg_t
struct umestore_rcv_dmon_config_msg_t_stct umestore_rcv_dmon_config_msg_t
Message containing repository configuration defined during receiver registration. ( umestore_dmon_ms...
umestore_store_dmon_config_msg_t_stct::disk_cache_dir_offset
lbm_uint16_t disk_cache_dir_offset
Byte offset from start of structure to start of Store&#39;s cache directory name string (null-terminated)...
Definition: umedmonmsgs.h:160
umestore_disk_dmon_stat_msg_t_stct::num_ios_pending
lbm_int64_t num_ios_pending
Number of disk writes the Store has submitted to the Operation System which have not yet completed...
Definition: umedmonmsgs.h:537
umestore_disk_dmon_stat_msg_t_stct::start_offset
lbm_int64_t start_offset
The relative location on disk of the first message, umestore_repo_dmon_stat_msg_t::trail_sqn.
Definition: umedmonmsgs.h:546
umestore_repo_dmon_config_msg_t_stct::sz_limit
lbm_uint32_t sz_limit
Value configured for the Store&#39;s option repository-size-limit.
Definition: umedmonmsgs.h:277
umestore_disk_dmon_stat_msg_t_stct::regid
lbm_uint32_t regid
Registration ID used by the source to register.
Definition: umedmonmsgs.h:553
umestore_store_dmon_stat_msg_t_stct::ume_retx_req_rcv_count
lbm_uint32_t ume_retx_req_rcv_count
Retransmission Request Received count.
Definition: umedmonmsgs.h:411
umestore_smart_heap_dmon_stat_msg_t_stct::pageSize
lbm_uint32_t pageSize
Page size (bytes) as reported by SmartHeap&#39;s MemPoolInfo() function.
Definition: umedmonmsgs.h:390
umestore_repo_dmon_config_msg_t_stct::disk_max_write_aiocbs
lbm_uint32_t disk_max_write_aiocbs
Value configured for the Store&#39;s option repository-disk-max-write-async-cbs.
Definition: umedmonmsgs.h:283
umestore_repo_dmon_config_msg_t_stct::store_idx
lbm_uint16_t store_idx
Current Store number, starting with 0, counting each <store> element in the order configured...
Definition: umedmonmsgs.h:295
lbm_uint64_t
uint64_t lbm_uint64_t
For portability.
Definition: lbm.h:1748
umestore_store_dmon_stat_msg_t_stct::ume_retx_req_total_dropped
lbm_uint32_t ume_retx_req_total_dropped
Retransmission Request Total Dropped.
Definition: umedmonmsgs.h:421
umestore_disk_dmon_stat_msg_t_stct::max_offset
lbm_int64_t max_offset
The maximum size of the cache file, as configured by repository-disk-file-size-limit.
Definition: umedmonmsgs.h:534
umestore_rcv_dmon_stat_msg_t_stct::hdr
umestore_dmon_msg_hdr_t hdr
Standard header common to all messages.
Definition: umedmonmsgs.h:566
umestore_rcv_dmon_stat_msg_t
struct umestore_rcv_dmon_stat_msg_t_stct umestore_rcv_dmon_stat_msg_t
Message containing Store receiver statistics. ( umestore_dmon_msg_hdr_t_stct::type == LBM_UMESTORE_D...
umestore_repo_dmon_config_msg_t_stct::disk_aio_buffer_len
lbm_uint32_t disk_aio_buffer_len
Value configured for the Store&#39;s option repository-disk-async-buffer-length.
Definition: umedmonmsgs.h:289
umestore_topic_dmon_config_msg_t_stct::hdr
umestore_dmon_msg_hdr_t hdr
Standard header common to all messages.
Definition: umedmonmsgs.h:225
umestore_repo_dmon_stat_msg_t_stct::dmon_topic_idx
lbm_uint32_t dmon_topic_idx
Identifying index number for the topic of this source, defined in an earlier message of type LBM_UMES...
Definition: umedmonmsgs.h:439
lbm_int64_t
int64_t lbm_int64_t
For portability.
Definition: lbm.h:1752
umestore_rcv_dmon_config_msg_t_stct::domain_id
lbm_uint32_t domain_id
Topic Resolution Domain ID of the receiver.
Definition: umedmonmsgs.h:353
umestore_store_dmon_stat_msg_t_stct::store_idx
lbm_uint16_t store_idx
Current Store number, starting with 0, counting each <store> element in the order configured...
Definition: umedmonmsgs.h:424
umestore_repo_dmon_stat_msg_t_stct::memory_sz
lbm_uint32_t memory_sz
The number of bytes of messages in memory for a non-RPP repository (flags & UMESTORE_DMON_REPO_FLAG_R...
Definition: umedmonmsgs.h:448
umestore_repo_dmon_stat_msg_t_stct::store_idx
lbm_uint16_t store_idx
Current Store number, starting with 0, counting each <store> element in the order configured...
Definition: umedmonmsgs.h:488
umestore_repo_dmon_stat_msg_t_stct::sync_complete_sqn
lbm_uint32_t sync_complete_sqn
Most recent sequence number that the Operating System has confirmed persisting to disk...
Definition: umedmonmsgs.h:461
umestore_store_dmon_stat_msg_t_stct::ume_retx_req_serviced_count
lbm_uint32_t ume_retx_req_serviced_count
Retransmission Request Service count.
Definition: umedmonmsgs.h:413
umestore_store_dmon_config_msg_t_stct::store_iface
lbm_uint32_t store_iface
The network address of the Store, as configured with the interface attribute of the <store> element...
Definition: umedmonmsgs.h:145
umestore_repo_dmon_config_msg_t_stct::src_flightsz_bytes
lbm_uint64_t src_flightsz_bytes
Value configured for the Store&#39;s option source-flight-size-bytes-maximum.
Definition: umedmonmsgs.h:264
umestore_store_dmon_stat_msg_t_stct::ume_retx_stat_interval
lbm_uint32_t ume_retx_stat_interval
Seconds since the user last cleared the retransmit stats. If the user has not cleared them...
Definition: umedmonmsgs.h:419
umestore_disk_dmon_stat_msg_t_stct::num_read_ios_pending
lbm_int64_t num_read_ios_pending
Number of disk reads the Store has submitted to the Operation System which have not yet completed...
Definition: umedmonmsgs.h:540
umestore_dmon_msg_hdr_t_stct::version
lbm_uint16_t version
Version of the message definition. See Daemon Statistics Versioning for general information on versio...
Definition: umedmonmsgs.h:109
umestore_rcv_dmon_stat_msg_t_stct::dmon_topic_idx
lbm_uint32_t dmon_topic_idx
Identifying index number for the topic of this source, defined in an earlier message of type LBM_UMES...
Definition: umedmonmsgs.h:571
umestore_store_pattern_dmon_config_msg_t_stct::store_idx
lbm_uint16_t store_idx
Current Store number, starting with 0, counting each <store> element in the order configured...
Definition: umedmonmsgs.h:188
umestore_dmon_msg_hdr_t_stct::tv_usec
lbm_uint32_t tv_usec
Count of microseconds to be added to "tv_sec" to increase the precision of the timestamp. However, the accuracy of the timestamp is not guaranteed to be at the microsecond level.
Definition: umedmonmsgs.h:121
umestore_rcv_dmon_config_msg_t_stct::hdr
umestore_dmon_msg_hdr_t hdr
Standard header common to all messages.
Definition: umedmonmsgs.h:336
umestore_dmon_msg_hdr_t_stct::length
lbm_uint16_t length
Total length of the message, including this header. Note that some message types do not have fixed le...
Definition: umedmonmsgs.h:112
umestore_rcv_dmon_config_msg_t_stct::transport_idx
lbm_uint32_t transport_idx
The receiver&#39;s view of the transport session index.
Definition: umedmonmsgs.h:349
umestore_rcv_dmon_config_msg_t_stct::regid
lbm_uint32_t regid
Registration ID used by the receiver to register.
Definition: umedmonmsgs.h:347
umestore_repo_dmon_config_msg_t
struct umestore_repo_dmon_config_msg_t_stct umestore_repo_dmon_config_msg_t
Message containing repository configuration defined during source registration. ( umestore_dmon_msg_...
umestore_repo_dmon_stat_msg_t_stct::uls
lbm_uint32_t uls
Number of messages lost unrecoverably, not including burst loss events.
Definition: umedmonmsgs.h:479
lbm_uint8_t
uint8_t lbm_uint8_t
For portability.
Definition: lbm.h:1740
umestore_repo_dmon_stat_msg_t_stct::hdr
umestore_dmon_msg_hdr_t hdr
Standard header common to all messages.
Definition: umedmonmsgs.h:434
umestore_topic_dmon_config_msg_t_stct::store_idx
lbm_uint16_t store_idx
Current Store number, starting with 0, counting each <store> element in the order configured...
Definition: umedmonmsgs.h:231
umestore_rcv_dmon_config_msg_t_stct::sid
lbm_uint64_t sid
Session ID used by the receiver to register. (Session IDs are optional; if the receiver did not speci...
Definition: umedmonmsgs.h:340
umestore_store_dmon_config_msg_t_stct::store_idx
lbm_uint16_t store_idx
Current Store number, starting with 0, counting each <store> element in the order configured...
Definition: umedmonmsgs.h:151
umestore_repo_dmon_stat_msg_t
struct umestore_repo_dmon_stat_msg_t_stct umestore_repo_dmon_stat_msg_t
Message containing Store repository statistics. ( umestore_dmon_msg_hdr_t_stct::type == LBM_UMESTORE...
umestore_dmon_msg_hdr_t
struct umestore_dmon_msg_hdr_t_stct umestore_dmon_msg_hdr_t
Common message header structure included at the start of all messages.
umestore_smart_heap_dmon_stat_msg_t_stct::smallBlockSize
lbm_uint32_t smallBlockSize
Small block size (bytes) as reported by SmartHeap&#39;s MemPoolInfo() function.
Definition: umedmonmsgs.h:387
umestore_repo_dmon_stat_msg_t_stct::contig_sqn
lbm_uint32_t contig_sqn
Most recent sequence number that along with the trail_sqn, creates a range of sequence numbers with n...
Definition: umedmonmsgs.h:468
umestore_rcv_dmon_config_msg_t_stct::sin_addr
lbm_uint32_t sin_addr
The network address of the receiver. Format: as returned by standard function inet_addr() - a 32-bit ...
Definition: umedmonmsgs.h:359
umestore_store_dmon_config_msg_t_stct::hdr
umestore_dmon_msg_hdr_t hdr
Standard header common to all messages.
Definition: umedmonmsgs.h:138
umestore_smart_heap_dmon_stat_msg_t_stct::mem_minor_version
lbm_uint16_t mem_minor_version
SmartHeap minor version number.
Definition: umedmonmsgs.h:394
umestore_store_dmon_stat_msg_t_stct::hdr
umestore_dmon_msg_hdr_t hdr
Standard header common to all messages.
Definition: umedmonmsgs.h:409
umestore_repo_dmon_config_msg_t_stct::disk_max_read_aiocbs
lbm_uint32_t disk_max_read_aiocbs
Value configured for the Store&#39;s option repository-disk-max-read-async-cbs.
Definition: umedmonmsgs.h:286
umestore_repo_dmon_stat_msg_t_stct::sync_sqn
lbm_uint32_t sync_sqn
Most recent sequence number for which the Store has initiated persisting to disk, but the Operating S...
Definition: umedmonmsgs.h:458
umestore_smart_heap_dmon_stat_msg_t_stct::mem_update_version
lbm_uint16_t mem_update_version
SmartHeap update version number.
Definition: umedmonmsgs.h:396
umestore_topic_dmon_config_msg_t_stct::dmon_topic_idx
lbm_uint32_t dmon_topic_idx
Identifying index number for this topic, used to establish relationships with other data structures...
Definition: umedmonmsgs.h:228
umestore_rcv_dmon_config_msg_t_stct::store_idx
lbm_uint16_t store_idx
Current Store number, starting with 0, counting each <store> element in the order configured...
Definition: umedmonmsgs.h:362
umestore_dmon_msg_hdr_t_stct::type
lbm_uint16_t type
Message type set by sender to indicate which kind of message this is. Possible values: one of the LBM...
Definition: umedmonmsgs.h:105
umestore_repo_dmon_config_msg_t_stct::write_delay
lbm_uint32_t write_delay
Value configured for the Store&#39;s option repository-disk-write-delay.
Definition: umedmonmsgs.h:292
umestore_store_pattern_dmon_config_msg_t_stct::type
lbm_uint16_t type
Value configured for the <topic>&#39;s attribute "type" attribute. Possible values: UMESTORE_DMON_TOPIC_T...
Definition: umedmonmsgs.h:194
umestore_disk_dmon_stat_msg_t_stct::offset
lbm_int64_t offset
The relative location on disk of where the message umestore_repo_dmon_stat_msg_t::contig_sqn+1 will b...
Definition: umedmonmsgs.h:543
umestore_repo_dmon_config_msg_t_stct::sid
lbm_uint64_t sid
Session ID used by the source to register. (Session IDs are optional; if the source did not specify a...
Definition: umedmonmsgs.h:258
umestore_store_dmon_stat_msg_t_stct
Message containing Store message statistics. ( umestore_dmon_msg_hdr_t_stct::type == LBM_UMESTORE_DM...
Definition: umedmonmsgs.h:407
umestore_rcv_dmon_config_msg_t_stct
Message containing repository configuration defined during receiver registration. ( umestore_dmon_ms...
Definition: umedmonmsgs.h:334
umestore_rcv_dmon_stat_msg_t_stct::regid
lbm_uint32_t regid
Registration ID used by the receiver to register.
Definition: umedmonmsgs.h:573
umestore_rcv_dmon_config_msg_t_stct::dmon_topic_idx
lbm_uint32_t dmon_topic_idx
Identifying index number for the topic of this source, defined in an earlier message of type LBM_UMES...
Definition: umedmonmsgs.h:345
umestore_repo_dmon_stat_msg_t_stct::high_ulb_sqn
lbm_uint32_t high_ulb_sqn
The highest sequence number reported among any Unrecoverable Loss Burst (ULB) event. It is not reset after the ULB is handled; it is maintained throughout the life of the Store.
Definition: umedmonmsgs.h:473
umestore_smart_heap_dmon_stat_msg_t_stct
Message containing smart heap statistics. ( umestore_dmon_msg_hdr_t_stct::type == LBM_UMESTORE_DMON_...
Definition: umedmonmsgs.h:376
umestore_repo_dmon_stat_msg_t_stct
Message containing Store repository statistics. ( umestore_dmon_msg_hdr_t_stct::type == LBM_UMESTORE...
Definition: umedmonmsgs.h:432
umestore_dmon_msg_hdr_t_stct::magic
lbm_uint16_t magic
"Magic" value set by sender to indicate to the receiver whether byte swapping is needed. Possible values: LBM_UMESTORE_DMON_MAGIC, LBM_UMESTORE_DMON_ANTIMAGIC.
Definition: umedmonmsgs.h:99
umestore_store_dmon_config_msg_t_stct::store_name_offset
lbm_uint16_t store_name_offset
Byte offset from start of structure to start of Store name string (null-terminated). This is the name specified in the UMP Element "<store>" attribute "name").
Definition: umedmonmsgs.h:157
umestore_store_pattern_dmon_config_msg_t
struct umestore_store_pattern_dmon_config_msg_t_stct umestore_store_pattern_dmon_config_msg_t
Message containing unchanging Store pattern information set at store daemon startup. ( umestore_dmon_msg_hdr_t_stct::type == LBM_UMESTORE_DMON_MPG_STORE_PATTERN_CONFIG ) One or more of these will be published for a given Store, one for each <topic> configured. Except where indicated, all fields of type lbm_uintXX_t should be byte-swapped if hdr.magic is equal to LBM_UMESTORE_DMON_ANTIMAGIC.
umestore_store_pattern_dmon_config_msg_t_stct
Message containing unchanging Store pattern information set at store daemon startup. ( umestore_dmon_msg_hdr_t_stct::type == LBM_UMESTORE_DMON_MPG_STORE_PATTERN_CONFIG ) One or more of these will be published for a given Store, one for each <topic> configured. Except where indicated, all fields of type lbm_uintXX_t should be byte-swapped if hdr.magic is equal to LBM_UMESTORE_DMON_ANTIMAGIC.
Definition: umedmonmsgs.h:183
umestore_rcv_dmon_stat_msg_t_stct
Message containing Store receiver statistics. ( umestore_dmon_msg_hdr_t_stct::type == LBM_UMESTORE_D...
Definition: umedmonmsgs.h:564
umestore_rcv_dmon_config_msg_t_stct::topic_idx
lbm_uint32_t topic_idx
The receiver&#39;s view of the topic index within the transport session.
Definition: umedmonmsgs.h:351
umestore_rcv_dmon_config_msg_t_stct::sin_port
lbm_uint16_t sin_port
"Request port" configured for the receiver.
Definition: umedmonmsgs.h:364
umestore_disk_dmon_stat_msg_t_stct
Message containing Store disk statistics. ( umestore_dmon_msg_hdr_t_stct::type == LBM_UMESTORE_DMON_...
Definition: umedmonmsgs.h:529
umestore_repo_dmon_config_msg_t_stct::disk_sz_limit
lbm_uint64_t disk_sz_limit
Value configured for the Store&#39;s option repository-disk-file-size-limit.
Definition: umedmonmsgs.h:261
umestore_repo_dmon_config_msg_t_stct::allow_ack_on_reception
lbm_uint8_t allow_ack_on_reception
Value configured for the Store&#39;s option repository-allow-ack-on-reception. Possible values: UMESTORE_...
Definition: umedmonmsgs.h:306
umestore_repo_dmon_config_msg_t_stct::sz_threshold
lbm_uint32_t sz_threshold
Value configured for the Store&#39;s option repository-size-threshold.
Definition: umedmonmsgs.h:274
umestore_repo_dmon_stat_msg_t_stct::rpp_memory_sz
lbm_uint32_t rpp_memory_sz
The number of bytes of messages in memory for a RPP repository (flags & UMESTORE_DMON_REPO_FLAG_RPP !...
Definition: umedmonmsgs.h:452
umestore_rcv_dmon_stat_msg_t_stct::flags
lbm_uint16_t flags
Bit map of flags indicating various characteristics and current states of the Store. Possible bits: UMESTORE_DMON_RCV_FLAG_FIRST_ACK, UMESTORE_DMON_RCV_FLAG_OOD, UMESTORE_DMON_RCV_FLAG_CAPABILITY_QC, UMESTORE_DMON_RCV_FLAG_SHUTTING_DOWN, UMESTORE_DMON_RCV_FLAG_DEREGISTERING, UMESTORE_DMON_RCV_FLAG_RPP, UMESTORE_DMON_RCV_FLAG_RPP, UMESTORE_DMON_RCV_FLAG_RPP_IS_NON_BLOCKING, UMESTORE_DMON_RCV_FLAG_KEEPALIVES_DISABLED.
Definition: umedmonmsgs.h:590
umestore_rcv_dmon_stat_msg_t_stct::high_ack_sqn
lbm_uint32_t high_ack_sqn
The last message sequence number the receiver acknowledged.
Definition: umedmonmsgs.h:575
umestore_repo_dmon_config_msg_t_stct
Message containing repository configuration defined during source registration. ( umestore_dmon_msg_...
Definition: umedmonmsgs.h:252
umestore_repo_dmon_stat_msg_t_stct::ulbs
lbm_uint32_t ulbs
Number of messages lost unrecoverably due to burst loss events.
Definition: umedmonmsgs.h:482
umestore_repo_dmon_config_msg_t_stct::hdr
umestore_dmon_msg_hdr_t hdr
Standard header common to all messages.
Definition: umedmonmsgs.h:254
lbm_uint32_t
uint32_t lbm_uint32_t
For portability.
Definition: lbm.h:1744
umestore_repo_dmon_stat_msg_t_stct::sz_limit_drops
lbm_uint32_t sz_limit_drops
Total number of messages dropped due to reaching the repository-size-limit.
Definition: umedmonmsgs.h:485
umestore_store_dmon_config_msg_t_stct
Message containing unchanging daemon information set at Store daemon startup. ( umestore_dmon_msg_hd...
Definition: umedmonmsgs.h:136
umestore_repo_dmon_stat_msg_t_stct::message_map_sz
lbm_uint32_t message_map_sz
Total number of UM message fragments the Store has for this source, both on disk and in memory...
Definition: umedmonmsgs.h:444
umestore_smart_heap_dmon_stat_msg_t_stct::poolcount
lbm_int64_t poolcount
Active allocation count (bytes) as reported by SmartHeap&#39;s MemPoolCount() function.
Definition: umedmonmsgs.h:384
umestore_smart_heap_dmon_stat_msg_t_stct::poolsize
lbm_int64_t poolsize
Memory usage (bytes) as reported by SmartHeap&#39;s MemPoolSize() function.
Definition: umedmonmsgs.h:381
umestore_store_pattern_dmon_config_msg_t_stct::hdr
umestore_dmon_msg_hdr_t hdr
Standard header common to all messages.
Definition: umedmonmsgs.h:185
umestore_store_dmon_config_msg_t_stct::store_max_retransmission_processing_rate
lbm_uint32_t store_max_retransmission_processing_rate
Value configured for the Store&#39;s option retransmission-request-processing-rate.
Definition: umedmonmsgs.h:148
umestore_rcv_dmon_stat_msg_t_stct::store_idx
lbm_uint16_t store_idx
Current Store number, starting with 0, counting each <store> element in the order configured...
Definition: umedmonmsgs.h:578
umestore_disk_dmon_stat_msg_t_stct::store_idx
lbm_uint16_t store_idx
Current Store number, starting with 0, counting each <store> element in the order configured...
Definition: umedmonmsgs.h:556
umestore_repo_dmon_stat_msg_t_stct::lead_sqn
lbm_uint32_t lead_sqn
Lead sequence number: newest sequence number in the Store.
Definition: umedmonmsgs.h:454
umestore_repo_dmon_config_msg_t_stct::dmon_topic_idx
lbm_uint32_t dmon_topic_idx
Identifying index number for the topic of this source, defined in an earlier message of type LBM_UMES...
Definition: umedmonmsgs.h:269
umestore_dmon_msg_hdr_t_stct::tv_sec
lbm_uint32_t tv_sec
Approximate timestamp when the message was sent. Represents local wall clock time in seconds after th...
Definition: umedmonmsgs.h:116
umestore_repo_dmon_stat_msg_t_stct::flags
lbm_uint8_t flags
Bit map of flags indicating various characteristics and current states of the Store. Possible bits: UMESTORE_DMON_REPO_FLAG_INTENTIONAL_DROPS, UMESTORE_DMON_REPO_FLAG_ISN_SET, UMESTORE_DMON_REPO_FLAG_DISK_CKSUM, UMESTORE_DMON_REPO_FLAG_SHUTTING_DOWN, UMESTORE_DMON_REPO_FLAG_RPP, UMESTORE_DMON_REPO_FLAG_DELAY_WRITE.
Definition: umedmonmsgs.h:497
umestore_store_dmon_config_msg_t
struct umestore_store_dmon_config_msg_t_stct umestore_store_dmon_config_msg_t
Message containing unchanging daemon information set at Store daemon startup. ( umestore_dmon_msg_hd...
umestore_repo_dmon_stat_msg_t_stct::mem_trail_sqn
lbm_uint32_t mem_trail_sqn
Trail sequence number: oldest sequence number in memory.
Definition: umedmonmsgs.h:465
umestore_disk_dmon_stat_msg_t_stct::hdr
umestore_dmon_msg_hdr_t hdr
Standard header common to all messages.
Definition: umedmonmsgs.h:531
umestore_store_dmon_stat_msg_t
struct umestore_store_dmon_stat_msg_t_stct umestore_store_dmon_stat_msg_t
Message containing Store message statistics. ( umestore_dmon_msg_hdr_t_stct::type == LBM_UMESTORE_DM...
umestore_disk_dmon_stat_msg_t_stct::dmon_topic_idx
lbm_uint32_t dmon_topic_idx
Identifying index number for the topic of this source, defined in an earlier message of type LBM_UMES...
Definition: umedmonmsgs.h:551
umestore_topic_dmon_config_msg_t_stct
Message containing topic name of one or more registered sources. ( umestore_dmon_msg_hdr_t_stct::typ...
Definition: umedmonmsgs.h:223
umestore_smart_heap_dmon_stat_msg_t
struct umestore_smart_heap_dmon_stat_msg_t_stct umestore_smart_heap_dmon_stat_msg_t
Message containing smart heap statistics. ( umestore_dmon_msg_hdr_t_stct::type == LBM_UMESTORE_DMON_...
umestore_repo_dmon_stat_msg_t_stct::regid
lbm_uint32_t regid
Registration ID used by the source to register.
Definition: umedmonmsgs.h:441
lbm_uint16_t
uint16_t lbm_uint16_t
For portability.
Definition: lbm.h:1742
umestore_store_dmon_config_msg_t_stct::disk_state_dir_offset
lbm_uint16_t disk_state_dir_offset
Byte offset from start of structure to start of Store&#39;s state directory name string (null-terminated)...
Definition: umedmonmsgs.h:163