Functions — github.com/bloomberg/blazingmq

CodeHub MCPcopy Create free account

hub / github.com/bloomberg/blazingmq / functions

Functions9,318 in github.com/bloomberg/blazingmq

⨍ Functions 9,318◇ Types & classes 2,131

↓ 4 callersMethodhasNoHandleStreamProducers

src/groups/mqb/mqbi/mqbi_queue.h:1085

↓ 4 callersMethodhasReceipt

src/groups/mqb/mqbi/mqbi_storage.h:722

↓ 4 callersMethodhighResTimer

src/groups/mwc/mwcsys/mwcsys_mocktime.cpp:103

↓ 4 callersMethodhighWatermark

src/groups/mwc/mwcc/mwcc_monitoredqueue.h:753

↓ 4 callersMethodincrements

src/groups/mwc/mwcst/mwcst_statvalue.h:489

↓ 4 callersMethodinvalidate

src/groups/mqb/mqbblp/mqbblp_queueengineutil.h:727

↓ 4 callersMethodisClusterStateEvent

src/groups/bmq/bmqp/bmqp_event.h:472

↓ 4 callersMethodisEnabled

src/groups/bmq/bmqimp/bmqimp_messagedumper.h:260

↓ 4 callersMethodisFSMWorkflow

src/groups/mqb/mqbblp/mqbblp_cluster.cpp:3592

↓ 4 callersMethodisFileBackedValue

src/groups/mqb/mqbconfm/mqbconfm_messages.h:7062

↓ 4 callersMethodisHeartbeatRspEvent

src/groups/bmq/bmqp/bmqp_event.h:520

↓ 4 callersMethodisHostHealthy

src/groups/bmq/bmqimp/bmqimp_brokersession.cpp:5349

↓ 4 callersMethodisIncoming

src/groups/mqb/mqbnet/mqbnet_negotiator.h:266

↓ 4 callersMethodisPrimaryForPartition

src/groups/mqb/mqbc/mqbc_clusternodesession.cpp:167

↓ 4 callersMethodisRecoveryInProgress

src/groups/mqb/mqbblp/mqbblp_recoverymanager.h:1888

↓ 4 callersMethodisRejectEvent

src/groups/bmq/bmqp/bmqp_event.h:528

↓ 4 callersMethodisRunningOnDev

src/groups/mqb/mqbcfg/mqbcfg_messages.h:15266

↓ 4 callersMethodisSelfActivePrimary

src/groups/mqb/mqbc/mqbc_clusterstate.h:949

↓ 4 callersMethodisValid

src/groups/mqb/mqbnet/mqbnet_channel.t.cpp:246

↓ 4 callersMethodlastErrorMessage

src/groups/bmq/bmqeval/bmqeval_simpleevaluator.h:957

↓ 4 callersMethodledger

src/groups/mqb/mqbc/mqbc_incoreclusterstateledger.h:500

↓ 4 callersMethodloadAppIdHashes

src/groups/mqb/mqbs/mqbs_qlistfileiterator.cpp:339

↓ 4 callersMethodloadAppIds

src/groups/mqb/mqbs/mqbs_qlistfileiterator.cpp:304

↓ 4 callersFunctionloadUpdatesFromValues

Load into the specified `updates` corresponding updates from the specified `values` vector based on the specified `mask`, if `values` is non-zero, and

src/groups/mwc/mwcst/mwcst_statcontext.cpp:111

↓ 4 callersMethodlogsObserverMaxSize

src/groups/mqb/mqbcfg/mqbcfg_messages.h:15271

↓ 4 callersMethodlookupQueue

src/groups/bmq/bmqimp/bmqimp_brokersession.cpp:6930

↓ 4 callersMethodlowWatermark

src/groups/mwc/mwcc/mwcc_monitoredqueue.h:746

↓ 4 callersMethodmagic1

src/groups/mqb/mqbs/mqbs_filestoreprotocol.h:2152

↓ 4 callersMethodmagic2

src/groups/mqb/mqbs/mqbs_filestoreprotocol.h:2157

↓ 4 callersMethodmakeStorage

src/groups/mqb/mqbc/mqbc_storageutil.cpp:2405

↓ 4 callersMethodmaxArchivedFileSets

src/groups/mqb/mqbs/mqbs_datastore.h:1109

↓ 4 callersMethodmaxMissedHeartbeat

src/groups/mqb/mqbnet/mqbnet_negotiator.h:276

↓ 4 callersMethodmaxMsgGroupIds

src/groups/mqb/mqbblp/mqbblp_messagegroupidmanager.cpp:713

↓ 4 callersMethodmaxUnconfirmedBytes

src/groups/bmq/bmqt/bmqt_queueoptions.h:290

↓ 4 callersMethodmaxUnconfirmedMessages

