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

↓ 9 callersMethodwriteBlob

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

↓ 8 callersMethodallocationLimit

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

↓ 8 callersMethodappendConfirmMessage

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

↓ 8 callersMethodapply

src/groups/mqb/mqbblp/mqbblp_routers.cpp:750

↓ 8 callersMethodasCallbackEvent

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

↓ 8 callersMethodasPushEvent

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

↓ 8 callersFunctionbroadcastConfig

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

↓ 8 callersMethodclear

src/groups/bmq/bmqa/bmqa_messageproperties.cpp:120

↓ 8 callersFunctioncomputeWatermarkRatio

Load into the specified `watermarkRatio` the ratio of the specified `watermark` to the specified `capacity`. Behavior is undefined unless `0 <= water

src/groups/mqb/mqbu/mqbu_resourceusagemonitor.cpp:43

↓ 8 callersMethodconfirmMessages

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

↓ 8 callersMethodcountUnconfirmed

src/groups/mqb/mqba/mqba_clientsession.cpp:946

↓ 8 callersMethoddispatcher

src/groups/mqb/mqba/mqba_adminsession.h:369

↓ 8 callersMethoddumpMsg

src/applications/bmqtool/m_bmqtool_messages.h:10215

↓ 8 callersMethodenqueueStateRestoredIfNeeded

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

↓ 8 callersMethoderase

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

↓ 8 callersMethodeventSize

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

↓ 8 callersMethodfinalize

src/groups/mqb/mqbblp/mqbblp_routers.cpp:358

↓ 8 callersFunctionfindExpectedCrc32

src/groups/bmq/bmqp/bmqp_puteventbuilder.t.cpp:147

↓ 8 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_eventutil.t.cpp:98

↓ 8 callersFunctiongenerateSubQueueInfos

Populate the specified `subQueueInfos` with the specified `numSubQueueInfos` number of randomly generated pairs of sub-queue id and RDA counter. If `

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

↓ 8 callersMethodgetData

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

↓ 8 callersMethodgetIterator

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

↓ 8 callersMethodhasActiveLeader

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

↓ 8 callersMethodheaderSize

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

↓ 8 callersMethodheartbeatIntervalMs

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

↓ 8 callersMethodinitialize

src/groups/mqb/mqbstat/mqbstat_queuestats.cpp:347

↓ 8 callersFunctionisConfigure

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

↓ 8 callersMethodisDeleted

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

↓ 8 callersMethodisError

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

↓ 8 callersMethodisInBlob

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

↓ 8 callersMethodisSet

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

↓ 8 callersMethodisStarted

src/groups/mwc/mwcsys/mwcsys_statmonitor.h:437

↓ 8 callersMethodloadConfirmEventBuilder

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

↓ 8 callersMethodloadDataPosition

src/groups/bmq/bmqp/bmqp_storagemessageiterator.h:255

↓ 8 callersMethodloadMessageEventBuilder

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

↓ 8 callersMethodloadMsgGroupIdOption

src/groups/bmq/bmqp/bmqp_optionsview.cpp:354

↓ 8 callersMethodloggingVerbosity

src/groups/mwc/mwctsk/mwctsk_logcontroller.h:693

↓ 8 callersMethodlookupQueue

src/groups/mqb/mqbblp/mqbblp_domain.cpp:935

↓ 8 callersMethodmakeSchema

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

↓ 8 callersMethodmappingSize

src/groups/mqb/mqbs/mqbs_mappedfiledescriptor.h:179

↓ 8 callersMethodmasterAssignment

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

↓ 8 callersMethodmatch

src/groups/mwc/mwcu/mwcu_stringutil.cpp:181

↓ 8 callersMethodmaxDataFileSize

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

↓ 8 callersMethodmaxJournalFileSize

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

↓ 8 callersMethodmaxProducers

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

↓ 8 callersMethodmaxTimeNode

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

↓ 8 callersMethodmemoryDebug

src/applications/bmqtool/m_bmqtool_messages.h:10265

↓ 8 callersMethodmessagePropertiesAreaWords

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

↓ 8 callersMethodmessages

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

