Obsolete
/
libipc-old
Archived
3
0
Fork 0

client can send a first message : service version

more_to_read
lapupe 2016-09-16 15:22:14 +02:00
parent 546fb4b077
commit 66fe69e711
3 changed files with 77 additions and 5 deletions

View File

@ -7,10 +7,36 @@
#include <stdio.h> #include <stdio.h>
#include <stdlib.h> #include <stdlib.h>
#include <errno.h> #include <errno.h>
#include <string.h>
#define BUF_SIZE 1024
#define PORT 6000 #define PORT 6000
void write_message(int sock, const char *buffer)
{
if(send(sock, buffer, strlen(buffer), 0) < 0)
{
perror("send()");
exit(errno);
}
}
int read_message(int sock, char *buffer)
{
int n = 0;
if((n = recv(sock, buffer, BUF_SIZE - 1, 0)) < 0)
{
perror("recv()");
/* if recv error we disonnect the client */
n = 0;
}
buffer[n] = 0;
return n;
}
int main(int argc, char ** argv) { int main(int argc, char ** argv) {
int sock = socket(AF_INET, SOCK_STREAM, 0); int sock = socket(AF_INET, SOCK_STREAM, 0);
@ -31,6 +57,8 @@ int main(int argc, char ** argv) {
exit(errno); exit(errno);
} }
write_message(sock, "pongd 5");
close(sock); close(sock);
return 0; return 0;

View File

@ -7,8 +7,10 @@
#include <stdio.h> #include <stdio.h>
#include <stdlib.h> #include <stdlib.h>
#include <errno.h> #include <errno.h>
#include <string.h>
#define PORT 6000 #define PORT 6000
#define BUF_SIZE 1024
int init_connection(void) int init_connection(void)
{ {
@ -40,15 +42,41 @@ int init_connection(void)
return sock; return sock;
} }
void write_message(int sock, const char *buffer)
{
if(send(sock, buffer, strlen(buffer), 0) < 0)
{
perror("send()");
exit(errno);
}
}
// void printClientAddr(struct sockaddr_in &csin) { int read_message(int sock, char *buffer)
// printf("%s\n", ); {
// } int n = 0;
if((n = recv(sock, buffer, BUF_SIZE - 1, 0)) < 0)
{
perror("recv()");
/* if recv error we disonnect the client */
n = 0;
}
buffer[n] = 0;
return n;
}
void printClientAddr(struct sockaddr_in *csin) {
printf("%s\n", inet_ntoa(csin->sin_addr));
printf("%u\n", ntohs(csin->sin_port));
}
int main(int argc, char * argv[], char **env) { int main(int argc, char * argv[], char **env) {
int sock = init_connection(); int sock = init_connection();
char buffer[BUF_SIZE];
struct sockaddr_in csin = { 0 }; struct sockaddr_in csin = { 0 };
socklen_t sinsize = sizeof csin; socklen_t sinsize = sizeof csin;
@ -59,7 +87,16 @@ int main(int argc, char * argv[], char **env) {
exit(errno); exit(errno);
} }
printf("new client\n"); //printf("new client\n");
printClientAddr(&csin);
int n = read_message(csock, buffer);
if (n == -1) {
perror("read_message()");
}else {
printf("%s\n",buffer );
}
close(sock); close(sock);
close(csock); close(csock);

View File

@ -1,9 +1,16 @@
#ifndef __TCPDSERVER_H__ #ifndef __TCPDSERVER_H__
#define __TCPDSERVER_H__ #define __TCPDSERVER_H__
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
int initConnection (); int initConnection ();
void endConnection (int sock, int csock); void endConnection (int sock, int csock);
void printClientAddr (struct sockaddr_in *csin);
void write_message(int sock, const char *buffer);
int read_message(int sock, char *buffer);
#endif #endif