[mirror_qemu.git] / slirp / socket.h

/*
 * Copyright (c) 1995 Danny Gasparovski.
 *
 * Please read the file COPYRIGHT for the
 * terms and conditions of the copyright.
 */

#ifndef SLIRP_SOCKET_H
#define SLIRP_SOCKET_H

#define SO_EXPIRE 240000
#define SO_EXPIREFAST 10000

/*
 * Our socket structure
 */

struct socket {
  struct socket *so_next,*so_prev;      /* For a linked list of sockets */

  int s;                           /* The actual socket */

  int pollfds_idx;                 /* GPollFD GArray index */

  Slirp *slirp;			   /* managing slirp instance */

			/* XXX union these with not-yet-used sbuf params */
  struct mbuf *so_m;	           /* Pointer to the original SYN packet,
				    * for non-blocking connect()'s, and
				    * PING reply's */
  struct tcpiphdr *so_ti;	   /* Pointer to the original ti within
				    * so_mconn, for non-blocking connections */
  int so_urgc;
  union {   /* foreign host */
      struct sockaddr_storage ss;
      struct sockaddr_in sin;
      struct sockaddr_in6 sin6;
  } fhost;
#define so_faddr fhost.sin.sin_addr
#define so_fport fhost.sin.sin_port
#define so_faddr6 fhost.sin6.sin6_addr
#define so_fport6 fhost.sin6.sin6_port
#define so_ffamily fhost.ss.ss_family

  union {   /* local host */
      struct sockaddr_storage ss;
      struct sockaddr_in sin;
      struct sockaddr_in6 sin6;
  } lhost;
#define so_laddr lhost.sin.sin_addr
#define so_lport lhost.sin.sin_port
#define so_laddr6 lhost.sin6.sin6_addr
#define so_lport6 lhost.sin6.sin6_port
#define so_lfamily lhost.ss.ss_family

  uint8_t	so_iptos;	/* Type of service */
  uint8_t	so_emu;		/* Is the socket emulated? */

  u_char	so_type;		/* Type of socket, UDP or TCP */
  int	so_state;		/* internal state flags SS_*, below */

  struct 	tcpcb *so_tcpcb;	/* pointer to TCP protocol control block */
  u_int	so_expire;		/* When the socket will expire */

  int	so_queued;		/* Number of packets queued from this socket */
  int	so_nqueued;		/* Number of packets queued in a row
				 * Used to determine when to "downgrade" a session
					 * from fastq to batchq */

  struct sbuf so_rcv;		/* Receive buffer */
  struct sbuf so_snd;		/* Send buffer */
  void * extra;			/* Extra pointer */
};


/*
 * Socket state bits. (peer means the host on the Internet,
 * local host means the host on the other end of the modem)
 */
#define SS_NOFDREF		0x001	/* No fd reference */

#define SS_ISFCONNECTING	0x002	/* Socket is connecting to peer (non-blocking connect()'s) */
#define SS_ISFCONNECTED		0x004	/* Socket is connected to peer */
#define SS_FCANTRCVMORE		0x008	/* Socket can't receive more from peer (for half-closes) */
#define SS_FCANTSENDMORE	0x010	/* Socket can't send more to peer (for half-closes) */
#define SS_FWDRAIN		0x040	/* We received a FIN, drain data and set SS_FCANTSENDMORE */

#define SS_CTL			0x080
#define SS_FACCEPTCONN		0x100	/* Socket is accepting connections from a host on the internet */
#define SS_FACCEPTONCE		0x200	/* If set, the SS_FACCEPTCONN socket will die after one accept */

#define SS_PERSISTENT_MASK	0xf000	/* Unremovable state bits */
#define SS_HOSTFWD		0x1000	/* Socket describes host->guest forwarding */
#define SS_INCOMING		0x2000	/* Connection was initiated by a host on the internet */

static inline int sockaddr_equal(struct sockaddr_storage *a,
        struct sockaddr_storage *b)
{
    if (a->ss_family != b->ss_family) {
        return 0;
    }

    switch (a->ss_family) {
    case AF_INET:
    {
        struct sockaddr_in *a4 = (struct sockaddr_in *) a;
        struct sockaddr_in *b4 = (struct sockaddr_in *) b;
        return a4->sin_addr.s_addr == b4->sin_addr.s_addr
               && a4->sin_port == b4->sin_port;
    }
    case AF_INET6:
    {
        struct sockaddr_in6 *a6 = (struct sockaddr_in6 *) a;
        struct sockaddr_in6 *b6 = (struct sockaddr_in6 *) b;
        return (in6_equal(&a6->sin6_addr, &b6->sin6_addr)
                && a6->sin6_port == b6->sin6_port);
    }
    default:
        g_assert_not_reached();
    }

    return 0;
}

