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

↓ 23 callersMethoddispatchEvent

src/groups/mqb/mqbs/mqbs_filestore.h:1154

↓ 23 callersMethodloadApplicationData

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

↓ 23 callersMethodloadClusterMessage

src/groups/mqb/mqbc/mqbc_clusterstateledgerutil.cpp:411

↓ 23 callersMethodloadPushMessageIterator

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

↓ 23 callersMethodmappedFileDescriptor

src/groups/mqb/mqbs/mqbs_datafileiterator.h:262

↓ 23 callersMethodmessageEvent

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

↓ 23 callersMethodmessageIterator

src/groups/bmq/bmqa/bmqa_messageevent.cpp:51

↓ 23 callersMethodnumLinks

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

↓ 23 callersMethodpost

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

↓ 23 callersMethodprinter

src/groups/mwc/mwcu/mwcu_printutil.h:457

↓ 23 callersMethodread

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

↓ 23 callersMethodschemaId

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

↓ 23 callersMethodstartAsync

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

↓ 23 callersMethodstop

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

↓ 23 callersMethodwaitConnectionLostEvent

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

↓ 22 callersMethodcallback

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

↓ 22 callersMethodclearChannels

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

↓ 22 callersMethodcreateRequest

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

↓ 22 callersMethodcurrentLog

src/groups/mqb/mqbsl/mqbsl_ledger.h:213

↓ 22 callersMethoddomainFactory

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

↓ 22 callersFunctionfanoutConfig

Return a fanout domain configured with appIds from the specified `appIds`. The format of `appIdsStr` must be: `<appId_1>,<appId_2>,...,<appIdN>` The

src/groups/mqb/mqbblp/mqbblp_rootqueueengine.t.cpp:610

↓ 22 callersMethodflush

src/groups/mqb/mqba/mqba_adminsession.cpp:485

↓ 22 callersMethodheaderWords

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

↓ 22 callersMethodinDispatcherThread

src/groups/mqb/mqbmock/mqbmock_dispatcher.cpp:147

↓ 22 callersMethodisReverseMode

src/groups/mqb/mqbs/mqbs_datafileiterator.h:203

↓ 22 callersMethodmagic

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

↓ 22 callersMethodopen

MANIPULATORS (virtual mqbc::ClusterStateLedger)

src/groups/mqb/mqbc/mqbc_incoreclusterstateledger.cpp:1235

↓ 22 callersMethodqueueEngine

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

↓ 22 callersMethodstop

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

↓ 22 callersMethodsubQueueId

src/groups/bmq/bmqimp/bmqimp_queue.h:542

↓ 22 callersMethodverbosity

src/applications/bmqtool/m_bmqtool_parameters.h:667

↓ 21 callersMethodarrivalTimestamp

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

↓ 21 callersMethodcheckResultCallback

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

↓ 21 callersMethodclose

src/groups/mqb/mqbc/mqbc_incoreclusterstateledger.cpp:1292

↓ 21 callersMethoddomain

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

↓ 21 callersMethodhasOptions

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

↓ 21 callersMethodhasRecordSizeRemaining

src/groups/mqb/mqbs/mqbs_datafileiterator.h:192

↓ 21 callersMethodisCSLModeEnabled

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

↓ 21 callersMethodisCloseQueueValue

src/applications/bmqtool/m_bmqtool_messages.h:11080

↓ 21 callersMethodopenQueueAsync

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

↓ 21 callersFunctionpopulateBlob

Append at least the specified `atLeastLen` bytes to the specified `blob` and populate the specified `payloadLen` with the number of bytes appended.

src/groups/bmq/bmqp/bmqp_eventutil.t.cpp:130

↓ 21 callersMethodrecord

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

↓ 21 callersMethodrefCount

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

↓ 21 callersMethodreset

src/groups/mwc/mwcu/mwcu_blobobjectproxy.t.cpp:63

↓ 21 callersMethodreset

src/groups/mqb/mqbnet/mqbnet_channel.h:795

↓ 21 callersMethodsetPropertyAsInt32

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

↓ 21 callersMethodunpackedMessageSize

