#include <sys/types.h>
#include <sys/socket.h>
#include <assert.h>
#include <sys/time.h>
#include <uv.h>
#include <gnutls/gnutls.h>
Go to the source code of this file.
|
int | mapthread (uv_thread_t) |
|
void | codatunneld (int codatunnel_sockfd, const char *tcp_bindaddr, const char *udp_bindaddr, const char *bind_service, int onlytcp, const char *sslcertdir) __attribute__((noreturn)) |
|
const char * | tcpstatename (enum deststate) |
|
void | outbound_worker_cb (uv_async_t *async) |
|
void | initdestarray () |
|
dest_t * | getdest (const struct sockaddr_storage *, socklen_t) |
|
dest_t * | createdest (const struct sockaddr_storage *, socklen_t, const char *peername) |
|
void | free_dest (dest_t *d) |
|
void | enq_element (dest_t *, const uv_buf_t *, int) |
|
ssize_t | eat_uvbytes (gnutls_transport_ptr_t, void *, size_t) |
|
int | poll_uvbytes (gnutls_transport_ptr_t gtp, unsigned int ms) |
|
void | drain_outbound_queues (dest_t *d) |
|
void | hexdump (char *desc, void *addr, int len) |
|
void | printsockaddr (const struct sockaddr_storage *, socklen_t) |
|
◆ DEBUG
◆ ERROR
Value: do { \
fprintf(
stderr, __VA_ARGS__); \
} while (0)
stderr
Definition: gensrvstats.py:48
#define __LINE__
Definition: odytypes.h:68
◆ MAXRECEIVE
◆ UVBUFLIMIT
#define UVBUFLIMIT 10 /* drop packets beyond this limit */ |
◆ ctp_t
◆ dest_t
◆ deststate
Enumerator |
---|
FREE | |
ALLOCATED | |
TCPATTEMPTING | |
TLSHANDSHAKE | |
TCPACTIVE | |
TLSERROR | |
TCPCLOSING | |
◆ codatunneld()
void codatunneld |
( |
int |
codatunnel_sockfd, |
|
|
const char * |
tcp_bindaddr, |
|
|
const char * |
udp_bindaddr, |
|
|
const char * |
bind_service, |
|
|
int |
onlytcp, |
|
|
const char * |
sslcertdir |
|
) |
| |
◆ createdest()
◆ drain_outbound_queues()
void drain_outbound_queues |
( |
dest_t * |
d | ) |
|
◆ eat_uvbytes()
ssize_t eat_uvbytes |
( |
gnutls_transport_ptr_t |
gtp, |
|
|
void * |
tlsbuf, |
|
|
size_t |
nread |
|
) |
| |
◆ enq_element()
void enq_element |
( |
dest_t * |
d, |
|
|
const uv_buf_t * |
thisbuf, |
|
|
int |
nb |
|
) |
| |
◆ free_dest()
◆ getdest()
◆ hexdump()
void hexdump |
( |
char * |
desc, |
|
|
void * |
addr, |
|
|
int |
len |
|
) |
| |
◆ initdestarray()
◆ mapthread()
int mapthread |
( |
uv_thread_t |
t | ) |
|
◆ outbound_worker_cb()
void outbound_worker_cb |
( |
uv_async_t * |
async | ) |
|
◆ poll_uvbytes()
int poll_uvbytes |
( |
gnutls_transport_ptr_t |
gtp, |
|
|
unsigned int |
ms |
|
) |
| |
◆ printsockaddr()
◆ tcpstatename()
const char * tcpstatename |
( |
enum |
deststate | ) |
|