src/groups/bmq/bmqt/bmqt_queueoptions.h:285

↓ 4 callersFunctionmergeObjects

docs/assets/animations/libs/anime.js:342

↓ 4 callersMethodmessageReferenceCount

src/groups/mqb/mqbblp/mqbblp_relayqueueengine.h:625

↓ 4 callersMethodmonotonicClock

src/groups/mwc/mwcsys/mwcsys_mocktime.cpp:98

↓ 4 callersMethodnewSyncPointOffset

src/groups/mqb/mqbblp/mqbblp_recoverymanager.h:1490

↓ 4 callersMethodnumAttempts

src/groups/mwc/mwcio/mwcio_connectoptions.h:216

↓ 4 callersFunctionnumFlagsSet

Return the number of flags set in the flags member of the specified `config`.

src/groups/bmq/bmqp/bmqp_routingconfigurationutils.t.cpp:51

↓ 4 callersFunctionnumFlagsUnset

Return the number of flags not set in the flags member of the specified `config`.

src/groups/bmq/bmqp/bmqp_routingconfigurationutils.t.cpp:59

↓ 4 callersMethodnumQueues

src/groups/mwc/mwcc/mwcc_multiqueuethreadpool.h:1532

↓ 4 callersMethodoldSyncPointOffset

src/groups/mqb/mqbblp/mqbblp_recoverymanager.h:1478

↓ 4 callersMethodonPushEvent

src/groups/bmq/bmqimp/bmqimp_queuemanager.cpp:322

↓ 4 callersMethodopenQueue

src/groups/bmq/bmqa/bmqa_session.cpp:906

↓ 4 callersMethodopenQueueAsync

src/groups/bmq/bmqa/bmqa_abstractsession.t.cpp:120

↓ 4 callersMethodoptionsSize

src/groups/bmq/bmqp/bmqp_putmessageiterator.h:559

↓ 4 callersMethodpackPutMessage

src/groups/bmq/bmqimp/bmqimp_messagedumper.t.cpp:463

↓ 4 callersFunctionparseCommand

entry point (i.e. `root`) of the command parsing

src/groups/mqb/mqbcmd/mqbcmd_parseutil.cpp:227

↓ 4 callersFunctionparseMessages

