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

↓ 12 callersMethodload

src/groups/mqb/mqbc/mqbc_clusterutil.cpp:1963

↓ 12 callersMethodmaxSize

src/groups/mqb/mqbsi/mqbsi_log.h:531

↓ 12 callersMethodmaxTimeLeader

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

↓ 12 callersMethodmessageCorrelationIdContainer

src/groups/bmq/bmqimp/bmqimp_event.h:602

↓ 12 callersMethodmultiplex

src/groups/bmq/bmqp/bmqp_schemalearner.cpp:159

↓ 12 callersMethodnumProcessors

src/groups/mqb/mqba/mqba_dispatcher.h:595

↓ 12 callersMethodnumVirtualStorages

src/groups/mqb/mqbs/mqbs_inmemorystorage.h:793

↓ 12 callersMethodpopFront

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

↓ 12 callersMethodpostInterval

src/applications/bmqtool/m_bmqtool_messages.h:10250

↓ 12 callersMethodpreallocate

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

↓ 12 callersMethodrecordType

src/groups/mqb/mqbs/mqbs_journalfileiterator.h:282

↓ 12 callersMethodsendChannelRequest

src/groups/bmq/bmqp/bmqp_requestmanager.t.cpp:345

↓ 12 callersMethodsetGroupId

src/groups/mqb/mqbnet/mqbnet_multirequestmanager.h:507

↓ 12 callersMethodsetNode

Set specified `node` to specified `isActive` state.

src/groups/mqb/mqbblp/mqbblp_clusterstatemonitor.t.cpp:239

↓ 12 callersMethodstart

src/groups/mqb/mqba/mqba_dispatcher.cpp:470

↓ 12 callersMethodstop

src/groups/mwc/mwcex/mwcex_sequentialcontext.cpp:154

↓ 12 callersMethodstring

src/groups/mwc/mwcst/mwcst_stringkey.h:264

↓ 12 callersMethodthresholdFailover

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

↓ 12 callersMethodthresholdLeader

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

↓ 12 callersMethodtryPopFront

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

↓ 12 callersMethodtypeSpecific

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

↓ 12 callersMethod~Error

src/groups/mqb/mqbcmd/mqbcmd_messages.cpp:1757

↓ 11 callersMethodackPuts

src/groups/mqb/mqbblp/mqbblp_remotequeue.t.cpp:244

↓ 11 callersMethodadd

src/groups/bmq/bmqp/bmqp_optionutil.cpp:101

↓ 11 callersMethodbyteLowWatermarkRatio

src/groups/mqb/mqbu/mqbu_resourceusagemonitor.h:613

↓ 11 callersMethodclientsCountForProcessor

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

↓ 11 callersMethodcloseQueueSync

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

↓ 11 callersMethodconfigure

src/groups/mqb/mqbblp/mqbblp_queue.cpp:623

↓ 11 callersMethodcreateThread

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

↓ 11 callersMethodend

src/groups/mwc/mwcc/mwcc_twokeyhashmap.h:1447

↓ 11 callersMethodend

src/groups/mwc/mwcc/mwcc_orderedhashmapwithhistory.h:491

↓ 11 callersMethodenqueueSessionEvent

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

↓ 11 callersMethodeventsCount

src/applications/bmqtool/m_bmqtool_parameters.h:652

↓ 11 callersFunctionfillDTSpanQueueBaggage

Fills `baggage` with metadata from `queue` that should be added to every Distributed Trace span which represents an operation on a queue.

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

↓ 11 callersMethodflags

src/groups/bmq/bmqa/bmqa_queueid.cpp:106

↓ 11 callersMethodgenerateOldLogs

src/groups/mqb/mqbsl/mqbsl_ledger.t.cpp:213

↓ 11 callersFunctiongetConsumerInfo

src/groups/bmq/bmqimp/bmqimp_brokersession.t.cpp:302

↓ 11 callersMethodgetIterator

src/groups/mqb/mqbblp/mqbblp_storagemanager.h:901

↓ 11 callersMethodgetIterator

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

↓ 11 callersMethodidsForHandle

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

↓ 11 callersMethodisEmpty

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

↓ 11 callersMethodisLocalTimeout

src/groups/bmq/bmqp/bmqp_requestmanager.h:980

↓ 11 callersMethodisPartitionSyncEvent

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

↓ 11 callersMethoditeratePendingMessages

src/groups/mqb/mqbblp/mqbblp_remotequeue.cpp:1247

↓ 11 callersMethodloadAckMessageIterator

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

↓ 11 callersMethodloadConfirmMessageIterator

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

↓ 11 callersMethodloadMessagePropertiesPosition

src/groups/bmq/bmqp/bmqp_putmessageiterator.cpp:234

↓ 11 callersMethodmaxTimeMaster

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

↓ 11 callersMethodmessageLowWatermarkRatio

src/groups/mqb/mqbu/mqbu_resourceusagemonitor.h:638

↓ 11 callersMethodminor

src/groups/bmq/bmqt/bmqt_version.h:169

↓ 11 callersMethodonWatermark

src/groups/mqb/mqbnet/mqbnet_channel.cpp:348

↓ 11 callersMethodopenQueue

src/groups/mqb/mqbblp/mqbblp_clusterqueuehelper.cpp:4559

↓ 11 callersMethodport

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

↓ 11 callersMethodprocessPrimaryDetect

src/groups/mqb/mqbc/mqbc_storagemanager.cpp:3036

