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

↓ 33 callersMethodgenerateGUID

src/groups/bmq/bmqp/bmqp_messageguidgenerator.cpp:164

↓ 33 callersMethodlength

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

↓ 33 callersMethodnow

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

↓ 33 callersMethodnumBytes

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

↓ 33 callersFunctionprintTable

Print a table having the specified `headerCols` and `tableRecords` to the specified `out`.

src/groups/bmq/bmqp/bmqp_crc32c.t.cpp:274

↓ 32 callersMethodhasVirtualStorage

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

↓ 32 callersMethodprint

src/groups/mwc/mwcsys/mwcsys_statmonitorsnapshotrecorder.cpp:129

↓ 32 callersMethodreset

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

↓ 32 callersMethodreset

src/groups/mqb/mqbs/mqbs_offsetptr.h:102

↓ 32 callersMethodscheduler

src/groups/mqb/mqbblp/mqbblp_queuestate.h:530

↓ 32 callersMethodselectionId

src/applications/bmqtool/m_bmqtool_messages.h:6762

↓ 31 callersMethodapplyTimer

src/groups/mqb/mqbnet/mqbnet_elector.cpp:1760

↓ 31 callersFunctionexpectEnd

Verify that the specified `next` will yield no more nonempty strings. Return zero if `next` is finished, or return a nonzero value if `next` can yield

src/groups/mqb/mqbcmd/mqbcmd_parseutil.cpp:163

↓ 31 callersMethodhasMsgGroupId

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

↓ 31 callersMethodisEventDumpEnabled

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

↓ 31 callersMethodisLocal

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

↓ 31 callersMethodselfNode

src/groups/mqb/mqbnet/mqbnet_clusterimp.h:426

↓ 31 callersMethodsetPartitionId

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

↓ 31 callersMethodsetQueueId

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

↓ 31 callersMethodsetValue

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

↓ 30 callersMethodadvance

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

↓ 30 callersMethodclear

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

↓ 30 callersMethoderase

src/groups/bmq/bmqpi/bmqpi_dtspan.cpp:83

↓ 30 callersMethodmapping

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

↓ 30 callersMethodoutstandingJobs

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

↓ 30 callersMethodsetValue

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

↓ 30 callersMethodthreadAttributes

src/groups/mwc/mwcex/mwcex_systemexecutor.cpp:279

↓ 29 callersMethodaliasRecord

src/groups/mqb/mqbsl/mqbsl_ledger.cpp:670

↓ 29 callersMethodasync

src/applications/bmqtool/m_bmqtool_messages.h:6418

↓ 29 callersMethoddropHandle

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

↓ 29 callersMethodgetClusterNodeSession

src/groups/mqb/mqbc/mqbc_clustermembership.h:216

↓ 29 callersMethodinsertQueue

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

↓ 29 callersMethodstart

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

↓ 29 callersMethodstate

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

↓ 29 callersMethodstopGracefully

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

↓ 29 callersMethodwait

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

↓ 29 callersMethodwriteRecord

src/groups/mqb/mqbsl/mqbsl_ledger.cpp:555

↓ 28 callersMethodbyteCapacity

src/groups/mqb/mqbu/mqbu_capacitymeter.h:438

↓ 28 callersMethodid

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

↓ 28 callersMethodisAckEvent

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

↓ 28 callersMethodisValid

src/groups/mwc/mwcu/mwcu_tlsbool.h:282

↓ 28 callersMethodreset

src/groups/bmq/bmqt/bmqt_uri.cpp:129

↓ 28 callersMethodresult

src/groups/bmq/bmqa/bmqa_openqueuestatus.h:214

↓ 28 callersMethodsetPropertyAsInt64

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

↓ 28 callersMethodtryPushBack

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

↓ 28 callersMethodunlock

src/groups/mwc/mwcu/mwcu_atomicstate.h:124

↓ 28 callersMethod~Void

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

↓ 27 callersMethodallocator

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

↓ 27 callersMethodapplyScout

src/groups/mqb/mqbnet/mqbnet_elector.cpp:1741

↓ 27 callersMethodisValid

src/applications/bmqtool/m_bmqtool_parameters.cpp:101

↓ 27 callersMethodjournalOffsetWords

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

↓ 27 callersMethodlookupQueue

src/groups/bmq/bmqimp/bmqimp_event.cpp:477

↓ 27 callersMethodmessageCapacity

src/groups/mqb/mqbu/mqbu_capacitymeter.h:432

