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
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
|
// SPDX-License-Identifier: GPL-2.0-or-later
/* SPDX-FileCopyrightText: 2004-2015 Simon Wunderlich <sw@simonwunderlich.de>
*/
#include "global.h"
#include <stdio.h>
#include <stdlib.h> /* free() */
#include <errno.h> /* errno() */
#include <unistd.h> /* close(), read(),write() */
#include <signal.h> /* SIGPIPE,SIG_ERR,SIGIO */
#ifdef G_SDL
#include <SDL.h> /* SDL_SetTimer() */
#endif
#ifdef SIGS
#include <signal.h> /* sighandler_t SIG_PIPE */
#endif
/* here go all the network functions */
/* */
/* right now, there is only a basic implementation for tcp-scokets. */
/* upcoming are unix-sockets and ipv6-support */
/* defines: */
uint8_t ibuf[MAXPLEN]; /* input buffer for a packet */
uint8_t obuf[MAXPLEN]; /* output buffer */
#ifdef SIGS
static int sigio = 0;
#endif
#ifdef SIGS
void sigpipe_handler(int S3DUNUSED(unused))
{
errs("sigpip_handler()", "there is a broken pipe somewhere");
}
void sigio_handler(int S3DUNUSED(unused))
{
sigio = 1;
}
#endif
/* maybe change the errors to fatal errors ... */
int network_init(void)
{
#ifdef SIGS
/* struct sigaction act; */
#endif
#ifdef TCP
tcp_init();
#endif
#ifdef SHM
shm_init();
#endif
#ifdef SIGS
if (signal(SIGPIPE, sigpipe_handler) == SIG_ERR)
errn("network_init():signal()", errno);
if (signal(SIGIO, sigio_handler) == SIG_ERR)
errn("s3d_init():signal()", errno);
#endif
return 0;
}
volatile int turn;
uint32_t net_turn_off(uint32_t S3DUNUSED(interval), void *S3DUNUSED(param))
{
s3dprintf(VLOW, "Warning: High traffic on Network, interrupting read.");
turn = 0;
return 0;
}
/* this basicly polls for new connection */
int network_main(void)
{
#ifdef G_SDL
SDL_TimerID net_off_timer;
#endif
turn = 1;
#ifdef TCP
#ifdef SIGS
if (sigio == 1) { /* as long as there is no locking/threadsafety, do like this ... */
#endif
tcp_pollport(); /* this polls for new processes */
#ifdef G_SDL
net_off_timer = SDL_AddTimer(50, net_turn_off, NULL);
#endif
while (turn && tcp_pollproc()) {
} /* if there is new data, loop please. this is for testing now, and should be combined with timing later .. */
#ifdef G_SDL
SDL_RemoveTimer(net_off_timer);
#endif
#ifdef SIGS
sigio = 0;
}
#endif
#endif
#ifdef SHM
shm_main();
#endif
return 0;
}
int n_remove(struct t_process *p)
{
switch (p->con_type) {
#ifdef SHM
case CON_SHM:
shm_remove(p);
break;
#endif
#ifdef TCP
case CON_TCP:
tcp_remove(p->sockid);
break;
#endif
}
p->con_type = CON_NULL;
return -1;
}
int n_readn(struct t_process *p, uint8_t * str, int s)
{
switch (p->con_type) {
#ifdef TCP
case CON_TCP:
return tcp_readn(p->sockid, str, s);
#endif
#ifdef SHM
case CON_SHM:
return shm_readn((struct buf_t *)p->shmsock.data_ctos, str, s);
#endif
}
return -1;
}
int n_writen(struct t_process *p, uint8_t * str, int s)
{
switch (p->con_type) {
#ifdef TCP
case CON_TCP:
return tcp_writen(p->sockid, str, s);
#endif
#ifdef SHM
case CON_SHM:
return shm_writen((struct buf_t *)p->shmsock.data_stoc, str, s);
#endif
}
return -1;
}
int network_quit(void)
{
#ifdef TCP
tcp_quit();
#endif
#ifdef SHM
shm_quit();
#endif
return 0;
}
|
