-
Notifications
You must be signed in to change notification settings - Fork 0
/
server.c
106 lines (99 loc) · 2.68 KB
/
server.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
95
96
97
98
99
100
101
102
103
104
105
106
/* ************************************************************************** */
/* */
/* ::: :::::::: */
/* server.c :+: :+: :+: */
/* +:+ +:+ +:+ */
/* By: hardy <hardy@student.42.fr> +#+ +:+ +#+ */
/* +#+#+#+#+#+ +#+ */
/* Created: 2022/04/20 18:49:00 by hardy #+# #+# */
/* Updated: 2022/05/01 02:26:48 by hardy ### ########.fr */
/* */
/* ************************************************************************** */
#include "minitalk.h"
t_data g_operation;
void
calloc_memory(int signo, siginfo_t *info, void *context)
{
if (!g_operation.client_pid)
{
g_operation.client_pid = (int) info->si_pid;
g_operation.context = context;
}
if (signo == SIGUSR2)
{
g_operation.message_length++;
}
else
{
g_operation.message = \
ft_calloc(g_operation.message_length + 1, sizeof(char));
g_operation.stage++;
}
}
void
get_message(int signo, siginfo_t *info, void *context)
{
if (signo == SIGUSR2)
{
g_operation.message[g_operation.counter] += \
(unsigned char) 128 >> g_operation.shift_count;
}
g_operation.shift_count++;
if (g_operation.shift_count == 8)
{
if (g_operation.message[g_operation.counter] == '\0')
{
g_operation.stage++;
return ;
}
g_operation.shift_count = 0;
g_operation.counter++;
}
if (!g_operation.client_pid && signo && !info)
{
g_operation.context = context;
}
}
void
operate(void)
{
struct sigaction s_sigaction;
s_sigaction.sa_sigaction = &calloc_memory;
s_sigaction.sa_flags = SA_SIGINFO;
sigaction(SIGUSR1, &s_sigaction, 0);
sigaction(SIGUSR2, &s_sigaction, 0);
while (g_operation.stage == 0)
{
pause();
send_singal(0, g_operation.client_pid);
}
s_sigaction.sa_sigaction = &get_message;
sigaction(SIGUSR1, &s_sigaction, 0);
sigaction(SIGUSR2, &s_sigaction, 0);
usleep(100);
while (g_operation.stage == 1 && send_singal(0, g_operation.client_pid))
{
pause();
}
ft_write(g_operation.message);
free(g_operation.message);
send_singal(0, g_operation.client_pid);
}
int
main(void)
{
printf("Server pid => %d\n", getpid());
fflush(stdout);
usleep(100);
while (1)
{
operate();
g_operation.stage = 0;
g_operation.client_pid = 0;
g_operation.message_length = 0;
g_operation.message = NULL;
g_operation.counter = 0;
g_operation.shift_count = 0;
}
return (0);
}