Author: rhs
Date: Thu Mar 22 14:59:57 2012
New Revision: 1303824
URL: http://svn.apache.org/viewvc?rev=1303824&view=rev
Log:
initialize next incoming id as supplied in begin
Modified:
qpid/proton/trunk/proton-c/src/engine/engine.c
Modified: qpid/proton/trunk/proton-c/src/engine/engine.c
URL:
http://svn.apache.org/viewvc/qpid/proton/trunk/proton-c/src/engine/engine.c?rev=1303824&r1=1303823&r2=1303824&view=diff
==============================================================================
--- qpid/proton/trunk/proton-c/src/engine/engine.c (original)
+++ qpid/proton/trunk/proton-c/src/engine/engine.c Thu Mar 22 14:59:57 2012
@@ -972,6 +972,7 @@ void pn_do_begin(pn_dispatcher_t *disp)
{
pn_transport_t *transport = disp->context;
pn_value_t remote_channel = pn_list_get(disp->args, BEGIN_REMOTE_CHANNEL);
+ pn_sequence_t next = pn_to_uint32(pn_list_get(disp->args,
BEGIN_NEXT_OUTGOING_ID));
pn_session_state_t *state;
if (remote_channel.type == USHORT) {
// XXX: what if session is NULL?
@@ -980,6 +981,7 @@ void pn_do_begin(pn_dispatcher_t *disp)
pn_session_t *ssn = pn_session(transport->connection);
state = pn_session_get_state(transport, ssn);
}
+ state->incoming.next = next;
pn_map_channel(transport, disp->channel, state);
PN_SET_REMOTE(state->session->endpoint.state, PN_REMOTE_ACTIVE);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
