Blame SOURCES/0011-src-test-rgw-amqp_mock.cc.patch
|
 |
1f1c83 |
--- a/src/test/rgw/amqp_mock.cc
|
|
|
1f1c83 |
+++ b/src/test/rgw/amqp_mock.cc
|
|
|
1f1c83 |
@@ -291,7 +291,11 @@ amqp_confirm_select_ok_t* amqp_confirm_select(amqp_connection_state_t state, amq
|
|
|
1f1c83 |
return state->confirm;
|
|
|
1f1c83 |
}
|
|
|
1f1c83 |
|
|
|
1f1c83 |
-int amqp_simple_wait_frame_noblock(amqp_connection_state_t state, amqp_frame_t *decoded_frame, struct timeval* tv) {
|
|
|
1f1c83 |
+extern "C" {
|
|
|
1f1c83 |
+
|
|
|
1f1c83 |
+int amqp_simple_wait_frame_noblock(amqp_connection_state_t state,
|
|
|
1f1c83 |
+ amqp_frame_t *decoded_frame,
|
|
|
1f1c83 |
+ const struct timeval* tv) {
|
|
|
1f1c83 |
if (state->socket && state->socket->open_called &&
|
|
|
1f1c83 |
state->login_called && state->channel1 && state->channel2 && state->exchange &&
|
|
|
1f1c83 |
state->queue && state->consume && state->confirm && !FAIL_NEXT_READ) {
|
|
|
1f1c83 |
@@ -345,6 +349,7 @@ int amqp_simple_wait_frame_noblock(amqp_connection_state_t state, amqp_frame_t *
|
|
|
1f1c83 |
}
|
|
|
1f1c83 |
return AMQP_STATUS_CONNECTION_CLOSED;
|
|
|
1f1c83 |
}
|
|
|
1f1c83 |
+} // extern "C"
|
|
|
1f1c83 |
|
|
|
1f1c83 |
amqp_basic_consume_ok_t* amqp_basic_consume(
|
|
|
1f1c83 |
amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t queue,
|