{
g_mutex_init (&client->lock);
client->use_client_settings = DEFAULT_USE_CLIENT_SETTINGS;
- client->close_response_seq = 0;
+ client->close_seq = 0;
}
static void
/* send the response and store the seq number so we can wait until it's
* written to the client to close the connection */
gst_rtsp_watch_send_message (client->watch, response, close ?
- &client->close_response_seq : NULL);
+ &client->close_seq : NULL);
gst_rtsp_message_unset (response);
}
static GstRTSPResult
message_sent (GstRTSPWatch * watch, guint cseq, gpointer user_data)
{
- GstRTSPClient *client;
+ GstRTSPClient *client = GST_RTSP_CLIENT (user_data);
- client = GST_RTSP_CLIENT (user_data);
- if (client->close_response_seq && client->close_response_seq == cseq) {
- client->close_response_seq = 0;
+ if (client->close_seq && client->close_seq == cseq) {
+ client->close_seq = 0;
close_connection (client);
}
* @lock: lock protecting the client object
* @connection: the connection object handling the client request.
* @watch: watch for the connection
- * @close_response_seq: sequence number of message with close header
+ * @close_seq: sequence number of message with close header
* @server_ip: ip address of the server
* @is_ipv6: if we are IPv6
* @use_client_settings: whether to allow client transport settings for multicast
GMutex lock;
GstRTSPConnection *connection;
GstRTSPWatch *watch;
- guint close_response_seq;
+ guint close_seq;
gchar *server_ip;
gboolean is_ipv6;
gboolean use_client_settings;