Commit a7f8f58a authored by Ondřej Kuzník's avatar Ondřej Kuzník
Browse files

expose task functions for invalidation

parent bf9f99dd
...@@ -66,7 +66,7 @@ lload_connection_assign_nextid( LloadConnection *conn ) ...@@ -66,7 +66,7 @@ lload_connection_assign_nextid( LloadConnection *conn )
* already has a pdu pending on the same operation, it's their job to make sure * already has a pdu pending on the same operation, it's their job to make sure
* we're woken up again. * we're woken up again.
*/ */
static void * void *
handle_pdus( void *ctx, void *arg ) handle_pdus( void *ctx, void *arg )
{ {
LloadConnection *c = arg; LloadConnection *c = arg;
......
...@@ -87,6 +87,7 @@ LDAP_SLAPD_F (int) lload_back_init_cf( BackendInfo *bi ); ...@@ -87,6 +87,7 @@ LDAP_SLAPD_F (int) lload_back_init_cf( BackendInfo *bi );
* connection.c * connection.c
*/ */
LDAP_SLAPD_V (ldap_pvt_thread_mutex_t) clients_mutex; LDAP_SLAPD_V (ldap_pvt_thread_mutex_t) clients_mutex;
LDAP_SLAPD_F (void *) handle_pdus( void *ctx, void *arg );
LDAP_SLAPD_F (void) connection_write_cb( evutil_socket_t s, short what, void *arg ); LDAP_SLAPD_F (void) connection_write_cb( evutil_socket_t s, short what, void *arg );
LDAP_SLAPD_F (void) connection_read_cb( evutil_socket_t s, short what, void *arg ); LDAP_SLAPD_F (void) connection_read_cb( evutil_socket_t s, short what, void *arg );
LDAP_SLAPD_F (void) lload_connection_close( LloadConnection *c ); LDAP_SLAPD_F (void) lload_connection_close( LloadConnection *c );
...@@ -175,6 +176,7 @@ LDAP_SLAPD_F (void) operation_update_global_rejected( LloadOperation *op ); ...@@ -175,6 +176,7 @@ LDAP_SLAPD_F (void) operation_update_global_rejected( LloadOperation *op );
*/ */
LDAP_SLAPD_F (int) forward_final_response( LloadConnection *client, LloadOperation *op, BerElement *ber ); LDAP_SLAPD_F (int) forward_final_response( LloadConnection *client, LloadOperation *op, BerElement *ber );
LDAP_SLAPD_F (int) forward_response( LloadConnection *client, LloadOperation *op, BerElement *ber ); LDAP_SLAPD_F (int) forward_response( LloadConnection *client, LloadOperation *op, BerElement *ber );
LDAP_SLAPD_F (void *) upstream_bind( void *ctx, void *arg );
LDAP_SLAPD_F (LloadConnection *) upstream_init( ber_socket_t s, LloadBackend *b ); LDAP_SLAPD_F (LloadConnection *) upstream_init( ber_socket_t s, LloadBackend *b );
LDAP_SLAPD_F (void) upstream_destroy( LloadConnection *c ); LDAP_SLAPD_F (void) upstream_destroy( LloadConnection *c );
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment