CrunchBang Linux Pastebin - collaborative debugging

pastebin is a collaborative debugging tool allowing you to share and modify code snippets while chatting on IRC, IM or a message board.

This site is developed to XHTML and CSS2 W3C standards. If you see this paragraph, your browser does not support those standards and you need to upgrade. Visit WaSP for a variety of options.

CrunchBang Linux Pastebin

Posted by Anonymous on Wed 10th Oct 11:36 (modification of post by view diff)
download | new post

  1. #include <stdio.h>
  2. #include <stdlib.h>
  3. #include <stdbool.h>
  4. #include <sys/types.h>
  5. #include <sys/socket.h>
  6. #include <netinet/in.h>
  7. #include <arpa/inet.h>
  8. #include <string.h>
  9. #include <unistd.h>
  10. #include <pthread.h>
  11.  
  12. #define  INVALID_SOCKET  (-1)
  13. #define  SOCKET_ERROR    (-1)
  14. #define  MAX_LENGTH      60000
  15.  
  16. bool stop = false;
  17.  
  18. void * sendThread ( void * args )
  19. {
  20.         int clientSocket;
  21.         ssize_t bytesSent = SOCKET_ERROR;
  22.         char sendBuf[MAX_LENGTH] = "";
  23.  
  24.         clientSocket = *(int *)args;
  25.  
  26.         while ( stop == false )
  27.         {
  28.                 if ( fgets( sendBuf, sizeof(sendBuf), stdin ) == NULL )
  29.                 {
  30.                         stop = true;
  31.                         shutdown( clientSocket, SHUT_RDWR );
  32.                         close( clientSocket );
  33.                         return NULL;
  34.                 }
  35.                 bytesSent = send( clientSocket, sendBuf, strlen(sendBuf), 0);
  36.                 if ( bytesSent == SOCKET_ERROR )
  37.                         fprintf ( stderr, "Error Sending Message.\n" );
  38.         }
  39.         shutdown( clientSocket, SHUT_RDWR );
  40.         close( clientSocket );
  41.         return NULL;
  42. }
  43.  
  44. void * recvThread ( void * args )
  45. {
  46.         int clientSocket;
  47.         ssize_t bytesRecv = 0;
  48.         char recvBuf[MAX_LENGTH] = "";
  49.  
  50.         clientSocket = *(int *)args;
  51.  
  52.         while ( bytesRecv != SOCKET_ERROR && stop == false )
  53.         {
  54.                 bytesRecv = recv (clientSocket, recvBuf, sizeof(recvBuf), 0);
  55.                 if ( bytesRecv == 0 )
  56.                 {
  57.                         printf ( "Connection Closed.\n" );
  58.                         stop = true;
  59.                         shutdown( clientSocket, SHUT_RDWR );
  60.                         close( clientSocket );
  61.                         return NULL;
  62.                 }
  63.                 if ( bytesRecv < 0 )
  64.                 {
  65.                         stop = true;
  66.                         shutdown( clientSocket, SHUT_RDWR );
  67.                         close( clientSocket );
  68.                         return NULL;
  69.                 }
  70.                 recvBuf[bytesRecv] = '\0';
  71.                 puts ( recvBuf );
  72.         }
  73.         shutdown( clientSocket, SHUT_RDWR );
  74.         close( clientSocket );
  75.         return NULL;
  76. }
  77.  
  78. int main ( void )
  79. {
  80.         int serverSocket, clientSocket = SOCKET_ERROR;
  81.         struct sockaddr_in serverService, clientService;
  82.         socklen_t addrlen;
  83.  
  84.         pthread_t pSendThread, pRecvThread;
  85.  
  86.         serverSocket = socket( AF_INET, SOCK_STREAM, IPPROTO_TCP );
  87.         if ( serverSocket == INVALID_SOCKET )
  88.         {
  89.                 fprintf ( stderr, "Socket Initialization Error.\n" );
  90.                 return EXIT_FAILURE;
  91.         }
  92.  
  93.         memset( &serverService, 0, sizeof(serverService) );
  94.         serverService.sin_family = AF_INET;
  95.         serverService.sin_addr.s_addr = INADDR_ANY;
  96.         serverService.sin_port = htons(2007);
  97.         if ( bind( serverSocket, (struct sockaddr *)&serverService, sizeof(serverService) ) == SOCKET_ERROR )
  98.         {
  99.                 fprintf ( stderr, "Bind failed.\n" );
  100.                 shutdown( serverSocket, SHUT_RDWR );
  101.                 close( serverSocket );
  102.                 return EXIT_FAILURE;
  103.         }
  104.         if ( listen( serverSocket, 1 ) == SOCKET_ERROR )
  105.         {
  106.                 fprintf ( stderr, "Listen failed.\n" );
  107.                 shutdown( serverSocket, SHUT_RDWR );
  108.                 close( serverSocket );
  109.                 return EXIT_FAILURE;
  110.         }
  111.         printf ( "Waiting for a client to connect...\n" );
  112.         clientSocket = SOCKET_ERROR;
  113.         addrlen = sizeof(clientService);
  114.         while ( clientSocket == SOCKET_ERROR )
  115.         {
  116.                 clientSocket = accept ( serverSocket, (struct sockaddr *)&clientService, &addrlen );
  117.         }
  118.         printf ( "%s:%d connected.\n", inet_ntoa(clientService.sin_addr), ntohs(clientService.sin_port) );
  119.  
  120.         if ( pthread_create( &pSendThread, NULL, sendThread, &clientSocket ) )
  121.         {
  122.                 fprintf ( stderr, "Message sending thread Creation Failed.\n" );
  123.         }
  124.         if ( pthread_create( &pRecvThread, NULL, recvThread, &clientSocket ) )
  125.         {
  126.                 fprintf ( stderr, "Message receiving thread Creation Failed.\n" );
  127.         }
  128.  
  129.         pthread_join( pSendThread, NULL );
  130.         pthread_join( pRecvThread, NULL );
  131.  
  132.         shutdown( clientSocket, SHUT_RDWR );
  133.         close( clientSocket );
  134.         shutdown( serverSocket, SHUT_RDWR );
  135.         close( serverSocket );
  136.         return EXIT_SUCCESS;
  137. }

Submit a correction or amendment below (click here to make a fresh posting)
After submitting an amendment, you'll be able to view the differences between the old and new posts easily.

Syntax highlighting:

To highlight particular lines, prefix each line with @@


Remember me