Commit c676ac0f authored by Robert Haas's avatar Robert Haas

test_shm_mq: Use Size rather than uint64.

Commit 3bd261ca updated the API but
neglected to make the corresponding edits here.

Per Tom Lane and the buildfarm.
parent 49c0864d
...@@ -26,7 +26,7 @@ void _PG_init(void); ...@@ -26,7 +26,7 @@ void _PG_init(void);
Datum test_shm_mq(PG_FUNCTION_ARGS); Datum test_shm_mq(PG_FUNCTION_ARGS);
Datum test_shm_mq_pipelined(PG_FUNCTION_ARGS); Datum test_shm_mq_pipelined(PG_FUNCTION_ARGS);
static void verify_message(uint64 origlen, char *origdata, uint64 newlen, static void verify_message(Size origlen, char *origdata, Size newlen,
char *newdata); char *newdata);
/* /*
...@@ -50,7 +50,7 @@ test_shm_mq(PG_FUNCTION_ARGS) ...@@ -50,7 +50,7 @@ test_shm_mq(PG_FUNCTION_ARGS)
shm_mq_handle *outqh; shm_mq_handle *outqh;
shm_mq_handle *inqh; shm_mq_handle *inqh;
shm_mq_result res; shm_mq_result res;
uint64 len; Size len;
void *data; void *data;
/* A negative loopcount is nonsensical. */ /* A negative loopcount is nonsensical. */
...@@ -142,7 +142,7 @@ test_shm_mq_pipelined(PG_FUNCTION_ARGS) ...@@ -142,7 +142,7 @@ test_shm_mq_pipelined(PG_FUNCTION_ARGS)
shm_mq_handle *outqh; shm_mq_handle *outqh;
shm_mq_handle *inqh; shm_mq_handle *inqh;
shm_mq_result res; shm_mq_result res;
uint64 len; Size len;
void *data; void *data;
/* A negative loopcount is nonsensical. */ /* A negative loopcount is nonsensical. */
...@@ -247,9 +247,9 @@ test_shm_mq_pipelined(PG_FUNCTION_ARGS) ...@@ -247,9 +247,9 @@ test_shm_mq_pipelined(PG_FUNCTION_ARGS)
* Verify that two messages are the same. * Verify that two messages are the same.
*/ */
static void static void
verify_message(uint64 origlen, char *origdata, uint64 newlen, char *newdata) verify_message(Size origlen, char *origdata, Size newlen, char *newdata)
{ {
uint64 i; Size i;
if (origlen != newlen) if (origlen != newlen)
ereport(ERROR, ereport(ERROR,
......
...@@ -180,7 +180,7 @@ attach_to_queues(dsm_segment *seg, shm_toc *toc, int myworkernumber, ...@@ -180,7 +180,7 @@ attach_to_queues(dsm_segment *seg, shm_toc *toc, int myworkernumber,
static void static void
copy_messages(shm_mq_handle *inqh, shm_mq_handle *outqh) copy_messages(shm_mq_handle *inqh, shm_mq_handle *outqh)
{ {
uint64 len; Size len;
void *data; void *data;
shm_mq_result res; shm_mq_result res;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment