3 * Copyright 1998-2002 The OpenLDAP Foundation, All Rights Reserved.
4 * COPYING RESTRICTIONS APPLY, see COPYRIGHT file
8 * LDAPv3 Extended Operation Request
9 * ExtendedRequest ::= [APPLICATION 23] SEQUENCE {
10 * requestName [0] LDAPOID,
11 * requestValue [1] OCTET STRING OPTIONAL
14 * LDAPv3 Extended Operation Response
15 * ExtendedResponse ::= [APPLICATION 24] SEQUENCE {
16 * COMPONENTS OF LDAPResult,
17 * responseName [10] LDAPOID OPTIONAL,
18 * response [11] OCTET STRING OPTIONAL
26 #include <ac/stdlib.h>
28 #include <ac/socket.h>
29 #include <ac/string.h>
35 ldap_extended_operation(
37 LDAP_CONST char *reqoid,
38 struct berval *reqdata,
47 LDAP_LOG (( "extended", LDAP_LEVEL_ENTRY, "ldap_extended_operation\n" ));
49 Debug( LDAP_DEBUG_TRACE, "ldap_extended_operation\n", 0, 0, 0 );
53 assert( LDAP_VALID( ld ) );
54 assert( reqoid != NULL || *reqoid == '\0' );
55 assert( msgidp != NULL );
57 /* must be version 3 (or greater) */
58 if ( ld->ld_version < LDAP_VERSION3 ) {
59 ld->ld_errno = LDAP_NOT_SUPPORTED;
60 return( ld->ld_errno );
63 if( reqoid == NULL || *reqoid == '\0' || msgidp == NULL ) {
64 ld->ld_errno = LDAP_PARAM_ERROR;
65 return( ld->ld_errno );
68 /* create a message to send */
69 if ( (ber = ldap_alloc_ber_with_options( ld )) == NULL ) {
70 ld->ld_errno = LDAP_NO_MEMORY;
71 return( ld->ld_errno );
74 if ( reqdata != NULL ) {
75 rc = ber_printf( ber, "{it{tstON}", /* '}' */
76 ++ld->ld_msgid, LDAP_REQ_EXTENDED,
77 LDAP_TAG_EXOP_REQ_OID, reqoid,
78 LDAP_TAG_EXOP_REQ_VALUE, reqdata );
81 rc = ber_printf( ber, "{it{tsN}", /* '}' */
82 ++ld->ld_msgid, LDAP_REQ_EXTENDED,
83 LDAP_TAG_EXOP_REQ_OID, reqoid );
87 ld->ld_errno = LDAP_ENCODING_ERROR;
89 return( ld->ld_errno );
92 /* Put Server Controls */
93 if( ldap_int_put_controls( ld, sctrls, ber ) != LDAP_SUCCESS ) {
98 if ( ber_printf( ber, /*{*/ "N}" ) == -1 ) {
99 ld->ld_errno = LDAP_ENCODING_ERROR;
101 return( ld->ld_errno );
104 /* send the message */
105 *msgidp = ldap_send_initial_request( ld, LDAP_REQ_EXTENDED, NULL, ber );
107 return( *msgidp < 0 ? ld->ld_errno : LDAP_SUCCESS );
111 ldap_extended_operation_s(
113 LDAP_CONST char *reqoid,
114 struct berval *reqdata,
115 LDAPControl **sctrls,
116 LDAPControl **cctrls,
118 struct berval **retdatap )
125 LDAP_LOG (( "extended", LDAP_LEVEL_ENTRY, "ldap_extended_operation_s\n" ));
127 Debug( LDAP_DEBUG_TRACE, "ldap_extended_operation_s\n", 0, 0, 0 );
130 assert( ld != NULL );
131 assert( LDAP_VALID( ld ) );
132 assert( reqoid != NULL || *reqoid == '\0' );
133 assert( retoidp != NULL || retdatap != NULL );
135 if( retoidp == NULL || retdatap == NULL ) {
136 ld->ld_errno = LDAP_PARAM_ERROR;
137 return( ld->ld_errno );
140 rc = ldap_extended_operation( ld, reqoid, reqdata,
141 sctrls, cctrls, &msgid );
143 if ( rc != LDAP_SUCCESS ) {
147 if ( ldap_result( ld, msgid, 1, (struct timeval *) NULL, &res ) == -1 ) {
148 return( ld->ld_errno );
154 rc = ldap_parse_extended_result( ld, res, retoidp, retdatap, 0 );
156 if( rc != LDAP_SUCCESS ) {
161 return( ldap_result2error( ld, res, 1 ) );
164 /* Parse an extended result */
166 ldap_parse_extended_result (
170 struct berval **retdatap,
177 struct berval *resdata;
181 assert( ld != NULL );
182 assert( LDAP_VALID( ld ) );
183 assert( res != NULL );
186 LDAP_LOG (( "extended", LDAP_LEVEL_ENTRY, "ldap_parse_extended_result\n" ));
188 Debug( LDAP_DEBUG_TRACE, "ldap_parse_extended_result\n", 0, 0, 0 );
191 if( ld->ld_version < LDAP_VERSION3 ) {
192 ld->ld_errno = LDAP_NOT_SUPPORTED;
196 if( res->lm_msgtype != LDAP_RES_EXTENDED ) {
197 ld->ld_errno = LDAP_PARAM_ERROR;
201 if( retoidp != NULL ) *retoidp = NULL;
202 if( retdatap != NULL ) *retdatap = NULL;
204 if ( ld->ld_error ) {
205 LDAP_FREE( ld->ld_error );
209 if ( ld->ld_matched ) {
210 LDAP_FREE( ld->ld_matched );
211 ld->ld_matched = NULL;
214 ber = ber_dup( res->lm_ber );
217 ld->ld_errno = LDAP_NO_MEMORY;
221 rc = ber_scanf( ber, "{iaa" /*}*/, &errcode,
222 &ld->ld_matched, &ld->ld_error );
224 if( rc == LBER_ERROR ) {
225 ld->ld_errno = LDAP_DECODING_ERROR;
233 tag = ber_peek_tag( ber, &len );
235 if( tag == LDAP_TAG_REFERRAL ) {
236 /* skip over referral */
237 if( ber_scanf( ber, "x" ) == LBER_ERROR ) {
238 ld->ld_errno = LDAP_DECODING_ERROR;
243 tag = ber_peek_tag( ber, &len );
246 if( tag == LDAP_TAG_EXOP_RES_OID ) {
247 /* we have a resoid */
248 if( ber_scanf( ber, "a", &resoid ) == LBER_ERROR ) {
249 ld->ld_errno = LDAP_DECODING_ERROR;
254 tag = ber_peek_tag( ber, &len );
257 if( tag == LDAP_TAG_EXOP_RES_VALUE ) {
258 /* we have a resdata */
259 if( ber_scanf( ber, "O", &resdata ) == LBER_ERROR ) {
260 ld->ld_errno = LDAP_DECODING_ERROR;
262 if( resoid != NULL ) LDAP_FREE( resoid );
269 if( retoidp != NULL ) {
275 if( retdatap != NULL ) {
278 ber_bvfree( resdata );
281 ld->ld_errno = errcode;
291 /* Parse an extended partial */
293 ldap_parse_extended_partial (
297 struct berval **retdatap,
298 LDAPControl ***serverctrls,
305 struct berval *resdata;
308 assert( ld != NULL );
309 assert( LDAP_VALID( ld ) );
310 assert( res != NULL );
313 LDAP_LOG (( "extended", LDAP_LEVEL_ENTRY,
314 "ldap_parse_extended_partial\n" ));
316 Debug( LDAP_DEBUG_TRACE, "ldap_parse_extended_partial\n", 0, 0, 0 );
319 if( ld->ld_version < LDAP_VERSION3 ) {
320 ld->ld_errno = LDAP_NOT_SUPPORTED;
324 if( res->lm_msgtype != LDAP_RES_EXTENDED_PARTIAL ) {
325 ld->ld_errno = LDAP_PARAM_ERROR;
329 if( retoidp != NULL ) *retoidp = NULL;
330 if( retdatap != NULL ) *retdatap = NULL;
332 ber = ber_dup( res->lm_ber );
335 ld->ld_errno = LDAP_NO_MEMORY;
339 rc = ber_scanf( ber, "{" /*}*/ );
341 if( rc == LBER_ERROR ) {
342 ld->ld_errno = LDAP_DECODING_ERROR;
350 tag = ber_peek_tag( ber, &len );
352 if( tag == LDAP_TAG_EXOP_RES_OID ) {
353 /* we have a resoid */
354 if( ber_scanf( ber, "a", &resoid ) == LBER_ERROR ) {
355 ld->ld_errno = LDAP_DECODING_ERROR;
360 tag = ber_peek_tag( ber, &len );
363 if( tag == LDAP_TAG_EXOP_RES_VALUE ) {
364 /* we have a resdata */
365 if( ber_scanf( ber, "O", &resdata ) == LBER_ERROR ) {
366 ld->ld_errno = LDAP_DECODING_ERROR;
368 if( resoid != NULL ) LDAP_FREE( resoid );
373 if ( serverctrls == NULL ) {
375 goto free_and_return;
378 if ( ber_scanf( ber, /*{*/ "}" ) == LBER_ERROR ) {
379 rc = LDAP_DECODING_ERROR;
380 goto free_and_return;
383 rc = ldap_int_get_controls( ber, serverctrls );
388 if( retoidp != NULL ) {
394 if( retdatap != NULL ) {
397 ber_bvfree( resdata );