Dokumentacja pliku connections.c

#include "ekg2.h"
#include "ekg/internal.h"
#include <errno.h>
#include <gnutls/gnutls.h>

Wykres zależności załączania dla connections.c:

Struktury danych
struct	ekg_connection
struct	ekg_connection_starter
struct	ekg_gnutls_connection
struct	ekg_gnutls_connection_starter

Definicje
#define	NEED_SLAVERY   1
#define	EKG_CONNECTION_ERROR   ekg_connection_error_quark()
#define	EKG_GNUTLS_ERROR   ekg_gnutls_error_quark()

Definicje typów
typedef void(*	ekg_flush_handler_t) (struct ekg_connection *conn)

Funkcje
GQuark	ekg_connection_error_quark ()
static void	setup_async_read (struct ekg_connection *c)
static gboolean	setup_async_connect (GSocketClient *sock, struct ekg_connection_starter *cs)
static void	ekg_gnutls_new_session (GSocketClient *sockclient, GSocketConnection *sock, struct ekg_connection_starter *cs)
static G_GNUC_CONST GQuark	ekg_gnutls_error_quark ()
static void	ekg_connection_remove (struct ekg_connection *c)
static struct ekg_connection *	get_connection_by_outstream (GDataOutputStream *s)
static struct ekg_connection *	get_slave_connection_by_conn (GSocketConnection *c)
static void	done_async_read (GObject *obj, GAsyncResult *res, gpointer user_data)
static void	failed_write (struct ekg_connection *c)
static void	done_async_write (GObject *obj, GAsyncResult *res, gpointer user_data)
static void	setup_async_write (struct ekg_connection *c)
GDataOutputStream *	ekg_connection_add (GSocketConnection *conn, GInputStream *raw_instream, GOutputStream *raw_outstream, ekg_input_callback_t callback, ekg_failure_callback_t failure_callback, gpointer priv_data)
void	ekg_disconnect_by_outstream (GDataOutputStream *f)
void	ekg_connection_write_buf (GDataOutputStream *f, gconstpointer buf, gsize len)
void	ekg_connection_write (GDataOutputStream *f, const gchar *format,...)
static void	failed_async_connect (GSocketClient *sock, GError *err, struct ekg_connection_starter *cs)
static void	succeeded_async_connect (GSocketClient *sock, GSocketConnection *conn, struct ekg_connection_starter *cs, GInputStream *instream, GOutputStream *outstream)
static void	done_async_connect (GObject *obj, GAsyncResult *res, gpointer user_data)
ekg_connection_starter_t	ekg_connection_starter_new (guint16 defport)
void	ekg_connection_starter_free (ekg_connection_starter_t cs)
void	ekg_connection_starter_bind (ekg_connection_starter_t cs, const gchar *hostname)
void	ekg_connection_starter_set_srv_resolver (ekg_connection_starter_t cs, const gchar *service, const gchar *domain)
void	ekg_connection_starter_set_servers (ekg_connection_starter_t cs, const gchar *servers)
void	ekg_connection_starter_set_use_tls (ekg_connection_starter_t cs, gboolean use_tls)
GCancellable *	ekg_connection_starter_run (ekg_connection_starter_t cs, GSocketClient *sock, ekg_connection_callback_t callback, ekg_connection_failure_callback_t failure_callback, gpointer priv_data)
static void	ekg_gnutls_free_connection (struct ekg_gnutls_connection *conn)
static void	ekg_gnutls_free_connection_starter (struct ekg_gnutls_connection_starter *gcs)
static gssize	ekg_gnutls_pull (gnutls_transport_ptr_t connptr, gpointer buf, gsize len)
static gssize	ekg_gnutls_push (gnutls_transport_ptr_t connptr, gconstpointer buf, gsize len)
static void	ekg_gnutls_handle_data_failure (GDataInputStream *s, GError *err, gpointer data)
static void	ekg_gnutls_handle_data (GDataInputStream *s, gpointer data)
static void	ekg_gnutls_flush (struct ekg_connection *c)
static void	ekg_gnutls_handle_handshake_failure (GDataInputStream *s, GError *err, gpointer data)
static void	ekg_gnutls_async_handshake (struct ekg_gnutls_connection_starter *gcs)
static void	ekg_gnutls_handle_handshake_input (GDataInputStream *s, gpointer data)
static void	ekg_gnutls_log (gint level, const char *msg)
void	ekg_tls_init (void)
void	ekg_tls_deinit (void)

Zmienne
static GSList *	connections = NULL

Dokumentacja definicji

EKG_CONNECTION_ERROR

#define EKG_CONNECTION_ERROR   ekg_connection_error_quark()

EKG_GNUTLS_ERROR

#define EKG_GNUTLS_ERROR   ekg_gnutls_error_quark()

NEED_SLAVERY

#define NEED_SLAVERY   1

Dokumentacja definicji typów

ekg_flush_handler_t

typedef void(* ekg_flush_handler_t) (struct ekg_connection *conn)

Dokumentacja funkcji

done_async_connect()

static void done_async_connect ( GObject *  obj, GAsyncResult *  res, gpointer  user_data  )

static

done_async_read()

static void done_async_read ( GObject *  obj, GAsyncResult *  res, gpointer  user_data  )

static

done_async_write()

