2 * Copyright (c) 1995 Danny Gasparovski.
4 * Please read the file COPYRIGHT for the
5 * terms and conditions of the copyright.
11 insque(void *a
, void *b
)
13 register struct quehead
*element
= (struct quehead
*) a
;
14 register struct quehead
*head
= (struct quehead
*) b
;
15 element
->qh_link
= head
->qh_link
;
16 head
->qh_link
= (struct quehead
*)element
;
17 element
->qh_rlink
= (struct quehead
*)head
;
18 ((struct quehead
*)(element
->qh_link
))->qh_rlink
19 = (struct quehead
*)element
;
25 register struct quehead
*element
= (struct quehead
*) a
;
26 ((struct quehead
*)(element
->qh_link
))->qh_rlink
= element
->qh_rlink
;
27 ((struct quehead
*)(element
->qh_rlink
))->qh_link
= element
->qh_link
;
28 element
->qh_rlink
= NULL
;
33 add_guestfwd(struct gfwd_list
**ex_ptr
,
34 SlirpWriteCb write_cb
, void *opaque
,
35 struct in_addr addr
, int port
)
37 struct gfwd_list
*f
= g_new0(struct gfwd_list
, 1);
39 f
->write_cb
= write_cb
;
50 add_exec(struct gfwd_list
**ex_ptr
, const char *cmdline
,
51 struct in_addr addr
, int port
)
53 struct gfwd_list
*f
= add_guestfwd(ex_ptr
, NULL
, NULL
, addr
, port
);
55 f
->ex_exec
= g_strdup(cmdline
);
61 slirp_socketpair_with_oob(int sv
[2])
63 struct sockaddr_in addr
= {
64 .sin_family
= AF_INET
,
66 .sin_addr
.s_addr
= INADDR_ANY
,
68 socklen_t addrlen
= sizeof(addr
);
72 s
= slirp_socket(AF_INET
, SOCK_STREAM
, 0);
73 if (s
< 0 || bind(s
, (struct sockaddr
*)&addr
, addrlen
) < 0 ||
75 getsockname(s
, (struct sockaddr
*)&addr
, &addrlen
) < 0) {
79 sv
[1] = slirp_socket(AF_INET
, SOCK_STREAM
, 0);
84 * This connect won't block because we've already listen()ed on
85 * the server end (even though we won't accept() the connection
89 ret
= connect(sv
[1], (struct sockaddr
*)&addr
, addrlen
);
90 } while (ret
< 0 && errno
== EINTR
);
96 sv
[0] = accept(s
, (struct sockaddr
*)&addr
, &addrlen
);
97 } while (sv
[0] < 0 && errno
== EINTR
);
106 g_critical("slirp_socketpair(): %s", strerror(errno
));
117 fork_exec_child_setup(gpointer data
)
124 #pragma GCC diagnostic push
125 #pragma GCC diagnostic ignored "-Wdeprecated-declarations"
127 #if !GLIB_CHECK_VERSION(2, 58, 0)
128 typedef struct SlirpGSpawnFds
{
129 GSpawnChildSetupFunc child_setup
;
137 slirp_gspawn_fds_setup(gpointer user_data
)
139 SlirpGSpawnFds
*q
= (SlirpGSpawnFds
*)user_data
;
141 dup2(q
->stdin_fd
, 0);
142 dup2(q
->stdout_fd
, 1);
143 dup2(q
->stderr_fd
, 2);
144 q
->child_setup(q
->user_data
);
148 static inline gboolean
149 g_spawn_async_with_fds_slirp(const gchar
*working_directory
,
153 GSpawnChildSetupFunc child_setup
,
161 #if GLIB_CHECK_VERSION(2, 58, 0)
162 return g_spawn_async_with_fds(working_directory
, argv
, envp
, flags
,
163 child_setup
, user_data
,
164 child_pid
, stdin_fd
, stdout_fd
, stderr_fd
,
167 SlirpGSpawnFds setup
= {
168 .child_setup
= child_setup
,
169 .user_data
= user_data
,
170 .stdin_fd
= stdin_fd
,
171 .stdout_fd
= stdout_fd
,
172 .stderr_fd
= stderr_fd
,
175 return g_spawn_async(working_directory
, argv
, envp
, flags
,
176 slirp_gspawn_fds_setup
, &setup
,
181 #define g_spawn_async_with_fds(wd, argv, env, f, c, d, p, ifd, ofd, efd, err) \
182 g_spawn_async_with_fds_slirp(wd, argv, env, f, c, d, p, ifd, ofd, efd, err)
184 #pragma GCC diagnostic pop
187 fork_exec(struct socket
*so
, const char *ex
)
193 DEBUG_CALL("fork_exec");
194 DEBUG_ARG("so = %p", so
);
195 DEBUG_ARG("ex = %p", ex
);
197 if (slirp_socketpair_with_oob(sp
) < 0) {
201 argv
= g_strsplit(ex
, " ", -1);
202 g_spawn_async_with_fds(NULL
/* cwd */,
206 fork_exec_child_setup
, NULL
/* data */,
207 NULL
/* child_pid */,
213 g_critical("fork_exec: %s", err
->message
);
222 slirp_socket_set_fast_reuse(so
->s
);
224 setsockopt(so
->s
, SOL_SOCKET
, SO_OOBINLINE
, &opt
, sizeof(int));
225 slirp_set_nonblock(so
->s
);
226 so
->slirp
->cb
->register_poll_fd(so
->s
, so
->slirp
->opaque
);
230 char *slirp_connection_info(Slirp
*slirp
)
232 GString
*str
= g_string_new(NULL
);
233 const char * const tcpstates
[] = {
234 [TCPS_CLOSED
] = "CLOSED",
235 [TCPS_LISTEN
] = "LISTEN",
236 [TCPS_SYN_SENT
] = "SYN_SENT",
237 [TCPS_SYN_RECEIVED
] = "SYN_RCVD",
238 [TCPS_ESTABLISHED
] = "ESTABLISHED",
239 [TCPS_CLOSE_WAIT
] = "CLOSE_WAIT",
240 [TCPS_FIN_WAIT_1
] = "FIN_WAIT_1",
241 [TCPS_CLOSING
] = "CLOSING",
242 [TCPS_LAST_ACK
] = "LAST_ACK",
243 [TCPS_FIN_WAIT_2
] = "FIN_WAIT_2",
244 [TCPS_TIME_WAIT
] = "TIME_WAIT",
246 struct in_addr dst_addr
;
247 struct sockaddr_in src
;
254 g_string_append_printf(str
,
255 " Protocol[State] FD Source Address Port "
256 "Dest. Address Port RecvQ SendQ\n");
260 for (so
= slirp
->tcb
.so_next
; so
!= &slirp
->tcb
; so
= so
->so_next
) {
261 if (so
->so_state
& SS_HOSTFWD
) {
262 state
= "HOST_FORWARD";
263 } else if (so
->so_tcpcb
) {
264 state
= tcpstates
[so
->so_tcpcb
->t_state
];
268 if (so
->so_state
& (SS_HOSTFWD
| SS_INCOMING
)) {
269 src_len
= sizeof(src
);
270 getsockname(so
->s
, (struct sockaddr
*)&src
, &src_len
);
271 dst_addr
= so
->so_laddr
;
272 dst_port
= so
->so_lport
;
274 src
.sin_addr
= so
->so_laddr
;
275 src
.sin_port
= so
->so_lport
;
276 dst_addr
= so
->so_faddr
;
277 dst_port
= so
->so_fport
;
279 snprintf(buf
, sizeof(buf
), " TCP[%s]", state
);
280 g_string_append_printf(str
, "%-19s %3d %15s %5d ", buf
, so
->s
,
281 src
.sin_addr
.s_addr
? inet_ntoa(src
.sin_addr
) : "*",
282 ntohs(src
.sin_port
));
283 g_string_append_printf(str
, "%15s %5d %5d %5d\n",
284 inet_ntoa(dst_addr
), ntohs(dst_port
),
285 so
->so_rcv
.sb_cc
, so
->so_snd
.sb_cc
);
288 for (so
= slirp
->udb
.so_next
; so
!= &slirp
->udb
; so
= so
->so_next
) {
289 if (so
->so_state
& SS_HOSTFWD
) {
290 snprintf(buf
, sizeof(buf
), " UDP[HOST_FORWARD]");
291 src_len
= sizeof(src
);
292 getsockname(so
->s
, (struct sockaddr
*)&src
, &src_len
);
293 dst_addr
= so
->so_laddr
;
294 dst_port
= so
->so_lport
;
296 snprintf(buf
, sizeof(buf
), " UDP[%d sec]",
297 (so
->so_expire
- curtime
) / 1000);
298 src
.sin_addr
= so
->so_laddr
;
299 src
.sin_port
= so
->so_lport
;
300 dst_addr
= so
->so_faddr
;
301 dst_port
= so
->so_fport
;
303 g_string_append_printf(str
, "%-19s %3d %15s %5d ", buf
, so
->s
,
304 src
.sin_addr
.s_addr
? inet_ntoa(src
.sin_addr
) : "*",
305 ntohs(src
.sin_port
));
306 g_string_append_printf(str
, "%15s %5d %5d %5d\n",
307 inet_ntoa(dst_addr
), ntohs(dst_port
),
308 so
->so_rcv
.sb_cc
, so
->so_snd
.sb_cc
);
311 for (so
= slirp
->icmp
.so_next
; so
!= &slirp
->icmp
; so
= so
->so_next
) {
312 snprintf(buf
, sizeof(buf
), " ICMP[%d sec]",
313 (so
->so_expire
- curtime
) / 1000);
314 src
.sin_addr
= so
->so_laddr
;
315 dst_addr
= so
->so_faddr
;
316 g_string_append_printf(str
, "%-19s %3d %15s - ", buf
, so
->s
,
317 src
.sin_addr
.s_addr
? inet_ntoa(src
.sin_addr
) : "*");
318 g_string_append_printf(str
, "%15s - %5d %5d\n", inet_ntoa(dst_addr
),
319 so
->so_rcv
.sb_cc
, so
->so_snd
.sb_cc
);
322 return g_string_free(str
, FALSE
);