↓ 11 callersMethodprocessorHandle

src/groups/mqb/mqbi/mqbi_dispatcher.h:1780

↓ 11 callersMethodpushMessageIterator

src/groups/bmq/bmqimp/bmqimp_event.h:761

↓ 11 callersMethodputMessageIterator

src/groups/bmq/bmqimp/bmqimp_event.h:781

↓ 11 callersMethodrelease

src/groups/mwc/mwcu/mwcu_objectplaceholder_cpp03.h:391

↓ 11 callersMethodreset

src/groups/bmq/bmqa/bmqa_messageeventbuilder.cpp:176

↓ 11 callersMethodreset

src/groups/mwc/mwcc/mwcc_array.h:330

↓ 11 callersMethodshutdownGrace

src/applications/bmqtool/m_bmqtool_messages.h:10275

↓ 11 callersMethodsnapshot

src/groups/mwc/mwcsys/mwcsys_statmonitor.cpp:251

↓ 11 callersMethodstate

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

↓ 11 callersMethodstop

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

↓ 11 callersMethodstop

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

↓ 11 callersMethodverifyPrimarySendsReplicaStateRqst

src/groups/mqb/mqbc/mqbc_storagemanager.t.cpp:215

↓ 11 callersMethodwaitQueueSuspendedEvent

src/groups/bmq/bmqimp/bmqimp_brokersession.t.cpp:2335

↓ 10 callersMethodackMessageIterator

src/groups/bmq/bmqimp/bmqimp_event.h:771

↓ 10 callersMethodactiveNode

src/groups/mqb/mqbnet/mqbnet_clusteractivenodemanager.h:353

↓ 10 callersFunctionaddHandles

src/groups/mqb/mqbblp/mqbblp_messagegroupidmanager.t.cpp:80

↓ 10 callersMethodasPutEvent

src/groups/mqb/mqbi/mqbi_dispatcher.h:1670

↓ 10 callersMethodblobBufferSize

src/groups/bmq/bmqt/bmqt_sessionoptions.h:525

↓ 10 callersMethodblobSpPool

src/groups/mqb/mqbc/mqbc_clusterdata.h:384

↓ 10 callersMethodbroadcastedMessage

src/groups/mqb/mqbc/mqbc_incoreclusterstateledger.t.cpp:409

↓ 10 callersMethodbufferFactory

src/groups/mqb/mqbc/mqbc_clusterstateledgerutil.t.cpp:194

↓ 10 callersMethodbytesWatermarkRatio

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

↓ 10 callersMethodclose

src/groups/mqb/mqbblp/mqbblp_queue.cpp:739

↓ 10 callersMethodconfigure

src/groups/mqb/mqbs/mqbs_inmemorystorage.t.cpp:434

↓ 10 callersMethoddispatcherFlush

src/groups/mqb/mqbs/mqbs_filestore.cpp:6786

↓ 10 callersMethodemplaceValue

src/groups/mwc/mwcex/mwcex_future.h:1669

↓ 10 callersMethodend

src/groups/bmq/bmqp/bmqp_protocolutil.h:1264

↓ 10 callersMethodenqueueEvent

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

↓ 10 callersMethoderaseByKey1

src/groups/mwc/mwcc/mwcc_twokeyhashmap.h:1338

↓ 10 callersMethodeventQueueHighWatermark

src/groups/bmq/bmqt/bmqt_sessionoptions.h:587

↓ 10 callersMethodeventSize

src/applications/bmqtool/m_bmqtool_messages.h:10225

↓ 10 callersMethodfieldMask

src/groups/mwc/mwcstm/mwcstm_values.h:2590

↓ 10 callersMethodfuture

src/groups/mwc/mwcex/mwcex_promise.h:705

↓ 10 callersFunctiongenerateRandomInteger

Return a 15-bit random number between the specified `min` and the specified `max`, inclusive. The behavior is undefined unless `min >= 0` and `max >=

src/groups/bmq/bmqp/bmqp_pushmessageiterator.t.cpp:171

↓ 10 callersFunctiongenerateStorageKeys

Populate the specified `keys` with the specified `numKeys` number of randomly generated `StorageKey`.

src/groups/mqb/mqbu/mqbu_storagekey.t.cpp:91

↓ 10 callersFunctiongetAttribute

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

↓ 10 callersMethodgetOutboundEvent

src/groups/bmq/bmqimp/bmqimp_brokersession.t.cpp:2388

↓ 10 callersMethodhasMaxUnconfirmedBytes

src/groups/bmq/bmqt/bmqt_subscription.h:483

↓ 10 callersMethodhasNoHandleClients

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

↓ 10 callersMethodhighestLSNNode

src/groups/mqb/mqbc/mqbc_clusterfsm.h:414

↓ 10 callersMethodisClusterMember

src/groups/mqb/mqbblp/mqbblp_cluster.h:813

↓ 10 callersFunctionisConfigure

src/groups/bmq/bmqimp/bmqimp_brokersession.t.cpp:277

↓ 10 callersMethodisConfirmEvent

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

↓ 10 callersMethodisEmpty

src/groups/mqb/mqbs/mqbs_virtualstorage.h:558

↓ 10 callersMethodleaderAdvisoryWords

src/groups/mqb/mqbc/mqbc_clusterstateledgerprotocol.h:544

↓ 10 callersMethodlisten

src/groups/mwc/mwcio/mwcio_ntcchannelfactory.t.cpp:595

← previous next →701–800 of 9,318, ranked by callers