X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=net.h;h=7499ce6267b5f9174e9556a23f82c7707e14dc40;hp=1695504caa87408be9e8e53b08330a6bc1c721f0;hb=8d7f47e8cec74e4d209cfa1f6c4c0cec3b0e5019;hpb=cd4b294da6f6802d9918c8fe5bcecb8a2a2363c3 diff --git a/net.h b/net.h index 1695504c..7499ce62 100644 --- a/net.h +++ b/net.h @@ -16,15 +16,37 @@ #define UNIX_PATH_MAX 108 #endif +/** \cond 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 */ +#endif +/** \endcond */ + +/** + * Generic socket creation (passive and active sockets). + */ +extern int makesock(unsigned l3type, unsigned l4type, int passive, + const char *host, unsigned short port_number); + +/** + * Functions to support listening sockets. + */ +/** 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); + +/** Pretty-printing of IPv4/6 socket addresses */ +extern char *host_and_port(struct sockaddr *sa, socklen_t len); +extern char *local_name(int sockfd); +extern char *remote_name(int sockfd); + /** used to crypt the communication between para_server and para_client */ typedef void crypt_function(unsigned long len, const unsigned char *indata, unsigned char *outdata, void *private_data); -#include /* hostent */ -int get_host_info(char *host, struct hostent **ret); -int get_socket(void); -void init_sockaddr(struct sockaddr_in*, int, const struct hostent*); -int para_connect(int, struct sockaddr_in *); +int get_stream_socket(int domain); int send_buffer(int, const char *); int send_bin_buffer(int, const char *, size_t); __printf_2_3 int send_va_buffer(int fd, const char *fmt, ...); @@ -37,8 +59,29 @@ int init_unix_addr(struct sockaddr_un *, const char *); int recv_cred_buffer(int, char *, size_t); ssize_t send_cred_buffer(int, char*); int recv_pattern(int fd, const char *pattern, size_t bufsize); -int init_tcp_socket(int port); void enable_crypt(int fd, crypt_function *recv_f, crypt_function *send_f, void *private_data); void disable_crypt(int fd); +/** + * A wrapper around connect(2). + * + * \param fd The file descriptor. + * \param addr The address to connect. + * \param len The size of \a addr. + * + * This should not be called directly. Always use the PARA_CONNECT macro. + * + * \return \p -E_CONNECT on errors, 1 on success. + * + * \sa connect(2), PARA_CONNECT. + */ +static inline int _para_connect(int fd, void *addr, socklen_t len) +{ + if (connect(fd, (struct sockaddr *)addr, len) == -1) + return -E_CONNECT; + return 1; +} + +/** A macro for connect() which does not need a \a len parameter. */ +#define PARA_CONNECT(fd, addr) _para_connect(fd, addr, sizeof(*(addr)))