↓ 8 callersMethodmsgSize

src/applications/bmqtool/m_bmqtool_messages.h:10230

↓ 8 callersMethodnextEvent

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

↓ 8 callersMethodnumAttempts

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

↓ 8 callersMethodonAckMessage

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

↓ 8 callersMethodonClose

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

↓ 8 callersMethodonLostUpstream

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

↓ 8 callersMethodonMessageSent

src/groups/mqb/mqbblp/mqbblp_queueconsumptionmonitor.h:418

↓ 8 callersMethodonOpenUpstream

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

↓ 8 callersMethodonOperationCompleted

PRIVATE MANIPULATORS

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

↓ 8 callersMethodopenQueueAsync

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

↓ 8 callersMethodoptionsWords

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

↓ 8 callersMethodpop

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

↓ 8 callersMethodprefaultPages

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

↓ 8 callersMethodprefaultPages

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

↓ 8 callersFunctionprepareBlobForMessageEvent

Append message event of particular `type` to given blob `eb`. As a result blob will contain general event header, custom message header (PUT,PUSH or

src/groups/bmq/bmqimp/bmqimp_event.t.cpp:93

↓ 8 callersMethodprimaryLeaseId

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

↓ 8 callersMethodprimaryNodeId

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

↓ 8 callersMethodprocessResponse

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

↓ 8 callersFunctionqueueAsyncCanceled

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

↓ 8 callersMethodqueueUriRecordOffsetWords

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

↓ 8 callersMethodregisterQueue

src/groups/mqb/mqbblp/mqbblp_domain.cpp:614

↓ 8 callersMethodremove

src/groups/mqb/mqbs/mqbs_filebackedstorage.cpp:458

↓ 8 callersMethodremoveVirtualStorage

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

↓ 8 callersMethodreset

src/applications/bmqtool/m_bmqtool_messages.cpp:150

↓ 8 callersMethodsendControlMessage

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

↓ 8 callersMethodsetAllocationLimit

src/groups/mwc/mwcma/mwcma_countingallocator.cpp:273

↓ 8 callersMethodsetDomain

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

↓ 8 callersMethodsetLeader

Set leader to specified `isActive` state.

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

↓ 8 callersMethodsetNextInList

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

↓ 8 callersMethodsetNodeStatus

src/groups/mqb/mqbc/mqbc_clusternodesession.h:369

↓ 8 callersMethodsetNumAttempts

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

↓ 8 callersMethodsetQueue

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

↓ 8 callersMethodsetStreamParameters

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

↓ 8 callersMethodsetTable

src/groups/mwc/mwcst/mwcst_basictableinfoprovider.cpp:370

↓ 8 callersMethodstop

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

↓ 8 callersMethodtimedPopFront

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

↓ 8 callersMethodverifyCloseQueueResult

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

↓ 8 callersFunctionverifyLeaderAdvisoryCommit

Verify that the record at the specified `cslIter` position is a leader advisory commit of the specified `sequenceNumber`.

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

↓ 8 callersMethodwaitForChannelClose

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

↓ 7 callersMethodaddMessageConfirmation

src/groups/bmq/bmqa/bmqa_confirmeventbuilder.h:240

↓ 7 callersMethodaddQueueOpRecordHandle

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

↓ 7 callersMethodadvertiseV2Support

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

↓ 7 callersMethodasConfirmEvent

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

↓ 7 callersMethodasRejectEvent

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

↓ 7 callersMethodassertAckIsSentIfExpected

Depending on the specified `ackResult` it might assert that an ack message for the specified `queueId`, `msgGUID` and `correlationId` is sent downstre

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

↓ 7 callersMethodcanAdd

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

↓ 7 callersFunctionclient

src/groups/mqb/mqba/mqba_adminsession.t.cpp:92

↓ 7 callersMethodclientsCount

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

↓ 7 callersMethodconfigureQueue

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

↓ 7 callersMethodconfirmationCookie

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

↓ 7 callersMethodconsoleSeverityThreshold

src/groups/mwc/mwctsk/mwctsk_logcontroller.h:704

← previous next →901–1,000 of 9,318, ranked by callers