operation.c 4.62 KB
Newer Older
Kurt Zeilenga's avatar
Kurt Zeilenga committed
1
/* operation.c - routines to deal with pending ldap operations */
2
/* $OpenLDAP$ */
Kurt Zeilenga's avatar
Kurt Zeilenga committed
3
4
/* This work is part of OpenLDAP Software <http://www.openldap.org/>.
 *
Kurt Zeilenga's avatar
Kurt Zeilenga committed
5
 * Copyright 1998-2008 The OpenLDAP Foundation.
Kurt Zeilenga's avatar
Kurt Zeilenga committed
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted only as authorized by the OpenLDAP
 * Public License.
 *
 * A copy of this license is available in the file LICENSE in the
 * top-level directory of the distribution or, alternatively, at
 * <http://www.OpenLDAP.org/license.html>.
 */
/* Portions Copyright (c) 1995 Regents of the University of Michigan.
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms are permitted
 * provided that this notice is preserved and that due credit is given
 * to the University of Michigan at Ann Arbor. The name of the University
 * may not be used to endorse or promote products derived from this
 * software without specific prior written permission. This software
 * is provided ``as is'' without express or implied warranty.
Kurt Zeilenga's avatar
Kurt Zeilenga committed
25
 */
Kurt Zeilenga's avatar
Kurt Zeilenga committed
26

Kurt Zeilenga's avatar
Kurt Zeilenga committed
27
28
#include "portable.h"

Kurt Zeilenga's avatar
Kurt Zeilenga committed
29
#include <stdio.h>
Kurt Zeilenga's avatar
Kurt Zeilenga committed
30
31
32
33

#include <ac/string.h>
#include <ac/socket.h>

Kurt Zeilenga's avatar
Kurt Zeilenga committed
34
#include "slap.h"
35
36

#ifdef LDAP_SLAPI
37
#include "slapi/slapi.h"
38
#endif
Kurt Zeilenga's avatar
Kurt Zeilenga committed
39

40
41
static ldap_pvt_thread_mutex_t	slap_op_mutex;
static LDAP_STAILQ_HEAD(s_o, slap_op)	slap_free_ops;
Kurt Zeilenga's avatar
Kurt Zeilenga committed
42
43
static time_t last_time;
static int last_incr;
44

Pierangelo Masarati's avatar
Pierangelo Masarati committed
45
void slap_op_init(void)
46
47
48
49
50
{
	ldap_pvt_thread_mutex_init( &slap_op_mutex );
	LDAP_STAILQ_INIT(&slap_free_ops);
}

Pierangelo Masarati's avatar
Pierangelo Masarati committed
51
void slap_op_destroy(void)
52
53
54
55
56
57
58
59
60
61
{
	Operation *o;

	while ( (o = LDAP_STAILQ_FIRST( &slap_free_ops )) != NULL) {
		LDAP_STAILQ_REMOVE_HEAD( &slap_free_ops, o_next );
		LDAP_STAILQ_NEXT(o, o_next) = NULL;
		ch_free( o );
	}
	ldap_pvt_thread_mutex_destroy( &slap_op_mutex );
}
Kurt Zeilenga's avatar
Kurt Zeilenga committed
62

Pierangelo Masarati's avatar
Pierangelo Masarati committed
63
64
65
66
67
68
69
70
71
72
73
void
slap_op_groups_free( Operation *op )
{
	GroupAssertion *g, *n;
	for ( g = op->o_groups; g; g = n ) {
		n = g->ga_next;
		slap_sl_free( g, op->o_tmpmemctx );
	}
	op->o_groups = NULL;
}

Kurt Zeilenga's avatar
Kurt Zeilenga committed
74
void
75
slap_op_free( Operation *op )
Kurt Zeilenga's avatar
Kurt Zeilenga committed
76
{
77
	assert( LDAP_STAILQ_NEXT(op, o_next) == NULL );
78

79
	if ( op->o_ber != NULL ) {
Kurt Zeilenga's avatar
Kurt Zeilenga committed
80
		ber_free( op->o_ber, 1 );
81
	}
82
	if ( !BER_BVISNULL( &op->o_dn ) ) {
Kurt Zeilenga's avatar
Kurt Zeilenga committed
83
		ch_free( op->o_dn.bv_val );
Howard Chu's avatar
Howard Chu committed
84
	}
85
	if ( !BER_BVISNULL( &op->o_ndn ) ) {
Kurt Zeilenga's avatar
Kurt Zeilenga committed
86
		ch_free( op->o_ndn.bv_val );
Howard Chu's avatar
Howard Chu committed
87
	}
88
	if ( !BER_BVISNULL( &op->o_authmech ) ) {
Kurt Zeilenga's avatar
Kurt Zeilenga committed
89
		ch_free( op->o_authmech.bv_val );
Howard Chu's avatar
Howard Chu committed
90
	}
Kurt Zeilenga's avatar
Kurt Zeilenga committed
91
	if ( op->o_ctrls != NULL ) {
92
		slap_free_ctrls( op, op->o_ctrls );
Kurt Zeilenga's avatar
Kurt Zeilenga committed
93
	}
94

95
96
97
98
99
#ifdef LDAP_CONNECTIONLESS
	if ( op->o_res_ber != NULL ) {
		ber_free( op->o_res_ber, 1 );
	}
#endif
Jong Hyuk Choi's avatar
Jong Hyuk Choi committed
100

Pierangelo Masarati's avatar
Pierangelo Masarati committed
101
102
	if ( op->o_groups ) {
		slap_op_groups_free( op );
103
104
	}

105
#if defined( LDAP_SLAPI )
Kurt Zeilenga's avatar
Kurt Zeilenga committed
106
	if ( slapi_plugins_used ) {
107
		slapi_int_free_object_extensions( SLAPI_X_EXT_OPERATION, op );
108
109
110
	}
#endif /* defined( LDAP_SLAPI ) */

Jong Hyuk Choi's avatar
Jong Hyuk Choi committed
111

112
113
114
	memset( op, 0, sizeof(Operation) + sizeof(Opheader) + SLAP_MAX_CIDS * sizeof(void *) );
	op->o_hdr = (Opheader *)(op+1);
	op->o_controls = (void **)(op->o_hdr+1);
Jong Hyuk Choi's avatar
Jong Hyuk Choi committed
115

116
117
118
	ldap_pvt_thread_mutex_lock( &slap_op_mutex );
	LDAP_STAILQ_INSERT_HEAD( &slap_free_ops, op, o_next );
	ldap_pvt_thread_mutex_unlock( &slap_op_mutex );
Kurt Zeilenga's avatar
Kurt Zeilenga committed
119
120
}

