/**************************************************************************/
/* CLIENT MESSAGES (domaine Internet, mode connecte , protocole TCP) */
/* */
/**************************************************************************/
#include <stdio.h> /* E/S standard: gets, printf, etc. */
#include <string.h> /* strlen etc. , memcpy */
/* compatibilite */
#ifdef WIN32
#include <winsock2.h>
#else
#include <sys/types.h> /* Divers designateurs de type */
#include <sys/socket.h> /* Sockets en general */
#include <netinet/in.h> /* Sockets du domaine Internet */
#include <netdb.h> /* hostent, gethostbyname, gethostbyaddr */
#include <arpa/inet.h>
#include <unistd.h>
#include <stdlib.h>
#define closesocket(s) close(s)
#endif
/**************************************************************************/
#define nomhoteserveur "localhost"
#define portserveur 11111
struct sockaddr_in adrserveur; /* Adresse du serveur */
struct sockaddr_in adrclient; /* Adresse du client */
int s; /* Numero socket */
char message[100]; /* Tampon Donnees niveau application */
struct hostent *h;
/**************************************************************************/
static int app (void)
{
/******************** CREATION DE LA SOCKET *****************************/
if ((s = socket (AF_INET, SOCK_STREAM, 6)) == -1) /* 6 = numero protocole TCP */
{
printf (">>> %s\n\n", "Creation socket impossible");
exit (1);
}
/************** INITIALISATION DE L'ADRESSE DU SERVEUR ***************/
adrserveur.sin_family = AF_INET;
if ((h = gethostbyname (nomhoteserveur)) == NULL)
{
printf ("\n>>> %s\n\n", "Nom hote serveur inconnu");
exit (1);
}
memcpy (&adrserveur.sin_addr, h->h_addr, h->h_length);
adrserveur.sin_port = portserveur;
/******** DEMANDE DE CONNEXION ********************************************/
if (connect (s, (struct sockaddr *) &adrserveur, sizeof (adrserveur)) ==
-1)
{
printf ("\n>>> %s\n\n", "Connexion au serveur impossible");
exit (1);
}
/******** EMISSION DU MESSAGE ************************/
char nom[50] = "c:\\fichier_send.txt";
int fin, current;
FILE *fichier_src = fopen (nom, "rb");
if (fichier_src == NULL)
{
perror ("fopen() ");
exit (0); //exit(EXIT_FAILURE);
}
fseek(fichier_src, 0, SEEK_END);
fin=ftell(fichier_src);
/* On se place a l'endroit qui va bien dans le binaire */
fseek (fichier_src, 0, SEEK_SET);
current = 0; /* Détermination de la position courante dans la fichier */
#define BUFSIZE 1024
int nb_lu;
char buffer[BUFSIZE];
memset (buffer, 0, BUFSIZE);
nb_lu = fread (buffer, sizeof (char), BUFSIZE, fichier_src);
int nb_send;
int inc = 1;
while ((nb_lu > 0) && (nb_lu <= fin - current))
{
if ((nb_send = send (s, buffer, nb_lu, 0)) == -1)
{
perror ("send() ");
exit (-1);
}
printf ("nb_send(boucle) \'%d \' = %d\n", inc, nb_send);
if (nb_send == -1)
perror ("send () ");
current = current + nb_lu;
memset (buffer, 0, BUFSIZE);
inc++;
if (fin - current < BUFSIZE)
{
break;
}
else
nb_lu = fread (buffer, sizeof (char), BUFSIZE, fichier_src);
}
memset (buffer, 0, BUFSIZE);
fread (buffer, sizeof (char), fin - current, fichier_src);
if ((nb_send = send (s, buffer, fin - current, 0)) == -1)
{
perror ("write() ");
}
printf ("nb_send = %d\n", nb_send);
fclose (fichier_src);
return 0;
}
int main (void)
{
int ret;
#if defined (WIN32)
WSADATA wsa_data;
int err = WSAStartup (MAKEWORD (2,2), &wsa_data);
if (!err)
{
puts ("WIN: winsock2: OK");
#else
int err;
#endif
err = app ();
#if defined (WIN32)
WSACleanup ();
}
#endif
if (err)
{
ret = EXIT_FAILURE;
}
else
{
ret = EXIT_SUCCESS;
}
return ret;
}
