Skip to content

Commit 334d1bc

Browse files
authored
Fix disconnected C result handling (#590)
1 parent 05f8a6d commit 334d1bc

2 files changed

Lines changed: 8 additions & 0 deletions

File tree

include/pulsar/c/result.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -92,6 +92,7 @@ typedef enum
9292

9393
pulsar_result_MemoryBufferIsFull, /// Client-wide memory limit has been reached
9494
pulsar_result_Interrupted, /// Interrupted while waiting to dequeue
95+
pulsar_result_Disconnected, /// Client connection has been disconnected
9596
} pulsar_result;
9697

9798
// Return string representation of result code

tests/c/c_MessageTest.cc

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,9 @@
1818
*/
1919
#include <gtest/gtest.h>
2020
#include <lib/c/c_structs.h>
21+
#include <pulsar/Result.h>
2122
#include <pulsar/c/message.h>
23+
#include <pulsar/c/result.h>
2224

2325
#include "../PulsarFriend.h"
2426

@@ -48,3 +50,8 @@ TEST(c_MessageTest, ReplicationMetadataAccessors) {
4850

4951
pulsar_message_free(message);
5052
}
53+
54+
TEST(c_ResultTest, DisconnectedResultMatchesCppResult) {
55+
ASSERT_EQ(static_cast<int>(pulsar::ResultDisconnected), static_cast<int>(pulsar_result_Disconnected));
56+
ASSERT_STREQ("ResultDisconnected", pulsar_result_str(pulsar_result_Disconnected));
57+
}

0 commit comments

Comments
 (0)