Populate the specified `messages` with messages parsed from the specified `messagesStr`. The format of `messagesStr` must be: `<msg1>,<msg2>,...,<msg

src/groups/mqb/mqbblp/mqbblp_queueenginetester.cpp:150

↓ 4 callersMethodpayloadSize

----------------------------- struct OptionUtil::OptionMeta ----------------------------- ACCESSORS

src/groups/bmq/bmqp/bmqp_optionutil.h:250

↓ 4 callersFunctionpopulateBlob

Populate specified `blob` with a STORAGE event which has specified `numMsgs` storage messages, update specified `eh` with corresponding EventHeader, a

src/groups/bmq/bmqp/bmqp_storagemessageiterator.t.cpp:94

↓ 4 callersMethodpopulateRequest

src/groups/mqb/mqbnet/mqbnet_multirequestmanager.t.cpp:423

↓ 4 callersFunctionprintProcessedItems

src/groups/mwc/mwcc/mwcc_monitoredqueue_bdlccfixedqueue.t.cpp:110

↓ 4 callersFunctionprintProcessedItems

src/groups/mwc/mwcc/mwcc_multiqueuethreadpool.t.cpp:119

↓ 4 callersFunctionprintProcessedItems

src/groups/mwc/mwcc/mwcc_monitoredqueue_bdlccsingleconsumerqueue.t.cpp:111

↓ 4 callersFunctionprintStartStopTrace

Print the start/stop trace for the specified `action` (starting, started, stopping, stopped, ...) for the specified `instance` (could be empty).

src/applications/bmqbrkr/bmqbrkr.m.cpp:224

↓ 4 callersFunctionprintValue

src/groups/mqb/mqbcmd/mqbcmd_humanprinter.cpp:213

↓ 4 callersMethodprocessFollowerLSNRequest

src/groups/mqb/mqbc/mqbc_clusterstatemanager.cpp:1571

↓ 4 callersMethodprocessStorageEvent

src/groups/mqb/mqbblp/mqbblp_storagemanager.cpp:2402

↓ 4 callersMethodqlistFileOffset

src/groups/mqb/mqbblp/mqbblp_recoverymanager.h:1508

↓ 4 callersMethodqueueHighWatermark

src/groups/mqb/mqbcfg/mqbcfg_messages.h:11298

↓ 4 callersMethodqueueLowWatermark

src/groups/mqb/mqbcfg/mqbcfg_messages.h:11303

↓ 4 callersMethodqueueThreadHandle

src/groups/mwc/mwcc/mwcc_multiqueuethreadpool.h:1538

↓ 4 callersMethodrealtimeClock

src/groups/mwc/mwcsys/mwcsys_mocktime.cpp:93

↓ 4 callersMethodrefCount

src/groups/mqb/mqbi/mqbi_storage.h:711

↓ 4 callersFunctionregexMatch

Match the specified `str` against the specified `pattern` using the specified `allocator` and return true on success, false otherwise. The matching i

src/groups/mwc/mwcsys/mwcsys_statmonitorsnapshotrecorder.t.cpp:48

↓ 4 callersMethodremove

src/groups/bmq/bmqimp/bmqimp_messagecorrelationidcontainer.cpp:182

↓ 4 callersMethodremove

src/groups/mqb/mqbs/mqbs_inmemorystorage.cpp:286

↓ 4 callersMethodremoveClient

src/groups/mqb/mqbu/mqbu_loadbalancer.h:236

↓ 4 callersMethodreserveCapacity

src/groups/mwc/mwcu/mwcu_memoutstream.h:189

↓ 4 callersMethodreset

src/groups/mqb/mqbc/mqbc_recoverymanager.cpp:104

↓ 4 callersMethodresetSubStreamCount

src/groups/bmq/bmqimp/bmqimp_queuemanager.cpp:499

↓ 4 callersMethodresize

src/groups/mwc/mwcu/mwcu_blobobjectproxy.h:709

↓ 4 callersMethodrotationBytes

src/groups/mqb/mqbcfg/mqbcfg_messages.h:13313

↓ 4 callersMethodsendClusterState

src/groups/mqb/mqbblp/mqbblp_clusterstatemanager.cpp:1223

↓ 4 callersMethodsendPush

Sends a `Push` event for the specified `queueId`, `msgGUID` and `correlationId` with `isAckRequested` flag to this testbench's `ClientSession`.

src/groups/mqb/mqba/mqba_clientsession.t.cpp:898

↓ 4 callersMethodsendRequest

src/groups/mqb/mqbnet/mqbnet_multirequestmanager.t.cpp:377

↓ 4 callersFunctionsetAnimationsProgress

docs/assets/animations/libs/anime.js:965

↓ 4 callersMethodsetExpectedChunkFileType

src/groups/mqb/mqbblp/mqbblp_recoverymanager.h:1353

↓ 4 callersMethodsetNeedsPartitionSync

src/groups/mqb/mqbblp/mqbblp_recoverymanager.h:1596

↓ 4 callersMethodsetOldSyncPoint

src/groups/mqb/mqbblp/mqbblp_recoverymanager.h:1383

↓ 4 callersMethodsetOldSyncPointOffset

src/groups/mqb/mqbblp/mqbblp_recoverymanager.h:1389

↓ 4 callersMethodsetPrimaryStatus

src/groups/mqb/mqbblp/mqbblp_clusterstatemanager.cpp:1104

↓ 4 callersMethodsetQueue

src/groups/mqb/mqbs/mqbs_virtualstorage.cpp:92

↓ 4 callersFunctionsnapshotValueVec

src/groups/mwc/mwcst/mwcst_statcontext.cpp:63

↓ 4 callersMethodsplit

src/groups/bmq/bmqp/bmqp_protocol.h:3688

↓ 4 callersMethodstop

src/groups/bmq/bmqimp/bmqimp_application.cpp:731

↓ 4 callersMethodstop

src/groups/mwc/mwcio/mwcio_ntcchannelfactory.cpp:265

↓ 4 callersMethodstop

src/groups/mwc/mwcc/mwcc_multiqueuethreadpool.h:1357

↓ 4 callersMethodstopAsync

src/groups/bmq/bmqa/bmqa_session.cpp:756

↓ 4 callersMethodsum

src/groups/mwc/mwcst/mwcst_statvalue.h:507

↓ 4 callersMethodswap

src/groups/mwc/mwcu/mwcu_operationchain.cpp:408

↓ 4 callersFunctiontest

This implements the core testing functionality. Implements a test run for the configuration defined by the specified `clientType`, `atMostOnce`, `put

src/groups/mqb/mqba/mqba_clientsession.t.cpp:1064

↓ 4 callersMethodtimedPopFront

src/groups/mwc/mwcc/mwcc_monitoredqueue.h:654

↓ 4 callersMethodtoHex

src/groups/bmq/bmqt/bmqt_messageguid.cpp:116

↓ 4 callersMethodtotalElapsed

src/groups/mwc/mwcsys/mwcsys_statmonitorsnapshotrecorder.cpp:184

↓ 4 callersMethodtryLock

src/groups/mwc/mwcu/mwcu_atomicstate.h:106

↓ 4 callersMethodunregisterObserver

src/groups/mqb/mqbnet/mqbnet_clusterimp.cpp:228

← previous next →1,401–1,500 of 9,318, ranked by callers