-
Notifications
You must be signed in to change notification settings - Fork 1
/
Copy pathclient.c
94 lines (86 loc) · 1.95 KB
/
client.c
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
/*
*
* Created by Akshat Singhal on 12/04/18.
*
*/
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <netdb.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>
#include <errno.h>
#include <arpa/inet.h>
#include <pthread.h>
int sockfd = 0;
char id[2];
pthread_t tid1,tid2;
void *read_msg(void *arg)
{
char str[100];
read(sockfd,str, 100);
if(strcmp(str,"exit")==0)
{
printf("OK Bye!\n");
close(sockfd);
exit(0);
}
printf("%c says: %s\n",str[99],str);
pthread_create(&tid1,NULL,read_msg,NULL);
return (NULL);
}
void *write_msg(void *arg)
{
char str[100];
fflush(stdout);
scanf("%[^\n]%*c", str);
str[99] = id[0];
write(sockfd, str, 100);
if(strcmp(str,"exit")==0)
{
close(sockfd);
exit(0);
}
pthread_create(&tid2,NULL,write_msg,NULL);
return (NULL);
}
int main(int argc, char *argv[])
{
int n = 0;
char recvBuff[1024];int temp;
struct sockaddr_in serv_addr;
char s[100];
if(argc != 2)
{
printf("\n Usage: %s <ip of server> \n",argv[0]);
return 1;
}
memset(recvBuff, '0',sizeof(recvBuff));
if((sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0)
{
printf("\n Error : Could not create socket \n");
return 1;
}
memset(&serv_addr, '0', sizeof(serv_addr));
serv_addr.sin_family = AF_INET;
serv_addr.sin_port = htons(5000);
printf("Server address used is: %s\n", argv[1]);
if(inet_pton(AF_INET, argv[1], &serv_addr.sin_addr)<=0)
{
printf("\n inet_pton error occured\n");
return 1;
}
if( connect(sockfd, (struct sockaddr *)&serv_addr, sizeof(serv_addr)) < 0)
{
printf("\n Error : Connect Failed \n");
return 1;
}
read(sockfd, id, 5);
printf("My ID : %c\n", id[0]);
pthread_create(&tid1,NULL,read_msg,NULL);
pthread_create(&tid2,NULL,write_msg,NULL);
while(1);
return 0;
}