Diff for /libraries/libldap/result.c between versions 1.99.2.17 and 1.124.2.1

version 1.99.2.17, 2006/08/18 15:14:38 version 1.124.2.1, 2006/04/11 16:07:16
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.99.2.16 2006/08/17 02:43:58 kurt 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-2006 The OpenLDAP Foundation.   * Copyright 1998-2006 The OpenLDAP Foundation.
Line 140  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 233  wait4msg( Line 239  wait4msg(
                         *tvp;                          *tvp;
         time_t          start_time = 0;          time_t          start_time = 0;
         time_t          tmp_time;          time_t          tmp_time;
         LDAPConn        *lc;          LDAPConn        *lc, *nextlc;
   
         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 277  wait4msg( Line 287  wait4msg(
 #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
                         for ( lc = ld->ld_conns; lc != NULL; lc = lc->lconn_next ) {                          for ( lc = ld->ld_conns; lc != NULL; lc = nextlc ) {
                                   nextlc = lc->lconn_next;
                                 if ( ber_sockbuf_ctrl( lc->lconn_sb,                                  if ( ber_sockbuf_ctrl( lc->lconn_sb,
                                                 LBER_SB_OPT_DATA_READY, NULL ) ) {                                                  LBER_SB_OPT_DATA_READY, NULL ) ) {
 #ifdef LDAP_R_COMPILE  #ifdef LDAP_R_COMPILE
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;                                          for ( lc = ld->ld_conns; rc == LDAP_MSG_X_KEEP_LOOKING && lc != NULL;
                                                 rc == LDAP_MSG_X_KEEP_LOOKING && lc != NULL; )                                                  lc = nextlc )
                                         {                                          {
                                                   nextlc = lc->lconn_next;
                                                 if ( lc->lconn_status == LDAP_CONNST_CONNECTED &&                                                  if ( lc->lconn_status == LDAP_CONNST_CONNECTED &&
                                                         ldap_is_read_ready( ld, lc->lconn_sb ))                                                          ldap_is_read_ready( ld, lc->lconn_sb ))
                                                 {                                                  {
Line 342  wait4msg( Line 354  wait4msg(
                                                         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, result );                                                          rc = try_read1msg( ld, msgid, all, &lc, result );
                                                                   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 );
 #endif  #endif
                                                         if ( lc == NULL ) {  
                                                                 /* if lc gets free()'d,  
                                                                  * there's no guarantee  
                                                                  * lc->lconn_next is still  
                                                                  * sane; better restart  
                                                                  * (ITS#4405) */  
                                                                 lc = ld->ld_conns;  
   
                                                                 /* don't get to next conn! */  
                                                                 break;  
                                                         }  
                                                 }                                                  }
   
                                                 /* next conn */  
                                                 lc = lc->lconn_next;  
                                         }                                          }
 #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 );
Line 427  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 576  nextresp2: Line 579  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 675  nextresp2: Line 666  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 1193  ldap_msgdelete( LDAP *ld, int msgid ) Line 1173  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 1211  ldap_abandoned( LDAP *ld, ber_int_t msgi Line 1199  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.17  
changed lines
  Added in v.1.124.2.1


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