slapd/back-meta/search.c

78 	SlapReply		*candidates )
138 		candidates[ candidate ].sr_msgid = META_MSGID_NEED_BIND;
257 			NULL, NULL, &candidates[ candidate ].sr_msgid );
272 		assert( candidates[ candidate ].sr_msgid >= 0 );
273 		META_BINDING_SET( &candidates[ candidate ] );
278 		candidates[ candidate ].sr_msgid = META_MSGID_CONNECTING;
288 		if ( !META_IS_RETRYING( &candidates[ candidate ] ) ) {
289 			META_RETRYING_SET( &candidates[ candidate ] );
328 				candidates[ candidate ].sr_msgid = META_MSGID_IGNORE;
336 			candidates[ candidate ].sr_msgid = META_MSGID_IGNORE;
348 		candidates[ candidate ].sr_err = rc;
360 		candidates[ candidate ].sr_msgid = META_MSGID_IGNORE;
374 	SlapReply		*candidates,
388 		&candidates[ candidate ].sr_err,
391 		candidates[ candidate ].sr_err = rc;
394 		rc = slap_map_api2result( &candidates[ candidate ] );
401 		candidates[ candidate ].sr_err = rc;
426 	candidates[ candidate ].sr_msgid = META_MSGID_IGNORE;
427 	META_BINDING_CLEAR( &candidates[ candidate ] );
441 	SlapReply		*candidates )
463 		candidates[ candidate ].sr_err = LDAP_OTHER;
467 		candidates[ candidate ].sr_msgid = META_MSGID_IGNORE;
539 	retcode = meta_search_dobind_init( op, rs, mcp, candidate, candidates );
615 		candidates[ candidate ].sr_msgid = META_MSGID_IGNORE;
628 			&candidates[ candidate ].sr_msgid );
644 			candidates[ candidate ].sr_msgid = META_MSGID_IGNORE;
650 		candidates[ candidate ].sr_msgid = META_MSGID_IGNORE;
693 	SlapReply	*candidates = NULL;
710 	if ( candidates == NULL ) candidates = meta_back_candidates_get( op );
717 		candidates[ i ].sr_msgid = META_MSGID_IGNORE;
726 		if ( !META_IS_CANDIDATE( &candidates[ i ] ) ) {
730 		candidates[ i ].sr_matched = NULL;
731 		candidates[ i ].sr_text = NULL;
732 		candidates[ i ].sr_ref = NULL;
733 		candidates[ i ].sr_ctrls = NULL;
735 		/* get largest timeout among candidates */
744 		if ( !META_IS_CANDIDATE( &candidates[ i ] )
745 			|| candidates[ i ].sr_err != LDAP_SUCCESS )
750 		switch ( meta_back_search_start( op, rs, &dc, &mc, i, candidates ) )
753 			candidates[ i ].sr_msgid = META_MSGID_IGNORE;
763 			candidates[ i ].sr_type = REP_INTERMEDIATE;
824 			if ( META_IS_CANDIDATE( &candidates[ c ] ) ) {
854 			if ( META_IS_CANDIDATE( &candidates[ i ] )
855 				&& candidates[ i ].sr_err != LDAP_SUCCESS )
857 				rc = candidates[ i ].sr_err;
877 	 * In case there are no candidates, no cycle takes place...
880 	 * among the candidates
921 			if ( candidates[ i ].sr_msgid == META_MSGID_IGNORE ) {
926 			if ( candidates[ i ].sr_msgid == META_MSGID_NEED_BIND
927 				|| candidates[ i ].sr_msgid == META_MSGID_CONNECTING )
930 				retcode = meta_search_dobind_init( op, rs, &mc, i, candidates );
945 					candidates[ i ].sr_err = rs->sr_err;
957 					 * When no candidates are left,
960 					candidates[ i ].sr_msgid = META_MSGID_IGNORE;
966 					candidates[ i ].sr_msgid = META_MSGID_IGNORE;
967 					switch ( meta_back_search_start( op, rs, &dc, &mc, i, candidates ) )
970 						assert( candidates[ i ].sr_msgid >= 0 );
974 						candidates[ i ].sr_err = rs->sr_err;
987 						candidates[ i ].sr_msgid = META_MSGID_IGNORE;
1020 					candidates[ i ].sr_msgid,
1021 					META_IS_BINDING( &candidates[ i ] ) ? " binding" : "",
1038 			rc = ldap_result( msc->msc_ld, candidates[ i ].sr_msgid,
1049 				if ( candidates[ i ].sr_type == REP_INTERMEDIATE ) {
1050 					candidates[ i ].sr_type = REP_RESULT;
1053 						candidates[ i ].sr_msgid = META_MSGID_IGNORE;
1054 						switch ( meta_back_search_start( op, rs, &dc, &mc, i, candidates ) )
1058 							candidates[ i ].sr_msgid = META_MSGID_IGNORE;
1063 							candidates[ i ].sr_err = rs->sr_err;
1085 							candidates[ i ].sr_msgid = META_MSGID_IGNORE;
1091 					candidates[ i ].sr_err = rs->sr_err;
1102 				 * When no candidates are left,
1105 				candidates[ i ].sr_msgid = META_MSGID_IGNORE;
1108 				rs->sr_err = candidates[ i ].sr_err;
1129 					if ( candidates[ i ].sr_type == REP_INTERMEDIATE ) {
1131 						candidates[ i ].sr_type = REP_RESULT;
1173 					if ( candidates[ i ].sr_type == REP_INTERMEDIATE ) {
1175 						candidates[ i ].sr_type = REP_RESULT;
1237 					if ( candidates[ i ].sr_type == REP_INTERMEDIATE ) {
1239 						candidates[ i ].sr_type = REP_RESULT;
1251 						candidates[ i ].sr_type = REP_RESULT;
1278 					if ( candidates[ i ].sr_type == REP_INTERMEDIATE ) {
1280 						candidates[ i ].sr_type = REP_RESULT;
1283 					candidates[ i ].sr_msgid = META_MSGID_IGNORE;
1296 						&candidates[ i ].sr_err,
1297 						(char **)&candidates[ i ].sr_matched,
1298 						NULL /* (char **)&candidates[ i ].sr_text */ ,
1300 						NULL /* &candidates[ i ].sr_ctrls (unused) */ ,
1303 						sres = slap_map_api2result( &candidates[ i ] );
1304 						candidates[ i ].sr_type = REP_RESULT;
1310 					rs->sr_err = candidates[ i ].sr_err;
1313 					if ( candidates[ i ].sr_matched != NULL ) {
1316 						ber_str2bv( candidates[ i ].sr_matched,
1318 						candidates[ i ].sr_matched = NULL;
1324 								candidates[ i ].sr_matched
1328 								candidates[ i ].sr_matched = mmatch.bv_val;
1402 							candidates[ i ].sr_matched ? candidates[ i ].sr_matched : "",
1403 							(long) candidates[ i ].sr_err );
1404 						if ( candidates[ i ].sr_err == LDAP_SUCCESS ) {
1409 								buf, ldap_err2string( candidates[ i ].sr_err ), 0 );
1440 						candidates[ i ].sr_err = rs->sr_err;
1455 						candidates[ i ].sr_err = rs->sr_err;
1472 					 * When no candidates are left,
1481 					retcode = meta_search_dobind_result( op, rs, &mc, i, candidates, msg );
1483 						candidates[ i ].sr_msgid = META_MSGID_IGNORE;
1484 						retcode = meta_back_search_start( op, rs, &dc, &mc, i, candidates );
1494 						candidates[ i ].sr_msgid = META_MSGID_IGNORE;
1498 						candidates[ i ].sr_err = rs->sr_err;
1536 				if ( candidates[ i ].sr_msgid >= 0
1537 					|| candidates[ i ].sr_msgid == META_MSGID_CONNECTING )
1539 					if ( META_IS_BINDING( &candidates[ i ] )
1540 						|| candidates[ i ].sr_msgid == META_MSGID_CONNECTING )
1544 							|| candidates[ i ].sr_msgid == META_MSGID_CONNECTING )
1562 						META_BINDING_CLEAR( &candidates[ i ] );
1566 							candidates[ i ].sr_msgid, i,
1570 					candidates[ i ].sr_msgid = META_MSGID_IGNORE;
1634 			if ( META_IS_CANDIDATE( &candidates[ i ] )
1635 					&& candidates[ i ].sr_matched != NULL )
1645 					&& candidates[ i ].sr_err == LDAP_NO_SUCH_OBJECT
1648 					free( (char *)candidates[ i ].sr_matched );
1649 					candidates[ i ].sr_matched = NULL;
1653 				ber_str2bv( candidates[ i ].sr_matched, 0, 0, &bv );
1673 				if ( candidates[ i ].sr_matched != NULL ) {
1674 					free( (char *)candidates[ i ].sr_matched );
1675 					candidates[ i ].sr_matched = NULL;
1706 				if ( !META_IS_CANDIDATE( &candidates[ i ] ) ) {
1710 				if ( candidates[ i ].sr_err != LDAP_SUCCESS
1711 					&& candidates[ i ].sr_err != LDAP_NO_SUCH_OBJECT )
1713 					sres = candidates[ i ].sr_err;
1738 		if ( !META_IS_CANDIDATE( &candidates[ i ] ) ) {
1743 			if ( META_IS_BINDING( &candidates[ i ] )
1744 				|| candidates[ i ].sr_msgid == META_MSGID_CONNECTING )
1748 					|| candidates[ i ].sr_msgid == META_MSGID_CONNECTING )
1750 					assert( candidates[ i ].sr_msgid >= 0
1751 						|| candidates[ i ].sr_msgid == META_MSGID_CONNECTING );
1764 				META_BINDING_CLEAR( &candidates[ i ] );
1766 			} else if ( candidates[ i ].sr_msgid >= 0 ) {
1768 					candidates[ i ].sr_msgid, i,
1773 		if ( candidates[ i ].sr_matched ) {
1774 			free( (char *)candidates[ i ].sr_matched );
1775 			candidates[ i ].sr_matched = NULL;
1778 		if ( candidates[ i ].sr_text ) {
1779 			ldap_memfree( (char *)candidates[ i ].sr_text );
1780 			candidates[ i ].sr_text = NULL;
1783 		if ( candidates[ i ].sr_ref ) {
1784 			ber_bvarray_free( candidates[ i ].sr_ref );
1785 			candidates[ i ].sr_ref = NULL;
1788 		if ( candidates[ i ].sr_ctrls ) {
1789 			ldap_controls_free( candidates[ i ].sr_ctrls );
1790 			candidates[ i ].sr_ctrls = NULL;
1794 			meta_back_quarantine( op, &candidates[ i ], i );