more logging

This commit is contained in:
Hiroshi Horie
2021-12-16 03:30:48 +07:00
parent 28e7091325
commit e015f62b9c
3 changed files with 13 additions and 6 deletions
+3 -3
View File
@@ -1,7 +1,7 @@
class Timeouts { class Timeouts {
static const connection = Duration(seconds: 5); static const connection = Duration(seconds: 10);
static const debounce = Duration(milliseconds: 100); static const debounce = Duration(milliseconds: 100);
static const publish = Duration(seconds: 3); static const publish = Duration(seconds: 10);
static const iceConnection = Duration(seconds: 5); static const iceConnection = Duration(seconds: 10);
static const iceRestart = Duration(seconds: 10); static const iceRestart = Duration(seconds: 10);
} }
+2 -1
View File
@@ -47,7 +47,6 @@ class RemoteParticipant extends Participant<RemoteTrackPublication> {
RemoteParticipant.fromInfo({ RemoteParticipant.fromInfo({
required Room room, required Room room,
required lk_models.ParticipantInfo info, required lk_models.ParticipantInfo info,
required EventsEmitter<RoomEvent> roomEvents,
}) : super( }) : super(
room: room, room: room,
sid: info.sid, sid: info.sid,
@@ -75,6 +74,7 @@ class RemoteParticipant extends Participant<RemoteTrackPublication> {
RemoteTrackPublication? pub = getTrackPublication(trackSid); RemoteTrackPublication? pub = getTrackPublication(trackSid);
if (pub == null) { if (pub == null) {
logger.fine('addSubscribedMediaTrack() pub is null, will wait...'); logger.fine('addSubscribedMediaTrack() pub is null, will wait...');
logger.fine('addSubscribedMediaTrack() tracks: $trackPublications');
// Wait for the metadata to arrive // Wait for the metadata to arrive
final event = await events.waitFor<TrackPublishedEvent>( final event = await events.waitFor<TrackPublishedEvent>(
filter: (event) => filter: (event) =>
@@ -128,6 +128,7 @@ class RemoteParticipant extends Participant<RemoteTrackPublication> {
@override @override
@internal @internal
Future<void> updateFromInfo(lk_models.ParticipantInfo info) async { Future<void> updateFromInfo(lk_models.ParticipantInfo info) async {
logger.fine('RemoteParticipant.updateFromInfo(info: $info)');
final hadInfo = hasInfo; final hadInfo = hasInfo;
super.updateFromInfo(info); super.updateFromInfo(info);
+8 -2
View File
@@ -125,7 +125,11 @@ class Room extends DisposableChangeNotifier with EventsEmittable<RoomEvent> {
info: joinResponse.participant, info: joinResponse.participant,
); );
logger.fine('DEBUG_01 Did connect');
for (final info in joinResponse.otherParticipants) { for (final info in joinResponse.otherParticipants) {
logger.fine(
'DEBUG_01 Existing Participant: ${info.sid}(${info.identity}) tracks:${info.tracks.map((e) => e.sid)}');
_getOrCreateRemoteParticipant(info.sid, info); _getOrCreateRemoteParticipant(info.sid, info);
} }
} }
@@ -164,6 +168,8 @@ class Room extends DisposableChangeNotifier with EventsEmittable<RoomEvent> {
} }
}) })
..on<EngineTrackAddedEvent>((event) async { ..on<EngineTrackAddedEvent>((event) async {
logger.fine('DEBUG_01 EngineTrackAddedEvent id:${event.track.id}');
final idParts = event.stream.id.split('|'); final idParts = event.stream.id.split('|');
final participantSid = idParts[0]; final participantSid = idParts[0];
final trackSid = idParts.elementAtOrNull(1) ?? event.track.id; final trackSid = idParts.elementAtOrNull(1) ?? event.track.id;
@@ -181,7 +187,7 @@ class Room extends DisposableChangeNotifier with EventsEmittable<RoomEvent> {
trackSid, trackSid,
); );
} on TrackSubscriptionExceptionEvent catch (event) { } on TrackSubscriptionExceptionEvent catch (event) {
logger.warning('addSubscribedMediaTrack() throwed ${event}'); logger.severe('addSubscribedMediaTrack() throwed ${event}');
[participant.room.events, participant.events].emit(event); [participant.room.events, participant.events].emit(event);
} catch (exception) { } catch (exception) {
// We don't want to pass up any exception so catch everything here. // We don't want to pass up any exception so catch everything here.
@@ -210,6 +216,7 @@ class Room extends DisposableChangeNotifier with EventsEmittable<RoomEvent> {
} }
if (info == null) { if (info == null) {
logger.warning('DEBUG_01 RemoteParticipant.info is null... sid:$sid');
participant = RemoteParticipant( participant = RemoteParticipant(
room: this, room: this,
sid: sid, sid: sid,
@@ -219,7 +226,6 @@ class Room extends DisposableChangeNotifier with EventsEmittable<RoomEvent> {
participant = RemoteParticipant.fromInfo( participant = RemoteParticipant.fromInfo(
room: this, room: this,
info: info, info: info,
roomEvents: events,
); );
} }