Fixed code to check version numbers on messages.

src/api/config_info.c

@@ -60,14 +60,15 @@ slurm_load_build (time_t update_time, struct build_table **build_table_ptr )
 	if ( ( rc = slurm_send_controller_msg ( sockfd , & request_msg ) ) == SLURM_SOCKET_ERROR )
 		return SLURM_SOCKET_ERROR ;	
 	
-
 	/* receive message */
 	if ( ( msg_size = slurm_receive_msg ( sockfd , & response_msg ) ) == SLURM_SOCKET_ERROR )
 		return SLURM_SOCKET_ERROR ;	
 	/* shutdown message connection */
 	if ( ( rc = slurm_shutdown_msg_conn ( sockfd ) ) == SLURM_SOCKET_ERROR )
 		return SLURM_SOCKET_ERROR ;	
-	
+	if ( msg_size )
+		return msg_size;
+
 	switch ( response_msg . msg_type )
         {
                 case RESPONSE_BUILD_INFO:

src/api/job_info.c

@@ -123,6 +123,8 @@ slurm_load_jobs (time_t update_time, job_info_msg_t **job_info_msg_pptr)
         /* shutdown message connection */
         if ( ( rc = slurm_shutdown_msg_conn ( sockfd ) ) == SLURM_SOCKET_ERROR )
                 return SLURM_SOCKET_ERROR ;
+	if ( msg_size )
+		return msg_size;
 
 	switch ( response_msg . msg_type )
 	{

src/api/node_info.c

@@ -106,6 +106,8 @@ slurm_load_node (time_t update_time, node_info_msg_t **node_info_msg_pptr)
         /* shutdown message connection */
         if ( ( rc = slurm_shutdown_msg_conn ( sockfd ) ) == SLURM_SOCKET_ERROR )
                 return SLURM_SOCKET_ERROR ;
+	if ( msg_size )
+		return msg_size;
 
 	switch ( response_msg . msg_type )
 	{

src/api/partition_info.c

@@ -100,6 +100,8 @@ slurm_load_partitions (time_t update_time, partition_info_msg_t **partition_info
         /* shutdown message connection */
         if ( ( rc = slurm_shutdown_msg_conn ( sockfd ) ) == SLURM_SOCKET_ERROR )
                 return SLURM_SOCKET_ERROR ;
+	if ( msg_size )
+		return msg_size;
 
 	switch ( response_msg . msg_type )
 	{

src/common/slurm_protocol_pack.c

@@ -598,7 +598,7 @@ void pack_job_desc ( job_desc_msg_t * job_desc_ptr, void ** buf_ptr , int * buff
 
 }
 
-/* unpack_msg
+/* unpack_job_desc
  * unpacks a job_desc struct
  * header 	- the body structure to unpack
  * buf_ptr	- destination of the pack, note buffer will be incremented by underlying unpack routines

src/common/slurm_protocol_util.c

@@ -8,7 +8,7 @@ uint32_t check_header_version( header_t * header)
 {
 	if ( header -> version != SLURM_PROTOCOL_VERSION )
 	{
-		debug ( "Invalid Protocol Version from " ) ;
+		info ( "Invalid Protocol Version %d ", header -> version ) ;
 		return SLURM_PROTOCOL_VERSION_ERROR ;
 	}
 	return SLURM_PROTOCOL_SUCCESS ;