K0RB4K/qotd
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

working udp

Browse Source
This commit is contained in:
Arthur-Coppey 2021-10-15 14:08:44 +02:00
parent 61221bffff
commit 7ad0e7ad56
7 changed files with 181 additions and 54 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
CMakeLists.txt
View File

@ -4,4 +4,4 @@ project(qotd C)
set(CMAKE_C_STANDARD 99) set(CMAKE_C_STANDARD 99)
add_executable(server server/main.c server/quote.c server/quote.h server/server.c server/server.h) add_executable(server server/main.c server/quote.c server/quote.h server/server.c server/server.h)
add_executable(client client/main.c) add_executable(client client/main.c client/client.c client/client.h)

85
client/client.c Normal file
View File

@ -0,0 +1,85 @@
//
// Created by k0rb4k on 11/10/2021.
//
#include "client.h"
int tcp() {
struct sockaddr_in server;
int sock;
int proto = IPPROTO_IP;
enum __socket_type socketType = SOCK_STREAM;
server.sin_family = AF_INET;
server.sin_addr.s_addr = inet_addr("127.0.0.1");
server.sin_port = htons(17);
sock = socket(server.sin_family, socketType, proto);
if (sock == -1) {
puts("socket not created");
return 1;
}
puts("socket created");
if (connect(sock, (const struct sockaddr *) &server, sizeof(server)) < 0) {
puts("connection failed");
return 2;
}
puts("connected to server");
char *payload = "I dream of sushi";
if (send(sock, payload, strlen(payload), 0) < 0) {
puts("error while sending payload");
return 3;
}
puts("payload sent");
char response[2048];
if (recv(sock, response, 2048, 0) < 0) {
puts("receive failed");
return 4;
}
printf("server response : %s\n", response);
close(sock);
return 0;
}
int udp() {
struct sockaddr_in server;
int sock;
int proto = IPPROTO_UDP;
enum __socket_type socketType = SOCK_DGRAM;
server.sin_family = AF_INET;
server.sin_addr.s_addr = inet_addr("127.0.0.1");
server.sin_port = htons(17);
sock = socket(server.sin_family, socketType, proto);
if (sock == -1) {
puts("socket not created");
return 1;
}
puts("socket created");
char *payload = "I dream of sushi";
if (sendto(sock, payload, strlen(payload), 0, (const struct sockaddr *) &server, sizeof server) < 0) {
puts("error while sending payload");
return 3;
}
puts("payload sent");
char response[2048];
if (recvfrom(sock, response, 2048, 0, (struct sockaddr *) &server, (socklen_t *) sizeof server) < 0) {
puts("receive failed");
return 4;
}
printf("server response : %s\n", response);
close(sock);
return 0;
}

19
client/client.h Normal file
View File

@ -0,0 +1,19 @@
//
// Created by k0rb4k on 11/10/2021.
//
#ifndef QOTD_CLIENT_H
#define QOTD_CLIENT_H
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <string.h>
#include <stdio.h>
#include <unistd.h>
int tcp();
int udp();
#endif //QOTD_CLIENT_H

45
client/main.c
View File

@ -2,50 +2,11 @@
// Created by k0rb4k on 22/04/2021. // Created by k0rb4k on 22/04/2021.
// //
#include <sys/socket.h> #include "client.h"
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <stdio.h>
int main(int argc, char *argv[]) { int main(int argc, char *argv[]) {
struct sockaddr_in server; // TODO: arg options for tcp or udp
int sock; udp();
server.sin_family = AF_INET;
server.sin_addr.s_addr = inet_addr("127.0.0.1");
server.sin_port = htons(17);
sock = socket(server.sin_family, SOCK_STREAM, IPPROTO_IP);
if (sock == -1) {
puts("socket not created");
return 1;
}
puts("socket created");
if (connect(sock, (const struct sockaddr *) &server, sizeof(server)) < 0) {
puts("connection failed");
return 2;
}
puts("connected to server");
char *payload = "I dream of sushi";
if (send(sock, payload, strlen(payload), 0) < 0) {
puts("error while sending payload");
return 3;
}
puts("payload sent");
char response[2048];
if (recv(sock, response, 2048, 0) < 0) {
puts("receive failed");
return 4;
}
printf("server response : %s\n", response);
close(sock);
return 0; return 0;
} }

2
server/main.c
View File

@ -4,7 +4,7 @@ int main(int argc, char *argv[]) {
// char quote[1024]; // char quote[1024];
// getRandomQuote(quote); // getRandomQuote(quote);
// printf("%s\n", quote); // printf("%s\n", quote);
tcpServer(); udpServer();
return 0; return 0;
} }

77
server/server.c
View File

