119     StreamContext::DataMQ* const dataMQ = mContext->getDataMQ();  in init()  local
120     if (dataMQ == nullptr) return "Data MQ is null";  in init()
121     if (sizeof(DataBufferElement) != dataMQ->getQuantumSize()) {  in init()
122         return "Unexpected Data MQ quantum size: " + std::to_string(dataMQ->getQuantumSize());  in init()
124     mDataBufferSize = dataMQ->getQuantumCount() * dataMQ->getQuantumSize();  in init()
128                std::to_string(dataMQ->getQuantumCount()) +  in init()
319     StreamContext::DataMQ* const dataMQ = mContext->getDataMQ();  in read()  local
323             {clientSize, dataMQ->availableToWrite(&fmqError, &fmqErrorMsg), mDataBufferSize});  in read()
343     if (bool success = actualByteCount > 0 ? dataMQ->write(&mDataBuffer[0], actualByteCount) : true;  in read()
597     StreamContext::DataMQ* const dataMQ = mContext->getDataMQ();  in write()  local
600     const size_t readByteCount = dataMQ->availableToRead(&fmqError, &fmqErrorMsg);  in write()
605     if (readByteCount > 0 ? dataMQ->read(&mDataBuffer[0], readByteCount) : true) {  in write()