| Commit message (Collapse) | Author | Age | Files | Lines |
|
|
|
|
|
|
| |
This makes license detection machine-readable, and makes source files more concise and easier
to read and understand.
Signed-off-by: GitHub <noreply@github.com>
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
Move official rabbitmq-c includes under the rabbitmq-c, thus new
programs should use the following include paths:
amqp.h -> rabbitmq-c/amqp.h
amqp_tcp_socket.h -> rabbitmq-c/tcp_socket.h
amqp_ssl_socket .h-> rabbitmq-c/ssl_socket.h
amqp_framing.h -> rabbitmq-c/framing.h
Existing include files are left with a warning message and including
their new equivalents, so existing programs should compile without
modification.
Signed-off-by: GitHub <noreply@github.com>
|
|
|
|
| |
Make all struct timeval parameters that can be a const, a const.
|
| |
|
|
|
|
| |
They're hard to keep in sync with .clang-format or other tools.
|
| |
|
|
|
|
|
|
|
| |
Cygwin defines TCP_NOPUSH, but fails with an error when you try to use
it. Disable it on Cygwin.
Fixes #335
|
|
|
|
|
|
|
|
| |
If a heartbeat timeout occurs skip calling SSL_shutdown as it involves doing a
send() which will likely hang. Additionally don't wait for a response when doing
an SSL_shutdown, as the underlying transport will not be reused.
Fixes #313
|
|
|
|
| |
<netinet/in.h> for IPPROTO_TCP definition.
|
|
|
|
| |
These are not the same constants, rabbitmq-c fails on Win32 as a result.
|
| |
|
| |
|
|
|
|
|
|
|
|
| |
As a performance optimization in the send path, add an AMQP_SF_MORE flag
indicating that more data is intended to be sent, and that packets shouldn't be
sent out on the wire unless there is a full packet's worth of data available.
Use this to specify MSG_MORE to send() on Linux.
|
|
|
|
|
| |
These constants are already defined in the Win32, and they're being incorrectly
redefined by rabbitmq-c.
|
| |
|
| |
|
| |
|
|
|
|
|
| |
When tcp socket is in non-blocking mode, return
AMQP_STATUS_PRIVATE_SOCKET_NEEDREAD when socket doesn't have any data in it.
|
|
|
|
| |
C89 compilers can't do mixed definitions and code.
|
|
|
|
|
|
|
| |
Check to state of socket when doing open/read/write/close to prevent double-open
and double-close issues with the socket implementation.
Fixes #228
|
|
|
|
|
|
|
| |
Fix a bug that manifested itself by the broker disconnecting the client
with an invalid_frame_end_marker error. The cause was when send()
returned less than the size of the buffer to be sent we weren't using
the correct parameters when restarting the send call.
|
| |
|
|
|
|
|
| |
Get rid of experimental amqp_socket_error interface. Errors are returned
using the error codes from the primary function
|
|
|
|
|
|
|
|
| |
Improve the socket interface by making the amqp_connection_state_t
object the amqp_socket_t owner, and tie its lifetime to the connection's
lifetime. This prevents a class of silly errors where the socket object
isn't freed, or the socket object is assigned to two different
connection objects
|
| |
|
| |
|
|
|
|
|
|
|
|
|
|
| |
Publicly define the error codes returned from the various public API
functions. The error codes are defined in the amqp_status_enum and are
all negative in value to work with functions that return positive
values.
OS and SSL specific codes are no longer munged into the error code, as
it is unlikely for that information to be useful to library users.
|
| |
|
| |
|
| |
|
|
Signed-off-by: Michael Steinert <mike.steinert@gmail.com>
|