upstream/openldap
1
0
Fork 0
mirror of https://git.openldap.org/openldap/openldap.git synced 2025-12-20 22:59:34 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

ITS#9789 Expose operation_counter_init

Browse source
This commit is contained in:
Ondřej Kuzník 2022-01-25 14:31:51 +00:00 committed by Quanah Gibson-Mount
parent 70c9dbf93d
commit ebfbf8281a
2 changed files with 6 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
servers/slapd/connection.c
View file

@ -963,18 +963,18 @@ conn_counter_destroy( void *key, void *data )
ldap_pvt_thread_mutex_unlock( &slap_counters.sc_mutex );
}
static void
conn_counter_init( Operation *op, void *ctx )
void
operation_counter_init( Operation *op, void *ctx )
{
slap_counters_t *sc;
void *vsc = NULL;
if ( ldap_pvt_thread_pool_getkey(
ctx, (void *)conn_counter_init, &vsc, NULL ) || !vsc ) {
ctx, (void *)operation_counter_init, &vsc, NULL ) || !vsc ) {
vsc = ch_malloc( sizeof( slap_counters_t ));
sc = vsc;
slap_counters_init( sc );
ldap_pvt_thread_pool_setkey( ctx, (void*)conn_counter_init, vsc,
ldap_pvt_thread_pool_setkey( ctx, (void*)operation_counter_init, vsc,
conn_counter_destroy, NULL, NULL );
ldap_pvt_thread_mutex_lock( &slap_counters.sc_mutex );
@ -1032,7 +1032,7 @@ connection_operation( void *ctx, void *arg_v )
op->o_qtime.tv_sec--;
}
op->o_qtime.tv_sec -= op->o_time;
conn_counter_init( op, ctx );
operation_counter_init( op, ctx );
ldap_pvt_thread_mutex_lock( &op->o_counters->sc_mutex );
/* FIXME: returns 0 in case of failure */
ldap_pvt_mp_add_ulong(op->o_counters->sc_ops_initiated, 1);

1
servers/slapd/proto-slap.h
View file

@ -775,6 +775,7 @@ LDAP_SLAPD_F (Connection *) connection_init LDAP_P((
struct berval *id
LDAP_PF_LOCAL_SENDMSG_ARG(struct berval *peerbv)));
LDAP_SLAPD_F (void) operation_counter_init LDAP_P(( Operation *op, void *threadctx ));
LDAP_SLAPD_F (void) connection_closing LDAP_P((
Connection *c, const char *why ));
LDAP_SLAPD_F (int) connection_is_active LDAP_P(( ber_socket_t s ));