slapd/back-asyncmeta/add.c

48 			int candidate)
51 	mc->mc_conns[candidate].msc_active--;
69 			 int candidate,
78 	a_metatarget_t	*mt = mi->mi_targets[ candidate ];
82 	a_metasingleconn_t	*msc = &mc->mc_conns[ candidate ];
133 	if ( asyncmeta_controls_add( op, rs, mc, candidate, bc->is_root, &ctrls ) != LDAP_SUCCESS )
135 		candidates[ candidate ].sr_msgid = META_MSGID_IGNORE;
179 			candidates[ candidate ].sr_msgid = msgid;
199 				asyncmeta_reset_msc(NULL, mc, candidate, 0, __FUNCTION__);
212 	switch (bc->nretries[candidate]) {
218 		candidates[ candidate ].sr_msgid = META_MSGID_IGNORE;
225 		bc->nretries[candidate]--;
237 	Debug( LDAP_DEBUG_TRACE, "%s <<< asyncmeta_back_add_start[%p]=%d\n", op->o_log_prefix, msc, candidates[candidate].sr_msgid );
248 	int		rc, candidate = -1;
271 	mc = asyncmeta_getconn( op, rs, candidates, &candidate, LDAP_BACK_DONTSEND, 0);
277 	mt = mi->mi_targets[ candidate ];
293 	mc->mc_conns[candidate].msc_active++;
301 		mc->mc_conns[candidate].msc_active--;
314 		asyncmeta_error_cleanup(op, rs, bc, mc, candidate);
318 	rc = asyncmeta_dobind_init_with_retry(op, rs, bc, mc, candidate);
324 		       "cnd=\"%d\"\n", op->o_log_prefix, candidate );
326 		rc = asyncmeta_back_add_start( op, rs, mc, bc, candidate, 1);
328 			asyncmeta_error_cleanup(op, rs, bc, mc, candidate);
337 		       "cnd=\"%d\"\n", op->o_log_prefix, candidate );
338 		asyncmeta_error_cleanup(op, rs, bc, mc, candidate);
344 		       "cnd=\"%d\" %p\n", op->o_log_prefix, candidate , &mc->mc_conns[candidate]);
351 		       "cnd=\"%d\"\n", op->o_log_prefix, candidate );
352 		asyncmeta_error_cleanup(op, rs, bc, mc, candidate);
360 	mc->mc_conns[candidate].msc_active--;
361 	asyncmeta_start_one_listener(mc, candidates, bc, candidate);