UnknownObject/WebCC
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Refine coding style

Browse Source
This commit is contained in:
Chunting Gu
2019-05-29 11:11:41 +08:00
parent e9f0cd97e8
commit e326a663f6
2 changed files with 12 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files
webcc/socket.cc
+6 -5
View File
@@ -3,6 +3,7 @@
#include "boost/asio/connect.hpp" #include "boost/asio/connect.hpp"
#include "boost/asio/read.hpp" #include "boost/asio/read.hpp"
#include "boost/asio/write.hpp" #include "boost/asio/write.hpp"
#include "boost/core/ignore_unused.hpp"
#include "webcc/logger.h" #include "webcc/logger.h"
@@ -14,14 +15,14 @@ Socket::Socket(boost::asio::io_context& io_context)
: socket_(io_context) { : socket_(io_context) {
} }
void Socket::Connect(const std::string& /*host*/, void Socket::Connect(const std::string& host, const Endpoints& endpoints,
const Endpoints& endpoints, boost::system::error_code* ec) {
boost::system::error_code* ec) { boost::ignore_unused(host);
boost::asio::connect(socket_, endpoints, *ec); boost::asio::connect(socket_, endpoints, *ec);
} }
void Socket::Write(const Request& request, void Socket::Write(const Request& request, boost::system::error_code* ec) {
boost::system::error_code* ec) {
boost::asio::write(socket_, request.payload(), *ec); boost::asio::write(socket_, request.payload(), *ec);
} }
webcc/socket.h
+6 -12
View File
@@ -26,12 +26,10 @@ public:
std::function<void(boost::system::error_code, std::size_t)>; std::function<void(boost::system::error_code, std::size_t)>;
// TODO: Remove |host| // TODO: Remove |host|
virtual void Connect(const std::string& host, virtual void Connect(const std::string& host, const Endpoints& endpoints,
const Endpoints& endpoints,
boost::system::error_code* ec) = 0; boost::system::error_code* ec) = 0;
virtual void Write(const Request& request, virtual void Write(const Request& request, boost::system::error_code* ec) = 0;
boost::system::error_code* ec) = 0;
virtual void AsyncReadSome(ReadHandler&& handler, virtual void AsyncReadSome(ReadHandler&& handler,
std::vector<char>* buffer) = 0; std::vector<char>* buffer) = 0;
@@ -45,12 +43,10 @@ class Socket : public SocketBase {
public: public:
explicit Socket(boost::asio::io_context& io_context); explicit Socket(boost::asio::io_context& io_context);
void Connect(const std::string& host, void Connect(const std::string& host, const Endpoints& endpoints,
const Endpoints& endpoints,
boost::system::error_code* ec) override; boost::system::error_code* ec) override;
void Write(const Request& request, void Write(const Request& request, boost::system::error_code* ec) override;
boost::system::error_code* ec) override;
void AsyncReadSome(ReadHandler&& handler, std::vector<char>* buffer) override; void AsyncReadSome(ReadHandler&& handler, std::vector<char>* buffer) override;
@@ -69,12 +65,10 @@ public:
explicit SslSocket(boost::asio::io_context& io_context, explicit SslSocket(boost::asio::io_context& io_context,
bool ssl_verify = true); bool ssl_verify = true);
void Connect(const std::string& host, void Connect(const std::string& host, const Endpoints& endpoints,
const Endpoints& endpoints,
boost::system::error_code* ec) override; boost::system::error_code* ec) override;
void Write(const Request& request, void Write(const Request& request, boost::system::error_code* ec) override;
boost::system::error_code* ec) override;
void AsyncReadSome(ReadHandler&& handler, std::vector<char>* buffer) override; void AsyncReadSome(ReadHandler&& handler, std::vector<char>* buffer) override;