diff --git a/src/test/Makefile.am b/src/test/Makefile.am index a155fc0f75975c356d0399b42d137ac3b5a09afe..e751c4e427a415e1406f49f2662e89e021256e83 100644 --- a/src/test/Makefile.am +++ b/src/test/Makefile.am @@ -6,6 +6,6 @@ else elan_testprogs = endif -noinst_PROGRAMS = $(elan_testprogs) slurm_protocol_stream_client slurm_protocol_stream_server +noinst_PROGRAMS = $(elan_testprogs) LDADD = $(top_srcdir)/src/common/libcommon.la diff --git a/src/test/slurm_protocol_stream_client.c b/src/test/slurm_protocol_stream_client.c deleted file mode 100644 index 0024e52cc229dfa1f604aad1562c6fc459f5d3a6..0000000000000000000000000000000000000000 --- a/src/test/slurm_protocol_stream_client.c +++ /dev/null @@ -1,35 +0,0 @@ -#include <src/common/slurm_protocol_api.h> -#include <stdlib.h> -#include <stdio.h> -#include <string.h> - -int main ( int argc , char * argv[] ) -{ - /* declare file descriptors */ - slurm_fd worker_socket ; - - /* declare address structures */ - slurm_addr worker_address ; - - unsigned int buffer_len = 1024 ; - char buf_temp [ buffer_len ] ; - char * buffer = buf_temp ; - char * test_send = "This is a test of simple socket communication" ; - unsigned int test_send_len = strlen ( test_send ) ; - unsigned int length_io ; - - /* init address sturctures */ - slurm_set_addr_uint ( & worker_address , 7000 , SLURM_INADDR_ANY ) ; - /* connect socket */ - worker_socket = slurm_open_stream ( & worker_address ) ; - - length_io = slurm_read_stream ( worker_socket , buffer , buffer_len ) ; - printf ( "Bytes Recieved %i\n", length_io ) ; - - length_io = slurm_write_stream ( worker_socket , test_send , test_send_len ) ; - printf ( "Bytes Sent %i\n", length_io ) ; - - slurm_close_stream ( worker_socket ) ; - - return 0 ; -} diff --git a/src/test/slurm_protocol_stream_server.c b/src/test/slurm_protocol_stream_server.c deleted file mode 100644 index 7b9b60408747f6c0b05cd4121a33e79b2f616d3a..0000000000000000000000000000000000000000 --- a/src/test/slurm_protocol_stream_server.c +++ /dev/null @@ -1,43 +0,0 @@ -#include <netinet/in.h> -#include <src/common/slurm_protocol_api.h> -#include <stdlib.h> -#include <stdio.h> -#include <string.h> - -int main ( int argc , char * argv[] ) -{ - /* declare file descriptors */ - slurm_fd listen_socket ; - slurm_fd worker_socket ; - - /* declare address structures */ - slurm_addr listen_address ; - slurm_addr worker_address ; - - unsigned int buffer_len = 1024 ; - char buf_temp [ buffer_len ] ; - char * buffer = buf_temp ; - char * test_send = "This is a test of simple socket communication" ; - unsigned int test_send_len = strlen ( test_send ) ; - unsigned int length_io ; - - /* init address sturctures */ - slurm_set_addr_uint ( & listen_address , 7000, SLURM_INADDR_ANY ) ; - /* open and listen on socket */ - listen_socket = slurm_listen_stream ( & listen_address ) ; - /* accept socket */ - while ( true ) - { - worker_socket = slurm_accept_stream ( listen_socket , & worker_address ) ; - - length_io = slurm_write_stream ( worker_socket , test_send , test_send_len ) ; - printf ( "Bytes Sent %i\n", length_io ) ; - - length_io = slurm_read_stream ( worker_socket , buffer , buffer_len ) ; - printf ( "Bytes Recieved %i\n", length_io ) ; - } - slurm_close_stream ( worker_socket ) ; - slurm_close_stream ( listen_socket ) ; - - return 0 ; -}