Kurt Zeilenga's avatar
Kurt Zeilenga committed
121
122
123
124
void
slap_op_time(time_t *t, int *nop)
{
	ldap_pvt_thread_mutex_lock( &slap_op_mutex );
Quanah Gibson-Mount's avatar
Quanah Gibson-Mount committed
125
	*t = slap_get_time();
Kurt Zeilenga's avatar
Kurt Zeilenga committed
126
127
128
129
130
131
132
133
134
135
	if ( *t == last_time ) {
		*nop = ++last_incr;
	} else {
		last_time = *t;
		last_incr = 0;
		*nop = 0;
	}
	ldap_pvt_thread_mutex_unlock( &slap_op_mutex );
}

Kurt Zeilenga's avatar
Kurt Zeilenga committed
136
Operation *
137
slap_op_alloc(
Kurt Zeilenga's avatar
Kurt Zeilenga committed
138
    BerElement		*ber,
139
140
141
    ber_int_t	msgid,
    ber_tag_t	tag,
    ber_int_t	id
Kurt Zeilenga's avatar
Kurt Zeilenga committed
142
143
)
{
144
	Operation	*op;
Kurt Zeilenga's avatar
Kurt Zeilenga committed
145

146
	ldap_pvt_thread_mutex_lock( &slap_op_mutex );
Pierangelo Masarati's avatar
Pierangelo Masarati committed
147
	if ((op = LDAP_STAILQ_FIRST( &slap_free_ops ))) {
148
149
150
151
		LDAP_STAILQ_REMOVE_HEAD( &slap_free_ops, o_next );
	}
	ldap_pvt_thread_mutex_unlock( &slap_op_mutex );

Jong Hyuk Choi's avatar
Jong Hyuk Choi committed
152
	if (!op) {
153
154
155
156
		op = (Operation *) ch_calloc( 1, sizeof(Operation)
			+ sizeof(Opheader) + SLAP_MAX_CIDS * sizeof(void *) );
		op->o_hdr = (Opheader *)(op + 1);
		op->o_controls = (void **)(op->o_hdr+1);
Jong Hyuk Choi's avatar
Jong Hyuk Choi committed
157
	}
158

159
160
161
	op->o_ber = ber;
	op->o_msgid = msgid;
	op->o_tag = tag;
162

Kurt Zeilenga's avatar
Kurt Zeilenga committed
163
	slap_op_time( &op->o_time, &op->o_tincr );
164
	op->o_opid = id;
165
	op->o_res_ber = NULL;
Kurt Zeilenga's avatar
Kurt Zeilenga committed
166

167
#if defined( LDAP_SLAPI )
168
	if ( slapi_plugins_used ) {
169
		slapi_int_create_object_extensions( SLAPI_X_EXT_OPERATION, op );
170
	}
171
172
#endif /* defined( LDAP_SLAPI ) */

173
	return( op );
Kurt Zeilenga's avatar
Kurt Zeilenga committed
174
}
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203

slap_op_t
slap_req2op( ber_tag_t tag )
{
	switch ( tag ) {
	case LDAP_REQ_BIND:
		return SLAP_OP_BIND;
	case LDAP_REQ_UNBIND:
		return SLAP_OP_UNBIND;
	case LDAP_REQ_ADD:
		return SLAP_OP_ADD;
	case LDAP_REQ_DELETE:
		return SLAP_OP_DELETE;
	case LDAP_REQ_MODRDN:
		return SLAP_OP_MODRDN;
	case LDAP_REQ_MODIFY:
		return SLAP_OP_MODIFY;
	case LDAP_REQ_COMPARE:
		return SLAP_OP_COMPARE;
	case LDAP_REQ_SEARCH:
		return SLAP_OP_SEARCH;
	case LDAP_REQ_ABANDON:
		return SLAP_OP_ABANDON;
	case LDAP_REQ_EXTENDED:
		return SLAP_OP_EXTENDED;
	}

	return SLAP_OP_LAST;
}