Diff for /libraries/libldap/result.c between versions 1.99.2.12 and 1.126

version 1.99.2.12, 2005/11/15 20:25:46 version 1.126, 2006/04/24 15:20:13
Line 1 Line 1
 /* result.c - wait for an ldap result */  /* result.c - wait for an ldap result */
 /* $OpenLDAP: pkg/ldap/libraries/libldap/result.c,v 1.120 2005/11/14 20:47:17 ando Exp $ */  /* $OpenLDAP: pkg/ldap/libraries/libldap/result.c,v 1.125 2006/04/08 09:01:19 ando Exp $ */
 /* This work is part of OpenLDAP Software <http://www.openldap.org/>.  /* This work is part of OpenLDAP Software <http://www.openldap.org/>.
  *   *
  * Copyright 1998-2005 The OpenLDAP Foundation.   * Copyright 1998-2006 The OpenLDAP Foundation.
  * All rights reserved.   * All rights reserved.
  *   *
  * Redistribution and use in source and binary forms, with or without   * Redistribution and use in source and binary forms, with or without
Line 73  static int ldap_mark_abandoned LDAP_P(( Line 73  static int ldap_mark_abandoned LDAP_P((
 static int wait4msg LDAP_P(( LDAP *ld, ber_int_t msgid, int all, struct timeval *timeout,  static int wait4msg LDAP_P(( LDAP *ld, ber_int_t msgid, int all, struct timeval *timeout,
         LDAPMessage **result ));          LDAPMessage **result ));
 static ber_tag_t try_read1msg LDAP_P(( LDAP *ld, ber_int_t msgid,  static ber_tag_t try_read1msg LDAP_P(( LDAP *ld, ber_int_t msgid,
         int all, Sockbuf *sb, LDAPConn **lc, LDAPMessage **result ));          int all, LDAPConn **lc, LDAPMessage **result ));
 static ber_tag_t build_result_ber LDAP_P(( LDAP *ld, BerElement **bp, LDAPRequest *lr ));  static ber_tag_t build_result_ber LDAP_P(( LDAP *ld, BerElement **bp, LDAPRequest *lr ));
 static void merge_error_info LDAP_P(( LDAP *ld, LDAPRequest *parentr, LDAPRequest *lr ));  static void merge_error_info LDAP_P(( LDAP *ld, LDAPRequest *parentr, LDAPRequest *lr ));
 static LDAPMessage * chkResponseList LDAP_P(( LDAP *ld, int msgid, int all));  static LDAPMessage * chkResponseList LDAP_P(( LDAP *ld, int msgid, int all));
   
   #define LDAP_MSG_X_KEEP_LOOKING         (-2)
   
   
 /*  /*
  * ldap_result - wait for an ldap result response to a message from the   * ldap_result - wait for an ldap result response to a message from the
Line 138  chkResponseList( Line 140  chkResponseList(
         int all)          int all)
 {  {
         LDAPMessage     *lm, **lastlm, *nextlm;          LDAPMessage     *lm, **lastlm, *nextlm;
     /*  
           /*
          * Look through the list of responses we have received on           * Look through the list of responses we have received on
          * this association and see if the response we're interested in           * this association and see if the response we're interested in
          * is there.  If it is, return it.  If not, call wait4msg() to           * is there.  If it is, return it.  If not, call wait4msg() to
          * wait until it arrives or timeout occurs.           * wait until it arrives or timeout occurs.
          */           */
   
   #ifdef LDAP_R_COMPILE
           LDAP_PVT_THREAD_ASSERT_MUTEX_OWNER( &ld->ld_res_mutex );
   #endif
   
         Debug( LDAP_DEBUG_TRACE,          Debug( LDAP_DEBUG_TRACE,
                 "ldap_chkResponseList ld %p msgid %d all %d\n",                  "ldap_chkResponseList ld %p msgid %d all %d\n",
                 (void *)ld, msgid, all );                  (void *)ld, msgid, all );
   
         lastlm = &ld->ld_responses;          lastlm = &ld->ld_responses;
         for ( lm = ld->ld_responses; lm != NULL; lm = nextlm ) {          for ( lm = ld->ld_responses; lm != NULL; lm = nextlm ) {
                 nextlm = lm->lm_next;                  nextlm = lm->lm_next;
Line 236  wait4msg( Line 244  wait4msg(
         assert( ld != NULL );          assert( ld != NULL );
         assert( result != NULL );          assert( result != NULL );
   
   #ifdef LDAP_R_COMPILE
           LDAP_PVT_THREAD_ASSERT_MUTEX_OWNER( &ld->ld_res_mutex );
   #endif
   
 #ifdef LDAP_DEBUG  #ifdef LDAP_DEBUG
         if ( timeout == NULL ) {          if ( timeout == NULL ) {
                 Debug( LDAP_DEBUG_TRACE, "wait4msg ld %p msgid %d (infinite timeout)\n",                  Debug( LDAP_DEBUG_TRACE, "wait4msg ld %p msgid %d (infinite timeout)\n",
Line 255  wait4msg( Line 267  wait4msg(
                 start_time = time( NULL );                  start_time = time( NULL );
         }          }
                                           
         rc = -2;          rc = LDAP_MSG_X_KEEP_LOOKING;
         while ( rc == -2 ) {          while ( rc == LDAP_MSG_X_KEEP_LOOKING ) {
 #ifdef LDAP_DEBUG  #ifdef LDAP_DEBUG
                 if ( ldap_debug & LDAP_DEBUG_TRACE ) {                  if ( ldap_debug & LDAP_DEBUG_TRACE ) {
                         Debug( LDAP_DEBUG_TRACE, "wait4msg continue ld %p msgid %d all %d\n",                          Debug( LDAP_DEBUG_TRACE, "wait4msg continue ld %p msgid %d all %d\n",
Line 282  wait4msg( Line 294  wait4msg(
 #ifdef LDAP_R_COMPILE  #ifdef LDAP_R_COMPILE
                                         ldap_pvt_thread_mutex_unlock( &ld->ld_conn_mutex );                                          ldap_pvt_thread_mutex_unlock( &ld->ld_conn_mutex );
 #endif  #endif
                                         rc = try_read1msg( ld, msgid, all, lc->lconn_sb,                                          rc = try_read1msg( ld, msgid, all, &lc, result );
                                                 &lc, result );  
 #ifdef LDAP_R_COMPILE  #ifdef LDAP_R_COMPILE
                                         ldap_pvt_thread_mutex_lock( &ld->ld_conn_mutex );                                          ldap_pvt_thread_mutex_lock( &ld->ld_conn_mutex );
 #endif  #endif
Line 315  wait4msg( Line 326  wait4msg(
                                 }                                  }
   
                                 if ( rc == -1 ) {                                  if ( rc == -1 ) {
                                         rc = -2;        /* select interrupted: loop */                                          rc = LDAP_MSG_X_KEEP_LOOKING;   /* select interrupted: loop */
                                 } else {                                  } else {
                                         rc = -2;                                          rc = LDAP_MSG_X_KEEP_LOOKING;
 #ifdef LDAP_R_COMPILE  #ifdef LDAP_R_COMPILE
                                         ldap_pvt_thread_mutex_lock( &ld->ld_req_mutex );                                          ldap_pvt_thread_mutex_lock( &ld->ld_req_mutex );
 #endif  #endif
Line 332  wait4msg( Line 343  wait4msg(
                                         ldap_pvt_thread_mutex_unlock( &ld->ld_req_mutex );                                          ldap_pvt_thread_mutex_unlock( &ld->ld_req_mutex );
                                         ldap_pvt_thread_mutex_lock( &ld->ld_conn_mutex );                                          ldap_pvt_thread_mutex_lock( &ld->ld_conn_mutex );
 #endif  #endif
                                         for ( lc = ld->ld_conns; rc == -2 && lc != NULL;                                          for ( lc = ld->ld_conns; rc == LDAP_MSG_X_KEEP_LOOKING && lc != NULL;
                                                 lc = nextlc )                                                  lc = nextlc )
                                         {                                          {
                                                 nextlc = lc->lconn_next;                                                  nextlc = lc->lconn_next;
Line 342  wait4msg( Line 353  wait4msg(
 #ifdef LDAP_R_COMPILE  #ifdef LDAP_R_COMPILE
                                                         ldap_pvt_thread_mutex_unlock( &ld->ld_conn_mutex );                                                          ldap_pvt_thread_mutex_unlock( &ld->ld_conn_mutex );
 #endif  #endif
                                                         rc = try_read1msg( ld, msgid, all,                                                          rc = try_read1msg( ld, msgid, all, &lc, result );
                                                                 lc->lconn_sb, &lc, result );  
                                                                 if ( lc == NULL ) lc = nextlc;                                                                  if ( lc == NULL ) lc = nextlc;
 #ifdef LDAP_R_COMPILE  #ifdef LDAP_R_COMPILE
                                                         ldap_pvt_thread_mutex_lock( &ld->ld_conn_mutex );                                                          ldap_pvt_thread_mutex_lock( &ld->ld_conn_mutex );
Line 357  wait4msg( Line 367  wait4msg(
                         }                          }
                 }                  }
   
                 if ( rc == -2 && tvp != NULL ) {                  if ( rc == LDAP_MSG_X_KEEP_LOOKING && tvp != NULL ) {
                         tmp_time = time( NULL );                          tmp_time = time( NULL );
                         tv0.tv_sec -= ( tmp_time - start_time );                          tv0.tv_sec -= ( tmp_time - start_time );
                         if ( tv0.tv_sec <= 0 ) {                          if ( tv0.tv_sec <= 0 ) {
Line 382  try_read1msg( Line 392  try_read1msg(
         LDAP *ld,          LDAP *ld,
         ber_int_t msgid,          ber_int_t msgid,
         int all,          int all,
         Sockbuf *sb,  
         LDAPConn **lcp,          LDAPConn **lcp,
         LDAPMessage **result )          LDAPMessage **result )
 {  {
Line 417  try_read1msg( Line 426  try_read1msg(
         assert( lcp != NULL );          assert( lcp != NULL );
         assert( *lcp != NULL );          assert( *lcp != NULL );
                   
   #ifdef LDAP_R_COMPILE
           LDAP_PVT_THREAD_ASSERT_MUTEX_OWNER( &ld->ld_res_mutex );
   #endif
   
         Debug( LDAP_DEBUG_TRACE, "read1msg: ld %p msgid %d all %d\n",          Debug( LDAP_DEBUG_TRACE, "read1msg: ld %p msgid %d all %d\n",
                 (void *)ld, msgid, all );                  (void *)ld, msgid, all );
   
Line 439  retry: Line 452  retry:
 #ifdef LDAP_CONNECTIONLESS  #ifdef LDAP_CONNECTIONLESS
         if ( LDAP_IS_UDP(ld) ) {          if ( LDAP_IS_UDP(ld) ) {
                 struct sockaddr from;                  struct sockaddr from;
                 ber_int_sb_read(sb, &from, sizeof(struct sockaddr));                  ber_int_sb_read( lc->lconn_sb, &from, sizeof(struct sockaddr) );
                 if (ld->ld_options.ldo_version == LDAP_VERSION2) isv2=1;                  if (ld->ld_options.ldo_version == LDAP_VERSION2) isv2=1;
         }          }
 nextresp3:  nextresp3:
 #endif  #endif
         tag = ber_get_next( sb, &len, ber );          tag = ber_get_next( lc->lconn_sb, &len, ber );
         if ( tag == LDAP_TAG_MESSAGE ) {          switch ( tag ) {
           case LDAP_TAG_MESSAGE:
                 /*                  /*
                  * We read a complete message.                   * We read a complete message.
                  * The connection should no longer need this ber.                   * The connection should no longer need this ber.
                  */                   */
                 lc->lconn_ber = NULL;                  lc->lconn_ber = NULL;
         }                  break;
         if ( tag != LDAP_TAG_MESSAGE ) {  
                 if ( tag == LBER_DEFAULT) {          case LBER_DEFAULT:
 #ifdef LDAP_DEBUG                    #ifdef LDAP_DEBUG                  
                         Debug( LDAP_DEBUG_CONNS,                  Debug( LDAP_DEBUG_CONNS,
                                 "ber_get_next failed.\n", 0, 0, 0 );                          "ber_get_next failed.\n", 0, 0, 0 );
 #endif               #endif             
 #ifdef EWOULDBLOCK                        #ifdef EWOULDBLOCK                      
                         if (errno==EWOULDBLOCK) return -2;                  if ( errno == EWOULDBLOCK ) return LDAP_MSG_X_KEEP_LOOKING;
 #endif  #endif
 #ifdef EAGAIN  #ifdef EAGAIN
                         if (errno == EAGAIN) return -2;                  if ( errno == EAGAIN ) return LDAP_MSG_X_KEEP_LOOKING;
 #endif  #endif
                         ld->ld_errno = LDAP_SERVER_DOWN;                  ld->ld_errno = LDAP_SERVER_DOWN;
                         return -1;                  return -1;
                 }  
           default:
                 ld->ld_errno = LDAP_LOCAL_ERROR;                  ld->ld_errno = LDAP_LOCAL_ERROR;
                 return -1;                  return -1;
         }          }
Line 484  nextresp3: Line 499  nextresp3:
                         (void *)ld, (long) id, 0);                          (void *)ld, (long) id, 0);
 retry_ber:  retry_ber:
                 ber_free( ber, 1 );                  ber_free( ber, 1 );
                 if ( ber_sockbuf_ctrl( sb, LBER_SB_OPT_DATA_READY, NULL ) ) {                  if ( ber_sockbuf_ctrl( lc->lconn_sb, LBER_SB_OPT_DATA_READY, NULL ) ) {
                         goto retry;                          goto retry;
                 }                  }
                 return( -2 );   /* continue looking */                  return( LDAP_MSG_X_KEEP_LOOKING );      /* continue looking */
         }          }
   
         lr = ldap_find_request_by_msgid( ld, id );          lr = ldap_find_request_by_msgid( ld, id );
Line 517  nextresp2: Line 532  nextresp2:
         id = lr->lr_origid;          id = lr->lr_origid;
         refer_cnt = 0;          refer_cnt = 0;
         hadref = simple_request = 0;          hadref = simple_request = 0;
         rc = -2;        /* default is to keep looking (no response found) */          rc = LDAP_MSG_X_KEEP_LOOKING;   /* default is to keep looking (no response found) */
         lr->lr_res_msgtype = tag;          lr->lr_res_msgtype = tag;
   
         /*          /*
Line 566  nextresp2: Line 581  nextresp2:
                         ber_len_t       len;                          ber_len_t       len;
                         char            *lr_res_error = NULL;                          char            *lr_res_error = NULL;
   
 #ifdef LDAP_NULL_IS_NULL  
                         if ( ber_scanf( &tmpber, "{eAA",/*}*/ &lderr,                          if ( ber_scanf( &tmpber, "{eAA",/*}*/ &lderr,
                                     &lr->lr_res_matched, &lr_res_error )                                      &lr->lr_res_matched, &lr_res_error )
                                     != LBER_ERROR )                                      != LBER_ERROR )
 #else /* ! LDAP_NULL_IS_NULL */  
                         if ( ber_scanf( &tmpber, "{eaa",/*}*/ &lderr,  
                                     &lr->lr_res_matched, &lr_res_error )  
                                     != LBER_ERROR )  
 #endif /* ! LDAP_NULL_IS_NULL */  
                         {                          {
                                 if ( lr_res_error != NULL ) {                                  if ( lr_res_error != NULL ) {
 #ifndef LDAP_NULL_IS_NULL  
                                         if ( lr_res_error[ 0 ] == '\0' ) {  
                                                 LDAP_FREE( lr_res_error );  
                                                 lr_res_error = NULL;  
                                         } else  
 #endif /* ! LDAP_NULL_IS_NULL */  
                                         {                                          {
                                                 if ( lr->lr_res_error != NULL ) {                                                  if ( lr->lr_res_error != NULL ) {
                                                         (void)ldap_append_referral( ld, &lr->lr_res_error, lr_res_error );                                                          (void)ldap_append_referral( ld, &lr->lr_res_error, lr_res_error );
Line 665  nextresp2: Line 668  nextresp2:
                                  */                                   */
                                 if ( tag == LDAP_RES_SEARCH_RESULT )                                  if ( tag == LDAP_RES_SEARCH_RESULT )
                                         refer_cnt = 0;                                          refer_cnt = 0;
 #ifdef LDAP_NULL_IS_NULL  
                         } else if ( ber_scanf( &tmpber, "{eAA}", &lderr,                          } else if ( ber_scanf( &tmpber, "{eAA}", &lderr,
                                 &lr->lr_res_matched, &lr_res_error )                                  &lr->lr_res_matched, &lr_res_error )
                                 != LBER_ERROR )                                  != LBER_ERROR )
 #else /* ! LDAP_NULL_IS_NULL */  
                         } else if ( ber_scanf( &tmpber, "{eaa}", &lderr,  
                                 &lr->lr_res_matched, &lr_res_error )  
                                 != LBER_ERROR )  
 #endif /* ! LDAP_NULL_IS_NULL */  
                         {                          {
                                 if ( lr_res_error != NULL ) {                                  if ( lr_res_error != NULL ) {
 #ifndef LDAP_NULL_IS_NULL  
                                         if ( lr_res_error[ 0 ] == '\0' ) {  
                                                 LDAP_FREE( lr_res_error );  
                                         } else  
 #endif /* ! LDAP_NULL_IS_NULL */  
                                         {                                          {
                                                 if ( lr->lr_res_error != NULL ) {                                                  if ( lr->lr_res_error != NULL ) {
                                                         (void)ldap_append_referral( ld, &lr->lr_res_error, lr_res_error );                                                          (void)ldap_append_referral( ld, &lr->lr_res_error, lr_res_error );
Line 803  lr->lr_res_matched ? lr->lr_res_matched Line 795  lr->lr_res_matched ? lr->lr_res_matched
                                         ber_free( ber, 1 );                                          ber_free( ber, 1 );
                                         ber = NULL;                                          ber = NULL;
                                         if ( build_result_ber( ld, &ber, lr )                                          if ( build_result_ber( ld, &ber, lr )
                                             == LBER_ERROR ) {                                              == LBER_ERROR )
                                           {
                                                 rc = -1; /* fatal error */                                                  rc = -1; /* fatal error */
                                         }                                          }
                                 }                                  }
Line 825  lr->lr_res_matched ? lr->lr_res_matched Line 818  lr->lr_res_matched ? lr->lr_res_matched
 #ifdef LDAP_R_COMPILE  #ifdef LDAP_R_COMPILE
                                 ldap_pvt_thread_mutex_unlock( &ld->ld_req_mutex );                                  ldap_pvt_thread_mutex_unlock( &ld->ld_req_mutex );
 #endif  #endif
                                 *lcp = NULL;                                  lc = *lcp = NULL;
                         }                          }
                 }                  }
         }          }
Line 886  lr->lr_res_matched ? lr->lr_res_matched Line 879  lr->lr_res_matched ? lr->lr_res_matched
                                  * datagram, if the sockbuf is readable we still have data                                   * datagram, if the sockbuf is readable we still have data
                                  * to parse.                                   * to parse.
                                  */                                   */
                                 ber = ldap_alloc_ber_with_options(ld);                                  ber = ldap_alloc_ber_with_options( ld );
                                 if (ber_sockbuf_ctrl(sb, LBER_SB_OPT_DATA_READY, NULL)) ok=1;                                  if ( ber_sockbuf_ctrl( lc->lconn_sb, LBER_SB_OPT_DATA_READY, NULL ) ) ok = 1;
                         }                          }
                         /* set up response chain */                          /* set up response chain */
                         if ( tmp == NULL ) {                          if ( tmp == NULL ) {
Line 986  exit: Line 979  exit:
                 ld->ld_errno = LDAP_SUCCESS;                  ld->ld_errno = LDAP_SUCCESS;
                 return( tag );                  return( tag );
         }          }
         if ( ber_sockbuf_ctrl( sb, LBER_SB_OPT_DATA_READY, NULL ) ) {          if ( lc && ber_sockbuf_ctrl( lc->lconn_sb, LBER_SB_OPT_DATA_READY, NULL ) ) {
                 goto retry;                  goto retry;
         }          }
         return( -2 );   /* continue looking */          return( LDAP_MSG_X_KEEP_LOOKING );      /* continue looking */
 }  }
   
   
Line 1183  ldap_msgdelete( LDAP *ld, int msgid ) Line 1176  ldap_msgdelete( LDAP *ld, int msgid )
   
   
 /*  /*
    * ldap_abandoned
    *
  * return 1 if message msgid is waiting to be abandoned, 0 otherwise   * return 1 if message msgid is waiting to be abandoned, 0 otherwise
    *
    * expects ld_res_mutex to be locked
  */   */
 static int  static int
 ldap_abandoned( LDAP *ld, ber_int_t msgid )  ldap_abandoned( LDAP *ld, ber_int_t msgid )
 {  {
         int     i;          int     i;
   
   #ifdef LDAP_R_COMPILE
           LDAP_PVT_THREAD_ASSERT_MUTEX_OWNER( &ld->ld_res_mutex );
   #endif
   
         if ( ld->ld_abandoned == NULL )          if ( ld->ld_abandoned == NULL )
                 return( 0 );                  return( 0 );
   
Line 1201  ldap_abandoned( LDAP *ld, ber_int_t msgi Line 1202  ldap_abandoned( LDAP *ld, ber_int_t msgi
 }  }
   
   
   /*
    * ldap_mark_abandoned
    *
    * expects ld_res_mutex to be locked
    */
 static int  static int
 ldap_mark_abandoned( LDAP *ld, ber_int_t msgid )  ldap_mark_abandoned( LDAP *ld, ber_int_t msgid )
 {  {
         int     i;          int     i;
   
   #ifdef LDAP_R_COMPILE
           LDAP_PVT_THREAD_ASSERT_MUTEX_OWNER( &ld->ld_res_mutex );
   #endif
   
         if ( ld->ld_abandoned == NULL )          if ( ld->ld_abandoned == NULL )
                 return( -1 );                  return( -1 );
   

Removed from v.1.99.2.12  
changed lines
  Added in v.1.126


______________
© Copyright 1998-2020, OpenLDAP Foundation, info@OpenLDAP.org