unx_socket_serv.c
1.76 KB
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
107
108
109
110
111
112
113
114
115
116
#include <string.h>
#include <errno.h>
#include <unistd.h>
#include <stdio.h>
#include <signal.h>
#include <scot/socket.h>
#include <scot/socket_un.h>
#include <scot/stream.h>
#include <scot/exception.h>
#include <scot_common.h>
struct scot_socket * sock;
struct scot_socket * con_sock;
void
on_exit_func (void)
{
if (con_sock != NULL)
scot_socket_free (con_sock);
scot_socket_free (sock);
exc_end ();
}
void
exit_func (int inum)
{
exit (0);
}
int
main (int argc, char * argv [])
{
excenv_t * ee;
signal (SIGINT, exit_func);
atexit (on_exit_func);
TRY
{
sock = scot_socket_un_new ("/tmp/socket");
scot_socket_listen (sock);
}
CATCH (ee)
{
exception_t *e;
while (e = retrive_exception (ee))
{
print_exception (e);
if (EXC_IN_THIS_TRY (e))
{
switch (exc_errnum_get (e))
{
case SCOT_SOCKET_LISTEN_FAIL:
scot_socket_free (sock);
case SCOT_SOCKET_NEW_FAIL:
break;
}
}
free_exception (e);
}
free_catched (ee);
}
TRY
{
while ((con_sock = scot_socket_accept (sock)) >= 0)
{
struct scot_stream * sock_stream;
int i, n;
char puffer [1024];
sock_stream = (struct scot_stream *) con_sock;
while ((n = recv (sock_stream->handle.sock, puffer, 1024, 0)) > 0)
{
printf ("Server: ");
if (puffer [0] == 'q')
break;
for (i=0; i<n-1; i++)
printf ("%c=%02x ", puffer[i], puffer[i]);
printf ("\n");
fflush (stdout);
}
scot_socket_free (con_sock);
con_sock = NULL;
}
}
CATCH (ee)
{
exception_t *e;
while (e = retrive_exception (ee))
{
print_exception (e);
free_exception (e);
}
free_catched (ee);
}
scot_socket_free (sock);
return 0;
}