Skip to content

Commit

Permalink
Fixes skupperproject#1249: allow the outbound dispatch link to accept…
Browse files Browse the repository at this point in the history
… streaming messages (skupperproject#1252)
  • Loading branch information
kgiusti authored Oct 9, 2023
1 parent 11562ee commit 3d81fb8
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/adaptors/tcp_lite/tcp_lite.c
Original file line number Diff line number Diff line change
Expand Up @@ -268,6 +268,7 @@ static void TL_setup_connector(tcplite_connector_t *cr)
vflow_add_rate(cr->common.vflow, VFLOW_ATTRIBUTE_FLOW_COUNT_L4, VFLOW_ATTRIBUTE_FLOW_RATE_L4);

cr->out_link = qdr_link_first_attach(cr->common.core_conn, QD_OUTGOING, source, 0, "tcp.connector.out", 0, false, 0, &cr->link_id);
qdr_link_set_user_streaming(cr->out_link);
qdr_link_set_context(cr->out_link, cr);
qdr_link_flow(tcplite_context->core, cr->out_link, 5, false);
}
Expand Down Expand Up @@ -963,7 +964,6 @@ static void handle_first_outbound_delivery_CSIDE(tcplite_connector_t *cr, qdr_li
conn->listener_side = false;
conn->state = CSIDE_RAW_CONNECTION_OPENING;
conn->outbound_delivery = delivery;
conn->outbound_link = link;
conn->outbound_stream = qdr_delivery_message(delivery);

conn->common.vflow = vflow_start_record(VFLOW_RECORD_FLOW, cr->common.vflow);
Expand Down

0 comments on commit 3d81fb8

Please sign in to comment.