diff options
| author | Alan Antonuk <alan.antonuk@gmail.com> | 2015-04-06 23:42:17 -0700 |
|---|---|---|
| committer | Alan Antonuk <alan.antonuk@gmail.com> | 2015-04-19 22:09:32 -0700 |
| commit | 3b775c45f7ba6a3f8b54491f3535d54efe5f89fa (patch) | |
| tree | dc9dfa1a9f11520adca6502d8e9d499f8777a009 /librabbitmq/amqp_private.h | |
| parent | 8a2b35620a8cbe094bce0b6b3ed33e3c49ebc048 (diff) | |
| download | rabbitmq-c-3b775c45f7ba6a3f8b54491f3535d54efe5f89fa.tar.gz | |
Return NEEDREAD status from amqp_tcp_socket_recv
When tcp socket is in non-blocking mode, return
AMQP_STATUS_PRIVATE_SOCKET_NEEDREAD when socket doesn't have any data in it.
Diffstat (limited to 'librabbitmq/amqp_private.h')
| -rw-r--r-- | librabbitmq/amqp_private.h | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/librabbitmq/amqp_private.h b/librabbitmq/amqp_private.h index 77a8f39..50905e1 100644 --- a/librabbitmq/amqp_private.h +++ b/librabbitmq/amqp_private.h @@ -121,6 +121,15 @@ typedef enum amqp_connection_state_enum_ { CONNECTION_STATE_BODY } amqp_connection_state_enum; +typedef enum amqp_status_private_enum_ +{ + /* 0x00xx -> AMQP_STATUS_*/ + /* 0x01xx -> AMQP_STATUS_TCP_* */ + /* 0x02xx -> AMQP_STATUS_SSL_* */ + AMQP_PRIVATE_STATUS_SOCKET_NEEDREAD = -0x1301, + AMQP_PRIVATE_STATUS_SOCKET_NEEDWRITE = -0x1302 +} amqp_status_private_enum; + /* 7 bytes up front, then payload, then 1 byte footer */ #define HEADER_SIZE 7 #define FOOTER_SIZE 1 |