aboutsummaryrefslogtreecommitdiff
path: root/q6/c
diff options
context:
space:
mode:
authorAkshay <[email protected]>2020-11-04 13:51:35 +0000
committerAkshay <[email protected]>2020-11-04 13:51:35 +0000
commita903588ed52a877db413f72a018570fb6810ad2c (patch)
treeebda6c834eda43e144146e7ec401fbe4cec62d81 /q6/c
parenta56f00426303b91a2a01669261e4efd54b818d0f (diff)
add concurrent, iterative and UDP servers
Diffstat (limited to 'q6/c')
-rw-r--r--q6/c/client.c41
-rw-r--r--q6/c/server.c38
2 files changed, 79 insertions, 0 deletions
diff --git a/q6/c/client.c b/q6/c/client.c
new file mode 100644
index 0000000..12e00fa
--- /dev/null
+++ b/q6/c/client.c
@@ -0,0 +1,41 @@
1#include <stdio.h>
2#include <stdlib.h>
3#include <string.h>
4#include <unistd.h>
5#include <sys/types.h>
6#include <sys/socket.h>
7#include <arpa/inet.h>
8#include <netinet/in.h>
9#include <string.h>
10
11int main(int argc, char *argv[]) {
12 int sockfd;
13 struct sockaddr_in servaddr;
14 sockfd = socket(AF_INET, SOCK_DGRAM, 0);
15
16 servaddr.sin_family = AF_INET;
17 servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
18
19 int port = atoi(argv[1]);
20 servaddr.sin_port = htons(port);
21
22 int n;
23
24 socklen_t len = sizeof(servaddr);
25 char *buf = malloc(100);
26 fgets(buf, 100, stdin);
27 while(strcmp(buf, "quit\n") != 0) {
28 sendto(sockfd, buf, strlen(buf),
29 MSG_CONFIRM, (const struct sockaddr *) &servaddr,
30 sizeof(servaddr));
31
32 n = recvfrom(sockfd, buf, 100,
33 MSG_WAITALL, (struct sockaddr *) &servaddr,
34 &len);
35 printf("Recieved: %s", buf);
36 fgets(buf, 100, stdin);
37 }
38
39 close(sockfd);
40 return 0;
41}
diff --git a/q6/c/server.c b/q6/c/server.c
new file mode 100644
index 0000000..4b25070
--- /dev/null
+++ b/q6/c/server.c
@@ -0,0 +1,38 @@
1#include <stdio.h>
2#include <stdlib.h>
3#include <string.h>
4#include <unistd.h>
5#include <sys/types.h>
6#include <sys/socket.h>
7#include <arpa/inet.h>
8#include <netinet/in.h>
9
10int main(int argc, char *argv[]) {
11 int sockfd;
12 struct sockaddr_in servaddr, cli;
13 sockfd = socket(AF_INET, SOCK_DGRAM, 0);
14
15 servaddr.sin_family = AF_INET;
16 servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
17
18 int port = atoi(argv[1]);
19 servaddr.sin_port = htons(port);
20
21 bind(sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr));
22
23 socklen_t len = sizeof(cli);
24 while(1) {
25 int n;
26 char *buf = malloc(100);
27 while(
28 (n = recvfrom(sockfd, (char *)buf, 100, MSG_WAITALL, (struct sockaddr*) &cli, &len))
29 > 0
30 ) {
31 printf("Client message: %s\n", buf);
32 fflush(stdout);
33 sendto(sockfd, buf, n, MSG_CONFIRM, (const struct sockaddr *) &cli, len);
34 }
35 }
36 close(sockfd);
37 return 0;
38}