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

↓ 7 callersMethodcontext

ACCESSORS (specific to mwcma::CountingAllocator)

src/groups/mwc/mwcma/mwcma_countingallocator.h:272

↓ 7 callersMethodcreateRequestContext

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

↓ 7 callersMethoddisable

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

↓ 7 callersFunctioneZlibCompressDecompressHelper

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

↓ 7 callersMethodgarbageCollectMessages

src/groups/mqb/mqbblp/mqbblp_queueenginetester.cpp:1129

↓ 7 callersMethodgetAsBool

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

↓ 7 callersMethodgetAsInt32

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

↓ 7 callersMethodgetAsInt64

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

↓ 7 callersMethodgetAsShort

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

↓ 7 callersMethodhasNext

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

↓ 7 callersMethodhasPreallocate

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

↓ 7 callersMethodhasPrefaultPages

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

↓ 7 callersMethodhighWatermark

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

↓ 7 callersMethodhistorySize

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

↓ 7 callersMethodinRecovery

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

↓ 7 callersMethodincrementAliasedChunksCount

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

↓ 7 callersMethodincrementSubStreamCount

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

↓ 7 callersMethodinit

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

↓ 7 callersMethodinitialWaitTimeoutMs

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

↓ 7 callersMethodinnerExecutor

src/groups/mwc/mwcex/mwcex_strand.h:520

↓ 7 callersFunctionisClientOrProxy

src/groups/mqb/mqbnet/mqbnet_tcpsessionfactory.cpp:231

↓ 7 callersMethodisFirstHop

src/groups/mqb/mqbi/mqbi_queue.h:1196

↓ 7 callersMethodisPotentiallyPoisonous

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

↓ 7 callersMethodisReady

src/groups/mwc/mwcex/mwcex_future_cpp03.h:1450

↓ 7 callersMethodisUndefined

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

↓ 7 callersMethodloadChunkPosition

src/groups/bmq/bmqp/bmqp_recoverymessageiterator.h:242

↓ 7 callersMethodloadVirtualStorageDetails

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

↓ 7 callersMethodmaxQueues

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

↓ 7 callersMethodnodeLowWatermark

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

↓ 7 callersMethodnumRows

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

↓ 7 callersMethodpartitionSyncEventSize

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

↓ 7 callersFunctionpopulateBlob

src/groups/bmq/bmqp/bmqp_ackmessageiterator.t.cpp:55

↓ 7 callersFunctionpopulateBlob

Populate the specified `blob` with the specified `numMsgs` reject messages, and store them also in the specified `vec`. Populate the specified `eh` w

src/groups/bmq/bmqp/bmqp_rejectmessageiterator.t.cpp:83

↓ 7 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_pushmessageiterator.t.cpp:229

↓ 7 callersFunctionpopulateBlob

Populate the specified `blob` with the specified `numMsgs` confirm messages, and store them also in the specified `vec`. Populate the specified `eh`

src/groups/bmq/bmqp/bmqp_confirmmessageiterator.t.cpp:82

↓ 7 callersFunctionpopulateBlob

Populate specified `blob` with a RECOVERY event which has specified `numMsgs` recovery messages, update specified `eh` with corresponding EventHeader,

src/groups/bmq/bmqp/bmqp_recoverymessageiterator.t.cpp:55

↓ 7 callersFunctionpopulateBufferLengthsSorted

