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

↓ 10 callersMethodloadApplicationData

src/groups/mqb/mqbs/mqbs_datafileiterator.cpp:244

↓ 10 callersMethodloadMessageProperties

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

↓ 10 callersMethodloadProperties

src/groups/bmq/bmqa/bmqa_message.cpp:495

↓ 10 callersMethodmaxTimeFailover

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

↓ 10 callersMethodmessagesWatermarkRatio

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

↓ 10 callersMethodmin

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

↓ 10 callersFunctionminMax

(val, min, max)

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

↓ 10 callersMethodnumAppIds

src/groups/mqb/mqbs/mqbs_qlistfileiterator.h:277

↓ 10 callersMethodnumColumns

src/groups/mwc/mwcst/mwcst_table.cpp:46

↓ 10 callersMethodnumCorrrelationIds

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

↓ 10 callersMethodnumProcessingThreads

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

↓ 10 callersMethodopenQueueSync

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

↓ 10 callersMethodpacked

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

↓ 10 callersMethodpopFront

src/groups/bmq/bmqimp/bmqimp_eventqueue.cpp:535

↓ 10 callersMethodpostRate

src/applications/bmqtool/m_bmqtool_messages.h:10235

↓ 10 callersMethodprocessDumpCommand

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

↓ 10 callersMethodqueueSizeLowWatermark

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

↓ 10 callersMethodregisterClient

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

↓ 10 callersMethodreset

src/groups/mwc/mwct/mwct_valueorerror.h:424

↓ 10 callersFunctionsendMessage

(tl, step, from, toList)

docs/assets/animations/animations/bmq/distribution-tree/animation.js:13

↓ 10 callersMethodsessionEvent

src/groups/bmq/bmqa/bmqa_event.cpp:47

↓ 10 callersMethodshutdownTimeoutMs

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

↓ 10 callersMethodstatContext

src/groups/mqb/mqbstat/mqbstat_queuestats.h:383

↓ 10 callersMethodstorageProtocolVersion

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

↓ 10 callersMethodstreamIn

src/groups/bmq/bmqp/bmqp_messageproperties.cpp:750

↓ 10 callersMethodsubStreamCount

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

↓ 10 callersMethodtheNumeric

src/groups/bmq/bmqt/bmqt_correlationid.h:458

↓ 10 callersMethodthresholdNode

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

↓ 10 callersMethoduserData

src/groups/mwc/mwcst/mwcst_statcontext.h:1196

↓ 10 callersMethodverifyCloseRequestSent

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

↓ 10 callersMethodverifyRegistrationRequestSent

src/groups/mqb/mqbc/mqbc_clusterstatemanager.t.cpp:369

↓ 10 callersMethodwaitHostUnhealthyEvent

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

↓ 10 callersMethodwaitQueueResumedEvent

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

↓ 9 callersMethodadjustQueueCount

src/groups/mqb/mqbc/mqbc_clusterstate.cpp:548

↓ 9 callersMethodappend

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

↓ 9 callersMethodasAckEvent

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

↓ 9 callersMethodatEnd

src/groups/mwc/mwcu/mwcu_blobiterator.h:290

↓ 9 callersMethodbufferFactory

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

↓ 9 callersMethodbytes

src/groups/mqb/mqbblp/mqbblp_clusterproxy.h:699

↓ 9 callersMethodclear

src/groups/mqb/mqbc/mqbc_clusterstate.cpp:535

↓ 9 callersMethodconfirmMessage

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

↓ 9 callersMethodconfirmMsg

src/applications/bmqtool/m_bmqtool_messages.h:10220

↓ 9 callersMethodconnect

src/groups/mwc/mwcio/mwcio_ntcchannel.cpp:993

↓ 9 callersMethodcrc32c

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

↓ 9 callersFunctioncreateClusterMessage

Load into the specified `message` an artificial cluster message of the specified `advisoryType` having the specified `sequenceNumber`. Return the app

src/groups/mqb/mqbc/mqbc_incoreclusterstateledgeriterator.t.cpp:89

↓ 9 callersMethoddatumAllocator

src/groups/mwc/mwcst/mwcst_statcontext.h:1201

↓ 9 callersMethodeventQueueLowWatermark

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

↓ 9 callersFunctiongenerateStorageKey

Populate the specified `key` buffer with a unique character array of length `mqbu::StorageKey::e_KEY_LENGTH_BINARY` by hashing the specified `value`,

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

