_channel->open_cb.callback = callback;
_channel->open_cb.user_data = user_data;
- LOG_INFO("callback[%p] user_data[%p]", callback, user_data);
+ LOG_INFO("channel[%p] callback[%p] user_data[%p]", _channel, callback, user_data);
g_mutex_unlock(&_channel->mutex);
RET_VAL_WITH_UNLOCK_IF(_channel->open_cb.callback == NULL, WEBRTC_ERROR_INVALID_OPERATION, &_channel->mutex, "callback was not set");
- LOG_INFO("callback[%p] user_data[%p] is reset to NULL",
- _channel->open_cb.callback, _channel->open_cb.user_data);
+ LOG_INFO("channel[%p] callback[%p] user_data[%p] is reset to NULL",
+ _channel, _channel->open_cb.callback, _channel->open_cb.user_data);
_channel->open_cb.callback = NULL;
_channel->open_cb.user_data = NULL;
_channel->message_cb.callback = callback;
_channel->message_cb.user_data = user_data;
- LOG_INFO("callback[%p] user_data[%p]", callback, user_data);
+ LOG_INFO("channel[%p] callback[%p] user_data[%p]", _channel, callback, user_data);
g_mutex_unlock(&_channel->mutex);
RET_VAL_WITH_UNLOCK_IF(_channel->message_cb.callback == NULL, WEBRTC_ERROR_INVALID_OPERATION, &_channel->mutex, "callback was not set");
- LOG_INFO("callback[%p] user_data[%p] is reset to NULL",
- _channel->message_cb.callback, _channel->message_cb.user_data);
+ LOG_INFO("channel[%p] callback[%p] user_data[%p] is reset to NULL",
+ _channel, _channel->message_cb.callback, _channel->message_cb.user_data);
_channel->message_cb.callback = NULL;
_channel->message_cb.user_data = NULL;
_channel->error_cb.callback = callback;
_channel->error_cb.user_data = user_data;
- LOG_INFO("callback[%p] user_data[%p]", callback, user_data);
+ LOG_INFO("channel[%p] callback[%p] user_data[%p]", _channel, callback, user_data);
g_mutex_unlock(&_channel->mutex);
RET_VAL_WITH_UNLOCK_IF(_channel->error_cb.callback == NULL, WEBRTC_ERROR_INVALID_OPERATION, &_channel->mutex, "callback was not set");
- LOG_INFO("callback[%p] user_data[%p] is reset to NULL",
- _channel->error_cb.callback, _channel->error_cb.user_data);
+ LOG_INFO("channel[%p] callback[%p] user_data[%p] is reset to NULL",
+ _channel, _channel->error_cb.callback, _channel->error_cb.user_data);
_channel->error_cb.callback = NULL;
_channel->error_cb.user_data = NULL;
_channel->close_cb.callback = callback;
_channel->close_cb.user_data = user_data;
- LOG_INFO("callback[%p] user_data[%p]", callback, user_data);
+ LOG_INFO("channel[%p] callback[%p] user_data[%p]", _channel, callback, user_data);
g_mutex_unlock(&_channel->mutex);
RET_VAL_WITH_UNLOCK_IF(_channel->close_cb.callback == NULL, WEBRTC_ERROR_INVALID_OPERATION, &_channel->mutex, "callback was not set");
- LOG_INFO("callback[%p] user_data[%p] is reset to NULL",
- _channel->close_cb.callback, _channel->close_cb.user_data);
+ LOG_INFO("channel[%p] callback[%p] user_data[%p] is reset to NULL",
+ _channel, _channel->close_cb.callback, _channel->close_cb.user_data);
_channel->close_cb.callback = NULL;
_channel->close_cb.user_data = NULL;
*label = strdup(_label);
- LOG_INFO("label[%s]", *label);
+ LOG_INFO("channel[%p, label:%s]", _channel, *label);
g_free(_label);
RET_IF(channel == NULL, "channel is NULL");
- LOG_DEBUG("data_channel[%s] user_data[%p]", GST_OBJECT_NAME(data_channel), user_data);
+ LOG_DEBUG("channel[%p, %s] user_data[%p]", channel, GST_OBJECT_NAME(data_channel), user_data);
if (channel->open_cb.callback) {
LOG_DEBUG(">>> callback[%p] user_data[%p]", channel->open_cb.callback, channel->open_cb.user_data);
RET_IF(channel == NULL, "channel is NULL");
- LOG_INFO("data_channel[%s] <<<<< [%s]", GST_OBJECT_NAME(data_channel), string);
+ LOG_INFO("channel[%p, %s] <<<<< [%s]", channel, GST_OBJECT_NAME(data_channel), string);
if (channel->message_cb.callback) {
LOG_DEBUG(">>> callback[%p] user_data[%p]", channel->message_cb.callback, channel->message_cb.user_data);
RET_IF(channel == NULL, "channel is NULL");
- LOG_DEBUG("data_channel[%s] bytes[%p, size:%u] user_data[%p]", GST_OBJECT_NAME(data_channel), bytes, g_bytes_get_size(bytes), user_data);
+ LOG_DEBUG("channel[%p, %s] bytes[%p, size:%u] user_data[%p]",
+ channel, GST_OBJECT_NAME(data_channel), bytes, g_bytes_get_size(bytes), user_data);
if (channel->message_cb.callback) {
webrtc_bytes_data_s data = { 0, };
else if (error->domain == GST_STREAM_ERROR)
err = WEBRTC_ERROR_STREAM_FAILED;
- LOG_DEBUG("data_channel[%s] error[0x%x] user_data[%p]", GST_OBJECT_NAME(data_channel), err, user_data);
+ LOG_DEBUG("channel[%p, %s] error[0x%x] user_data[%p]", channel, GST_OBJECT_NAME(data_channel), err, user_data);
if (channel->error_cb.callback) {
LOG_DEBUG(">>> callback[%p] user_data[%p]", channel->error_cb.callback, channel->error_cb.user_data);
RET_IF(channel == NULL, "channel is NULL");
- LOG_DEBUG("data_channel[%s] user_data[%p]", GST_OBJECT_NAME(data_channel), user_data);
+ LOG_DEBUG("channel[%p, %s] user_data[%p]", channel, GST_OBJECT_NAME(data_channel), user_data);
if (channel->close_cb.callback) {
LOG_DEBUG(">>> callback[%p] user_data[%p]", channel->close_cb.callback, channel->close_cb.user_data);
RET_IF(webrtc == NULL, "webrtc is NULL");
RET_IF(channel == NULL, "channel is NULL");
- LOG_INFO("data_channel[%s]", GST_OBJECT_NAME(channel->channel));
+ LOG_INFO("channel[%p, %s]", channel, GST_OBJECT_NAME(channel->channel));
if (webrtc->data_channel_cb.callback) {
LOG_DEBUG(">>> callback[%p] user_data[%p]", webrtc->data_channel_cb.callback, webrtc->data_channel_cb.user_data);
RET_IF(webrtc == NULL, "webrtc is NULL");
- LOG_DEBUG("data_channel[%s] user_data[%p]", GST_OBJECT_NAME(data_channel), user_data);
-
channel = g_new0(webrtc_data_channel_s, 1);
g_mutex_init(&channel->mutex);
g_mutex_lock(&channel->mutex);
channel->channel = data_channel;
+ LOG_DEBUG("channel[%p, %s] user_data[%p]", channel, GST_OBJECT_NAME(data_channel), user_data);
+
g_hash_table_insert(webrtc->data_channels, (gpointer)channel, (gpointer)channel);
_connect_and_append_signal(&channel->signals, channel->channel, "on-open", G_CALLBACK(__data_channel_on_open_cb), channel);
return WEBRTC_ERROR_INVALID_OPERATION;
}
- LOG_INFO("data channel[%s] label[%s] is created", GST_OBJECT_NAME(data_channel), label);
-
_channel = g_new0(webrtc_data_channel_s, 1);
g_mutex_init(&_channel->mutex);
g_mutex_lock(&_channel->mutex);
_channel->channel = data_channel;
+ LOG_INFO("channel[%p, label:%s] is created", _channel, label);
+
_connect_and_append_signal(&_channel->signals, data_channel, "on-open", G_CALLBACK(__data_channel_on_open_cb), _channel);
_connect_and_append_signal(&_channel->signals, data_channel, "on-message-string", G_CALLBACK(__data_channel_on_message_string_cb), _channel);
_connect_and_append_signal(&_channel->signals, data_channel, "on-message-data", G_CALLBACK(__data_channel_on_message_data_cb), _channel);
g_list_free_full(channel->signals, _disconnect_signal);
channel->signals = NULL;
- LOG_INFO("data_channel[%s] is destroyed", GST_OBJECT_NAME(channel->channel));
+ LOG_INFO("channel[%p] is destroyed", channel);
g_mutex_unlock(&channel->mutex);
g_mutex_clear(&channel->mutex);
g_signal_emit_by_name(channel->channel, "send-string", string);
- LOG_INFO("data_channel[%s] >>>>> [%s]", GST_OBJECT_NAME(channel->channel), string);
+ LOG_INFO("channel[%p, %s] >>>>> [%s]", channel, GST_OBJECT_NAME(channel->channel), string);
return WEBRTC_ERROR_NONE;
}
g_signal_emit_by_name(channel->channel, "send-data", bytes);
- LOG_INFO("data_channel[%s] >>>>> [%p, size:%u]", GST_OBJECT_NAME(channel->channel), data, size);
+ LOG_INFO("channel[%p, %s] >>>>> [%p, size:%u]", channel, GST_OBJECT_NAME(channel->channel), data, size);
g_bytes_unref(bytes);