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

↓ 5 callersMethodselectionName

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

↓ 5 callersMethodsendAck

Sends an `Ack` event for the specified `queueId`, `guid` and `ackResult` to this testbench's `ClientSession`.

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

↓ 5 callersMethodset

PUBLIC MODIFIERS

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

↓ 5 callersFunctionsetAllFlags

Ensure the flags member of the specified `config` are all set.

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

↓ 5 callersMethodsetAtMostOnce

src/groups/bmq/bmqp/bmqp_routingconfigurationutils.h:155

↓ 5 callersMethodsetEnd

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

↓ 5 callersMethodsetEventScheduler

src/groups/mqb/mqbblp/mqbblp_remotequeue.h:574

↓ 5 callersMethodsetHasMultipleSubStreams

src/groups/bmq/bmqp/bmqp_routingconfigurationutils.h:182

↓ 5 callersMethodsetPartitionId

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

↓ 5 callersMethodsetProcessorForClient

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

↓ 5 callersMethodseverityThreshold

src/groups/mwc/mwctst/mwctst_scopedlogobserver.cpp:116

↓ 5 callersMethodsize

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

↓ 5 callersMethodsnapshotFromUpdate

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

↓ 5 callersMethodstart

src/groups/mwc/mwctsk/mwctsk_logcleaner.cpp:150

↓ 5 callersMethodstartAsync

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

↓ 5 callersMethodstatReportCompressionRatio

src/groups/bmq/bmqimp/bmqimp_queue.cpp:367

↓ 5 callersMethodstop

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

↓ 5 callersMethodstopTimeoutMs

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

↓ 5 callersMethodstorageSyncReqTimeoutMs

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

↓ 5 callersFunctionstringContains

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

↓ 5 callersMethodsubId

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

↓ 5 callersMethodsubscriptionHandle

src/tutorials/subscriptions/consumer.cpp:548

↓ 5 callersMethodswap

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

↓ 5 callersMethodteardown

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

↓ 5 callersFunctiontest_disconnectRequestErr

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

↓ 5 callersMethodtransitionToNewLeader

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

↓ 5 callersMethodttlSeconds

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

↓ 5 callersMethodunconfirmedMessages

src/groups/bmq/bmqa/bmqa_mocksession.h:1490

↓ 5 callersMethodunconfirmedMonitors

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

↓ 5 callersMethodunregisterQueue

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

↓ 5 callersMethodunregisterSubStream

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

↓ 5 callersMethodupstreamBroker

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

↓ 5 callersMethoduseNtf

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

↓ 5 callersMethodwaitAckEvent

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

↓ 5 callersFunctionwaitRealTime

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

↓ 5 callersMethodwritePut

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

↓ 5 callersFunctionwriteRecordRawImpl

Impl. of the "WRITE RECORD RAW" test, using the specified `ledger`.

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

↓ 4 callersMethodaddPartitionRaw

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

↓ 4 callersFunctionaddRecords

src/groups/mqb/mqbs/mqbs_datafileiterator.t.cpp:54

↓ 4 callersMethodadvance

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

↓ 4 callersMethodadvanceTime

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

↓ 4 callersMethodareFilesMapped

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

↓ 4 callersMethodassignQueue

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

↓ 4 callersMethodautoReconnect

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

↓ 4 callersMethodbaseAllocator

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

↓ 4 callersMethodbegin

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

↓ 4 callersMethodblob

src/groups/mwc/mwcst/mwcst_testutil.cpp:170

↓ 4 callersFunctionbreathingTestHelper

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

↓ 4 callersMethodbucket_count

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

↓ 4 callersMethodbufferFactory

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

↓ 4 callersMethodbytes

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

↓ 4 callersFunctioncalcBezier

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

↓ 4 callersMethodcleanup

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

↓ 4 callersMethodclearCache

src/groups/mqb/mqba/mqba_domainresolver.cpp:325

↓ 4 callersMethodclient

src/groups/mqb/mqbmock/mqbmock_queuehandle.cpp:125

↓ 4 callersMethodclient

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

↓ 4 callersMethodcloseChannels

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

↓ 4 callersMethodcloseQueue

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

↓ 4 callersMethodcloseQueueAsync

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

↓ 4 callersMethodcolumnName

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

↓ 4 callersMethodcompile

src/groups/bmq/bmqeval/bmqeval_simpleevaluator.cpp:51

↓ 4 callersMethodcompressionAlgorithmType

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

↓ 4 callersMethodcomputeHash

src/groups/bmq/bmqt/bmqt_messageguid.h:386

↓ 4 callersMethodconfigure

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

↓ 4 callersMethodconfigureQueue

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

↓ 4 callersMethodconfigureQueueAsync

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

↓ 4 callersMethodconfigureQueueSync

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

↓ 4 callersMethodconfirmMessage

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

↓ 4 callersMethodconsumerPriority

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

↓ 4 callersMethodcount

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

↓ 4 callersMethodcreateConfigureQueueContext

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

↓ 4 callersFunctioncreateFile

Create a file at the specified `path` and write the specified `content` into it; ensure the file has the specified `mode` flags set.

src/groups/mwc/mwcsys/mwcsys_executil.t.cpp:39

↓ 4 callersMethodcreateQueueOnStep

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

↓ 4 callersMethoddataFileOffset

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

↓ 4 callersMethoddecrements

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

↓ 4 callersMethoddemultiplex

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

↓ 4 callersMethoddestination

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

↓ 4 callersMethoddispatch

src/groups/mwc/mwcex/mwcex_strand.t.cpp:265

↓ 4 callersMethoddispatch

src/groups/mwc/mwcex/mwcex_executor.h:576

↓ 4 callersFunctiondoWork

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

↓ 4 callersMethoddropPuts

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

↓ 4 callersFunctionencode

src/groups/bmq/bmqp/bmqp_messageproperties.t.cpp:377

↓ 4 callersFunctionencode

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

↓ 4 callersMethodevents

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

↓ 4 callersMethodexceedsMaxMsgGroupIdsLimit

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

↓ 4 callersMethodfileMaxAgeDays

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

↓ 4 callersMethodfileMaxAgeDays

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

↓ 4 callersFunctionfilterArray

(arr, callback)

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

↓ 4 callersMethodfind

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

↓ 4 callersMethodfind

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

↓ 4 callersMethodfindByAppIdSafe

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

↓ 4 callersMethodfirstRecordPosition

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

↓ 4 callersMethodfirstSyncPointOffsetWords

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

↓ 4 callersMethodflush

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

↓ 4 callersMethodgc

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

↓ 4 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_pusheventbuilder.t.cpp:116

↓ 4 callersFunctiongenerateRandomString

Load into the specified `str` a string of random alphanumeric characters of the specified `len` size.

src/groups/bmq/bmqp/bmqp_compression.t.cpp:69

↓ 4 callersMethodget

Return a `bdld::Datum` object with value for the specified `name`. Use the specified `allocator` for any memory allocation.

src/groups/bmq/bmqeval/bmqeval_simpleevaluator.t.cpp:65

↓ 4 callersMethodgetQueueId

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

↓ 4 callersMethodhandleAllQueuesResumed

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

← previous next →1,301–1,400 of 9,318, ranked by callers