↓ 27 callersMethodnodeStatus

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

↓ 27 callersMethodsendMessageSafe

src/groups/mqb/mqbc/mqbc_controlmessagetransmitter.cpp:207

↓ 27 callersMethodwaitForQueueState

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

↓ 26 callersMethodalias

src/groups/mqb/mqbsl/mqbsl_inmemorylog.cpp:273

↓ 26 callersMethodapplicationDataSize

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

↓ 26 callersFunctionareEqual

Return 0 if `lhs` is equal to `rhs`, non-zero loggable value otherwise.

src/groups/mqb/mqbs/mqbs_journalfileiterator.t.cpp:59

↓ 26 callersMethodcompressionAlgorithmType

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

↓ 26 callersMethodelectorState

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

↓ 26 callersMethodgetDefault

src/groups/mwc/mwcu/mwcu_tlsbool.h:287

↓ 26 callersMethodisRelay

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

↓ 26 callersMethodisValid

src/groups/bmq/bmqt/bmqt_uri.h:420

↓ 26 callersFunctionregexMatch

Match the specified `str` against the specified `pattern` using the specified `allocator` and return true on success, false otherwise. The matching i

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

↓ 26 callersMethodsetTimer

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

↓ 26 callersMethodtype

src/applications/bmqtool/m_bmqtool_messages.h:9051

↓ 25 callersMethodclearChannels

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

↓ 25 callersMethodfail

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

↓ 25 callersMethodisValid

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

↓ 25 callersMethodnext

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

↓ 25 callersMethodnumCommittedMessages

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

↓ 25 callersMethodsetPrimaryLeaseId

src/groups/mqb/mqbi/mqbi_storagemanager.h:457

↓ 25 callersMethodstatistics

Return a pointer to the statistics provided on construction.

src/groups/mwc/mwcex/mwcex_executor.t.cpp:141

↓ 25 callersMethodtimestamp

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

↓ 24 callersMethodaddMessages

NOTE: Here the `addMessages` function adds the timestamp as incrementing values from 0 or from dataOffset provided Thus acting like a vector clock, al

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

↓ 24 callersMethodappendMessage

src/groups/bmq/bmqp/bmqp_ackeventbuilder.cpp:72

↓ 24 callersFunctioncheckSnapshot

Compare the snapshot of the specified `value` at he specified `index` of the specified `level` to the specified `snapshotDesc`. `snapshotDesc` is a sp

src/groups/mwc/mwcst/mwcst_statcontext.t.cpp:120

↓ 24 callersMethodclear

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

↓ 24 callersMethodcompressionAlgorithmType

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

↓ 24 callersMethodconfigureQueueAsync

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

↓ 24 callersMethodenable

src/groups/mqb/mqbnet/mqbnet_elector.cpp:1597

↓ 24 callersFunctionfield

Return the value of the specified `field` within the specified `update`. The behavior is undefined unless `hasField(update, field)`

src/groups/mwc/mwcst/mwcst_statcontext.t.cpp:163

↓ 24 callersMethodfromBinary

src/groups/mqb/mqbu/mqbu_storagekey.h:304

↓ 24 callersMethodgetEvent

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

↓ 24 callersMethodinvalidate

src/groups/mwc/mwcu/mwcu_sharedresource.cpp:134

↓ 24 callersMethodnextMessage

src/groups/bmq/bmqa/bmqa_messageiterator.cpp:42

↓ 24 callersFunctionqueueLateAsyncCanceled

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

↓ 24 callersMethodreadRecord

ACCESSORS (virtual 'mqbsi::Ledger')

src/groups/mqb/mqbsl/mqbsl_ledger.cpp:624

↓ 24 callersMethodrecordType

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

↓ 24 callersMethodsetMessage

src/groups/bmq/bmqp/bmqp_schemaeventbuilder.h:198

↓ 24 callersMethodsetWriteStatus

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

↓ 24 callersMethodstart

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

↓ 24 callersMethodtype

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

↓ 24 callersMethodwaitForScheduler

src/groups/mqb/mqbmock/mqbmock_cluster.cpp:487

↓ 23 callersMethodacquireWeak

src/groups/mwc/mwcu/mwcu_sharedresource.h:624

↓ 23 callersMethodbrokerVersion

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

↓ 23 callersMethodcapacity

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

↓ 23 callersFunctioncheckValue

src/groups/mwc/mwct/mwct_propertybag.t.cpp:40

↓ 23 callersMethodclear

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

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