Team2890/allwpilib
4
0
Fork 0
mirror of https://github.com/wpilibsuite/allwpilib synced 2026-06-22 01:11:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

HTTPSinkImpl: Implement GetDescription.

Browse Source
This commit is contained in:
Peter Johnson
2016-09-10 12:46:43 -07:00
parent 451c08ef7b
commit 775386d8b3
2 changed files with 18 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
src/HTTPSinkImpl.cpp
View File

@@ -248,14 +248,21 @@ void HTTPSinkImpl::SendJSON(llvm::raw_ostream& os, SourceImpl& source,
os.flush();
}
HTTPSinkImpl::HTTPSinkImpl(llvm::StringRef name,
HTTPSinkImpl::HTTPSinkImpl(llvm::StringRef name, llvm::StringRef description,
std::unique_ptr<wpi::NetworkAcceptor> acceptor)
: SinkImpl{name}, m_acceptor{std::move(acceptor)} {
: SinkImpl{name},
m_description(description),
m_acceptor{std::move(acceptor)} {
m_serverThread = std::thread(&HTTPSinkImpl::ServerThreadMain, this);
}
HTTPSinkImpl::~HTTPSinkImpl() { Stop(); }
void HTTPSinkImpl::GetDescription(llvm::SmallVectorImpl<char>& desc) const {
llvm::raw_svector_ostream oss{desc};
oss << m_description;
}
void HTTPSinkImpl::Stop() {
m_active = false;
@@ -436,10 +443,14 @@ namespace cs {
CS_Sink CreateHTTPSink(llvm::StringRef name, llvm::StringRef listenAddress,
int port, CS_Status* status) {
llvm::SmallString<128> descBuf;
llvm::raw_svector_ostream desc{descBuf};
desc << "HTTP Server on port " << port;
llvm::SmallString<128> str{listenAddress};
auto sink = std::make_shared<HTTPSinkImpl>(
name, std::unique_ptr<wpi::NetworkAcceptor>(new wpi::TCPAcceptor(
port, str.c_str(), Logger::GetInstance())));
name, desc.str(),
std::unique_ptr<wpi::NetworkAcceptor>(
new wpi::TCPAcceptor(port, str.c_str(), Logger::GetInstance())));
return Sinks::GetInstance().Allocate(SinkData::kHTTP, sink);
}