.class public final Lcom/discord/rtcconnection/RtcConnection; .super Ljava/lang/Object; .source "RtcConnection.kt" # annotations .annotation system Ldalvik/annotation/MemberClasses; value = { Lcom/discord/rtcconnection/RtcConnection$c;, Lcom/discord/rtcconnection/RtcConnection$State;, Lcom/discord/rtcconnection/RtcConnection$Quality;, Lcom/discord/rtcconnection/RtcConnection$b;, Lcom/discord/rtcconnection/RtcConnection$AnalyticsEvent;, Lcom/discord/rtcconnection/RtcConnection$a; } .end annotation # static fields .field public static H:I .field public static final I:Lcom/discord/rtcconnection/RtcConnection$a; # instance fields .field public final A:J .field public final B:Lcom/discord/rtcconnection/mediaengine/MediaEngine; .field public final C:Lcom/discord/utilities/logging/Logger; .field public final D:Lcom/discord/utilities/time/Clock; .field public final E:Lcom/discord/rtcconnection/RtcConnection$c; .field public final F:Ljava/util/Map; .annotation system Ldalvik/annotation/Signature; value = { "Ljava/util/Map<", "Ljava/lang/Long;", "Ljava/lang/Boolean;", ">;" } .end annotation .end field .field public final G:Ljava/lang/String; .field public final a:Ljava/lang/String; .field public final b:Ljava/lang/String; .field public final c:Ljava/util/List; .annotation system Ldalvik/annotation/Signature; value = { "Ljava/util/List<", "Lcom/discord/rtcconnection/RtcConnection$b;", ">;" } .end annotation .end field .field public final d:Lf/a/h/t/d; .field public final e:Lcom/discord/utilities/networking/Backoff; .field public f:Lcom/discord/rtcconnection/mediaengine/MediaEngineConnection$TransportInfo; .field public g:Lcom/discord/rtcconnection/RtcConnection$State; .field public h:Z .field public i:Ljava/util/LinkedList; .annotation system Ldalvik/annotation/Signature; value = { "Ljava/util/LinkedList<", "Ljava/lang/Long;", ">;" } .end annotation .end field .field public j:Lf/a/h/s/a; .field public k:Lcom/discord/rtcconnection/mediaengine/MediaEngineConnection; .field public l:Ljava/lang/String; .field public m:Ljava/lang/Integer; .field public n:I .field public o:Ljava/lang/Long; .field public p:Ljava/lang/Long; .field public q:I .field public r:Z .field public s:Ljava/lang/String; .field public final t:Lf/a/h/p; .field public final u:Lf/a/h/j; .field public final v:Ljava/lang/Long; .field public final w:J .field public x:Ljava/lang/String; .field public final y:Z .field public final z:Ljava/lang/String; # direct methods .method public static constructor ()V .locals 2 new-instance v0, Lcom/discord/rtcconnection/RtcConnection$a; const/4 v1, 0x0 invoke-direct {v0, v1}, Lcom/discord/rtcconnection/RtcConnection$a;->(Lkotlin/jvm/internal/DefaultConstructorMarker;)V sput-object v0, Lcom/discord/rtcconnection/RtcConnection;->I:Lcom/discord/rtcconnection/RtcConnection$a; return-void .end method .method public constructor (Ljava/lang/Long;JLjava/lang/String;ZLjava/lang/String;JLcom/discord/rtcconnection/mediaengine/MediaEngine;Lcom/discord/utilities/logging/Logger;Lcom/discord/utilities/time/Clock;Lcom/discord/rtcconnection/RtcConnection$c;Lcom/discord/utilities/networking/NetworkMonitor;Ljava/util/Map;Ljava/lang/String;I)V .locals 14 move-object v0, p0 move-object/from16 v1, p4 move-object/from16 v2, p6 move-object/from16 v3, p9 move-object/from16 v4, p10 move-object/from16 v5, p11 move/from16 v6, p16 and-int/lit16 v7, v6, 0x200 if-eqz v7, :cond_0 sget-object v7, Lcom/discord/rtcconnection/RtcConnection$c$a;->a:Lcom/discord/rtcconnection/RtcConnection$c$a; goto :goto_0 :cond_0 move-object/from16 v7, p12 :goto_0 and-int/lit16 v8, v6, 0x800 if-eqz v8, :cond_1 new-instance v8, Ljava/util/HashMap; invoke-direct {v8}, Ljava/util/HashMap;->()V goto :goto_1 :cond_1 move-object/from16 v8, p14 :goto_1 and-int/lit16 v6, v6, 0x1000 if-eqz v6, :cond_2 const/4 v6, 0x0 goto :goto_2 :cond_2 move-object/from16 v6, p15 :goto_2 const-string v9, "sessionId" invoke-static {v1, v9}, Lk0/n/c/i;->checkNotNullParameter(Ljava/lang/Object;Ljava/lang/String;)V const-string v9, "rtcServerId" invoke-static {v2, v9}, Lk0/n/c/i;->checkNotNullParameter(Ljava/lang/Object;Ljava/lang/String;)V const-string v9, "mediaEngine" invoke-static {v3, v9}, Lk0/n/c/i;->checkNotNullParameter(Ljava/lang/Object;Ljava/lang/String;)V const-string v9, "logger" invoke-static {v4, v9}, Lk0/n/c/i;->checkNotNullParameter(Ljava/lang/Object;Ljava/lang/String;)V const-string v9, "clock" invoke-static {v5, v9}, Lk0/n/c/i;->checkNotNullParameter(Ljava/lang/Object;Ljava/lang/String;)V const-string v9, "rtcConnectionType" invoke-static {v7, v9}, Lk0/n/c/i;->checkNotNullParameter(Ljava/lang/Object;Ljava/lang/String;)V const-string v9, "networkMonitor" move-object/from16 v10, p13 invoke-static {v10, v9}, Lk0/n/c/i;->checkNotNullParameter(Ljava/lang/Object;Ljava/lang/String;)V const-string v9, "mutedUsers" invoke-static {v8, v9}, Lk0/n/c/i;->checkNotNullParameter(Ljava/lang/Object;Ljava/lang/String;)V invoke-direct {p0}, Ljava/lang/Object;->()V move-object v9, p1 iput-object v9, v0, Lcom/discord/rtcconnection/RtcConnection;->v:Ljava/lang/Long; move-wide/from16 v11, p2 iput-wide v11, v0, Lcom/discord/rtcconnection/RtcConnection;->w:J iput-object v1, v0, Lcom/discord/rtcconnection/RtcConnection;->x:Ljava/lang/String; move/from16 v1, p5 iput-boolean v1, v0, Lcom/discord/rtcconnection/RtcConnection;->y:Z iput-object v2, v0, Lcom/discord/rtcconnection/RtcConnection;->z:Ljava/lang/String; move-wide/from16 v1, p7 iput-wide v1, v0, Lcom/discord/rtcconnection/RtcConnection;->A:J iput-object v3, v0, Lcom/discord/rtcconnection/RtcConnection;->B:Lcom/discord/rtcconnection/mediaengine/MediaEngine; iput-object v4, v0, Lcom/discord/rtcconnection/RtcConnection;->C:Lcom/discord/utilities/logging/Logger; iput-object v5, v0, Lcom/discord/rtcconnection/RtcConnection;->D:Lcom/discord/utilities/time/Clock; iput-object v7, v0, Lcom/discord/rtcconnection/RtcConnection;->E:Lcom/discord/rtcconnection/RtcConnection$c; iput-object v8, v0, Lcom/discord/rtcconnection/RtcConnection;->F:Ljava/util/Map; iput-object v6, v0, Lcom/discord/rtcconnection/RtcConnection;->G:Ljava/lang/String; invoke-static {}, Ljava/util/UUID;->randomUUID()Ljava/util/UUID; move-result-object v1 invoke-virtual {v1}, Ljava/util/UUID;->toString()Ljava/lang/String; move-result-object v1 const-string v2, "UUID.randomUUID().toString()" invoke-static {v1, v2}, Lk0/n/c/i;->checkNotNullExpressionValue(Ljava/lang/Object;Ljava/lang/String;)V iput-object v1, v0, Lcom/discord/rtcconnection/RtcConnection;->a:Ljava/lang/String; new-instance v1, Ljava/lang/StringBuilder; invoke-direct {v1}, Ljava/lang/StringBuilder;->()V const-class v2, Lcom/discord/rtcconnection/RtcConnection; invoke-virtual {v2}, Ljava/lang/Class;->getSimpleName()Ljava/lang/String; move-result-object v2 invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; const/16 v2, 0x3a invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(C)Ljava/lang/StringBuilder; sget v2, Lcom/discord/rtcconnection/RtcConnection;->H:I const/4 v3, 0x1 add-int/2addr v2, v3 sput v2, Lcom/discord/rtcconnection/RtcConnection;->H:I invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder; invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object v1 iput-object v1, v0, Lcom/discord/rtcconnection/RtcConnection;->b:Ljava/lang/String; new-instance v1, Ljava/util/ArrayList; invoke-direct {v1}, Ljava/util/ArrayList;->()V iput-object v1, v0, Lcom/discord/rtcconnection/RtcConnection;->c:Ljava/util/List; new-instance v1, Lf/a/h/t/d; iget-object v2, v0, Lcom/discord/rtcconnection/RtcConnection;->C:Lcom/discord/utilities/logging/Logger; const-wide/16 v4, 0x3e8 invoke-direct {v1, v4, v5, v2}, Lf/a/h/t/d;->(JLcom/discord/utilities/logging/Logger;)V iput-object v1, v0, Lcom/discord/rtcconnection/RtcConnection;->d:Lf/a/h/t/d; new-instance v1, Lcom/discord/utilities/networking/Backoff; const-wide/16 v4, 0x2710 const/4 v2, 0x0 const/4 v6, 0x0 const/4 v7, 0x0 const/16 v8, 0x1c const/4 v9, 0x0 const-wide/16 v11, 0x3e8 const/4 v13, 0x0 move-object p1, v1 move-wide/from16 p2, v11 move-wide/from16 p4, v4 move/from16 p6, v13 move/from16 p7, v6 move-object/from16 p8, v7 move/from16 p9, v8 move-object/from16 p10, v9 invoke-direct/range {p1 .. p10}, Lcom/discord/utilities/networking/Backoff;->(JJIZLcom/discord/utilities/networking/Backoff$Scheduler;ILkotlin/jvm/internal/DefaultConstructorMarker;)V iput-object v1, v0, Lcom/discord/rtcconnection/RtcConnection;->e:Lcom/discord/utilities/networking/Backoff; new-instance v1, Lcom/discord/rtcconnection/RtcConnection$State$d; invoke-direct {v1, v2}, Lcom/discord/rtcconnection/RtcConnection$State$d;->(Z)V iput-object v1, v0, Lcom/discord/rtcconnection/RtcConnection;->g:Lcom/discord/rtcconnection/RtcConnection$State; new-instance v1, Ljava/util/LinkedList; invoke-direct {v1}, Ljava/util/LinkedList;->()V iput-object v1, v0, Lcom/discord/rtcconnection/RtcConnection;->i:Ljava/util/LinkedList; iget-object v1, v0, Lcom/discord/rtcconnection/RtcConnection;->C:Lcom/discord/utilities/logging/Logger; const-string v2, "Created RtcConnection. GuildID: " invoke-static {v2}, Lf/e/b/a/a;->E(Ljava/lang/String;)Ljava/lang/StringBuilder; move-result-object v2 iget-object v4, v0, Lcom/discord/rtcconnection/RtcConnection;->v:Ljava/lang/Long; invoke-virtual {v2, v4}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder; const-string v4, " ChannelID: " invoke-virtual {v2, v4}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; iget-wide v4, v0, Lcom/discord/rtcconnection/RtcConnection;->w:J invoke-virtual {v2, v4, v5}, Ljava/lang/StringBuilder;->append(J)Ljava/lang/StringBuilder; invoke-virtual {v2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object v2 iget-object v4, v0, Lcom/discord/rtcconnection/RtcConnection;->b:Ljava/lang/String; invoke-virtual {v1, v2, v4}, Lcom/discord/utilities/logging/Logger;->recordBreadcrumb(Ljava/lang/String;Ljava/lang/String;)V invoke-virtual/range {p13 .. p13}, Lcom/discord/utilities/networking/NetworkMonitor;->observeIsConnected()Lrx/Observable; move-result-object v1 invoke-virtual {v1, v3}, Lrx/Observable;->O(I)Lrx/Observable; move-result-object v1 new-instance v2, Lf/a/h/b; invoke-direct {v2, p0}, Lf/a/h/b;->(Lcom/discord/rtcconnection/RtcConnection;)V invoke-virtual {v1, v2}, Lrx/Observable;->R(Lrx/functions/Action1;)Lrx/Subscription; new-instance v1, Lf/a/h/p; invoke-direct {v1, p0}, Lf/a/h/p;->(Lcom/discord/rtcconnection/RtcConnection;)V iput-object v1, v0, Lcom/discord/rtcconnection/RtcConnection;->t:Lf/a/h/p; new-instance v1, Lf/a/h/j; invoke-direct {v1, p0}, Lf/a/h/j;->(Lcom/discord/rtcconnection/RtcConnection;)V iput-object v1, v0, Lcom/discord/rtcconnection/RtcConnection;->u:Lf/a/h/j; return-void .end method .method public static synthetic e(Lcom/discord/rtcconnection/RtcConnection;ZLjava/lang/String;Ljava/lang/Throwable;I)V .locals 0 and-int/lit8 p3, p4, 0x4 const/4 p3, 0x0 invoke-virtual {p0, p1, p2, p3}, Lcom/discord/rtcconnection/RtcConnection;->d(ZLjava/lang/String;Ljava/lang/Throwable;)V return-void .end method # virtual methods .method public final a(Ljava/util/Map;)Ljava/util/Map; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/Map<", "Ljava/lang/String;", "Ljava/lang/Object;", ">;)", "Ljava/util/Map<", "Ljava/lang/String;", "Ljava/lang/Object;", ">;" } .end annotation iget-object v0, p0, Lcom/discord/rtcconnection/RtcConnection;->l:Ljava/lang/String; if-eqz v0, :cond_0 const-string v1, "hostname" invoke-interface {p1, v1, v0}, Ljava/util/Map;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; :cond_0 iget-object v0, p0, Lcom/discord/rtcconnection/RtcConnection;->m:Ljava/lang/Integer; if-eqz v0, :cond_1 invoke-virtual {v0}, Ljava/lang/Number;->intValue()I move-result v0 invoke-static {v0}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object v0 const-string v1, "port" invoke-interface {p1, v1, v0}, Ljava/util/Map;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; :cond_1 return-object p1 .end method .method public final b(Lcom/discord/rtcconnection/RtcConnection$b;)V .locals 1 const-string v0, "listener" invoke-static {p1, v0}, Lk0/n/c/i;->checkNotNullParameter(Ljava/lang/Object;Ljava/lang/String;)V iget-object v0, p0, Lcom/discord/rtcconnection/RtcConnection;->c:Ljava/util/List; invoke-interface {v0, p1}, Ljava/util/List;->add(Ljava/lang/Object;)Z return-void .end method .method public final c(Ljava/lang/String;)V .locals 5 iget-object v0, p0, Lcom/discord/rtcconnection/RtcConnection;->e:Lcom/discord/utilities/networking/Backoff; invoke-virtual {v0}, Lcom/discord/utilities/networking/Backoff;->cancel()V iget-object v0, p0, Lcom/discord/rtcconnection/RtcConnection;->j:Lf/a/h/s/a; if-eqz v0, :cond_0 iget-object v1, v0, Lf/a/h/s/a;->p:Ljava/util/List; invoke-interface {v1}, Ljava/util/List;->clear()V invoke-virtual {v0}, Lf/a/h/s/a;->d()V :cond_0 const/4 v0, 0x0 iput-object v0, p0, Lcom/discord/rtcconnection/RtcConnection;->j:Lf/a/h/s/a; iget-object v1, p0, Lcom/discord/rtcconnection/RtcConnection;->g:Lcom/discord/rtcconnection/RtcConnection$State; instance-of v1, v1, Lcom/discord/rtcconnection/RtcConnection$State$d; const/4 v2, 0x0 if-nez v1, :cond_2 invoke-virtual {p0, v2, p1}, Lcom/discord/rtcconnection/RtcConnection;->h(ZLjava/lang/String;)V iget-object p1, p0, Lcom/discord/rtcconnection/RtcConnection;->E:Lcom/discord/rtcconnection/RtcConnection$c; instance-of v1, p1, Lcom/discord/rtcconnection/RtcConnection$c$b; if-eqz v1, :cond_2 check-cast p1, Lcom/discord/rtcconnection/RtcConnection$c$b; iget-wide v3, p1, Lcom/discord/rtcconnection/RtcConnection$c$b;->a:J iget-object p1, p0, Lcom/discord/rtcconnection/RtcConnection;->d:Lf/a/h/t/d; iget-object p1, p1, Lf/a/h/t/d;->a:Lco/discord/media_engine/Stats; if-eqz p1, :cond_1 invoke-virtual {p1}, Lco/discord/media_engine/Stats;->getInboundRtpVideo()Ljava/util/Map; move-result-object p1 if-eqz p1, :cond_1 invoke-static {v3, v4}, Ljava/lang/String;->valueOf(J)Ljava/lang/String; move-result-object v1 invoke-interface {p1, v1}, Ljava/util/Map;->get(Ljava/lang/Object;)Ljava/lang/Object; move-result-object p1 check-cast p1, Lco/discord/media_engine/InboundRtpVideo; goto :goto_0 :cond_1 move-object p1, v0 :goto_0 if-eqz p1, :cond_2 iget-object v1, p0, Lcom/discord/rtcconnection/RtcConnection;->E:Lcom/discord/rtcconnection/RtcConnection$c; check-cast v1, Lcom/discord/rtcconnection/RtcConnection$c$b; iget-wide v3, v1, Lcom/discord/rtcconnection/RtcConnection$c$b;->a:J invoke-virtual {p0, v3, v4, p1}, Lcom/discord/rtcconnection/RtcConnection;->g(JLco/discord/media_engine/InboundRtpVideo;)V :cond_2 iget-object p1, p0, Lcom/discord/rtcconnection/RtcConnection;->k:Lcom/discord/rtcconnection/mediaengine/MediaEngineConnection; if-eqz p1, :cond_3 invoke-interface {p1}, Lcom/discord/rtcconnection/mediaengine/MediaEngineConnection;->g()V :cond_3 iput-object v0, p0, Lcom/discord/rtcconnection/RtcConnection;->k:Lcom/discord/rtcconnection/mediaengine/MediaEngineConnection; new-instance p1, Lcom/discord/rtcconnection/RtcConnection$State$d; invoke-direct {p1, v2}, Lcom/discord/rtcconnection/RtcConnection$State$d;->(Z)V invoke-virtual {p0, p1}, Lcom/discord/rtcconnection/RtcConnection;->n(Lcom/discord/rtcconnection/RtcConnection$State;)V iget-object p1, p0, Lcom/discord/rtcconnection/RtcConnection;->c:Ljava/util/List; invoke-interface {p1}, Ljava/util/List;->clear()V const/4 p1, 0x1 iput-boolean p1, p0, Lcom/discord/rtcconnection/RtcConnection;->h:Z return-void .end method .method public final d(ZLjava/lang/String;Ljava/lang/Throwable;)V .locals 7 iget-object v0, p0, Lcom/discord/rtcconnection/RtcConnection;->C:Lcom/discord/utilities/logging/Logger; iget-object v1, p0, Lcom/discord/rtcconnection/RtcConnection;->b:Ljava/lang/String; const/4 v4, 0x0 const/16 v5, 0x8 const/4 v6, 0x0 move-object v2, p2 move-object v3, p3 invoke-static/range {v0 .. v6}, Lcom/discord/utilities/logging/Logger;->e$default(Lcom/discord/utilities/logging/Logger;Ljava/lang/String;Ljava/lang/String;Ljava/lang/Throwable;Ljava/util/Map;ILjava/lang/Object;)V iget-object p3, p0, Lcom/discord/rtcconnection/RtcConnection;->d:Lf/a/h/t/d; invoke-virtual {p3}, Lf/a/h/t/d;->a()V iget-object p3, p0, Lcom/discord/rtcconnection/RtcConnection;->k:Lcom/discord/rtcconnection/mediaengine/MediaEngineConnection; if-eqz p3, :cond_0 invoke-interface {p3}, Lcom/discord/rtcconnection/mediaengine/MediaEngineConnection;->g()V :cond_0 const/4 p3, 0x0 iput-object p3, p0, Lcom/discord/rtcconnection/RtcConnection;->k:Lcom/discord/rtcconnection/mediaengine/MediaEngineConnection; iget-object p3, p0, Lcom/discord/rtcconnection/RtcConnection;->e:Lcom/discord/utilities/networking/Backoff; invoke-virtual {p3}, Lcom/discord/utilities/networking/Backoff;->cancel()V new-instance p3, Lcom/discord/rtcconnection/RtcConnection$State$d; invoke-direct {p3, p1}, Lcom/discord/rtcconnection/RtcConnection$State$d;->(Z)V invoke-virtual {p0, p3}, Lcom/discord/rtcconnection/RtcConnection;->n(Lcom/discord/rtcconnection/RtcConnection$State;)V if-eqz p1, :cond_1 invoke-virtual {p0}, Lcom/discord/rtcconnection/RtcConnection;->k()V goto :goto_0 :cond_1 sget-object p1, Lcom/discord/rtcconnection/RtcConnection$d;->d:Lcom/discord/rtcconnection/RtcConnection$d; invoke-virtual {p0, p1}, Lcom/discord/rtcconnection/RtcConnection;->j(Lkotlin/jvm/functions/Function1;)V invoke-virtual {p0, p2}, Lcom/discord/rtcconnection/RtcConnection;->c(Ljava/lang/String;)V :goto_0 return-void .end method .method public final f(JLjava/util/Map;)V .locals 3 .annotation system Ldalvik/annotation/Signature; value = { "(J", "Ljava/util/Map<", "Ljava/lang/String;", "Ljava/lang/Object;", ">;)V" } .end annotation new-instance v0, Ljava/util/HashMap; invoke-direct {v0}, Ljava/util/HashMap;->()V iget-object v1, p0, Lcom/discord/rtcconnection/RtcConnection;->v:Ljava/lang/Long; if-eqz v1, :cond_0 invoke-virtual {v1}, Ljava/lang/Number;->longValue()J iget-object v1, p0, Lcom/discord/rtcconnection/RtcConnection;->v:Ljava/lang/Long; const-string v2, "guild_id" invoke-virtual {v0, v2, v1}, Ljava/util/HashMap;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; :cond_0 iget-wide v1, p0, Lcom/discord/rtcconnection/RtcConnection;->w:J invoke-static {v1, v2}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long; move-result-object v1 const-string v2, "channel_id" invoke-virtual {v0, v2, v1}, Ljava/util/HashMap;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; invoke-static {p1, p2}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long; move-result-object p1 const-string p2, "sender_user_id" invoke-virtual {v0, p2, p1}, Ljava/util/HashMap;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; invoke-virtual {v0, p3}, Ljava/util/HashMap;->putAll(Ljava/util/Map;)V sget-object p1, Lcom/discord/rtcconnection/RtcConnection$AnalyticsEvent;->VIDEO_STREAM_ENDED:Lcom/discord/rtcconnection/RtcConnection$AnalyticsEvent; invoke-virtual {p0, p1, v0}, Lcom/discord/rtcconnection/RtcConnection;->i(Lcom/discord/rtcconnection/RtcConnection$AnalyticsEvent;Ljava/util/Map;)V return-void .end method .method public final g(JLco/discord/media_engine/InboundRtpVideo;)V .locals 6 invoke-virtual {p3}, Lco/discord/media_engine/InboundRtpVideo;->getFramesReceived()I move-result v0 const/4 v1, 0x1 const/4 v2, 0x0 if-lez v0, :cond_0 const/4 v0, 0x1 goto :goto_0 :cond_0 const/4 v0, 0x0 :goto_0 if-nez v0, :cond_1 return-void :cond_1 const-string v0, "$this$toAnalyticsProperties" invoke-static {p3, v0}, Lk0/n/c/i;->checkNotNullParameter(Ljava/lang/Object;Ljava/lang/String;)V const/4 v0, 0x5 new-array v0, v0, [Lkotlin/Pair; new-instance v3, Lkotlin/Pair; const-string v4, "participant_type" const-string v5, "receiver" invoke-direct {v3, v4, v5}, Lkotlin/Pair;->(Ljava/lang/Object;Ljava/lang/Object;)V aput-object v3, v0, v2 invoke-virtual {p3}, Lco/discord/media_engine/InboundRtpVideo;->getBytesReceived()J move-result-wide v2 invoke-static {v2, v3}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long; move-result-object v2 new-instance v3, Lkotlin/Pair; const-string v4, "num_bytes_received" invoke-direct {v3, v4, v2}, Lkotlin/Pair;->(Ljava/lang/Object;Ljava/lang/Object;)V aput-object v3, v0, v1 const/4 v1, 0x2 invoke-virtual {p3}, Lco/discord/media_engine/InboundRtpVideo;->getFramesDropped()I move-result v2 invoke-static {v2}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object v2 new-instance v3, Lkotlin/Pair; const-string v4, "num_frames_dropped" invoke-direct {v3, v4, v2}, Lkotlin/Pair;->(Ljava/lang/Object;Ljava/lang/Object;)V aput-object v3, v0, v1 const/4 v1, 0x3 invoke-virtual {p3}, Lco/discord/media_engine/InboundRtpVideo;->getFramesReceived()I move-result v2 invoke-static {v2}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object v2 new-instance v3, Lkotlin/Pair; const-string v4, "num_frames_received" invoke-direct {v3, v4, v2}, Lkotlin/Pair;->(Ljava/lang/Object;Ljava/lang/Object;)V aput-object v3, v0, v1 const/4 v1, 0x4 invoke-virtual {p3}, Lco/discord/media_engine/InboundRtpVideo;->getPacketsReceived()I move-result p3 invoke-static {p3}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object p3 new-instance v2, Lkotlin/Pair; const-string v3, "num_packets" invoke-direct {v2, v3, p3}, Lkotlin/Pair;->(Ljava/lang/Object;Ljava/lang/Object;)V aput-object v2, v0, v1 invoke-static {v0}, Lf/h/a/f/e/n/f;->mutableMapOf([Lkotlin/Pair;)Ljava/util/Map; move-result-object p3 invoke-virtual {p0, p1, p2, p3}, Lcom/discord/rtcconnection/RtcConnection;->f(JLjava/util/Map;)V return-void .end method .method public final h(ZLjava/lang/String;)V .locals 11 const/4 v0, 0x2 new-array v1, v0, [Lkotlin/Pair; iget v2, p0, Lcom/discord/rtcconnection/RtcConnection;->n:I invoke-static {v2}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object v2 new-instance v3, Lkotlin/Pair; const-string v4, "ping_bad_count" invoke-direct {v3, v4, v2}, Lkotlin/Pair;->(Ljava/lang/Object;Ljava/lang/Object;)V const/4 v2, 0x0 aput-object v3, v1, v2 iget v3, p0, Lcom/discord/rtcconnection/RtcConnection;->q:I invoke-static {v3}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object v3 new-instance v4, Lkotlin/Pair; const-string v5, "connect_count" invoke-direct {v4, v5, v3}, Lkotlin/Pair;->(Ljava/lang/Object;Ljava/lang/Object;)V const/4 v3, 0x1 aput-object v4, v1, v3 invoke-static {v1}, Lf/h/a/f/e/n/f;->mutableMapOf([Lkotlin/Pair;)Ljava/util/Map; move-result-object v1 invoke-virtual {p0, v1}, Lcom/discord/rtcconnection/RtcConnection;->a(Ljava/util/Map;)Ljava/util/Map; invoke-static {p1}, Ljava/lang/Boolean;->valueOf(Z)Ljava/lang/Boolean; move-result-object p1 move-object v4, v1 check-cast v4, Ljava/util/HashMap; const-string v5, "reconnect" invoke-virtual {v4, v5, p1}, Ljava/util/HashMap;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; if-eqz p2, :cond_0 const-string p1, "reason" invoke-virtual {v4, p1, p2}, Ljava/util/HashMap;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; :cond_0 iget-object p1, p0, Lcom/discord/rtcconnection/RtcConnection;->i:Ljava/util/LinkedList; const-string p2, "$this$average" invoke-static {p1, p2}, Lk0/n/c/i;->checkNotNullParameter(Ljava/lang/Object;Ljava/lang/String;)V invoke-interface {p1}, Ljava/lang/Iterable;->iterator()Ljava/util/Iterator; move-result-object p1 const-wide/16 v5, 0x0 const/4 p2, 0x0 :goto_0 invoke-interface {p1}, Ljava/util/Iterator;->hasNext()Z move-result v7 const/4 v8, 0x0 if-eqz v7, :cond_2 invoke-interface {p1}, Ljava/util/Iterator;->next()Ljava/lang/Object; move-result-object v7 check-cast v7, Ljava/lang/Number; invoke-virtual {v7}, Ljava/lang/Number;->longValue()J move-result-wide v9 long-to-double v9, v9 add-double/2addr v5, v9 add-int/lit8 p2, p2, 0x1 if-ltz p2, :cond_1 goto :goto_0 :cond_1 invoke-static {}, Lf/h/a/f/e/n/f;->throwCountOverflow()V throw v8 :cond_2 if-nez p2, :cond_3 const-wide/high16 p1, 0x7ff8000000000000L # Double.NaN goto :goto_1 :cond_3 int-to-double p1, p2 div-double p1, v5, p1 :goto_1 invoke-static {p1, p2}, Ljava/lang/Double;->isNaN(D)Z move-result v5 if-nez v5, :cond_7 invoke-static {p1, p2}, Ljava/lang/Double;->isNaN(D)Z move-result v5 if-nez v5, :cond_6 const v5, 0x7fffffff int-to-double v6, v5 const/high16 v9, -0x80000000 cmpl-double v10, p1, v6 if-lez v10, :cond_4 goto :goto_2 :cond_4 int-to-double v5, v9 cmpg-double v7, p1, v5 if-gez v7, :cond_5 const/high16 v5, -0x80000000 goto :goto_2 :cond_5 invoke-static {p1, p2}, Ljava/lang/Math;->round(D)J move-result-wide p1 long-to-int v5, p1 :goto_2 invoke-static {v5}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object p1 const-string p2, "ping_average" invoke-virtual {v4, p2, p1}, Ljava/util/HashMap;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; goto :goto_3 :cond_6 new-instance p1, Ljava/lang/IllegalArgumentException; const-string p2, "Cannot round NaN value." invoke-direct {p1, p2}, Ljava/lang/IllegalArgumentException;->(Ljava/lang/String;)V throw p1 :cond_7 :goto_3 iget-object p1, p0, Lcom/discord/rtcconnection/RtcConnection;->s:Ljava/lang/String; if-eqz p1, :cond_8 const-string p2, "media_session_id" invoke-virtual {v4, p2, p1}, Ljava/util/HashMap;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; :cond_8 iget-object p1, p0, Lcom/discord/rtcconnection/RtcConnection;->d:Lf/a/h/t/d; iget-object p1, p1, Lf/a/h/t/d;->a:Lco/discord/media_engine/Stats; if-eqz p1, :cond_f invoke-virtual {p1}, Lco/discord/media_engine/Stats;->getOutboundRtpAudio()Lco/discord/media_engine/OutboundRtpAudio; move-result-object p2 if-eqz p2, :cond_9 invoke-virtual {p2}, Lco/discord/media_engine/OutboundRtpAudio;->getPacketsSent()I move-result v5 invoke-static {v5}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object v5 const-string v6, "packets_sent" invoke-virtual {v4, v6, v5}, Ljava/util/HashMap;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; invoke-virtual {p2}, Lco/discord/media_engine/OutboundRtpAudio;->getPacketsLost()I move-result p2 invoke-static {p2}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object p2 const-string v5, "packets_sent_lost" invoke-virtual {v4, v5, p2}, Ljava/util/HashMap;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; :cond_9 invoke-virtual {p1}, Lco/discord/media_engine/Stats;->getInboundRtpAudio()Ljava/util/Map; move-result-object p1 invoke-interface {p1}, Ljava/util/Map;->values()Ljava/util/Collection; move-result-object p1 invoke-interface {p1}, Ljava/lang/Iterable;->iterator()Ljava/util/Iterator; move-result-object p1 const/4 p2, 0x0 const/4 v5, 0x0 :goto_4 invoke-interface {p1}, Ljava/util/Iterator;->hasNext()Z move-result v6 if-eqz v6, :cond_a invoke-interface {p1}, Ljava/util/Iterator;->next()Ljava/lang/Object; move-result-object v6 check-cast v6, Lco/discord/media_engine/InboundRtpAudio; invoke-virtual {v6}, Lco/discord/media_engine/InboundRtpAudio;->getPacketsLost()I move-result v7 add-int/2addr v5, v7 invoke-virtual {v6}, Lco/discord/media_engine/InboundRtpAudio;->getPacketsReceived()I move-result v6 add-int/2addr p2, v6 goto :goto_4 :cond_a invoke-static {p2}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object p1 const-string p2, "packets_received" invoke-virtual {v4, p2, p1}, Ljava/util/HashMap;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; invoke-static {v5}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object p1 const-string p2, "packets_received_lost" invoke-virtual {v4, p2, p1}, Ljava/util/HashMap;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; iget-object p1, p0, Lcom/discord/rtcconnection/RtcConnection;->d:Lf/a/h/t/d; iget-object p1, p1, Lf/a/h/t/d;->b:Lco/discord/media_engine/VoiceQuality; if-eqz p1, :cond_b invoke-virtual {p1, v1}, Lco/discord/media_engine/VoiceQuality;->getDurationStats(Ljava/util/Map;)V :cond_b iget-object p1, p0, Lcom/discord/rtcconnection/RtcConnection;->d:Lf/a/h/t/d; iget-object p1, p1, Lf/a/h/t/d;->b:Lco/discord/media_engine/VoiceQuality; if-eqz p1, :cond_c invoke-virtual {p1, v1}, Lco/discord/media_engine/VoiceQuality;->getMosStats(Ljava/util/Map;)V :cond_c iget-object p1, p0, Lcom/discord/rtcconnection/RtcConnection;->d:Lf/a/h/t/d; iget-object p1, p1, Lf/a/h/t/d;->b:Lco/discord/media_engine/VoiceQuality; if-eqz p1, :cond_d invoke-virtual {p1, v1}, Lco/discord/media_engine/VoiceQuality;->getPacketStats(Ljava/util/Map;)V :cond_d iget-object p1, p0, Lcom/discord/rtcconnection/RtcConnection;->d:Lf/a/h/t/d; iget-object p1, p1, Lf/a/h/t/d;->b:Lco/discord/media_engine/VoiceQuality; if-eqz p1, :cond_e invoke-virtual {p1, v1}, Lco/discord/media_engine/VoiceQuality;->getBufferStats(Ljava/util/Map;)V :cond_e iget-object p1, p0, Lcom/discord/rtcconnection/RtcConnection;->d:Lf/a/h/t/d; iget-object p1, p1, Lf/a/h/t/d;->b:Lco/discord/media_engine/VoiceQuality; if-eqz p1, :cond_f invoke-virtual {p1, v1}, Lco/discord/media_engine/VoiceQuality;->getFrameOpStats(Ljava/util/Map;)V :cond_f iget-object p1, p0, Lcom/discord/rtcconnection/RtcConnection;->p:Ljava/lang/Long; if-eqz p1, :cond_10 invoke-virtual {p1}, Ljava/lang/Number;->longValue()J move-result-wide p1 iget-object v5, p0, Lcom/discord/rtcconnection/RtcConnection;->D:Lcom/discord/utilities/time/Clock; invoke-interface {v5}, Lcom/discord/utilities/time/Clock;->currentTimeMillis()J move-result-wide v5 sub-long/2addr v5, p1 invoke-static {v5, v6}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long; move-result-object p1 goto :goto_5 :cond_10 move-object p1, v8 :goto_5 if-eqz p1, :cond_11 invoke-virtual {p1}, Ljava/lang/Number;->longValue()J move-result-wide p1 invoke-static {p1, p2}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long; move-result-object p1 const-string p2, "duration" invoke-virtual {v4, p2, p1}, Ljava/util/HashMap;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; :cond_11 iget-object p1, p0, Lcom/discord/rtcconnection/RtcConnection;->f:Lcom/discord/rtcconnection/mediaengine/MediaEngineConnection$TransportInfo; if-eqz p1, :cond_12 iget-object p1, p1, Lcom/discord/rtcconnection/mediaengine/MediaEngineConnection$TransportInfo;->c:Lcom/discord/rtcconnection/mediaengine/MediaEngineConnection$TransportInfo$Protocol; goto :goto_6 :cond_12 move-object p1, v8 :goto_6 if-eqz p1, :cond_15 invoke-virtual {p1}, Ljava/lang/Enum;->ordinal()I move-result p1 if-eqz p1, :cond_14 if-ne p1, v3, :cond_13 const-string p1, "tcp" goto :goto_7 :cond_13 new-instance p1, Lkotlin/NoWhenBranchMatchedException; invoke-direct {p1}, Lkotlin/NoWhenBranchMatchedException;->()V throw p1 :cond_14 const-string/jumbo p1, "udp" :goto_7 const-string p2, "protocol" invoke-virtual {v4, p2, p1}, Ljava/util/HashMap;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; :cond_15 sget-object p1, Lcom/discord/rtcconnection/RtcConnection$AnalyticsEvent;->VOICE_DISCONNECT:Lcom/discord/rtcconnection/RtcConnection$AnalyticsEvent; invoke-virtual {p0, p1, v1}, Lcom/discord/rtcconnection/RtcConnection;->i(Lcom/discord/rtcconnection/RtcConnection$AnalyticsEvent;Ljava/util/Map;)V iget-object p1, p0, Lcom/discord/rtcconnection/RtcConnection;->E:Lcom/discord/rtcconnection/RtcConnection$c; instance-of p1, p1, Lcom/discord/rtcconnection/RtcConnection$c$a; if-eqz p1, :cond_1a iget-object p1, p0, Lcom/discord/rtcconnection/RtcConnection;->d:Lf/a/h/t/d; iget-object p1, p1, Lf/a/h/t/d;->a:Lco/discord/media_engine/Stats; if-eqz p1, :cond_17 invoke-virtual {p1}, Lco/discord/media_engine/Stats;->getInboundRtpVideo()Ljava/util/Map; move-result-object p1 if-eqz p1, :cond_17 invoke-interface {p1}, Ljava/util/Map;->entrySet()Ljava/util/Set; move-result-object p1 invoke-interface {p1}, Ljava/util/Set;->iterator()Ljava/util/Iterator; move-result-object p1 :cond_16 :goto_8 invoke-interface {p1}, Ljava/util/Iterator;->hasNext()Z move-result p2 if-eqz p2, :cond_17 invoke-interface {p1}, Ljava/util/Iterator;->next()Ljava/lang/Object; move-result-object p2 check-cast p2, Ljava/util/Map$Entry; invoke-interface {p2}, Ljava/util/Map$Entry;->getKey()Ljava/lang/Object; move-result-object v1 check-cast v1, Ljava/lang/String; invoke-interface {p2}, Ljava/util/Map$Entry;->getValue()Ljava/lang/Object; move-result-object p2 check-cast p2, Lco/discord/media_engine/InboundRtpVideo; invoke-static {v1}, Lk0/t/j;->toLongOrNull(Ljava/lang/String;)Ljava/lang/Long; move-result-object v1 if-eqz v1, :cond_16 invoke-virtual {v1}, Ljava/lang/Long;->longValue()J move-result-wide v4 invoke-virtual {p0, v4, v5, p2}, Lcom/discord/rtcconnection/RtcConnection;->g(JLco/discord/media_engine/InboundRtpVideo;)V goto :goto_8 :cond_17 iget-wide p1, p0, Lcom/discord/rtcconnection/RtcConnection;->A:J iget-object v1, p0, Lcom/discord/rtcconnection/RtcConnection;->d:Lf/a/h/t/d; iget-object v1, v1, Lf/a/h/t/d;->a:Lco/discord/media_engine/Stats; if-eqz v1, :cond_18 invoke-virtual {v1}, Lco/discord/media_engine/Stats;->getOutboundRtpVideo()Lco/discord/media_engine/OutboundRtpVideo; move-result-object v8 :cond_18 if-nez v8, :cond_19 goto/16 :goto_9 :cond_19 const-string v1, "$this$toAnalyticsProperties" invoke-static {v8, v1}, Lk0/n/c/i;->checkNotNullParameter(Ljava/lang/Object;Ljava/lang/String;)V const/4 v1, 0x7 new-array v1, v1, [Lkotlin/Pair; new-instance v4, Lkotlin/Pair; const-string v5, "participant_type" const-string v6, "sender" invoke-direct {v4, v5, v6}, Lkotlin/Pair;->(Ljava/lang/Object;Ljava/lang/Object;)V aput-object v4, v1, v2 invoke-virtual {v8}, Lco/discord/media_engine/OutboundRtpVideo;->getBitrate()I move-result v2 invoke-static {v2}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object v2 new-instance v4, Lkotlin/Pair; const-string v5, "avg_bitrate" invoke-direct {v4, v5, v2}, Lkotlin/Pair;->(Ljava/lang/Object;Ljava/lang/Object;)V aput-object v4, v1, v3 invoke-virtual {v8}, Lco/discord/media_engine/OutboundRtpVideo;->getBitrateTarget()I move-result v2 invoke-static {v2}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object v2 new-instance v3, Lkotlin/Pair; const-string v4, "target_bitrate" invoke-direct {v3, v4, v2}, Lkotlin/Pair;->(Ljava/lang/Object;Ljava/lang/Object;)V aput-object v3, v1, v0 const/4 v0, 0x3 invoke-virtual {v8}, Lco/discord/media_engine/OutboundRtpVideo;->getNackCount()I move-result v2 invoke-static {v2}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object v2 new-instance v3, Lkotlin/Pair; const-string v4, "num_nacks" invoke-direct {v3, v4, v2}, Lkotlin/Pair;->(Ljava/lang/Object;Ljava/lang/Object;)V aput-object v3, v1, v0 const/4 v0, 0x4 invoke-virtual {v8}, Lco/discord/media_engine/OutboundRtpVideo;->getPacketsLost()I move-result v2 invoke-static {v2}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object v2 new-instance v3, Lkotlin/Pair; const-string v4, "num_packets_lost" invoke-direct {v3, v4, v2}, Lkotlin/Pair;->(Ljava/lang/Object;Ljava/lang/Object;)V aput-object v3, v1, v0 const/4 v0, 0x5 invoke-virtual {v8}, Lco/discord/media_engine/OutboundRtpVideo;->getPliCount()I move-result v2 invoke-static {v2}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object v2 new-instance v3, Lkotlin/Pair; const-string v4, "num_plis" invoke-direct {v3, v4, v2}, Lkotlin/Pair;->(Ljava/lang/Object;Ljava/lang/Object;)V aput-object v3, v1, v0 const/4 v0, 0x6 invoke-virtual {v8}, Lco/discord/media_engine/OutboundRtpVideo;->getResolution()Lco/discord/media_engine/Resolution; move-result-object v2 invoke-virtual {v2}, Lco/discord/media_engine/Resolution;->getHeight()I move-result v2 invoke-static {v2}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer; move-result-object v2 new-instance v3, Lkotlin/Pair; const-string v4, "target_resolution_height" invoke-direct {v3, v4, v2}, Lkotlin/Pair;->(Ljava/lang/Object;Ljava/lang/Object;)V aput-object v3, v1, v0 invoke-static {v1}, Lf/h/a/f/e/n/f;->mutableMapOf([Lkotlin/Pair;)Ljava/util/Map; move-result-object v0 invoke-virtual {p0, p1, p2, v0}, Lcom/discord/rtcconnection/RtcConnection;->f(JLjava/util/Map;)V :cond_1a :goto_9 return-void .end method .method public final i(Lcom/discord/rtcconnection/RtcConnection$AnalyticsEvent;Ljava/util/Map;)V .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lcom/discord/rtcconnection/RtcConnection$AnalyticsEvent;", "Ljava/util/Map<", "Ljava/lang/String;", "Ljava/lang/Object;", ">;)V" } .end annotation iget-object v0, p0, Lcom/discord/rtcconnection/RtcConnection;->a:Ljava/lang/String; const-string v1, "rtc_connection_id" invoke-interface {p2, v1, v0}, Ljava/util/Map;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; iget-object v0, p0, Lcom/discord/rtcconnection/RtcConnection;->E:Lcom/discord/rtcconnection/RtcConnection$c; sget-object v1, Lcom/discord/rtcconnection/RtcConnection$c$a;->a:Lcom/discord/rtcconnection/RtcConnection$c$a; invoke-static {v0, v1}, Lk0/n/c/i;->areEqual(Ljava/lang/Object;Ljava/lang/Object;)Z move-result v1 if-eqz v1, :cond_0 const-string v0, "default" goto :goto_0 :cond_0 instance-of v0, v0, Lcom/discord/rtcconnection/RtcConnection$c$b; if-eqz v0, :cond_3 const-string v0, "stream" :goto_0 const-string v1, "context" invoke-interface {p2, v1, v0}, Ljava/util/Map;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; iget-object v0, p0, Lcom/discord/rtcconnection/RtcConnection;->s:Ljava/lang/String; if-eqz v0, :cond_1 const-string v1, "media_session_id" invoke-interface {p2, v1, v0}, Ljava/util/Map;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; :cond_1 iget-object v0, p0, Lcom/discord/rtcconnection/RtcConnection;->G:Ljava/lang/String; if-eqz v0, :cond_2 const-string v1, "parent_media_session_id" invoke-interface {p2, v1, v0}, Ljava/util/Map;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; :cond_2 new-instance v0, Lcom/discord/rtcconnection/RtcConnection$e; invoke-direct {v0, p1, p2}, Lcom/discord/rtcconnection/RtcConnection$e;->(Lcom/discord/rtcconnection/RtcConnection$AnalyticsEvent;Ljava/util/Map;)V invoke-virtual {p0, v0}, Lcom/discord/rtcconnection/RtcConnection;->j(Lkotlin/jvm/functions/Function1;)V return-void :cond_3 new-instance p1, Lkotlin/NoWhenBranchMatchedException; invoke-direct {p1}, Lkotlin/NoWhenBranchMatchedException;->()V throw p1 .end method .method public final j(Lkotlin/jvm/functions/Function1;)V .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkotlin/jvm/functions/Function1<", "-", "Lcom/discord/rtcconnection/RtcConnection$b;", "Lkotlin/Unit;", ">;)V" } .end annotation iget-object v0, p0, Lcom/discord/rtcconnection/RtcConnection;->c:Ljava/util/List; invoke-interface {v0}, Ljava/lang/Iterable;->iterator()Ljava/util/Iterator; move-result-object v0 :goto_0 invoke-interface {v0}, Ljava/util/Iterator;->hasNext()Z move-result v1 if-eqz v1, :cond_0 invoke-interface {v0}, Ljava/util/Iterator;->next()Ljava/lang/Object; move-result-object v1 invoke-interface {p1, v1}, Lkotlin/jvm/functions/Function1;->invoke(Ljava/lang/Object;)Ljava/lang/Object; goto :goto_0 :cond_0 return-void .end method .method public final k()V .locals 3 iget-object v0, p0, Lcom/discord/rtcconnection/RtcConnection;->C:Lcom/discord/utilities/logging/Logger; iget-object v1, p0, Lcom/discord/rtcconnection/RtcConnection;->b:Ljava/lang/String; const-string v2, "reconnect" invoke-virtual {v0, v2, v1}, Lcom/discord/utilities/logging/Logger;->recordBreadcrumb(Ljava/lang/String;Ljava/lang/String;)V iget-boolean v0, p0, Lcom/discord/rtcconnection/RtcConnection;->r:Z if-eqz v0, :cond_0 iget-object v0, p0, Lcom/discord/rtcconnection/RtcConnection;->D:Lcom/discord/utilities/time/Clock; invoke-interface {v0}, Lcom/discord/utilities/time/Clock;->currentTimeMillis()J move-result-wide v0 invoke-static {v0, v1}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long; move-result-object v0 iput-object v0, p0, Lcom/discord/rtcconnection/RtcConnection;->o:Ljava/lang/Long; :cond_0 iget v0, p0, Lcom/discord/rtcconnection/RtcConnection;->q:I add-int/lit8 v0, v0, 0x1 iput v0, p0, Lcom/discord/rtcconnection/RtcConnection;->q:I iget-object v0, p0, Lcom/discord/rtcconnection/RtcConnection;->j:Lf/a/h/s/a; if-eqz v0, :cond_1 invoke-virtual {v0}, Lf/a/h/s/a;->d()V invoke-virtual {v0}, Lf/a/h/s/a;->e()Z :cond_1 return-void .end method .method public final l(Lkotlin/jvm/functions/Function0;)Ljava/util/concurrent/Future; .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkotlin/jvm/functions/Function0<", "Lkotlin/Unit;", ">;)", "Ljava/util/concurrent/Future<", "*>;" } .end annotation iget-object v0, p0, Lcom/discord/rtcconnection/RtcConnection;->B:Lcom/discord/rtcconnection/mediaengine/MediaEngine; invoke-interface {v0}, Lcom/discord/rtcconnection/mediaengine/MediaEngine;->l()Ljava/util/concurrent/ExecutorService; move-result-object v0 if-eqz p1, :cond_0 new-instance v1, Lf/a/h/q; invoke-direct {v1, p1}, Lf/a/h/q;->(Lkotlin/jvm/functions/Function0;)V move-object p1, v1 :cond_0 check-cast p1, Ljava/lang/Runnable; invoke-interface {v0, p1}, Ljava/util/concurrent/ExecutorService;->submit(Ljava/lang/Runnable;)Ljava/util/concurrent/Future; move-result-object p1 return-object p1 .end method .method public final m(Landroid/content/Intent;)V .locals 3 iget-object v0, p0, Lcom/discord/rtcconnection/RtcConnection;->E:Lcom/discord/rtcconnection/RtcConnection$c; instance-of v0, v0, Lcom/discord/rtcconnection/RtcConnection$c$b; if-nez v0, :cond_0 return-void :cond_0 iget-object v0, p0, Lcom/discord/rtcconnection/RtcConnection;->C:Lcom/discord/utilities/logging/Logger; new-instance v1, Ljava/lang/StringBuilder; invoke-direct {v1}, Ljava/lang/StringBuilder;->()V const-string v2, "Setting screenshare " invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v1, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder; const/16 v2, 0x20 invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(C)Ljava/lang/StringBuilder; iget-object v2, p0, Lcom/discord/rtcconnection/RtcConnection;->k:Lcom/discord/rtcconnection/mediaengine/MediaEngineConnection; invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder; invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object v1 iget-object v2, p0, Lcom/discord/rtcconnection/RtcConnection;->b:Ljava/lang/String; invoke-virtual {v0, v1, v2}, Lcom/discord/utilities/logging/Logger;->recordBreadcrumb(Ljava/lang/String;Ljava/lang/String;)V iget-object v0, p0, Lcom/discord/rtcconnection/RtcConnection;->k:Lcom/discord/rtcconnection/mediaengine/MediaEngineConnection; if-eqz v0, :cond_2 if-eqz p1, :cond_1 invoke-interface {v0, p1}, Lcom/discord/rtcconnection/mediaengine/MediaEngineConnection;->d(Landroid/content/Intent;)V goto :goto_0 :cond_1 invoke-interface {v0}, Lcom/discord/rtcconnection/mediaengine/MediaEngineConnection;->c()V :cond_2 :goto_0 return-void .end method .method public final n(Lcom/discord/rtcconnection/RtcConnection$State;)V .locals 1 iget-object v0, p0, Lcom/discord/rtcconnection/RtcConnection;->g:Lcom/discord/rtcconnection/RtcConnection$State; invoke-static {p1, v0}, Lk0/n/c/i;->areEqual(Ljava/lang/Object;Ljava/lang/Object;)Z move-result v0 xor-int/lit8 v0, v0, 0x1 if-eqz v0, :cond_0 iput-object p1, p0, Lcom/discord/rtcconnection/RtcConnection;->g:Lcom/discord/rtcconnection/RtcConnection$State; new-instance v0, Lcom/discord/rtcconnection/RtcConnection$f; invoke-direct {v0, p1}, Lcom/discord/rtcconnection/RtcConnection$f;->(Lcom/discord/rtcconnection/RtcConnection$State;)V invoke-virtual {p0, v0}, Lcom/discord/rtcconnection/RtcConnection;->j(Lkotlin/jvm/functions/Function1;)V :cond_0 return-void .end method