diff --git a/gst/rtmp2/rtmp/rtmpconnection.c b/gst/rtmp2/rtmp/rtmpconnection.c index 02d3e80ac4..ec41ea1ebc 100644 --- a/gst/rtmp2/rtmp/rtmpconnection.c +++ b/gst/rtmp2/rtmp/rtmpconnection.c @@ -1064,6 +1064,21 @@ gst_rtmp_connection_send_ping_response (GstRtmpConnection * connection, gst_rtmp_message_new_user_control (&uc)); } +void +gst_rtmp_connection_set_chunk_size (GstRtmpConnection * connection, + guint32 chunk_size) +{ + GstRtmpProtocolControl pc = { + .type = GST_RTMP_MESSAGE_TYPE_SET_CHUNK_SIZE, + .param = chunk_size, + }; + + g_return_if_fail (GST_IS_RTMP_CONNECTION (connection)); + + gst_rtmp_connection_queue_message (connection, + gst_rtmp_message_new_protocol_control (&pc)); +} + void gst_rtmp_connection_request_window_size (GstRtmpConnection * connection, guint32 window_ack_size) diff --git a/gst/rtmp2/rtmp/rtmpconnection.h b/gst/rtmp2/rtmp/rtmpconnection.h index f4c4b96748..f7e78ce6f9 100644 --- a/gst/rtmp2/rtmp/rtmpconnection.h +++ b/gst/rtmp2/rtmp/rtmpconnection.h @@ -81,6 +81,8 @@ void gst_rtmp_connection_expect_command (GstRtmpConnection * connection, GstRtmpCommandCallback response_command, gpointer user_data, guint32 stream_id, const gchar * command_name); +void gst_rtmp_connection_set_chunk_size (GstRtmpConnection * connection, + guint32 chunk_size); void gst_rtmp_connection_request_window_size (GstRtmpConnection * connection, guint32 window_ack_size);