↓ 9 callersMethodget

src/groups/mwc/mwcma/mwcma_countingallocatorstore.cpp:54

↓ 9 callersMethodgetAsChar

src/groups/bmq/bmqp/bmqp_messageproperties.h:1040

↓ 9 callersMethodgetProcessorForClient

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

↓ 9 callersMethodgetSubcontext

src/groups/mwc/mwcst/mwcst_statcontext.h:1151

↓ 9 callersFunctiongetUnit

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

↓ 9 callersMethodhasConsumerPriority

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

↓ 9 callersMethodhasHandle

src/groups/mqb/mqbblp/mqbblp_routers.h:820

↓ 9 callersMethodhasMaxUnconfirmedMessages

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

↓ 9 callersMethodhasMultipleSubStreams

src/groups/mqb/mqbblp/mqbblp_queue.h:538

↓ 9 callersMethodisChannelEmpty

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

↓ 9 callersMethodisInMemoryValue

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

↓ 9 callersMethodisRecoveryEvent

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

↓ 9 callersMethodisSelfActiveLeader

src/groups/mqb/mqbc/mqbc_electorinfo.h:412

↓ 9 callersMethodisValue

src/groups/mwc/mwct/mwct_valueorerror.h:395

↓ 9 callersMethodjoin

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

↓ 9 callersMethodloadRecoveryMessageIterator

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

↓ 9 callersMethodmaxMessageCount

src/groups/bmq/bmqp/bmqp_ackeventbuilder.h:159

↓ 9 callersMethodmaxQlistFileSize

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

↓ 9 callersMethodnoSessionEventHandler

src/applications/bmqtool/m_bmqtool_messages.h:10280

↓ 9 callersMethodnumActiveQueues

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

↓ 9 callersMethodnumOperationsExecuting

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

↓ 9 callersMethodnumSubcontexts

src/groups/mwc/mwcst/mwcst_statcontext.h:1137

↓ 9 callersMethodobjectAddress

src/groups/mwc/mwcu/mwcu_objectplaceholder.h:447

↓ 9 callersMethodpackMessageRaw

src/groups/bmq/bmqp/bmqp_puteventbuilder.cpp:395

↓ 9 callersFunctionpopulateBlob

Populate the specified `blob` with a PUSH event consisting of an event header, a push header, an options area containing an options header followed by

src/groups/bmq/bmqp/bmqp_optionsview.t.cpp:183

↓ 9 callersMethodprimarySyncInProgress

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

↓ 9 callersMethodprocessReplicaDetect

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

↓ 9 callersMethodprocessorHandle

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

↓ 9 callersMethodqueueSizeHighWatermark

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

↓ 9 callersMethodqueueUriLengthWords

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

↓ 9 callersMethodregisterObserver

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

↓ 9 callersMethodremove

src/groups/mqb/mqbu/mqbu_capacitymeter.cpp:348

↓ 9 callersMethodremoveRecordRaw

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

↓ 9 callersMethodreopenQueue

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

↓ 9 callersMethodreset

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

↓ 9 callersMethodreset

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

↓ 9 callersMethodscheduler

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

↓ 9 callersMethodsendOldPut

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

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

↓ 9 callersFunctionsetCallback

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

↓ 9 callersMethodsetChannel

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

↓ 9 callersMethodsetFilter

src/groups/mwc/mwcst/mwcst_tablerecords.cpp:165

↓ 9 callersMethodsetPeerUri

src/groups/mwc/mwcio/mwcio_testchannel.cpp:91

↓ 9 callersMethodsetPrevInList

src/groups/mwc/mwcc/mwcc_orderedhashmap.h:799

↓ 9 callersMethodsetPropertyAsChar

src/groups/bmq/bmqp/bmqp_messageproperties.h:840

↓ 9 callersMethodstorage

src/groups/mqb/mqbc/mqbc_storagemanager.h:1057

↓ 9 callersMethodthePointer

src/groups/bmq/bmqt/bmqt_correlationid.h:466

↓ 9 callersMethodthresholdMaster

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

↓ 9 callersMethodtimeStamp

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

↓ 9 callersFunctionverify

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

↓ 9 callersMethodverifyReplicaSendsPrimaryStateRqst

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

↓ 9 callersMethodwaitHostHealthRestoredEvent

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

↓ 9 callersMethodwords

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

← previous next →801–900 of 9,318, ranked by callers