Searched refs:inputBuffer (Results 1 – 4 of 4) sorted by relevance
57 if (data.length() > inputBuffer.capacity()) in onMessage()68 inputBuffer.prepare(data.size()), boost::asio::buffer(data)); in onMessage()71 inputBuffer.commit(copied); in onMessage()74 inputBuffer.size()); in onMessage()128 if (inputBuffer.size() == 0) in doWrite()137 inputBuffer.data(), in doWrite()148 inputBuffer.consume(bytesWritten); in doWrite()173 boost::beast::flat_static_buffer<1024UL> inputBuffer; member in crow::obmc_kvm::KvmSession
63 if (inputBuffer.empty()) in doWrite()71 boost::asio::buffer(inputBuffer.data(), inputBuffer.size()), in doWrite()81 self->inputBuffer.erase(0, bytesWritten); in doWrite()160 std::string inputBuffer; member in crow::obmc_console::ConsoleHandler334 handler->second->inputBuffer += data; in onMessage()
111 if (inputBuffer.size() == 0) in doWrite()119 inputBuffer.data(), in doWrite()124 inputBuffer.consume(bytesWritten); in doWrite()185 boost::beast::flat_static_buffer<nbdBufferSize> inputBuffer; member in crow::obmc_vm::Handler601 handler->inputBuffer.clear(); in requestRoutes()607 if (data.length() > handler->inputBuffer.capacity() - in requestRoutes()608 handler->inputBuffer.size()) in requestRoutes()617 handler->inputBuffer.prepare(data.size()), in requestRoutes()619 handler->inputBuffer.commit(copied); in requestRoutes()
137 if (inputBuffer.size() == 0) in doWrite()146 inputBuffer.data(), in doWrite()157 inputBuffer.consume(bytesTransferred); in doWriteCallback()194 if (id.size() + msg.size() + inputBuffer.size() >= bufferLimit) in dataFormat()220 inputBuffer.prepare(rawData.size()), boost::asio::buffer(rawData)); in dataFormat()221 inputBuffer.commit(copied); in dataFormat()262 boost::beast::multi_buffer inputBuffer; member in crow::sse_socket::ConnectionImpl