summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/sys/posix
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/sys/posix')
-rw-r--r--cpp/src/qpid/sys/posix/Socket.cpp25
-rw-r--r--cpp/src/qpid/sys/posix/Thread.h12
2 files changed, 4 insertions, 33 deletions
diff --git a/cpp/src/qpid/sys/posix/Socket.cpp b/cpp/src/qpid/sys/posix/Socket.cpp
index c742b08c64..65345219f0 100644
--- a/cpp/src/qpid/sys/posix/Socket.cpp
+++ b/cpp/src/qpid/sys/posix/Socket.cpp
@@ -167,31 +167,6 @@ Socket::close() const
socket = -1;
}
-ssize_t
-Socket::send(const void* data, size_t size) const
-{
- const int& socket = impl->fd;
- ssize_t sent = ::send(socket, data, size, 0);
- if (sent < 0) {
- if (errno == ECONNRESET) return SOCKET_EOF;
- if (errno == ETIMEDOUT) return SOCKET_TIMEOUT;
- throw QPID_POSIX_ERROR(errno);
- }
- return sent;
-}
-
-ssize_t
-Socket::recv(void* data, size_t size) const
-{
- const int& socket = impl->fd;
- ssize_t received = ::recv(socket, data, size, 0);
- if (received < 0) {
- if (errno == ETIMEDOUT) return SOCKET_TIMEOUT;
- throw QPID_POSIX_ERROR(errno);
- }
- return received;
-}
-
int Socket::listen(uint16_t port, int backlog) const
{
const int& socket = impl->fd;
diff --git a/cpp/src/qpid/sys/posix/Thread.h b/cpp/src/qpid/sys/posix/Thread.h
index 7d51ec73aa..dae2b5ca11 100644
--- a/cpp/src/qpid/sys/posix/Thread.h
+++ b/cpp/src/qpid/sys/posix/Thread.h
@@ -22,6 +22,10 @@
*
*/
+#ifdef HAVE_CONFIG_H
+#include "config.h"
+#endif
+
#include "check.h"
#include <pthread.h>
@@ -40,8 +44,6 @@ class Thread
*/
static unsigned long logId() { return current().id(); }
- inline static void yield();
-
inline Thread();
inline explicit Thread(qpid::sys::Runnable*);
inline explicit Thread(qpid::sys::Runnable&);
@@ -82,11 +84,5 @@ Thread Thread::current() {
return Thread(pthread_self());
}
-void Thread::yield()
-{
- QPID_POSIX_ASSERT_THROW_IF(pthread_yield());
-}
-
-
}}
#endif /*!_sys_posix_Thread_h*/