Populate the specified `bufferLengths` with various lengths in increasing sorted order. Return the maximum length populated. Note that `bufferLength

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

↓ 7 callersFunctionpopulateProperties

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

↓ 7 callersMethodprevInList

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

↓ 7 callersMethodpropertyNameLength

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

↓ 7 callersMethodpropertyValueLength

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

↓ 7 callersMethodprotocolVersion

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

↓ 7 callersMethodpurgeQueue

src/groups/mqb/mqbblp/mqbblp_queueenginetester.cpp:1164

↓ 7 callersMethodrecordWords

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

↓ 7 callersMethodregisterStatContext

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

↓ 7 callersMethodregisterSubscriptions

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

↓ 7 callersMethodrelease

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

↓ 7 callersMethodremove

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

↓ 7 callersMethodrequesterNode

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

↓ 7 callersMethodrinsert

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

↓ 7 callersMethodselectionId

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

↓ 7 callersMethodselfNodeSession

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

↓ 7 callersMethodsetComplete

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

↓ 7 callersMethodsetPropertyAsBool

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

↓ 7 callersMethodsetPropertyAsShort

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

↓ 7 callersMethodsetWriteStatus

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

↓ 7 callersMethodsize

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

↓ 7 callersMethodsnapshotTime

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

↓ 7 callersMethodsource

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

↓ 7 callersMethodstatusCode

src/groups/bmq/bmqa/bmqa_sessionevent.cpp:108

↓ 7 callersMethodstorageManager

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

↓ 7 callersFunctionsyncValues

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

↓ 7 callersMethodtarget

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

↓ 7 callersMethoduptime

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

↓ 7 callersMethodvalue

src/groups/mwc/mwcst/mwcst_statutil.cpp:37

↓ 7 callersFunctionverify

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

↓ 7 callersMethodverifyFollowerClusterStateRequestSent

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

↓ 7 callersMethodwaitForChannel

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

↓ 7 callersMethodwrite

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

↓ 6 callersFunctionaddValues

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

↓ 6 callersMethodappendAckMessage

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

↓ 6 callersFunctionappendDatum

Append to the specified `data` an entry having the specified `numSubQueueInfos` and `payloadLength` using the specified `bufferFactory` and `allocator

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

↓ 6 callersFunctionappendDatum1

Append to the specified `data` an entry having the specified `qid`, `useOldSubQueueIds` flag and `payloadLength` using the specified `bufferFactory` a

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

↓ 6 callersMethodapply

src/groups/mqb/mqbi/mqbi_queue.h:1069

↓ 6 callersMethodatMostOnce

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

↓ 6 callersMethodbroadcastMessage

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

↓ 6 callersMethodcancel

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

↓ 6 callersMethodcancel

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

↓ 6 callersMethodcheckChannelClose

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

↓ 6 callersMethodclearValues

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

↓ 6 callersFunctioncloneNode

(source, clone_id, startLocation)

docs/assets/animations/animations/utils.js:62

↓ 6 callersMethodclose

src/applications/bmqtool/m_bmqtool_filelogger.cpp:137

↓ 6 callersMethodcloseQueueWithError

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

↓ 6 callersMethodcloseTimeoutMs

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

↓ 6 callersMethodcluster

src/groups/mqb/mqbnet/mqbnet_elector.h:1383

↓ 6 callersMethodcommitUnreserved

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

↓ 6 callersFunctioncomputePercentage

Return a rounded (down) percentage value (range [0-100]) representing the space in use on a file with the specified `capacity`, currently having the s

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

↓ 6 callersFunctioncomputePercentile

Compute the `k`th percentile value of the specified `data` (data must be sorted). Formula: - compute the index (k percent * data size) - if index is n

src/applications/bmqtool/m_bmqtool_application.cpp:119

↓ 6 callersMethodconfigVersion

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

↓ 6 callersMethodconfigureTimeoutMs

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

↓ 6 callersMethodconsumer

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

↓ 6 callersMethodcpuAll

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

↓ 6 callersMethodcpuSystem

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

↓ 6 callersMethodcpuUser

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

↓ 6 callersMethodcrc32c

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

↓ 6 callersMethodcreateDomain

src/groups/mqb/mqbmock/mqbmock_domain.cpp:248

↓ 6 callersMethodcreateEvent

src/groups/bmq/bmqimp/bmqimp_brokersession.h:1706

↓ 6 callersMethodcreateRequest

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

↓ 6 callersMethodcreateResponse

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

↓ 6 callersMethoddecrements

src/groups/mwc/mwcst/mwcst_statutil.cpp:100

← previous next →1,001–1,100 of 9,318, ranked by callers