X-Git-Url: http://git.tuebingen.mpg.de/?a=blobdiff_plain;f=net.h;h=e9974d1c342316c4f6073b5f4afb8895143dc5d6;hb=eecc102ad0abeb0335fe994bb72031a15b9090d7;hp=66bf875568eadd9fe07587e31edc5539e472575d;hpb=e9e826f4fb415c4225ff5934fe42572ffa3b5ebc;p=paraslash.git diff --git a/net.h b/net.h index 66bf8755..e9974d1c 100644 --- a/net.h +++ b/net.h @@ -17,19 +17,52 @@ #define UNIX_PATH_MAX 108 #endif -/** \cond Userland defines for Linux DCCP support. */ +/* Userland defines for Linux DCCP support. */ + #ifndef IPPROTO_DCCP -#define IPPROTO_DCCP 33 /* IANA assigned value */ -#define SOCK_DCCP 6 /* Linux socket type */ -#define SOL_DCCP 269 /* Linux socket level */ -/* Per-connection CCID support (since v2.6.30-rc1) */ -#define DCCP_SOCKOPT_AVAILABLE_CCIDS 12 /* List of supported CCIDs */ -#define DCCP_SOCKOPT_CCID 13 /* Sets both TX/RX CCID */ -#define DCCP_SOCKOPT_TX_CCID 14 /* Set/get the TX CCID */ -#define DCCP_SOCKOPT_RX_CCID 15 /* Set/get the RX CCID */ +#define IPPROTO_DCCP 33 /**< IANA assigned value. */ +#endif + +#ifndef SOCK_DCCP +#define SOCK_DCCP 6 /**< Linux socket type. */ +#endif + +#ifndef DCCP_SOCKOPT_RX_CCID +/** Per-connection CCID support (set/get the RX CCID, since v2.6.30-rc1). */ +#define DCCP_SOCKOPT_RX_CCID 15 +#endif + +#ifndef SOL_DCCP +#define SOL_DCCP 269 /**< Linux socket level. */ +#endif + +#ifndef DCCP_SOCKOPT_AVAILABLE_CCIDS +#define DCCP_SOCKOPT_AVAILABLE_CCIDS 12 /**< List of supported CCIDs. */ #endif -/** \endcond */ +#ifndef DCCP_SOCKOPT_CCID +#define DCCP_SOCKOPT_CCID 13 /**< Sets both TX/RX CCID. */ +#endif + +#ifndef DCCP_SOCKOPT_TX_CCID +#define DCCP_SOCKOPT_TX_CCID 14 /**< Set/get the TX CCID. */ +#endif + +/** + * Flowopts: Transport-layer independent encapsulation of socket options + * that need to be registered prior to setting up a connection. + */ +struct flowopts; + +extern struct flowopts *flowopt_new(void); +extern void flowopt_add(struct flowopts *fo, int level, int opt, + char *name, const void *val, int len); +extern void flowopt_add_bool(struct flowopts *fo, int lev, int opt, + char *optname, bool on_or_off); +/** Flowopt shortcut macros */ +#define OPT_ADD(fo, lev, opt, val, len) flowopt_add(fo, lev, opt, #opt, val, len) +#define OPT_ENABLE(fo, lev, opt) flowopt_add_bool(fo, lev, opt, #opt, 1) +#define OPT_DISABLE(fo, lev, opt) flowopt_add_bool(fo, lev, opt, #opt, 0) /** * Functions to parse and validate (parts of) URLs. @@ -71,8 +104,16 @@ _static_inline_ bool is_valid_ipv6_address(const char *address) /** * Generic socket creation (passive and active sockets). */ -extern int makesock(unsigned l3type, unsigned l4type, int passive, - const char *host, unsigned short port_number); +extern int makesock(unsigned l4type, bool passive, + const char *host, uint16_t port_number, + struct flowopts *fo); + +static inline int para_connect_simple(unsigned l4type, + const char *host, uint16_t port) +{ + return makesock(l4type, 0, host, port, NULL); +} + extern struct in_addr extract_v4_addr(const struct sockaddr_storage *ss); /** @@ -80,7 +121,12 @@ extern struct in_addr extract_v4_addr(const struct sockaddr_storage *ss); */ /** How many pending connections queue of a listening server will hold. */ #define BACKLOG 10 -extern int para_listen(unsigned l3type, unsigned l4type, unsigned short port); +extern int para_listen(unsigned l4type, uint16_t port, struct flowopts *fo); + +static inline int para_listen_simple(unsigned l4type, uint16_t port) +{ + return para_listen(l4type, port, NULL); +} /** Pretty-printing of IPv4/6 socket addresses */ extern char *local_name(int sockfd);