diff options
Diffstat (limited to 'contrib/native/client/src/clientlib/drillClientImpl.hpp')
| -rw-r--r-- | contrib/native/client/src/clientlib/drillClientImpl.hpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/contrib/native/client/src/clientlib/drillClientImpl.hpp b/contrib/native/client/src/clientlib/drillClientImpl.hpp index a5eeb7775..fdcf17882 100644 --- a/contrib/native/client/src/clientlib/drillClientImpl.hpp +++ b/contrib/native/client/src/clientlib/drillClientImpl.hpp @@ -211,7 +211,7 @@ class DrillClientImpl{ m_deadlineTimer.cancel(); m_io_service.stop(); boost::system::error_code ignorederr; - m_socket.shutdown(boost::asio::ip::tcp::socket::shutdown_send, ignorederr); + m_socket.shutdown(boost::asio::ip::tcp::socket::shutdown_both, ignorederr); m_socket.close(); if(m_rbuf!=NULL){ Utils::freeBuffer(m_rbuf, MAX_SOCK_RD_BUFSIZE); m_rbuf=NULL; @@ -235,7 +235,7 @@ class DrillClientImpl{ DrillClientError* getError(){ return m_pError;} DrillClientQueryResult* SubmitQuery(::exec::shared::QueryType t, const std::string& plan, pfnQueryResultsListener listener, void* listenerCtx); void waitForResults(); - bool validateHandShake(const char* defaultSchema); + connectionStatus_t validateHandShake(const char* defaultSchema); private: friend class DrillClientQueryResult; @@ -341,7 +341,7 @@ inline void DrillClientImpl::Close() { //TODO: cancel pending query if(this->m_bIsConnected){ boost::system::error_code ignorederr; - m_socket.shutdown(boost::asio::ip::tcp::socket::shutdown_send, ignorederr); + m_socket.shutdown(boost::asio::ip::tcp::socket::shutdown_both, ignorederr); m_socket.close(); m_bIsConnected=false; } |