static inline socklen_t sockaddr_size(struct sockaddr_storage *a)
{
    switch (a->ss_family) {
    case AF_INET:
        return sizeof(struct sockaddr_in);
    case AF_INET6:
        return sizeof(struct sockaddr_in6);
    default:
        g_assert_not_reached();
    }
}

struct socket *solookup(struct socket **, struct socket *,
        struct sockaddr_storage *, struct sockaddr_storage *);
struct socket *socreate(Slirp *);
void sofree(struct socket *);
int soread(struct socket *);
int sorecvoob(struct socket *);
int sosendoob(struct socket *);
int sowrite(struct socket *);
void sorecvfrom(struct socket *);
int sosendto(struct socket *, struct mbuf *);
struct socket * tcp_listen(Slirp *, uint32_t, u_int, uint32_t, u_int,
                               int);
void soisfconnecting(register struct socket *);
void soisfconnected(register struct socket *);
void sofwdrain(struct socket *);
struct iovec; /* For win32 */
size_t sopreprbuf(struct socket *so, struct iovec *iov, int *np);
int soreadbuf(struct socket *so, const char *buf, int size);

void sotranslate_out(struct socket *, struct sockaddr_storage *);
void sotranslate_in(struct socket *, struct sockaddr_storage *);
void sotranslate_accept(struct socket *);


#endif /* SLIRP_SOCKET_H */
Commit	Line	Data
f0cbd3ec FB	1	/*
f0cbd3ec FB	2	* Copyright (c) 1995 Danny Gasparovski.
5fafdf24 TS	3	*
5fafdf24 TS	4	* Please read the file COPYRIGHT for the
f0cbd3ec FB	5	* terms and conditions of the copyright.
	6	*/
	7
2a6a4076 MA	8	#ifndef SLIRP_SOCKET_H
2a6a4076 MA	9	#define SLIRP_SOCKET_H
f0cbd3ec FB	10
	11	#define SO_EXPIRE 240000
	12	#define SO_EXPIREFAST 10000
	13
	14	/*
	15	* Our socket structure
	16	*/
	17
	18	struct socket {
	19	struct socket so_next,so_prev; /* For a linked list of sockets */
	20
	21	int s; /* The actual socket */
	22
8917c3bd SH	23	int pollfds_idx; /* GPollFD GArray index */
8917c3bd SH	24
460fec67 JK	25	Slirp slirp; / managing slirp instance */
460fec67 JK	26
f0cbd3ec FB	27	/* XXX union these with not-yet-used sbuf params */
	28	struct mbuf so_m; / Pointer to the original SYN packet,
	29	* for non-blocking connect()'s, and
	30	* PING reply's */
	31	struct tcpiphdr so_ti; / Pointer to the original ti within
	32	* so_mconn, for non-blocking connections */
	33	int so_urgc;
eae303ff GS	34	union { /* foreign host */
	35	struct sockaddr_storage ss;
	36	struct sockaddr_in sin;
15d62af4	37	struct sockaddr_in6 sin6;
eae303ff GS	38	} fhost;
	39	#define so_faddr fhost.sin.sin_addr
	40	#define so_fport fhost.sin.sin_port
15d62af4 GS	41	#define so_faddr6 fhost.sin6.sin6_addr
15d62af4 GS	42	#define so_fport6 fhost.sin6.sin6_port
eae303ff GS	43	#define so_ffamily fhost.ss.ss_family
	44
	45	union { /* local host */
	46	struct sockaddr_storage ss;
	47	struct sockaddr_in sin;
15d62af4	48	struct sockaddr_in6 sin6;
eae303ff GS	49	} lhost;
	50	#define so_laddr lhost.sin.sin_addr
	51	#define so_lport lhost.sin.sin_port
15d62af4 GS	52	#define so_laddr6 lhost.sin6.sin6_addr
15d62af4 GS	53	#define so_lport6 lhost.sin6.sin6_port
eae303ff	54	#define so_lfamily lhost.ss.ss_family
3b46e624	55
b6dce92e SW	56	uint8_t so_iptos; /* Type of service */
b6dce92e SW	57	uint8_t so_emu; /* Is the socket emulated? */
3b46e624	58
f0cbd3ec FB	59	u_char so_type; /* Type of socket, UDP or TCP */
f0cbd3ec FB	60	int so_state; /* internal state flags SS_, below /
3b46e624	61
f0cbd3ec FB	62	struct tcpcb so_tcpcb; / pointer to TCP protocol control block */
f0cbd3ec FB	63	u_int so_expire; /* When the socket will expire */
3b46e624	64
f0cbd3ec FB	65	int so_queued; /* Number of packets queued from this socket */
	66	int so_nqueued; /* Number of packets queued in a row
	67	* Used to determine when to "downgrade" a session
	68	* from fastq to batchq */
5fafdf24	69
f0cbd3ec FB	70	struct sbuf so_rcv; /* Receive buffer */
	71	struct sbuf so_snd; /* Send buffer */
	72	void * extra; /* Extra pointer */
	73	};
	74
	75
	76	/*
	77	* Socket state bits. (peer means the host on the Internet,
	78	* local host means the host on the other end of the modem)
	79	*/
	80	#define SS_NOFDREF 0x001 /* No fd reference */
	81
	82	#define SS_ISFCONNECTING 0x002 /* Socket is connecting to peer (non-blocking connect()'s) */
	83	#define SS_ISFCONNECTED 0x004 /* Socket is connected to peer */
	84	#define SS_FCANTRCVMORE 0x008 /* Socket can't receive more from peer (for half-closes) */
	85	#define SS_FCANTSENDMORE 0x010 /* Socket can't send more to peer (for half-closes) */
