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
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
62 if (inputBuffer.empty()) in doWrite()70 boost::asio::buffer(inputBuffer.data(), inputBuffer.size()), in doWrite()80 self->inputBuffer.erase(0, bytesWritten); in doWrite()159 std::string inputBuffer; member in crow::obmc_console::ConsoleHandler333 handler->second->inputBuffer += data; in onMessage()
110 if (inputBuffer.size() == 0) in doWrite()118 inputBuffer.data(), in doWrite()123 inputBuffer.consume(bytesWritten); in doWrite()184 boost::beast::flat_static_buffer<nbdBufferSize> inputBuffer; member in crow::obmc_vm::Handler600 handler->inputBuffer.clear(); in requestRoutes()606 if (data.length() > handler->inputBuffer.capacity() - in requestRoutes()607 handler->inputBuffer.size()) in requestRoutes()616 handler->inputBuffer.prepare(data.size()), in requestRoutes()618 handler->inputBuffer.commit(copied); in requestRoutes()