tls clear text write queue. More...

#include "tls_ct_wrq.h"
#include "tls_cfg.h"
#include "tls_server.h"
#include "../../atomic_ops.h"
#include "../../mem/shm_mem.h"
#include <openssl/err.h>
#include <openssl/ssl.h>

Include dependency graph for tls_ct_wrq.c:

Go to the source code of this file.

Functions

static int ssl_flush (void *tcp_c, void *error, const void *buf, unsigned size)
Callback for tls_ct_q_flush().
int tls_ct_wq_add (tls_ct_q **ct_q, const void *data, unsigned int size)
Wrapper over tls_ct_q_add().
void tls_ct_wq_destroy ()
Destroy clear text write queues support.
int tls_ct_wq_flush (struct tcp_connection *c, tls_ct_q **ct_q, int *flags, int *ssl_err)
Wrapper over tls_ct_q_flush().
unsigned int tls_ct_wq_free (tls_ct_q **ct_q)
Wrapper over tls_ct_q_destroy() Wrapper over tls_ct_q_destroy(), besides doing a tls_ct_q_destroy it also keeps track of the total queued bytes.
int tls_ct_wq_init ()
Init clear text write queues support.
unsigned int tls_ct_wq_total_bytes ()
Total number of written queued bytes in all the SSL connections.

Detailed Description

(queue clear text when SSL_write() cannot write it immediately due to re-keying).

Module: SIP-router TLS support

Definition in file tls_ct_wrq.c.

Function Documentation

static int ssl_flush	(	void *	tcp_c,
		void *	error,
		const void *	buf,
		unsigned	size
	)			`[static]`

Parameters:

	tcp_c	TCP connection containing the SSL context
	error	error reason (set on exit)
	buf	buffer
	size	buffer size

Returns:: >0 on success (bytes written), <=0 on ssl error (should be handled outside)

Warning:: the SSL context must have the wbio and rbio previously set!

Definition at line 97 of file tls_ct_wrq.c.

References tls_accept(), and tls_connect().

Referenced by tls_ct_wq_flush().

Here is the call graph for this function:

Here is the caller graph for this function:

int tls_ct_wq_add	(	tls_ct_q **	ct_q,
		const void *	data,
		unsigned int	size
	)

Wrapper over tls_ct_q_add(), besides doing a tls_ct_q_add it also keeps track of queue size and total queued bytes. If the maximum queue size is exceeded => error.

Parameters: