Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Squash warnings about static initializers in tools.initializer_warnings | Alan Antonuk | 2015-05-03 | 5 | -24/+24 |
| | |||||
* | Check for heartbeats when in blocking send.timer_refactor | Alan Antonuk | 2015-05-03 | 2 | -5/+32 |
| | | | | | | | Check for recv heartbeats when blocking on sending to the socket. A blocked send can indicate that the broker is applying backpressure to publishers, it could also be that the TCP connection is dead, checking for recv heartbeats can give an earlier indication that the connection is broken. | ||||
* | Remove writev specific code. | Alan Antonuk | 2015-05-03 | 5 | -228/+5 |
| | |||||
* | Refactor frame encoding to its own function. | Alan Antonuk | 2015-05-03 | 1 | -40/+45 |
| | | | | | | | | | | | Refactor frame encoding into its own function. This is in preparation for doing heartbeats while waiting for the socket to become writable. As a de-optimization: stop using writev for the body frames. This now requires memcpy'ing the whole message body, which is an additional copy. On the flip side this is already done behind the scenes on Linux and anything using OpenSSL. This may also improve performance as fewer OS calls are made when writev doesn't support SO_NOSIGNAL. | ||||
* | Fixup of comment | Alan Antonuk | 2015-05-03 | 1 | -1/+1 |
| | |||||
* | Extract poll selection from send/writev | Alan Antonuk | 2015-05-03 | 1 | -30/+19 |
| | |||||
* | Extract deadline as param of try_writev/try_send | Alan Antonuk | 2015-05-03 | 3 | -20/+8 |
| | |||||
* | Refactor heartbeat timeout code to be simpler | Alan Antonuk | 2015-05-03 | 6 | -120/+140 |
| | | | | | Refactor the heartbeat timeout code to hopefully simplify it and hopefully make it less hairy to deal with in the future. | ||||
* | Rename amqp_timer_t related functions. | Alan Antonuk | 2015-05-03 | 5 | -71/+100 |
| | | | | | Rename amqp_timer_t related functions to improve readability of the code and clarify what they do. | ||||
* | Rename amqp_timer.[ch] to amqp_time.[ch]. | Alan Antonuk | 2015-05-03 | 10 | -10/+10 |
| | | | | Rename the files to better reflect the functions that they contain. | ||||
* | Correct configure_file in tests directory. | Alan Antonuk | 2015-05-02 | 1 | -1/+1 |
| | | | | COPY_ONLY should be COPYONLY. (Yay developer warnings). | ||||
* | Correct buffer recalc error in amqp_try_send | Alan Antonuk | 2015-04-30 | 1 | -1/+1 |
| | | | | | This one only shows up when send() does a partial read, which is why it wasn't caught immediately. Need some better tests for this. | ||||
* | Update README.md | Alan Antonuk | 2015-04-27 | 1 | -6/+3 |
| | |||||
* | Add nonblocking sockets in OpenSSL socket implnonblocking_socket | Alan Antonuk | 2015-04-19 | 1 | -5/+55 |
| | |||||
* | Simplify the timer/timeout logic. | Alan Antonuk | 2015-04-19 | 6 | -166/+146 |
| | | | | | | | | | | | Instead of passing around a start time and timeout interval, calculate this early and pass around the timeout value (as a implementation detail), then calculate against current timestamp. This simplifies the code, gives a more realistic 'timeout' for the function at the cost of potentially a few more timer pings. Conflicts: librabbitmq/amqp_socket.c | ||||
* | Refactor read/write poll function usage. | Alan Antonuk | 2015-04-19 | 2 | -88/+78 |
| | |||||
* | Add support for send/writev in non-blocking mode | Alan Antonuk | 2015-04-19 | 4 | -68/+197 |
| | |||||
* | Add support for non-blocking read in rabbitmq-c | Alan Antonuk | 2015-04-19 | 1 | -58/+60 |
| | |||||
* | Return NEEDREAD status from amqp_tcp_socket_recv | Alan Antonuk | 2015-04-19 | 2 | -4/+24 |
| | | | | | When tcp socket is in non-blocking mode, return AMQP_STATUS_PRIVATE_SOCKET_NEEDREAD when socket doesn't have any data in it. | ||||
* | Leave socket as non-blocking after connect | Alan Antonuk | 2015-04-19 | 1 | -12/+0 |
| | |||||
* | Simplify amqp_open_socket_nonblock. | Alan Antonuk | 2015-04-19 | 1 | -80/+65 |
| | |||||
* | Build only shared libs on AppVeyor config. | Alan Antonuk | 2015-04-18 | 1 | -1/+1 |
| | | | | rabbitmq-c doesn't currently work as a static lib on Win32. | ||||
* | Disable tests in appveyor config. | Alan Antonuk | 2015-04-18 | 1 | -1/+1 |
| | | | | | Tests require building statically, and its not possible to build statically on Win32. | ||||
* | fix WSAEINVAL WSAPoll due to POLERR in events | Ivan Efimov | 2015-04-08 | 1 | -1/+1 |
| | |||||
* | Unit test for verify sasl mechanisms | Bhasker Allam | 2015-04-05 | 5 | -3/+86 |
| | |||||
* | Add error codes for unsupported SASL type. | Bhasker Allam | 2015-04-05 | 3 | -1/+4 |
| | | | | | Add error codes and associated error strings when the broker does not support the desired SASL method. | ||||
* | Add EXTERNAL SASL mechanism. | Alan Antonuk | 2015-04-05 | 2 | -2/+73 |
| | |||||
* | Make tests only link against static rabbitmq | Alan Antonuk | 2015-04-05 | 3 | -7/+12 |
| | | | | | This gets around issues with symbol visibility issues while testing functions that are not declared to be visibile outside the library. | ||||
* | Remove trailing whitespace in CMakeLists.txt | Alan Antonuk | 2015-04-05 | 1 | -1/+1 |
| | |||||
* | Add minimal appveyor configuration.appveyor | Alan Antonuk | 2015-03-17 | 1 | -0/+14 |
| | |||||
* | Add support for heartbeats in tools.tools_heartbeat | Alan Antonuk | 2015-03-06 | 1 | -1/+10 |
| | |||||
* | Bumping revision for development. | Alan Antonuk | 2015-02-22 | 3 | -5/+5 |
| | |||||
* | Preparation for v0.6.0 release.v0.6.0 | Alan Antonuk | 2015-02-22 | 5 | -12/+21 |
| | |||||
* | Add methods to get frame_max and heartbeat of the connection | Bogdan Padalko | 2015-02-11 | 2 | -0/+40 |
| | |||||
* | Update rabbitmq-users list link | Alan Antonuk | 2015-01-30 | 1 | -1/+1 |
| | |||||
* | Give the docs section its own header | Dave Rolsky | 2015-01-12 | 1 | -0/+2 |
| | |||||
* | Add test for amqp_error_string2() for new values. | Alan Antonuk | 2015-01-06 | 5 | -2/+70 |
| | | | | | Add a tests that ensures that we add error message strings as we add new amqp_status_enum values. | ||||
* | Add error strings for new AMQP_STATUS values. | Alan Antonuk | 2015-01-06 | 2 | -1/+5 |
| | |||||
* | Enable SSL verification of hostname using certificates with Subject ↵ | Yevhen Kyriukha | 2015-01-06 | 1 | -29/+75 |
| | | | | | | | | Alternate Names DNS entries. Additional check for entries in SSL certificate. Signed-off-by: Yevhen Kyriukha <kirgene@gmail.com> | ||||
* | Check for closed socket in amqp_ssl_socket_send(). | Alan Antonuk | 2015-01-06 | 1 | -0/+4 |
| | |||||
* | Remove extra line from docs. | Alan Antonuk | 2015-01-02 | 1 | -1/+0 |
| | | | | | Remove extra text from documentation of amqp_basic_publish that was left there from an earlier edit. | ||||
* | Alloc an struct when decoding methods w/o fields | Alan Antonuk | 2014-12-29 | 2 | -24/+39 |
| | | | | | | | For consistency sake, allocate and return a struct when decoding methods that don't have fields. Fixes #225 | ||||
* | Add blocks to allow compilation with C89 compilers. | Alan Antonuk | 2014-12-29 | 1 | -77/+87 |
| | | | | C89 compilers can't do mixed definitions and code. | ||||
* | Check for double close/open in socket impl | Alan Antonuk | 2014-12-29 | 3 | -15/+41 |
| | | | | | | | 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 | ||||
* | Enable auto_delete & internal for exchange.declaredeclare_xchg_parms | Alan Antonuk | 2014-10-19 | 5 | -7/+10 |
| | | | | | | | | Enable auto_delete and internal parameters of amqp_exchange_declare() in codegen. These were once not generated because RabbitMQ did not support these parameters. The broker now supports these and so should we. This fixes #218 | ||||
* | Regen amqp_framing.[ch] to include autogend docs.framing_docs | Alan Antonuk | 2014-10-19 | 2 | -346/+921 |
| | | | | Doing this because the next change will cause a ton of diffs otherwise. | ||||
* | Enable SSL support for tools too. | Michael Fladischer | 2014-10-17 | 1 | -0/+4 |
| | | | | | In tools/common.c `#ifdef WITH_SSL` is used but never defined if SSL support is desired. | ||||
* | Fix spelling in comment for amqp_socket_writev() | Eddy Jansson | 2014-10-14 | 1 | -1/+1 |
| | |||||
* | Bumping revision for development. | Alan Antonuk | 2014-09-13 | 3 | -5/+5 |
| | |||||
* | Preparation for v0.5.2 release.v0.5.2 | Alan Antonuk | 2014-09-13 | 5 | -6/+14 |
| |