src/groups/bmq/bmqp/bmqp_puteventbuilder.h:498

↓ 21 callersMethodverify

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

↓ 21 callersMethodverifyFollowerLSNRequestsSent

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

↓ 21 callersMethodwaitStateRestoredEvent

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

↓ 20 callersMethodacquire

src/groups/mwc/mwcu/mwcu_atomicvalidator.h:226

↓ 20 callersMethodadd

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

↓ 20 callersMethoddeleteObject

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

↓ 20 callersMethodemitEvent

src/groups/bmq/bmqa/bmqa_mocksession.cpp:1361

↓ 20 callersMethodinitialize

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

↓ 20 callersMethodisAvailable

src/groups/mqb/mqbnet/mqbnet_channel.h:1103

↓ 20 callersMethodisControlEvent

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

↓ 20 callersMethodisExtended

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

↓ 20 callersMethodisForwardIterator

src/groups/mqb/mqbs/mqbs_memoryblockiterator.h:209

↓ 20 callersMethodisStopping

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

↓ 20 callersMethodlastRecordPosition

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

↓ 20 callersMethodmaxDataFileSize

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

↓ 20 callersMethodnumRegistrants

src/groups/bmq/bmqimp/bmqimp_manualhosthealthmonitor.cpp:60

↓ 20 callersMethodpost

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

↓ 20 callersMethodprotocolVersion

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

↓ 20 callersMethodput

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

↓ 20 callersMethodputEventBuilder

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

↓ 20 callersMethodqueueFlags

src/applications/bmqtool/m_bmqtool_parameters.h:607

↓ 20 callersMethodregisterSubStream

src/groups/mqb/mqbblp/mqbblp_queuehandle.cpp:566

↓ 20 callersMethodsendRequest

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

↓ 20 callersMethodsetContext

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

↓ 20 callersMethodsetException

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

↓ 20 callersMethodsetPartition

Set primary of specified `partition` to specified `isActive` state.

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

↓ 20 callersMethodstart

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

↓ 20 callersMethodstate

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

↓ 20 callersMethodstop

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

↓ 20 callersMethodsuspendsOnBadHostHealth

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

↓ 20 callersMethodtest

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

↓ 19 callersMethod_bufferFactory

src/groups/mqb/mqbmock/mqbmock_cluster.h:541

↓ 19 callersMethodchunkSequenceNumber

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

↓ 19 callersMethodfileChunkType

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

↓ 19 callersFunctionhashAppend

src/groups/mwc/mwcc/mwcc_orderedhashmap.t.cpp:88

↓ 19 callersFunctionincrementInteger

Increment the specified `n` by one.

src/groups/mwc/mwcu/mwcu_throttledaction.t.cpp:47

↓ 19 callersMethodisAtMostOnce

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

↓ 19 callersMethodisNull

src/groups/mwc/mwcst/mwcst_value.h:240

↓ 19 callersMethodisSelfPrimary

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

↓ 19 callersMethodmaxJournalFileSize

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

↓ 19 callersMethodmaxQlistFileSize

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

↓ 19 callersMethodmessageCount

src/groups/mqb/mqbnet/mqbnet_channel.h:790

↓ 19 callersMethodmessageTtl

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

↓ 19 callersMethodmessageWords

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

↓ 19 callersMethodoptionsWords

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

↓ 19 callersFunctionprocessCommand

`fake` command processor to pass to the object under test, print the specified `cmd` from the specified `source` to stdout, and write `SUCCESS` to the

src/groups/mqb/mqbstat/mqbstat_statcontroller.t.cpp:49

↓ 19 callersMethodrequestId

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

↓ 19 callersMethodsnapshotInterval

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

↓ 19 callersMethodstart

src/groups/mqb/mqbstat/mqbstat_printer.cpp:148

↓ 19 callersMethodsynchronize

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

↓ 19 callersMethodupdateBytes

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

↓ 19 callersMethodupdateMessages

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

↓ 18 callersMethodaddSubQueueInfosOption

src/groups/bmq/bmqp/bmqp_pusheventbuilder.cpp:240

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