f0cbd3ec FB	86	#define SS_FWDRAIN 0x040 /* We received a FIN, drain data and set SS_FCANTSENDMORE */
	87
	88	#define SS_CTL 0x080
	89	#define SS_FACCEPTCONN 0x100 /* Socket is accepting connections from a host on the internet */
	90	#define SS_FACCEPTONCE 0x200 /* If set, the SS_FACCEPTCONN socket will die after one accept */
	91
f932b6ce	92	#define SS_PERSISTENT_MASK 0xf000 /* Unremovable state bits */
6dd5ffb6	93	#define SS_HOSTFWD 0x1000 /* Socket describes host->guest forwarding */
4a82347a	94	#define SS_INCOMING 0x2000 /* Connection was initiated by a host on the internet */
f932b6ce	95
8a87f121 GS	96	static inline int sockaddr_equal(struct sockaddr_storage *a,
	97	struct sockaddr_storage *b)
	98	{
	99	if (a->ss_family != b->ss_family) {
	100	return 0;
	101	}
	102
	103	switch (a->ss_family) {
	104	case AF_INET:
	105	{
	106	struct sockaddr_in a4 = (struct sockaddr_in ) a;
	107	struct sockaddr_in b4 = (struct sockaddr_in ) b;
	108	return a4->sin_addr.s_addr == b4->sin_addr.s_addr
	109	&& a4->sin_port == b4->sin_port;
	110	}
0d6ff71a GS	111	case AF_INET6:
	112	{
	113	struct sockaddr_in6 a6 = (struct sockaddr_in6 ) a;
	114	struct sockaddr_in6 b6 = (struct sockaddr_in6 ) b;
	115	return (in6_equal(&a6->sin6_addr, &b6->sin6_addr)
	116	&& a6->sin6_port == b6->sin6_port);
	117	}
8a87f121 GS	118	default:
	119	g_assert_not_reached();
	120	}
	121
	122	return 0;
	123	}
	124
0d48dfed ST	125	static inline socklen_t sockaddr_size(struct sockaddr_storage *a)
	126	{
	127	switch (a->ss_family) {
	128	case AF_INET:
	129	return sizeof(struct sockaddr_in);
	130	case AF_INET6:
	131	return sizeof(struct sockaddr_in6);
	132	default:
	133	g_assert_not_reached();
	134	}
	135	}
	136
a5fd24aa	137	struct socket solookup(struct socket , struct socket ,
8a87f121	138	struct sockaddr_storage , struct sockaddr_storage );
a5fd24aa	139	struct socket socreate(Slirp );
6cb9c6d3 BS	140	void sofree(struct socket *);
6cb9c6d3 BS	141	int soread(struct socket *);
bfb1ac14	142	int sorecvoob(struct socket *);
6cb9c6d3 BS	143	int sosendoob(struct socket *);
	144	int sowrite(struct socket *);
	145	void sorecvfrom(struct socket *);
	146	int sosendto(struct socket , struct mbuf );
b6dce92e	147	struct socket * tcp_listen(Slirp *, uint32_t, u_int, uint32_t, u_int,
6cb9c6d3 BS	148	int);
	149	void soisfconnecting(register struct socket *);
	150	void soisfconnected(register struct socket *);
	151	void sofwdrain(struct socket *);
b9e82a59	152	struct iovec; /* For win32 */
e1c5a2b3 AL	153	size_t sopreprbuf(struct socket so, struct iovec iov, int *np);
e1c5a2b3 AL	154	int soreadbuf(struct socket so, const char buf, int size);
f0cbd3ec	155
5379229a GS	156	void sotranslate_out(struct socket , struct sockaddr_storage );
	157	void sotranslate_in(struct socket , struct sockaddr_storage );
	158	void sotranslate_accept(struct socket *);
	159
	160
2a6a4076	161	#endif /* SLIRP_SOCKET_H */