From c467e9e12fb1e09c225e1fd6809bf16cebbe4742 Mon Sep 17 00:00:00 2001
From: Moe Jette <jette1@llnl.gov>
Date: Thu, 18 Dec 2003 21:04:57 +0000
Subject: [PATCH] Add missing time argument to slurm receive message function.
---
testsuite/slurm_unit/common/slurm_protocol_message_client.c | 4 ++--
testsuite/slurm_unit/common/slurm_protocol_message_server.c | 4 ++--
testsuite/slurm_unit/common/stream_server.c | 2 +-
3 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/testsuite/slurm_unit/common/slurm_protocol_message_client.c b/testsuite/slurm_unit/common/slurm_protocol_message_client.c
index 468104e68a2..5d264b2edb0 100644
--- a/testsuite/slurm_unit/common/slurm_protocol_message_client.c
+++ b/testsuite/slurm_unit/common/slurm_protocol_message_client.c
@@ -10,7 +10,7 @@ int main ( int argc , char * argv[] )
slurm_addr worker_address ;
slurm_msg_t msg;
slurm_msg_t resp;
- int16_t port;
+ int16_t port = 0;
update_node_msg_t *in_msg, out_msg;
/* init address sturctures */
@@ -32,7 +32,7 @@ int main ( int argc , char * argv[] )
slurm_send_node_msg( worker_socket , &msg ) ;
printf("Sending message=%s\n", out_msg.node_names);
- if (slurm_receive_msg (worker_socket, &resp) < 0) {
+ if (slurm_receive_msg (worker_socket, &resp, 0) < 0) {
printf("Error reading slurm_receive_msg %m\n");
exit(1);
}
diff --git a/testsuite/slurm_unit/common/slurm_protocol_message_server.c b/testsuite/slurm_unit/common/slurm_protocol_message_server.c
index 76ff7938e39..cc92ceb9ec9 100644
--- a/testsuite/slurm_unit/common/slurm_protocol_message_server.c
+++ b/testsuite/slurm_unit/common/slurm_protocol_message_server.c
@@ -11,7 +11,7 @@ int main ( int argc , char * argv[] )
slurm_addr peer_address ;
slurm_msg_t msg;
slurm_msg_t resp;
- int16_t port;
+ int16_t port = 0;
update_node_msg_t *in_msg, out_msg;
/* init address sturctures */
@@ -29,7 +29,7 @@ int main ( int argc , char * argv[] )
printf ( "worker socket %i\n", worker_socket ) ;
while (1) {
- if (slurm_receive_msg (worker_socket, &msg) == SLURM_SOCKET_ERROR ) {
+ if (slurm_receive_msg (worker_socket, &msg, 0) == SLURM_SOCKET_ERROR ) {
printf ("slurm_receive_msg error\n");
break;
}
diff --git a/testsuite/slurm_unit/common/stream_server.c b/testsuite/slurm_unit/common/stream_server.c
index 59346730525..3906ef45c6a 100644
--- a/testsuite/slurm_unit/common/stream_server.c
+++ b/testsuite/slurm_unit/common/stream_server.c
@@ -72,7 +72,7 @@ int main ( int argc , char * argv[] )
/* read thread */
pthread_t read_pth ;
- int16_t port;
+ int16_t port = 0;
if (argc > 1)
port = atoi( argv[1] ) ;
--
GitLab