diff --git a/aeron-driver/src/main/c/aeron_flow_control.c b/aeron-driver/src/main/c/aeron_flow_control.c index 5246386f2d..47e6441a55 100644 --- a/aeron-driver/src/main/c/aeron_flow_control.c +++ b/aeron-driver/src/main/c/aeron_flow_control.c @@ -122,7 +122,7 @@ int aeron_max_multicast_flow_control_strategy_supplier( int32_t stream_id, int64_t registration_id, int32_t initial_term_id, - size_t term_buffer_capacity) + size_t term_length) { aeron_flow_control_strategy_t *_strategy; @@ -154,8 +154,8 @@ int aeron_unicast_flow_control_strategy_supplier( int32_t stream_id, int64_t registration_id, int32_t initial_term_id, - size_t term_buffer_capacity) + size_t term_length) { return aeron_max_multicast_flow_control_strategy_supplier( - strategy, channel_length, channel, stream_id, registration_id, initial_term_id, term_buffer_capacity); + strategy, channel_length, channel, stream_id, registration_id, initial_term_id, term_length); } diff --git a/aeron-driver/src/main/c/aeronmd.h b/aeron-driver/src/main/c/aeronmd.h index c7511d7e9b..3e55bcd105 100644 --- a/aeron-driver/src/main/c/aeronmd.h +++ b/aeron-driver/src/main/c/aeronmd.h @@ -249,7 +249,7 @@ typedef int (*aeron_flow_control_strategy_supplier_func_t)( int32_t stream_id, int64_t registration_id, int32_t initial_term_id, - size_t term_buffer_capacity); + size_t term_length); /** * Supplier for flow control structure to be employed for multicast channels.