qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acon...@apache.org
Subject qpid-proton git commit: PROTON-1914: [c] reproducer for settling an incomplete incoming
Date Fri, 10 Aug 2018 19:04:32 GMT
Repository: qpid-proton
Updated Branches:
  refs/heads/master f790480d5 -> 1d64ea54d


PROTON-1914: [c] reproducer for settling an incomplete incoming


Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/1d64ea54
Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/1d64ea54
Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/1d64ea54

Branch: refs/heads/master
Commit: 1d64ea54d7609471d322585d907e0b330c3fc5cf
Parents: f790480
Author: Alan Conway <aconway@redhat.com>
Authored: Fri Aug 10 14:55:48 2018 -0400
Committer: Alan Conway <aconway@redhat.com>
Committed: Fri Aug 10 14:55:48 2018 -0400

----------------------------------------------------------------------
 c/tests/connection_driver.c | 48 ++++++++++++++++++++++++++++++++++++++++
 1 file changed, 48 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/1d64ea54/c/tests/connection_driver.c
----------------------------------------------------------------------
diff --git a/c/tests/connection_driver.c b/c/tests/connection_driver.c
index 16d75a3..9558244 100644
--- a/c/tests/connection_driver.c
+++ b/c/tests/connection_driver.c
@@ -530,6 +530,53 @@ static void test_duplicate_link_client(test_t *t) {
   test_connection_drivers_destroy(&client, &server);
 }
 
+/* Settling an incomplete delivery should not cause an error */
+static void test_settle_incomplete_receiver(test_t *t) {
+  /* This test will fail till PROTON-1832 is fully fixed */
+  t->inverted = true;
+
+  /* Set up the link, give credit, start the delivery */
+  test_connection_driver_t client, server;
+  test_connection_driver_init(&client, t, send_client_handler, NULL);
+  test_connection_driver_init(&server, t, delivery_handler, NULL);
+  pn_transport_set_server(server.driver.transport);
+  pn_connection_open(client.driver.connection);
+
+  test_connection_drivers_run(&client, &server);
+  pn_link_t *rcv = server.handler.link;
+  pn_link_t *snd = client.handler.link;
+  char data[100] = {0};          /* Dummy data to send. */
+  char rbuf[sizeof(data)] = {0}; /* Read buffer for incoming data. */
+  pn_link_flow(rcv, 1);
+  pn_delivery(snd, PN_BYTES_LITERAL(1)); /* Prepare to send */
+  test_connection_drivers_run(&client, &server);
+
+  /* Send/receive a frame */
+  TEST_INT_EQUAL(t, sizeof(data), pn_link_send(snd, data, sizeof(data)));
+  test_connection_drivers_run(&client, &server);
+  TEST_HANDLER_EXPECT_LAST(&server.handler, PN_DELIVERY);
+  TEST_INT_EQUAL(t, sizeof(data), pn_link_recv(rcv, rbuf, sizeof(data)));
+  test_connection_drivers_run(&client, &server);
+
+  /* Settle the receiver's delivery */
+  pn_delivery_settle(pn_link_current(rcv));
+  test_connection_drivers_run(&client, &server);
+  TEST_COND_EMPTY(t, pn_connection_remote_condition(client.driver.connection));
+  TEST_COND_EMPTY(t, pn_connection_condition(server.driver.connection));
+
+  /* Send/receive a frame, should not cause error */
+  TEST_INT_EQUAL(t, sizeof(data), pn_link_send(snd, data, sizeof(data)));
+  test_connection_drivers_run(&client, &server);
+  TEST_HANDLER_EXPECT_LAST(&server.handler, PN_DELIVERY);
+  TEST_INT_EQUAL(t, sizeof(data), pn_link_recv(rcv, rbuf, sizeof(data)));
+  test_connection_drivers_run(&client, &server);
+  TEST_COND_EMPTY(t, pn_connection_remote_condition(client.driver.connection));
+  TEST_COND_EMPTY(t, pn_connection_condition(server.driver.connection));
+
+  test_connection_driver_destroy(&client);
+  test_connection_driver_destroy(&server);
+}
+
 int main(int argc, char **argv) {
   int failed = 0;
   RUN_ARGV_TEST(failed, t, test_message_transfer(&t));
@@ -539,5 +586,6 @@ int main(int argc, char **argv) {
   RUN_ARGV_TEST(failed, t, test_session_flow_control(&t));
   RUN_ARGV_TEST(failed, t, test_duplicate_link_server(&t));
   RUN_ARGV_TEST(failed, t, test_duplicate_link_client(&t));
+  RUN_ARGV_TEST(failed, t, test_settle_incomplete_receiver(&t));
   return failed;
 }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org


Mime
View raw message