Searched refs:inputBuffer (Results 1 – 4 of 4) sorted by relevance
45 if (data.length() > inputBuffer.capacity()) in onMessage()56 inputBuffer.prepare(data.size()), boost::asio::buffer(data)); in onMessage()59 inputBuffer.commit(copied); in onMessage()62 inputBuffer.size()); in onMessage()116 if (inputBuffer.size() == 0) in doWrite()125 inputBuffer.data(), in doWrite()136 inputBuffer.consume(bytesWritten); in doWrite()161 boost::beast::flat_static_buffer<1024UL> inputBuffer; member in crow::obmc_kvm::KvmSession
48 if (inputBuffer.empty()) in doWrite() 56 boost::asio::buffer(inputBuffer.data(), inputBuffer.size()), in doWrite() 66 self->inputBuffer.erase(0, bytesWritten); in doWrite() 145 std::string inputBuffer; member in crow::obmc_console::ConsoleHandler 319 handler->second->inputBuffer += data; in onMessage()
91 if (inputBuffer.size() == 0) in doWrite()99 inputBuffer.data(), in doWrite()104 inputBuffer.consume(bytesWritten); in doWrite()165 boost::beast::flat_static_buffer<nbdBufferSize> inputBuffer; member in crow::obmc_vm::Handler581 handler->inputBuffer.clear(); in requestRoutes()587 if (data.length() > handler->inputBuffer.capacity() - in requestRoutes()588 handler->inputBuffer.size()) in requestRoutes()597 handler->inputBuffer.prepare(data.size()), in requestRoutes()599 handler->inputBuffer.commit(copied); in requestRoutes()
147 if (inputBuffer.size() == 0) in doWrite()156 inputBuffer.data(), in doWrite()167 inputBuffer.consume(bytesTransferred); in doWriteCallback()204 if (id.size() + msg.size() + inputBuffer.size() >= bufferLimit) in dataFormat()230 inputBuffer.prepare(rawData.size()), boost::asio::buffer(rawData)); in dataFormat()231 inputBuffer.commit(copied); in dataFormat()272 boost::beast::multi_buffer inputBuffer; member in crow::sse_socket::ConnectionImpl