X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;f=servers%2Fslapd%2Fabandon.c;h=3069ed7452d25de19f04a6aa593c999a3d86afff;hb=f90ed5aef8f41ee90e1f67b0badbb793cb99f3ed;hp=d0eb0244e89e186051e2d3a69b0891d5bd53ea47;hpb=00086db3f611e5be46e1c4840a68d1a9ce11299f;p=openldap diff --git a/servers/slapd/abandon.c b/servers/slapd/abandon.c index d0eb0244e8..3069ed7452 100644 --- a/servers/slapd/abandon.c +++ b/servers/slapd/abandon.c @@ -28,7 +28,7 @@ do_abandon( ber_int_t id; Operation *o; Operation **oo; - int rc; + int rc, notfound; Debug( LDAP_DEBUG_TRACE, "do_abandon\n", 0, 0, 0 ); @@ -40,7 +40,9 @@ do_abandon( if ( ber_scanf( op->o_ber, "i", &id ) == LBER_ERROR ) { Debug( LDAP_DEBUG_ANY, "do_abandon: ber_scanf failed\n", 0, 0 ,0 ); - return LDAP_PROTOCOL_ERROR; + send_ldap_disconnect( conn, op, + LDAP_PROTOCOL_ERROR, "decoding error" ); + return -1; } if( (rc = get_ctrls( conn, op, 0 )) != LDAP_SUCCESS ) { @@ -50,21 +52,28 @@ do_abandon( Debug( LDAP_DEBUG_ARGS, "do_abandon: id %d\n", id, 0 ,0 ); + if( id <= 0 ) { + Debug( LDAP_DEBUG_ANY, + "do_abandon: bad msgid %ld\n", (long) id, 0, 0 ); + return LDAP_SUCCESS; + } + + notfound = 1; /* not found */ + ldap_pvt_thread_mutex_lock( &conn->c_mutex ); /* * find the operation being abandoned and set the o_abandon * flag. It's up to the backend to periodically check this * flag and abort the operation at a convenient time. */ - ldap_pvt_thread_mutex_lock( &conn->c_mutex ); - for ( o = conn->c_ops; o != NULL; o = o->o_next ) { if ( o->o_msgid == id ) { ldap_pvt_thread_mutex_lock( &o->o_abandonmutex ); o->o_abandon = 1; ldap_pvt_thread_mutex_unlock( &o->o_abandonmutex ); - goto found_it; + notfound = 0; + goto done; } } @@ -79,13 +88,14 @@ do_abandon( o = *oo; *oo = (*oo)->o_next; slap_op_free( o ); - - goto found_it; + notfound = 0; } - Debug( LDAP_DEBUG_TRACE, "do_abandon: op not found\n", 0, 0, 0 ); - -found_it: +done: ldap_pvt_thread_mutex_unlock( &conn->c_mutex ); + + Debug( LDAP_DEBUG_TRACE, "do_abandon: op=%ld %sfound\n", + id, notfound ? "not " : "", 0 ); + return LDAP_SUCCESS; }