diff options
-rw-r--r-- | examples/amqp_consumer.c | 2 | ||||
-rw-r--r-- | examples/amqp_listen.c | 2 | ||||
-rw-r--r-- | examples/amqp_listenq.c | 2 | ||||
-rw-r--r-- | examples/amqp_rpc_sendstring_client.c | 2 | ||||
-rw-r--r-- | examples/amqps_consumer.c | 2 | ||||
-rw-r--r-- | examples/amqps_listen.c | 2 | ||||
-rw-r--r-- | examples/amqps_listenq.c | 2 | ||||
-rw-r--r-- | librabbitmq/amqp_socket.c | 4 |
8 files changed, 9 insertions, 9 deletions
diff --git a/examples/amqp_consumer.c b/examples/amqp_consumer.c index 11e186e..188abce 100644 --- a/examples/amqp_consumer.c +++ b/examples/amqp_consumer.c @@ -61,7 +61,7 @@ static void run(amqp_connection_state_t conn) uint64_t now; - while (1) { + for (;;) { amqp_rpc_reply_t ret; amqp_envelope_t envelope; diff --git a/examples/amqp_listen.c b/examples/amqp_listen.c index 3f86830..b452cb5 100644 --- a/examples/amqp_listen.c +++ b/examples/amqp_listen.c @@ -104,7 +104,7 @@ int main(int argc, char const *const *argv) die_on_amqp_error(amqp_get_rpc_reply(conn), "Consuming"); { - while (1) { + for (;;) { amqp_rpc_reply_t res; amqp_envelope_t envelope; diff --git a/examples/amqp_listenq.c b/examples/amqp_listenq.c index 3735645..37c06bb 100644 --- a/examples/amqp_listenq.c +++ b/examples/amqp_listenq.c @@ -85,7 +85,7 @@ int main(int argc, char const *const *argv) die_on_amqp_error(amqp_get_rpc_reply(conn), "Consuming"); { - while (1) { + for (;;) { amqp_rpc_reply_t res; amqp_envelope_t envelope; diff --git a/examples/amqp_rpc_sendstring_client.c b/examples/amqp_rpc_sendstring_client.c index 8a16281..5b1ebfc 100644 --- a/examples/amqp_rpc_sendstring_client.c +++ b/examples/amqp_rpc_sendstring_client.c @@ -160,7 +160,7 @@ int main(int argc, char *argv[]) size_t body_target; size_t body_received; - while (1) { + for (;;) { amqp_maybe_release_buffers(conn); result = amqp_simple_wait_frame(conn, &frame); printf("Result: %d\n", result); diff --git a/examples/amqps_consumer.c b/examples/amqps_consumer.c index 9a2ba36..17dfc7f 100644 --- a/examples/amqps_consumer.c +++ b/examples/amqps_consumer.c @@ -63,7 +63,7 @@ static void run(amqp_connection_state_t conn) uint64_t now; - while (1) { + for (;;) { amqp_rpc_reply_t ret; amqp_envelope_t envelope; diff --git a/examples/amqps_listen.c b/examples/amqps_listen.c index 16f6825..dc563d8 100644 --- a/examples/amqps_listen.c +++ b/examples/amqps_listen.c @@ -134,7 +134,7 @@ int main(int argc, char const *const *argv) die_on_amqp_error(amqp_get_rpc_reply(conn), "Consuming"); { - while (1) { + for (;;) { amqp_rpc_reply_t res; amqp_envelope_t envelope; diff --git a/examples/amqps_listenq.c b/examples/amqps_listenq.c index 7b26ce1..7095686 100644 --- a/examples/amqps_listenq.c +++ b/examples/amqps_listenq.c @@ -115,7 +115,7 @@ int main(int argc, char const *const *argv) die_on_amqp_error(amqp_get_rpc_reply(conn), "Consuming"); { - while (1) { + for (;;) { amqp_rpc_reply_t res; amqp_envelope_t envelope; diff --git a/librabbitmq/amqp_socket.c b/librabbitmq/amqp_socket.c index e8df286..6e2932f 100644 --- a/librabbitmq/amqp_socket.c +++ b/librabbitmq/amqp_socket.c @@ -805,7 +805,7 @@ static int wait_frame_inner(amqp_connection_state_t state, return res; } - while (1) { + for (;;) { int res; while (amqp_data_in_buffer(state)) { @@ -951,7 +951,7 @@ int amqp_simple_wait_frame_on_channel(amqp_connection_state_t state, } } - while (1) { + for (;;) { res = wait_frame_inner(state, decoded_frame, NULL); if (AMQP_STATUS_OK != res) { |