static void done_async_write ( GObject *  obj, GAsyncResult *  res, gpointer  user_data  )

static

ekg_connection_add()

GDataOutputStream* ekg_connection_add	(	GSocketConnection *	conn,
		GInputStream *	raw_instream,
		GOutputStream *	raw_outstream,
		ekg_input_callback_t	callback,
		ekg_failure_callback_t	failure_callback,
		gpointer	priv_data
	)

ekg_connection_error_quark()

GQuark ekg_connection_error_quark

(

)

ekg_connection_remove()

static void ekg_connection_remove ( struct ekg_connection *  c )

static

ekg_connection_starter_bind()

void ekg_connection_starter_bind	(	ekg_connection_starter_t	cs,
		const gchar *	hostname
	)

ekg_connection_starter_free()

void ekg_connection_starter_free

(

ekg_connection_starter_t

cs

)

ekg_connection_starter_new()

ekg_connection_starter_t ekg_connection_starter_new

(

guint16

defport

)

ekg_connection_starter_run()

GCancellable* ekg_connection_starter_run	(	ekg_connection_starter_t	cs,
		GSocketClient *	sock,
		ekg_connection_callback_t	callback,
		ekg_connection_failure_callback_t	failure_callback,
		gpointer	priv_data
	)

ekg_connection_starter_set_servers()

void ekg_connection_starter_set_servers	(	ekg_connection_starter_t	cs,
		const gchar *	servers
	)

ekg_connection_starter_set_srv_resolver()

void ekg_connection_starter_set_srv_resolver	(	ekg_connection_starter_t	cs,
		const gchar *	service,
		const gchar *	domain
	)

ekg_connection_starter_set_use_tls()

void ekg_connection_starter_set_use_tls	(	ekg_connection_starter_t	cs,
		gboolean	use_tls
	)

ekg_connection_write()

void ekg_connection_write	(	GDataOutputStream *	f,
		const gchar *	format,
			...
	)

ekg_connection_write_buf()

void ekg_connection_write_buf	(	GDataOutputStream *	f,
		gconstpointer	buf,
		gsize	len
	)

ekg_disconnect_by_outstream()

void ekg_disconnect_by_outstream

(

GDataOutputStream *

f

)

ekg_gnutls_async_handshake()

static void ekg_gnutls_async_handshake ( struct ekg_gnutls_connection_starter *  gcs )

static

ekg_gnutls_error_quark()

static G_GNUC_CONST GQuark ekg_gnutls_error_quark ( )

static

ekg_gnutls_flush()

static void ekg_gnutls_flush ( struct ekg_connection *  c )

static

ekg_gnutls_free_connection()

static void ekg_gnutls_free_connection ( struct ekg_gnutls_connection *  conn )

static

ekg_gnutls_free_connection_starter()

static void ekg_gnutls_free_connection_starter ( struct ekg_gnutls_connection_starter *  gcs )

static

ekg_gnutls_handle_data()

static void ekg_gnutls_handle_data ( GDataInputStream *  s, gpointer  data  )

static

ekg_gnutls_handle_data_failure()

static void ekg_gnutls_handle_data_failure ( GDataInputStream *  s, GError *  err, gpointer  data  )

static

ekg_gnutls_handle_handshake_failure()

static void ekg_gnutls_handle_handshake_failure ( GDataInputStream *  s, GError *  err, gpointer  data  )

static

ekg_gnutls_handle_handshake_input()

static void ekg_gnutls_handle_handshake_input ( GDataInputStream *  s, gpointer  data  )

static

ekg_gnutls_log()

static void ekg_gnutls_log ( gint  level, const char *  msg  )

static

ekg_gnutls_new_session()

static void ekg_gnutls_new_session ( GSocketClient *  sockclient, GSocketConnection *  sock, struct ekg_connection_starter *  cs  )

static

ekg_gnutls_pull()

static gssize ekg_gnutls_pull ( gnutls_transport_ptr_t  connptr, gpointer  buf, gsize  len  )

static

ekg_gnutls_push()

static gssize ekg_gnutls_push ( gnutls_transport_ptr_t  connptr, gconstpointer  buf, gsize  len  )

static

ekg_tls_deinit()

void ekg_tls_deinit

(

void

)

ekg_tls_init()

void ekg_tls_init

(

void

)

failed_async_connect()

static void failed_async_connect ( GSocketClient *  sock, GError *  err, struct ekg_connection_starter *  cs  )

static

failed_write()

static void failed_write ( struct ekg_connection *  c )

static

get_connection_by_outstream()

static struct ekg_connection* get_connection_by_outstream ( GDataOutputStream *  s )

static

get_slave_connection_by_conn()

static struct ekg_connection* get_slave_connection_by_conn ( GSocketConnection *  c )

static

setup_async_connect()

static gboolean setup_async_connect ( GSocketClient *  sock, struct ekg_connection_starter *  cs  )

static

setup_async_read()

static void setup_async_read ( struct ekg_connection *  c )

static

setup_async_write()

static void setup_async_write ( struct ekg_connection *  c )

static

succeeded_async_connect()

static void succeeded_async_connect ( GSocketClient *  sock, GSocketConnection *  conn, struct ekg_connection_starter *  cs, GInputStream *  instream, GOutputStream *  outstream  )

static

Dokumentacja zmiennych

connections

GSList* connections = NULL

static