upstream/openldap
1
0
Fork 0
mirror of https://git.openldap.org/openldap/openldap.git synced 2025-12-20 22:59:34 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

ITS#10266 Adopt broader RFC4511 NoD interpretation, receiving side

Browse source
This commit is contained in:
Ondřej Kuzník 2024-08-14 10:55:29 +01:00 committed by Quanah Gibson-Mount
parent 89e34fded3
commit e101d0ecc1
1 changed files with 23 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
servers/lloadd/upstream.c
View file

@ -138,6 +138,8 @@ forward_final_response(
static int static int
handle_unsolicited( LloadConnection *c, BerElement *ber ) handle_unsolicited( LloadConnection *c, BerElement *ber )
{ {
TAvlnode *node;
CONNECTION_ASSERT_LOCKED(c); CONNECTION_ASSERT_LOCKED(c);
assert( c->c_state != LLOAD_C_INVALID ); assert( c->c_state != LLOAD_C_INVALID );
@ -151,10 +153,30 @@ handle_unsolicited( LloadConnection *c, BerElement *ber )
"teardown for upstream connection connid=%lu\n", "teardown for upstream connection connid=%lu\n",
c->c_connid ); c->c_connid );
CONNECTION_DESTROY(c); while ( c->c_ops ) {
TAvlnode *node = ldap_tavl_end( c->c_ops, TAVL_DIR_LEFT );
LloadOperation *op = node->avl_data;
/* Close operations that the upstream is not tracking, we don't get a
* response for those. */
if ( op->o_client_msgid || op->o_upstream_msgid ) {
assert( op->o_upstream_msgid != 0 );
break;
}
CONNECTION_UNLOCK(c);
OPERATION_UNLINK(op);
CONNECTION_LOCK(c);
};
out: out:
ber_free( ber, 1 ); ber_free( ber, 1 );
if ( c->c_state == LLOAD_C_CLOSING && c->c_ops ) {
CONNECTION_UNLOCK(c);
return 0;
}
CONNECTION_DESTROY(c);
return -1; return -1;
} }