UM C API 6.17.1

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

- File List
- Globals

umeprofile.h
Go to the documentation of this file.
1
13 /*
14 All of the documentation and software included in this and any
15 other Informatica Inc. Ultra Messaging Releases
16 Copyright (C) Informatica Inc. All rights reserved.
17
18 Redistribution and use in source and binary forms, with or without
19 modification, are permitted only as covered by the terms of a
20 valid software license agreement with Informatica Inc.
21
22 (C) Copyright 2004,2025 Informatica Inc. All Rights Reserved.
23
24 THE SOFTWARE IS PROVIDED "AS IS" AND INFORMATICA DISCLAIMS ALL WARRANTIES
25 EXPRESS OR IMPLIED, INCLUDING WITHOUT LIMITATION, ANY IMPLIED WARRANTIES OF
26 NON-INFRINGEMENT, MERCHANTABILITY OR FITNESS FOR A PARTICULAR
27 PURPOSE. INFORMATICA DOES NOT WARRANT THAT USE OF THE SOFTWARE WILL BE
28 UNINTERRUPTED OR ERROR-FREE. INFORMATICA SHALL NOT, UNDER ANY CIRCUMSTANCES, BE
29 LIABLE TO LICENSEE FOR LOST PROFITS, CONSEQUENTIAL, INCIDENTAL, SPECIAL OR
30 INDIRECT DAMAGES ARISING OUT OF OR RELATED TO THIS AGREEMENT OR THE
31 TRANSACTIONS CONTEMPLATED HEREUNDER, EVEN IF INFORMATICA HAS BEEN APPRISED OF
32 THE LIKELIHOOD OF SUCH DAMAGES.
33 */
34 #ifndef UME_PROFILE_H
35 #define UME_PROFILE_H
36
37 #if defined(__cplusplus)
38 extern "C" {
39 #endif /* __cplusplus */
40
41 /* Directives to show how we treat exporting functions with Windows from the DLL */
42 #if defined(_WIN32) && !defined(UMESTORE_STATIC_LIB)
43 # if defined(_DLL) && defined(UMESTORE_EXPORT_SYMS)
44 # define UMEStoreExpDLL __declspec(dllexport)
45 # elif defined(UMESTORE_STATIC_LIB)
46 # define UMEStoreExpDLL
47 # else
48 # define UMEStoreExpDLL __declspec(dllimport)
49 # endif /* _DLL && UMESTORE_EXPORT_SYMS */
50 #elif defined(__TANDEM)
51 # if defined(UMESTORE_EXPORT_SYMS)
52 # define UMEStoreExpDLL export$
53 # else
54 # define UMEStoreExpDLL import$
55 # endif
56 #else
57 # define UMEStoreExpDLL
58 #endif /* _WIN32 */
59
60 /* Limits & sizes */
61 #define LBM_SRP_MAX_DIRECTORY_STRLEN 256
62 /* MAX_PATH contains the full path and the filename so it must be bigger than MAX_DIRECTORY_STRLEN */
63 /* The filename is "/<regid>-state" or "/<regid>-cache" where regid is 10 digits worst case so 40 is with padding */
64 #define LBM_SRP_MAX_PATH_STRLEN (256 + 40)
65 #define LBM_SRP_TOPICNAME_MAX_LEN (256 + 8)
66 #define LBM_SRP_DISK_MAX_CKSUM_MSG_LEN 8192
67 #define LBM_SRP_LBMC_HDR_SZ 12
68
70 typedef enum {
72 LBM_SRP_SCAN_STATE_DIR_ERROR = -1,
74 LBM_SRP_FINDFFIRSTFILE_ERROR = -2,
76 LBM_SRP_FINDNEXTFILE_ERROR = -3
77 } lbm_srp_error_t;
78
81 typedef enum {
83 LBM_SRP_REPO_VALID = 1,
85 LBM_SRP_INVALID_STATE_FILE_NAME = -1,
87 LBM_SRP_STATE_FILE_OPEN_FAILURE = -2,
89 LBM_SRP_STATE_FILE_FSTAT_FAILURE = -3,
91 LBM_SRP_STATE_FILE_TOO_SMALL = -4,
93 LBM_SRP_STATE_FILE_GETSZ_FAILURE = -5,
95 LBM_SRP_STATE_FILE_READ_FAILURE = -6,
97 LBM_SRP_STATE_FILE_READ_TOO_SHORT = -7,
99 LBM_SRP_STATE_FILE_BAD_MAGIC = -8,
101 LBM_SRP_CACHE_FILE_OPEN_FAILURE = -9,
103 LBM_SRP_CACHE_MSG_CREATE_EVENT_FAILED = -10,
105 LBM_SRP_CACHE_MSG_READFILE_FAILED = -11,
107 LBM_SRP_CACHE_GETOVERLAPPEDRESULT_FAILED = -12,
109 LBM_SRP_CACHE_MSG_HEADER_UNDERSIZED = -13,
111 LBM_SRP_CACHE_MSG_HEADER_READ_MISMATCHED = -14,
113 LBM_SRP_CACHE_MSG_BAD_REC_HEADER_LENGTH = -15,
115 LBM_SRP_CACHE_MSG_BAD_CHECKSUM = -16,
117 LBM_SRP_CACHE_MSG_BAD_MRKR_HEADER_LENGTH = -17,
119 LBM_SRP_CACHE_MSG_UNKNOWN_HEADER = -18,
121 LBM_SRP_CACHE_MSG_MISSING_FIRST_REC = -19,
123 LBM_SRP_CACHE_MSG_FIRST_REC_SQN_MISMATCH = -20,
125 LBM_SRP_CACHE_MSG_MISSING_LAST_REC = -21,
127 LBM_SRP_CACHE_MSG_LAST_REC_SQN_MISMATCH = -22,
129 LBM_SRP_CACHE_MSG_SQN_OUT_OF_RANGE = -23,
131 LBM_SRP_CACHE_MSG_READ_LENGTH_MISMATCH = -24,
133 LBM_SRP_CACHE_DERIVED_LOW_SQN_MISMATCH = -25
134 } lbm_srp_repo_status_t;
135
138 typedef struct lbm_srp_repo_msg_t_stct {
140 lbm_uint32_t sqn;
142 lbm_uint8_t flags;
144 size_t disk_len;
146 lbm_uint64_t disk_offset;
148 struct timeval tsp;
150 char *buff;
152 lbm_uint8_t lbmc_ver_type;
154 lbm_uint8_t lbmc_next_hdr;
156 lbm_uint16_t lbmc_msglen;
158 lbm_uint32_t lbmc_tidx;
160 lbm_uint32_t lbmc_sqn;
162 lbm_uint8_t frag_next_hdr;
164 lbm_uint8_t frag_hdr_len;
166 lbm_uint16_t frag_flags;
168 lbm_uint32_t frag_first_sqn;
170 lbm_uint32_t frag_offset;
172 lbm_uint32_t frag_len;
174 lbm_uint32_t lbmc_msg_offset;
176 char fragment;
177 } lbm_srp_repo_msg_t;
178
182 typedef struct lbm_srp_repo_rcvr_t_stct {
184 lbm_uint32_t regid;
186 lbm_uint32_t sqn;
188 lbm_uint16_t store_id;
190 lbm_uint16_t rcv_port;
192 lbm_uint32_t rcv_addr;
194 lbm_uint32_t transport_idx;
196 lbm_uint32_t topic_idx;
198 lbm_uint64_t sid;
200 lbm_uint16_t flags;
202 lbm_uint8_t otid[LBM_OTID_BLOCK_SZ];
204 lbm_uint8_t ctxinst[LBM_CONTEXT_INSTANCE_BLOCK_SZ];
206 lbm_uint32_t rcv_domain_id;
208 lbm_ulong_t considered_activity_tmo;
210 lbm_ulong_t considered_state_lifetime;
211 } lbm_srp_repo_rcvr_t;
212
215 typedef struct lbm_srp_repo_t_stct {
217 char state_filename[LBM_SRP_MAX_PATH_STRLEN];
219 char cache_filename[LBM_SRP_MAX_PATH_STRLEN];
221 lbm_uint32_t ume_stored_version;
223 int cache_fd;
225 lbm_srp_repo_status_t repo_status;
227 int error_info;
229 lbm_uint32_t num_msgs;
231 lbm_uint32_t low_sqn;
233 lbm_uint32_t high_sqn;
235 lbm_uint64_t start_offset;
237 lbm_uint64_t end_offset;
239 void *msg_map;
241 int num_msg_duplicates;
243 char topicname[LBM_SRP_TOPICNAME_MAX_LEN];
245 lbm_uint32_t transport_idx;
247 lbm_uint32_t topic_idx;
249 lbm_uint32_t src_addr;
251 lbm_uint16_t src_port;
253 lbm_uint16_t store_id;
255 lbm_uint16_t num_rcvs;
257 lbm_uint16_t num_stores;
259 lbm_uint32_t num_grps;
261 lbm_uint64_t sid;
263 lbm_uint8_t otid[LBM_OTID_BLOCK_SZ];
265 lbm_uint8_t ctxinst[LBM_CONTEXT_INSTANCE_BLOCK_SZ];
267 lbm_uint8_t rpp_mode;
269 lbm_uint8_t repo_type;
271 lbm_ulong_t considered_src_activity_tmo;
273 lbm_ulong_t considered_src_state_lifetime;
275 size_t sz_threshold;
277 size_t sz_limit;
279 lbm_ulong_t disk_sz_limit;
281 lbm_uint32_t write_delay;
283 lbm_uint64_t src_flightsz_bytes;
285 lbm_uint32_t src_domain_id;
287 lbm_uint8_t allow_ack_on_reception;
289 lbm_uint8_t use_proxy;
291 lbm_srp_repo_rcvr_t * *rcvs;
292 } lbm_srp_repo_t;
293
296 typedef struct lbm_srp_t lbm_srp_t;
297
310 UMEStoreExpDLL int lbm_srp_create(const char *state_pathname, const char *cache_pathname, const int check_checksum, const lbm_srp_t * *srp_handle);
311
319 UMEStoreExpDLL int lbm_srp_delete(const lbm_srp_t * *srp_handle);
320
331 UMEStoreExpDLL int lbm_srp_get_repo_state(const lbm_srp_t * *srp_handle, int repo_idx, lbm_srp_repo_t * *srp_repo);
332
345 UMEStoreExpDLL int lbm_srp_get_repo_message(lbm_srp_repo_t *srp_repo, int sqn, lbm_srp_repo_msg_t *repo_msg);
346
354 UMEStoreExpDLL int lbm_srp_free_repo_state(lbm_srp_repo_t *srp_repo);
355
356 #if defined(__cplusplus)
357 }
358 #endif /* __cplusplus */
359
360 #endif /* UME_PROFILE_H */
LBM_SRP_CACHE_MSG_READ_LENGTH_MISMATCH
cache message read length actual did not match requested
Definition: umeprofile.h:131
lbm_srp_repo_msg_t_stct::tsp
struct timeval tsp
message timestamp
Definition: umeprofile.h:148
LBM_SRP_CACHE_MSG_MISSING_FIRST_REC
cache message first message record missing
Definition: umeprofile.h:121
lbm_srp_repo_msg_t
struct lbm_srp_repo_msg_t_stct lbm_srp_repo_msg_t
Information about a message in the repository, retrieved by lbm_srp_get_repo_message().
LBM_SRP_SCAN_STATE_DIR_ERROR
scandir failed
Definition: umeprofile.h:72
lbm_srp_delete
UMEStoreExpDLL int lbm_srp_delete(const lbm_srp_t **srp_handle)
Delete a store repository profile object.
lbm_srp_repo_msg_t_stct::lbmc_sqn
lbm_uint32_t lbmc_sqn
LBMC header sequence number.
Definition: umeprofile.h:160
lbm_srp_repo_t_stct::use_proxy
lbm_uint8_t use_proxy
use proxy source
Definition: umeprofile.h:289
lbm_srp_repo_t_stct::cache_fd
int cache_fd
opaque reference to the message cache file descriptor
Definition: umeprofile.h:223
LBM_SRP_CACHE_MSG_HEADER_READ_MISMATCHED
cache message header read length at working offset mismatched
Definition: umeprofile.h:111
LBM_SRP_CACHE_MSG_READFILE_FAILED
cache message read file [ReadFile] call failed at working offset
Definition: umeprofile.h:105
LBM_SRP_CACHE_FILE_OPEN_FAILURE
cache file open failed
Definition: umeprofile.h:101
lbm_srp_repo_msg_t_stct::frag_hdr_len
lbm_uint8_t frag_hdr_len
LBMC fragment header length.
Definition: umeprofile.h:164
lbm_srp_repo_msg_t_stct::lbmc_next_hdr
lbm_uint8_t lbmc_next_hdr
LBMC header next header.
Definition: umeprofile.h:154
lbm_srp_repo_t_stct::sz_limit
size_t sz_limit
size limit
Definition: umeprofile.h:277
LBM_SRP_CACHE_MSG_BAD_MRKR_HEADER_LENGTH
cache message header marker length at working offset was bad
Definition: umeprofile.h:117
LBM_SRP_CACHE_MSG_LAST_REC_SQN_MISMATCH
cache message last message record sequence number mismatch
Definition: umeprofile.h:127
lbm_srp_repo_t_stct::repo_status
lbm_srp_repo_status_t repo_status
repository status
Definition: umeprofile.h:225
LBM_SRP_CACHE_MSG_SQN_OUT_OF_RANGE
cache message sequence number out of range
Definition: umeprofile.h:129
lbm_srp_repo_t_stct::rpp_mode
lbm_uint8_t rpp_mode
receiver paced persistence mode
Definition: umeprofile.h:267
lbm_srp_repo_msg_t_stct::disk_len
size_t disk_len
message length on disk (includes LBM headers)
Definition: umeprofile.h:144
LBM_SRP_STATE_FILE_FSTAT_FAILURE
file status [fstat] call failed
Definition: umeprofile.h:89
lbm_srp_repo_rcvr_t_stct::sid
lbm_uint64_t sid
receiver session identifier
Definition: umeprofile.h:198
lbm_uint64_t
uint64_t lbm_uint64_t
For portability.
Definition: lbm.h:1748
lbm_srp_repo_msg_t_stct::buff
char * buff
message buffer pointer
Definition: umeprofile.h:150
lbm_srp_repo_msg_t_stct::lbmc_msg_offset
lbm_uint32_t lbmc_msg_offset
message offset
Definition: umeprofile.h:174
lbm_srp_repo_status_t
lbm_srp_repo_status_t
Repository status retrieved from lbm_srp_get_repo_state() via lbm_srp_repo_t_stct::repo_status.
Definition: umeprofile.h:81
lbm_srp_repo_msg_t_stct::frag_next_hdr
lbm_uint8_t frag_next_hdr
LBMC fragment header next header.
Definition: umeprofile.h:162
lbm_srp_repo_rcvr_t_stct
Receiver state information, retrieved by lbm_srp_get_repo_state() via lbm_srp_repo_t::rcvs.
Definition: umeprofile.h:182
LBM_SRP_STATE_FILE_OPEN_FAILURE
state file open call failed
Definition: umeprofile.h:87
lbm_srp_t
struct lbm_srp_t lbm_srp_t
SRP object (opaque) for UM.
Definition: umeprofile.h:296
lbm_srp_repo_rcvr_t_stct::considered_activity_tmo
lbm_ulong_t considered_activity_tmo
considered activity timeout
Definition: umeprofile.h:208
LBM_SRP_STATE_FILE_READ_TOO_SHORT
state file read byte count too short
Definition: umeprofile.h:97
lbm_srp_repo_rcvr_t_stct::rcv_domain_id
lbm_uint32_t rcv_domain_id
receive domain identifier
Definition: umeprofile.h:206
lbm_srp_error_t
lbm_srp_error_t
Possible error values returned by lbm_srp_create().
Definition: umeprofile.h:70
lbm_srp_repo_t_stct::disk_sz_limit
lbm_ulong_t disk_sz_limit
disk repository file size limit
Definition: umeprofile.h:279
lbm_srp_repo_rcvr_t_stct::regid
lbm_uint32_t regid
registration identifier
Definition: umeprofile.h:184
lbm_srp_repo_t_stct::src_domain_id
lbm_uint32_t src_domain_id
source domain identifier
Definition: umeprofile.h:285
lbm_srp_repo_t_stct::ume_stored_version
lbm_uint32_t ume_stored_version
store daemon version (n.n.n.n) that created the repository
Definition: umeprofile.h:221
LBM_SRP_FINDFFIRSTFILE_ERROR
FindFirstFile failed.
Definition: umeprofile.h:74
lbm_srp_repo_msg_t_stct::frag_flags
lbm_uint16_t frag_flags
LBMC fragment header flags.
Definition: umeprofile.h:166
lbm_srp_repo_msg_t_stct::frag_len
lbm_uint32_t frag_len
LBMC fragment header message length.
Definition: umeprofile.h:172
lbm_srp_repo_msg_t_stct::fragment
char fragment
1 means the message was a fragment
Definition: umeprofile.h:176
lbm_srp_repo_t_stct::start_offset
lbm_uint64_t start_offset
disk byte offset of the lowest sequence number in the repository cache
Definition: umeprofile.h:235
lbm_srp_free_repo_state
UMEStoreExpDLL int lbm_srp_free_repo_state(lbm_srp_repo_t *srp_repo)
Free store repository profile state object.
lbm_srp_repo_t_stct::sz_threshold
size_t sz_threshold
size threshold
Definition: umeprofile.h:275
lbm_srp_create
UMEStoreExpDLL int lbm_srp_create(const char *state_pathname, const char *cache_pathname, const int check_checksum, const lbm_srp_t **srp_handle)
Create and fill a store repository profile object.
LBM_SRP_CACHE_DERIVED_LOW_SQN_MISMATCH
Definition: umeprofile.h:133
lbm_srp_repo_msg_t_stct
Information about a message in the repository, retrieved by lbm_srp_get_repo_message().
Definition: umeprofile.h:138
lbm_srp_repo_rcvr_t
struct lbm_srp_repo_rcvr_t_stct lbm_srp_repo_rcvr_t
Receiver state information, retrieved by lbm_srp_get_repo_state() via lbm_srp_repo_t::rcvs.
LBM_SRP_STATE_FILE_TOO_SMALL
state file too small
Definition: umeprofile.h:91
LBM_SRP_CACHE_MSG_MISSING_LAST_REC
cache message last message record missing
Definition: umeprofile.h:125
lbm_srp_repo_t_stct::low_sqn
lbm_uint32_t low_sqn
lowest sequence number in the repository cache
Definition: umeprofile.h:231
lbm_srp_repo_rcvr_t_stct::considered_state_lifetime
lbm_ulong_t considered_state_lifetime
considered state lifetime
Definition: umeprofile.h:210
lbm_uint8_t
uint8_t lbm_uint8_t
For portability.
Definition: lbm.h:1740
LBM_SRP_CACHE_MSG_BAD_REC_HEADER_LENGTH
cache message header record length at working offset was bad
Definition: umeprofile.h:113
lbm_srp_get_repo_state
UMEStoreExpDLL int lbm_srp_get_repo_state(const lbm_srp_t **srp_handle, int repo_idx, lbm_srp_repo_t **srp_repo)
Get store repository profile state object.
lbm_srp_repo_t_stct::transport_idx
lbm_uint32_t transport_idx
source transport index
Definition: umeprofile.h:245
lbm_srp_repo_t_stct::src_port
lbm_uint16_t src_port
source IP port
Definition: umeprofile.h:251
lbm_srp_repo_t_stct::considered_src_state_lifetime
lbm_ulong_t considered_src_state_lifetime
considered state lifetime
Definition: umeprofile.h:273
LBM_SRP_STATE_FILE_READ_FAILURE
state file read call failed
Definition: umeprofile.h:95
lbm_srp_repo_msg_t_stct::lbmc_tidx
lbm_uint32_t lbmc_tidx
LBMC header topic index.
Definition: umeprofile.h:158
LBM_SRP_CACHE_GETOVERLAPPEDRESULT_FAILED
cache get overlapped result [GetOverlappedResult] call failed at working offset
Definition: umeprofile.h:107
lbm_srp_repo_t_stct::end_offset
lbm_uint64_t end_offset
disk byte offset of the highest sequence number in the repository cache
Definition: umeprofile.h:237
lbm_srp_repo_rcvr_t_stct::sqn
lbm_uint32_t sqn
high ack sequence number
Definition: umeprofile.h:186
lbm_srp_repo_rcvr_t_stct::rcv_addr
lbm_uint32_t rcv_addr
receiver IP address
Definition: umeprofile.h:192
lbm_srp_repo_msg_t_stct::disk_offset
lbm_uint64_t disk_offset
message offset on disk
Definition: umeprofile.h:146
lbm_srp_repo_msg_t_stct::frag_offset
lbm_uint32_t frag_offset
LBMC fragment header message offset.
Definition: umeprofile.h:170
LBM_SRP_INVALID_STATE_FILE_NAME
state file name is invalid
Definition: umeprofile.h:85
lbm_srp_repo_t_stct::considered_src_activity_tmo
lbm_ulong_t considered_src_activity_tmo
considered activity timeout
Definition: umeprofile.h:271
LBM_SRP_CACHE_MSG_BAD_CHECKSUM
cache message at working offset has bad checksum
Definition: umeprofile.h:115
lbm_srp_repo_msg_t_stct::flags
lbm_uint8_t flags
message flags
Definition: umeprofile.h:142
lbm_srp_repo_t_stct::src_flightsz_bytes
lbm_uint64_t src_flightsz_bytes
source flight size in bytes
Definition: umeprofile.h:283
lbm_srp_repo_rcvr_t_stct::store_id
lbm_uint16_t store_id
store identifier
Definition: umeprofile.h:188
lbm_ulong_t
unsigned long int lbm_ulong_t
For portability.
Definition: lbm.h:1734
LBM_SRP_STATE_FILE_BAD_MAGIC
state file has bad magic
Definition: umeprofile.h:99
LBM_SRP_CACHE_MSG_FIRST_REC_SQN_MISMATCH
cache message first message record sequence number mismatch
Definition: umeprofile.h:123
lbm_srp_repo_t_stct::allow_ack_on_reception
lbm_uint8_t allow_ack_on_reception
allow acknowledge on reception
Definition: umeprofile.h:287
lbm_srp_repo_msg_t_stct::sqn
lbm_uint32_t sqn
message sequence number
Definition: umeprofile.h:140
lbm_srp_repo_msg_t_stct::lbmc_msglen
lbm_uint16_t lbmc_msglen
LBMC header message length.
Definition: umeprofile.h:156
lbm_srp_repo_msg_t_stct::frag_first_sqn
lbm_uint32_t frag_first_sqn
LBMC fragment header first sequence number.
Definition: umeprofile.h:168
lbm_srp_repo_t_stct::rcvs
lbm_srp_repo_rcvr_t ** rcvs
pointers to registered repository receivers
Definition: umeprofile.h:291
LBM_SRP_STATE_FILE_GETSZ_FAILURE
file status [GetFileSizeEx] call failed
Definition: umeprofile.h:93
lbm_srp_repo_rcvr_t_stct::flags
lbm_uint16_t flags
flags
Definition: umeprofile.h:200
LBM_SRP_FINDNEXTFILE_ERROR
FindNextFile failed.
Definition: umeprofile.h:76
lbm_srp_repo_t_stct::num_stores
lbm_uint16_t num_stores
number of stores out of the block of 25 that are in use
Definition: umeprofile.h:257
lbm_srp_repo_t_stct::num_msg_duplicates
int num_msg_duplicates
the number of message duplicates in the repository cache
Definition: umeprofile.h:241
lbm_srp_repo_t_stct
Overall information about a store, retrieved by lbm_srp_get_repo_state()
Definition: umeprofile.h:215
lbm_srp_repo_rcvr_t_stct::rcv_port
lbm_uint16_t rcv_port
receiver IP port
Definition: umeprofile.h:190
LBM_SRP_CACHE_MSG_UNKNOWN_HEADER
cache message at working offset has unknown header type
Definition: umeprofile.h:119
lbm_srp_get_repo_message
UMEStoreExpDLL int lbm_srp_get_repo_message(lbm_srp_repo_t *srp_repo, int sqn, lbm_srp_repo_msg_t *repo_msg)
Get store repository profile message.
lbm_srp_repo_t_stct::src_addr
lbm_uint32_t src_addr
source IP address
Definition: umeprofile.h:249
lbm_srp_repo_t_stct::repo_type
lbm_uint8_t repo_type
repository type
Definition: umeprofile.h:269
LBM_SRP_REPO_VALID
Repository is valid.
Definition: umeprofile.h:83
lbm_uint32_t
uint32_t lbm_uint32_t
For portability.
Definition: lbm.h:1744
lbm_srp_repo_t_stct::num_grps
lbm_uint32_t num_grps
number of groups out of the block of 5 that are in use
Definition: umeprofile.h:259
lbm_srp_repo_rcvr_t_stct::transport_idx
lbm_uint32_t transport_idx
receiver transport index
Definition: umeprofile.h:194
LBM_SRP_CACHE_MSG_HEADER_UNDERSIZED
cache message header at working offset too small
Definition: umeprofile.h:109
lbm_srp_repo_t_stct::store_id
lbm_uint16_t store_id
store identifier
Definition: umeprofile.h:253
lbm_srp_repo_msg_t_stct::lbmc_ver_type
lbm_uint8_t lbmc_ver_type
LBMC header version/type.
Definition: umeprofile.h:152
lbm_srp_repo_t_stct::num_rcvs
lbm_uint16_t num_rcvs
number of receivers
Definition: umeprofile.h:255
lbm_srp_repo_t_stct::sid
lbm_uint64_t sid
source session identifier
Definition: umeprofile.h:261
lbm_srp_repo_t_stct::high_sqn
lbm_uint32_t high_sqn
highest sequence number in the repository cache
Definition: umeprofile.h:233
lbm_srp_repo_t_stct::msg_map
void * msg_map
opaque reference to the message cache
Definition: umeprofile.h:239
lbm_srp_repo_t_stct::write_delay
lbm_uint32_t write_delay
write delay
Definition: umeprofile.h:281
lbm_srp_repo_t_stct::error_info
int error_info
error information, e.g., errno/errnum
Definition: umeprofile.h:227
lbm_srp_repo_rcvr_t_stct::topic_idx
lbm_uint32_t topic_idx
topic index
Definition: umeprofile.h:196
LBM_SRP_CACHE_MSG_CREATE_EVENT_FAILED
cache message create event [CreateEvent] call failed at working offset
Definition: umeprofile.h:103
lbm_srp_repo_t_stct::topic_idx
lbm_uint32_t topic_idx
source topic index
Definition: umeprofile.h:247
lbm_uint16_t
uint16_t lbm_uint16_t
For portability.
Definition: lbm.h:1742
lbm_srp_repo_t_stct::num_msgs
lbm_uint32_t num_msgs
the number of messages in the repository cache
Definition: umeprofile.h:229
lbm_srp_repo_t
struct lbm_srp_repo_t_stct lbm_srp_repo_t
Overall information about a store, retrieved by lbm_srp_get_repo_state()