mirror of https://gitee.com/bigwinds/arangodb
remove unused functions
This commit is contained in:
parent
3f0b4ad4ee
commit
21ac01fba6
|
@ -128,6 +128,7 @@ class Socket {
|
|||
: _ioService(ioService),
|
||||
_context(std::move(context)),
|
||||
_encrypted(encrypted) {}
|
||||
Socket(Socket const& that) = delete;
|
||||
Socket(Socket&& that) = delete;
|
||||
virtual ~Socket() {}
|
||||
|
||||
|
|
|
@ -500,17 +500,3 @@ void SocketTask::asyncReadSome() {
|
|||
});
|
||||
}
|
||||
}
|
||||
|
||||
// caller must hold the _writeLock
|
||||
void SocketTask::closeReceiveStream() {
|
||||
if (!_closedReceive) {
|
||||
try {
|
||||
_peer->shutdownReceive();
|
||||
} catch (boost::system::system_error& err) {
|
||||
LOG_TOPIC(WARN, arangodb::Logger::FIXME) << "shutdown receive stream "
|
||||
<< " failed with: " << err.what();
|
||||
}
|
||||
|
||||
_closedReceive = true;
|
||||
}
|
||||
}
|
||||
|
|
|
@ -154,7 +154,6 @@ class SocketTask : virtual public Task {
|
|||
bool trySyncRead();
|
||||
bool processAll();
|
||||
void asyncReadSome();
|
||||
void closeReceiveStream();
|
||||
|
||||
private:
|
||||
Mutex _writeLock;
|
||||
|
|
|
@ -38,7 +38,8 @@ class SocketTcp final : public Socket {
|
|||
_socket(_sslSocket.next_layer()),
|
||||
_peerEndpoint() {}
|
||||
|
||||
SocketTcp(SocketTcp&& that) = default;
|
||||
SocketTcp(SocketTcp const& that) = delete;
|
||||
SocketTcp(SocketTcp&& that) = delete;
|
||||
|
||||
void close() override {
|
||||
MUTEX_LOCKER(guard, _lock);
|
||||
|
|
Loading…
Reference in New Issue