Diff for /libraries/libldap/result.c between versions 1.115 and 1.116

version 1.115, 2005/10/08 16:51:15 version 1.116, 2005/10/11 22:05:43
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.114 2005/09/10 17:00:15 ando Exp $ */  /* $OpenLDAP: pkg/ldap/libraries/libldap/result.c,v 1.115 2005/10/08 16:51:15 hyc 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-2005 The OpenLDAP Foundation.
Line 272  wait4msg( Line 272  wait4msg(
                 } else {                  } else {
                         int lc_ready = 0;                          int lc_ready = 0;
   
   #ifdef LDAP_R_COMPILE
                           ldap_pvt_thread_mutex_lock( &ld->ld_conn_mutex );
   #endif
                         for ( lc = ld->ld_conns; lc != NULL; lc = nextlc ) {                          for ( lc = ld->ld_conns; lc != NULL; lc = nextlc ) {
                                 nextlc = lc->lconn_next;                                  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
                                           ldap_pvt_thread_mutex_unlock( &ld->ld_conn_mutex );
   #endif
                                         rc = try_read1msg( ld, msgid, all, lc->lconn_sb,                                          rc = try_read1msg( ld, msgid, all, lc->lconn_sb,
                                                 &lc, result );                                                  &lc, result );
   #ifdef LDAP_R_COMPILE
                                           ldap_pvt_thread_mutex_lock( &ld->ld_conn_mutex );
   #endif
                                         lc_ready = 1;                                          lc_ready = 1;
                                         break;                                          break;
                                 }                                  }
                         }                          }
   #ifdef LDAP_R_COMPILE
                           ldap_pvt_thread_mutex_unlock( &ld->ld_conn_mutex );
   #endif
   
                         if ( !lc_ready ) {                          if ( !lc_ready ) {
                                 rc = ldap_int_select( ld, tvp );                                  rc = ldap_int_select( ld, tvp );
Line 318  wait4msg( Line 330  wait4msg(
                                         }                                          }
 #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 );
                                           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 == -2 && lc != NULL;
                                                 lc = nextlc )                                                  lc = nextlc )
Line 326  wait4msg( Line 339  wait4msg(
                                                 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 ))
                                                 {                                                  {
   #ifdef LDAP_R_COMPILE
                                                           ldap_pvt_thread_mutex_unlock( &ld->ld_conn_mutex );
   #endif
                                                         rc = try_read1msg( ld, msgid, all,                                                          rc = try_read1msg( ld, msgid, all,
                                                                 lc->lconn_sb, &lc, result );                                                                  lc->lconn_sb, &lc, result );
                                                                 if ( lc == NULL ) lc = nextlc;                                                                  if ( lc == NULL ) lc = nextlc;
   #ifdef LDAP_R_COMPILE
                                                           ldap_pvt_thread_mutex_lock( &ld->ld_conn_mutex );
   #endif
                                                 }                                                  }
                                         }                                          }
   #ifdef LDAP_R_COMPILE
                                           ldap_pvt_thread_mutex_unlock( &ld->ld_conn_mutex );
   #endif
                                 }                                  }
                         }                          }
                 }                  }

Removed from v.1.115  
changed lines
  Added in v.1.116


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