@ -4,10 +4,18 @@
#include "server.h" #include "server.h"
//TODO: refactor
//TODO: object-like C
extern int errno;
unsigned long addressLength = sizeof(struct sockaddr_in);
void tcpServer() { void tcpServer() {
int serverSocket, clientSocket; int serverSocket, clientSocket;
long read_size; long recvLen;
unsigned long addressLength; // unsigned long addressLength = sizeof(struct sockaddr_in);
struct sockaddr_in serverAddress, clientAddress; struct sockaddr_in serverAddress, clientAddress;
char quote[MESSAGE_STRING_LENGTH] = ""; char quote[MESSAGE_STRING_LENGTH] = "";
char clientMessage[MESSAGE_STRING_LENGTH] = ""; char clientMessage[MESSAGE_STRING_LENGTH] = "";
@ -38,13 +46,13 @@ void tcpServer() {
/*accept connections*/ /*accept connections*/
//TODO: t h r e a d s //TODO: t h r e a d s
addressLength = sizeof(struct sockaddr_in); while ((clientSocket = accept(serverSocket, (struct sockaddr *) &clientAddress, (socklen_t *) &addressLength)) >=
while ((clientSocket = accept(serverSocket, (struct sockaddr *) &clientAddress, (socklen_t *) &addressLength)) >= 0) { 0) {
puts("client connected"); puts("client connected");
/*receive data*/ /*receive data*/
while ((read_size = recv(clientSocket, clientMessage, MESSAGE_STRING_LENGTH, 0))) { while ((recvLen = recv(clientSocket, clientMessage, MESSAGE_STRING_LENGTH, 0))) {
if (read_size < 0) { if (recvLen < 0) {
puts("receive failed"); puts("receive failed");
} else { } else {
printf("client says: %s\n", clientMessage); printf("client says: %s\n", clientMessage);
@ -52,7 +60,7 @@ void tcpServer() {
/*send data*/ /*send data*/
getRandomQuote(quote); getRandomQuote(quote);
printf("responding: \"%s\"\n", quote); printf("responding: \"%s\"\n", quote);
write(clientSocket, quote, strlen(quote)); send(clientSocket, quote, strlen(quote), 0);
} }
} }
@ -65,6 +73,57 @@ void tcpServer() {
} }
} }
void udpServer() { _Noreturn void udpServer() {
//TODO: udp handling int sock;
// unsigned long addressLength = sizeof(struct sockaddr_in);
struct sockaddr_in serverAddress, clientAddress;
char quote[MESSAGE_STRING_LENGTH] = "";
char clientMessage[MESSAGE_STRING_LENGTH] = "";
/*initialize sock info*/
memset(&serverAddress, 0, addressLength);
memset(&clientAddress, 0, addressLength);
serverAddress.sin_family = AF_INET;
serverAddress.sin_addr.s_addr = INADDR_ANY;
serverAddress.sin_port = htons(17);
/*create sock*/
sock = socket(serverAddress.sin_family, SOCK_DGRAM, IPPROTO_UDP);
if (sock == -1) {
puts("sock not created");
exit(1);
}
puts("sock created");
/*bind sock to address:port*/
if (bind(sock, (const struct sockaddr *) &serverAddress, sizeof serverAddress) < 0) {
puts("bind failed");
exit(2);
}
puts("address bound");
/*accept connections*/
//TODO: t h r e a d s ?
while (1) {
/*receive data*/
int recvLen = recvfrom(sock, clientMessage, MESSAGE_STRING_LENGTH, 0,
(struct sockaddr *) &clientAddress, (socklen_t *) &addressLength);
uint16_t port = ntohs(clientAddress.sin_port);
char *ipv4 = inet_ntoa(clientAddress.sin_addr);
printf("recvLen = %d from = %s:%d\nmsg = `%s`\n", recvLen, ipv4, port, clientMessage);
perror("recvfrom");
if (recvLen >= 0) {
printf("client says: %s\n", clientMessage);
/*send data*/
getRandomQuote(quote);
printf("responding: `%s`\n", quote);
sendto(sock, strcat(quote, "\n"), sizeof quote, 0, (struct sockaddr *) &clientAddress, addressLength);
perror("sendto");
}
}
} }

5
server/server.h
View File

@ -6,11 +6,14 @@
#define QOTD_SERVER_H #define QOTD_SERVER_H
#include <sys/socket.h> #include <sys/socket.h>
//#include <sys/types.h>
#include <netinet/in.h> #include <netinet/in.h>
#include <arpa/inet.h>
#include <stdlib.h> #include <stdlib.h>
#include <unistd.h> #include <unistd.h>
#include <string.h> #include <string.h>
#include <stdio.h> #include <stdio.h>
#include <errno.h>
#include "quote.h" #include "quote.h"
@ -18,6 +21,6 @@
void tcpServer(); void tcpServer();
void udpServer(); _Noreturn void udpServer();
#endif //QOTD_SERVER_H #endif //QOTD_SERVER_H