slirp_state.h@ 39775

Last change on this file since 39775 was 39775, checked in by vboxsync, 13 years ago
NAT: introduces CFGM value .../HostResolverMappings/HostNamePattern which used for specifying range of host names user expects to return .../HostResolverMappings/HostIP on DNS requests from HostResolver mode.
Property svn:eol-style set to `native` Property svn:keywords set to `Author Date Id Revision`
File size: 29.0 KB

Line
1	/** @file
2	* NAT - slirp state/configuration.
3	*/
4
5	/*
6	* Copyright (C) 2006-2010 Oracle Corporation
7	*
8	* This file is part of VirtualBox Open Source Edition (OSE), as
9	* available from http://www.virtualbox.org. This file is free software;
10	* you can redistribute it and/or modify it under the terms of the GNU
11	* General Public License (GPL) as published by the Free Software
12	* Foundation, in version 2 as it comes in the "COPYING" file of the
13	* VirtualBox OSE distribution. VirtualBox OSE is distributed in the
14	* hope that it will be useful, but WITHOUT ANY WARRANTY of any kind.
15	*/
16
17	#ifndef ___slirp_state_h
18	#define ___slirp_state_h
19
20	#include <iprt/req.h>
21	#include <iprt/critsect.h>
22
23	#define COUNTERS_INIT
24	#include "counters.h"
25
26	#include "ip_icmp.h"
27	#include "dnsproxy/dnsproxy.h"
28
29
30	/** Where to start DHCP IP number allocation. */
31	#define START_ADDR 15
32
33	/** DHCP Lease time. */
34	#define LEASE_TIME (24 * 3600)
35
36	/*
37	* ARP cache this is naive implementaion of ARP
38	* cache of mapping 4 byte IPv4 address to 6 byte
39	* ethernet one.
40	*/
41	struct arp_cache_entry
42	{
43	uint32_t ip;
44	uint8_t ether[6];
45	LIST_ENTRY(arp_cache_entry) list;
46	};
47	LIST_HEAD(arp_cache_head, arp_cache_entry);
48
49	/** TFTP session entry. */
50	struct tftp_session
51	{
52	int in_use;
53	unsigned char filename[TFTP_FILENAME_MAX];
54
55	struct in_addr client_ip;
56	u_int16_t client_port;
57
58	int timestamp;
59	};
60
61	struct dns_domain_entry
62	{
63	char *dd_pszDomain;
64	LIST_ENTRY(dns_domain_entry) dd_list;
65	};
66	LIST_HEAD(dns_domain_list_head, dns_domain_entry);
67
68	#ifdef VBOX_WITH_DNSMAPPING_IN_HOSTRESOLVER
69	typedef struct DNSMAPPINGENTRY
70	{
71	/*
72	* host name to map
73	* Note: if pszCName isn't null pszPattern won't be used (see alias_dns.c for details)
74	*/
75	char *pszCName;
76	/* pattern of hostnames to map to specifaied IP */
77	char *pszPattern;
78	uint32_t u32IpAddress;
79	LIST_ENTRY(DNSMAPPINGENTRY) MapList;
80	} DNSMAPPINGENTRY, *PDNSMAPPINGENTRY;
81	typedef LIST_HEAD(DNSMAPPINGLISTHEAD, DNSMAPPINGENTRY) DNSMAPPINGLISTHEAD;
82	#endif
83
84	struct dns_entry
85	{
86	struct in_addr de_addr;
87	TAILQ_ENTRY(dns_entry) de_list;
88	};
89	TAILQ_HEAD(dns_list_head, dns_entry);
90	TAILQ_HEAD(if_queue, mbuf);
91
92	struct port_forward_rule
93	{
94	uint16_t proto;
95	uint16_t host_port;
96	uint16_t guest_port;
97	struct in_addr guest_addr;
98	struct in_addr bind_ip;
99	uint8_t mac_address[6]; /need ETH_ALEN here /
100	int activated;
101	struct socket *so;
102	LIST_ENTRY(port_forward_rule) list;
103	};
104	LIST_HEAD(port_forward_rule_list, port_forward_rule);
105
106
107
108	/* forward declaration */
109	struct proto_handler;
110
111	/** Main state/configuration structure for slirp NAT. */
112	typedef struct NATState
113	{
114	#define PROFILE_COUNTER(name, dsc) STAMPROFILE Stat ## name
115	#define COUNTING_COUNTER(name, dsc) STAMCOUNTER Stat ## name
116	#include "counters.h"
117	/* Stuff from boot.c */
118	void *pbootp_clients;
119	const char *bootp_filename;
120	/* Stuff from if.c */
121	int if_mtu, if_mru;
122	int if_comp;
123	int if_maxlinkhdr;
124	int if_queued;
125	int if_thresh;
126	/* Stuff from icmp.c */
127	struct icmpstat_t icmpstat;
128	/* Stuff from ip_input.c */
129	struct ipstat_t ipstat;
130	struct ipqhead ipq[IPREASS_NHASH];
131	int maxnipq; /* Administrative limit on # of reass queues*/
132	int maxfragsperpacket; /* Maximum number of IPv4 fragments allowed per packet */
133	int nipq; /* total number of reass queues */
134	uint16_t ip_currid;
135	/* Stuff from mbuf.c */
136	/* Stuff from slirp.c */
137	void *pvUser;
138	uint32_t curtime;
139	uint32_t time_fasttimo;
140	uint32_t last_slowtimo;
141	bool do_slowtimo;
142	bool link_up;
143	struct timeval tt;
144	struct in_addr our_addr;
145	struct in_addr alias_addr;
146	struct in_addr special_addr;
147
148	int tcp_rcvspace;
149	int tcp_sndspace;
150	int socket_rcv;
151	int socket_snd;
152	int soMaxConn;
153	#ifdef VBOX_WITH_SLIRP_MT
154	RTREQQUEUE hReqQueue;
155	#endif
156	#ifdef RT_OS_WINDOWS
157	ULONG (WINAPI * pfGetAdaptersAddresses)(ULONG, ULONG, PVOID, PIP_ADAPTER_ADDRESSES, PULONG);
158	#endif
159	struct dns_list_head pDnsList;
160	struct dns_domain_list_head pDomainList;
161	struct in_addr tftp_server;
162	struct in_addr loopback_addr;
163	uint32_t dnsLastUpdate;
164	uint32_t netmask;
165	#ifndef VBOX_WITH_NAT_SERVICE
166	uint8_t client_ethaddr[6];
167	#endif
168	const uint8_t *slirp_ethaddr;
169	char slirp_hostname[33];
170	bool fPassDomain;
171	struct in_addr bindIP;
172	/* Stuff from tcp_input.c */
173	struct socket tcb;
174	#ifdef VBOX_WITH_SLIRP_MT
175	RTCRITSECT tcb_mutex;
176	#endif
177	struct socket *tcp_last_so;
178	tcp_seq tcp_iss;
179	/* Stuff from tcp_timer.c */
180	struct tcpstat_t tcpstat;
181	uint32_t tcp_now;
182	int tcp_reass_qsize;
183	int tcp_reass_maxqlen;
184	int tcp_reass_maxseg;
185	int tcp_reass_overflows;
186	/* Stuff from tftp.c */
187	struct tftp_session tftp_sessions[TFTP_SESSIONS_MAX];
188	const char *tftp_prefix;
189	/* Stuff from udp.c */
190	struct udpstat_t udpstat;
191	struct socket udb;
192	#ifdef VBOX_WITH_SLIRP_MT
193	RTCRITSECT udb_mutex;
194	#endif
195	struct socket *udp_last_so;
196	struct socket icmp_socket;
197	struct icmp_storage icmp_msg_head;
198	# ifndef RT_OS_WINDOWS
199	/* counter of sockets needed for allocation enough room to
200	* process sockets with poll/epoll
201	*
202	* NSOCK_INC/DEC should be injected before every
203	* operation on socket queue (tcb, udb)
204	*/
205	int nsock;
206	# define NSOCK_INC() do {pData->nsock++;} while (0)
207	# define NSOCK_DEC() do {pData->nsock--;} while (0)
208	# define NSOCK_INC_EX(ex) do {ex->pData->nsock++;} while (0)
209	# define NSOCK_DEC_EX(ex) do {ex->pData->nsock--;} while (0)
210	# else
211	# define NSOCK_INC() do {} while (0)
212	# define NSOCK_DEC() do {} while (0)
213	# define NSOCK_INC_EX(ex) do {} while (0)
214	# define NSOCK_DEC_EX(ex) do {} while (0)
215	# endif
216	int cIcmpCacheSize;
217	int iIcmpCacheLimit;
218	# ifdef RT_OS_WINDOWS
219	void *pvIcmpBuffer;
220	size_t szIcmpBuffer;
221	/* Accordin MSDN specification IcmpParseReplies
222	* function should be detected in runtime
223	*/
224	long (WINAPI * pfIcmpParseReplies)(void *, long);
225	BOOL (WINAPI * pfIcmpCloseHandle)(HANDLE);
226	HMODULE hmIcmpLibrary;
227	# endif
228	#if defined(RT_OS_WINDOWS)
229	# define VBOX_SOCKET_EVENT (pData->phEvents[VBOX_SOCKET_EVENT_INDEX])
230	HANDLE phEvents[VBOX_EVENT_COUNT];
231	#endif
232	#ifdef zone_mbuf
233	# undef zone_mbuf
234	#endif
235	uma_zone_t zone_mbuf;
236	#ifdef zone_clust
237	# undef zone_clust
238	#endif
239	uma_zone_t zone_clust;
240	#ifdef zone_pack
241	# undef zone_pack
242	#endif
243	uma_zone_t zone_pack;
244	#ifdef zone_jumbop
245	# undef zone_jumbop
246	#endif
247	uma_zone_t zone_jumbop;
248	#ifdef zone_jumbo9
249	# undef zone_jumbo9
250	#endif
251	uma_zone_t zone_jumbo9;
252	#ifdef zone_jumbo16
253	# undef zone_jumbo16
254	#endif
255	uma_zone_t zone_jumbo16;
256	#ifdef zone_ext_refcnt
257	# undef zone_ext_refcnt
258	int nmbclusters; /* limits number of mbuf clusters */
259	int nmbjumbop; /* limits number of page size jumbo clusters */
260	int nmbjumbo9; /* limits number of 9k jumbo clusters */
261	int nmbjumbo16; /* limits number of 16k jumbo clusters */
262	struct mbstat mbstat;
263	#endif
264	uma_zone_t zone_ext_refcnt;
265	bool fUseHostResolver;
266	/* from dnsproxy/dnsproxy.h*/
267	unsigned int authoritative_port;
268	unsigned int authoritative_timeout;
269	unsigned int recursive_port;
270	unsigned int recursive_timeout;
271	unsigned int stats_timeout;
272	unsigned int port;
273
274	unsigned long active_queries;
275	unsigned long all_queries;
276	unsigned long authoritative_queries;
277	unsigned long recursive_queries;
278	unsigned long removed_queries;
279	unsigned long dropped_queries;
280	unsigned long answered_queries;
281	unsigned long dropped_answers;
282	unsigned long late_answers;
283	unsigned long hash_collisions;
284	/dnsproxy/dnsproxy.c/
285	unsigned short queryid;
286	struct sockaddr_in authoritative_addr;
287	struct sockaddr_in recursive_addr;
288	int sock_query;
289	int sock_answer;
290	/* dnsproxy/hash.c */
291	#define HASHSIZE 10
292	#define HASH(id) (id & ((1 << HASHSIZE) - 1))
293	struct request *request_hash[1 << HASHSIZE];
294	/* this field control behaviour of DHCP server */
295	bool fUseDnsProxy;
296
297	LIST_HEAD(RT_NOTHING, libalias) instancehead;
298	int i32AliasMode;
299	struct libalias *proxy_alias;
300	struct libalias *dns_alias;
301	LIST_HEAD(handler_chain, proto_handler) handler_chain;
302	struct port_forward_rule_list port_forward_rule_head;
303	int cRedirectionsActive;
304	int cRedirectionsStored;
305	struct arp_cache_head arp_cache;
306	/* libalis modules' handlers*/
307	struct proto_handler *ftp_module;
308	struct proto_handler *nbt_module;
309	struct proto_handler *dns_module;
310	#ifdef VBOX_WITH_NAT_SEND2HOME
311	/* array of home addresses */
312	struct sockaddr_in *pInSockAddrHomeAddress;
313	/* size of pInSockAddrHomeAddress in elements */
314	int cInHomeAddressSize;
315	#endif
316	#ifdef VBOX_WITH_DNSMAPPING_IN_HOSTRESOLVER
317	DNSMAPPINGLISTHEAD DNSMapHead;
318	#endif
319	} NATState;
320
321
322	/** Default IP time to live. */
323	#define ip_defttl IPDEFTTL
324
325	/** Number of permanent buffers in mbuf. */
326	#define mbuf_thresh 30
327
328	/** Use a fixed time before sending keepalive. */
329	#define tcp_keepidle TCPTV_KEEP_IDLE
330
331	/** Use a fixed interval between keepalive. */
332	#define tcp_keepintvl TCPTV_KEEPINTVL
333
334	/** Maximum idle time before timing out a connection. */
335	#define tcp_maxidle (TCPTV_KEEPCNT * tcp_keepintvl)
336
337	/** Default TCP socket options. */
338	#define so_options DO_KEEPALIVE
339
340	/** Default TCP MSS value. */
341	#define tcp_mssdflt TCP_MSS
342
343	/** Default TCP round trip time. */
344	#define tcp_rttdflt (TCPTV_SRTTDFLT / PR_SLOWHZ)
345
346	/** Enable RFC1323 performance enhancements.
347	* @todo check if it really works, it was turned off before. */
348	#define tcp_do_rfc1323 1
349
350	/** TCP receive buffer size. */
351	#define tcp_rcvspace pData->tcp_rcvspace
352
353	/** TCP receive buffer size. */
354	#define tcp_sndspace pData->tcp_sndspace
355
356	/* TCP duplicate ACK retransmit threshold. */
357	#define tcprexmtthresh 3
358
359
360	#define bootp_filename pData->bootp_filename
361
362	#define if_mtu pData->if_mtu
363	#define if_mru pData->if_mru
364	#define if_comp pData->if_comp
365	#define if_maxlinkhdr pData->if_maxlinkhdr
366	#define if_queued pData->if_queued
367	#define if_thresh pData->if_thresh
368
369	#define icmpstat pData->icmpstat
370
371	#define ipstat pData->ipstat
372	#define ipq pData->ipq
373	#define ip_currid pData->ip_currid
374
375	#define mbuf_alloced pData->mbuf_alloced
376	#define mbuf_max pData->mbuf_max
377	#define msize pData->msize
378	#define m_freelist pData->m_freelist
379	#define m_usedlist pData->m_usedlist
380
381	#define curtime pData->curtime
382	#define time_fasttimo pData->time_fasttimo
383	#define last_slowtimo pData->last_slowtimo
384	#define do_slowtimo pData->do_slowtimo
385	#define link_up pData->link_up
386	#define cUsers pData->cUsers
387	#define tt pData->tt
388	#define our_addr pData->our_addr
389	#ifndef VBOX_SLIRP_ALIAS
390	# define alias_addr pData->alias_addr
391	#else
392	# define handler_chain pData->handler_chain
393	#endif
394	#define dns_addr pData->dns_addr
395	#define loopback_addr pData->loopback_addr
396	#define client_ethaddr pData->client_ethaddr
397	#define slirp_hostname pData->slirp_hostname
398
399	#define tcb pData->tcb
400	#define tcp_last_so pData->tcp_last_so
401	#define tcp_iss pData->tcp_iss
402
403	#define tcpstat pData->tcpstat
404	#define tcp_now pData->tcp_now
405
406	#define tftp_sessions pData->tftp_sessions
407	#define tftp_prefix pData->tftp_prefix
408
409	#define udpstat pData->udpstat
410	#define udb pData->udb
411	#define udp_last_so pData->udp_last_so
412
413	#define maxfragsperpacket pData->maxfragsperpacket
414	#define maxnipq pData->maxnipq
415	#define nipq pData->nipq
416
417	#define tcp_reass_qsize pData->tcp_reass_qsize
418	#define tcp_reass_maxqlen pData->tcp_reass_maxqlen
419	#define tcp_reass_maxseg pData->tcp_reass_maxseg
420	#define tcp_reass_overflows pData->tcp_reass_overflows
421
422	#define queue_tcp_label tcb
423	#define queue_udp_label udb
424	#define VBOX_X2(x) x
425	#define VBOX_X(x) VBOX_X2(x)
426
427	#ifdef VBOX_WITH_SLIRP_MT
428
429	# define QSOCKET_LOCK(queue) \
430	do { \
431	int rc; \
432	/* Assert(strcmp(RTThreadSelfName(), "EMT") != 0); */ \
433	rc = RTCritSectEnter(&VBOX_X(queue) ## _mutex); \
434	AssertRC(rc); \
435	} while (0)
436	# define QSOCKET_UNLOCK(queue) \
437	do { \
438	int rc; \
439	rc = RTCritSectLeave(&VBOX_X(queue) ## _mutex); \
440	AssertRC(rc); \
441	} while (0)
442	# define QSOCKET_LOCK_CREATE(queue) \
443	do { \
444	int rc; \
445	rc = RTCritSectInit(&pData->queue ## _mutex); \
446	AssertRC(rc); \
447	} while (0)
448	# define QSOCKET_LOCK_DESTROY(queue) \
449	do { \
450	int rc = RTCritSectDelete(&pData->queue ## _mutex); \
451	AssertRC(rc); \
452	} while (0)
453
454	# define QSOCKET_FOREACH(so, sonext, label) \
455	QSOCKET_LOCK(VBOX_X2(queue_## label ## _label)); \
456	(so) = (VBOX_X(queue_ ## label ## _label)).so_next; \
457	QSOCKET_UNLOCK(VBOX_X2(queue_## label ##_label)); \
458	if ((so) != &(VBOX_X(queue_## label ## _label))) SOCKET_LOCK((so));\
459	for (;;) \
460	{ \
461	if ((so) == &(VBOX_X(queue_## label ## _label))) \
462	{ \
463	break; \
464	} \
465	Log2(("%s:%d Processing so:%R[natsock]\n", __FUNCTION__, __LINE__, (so)));
466
467	# define CONTINUE_NO_UNLOCK(label) goto loop_end_ ## label ## _mt_nounlock
468	# define CONTINUE(label) goto loop_end_ ## label ## _mt
469	/* @todo replace queue parameter with macrodinition */
470	/* _mt_nounlock - user should lock so_next before calling CONTINUE_NO_UNLOCK */
471	# define LOOP_LABEL(label, so, sonext) loop_end_ ## label ## _mt: \
472	(sonext) = (so)->so_next; \
473	SOCKET_UNLOCK(so); \
474	QSOCKET_LOCK(VBOX_X(queue_ ## label ## _label)); \
475	if ((sonext) != &(VBOX_X(queue_## label ## _label))) \
476	{ \
477	SOCKET_LOCK((sonext)); \
478	QSOCKET_UNLOCK(VBOX_X(queue_ ## label ## _label)); \
479	} \
480	else \
481	{ \
482	so = &VBOX_X(queue_ ## label ## _label); \
483	QSOCKET_UNLOCK(VBOX_X(queue_ ## label ## _label)); \
484	break; \
485	} \
486	(so) = (sonext); \
487	continue; \
488	loop_end_ ## label ## _mt_nounlock: \
489	(so) = (sonext)
490
491	# define DO_TCP_OUTPUT(data, sotcb) \
492	do { \
493	PRTREQ pReq; \
494	int rc; \
495	rc = RTReqQueueCallVoid((data)->hReqQueue, &pReq, 0 /cMillies/, \
496	(PFNRT)tcp_output 2, data, sotcb); \
497	if (RT_LIKELY(rc == VERR_TIMEOUT)) \
498	{ \
499	SOCKET_UNLOCK(so); \
500	rc = RTReqWait(pReq, RT_INDEFINITE_WAIT); \
501	AssertReleaseRC(rc); \
502	SOCKET_LOCK(so); \
503	RTReqRelease(pReq); \
504	} \
505	else \
506	AssertReleaseRC(rc); \
507	} while(0)
508
509	# define DO_TCP_INPUT(data, mbuf, size, so) \
510	do { \
511	int rc; \
512	rc = RTReqQueueCallEx((data)->hReqQueue, NULL, 0 /cMillies/, \
513	RTREQFLAGS_VOID \| RTREQFLAGS_NO_WAIT, \
514	(PFNRT)tcp_input, 4, data, mbuf, size, so); \
515	AssertReleaseRC(rc); \
516	} while(0)
517
518	# define DO_TCP_CONNECT(data, so) \
519	do { \
520	PRTREQ pReq; \
521	int rc; \
522	rc = RTReqQueueCallVoid((data)->hReqQueue, &pReq, 0 /cMillies/, \
523	(PFNRT)tcp_connect, 2, data, so); \
524	if (RT_LIKELY(rc == VERR_TIMEOUT)) \
525	{ \
526	SOCKET_UNLOCK(so); \
527	rc = RTReqWait(pReq, RT_INDEFINITE_WAIT); \
528	AssertReleaseRC(rc); \
529	SOCKET_LOCK(so); \
530	RTReqRelease(pReq); \
531	} \
532	else \
533	AssertReleaseRC(rc); \
534	} while(0)
535
536	# define DO_SOREAD(ret, data, so, ifclose) \
537	do { \
538	PRTREQ pReq; \
539	int rc; \
540	rc = RTReqQueueCallVoid((data)->hReqQueue, &pReq, 0 /cMillies/, \
541	(PFNRT)soread_queue, 4, \
542	data, so, ifclose, &(ret)); \
543	if (RT_LIKELY(rc == VERR_TIMEOUT)) \
544	{ \
545	SOCKET_UNLOCK(so); \
546	rc = RTReqWait(pReq, RT_INDEFINITE_WAIT); \
547	AssertReleaseRC(rc); \
548	SOCKET_LOCK(so); \
549	RTReqRelease(pReq); \
550	} \
551	else \
552	AssertReleaseRC(rc); \
553	} while(0)
554
555	# define DO_SOWRITE(ret, data, so) \
556	do { \
557	PRTREQ pReq; \
558	int rc; \
559	rc = RTReqQueueCall((data)->hReqQueue, &pReq, 0 /cMillies/, \
560	(PFNRT)sowrite, 2, data, so); \
561	if (RT_LIKELY(rc == VERR_TIMEOUT)) \
562	{ \
563	SOCKET_UNLOCK(so); \
564	rc = RTReqWait(pReq, RT_INDEFINITE_WAIT); \
565	SOCKET_LOCK(so); \
566	ret = pReq->iStatus; \
567	RTReqRelease(pReq); \
568	} \
569	else \
570	AssertReleaseRC(rc); \
571	} while(0)
572
573	# define DO_SORECFROM(data, so) \
574	do { \
575	PRTREQ pReq; \
576	int rc; \
577	rc = RTReqQueueCallVoid((data)->hReqQueue, &pReq, 0 /cMillies /, \
578	(PFNRT)sorecvfrom, 2, data, so); \
579	if (RT_LIKELY(rc == VERR_TIMEOUT)) \
580	{ \
581	SOCKET_UNLOCK(so); \
582	rc = RTReqWait(pReq, RT_INDEFINITE_WAIT); \
583	AssertReleaseRC(rc); \
584	SOCKET_LOCK(so); \
585	RTReqRelease(pReq); \
586	} \
587	else \
588	AssertReleaseRC(rc); \
589	} while(0)
590
591	# define DO_UDP_DETACH(data, so, so_next) \
592	do { \
593	PRTREQ pReq; \
594	int rc; \
595	rc = RTReqQueueCallVoid((data)->hReqQueue, &pReq, 0 /* cMillies*/, \
596	(PFNRT)udp_detach, 2, data, so); \
597	if (RT_LIKELY(rc == VERR_TIMEOUT)) \
598	{ \
599	SOCKET_UNLOCK(so); \
600	rc = RTReqWait(pReq, RT_INDEFINITE_WAIT); \
601	AssertReleaseRC(rc); \
602	if ((so_next) != &udb) SOCKET_LOCK((so_next)); \
603	RTReqRelease(pReq); \
604	} \
605	else \
606	AssertReleaseRC(rc); \
607	} while(0)
608
609	# define SOLOOKUP(so, label, src, sport, dst, dport) \
610	do { \
611	struct socket *sonxt; \
612	(so) = NULL; \
613	QSOCKET_FOREACH(so, sonxt, label) \
614	/* { */ \
615	if ( so->so_lport == (sport) \
616	&& so->so_laddr.s_addr == (src).s_addr \
617	&& so->so_faddr.s_addr == (dst).s_addr \
618	&& so->so_fport == (dport)) \
619	{ \
620	if (sonxt != &VBOX_X2(queue_ ## label ## _label)) \
621	SOCKET_UNLOCK(sonxt); \
622	break; /so is locked/ \
623	} \
624	LOOP_LABEL(so, sonxt, label); \
625	} \
626	} \
627	} while (0)
628
629	#else /* !VBOX_WITH_SLIRP_MT */
630
631	# define QSOCKET_LOCK(queue) do {} while (0)
632	# define QSOCKET_UNLOCK(queue) do {} while (0)
633	# define QSOCKET_LOCK_CREATE(queue) do {} while (0)
634	# define QSOCKET_LOCK_DESTROY(queue) do {} while (0)
635	# define QSOCKET_FOREACH(so, sonext, label) \
636	for ((so) = VBOX_X2(queue_ ## label ## _label).so_next; \
637	(so) != &(VBOX_X2(queue_ ## label ## _label)); \
638	(so) = (sonext)) \
639	{ \
640	(sonext) = (so)->so_next; \
641	Log2(("%s:%d Processing so:%R[natsock]\n", __FUNCTION__, __LINE__, (so)));
642	# define CONTINUE(label) continue
643	# define CONTINUE_NO_UNLOCK(label) continue
644	# define LOOP_LABEL(label, so, sonext) /* empty*/
645	# define DO_TCP_OUTPUT(data, sotcb) tcp_output((data), (sotcb))
646	# define DO_TCP_INPUT(data, mbuf, size, so) tcp_input((data), (mbuf), (size), (so))
647	# define DO_TCP_CONNECT(data, so) tcp_connect((data), (so))
648	# define DO_SOREAD(ret, data, so, ifclose) \
649	do { \
650	(ret) = soread((data), (so), (ifclose)); \
651	} while(0)
652	# define DO_SOWRITE(ret, data, so) \
653	do { \
654	(ret) = sowrite((data), (so)); \
655	} while(0)
656	# define DO_SORECFROM(data, so) sorecvfrom((data), (so))
657	# define SOLOOKUP(so, label, src, sport, dst, dport) \
658	do { \
659	(so) = solookup(&VBOX_X2(queue_ ## label ## _label), (src), (sport), (dst), (dport)); \
660	} while (0)
661	# define DO_UDP_DETACH(data, so, ignored) udp_detach((data), (so))
662
663	#endif /* !VBOX_WITH_SLIRP_MT */
664
665	#define TCP_OUTPUT(data, sotcb) DO_TCP_OUTPUT((data), (sotcb))
666	#define TCP_INPUT(data, mbuf, size, so) DO_TCP_INPUT((data), (mbuf), (size), (so))
667	#define TCP_CONNECT(data, so) DO_TCP_CONNECT((data), (so))
668	#define SOREAD(ret, data, so, ifclose) DO_SOREAD((ret), (data), (so), (ifclose))
669	#define SOWRITE(ret, data, so) DO_SOWRITE((ret), (data), (so))
670	#define SORECVFROM(data, so) DO_SORECFROM((data), (so))
671	#define UDP_DETACH(data, so, so_next) DO_UDP_DETACH((data), (so), (so_next))
672
673	/* dnsproxy/dnsproxy.c */
674	#define authoritative_port pData->authoritative_port
675	#define authoritative_timeout pData->authoritative_timeout
676	#define recursive_port pData->recursive_port
677	#define recursive_timeout pData->recursive_timeout
678	#define stats_timeout pData->stats_timeout
679	/* dnsproxy/hash.c */
680	#define dns_port pData->port
681	#define request_hash pData->request_hash
682	#define hash_collisions pData->hash_collisions
683	#define active_queries pData->active_queries
684	#define all_queries pData->all_queries
685	#define authoritative_queries pData->authoritative_queries
686	#define recursive_queries pData->recursive_queries
687	#define removed_queries pData->removed_queries
688	#define dropped_queries pData->dropped_queries
689	#define answered_queries pData->answered_queries
690	#define dropped_answers pData->dropped_answers
691	#define late_answers pData->late_answers
692
693	/* dnsproxy/dnsproxy.c */
694	#define queryid pData->queryid
695	#define authoritative_addr pData->authoritative_addr
696	#define recursive_addr pData->recursive_addr
697	#define sock_query pData->sock_query
698	#define sock_answer pData->sock_answer
699
700	#define instancehead pData->instancehead
701
702	#define nmbclusters pData->nmbclusters
703	#define nmbjumbop pData->nmbjumbop
704	#define nmbjumbo9 pData->nmbjumbo9
705	#define nmbjumbo16 pData->nmbjumbo16
706	#define mbstat pData->mbstat
707	#include "ext.h"
708	#undef zone_mbuf
709	#undef zone_clust
710	#undef zone_pack
711	#undef zone_jumbop
712	#undef zone_jumbo9
713	#undef zone_jumbo16
714	#undef zone_ext_refcnt
715	static inline uma_zone_t slirp_zone_pack(PNATState pData)
716	{
717	return pData->zone_pack;
718	}
719	static inline uma_zone_t slirp_zone_jumbop(PNATState pData)
720	{
721	return pData->zone_jumbop;
722	}
723	static inline uma_zone_t slirp_zone_jumbo9(PNATState pData)
724	{
725	return pData->zone_jumbo9;
726	}
727	static inline uma_zone_t slirp_zone_jumbo16(PNATState pData)
728	{
729	return pData->zone_jumbo16;
730	}
731	static inline uma_zone_t slirp_zone_ext_refcnt(PNATState pData)
732	{
733	return pData->zone_ext_refcnt;
734	}
735	static inline uma_zone_t slirp_zone_mbuf(PNATState pData)
736	{
737	return pData->zone_mbuf;
738	}
739	static inline uma_zone_t slirp_zone_clust(PNATState pData)
740	{
741	return pData->zone_clust;
742	}
743	#ifndef VBOX_SLIRP_BSD
744	# define m_adj(m, len) m_adj(pData, (m), (len))
745	#endif
746
747	#endif /* !___slirp_state_h */

Note: See TracBrowser for help on using the repository browser.

source: vbox/trunk/src/VBox/Devices/Network/slirp/slirp_state.h@ 39775

Download in other formats: