|
InfoDirectory使用手引書
|
目次
索引
 
|
5.5.3.9 非同期型リフェラル先のエントリ検索（自動追跡）
リフェラル先のエントリ検索（自動追跡）におけるサンプルプログラムを以下に示します。
このサンプルプログラムでは、リフェラル先への検索をLDAP-APIで自動的に行う場合の検索です。
［search_ref_auto.c］
/*
* Copyright (c) 2001. Fujitsu Limited. All rights reserved.
*
* Search the directory for all entry, and automatically follow referral.
*
*/
#include <sys/types.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#if defined(_WIN32)
#include <winsock.h>
#endif
#include "examples.h"
unsigned long global_counter = 0;
char *host = "localhost";
int port = LDAP_PORT;
char *s_base = "o=Fujitsu,c=JP";
int scope = LDAP_SCOPE_SUBTREE;
char *filter = "(objectclass=*)";
/*-------------------------------------------------------------*/
/*
* Perform other work while polling for results. This doesn't do anything
* useful, but it could.
*/
static void do_other_work()
{
extern unsigned long global_counter;
global_counter++;
}
/*-------------------------------------------------------------*/
/*
* main program
*/
int main(
int argc,
char *argv[]
)
{
LDAP *ld;
LDAPMessage *result;
LDAPMessage *entry;
struct timeval zerotime;
int msgid;
int rtn;
int optdata;
int finished;
int errcode;
char *errmsg;
char *mached;
int num_entries = 0;
char **referralsh;
extern char *host;
extern int port;
extern char *s_base;
extern int scope;
extern char *filter;
/*----------------------------------------------------------*/
printf( "%s is start\n", argv[0] );
printf( "%s: ldap_init( \"%s\", %d )\n", argv[0], host, port );
ld = ldap_init( host, port );
if ( ld == NULL ) {
perror( "ldap_init" );
printf( "%s is abnormal end\n", argv[0] );
exit( 1 );
}
/* set option ( LDAP_OPT_ON ) */
optdata = LDAP_OPT_ON;
printf( "%s: ldap_set_option( LDAP_OPT_REFERRALS, %d )\n", argv[0], optdata );
rtn = ldap_set_option(ld, LDAP_OPT_REFERRALS, (void *)(&optdata));
if ( rtn != 0 ) {
do_error_msg( "ldap_set_option", rtn, NULL, NULL );
do_unbind( ld, argv );
printf( "%s is abnormal end\n", argv[0] );
exit( 1 );
}
/* set option ( 10 ) */
optdata = 10;
printf( "%s: ldap_set_option( LDAP_OPT_REFERRAL_HOP_LIMIT, %d )\n", argv[0], optdata );
rtn = ldap_set_option(ld, LDAP_OPT_REFERRAL_HOP_LIMIT, (void *)(&optdata));
if ( rtn != 0 ) {
do_error_msg( "ldap_set_option", rtn, NULL, NULL );
do_unbind( ld, argv );
printf( "%s is abnormal end\n", argv[0] );
exit( 1 );
}
/* set option ( LDAP_DEREF_ALWAYS ) */
optdata = LDAP_DEREF_ALWAYS;
printf( "%s: ldap_set_option( LDAP_OPT_DEREF, %d )\n", argv[0], optdata );
rtn = ldap_set_option(ld, LDAP_OPT_DEREF, (void *)(&optdata));
if (rtn != 0 ) {
do_error_msg( "ldap_set_option", rtn, NULL, NULL );
do_unbind( ld, argv );
printf( "%s is abnormal end\n", argv[0] );
exit( 1 );
}
/* set option ( LDAP_VERSION3 ) */
optdata = LDAP_VERSION3;
printf( "%s: ldap_set_option( LDAP_OPT_PROTOCOL_VERSION, %d )\n", argv[0], optdata );
rtn = ldap_set_option(ld, LDAP_OPT_PROTOCOL_VERSION, (void *)(&optdata));
if ( rtn != 0 ) {
do_error_msg( "ldap_set_option", rtn, NULL, NULL );
do_unbind( ld, argv );
printf( "%s is abnormal end\n", argv[0] );
exit( 1 );
}
/* simple authentication */
printf( "%s: ldap_simple_bind_s( anonymous )\n", argv[0] );
rtn = ldap_simple_bind_s( ld, NULL, NULL );
if ( rtn != LDAP_SUCCESS ) {
do_error_msg( "ldap_simple_bind_s", rtn, NULL, NULL );
do_unbind( ld, argv );
printf( "%s is abnormal end\n", argv[0] );
exit( 1 );
}
/* entry search */
printf( "%s: ldap_search( \"%s\", %d, \"%s\" )\n", argv[0], s_base, scope, filter );
msgid = ldap_search( ld, s_base, scope, filter, NULL, 0 );
if ( msgid < 0 ) {
do_get_ldaperror( ld, &errcode, &errmsg );
do_error_msg( "ldap_search", errcode, NULL, errmsg );
do_unbind( ld, argv );
printf( "%s is abnormal end\n", argv[0] );
exit( 1 );
}
/* Loop, polling for results until finished */
finished = 0;
while ( finished == 0 ) {
printf( "%s: ldap_result( )\n", argv[0] );
result = NULL;
zerotime.tv_sec = 30L;
zerotime.tv_usec = 0L;
rtn = ldap_result( ld, msgid, LDAP_MSG_ONE, &zerotime, &result );
switch ( rtn ) {
case -1:
/* some error occurred */
if ( result != NULL ) {
errcode = 0;
mached = NULL;
errmsg = NULL;
ldap_parse_result( ld, result, &errcode, &mached, &errmsg, &referralsh, 0, 0 );
do_error_msg( "ldap_result", errcode, mached, errmsg );
if(referralsh != NULL && *referralsh != NULL) {
fprintf( stderr, "\tldapURL\t\t\t: %s\n", *referralsh );
ldap_value_free(referralsh);
}
}
printf( "%s: Entry search error.\n", argv[0] );
do_unbind( ld, argv );
printf( "%s is abnormal end\n", argv[0] );
exit( 1 );
case 0:
/* Timeout was exceeded.
No entries are ready for retrieval. */
if ( result != NULL ) {
ldap_msgfree( result );
}
#if defined(unix)
sleep(1);
#elif defined(_WIN32)
Sleep(1*1000);
#endif
break;
case LDAP_RES_SEARCH_REFERENCE:
if((rtn = ldap_parse_reference(ld,result,&referralsh,NULL,0)) == LDAP_SUCCESS) {
fprintf( stderr, "\tldapURL\t\t\t: %s\n", *referralsh );
do_get_ldaperror( ld, &errcode, &errmsg );
do_error_msg( "ldap_search", errcode, NULL, errmsg );
ldap_value_free(referralsh);
}
if ( result != NULL ) {
ldap_msgfree( result );
}
do_unbind( ld, argv );
printf( "%s is abnormal end\n", argv[0] );
exit( 1 );
case LDAP_RES_SEARCH_RESULT:
ldap_parse_result( ld, result, &errcode, &mached, &errmsg, &referralsh, 0, 0 );
if(errcode == LDAP_SUCCESS) {
printf("search finished.\n");
printf("\n");
} else {
do_error_msg( "ldap_result", errcode, mached, errmsg );
}
if(referralsh != NULL && *referralsh != NULL) {
fprintf( stderr, "\tldapURL\t\t\t: %s\n", *referralsh );
ldap_value_free(referralsh);
}
default:
/*
* Either an entry is ready for retrieval, or all entries
* have been retrieved.
*/
entry = ldap_first_entry( ld, result );
if ( entry == NULL ) {
/* All done */
finished = 1;
if ( result != NULL ) {
ldap_msgfree( result );
}
continue;
}
num_entries += print_entry( ld, result, 1 );
}
/* Do other work here while you are waiting... */
do_other_work();
}
/* All done. Print a summary. */
printf( "%s: %d entries retrieved. I counted to %ld while I was waiting.\n", argv[0], num_entries, global_counter );
do_unbind( ld, argv );
printf( "%s is normal end\n", argv[0] );
exit( 0 );
}
All Rights Reserved, Copyright(C) 富士通株式会社 2005