RTCConnectionHolder.smali

.class public Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;
.super Ljava/lang/Object;
.source "RTCConnectionHolder.java"


# annotations
.annotation system Ldalvik/annotation/MemberClasses;
    value = {
        Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder$PCObserver;,
        Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder$AnswerSdpObserver;
    }
.end annotation


# static fields
.field private static final DTLS_SRTP_KEY_AGREEMENT_CONSTRAINT:Ljava/lang/String; = "DtlsSrtpKeyAgreement"

.field private static final TAG:Ljava/lang/String; = "RTCConnectionHolder"


# instance fields
.field private cachedRtpSenders:Ljava/util/Map;
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "Ljava/util/Map<",
            "Ljava/lang/String;",
            "Lcn/rongcloud/rtc/core/RtpSender;",
            ">;"
        }
    .end annotation
.end field

.field private events:Lcn/rongcloud/rtc/webrtc/RTCConnectionEvents;

.field private everOfferIsCreated:Z

.field private factory:Lcn/rongcloud/rtc/webrtc/PeerConnectionFactoryHolder;

.field private mConnection:Lcn/rongcloud/rtc/core/PeerConnection;

.field private mConnectionLock:Ljava/lang/Object;

.field private mRTCConfig:Lcn/rongcloud/rtc/center/config/RCRTCConfigImpl;

.field private final pcObserver:Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder$PCObserver;


# direct methods
.method public constructor <init>(Lcn/rongcloud/rtc/webrtc/PeerConnectionFactoryHolder;Lcn/rongcloud/rtc/center/config/RCRTCConfigImpl;Lcn/rongcloud/rtc/webrtc/RTCConnectionEvents;)V
    .registers 5

    .line 1
    invoke-direct {p0}, Ljava/lang/Object;-><init>()V

    .line 2
    new-instance v0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder$PCObserver;

    invoke-direct {v0, p0}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder$PCObserver;-><init>(Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;)V

    iput-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->pcObserver:Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder$PCObserver;

    .line 3
    new-instance v0, Ljava/lang/Object;

    invoke-direct {v0}, Ljava/lang/Object;-><init>()V

    iput-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mConnectionLock:Ljava/lang/Object;

    .line 4
    new-instance v0, Ljava/util/HashMap;

    invoke-direct {v0}, Ljava/util/HashMap;-><init>()V

    iput-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->cachedRtpSenders:Ljava/util/Map;

    .line 5
    iput-object p1, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->factory:Lcn/rongcloud/rtc/webrtc/PeerConnectionFactoryHolder;

    .line 6
    iput-object p2, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mRTCConfig:Lcn/rongcloud/rtc/center/config/RCRTCConfigImpl;

    .line 7
    iput-object p3, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->events:Lcn/rongcloud/rtc/webrtc/RTCConnectionEvents;

    .line 8
    invoke-direct {p0}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->createRongRTCConnectionInternal()V

    return-void
.end method

.method static synthetic access$002(Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;Z)Z
    .registers 2

    .line 1
    iput-boolean p1, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->everOfferIsCreated:Z

    return p1
.end method

.method static synthetic access$100(Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;)Lcn/rongcloud/rtc/core/PeerConnection;
    .registers 1

    .line 1
    iget-object p0, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mConnection:Lcn/rongcloud/rtc/core/PeerConnection;

    return-object p0
.end method

.method static synthetic access$200(Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;)Lcn/rongcloud/rtc/webrtc/RTCConnectionEvents;
    .registers 1

    .line 1
    iget-object p0, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->events:Lcn/rongcloud/rtc/webrtc/RTCConnectionEvents;

    return-object p0
.end method

.method static synthetic access$300(Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;)Lcn/rongcloud/rtc/center/config/RCRTCConfigImpl;
    .registers 1

    .line 1
    iget-object p0, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mRTCConfig:Lcn/rongcloud/rtc/center/config/RCRTCConfigImpl;

    return-object p0
.end method

.method private createAndSetOffer(Ljava/lang/String;ZILcn/rongcloud/rtc/api/callback/IRCRTCResultDataCallback;)V
    .registers 19
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Ljava/lang/String;",
            "ZI",
            "Lcn/rongcloud/rtc/api/callback/IRCRTCResultDataCallback<",
            "Lcn/rongcloud/rtc/core/SessionDescription;",
            ">;)V"
        }
    .end annotation

    move-object v0, p0

    move-object/from16 v1, p4

    .line 1
    sget-object v2, Lcn/rongcloud/rtc/utils/ReportUtil$TAG;->CREATEOFFER:Lcn/rongcloud/rtc/utils/ReportUtil$TAG;

    const/4 v3, 0x1

    new-array v4, v3, [Ljava/lang/Object;

    invoke-static/range {p2 .. p2}, Ljava/lang/Boolean;->valueOf(Z)Ljava/lang/Boolean;

    move-result-object v5

    const/4 v6, 0x0

    aput-object v5, v4, v6

    const-string v5, "restartIce"

    invoke-static {v2, v5, v4}, Lcn/rongcloud/rtc/utils/ReportUtil;->libTask(Lcn/rongcloud/rtc/utils/ReportUtil$TAG;Ljava/lang/String;[Ljava/lang/Object;)V

    .line 2
    iget-object v2, v0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mConnection:Lcn/rongcloud/rtc/core/PeerConnection;

    .line 3
    invoke-virtual {p0}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->isAvailable()Z

    move-result v4

    const/4 v5, 0x2

    const-string v13, "code|errorMsg"

    if-nez v4, :cond_3e

    .line 4
    sget-object v2, Lcn/rongcloud/rtc/utils/ReportUtil$TAG;->CREATEOFFER:Lcn/rongcloud/rtc/utils/ReportUtil$TAG;

    new-array v4, v5, [Ljava/lang/Object;

    sget-object v5, Lcn/rongcloud/rtc/base/RTCErrorCode;->RongRTCCodeRTCConnectionIsNull:Lcn/rongcloud/rtc/base/RTCErrorCode;

    invoke-virtual {v5}, Lcn/rongcloud/rtc/base/RTCErrorCode;->getValue()I

    move-result v5

    invoke-static {v5}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;

    move-result-object v5

    aput-object v5, v4, v6

    const-string v5, "PeerConnection Is Null"

    aput-object v5, v4, v3

    invoke-static {v2, v13, v4}, Lcn/rongcloud/rtc/utils/ReportUtil;->libError(Lcn/rongcloud/rtc/utils/ReportUtil$TAG;Ljava/lang/String;[Ljava/lang/Object;)V

    if-eqz v1, :cond_3d

    .line 5
    sget-object v2, Lcn/rongcloud/rtc/base/RTCErrorCode;->RongRTCCodeRTCConnectionIsNull:Lcn/rongcloud/rtc/base/RTCErrorCode;

    invoke-interface {v1, v2}, Lcn/rongcloud/rtc/api/callback/IRCRTCFailedCallback;->onFailed(Lcn/rongcloud/rtc/base/RTCErrorCode;)V

    :cond_3d
    return-void

    :cond_3e
    const-string v4, "RTCConnectionHolder"

    const-string v7, " Create OFFER"

    .line 6
    invoke-static {v4, v7}, Lcn/rongcloud/rtc/utils/FinLog;->d(Ljava/lang/String;Ljava/lang/String;)V

    .line 7
    new-instance v4, Lcn/rongcloud/rtc/webrtc/RTCLocalSdpObserver;

    iget-object v9, v0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mRTCConfig:Lcn/rongcloud/rtc/center/config/RCRTCConfigImpl;

    new-instance v12, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder$2;

    invoke-direct {v12, p0, v1}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder$2;-><init>(Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;Lcn/rongcloud/rtc/api/callback/IRCRTCResultDataCallback;)V

    move-object v7, v4

    move-object v8, p1

    move-object v10, v2

    move/from16 v11, p3

    invoke-direct/range {v7 .. v12}, Lcn/rongcloud/rtc/webrtc/RTCLocalSdpObserver;-><init>(Ljava/lang/String;Lcn/rongcloud/rtc/center/config/RCRTCConfigImpl;Lcn/rongcloud/rtc/core/PeerConnection;ILcn/rongcloud/rtc/webrtc/RTCLocalSdpObserver$RTCSdpLocalSetListener;)V

    .line 8
    invoke-virtual {p0}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->isAvailable()Z

    move-result v7

    if-eqz v7, :cond_66

    move/from16 v7, p2

    .line 9
    invoke-direct {p0, v7}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->getSdpMediaConstraints(Z)Lcn/rongcloud/rtc/core/MediaConstraints;

    move-result-object v1

    invoke-virtual {v2, v4, v1}, Lcn/rongcloud/rtc/core/PeerConnection;->createOffer(Lcn/rongcloud/rtc/core/SdpObserver;Lcn/rongcloud/rtc/core/MediaConstraints;)V

    goto :goto_84

    .line 10
    :cond_66
    sget-object v2, Lcn/rongcloud/rtc/utils/ReportUtil$TAG;->CREATEOFFER:Lcn/rongcloud/rtc/utils/ReportUtil$TAG;

    new-array v4, v5, [Ljava/lang/Object;

    sget-object v5, Lcn/rongcloud/rtc/base/RTCErrorCode;->RongRTCCodeRTCConnectionIsNull:Lcn/rongcloud/rtc/base/RTCErrorCode;

    invoke-virtual {v5}, Lcn/rongcloud/rtc/base/RTCErrorCode;->getValue()I

    move-result v5

    invoke-static {v5}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;

    move-result-object v5

    aput-object v5, v4, v6

    const-string v5, "PeerConnection Is Released"

    aput-object v5, v4, v3

    invoke-static {v2, v13, v4}, Lcn/rongcloud/rtc/utils/ReportUtil;->libError(Lcn/rongcloud/rtc/utils/ReportUtil$TAG;Ljava/lang/String;[Ljava/lang/Object;)V

    if-eqz v1, :cond_84

    .line 11
    sget-object v2, Lcn/rongcloud/rtc/base/RTCErrorCode;->RongRTCCodeRTCConnectionIsNull:Lcn/rongcloud/rtc/base/RTCErrorCode;

    invoke-interface {v1, v2}, Lcn/rongcloud/rtc/api/callback/IRCRTCFailedCallback;->onFailed(Lcn/rongcloud/rtc/base/RTCErrorCode;)V

    :cond_84
    :goto_84
    return-void
.end method

.method private createRongRTCConnectionInternal()V
    .registers 10

    const-string v0, "RTCConnectionHolder"

    const-string v1, "Create RongRTC connection."

    .line 1
    invoke-static {v0, v1}, Lcn/rongcloud/rtc/utils/FinLog;->d(Ljava/lang/String;Ljava/lang/String;)V

    .line 2
    new-instance v1, Lcn/rongcloud/rtc/core/MediaConstraints;

    invoke-direct {v1}, Lcn/rongcloud/rtc/core/MediaConstraints;-><init>()V

    .line 3
    new-instance v2, Ljava/util/ArrayList;

    invoke-direct {v2}, Ljava/util/ArrayList;-><init>()V

    .line 4
    new-instance v3, Lcn/rongcloud/rtc/core/PeerConnection$RTCConfiguration;

    invoke-direct {v3, v2}, Lcn/rongcloud/rtc/core/PeerConnection$RTCConfiguration;-><init>(Ljava/util/List;)V

    .line 5
    sget-object v2, Lcn/rongcloud/rtc/core/PeerConnection$TcpCandidatePolicy;->ENABLED:Lcn/rongcloud/rtc/core/PeerConnection$TcpCandidatePolicy;

    iput-object v2, v3, Lcn/rongcloud/rtc/core/PeerConnection$RTCConfiguration;->tcpCandidatePolicy:Lcn/rongcloud/rtc/core/PeerConnection$TcpCandidatePolicy;

    .line 6
    sget-object v2, Lcn/rongcloud/rtc/core/PeerConnection$BundlePolicy;->MAXBUNDLE:Lcn/rongcloud/rtc/core/PeerConnection$BundlePolicy;

    iput-object v2, v3, Lcn/rongcloud/rtc/core/PeerConnection$RTCConfiguration;->bundlePolicy:Lcn/rongcloud/rtc/core/PeerConnection$BundlePolicy;

    .line 7
    sget-object v2, Lcn/rongcloud/rtc/core/PeerConnection$RtcpMuxPolicy;->REQUIRE:Lcn/rongcloud/rtc/core/PeerConnection$RtcpMuxPolicy;

    iput-object v2, v3, Lcn/rongcloud/rtc/core/PeerConnection$RTCConfiguration;->rtcpMuxPolicy:Lcn/rongcloud/rtc/core/PeerConnection$RtcpMuxPolicy;

    .line 8
    sget-object v2, Lcn/rongcloud/rtc/core/PeerConnection$ContinualGatheringPolicy;->GATHER_CONTINUALLY:Lcn/rongcloud/rtc/core/PeerConnection$ContinualGatheringPolicy;

    iput-object v2, v3, Lcn/rongcloud/rtc/core/PeerConnection$RTCConfiguration;->continualGatheringPolicy:Lcn/rongcloud/rtc/core/PeerConnection$ContinualGatheringPolicy;

    .line 9
    sget-object v2, Lcn/rongcloud/rtc/core/PeerConnection$KeyType;->ECDSA:Lcn/rongcloud/rtc/core/PeerConnection$KeyType;

    iput-object v2, v3, Lcn/rongcloud/rtc/core/PeerConnection$RTCConfiguration;->keyType:Lcn/rongcloud/rtc/core/PeerConnection$KeyType;

    .line 10
    iget-object v2, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mRTCConfig:Lcn/rongcloud/rtc/center/config/RCRTCConfigImpl;

    invoke-virtual {v2}, Lcn/rongcloud/rtc/center/config/RCRTCConfigImpl;->isSRTPEnable()Z

    move-result v2

    const-string v4, "DTLS_SRTP_KEY_AGREEMENT_CONSTRAINT= "

    const-string v5, "DtlsSrtpKeyAgreement"

    if-eqz v2, :cond_60

    .line 11
    sget-object v2, Ljava/lang/Boolean;->TRUE:Ljava/lang/Boolean;

    iput-object v2, v3, Lcn/rongcloud/rtc/core/PeerConnection$RTCConfiguration;->enableDtlsSrtp:Ljava/lang/Boolean;

    .line 12
    iget-object v2, v1, Lcn/rongcloud/rtc/core/MediaConstraints;->optional:Ljava/util/List;

    new-instance v6, Lcn/rongcloud/rtc/core/MediaConstraints$KeyValuePair;

    const/4 v7, 0x1

    .line 13
    invoke-static {v7}, Ljava/lang/String;->valueOf(Z)Ljava/lang/String;

    move-result-object v8

    invoke-direct {v6, v5, v8}, Lcn/rongcloud/rtc/core/MediaConstraints$KeyValuePair;-><init>(Ljava/lang/String;Ljava/lang/String;)V

    .line 14
    invoke-interface {v2, v6}, Ljava/util/List;->add(Ljava/lang/Object;)Z

    .line 15
    new-instance v2, Ljava/lang/StringBuilder;

    invoke-direct {v2}, Ljava/lang/StringBuilder;-><init>()V

    invoke-virtual {v2, v4}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-static {v7}, Ljava/lang/String;->valueOf(Z)Ljava/lang/String;

    move-result-object v4

    invoke-virtual {v2, v4}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {v2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;

    move-result-object v2

    invoke-static {v0, v2}, Lcn/rongcloud/rtc/utils/FinLog;->d(Ljava/lang/String;Ljava/lang/String;)V

    goto :goto_89

    .line 16
    :cond_60
    sget-object v2, Ljava/lang/Boolean;->FALSE:Ljava/lang/Boolean;

    iput-object v2, v3, Lcn/rongcloud/rtc/core/PeerConnection$RTCConfiguration;->enableDtlsSrtp:Ljava/lang/Boolean;

    .line 17
    iget-object v2, v1, Lcn/rongcloud/rtc/core/MediaConstraints;->optional:Ljava/util/List;

    new-instance v6, Lcn/rongcloud/rtc/core/MediaConstraints$KeyValuePair;

    const/4 v7, 0x0

    .line 18
    invoke-static {v7}, Ljava/lang/String;->valueOf(Z)Ljava/lang/String;

    move-result-object v8

    invoke-direct {v6, v5, v8}, Lcn/rongcloud/rtc/core/MediaConstraints$KeyValuePair;-><init>(Ljava/lang/String;Ljava/lang/String;)V

    .line 19
    invoke-interface {v2, v6}, Ljava/util/List;->add(Ljava/lang/Object;)Z

    .line 20
    new-instance v2, Ljava/lang/StringBuilder;

    invoke-direct {v2}, Ljava/lang/StringBuilder;-><init>()V

    invoke-virtual {v2, v4}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-static {v7}, Ljava/lang/String;->valueOf(Z)Ljava/lang/String;

    move-result-object v4

    invoke-virtual {v2, v4}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {v2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;

    move-result-object v2

    invoke-static {v0, v2}, Lcn/rongcloud/rtc/utils/FinLog;->d(Ljava/lang/String;Ljava/lang/String;)V

    .line 21
    :goto_89
    iget-object v2, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->factory:Lcn/rongcloud/rtc/webrtc/PeerConnectionFactoryHolder;

    iget-object v4, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->pcObserver:Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder$PCObserver;

    invoke-virtual {v2, v3, v1, v4}, Lcn/rongcloud/rtc/webrtc/PeerConnectionFactoryHolder;->createPeerConnection(Lcn/rongcloud/rtc/core/PeerConnection$RTCConfiguration;Lcn/rongcloud/rtc/core/MediaConstraints;Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder$PCObserver;)Lcn/rongcloud/rtc/core/PeerConnection;

    move-result-object v1

    iput-object v1, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mConnection:Lcn/rongcloud/rtc/core/PeerConnection;

    .line 22
    new-instance v1, Ljava/lang/StringBuilder;

    invoke-direct {v1}, Ljava/lang/StringBuilder;-><init>()V

    const-string v2, "RongRTC connection created."

    invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    iget-object v2, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mConnection:Lcn/rongcloud/rtc/core/PeerConnection;

    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

    invoke-static {v0, v1}, Lcn/rongcloud/rtc/utils/FinLog;->d(Ljava/lang/String;Ljava/lang/String;)V

    .line 23
    sget-object v0, Lcn/rongcloud/rtc/core/Logging$TraceLevel;->TRACE_DEFAULT:Lcn/rongcloud/rtc/core/Logging$TraceLevel;

    invoke-static {v0}, Ljava/util/EnumSet;->of(Ljava/lang/Enum;)Ljava/util/EnumSet;

    move-result-object v0

    const-string v1, "logcat:"

    invoke-static {v1, v0}, Lcn/rongcloud/rtc/core/Logging;->enableTracing(Ljava/lang/String;Ljava/util/EnumSet;)V

    return-void
.end method

.method private getCurrentSenders()Ljava/util/List;
    .registers 2
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "()",
            "Ljava/util/List<",
            "Lcn/rongcloud/rtc/core/RtpSender;",
            ">;"
        }
    .end annotation

    .line 1
    invoke-virtual {p0}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->isAvailable()Z

    move-result v0

    if-eqz v0, :cond_d

    .line 2
    iget-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mConnection:Lcn/rongcloud/rtc/core/PeerConnection;

    invoke-virtual {v0}, Lcn/rongcloud/rtc/core/PeerConnection;->getCurrentSenders()Ljava/util/List;

    move-result-object v0

    return-object v0

    :cond_d
    const/4 v0, 0x0

    return-object v0
.end method

.method private getSdpMediaConstraints(Z)Lcn/rongcloud/rtc/core/MediaConstraints;
    .registers 7

    .line 1
    new-instance v0, Lcn/rongcloud/rtc/core/MediaConstraints;

    invoke-direct {v0}, Lcn/rongcloud/rtc/core/MediaConstraints;-><init>()V

    .line 2
    iget-object v1, v0, Lcn/rongcloud/rtc/core/MediaConstraints;->mandatory:Ljava/util/List;

    new-instance v2, Lcn/rongcloud/rtc/core/MediaConstraints$KeyValuePair;

    const-string v3, "true"

    const-string v4, "OfferToReceiveVideo"

    invoke-direct {v2, v4, v3}, Lcn/rongcloud/rtc/core/MediaConstraints$KeyValuePair;-><init>(Ljava/lang/String;Ljava/lang/String;)V

    invoke-interface {v1, v2}, Ljava/util/List;->add(Ljava/lang/Object;)Z

    .line 3
    iget-object v1, v0, Lcn/rongcloud/rtc/core/MediaConstraints;->mandatory:Ljava/util/List;

    new-instance v2, Lcn/rongcloud/rtc/core/MediaConstraints$KeyValuePair;

    const-string v4, "OfferToReceiveAudio"

    invoke-direct {v2, v4, v3}, Lcn/rongcloud/rtc/core/MediaConstraints$KeyValuePair;-><init>(Ljava/lang/String;Ljava/lang/String;)V

    invoke-interface {v1, v2}, Ljava/util/List;->add(Ljava/lang/Object;)Z

    const-string v1, "IceRestart"

    if-eqz p1, :cond_2e

    .line 4
    iget-object p1, v0, Lcn/rongcloud/rtc/core/MediaConstraints;->optional:Ljava/util/List;

    new-instance v2, Lcn/rongcloud/rtc/core/MediaConstraints$KeyValuePair;

    invoke-direct {v2, v1, v3}, Lcn/rongcloud/rtc/core/MediaConstraints$KeyValuePair;-><init>(Ljava/lang/String;Ljava/lang/String;)V

    invoke-interface {p1, v2}, Ljava/util/List;->add(Ljava/lang/Object;)Z

    goto :goto_3a

    .line 5
    :cond_2e
    iget-object p1, v0, Lcn/rongcloud/rtc/core/MediaConstraints;->optional:Ljava/util/List;

    new-instance v2, Lcn/rongcloud/rtc/core/MediaConstraints$KeyValuePair;

    const-string v3, "false"

    invoke-direct {v2, v1, v3}, Lcn/rongcloud/rtc/core/MediaConstraints$KeyValuePair;-><init>(Ljava/lang/String;Ljava/lang/String;)V

    invoke-interface {p1, v2}, Ljava/util/List;->add(Ljava/lang/Object;)Z

    :goto_3a
    return-object v0
.end method

.method private getSendersByTrackId(Ljava/lang/String;)Lcn/rongcloud/rtc/core/RtpSender;
    .registers 5

    .line 1
    invoke-direct {p0}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->getCurrentSenders()Ljava/util/List;

    move-result-object v0

    if-eqz v0, :cond_37

    .line 2
    invoke-interface {v0}, Ljava/util/List;->iterator()Ljava/util/Iterator;

    move-result-object v0

    :goto_a
    invoke-interface {v0}, Ljava/util/Iterator;->hasNext()Z

    move-result v1

    if-eqz v1, :cond_2e

    invoke-interface {v0}, Ljava/util/Iterator;->next()Ljava/lang/Object;

    move-result-object v1

    check-cast v1, Lcn/rongcloud/rtc/core/RtpSender;

    .line 3
    invoke-virtual {v1}, Lcn/rongcloud/rtc/core/RtpSender;->track()Lcn/rongcloud/rtc/core/MediaStreamTrack;

    move-result-object v2

    invoke-virtual {v2}, Lcn/rongcloud/rtc/core/MediaStreamTrack;->id()Ljava/lang/String;

    move-result-object v2

    invoke-virtual {v2, p1}, Ljava/lang/String;->equals(Ljava/lang/Object;)Z

    move-result v2

    if-eqz v2, :cond_2a

    .line 4
    iget-object v2, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->cachedRtpSenders:Ljava/util/Map;

    invoke-interface {v2, p1, v1}, Ljava/util/Map;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;

    goto :goto_a

    .line 5
    :cond_2a
    invoke-virtual {v1}, Lcn/rongcloud/rtc/core/RtpSender;->dispose()V

    goto :goto_a

    .line 6
    :cond_2e
    iget-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->cachedRtpSenders:Ljava/util/Map;

    invoke-interface {v0, p1}, Ljava/util/Map;->get(Ljava/lang/Object;)Ljava/lang/Object;

    move-result-object p1

    check-cast p1, Lcn/rongcloud/rtc/core/RtpSender;

    return-object p1

    :cond_37
    const/4 p1, 0x0

    return-object p1
.end method

.method private declared-synchronized onSetRemoteDescription(Lcn/rongcloud/rtc/core/SessionDescription;IILcn/rongcloud/rtc/api/callback/IRCRTCResultCallback;)V
    .registers 11

    monitor-enter p0

    .line 1
    :try_start_1
    sget-object v0, Lcn/rongcloud/rtc/utils/ReportUtil$TAG;->SETREMOTESDP:Lcn/rongcloud/rtc/utils/ReportUtil$TAG;

    const-string v1, "desc"

    const/4 v2, 0x1

    new-array v3, v2, [Ljava/lang/Object;

    const-string v4, "setRemoteSDP"

    const/4 v5, 0x0

    aput-object v4, v3, v5

    invoke-static {v0, v1, v3}, Lcn/rongcloud/rtc/utils/ReportUtil;->libTask(Lcn/rongcloud/rtc/utils/ReportUtil$TAG;Ljava/lang/String;[Ljava/lang/Object;)V

    .line 2
    iget-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mConnection:Lcn/rongcloud/rtc/core/PeerConnection;

    .line 3
    invoke-virtual {p0}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->isAvailable()Z

    move-result v1

    const/4 v3, 0x2

    if-nez v1, :cond_44

    if-eqz v0, :cond_44

    const-string p1, "RTCConnectionHolder"

    const-string p2, "blinkConnection == null\uff0cgive up the setRemoteDescription"

    .line 4
    invoke-static {p1, p2}, Lcn/rongcloud/rtc/utils/FinLog;->e(Ljava/lang/String;Ljava/lang/String;)V

    .line 5
    sget-object p1, Lcn/rongcloud/rtc/utils/ReportUtil$TAG;->SETREMOTESDP:Lcn/rongcloud/rtc/utils/ReportUtil$TAG;

    const-string p2, "code|errorMsg"

    new-array p3, v3, [Ljava/lang/Object;

    sget-object v0, Lcn/rongcloud/rtc/base/RTCErrorCode;->RongRTCCodeRTCConnectionIsNull:Lcn/rongcloud/rtc/base/RTCErrorCode;

    invoke-virtual {v0}, Lcn/rongcloud/rtc/base/RTCErrorCode;->getValue()I

    move-result v0

    invoke-static {v0}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;

    move-result-object v0

    aput-object v0, p3, v5

    const-string v0, "PeerConnection Is Null or Closing"

    aput-object v0, p3, v2

    invoke-static {p1, p2, p3}, Lcn/rongcloud/rtc/utils/ReportUtil;->libError(Lcn/rongcloud/rtc/utils/ReportUtil$TAG;Ljava/lang/String;[Ljava/lang/Object;)V

    if-eqz p4, :cond_42

    .line 6
    sget-object p1, Lcn/rongcloud/rtc/base/RTCErrorCode;->RongRTCCodeRTCConnectionIsNull:Lcn/rongcloud/rtc/base/RTCErrorCode;

    invoke-interface {p4, p1}, Lcn/rongcloud/rtc/api/callback/IRCRTCFailedCallback;->onFailed(Lcn/rongcloud/rtc/base/RTCErrorCode;)V
    :try_end_42
    .catchall {:try_start_1 .. :try_end_42} :catchall_dd

    .line 7
    :cond_42
    monitor-exit p0

    return-void

    .line 8
    :cond_44
    :try_start_44
    iget-object v1, p1, Lcn/rongcloud/rtc/core/SessionDescription;->description:Ljava/lang/String;

    const-string v4, "H264"

    .line 9
    invoke-static {v1, v4, v5, p2, p3}, Lcn/rongcloud/rtc/utils/RTCSDPTools;->preferRemoteCodec(Ljava/lang/String;Ljava/lang/String;ZII)Ljava/lang/String;

    move-result-object p2

    const-string p3, "RTCConnectionHolder"

    .line 10
    new-instance v1, Ljava/lang/StringBuilder;

    invoke-direct {v1}, Ljava/lang/StringBuilder;-><init>()V

    const-string v4, "audioConfig: audio option for remote sdp audio bitrate : "

    invoke-virtual {v1, v4}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    iget-object v4, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mRTCConfig:Lcn/rongcloud/rtc/center/config/RCRTCConfigImpl;

    invoke-virtual {v4}, Lcn/rongcloud/rtc/center/config/RCRTCConfigImpl;->getAudioBitrate()I

    move-result v4

    invoke-virtual {v1, v4}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;

    invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;

    move-result-object v1

    invoke-static {p3, v1}, Lcn/rongcloud/rtc/utils/FinLog;->d(Ljava/lang/String;Ljava/lang/String;)V

    .line 11
    iget-object p3, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mRTCConfig:Lcn/rongcloud/rtc/center/config/RCRTCConfigImpl;

    invoke-virtual {p3}, Lcn/rongcloud/rtc/center/config/RCRTCConfigImpl;->getAudioBitrate()I

    move-result p3

    if-gtz p3, :cond_78

    iget-object p3, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mRTCConfig:Lcn/rongcloud/rtc/center/config/RCRTCConfigImpl;

    invoke-virtual {p3}, Lcn/rongcloud/rtc/center/config/RCRTCConfigImpl;->isStereo()Z

    move-result p3

    if-eqz p3, :cond_8a

    :cond_78
    const-string p3, "opus"

    .line 12
    iget-object v1, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mRTCConfig:Lcn/rongcloud/rtc/center/config/RCRTCConfigImpl;

    invoke-virtual {v1}, Lcn/rongcloud/rtc/center/config/RCRTCConfigImpl;->getAudioBitrate()I

    move-result v1

    iget-object v4, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mRTCConfig:Lcn/rongcloud/rtc/center/config/RCRTCConfigImpl;

    invoke-virtual {v4}, Lcn/rongcloud/rtc/center/config/RCRTCConfigImpl;->isStereo()Z

    move-result v4

    invoke-static {p3, v5, p2, v1, v4}, Lcn/rongcloud/rtc/utils/RTCSDPTools;->setStartBitrate(Ljava/lang/String;ZLjava/lang/String;IZ)Ljava/lang/String;

    move-result-object p2

    .line 13
    :cond_8a
    new-instance p3, Lcn/rongcloud/rtc/core/SessionDescription;

    iget-object p1, p1, Lcn/rongcloud/rtc/core/SessionDescription;->type:Lcn/rongcloud/rtc/core/SessionDescription$Type;

    invoke-direct {p3, p1, p2}, Lcn/rongcloud/rtc/core/SessionDescription;-><init>(Lcn/rongcloud/rtc/core/SessionDescription$Type;Ljava/lang/String;)V

    const-string p1, "RTCConnectionHolder"

    .line 14
    new-instance p2, Ljava/lang/StringBuilder;

    invoke-direct {p2}, Ljava/lang/StringBuilder;-><init>()V

    const-string v1, "setRemoteDescription: \r\n"

    invoke-virtual {p2, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    iget-object v1, p3, Lcn/rongcloud/rtc/core/SessionDescription;->description:Ljava/lang/String;

    invoke-virtual {p2, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {p2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;

    move-result-object p2

    invoke-static {p1, p2}, Lcn/rongcloud/rtc/utils/FinLog;->i(Ljava/lang/String;Ljava/lang/String;)V

    .line 15
    new-instance p1, Lcn/rongcloud/rtc/webrtc/RTCRemoteSdpObserver;

    new-instance p2, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder$4;

    invoke-direct {p2, p0, p4}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder$4;-><init>(Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;Lcn/rongcloud/rtc/api/callback/IRCRTCResultCallback;)V

    invoke-direct {p1, p3, p2}, Lcn/rongcloud/rtc/webrtc/RTCRemoteSdpObserver;-><init>(Lcn/rongcloud/rtc/core/SessionDescription;Lcn/rongcloud/rtc/webrtc/RTCRemoteSdpObserver$SdpSetRemoteListener;)V

    .line 16
    invoke-virtual {p0}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->isAvailable()Z

    move-result p2

    if-eqz p2, :cond_bd

    .line 17
    invoke-virtual {v0, p1, p3}, Lcn/rongcloud/rtc/core/PeerConnection;->setRemoteDescription(Lcn/rongcloud/rtc/core/SdpObserver;Lcn/rongcloud/rtc/core/SessionDescription;)V

    goto :goto_db

    .line 18
    :cond_bd
    sget-object p1, Lcn/rongcloud/rtc/utils/ReportUtil$TAG;->SETREMOTESDP:Lcn/rongcloud/rtc/utils/ReportUtil$TAG;

    const-string p2, "code|errorMsg"

    new-array p3, v3, [Ljava/lang/Object;

    sget-object v0, Lcn/rongcloud/rtc/base/RTCErrorCode;->RongRTCCodeRTCConnectionIsNull:Lcn/rongcloud/rtc/base/RTCErrorCode;

    invoke-virtual {v0}, Lcn/rongcloud/rtc/base/RTCErrorCode;->getValue()I

    move-result v0

    invoke-static {v0}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;

    move-result-object v0

    aput-object v0, p3, v5

    const-string v0, "PeerConnection Is Null or Released"

    aput-object v0, p3, v2

    invoke-static {p1, p2, p3}, Lcn/rongcloud/rtc/utils/ReportUtil;->libError(Lcn/rongcloud/rtc/utils/ReportUtil$TAG;Ljava/lang/String;[Ljava/lang/Object;)V

    .line 19
    sget-object p1, Lcn/rongcloud/rtc/base/RTCErrorCode;->RongRTCCodeRTCConnectionIsNull:Lcn/rongcloud/rtc/base/RTCErrorCode;

    invoke-interface {p4, p1}, Lcn/rongcloud/rtc/api/callback/IRCRTCFailedCallback;->onFailed(Lcn/rongcloud/rtc/base/RTCErrorCode;)V
    :try_end_db
    .catchall {:try_start_44 .. :try_end_db} :catchall_dd

    .line 20
    :goto_db
    monitor-exit p0

    return-void

    :catchall_dd
    move-exception p1

    monitor-exit p0

    throw p1
.end method

.method private releaseCachedRtpSenders()V
    .registers 4

    .line 1
    iget-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->cachedRtpSenders:Ljava/util/Map;

    invoke-interface {v0}, Ljava/util/Map;->keySet()Ljava/util/Set;

    move-result-object v0

    invoke-interface {v0}, Ljava/util/Set;->iterator()Ljava/util/Iterator;

    move-result-object v0

    :goto_a
    invoke-interface {v0}, Ljava/util/Iterator;->hasNext()Z

    move-result v1

    if-eqz v1, :cond_22

    invoke-interface {v0}, Ljava/util/Iterator;->next()Ljava/lang/Object;

    move-result-object v1

    check-cast v1, Ljava/lang/String;

    .line 2
    iget-object v2, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->cachedRtpSenders:Ljava/util/Map;

    invoke-interface {v2, v1}, Ljava/util/Map;->get(Ljava/lang/Object;)Ljava/lang/Object;

    move-result-object v1

    check-cast v1, Lcn/rongcloud/rtc/core/RtpSender;

    .line 3
    invoke-virtual {v1}, Lcn/rongcloud/rtc/core/RtpSender;->dispose()V

    goto :goto_a

    .line 4
    :cond_22
    iget-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->cachedRtpSenders:Ljava/util/Map;

    invoke-interface {v0}, Ljava/util/Map;->clear()V

    const/4 v0, 0x0

    .line 5
    iput-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->cachedRtpSenders:Ljava/util/Map;

    return-void
.end method

.method private setRtpSenderAudioEncryptor(Ljava/lang/String;)V
    .registers 5

    .line 1
    iget-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mRTCConfig:Lcn/rongcloud/rtc/center/config/RCRTCConfigImpl;

    invoke-virtual {v0}, Lcn/rongcloud/rtc/center/config/RCRTCConfigImpl;->isAudioEncryptionEnable()Z

    move-result v0

    if-eqz v0, :cond_39

    .line 2
    invoke-static {}, Lcn/rongcloud/rtc/crypto/CustomFrameEncryptorFactory;->getInstance()Lcn/rongcloud/rtc/crypto/CustomFrameEncryptorFactory;

    move-result-object v0

    .line 3
    invoke-static {}, Lcn/rongcloud/rtc/crypto/CustomFrameEncryptorFactory;->getInstance()Lcn/rongcloud/rtc/crypto/CustomFrameEncryptorFactory;

    move-result-object v1

    if-eqz v1, :cond_39

    .line 4
    invoke-direct {p0, p1}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->getSendersByTrackId(Ljava/lang/String;)Lcn/rongcloud/rtc/core/RtpSender;

    move-result-object p1

    if-eqz p1, :cond_39

    const-string v1, "RTCConnectionHolder"

    const-string v2, "custom_crypto audio setCustomFrameEncryptor"

    .line 5
    invoke-static {v1, v2}, Lcn/rongcloud/rtc/utils/FinLog;->i(Ljava/lang/String;Ljava/lang/String;)V

    .line 6
    invoke-virtual {p1}, Lcn/rongcloud/rtc/core/RtpSender;->track()Lcn/rongcloud/rtc/core/MediaStreamTrack;

    move-result-object v1

    invoke-virtual {v1}, Lcn/rongcloud/rtc/core/MediaStreamTrack;->kind()Ljava/lang/String;

    move-result-object v1

    invoke-virtual {p1}, Lcn/rongcloud/rtc/core/RtpSender;->track()Lcn/rongcloud/rtc/core/MediaStreamTrack;

    move-result-object v2

    invoke-virtual {v2}, Lcn/rongcloud/rtc/core/MediaStreamTrack;->id()Ljava/lang/String;

    move-result-object v2

    invoke-virtual {v0, v1, v2}, Lcn/rongcloud/rtc/crypto/CustomFrameEncryptorFactory;->createCustomAudioFrameEncryptor(Ljava/lang/String;Ljava/lang/String;)Lcn/rongcloud/rtc/crypto/CustomAudioFrameEncryptor;

    move-result-object v1

    invoke-virtual {p1, v1}, Lcn/rongcloud/rtc/core/RtpSender;->setCustomFrameEncryptor(Lcn/rongcloud/rtc/core/FrameEncryptor;)V

    .line 7
    invoke-virtual {p1, v0}, Lcn/rongcloud/rtc/core/RtpSender;->setDisposeObserver(Lcn/rongcloud/rtc/core/RtpSender$DisposeObserver;)V

    :cond_39
    return-void
.end method

.method private setRtpSenderVideoEncryptor(Ljava/lang/String;)V
    .registers 5

    .line 1
    iget-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mRTCConfig:Lcn/rongcloud/rtc/center/config/RCRTCConfigImpl;

    invoke-virtual {v0}, Lcn/rongcloud/rtc/center/config/RCRTCConfigImpl;->isVideoEncryptionEnable()Z

    move-result v0

    if-eqz v0, :cond_39

    .line 2
    invoke-static {}, Lcn/rongcloud/rtc/crypto/CustomFrameEncryptorFactory;->getInstance()Lcn/rongcloud/rtc/crypto/CustomFrameEncryptorFactory;

    move-result-object v0

    .line 3
    invoke-static {}, Lcn/rongcloud/rtc/crypto/CustomFrameEncryptorFactory;->getInstance()Lcn/rongcloud/rtc/crypto/CustomFrameEncryptorFactory;

    move-result-object v1

    if-eqz v1, :cond_39

    .line 4
    invoke-direct {p0, p1}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->getSendersByTrackId(Ljava/lang/String;)Lcn/rongcloud/rtc/core/RtpSender;

    move-result-object p1

    if-eqz p1, :cond_39

    const-string v1, "RTCConnectionHolder"

    const-string v2, "custom_crypto video setCustomFrameEncryptor"

    .line 5
    invoke-static {v1, v2}, Lcn/rongcloud/rtc/utils/FinLog;->i(Ljava/lang/String;Ljava/lang/String;)V

    .line 6
    invoke-virtual {p1}, Lcn/rongcloud/rtc/core/RtpSender;->track()Lcn/rongcloud/rtc/core/MediaStreamTrack;

    move-result-object v1

    invoke-virtual {v1}, Lcn/rongcloud/rtc/core/MediaStreamTrack;->kind()Ljava/lang/String;

    move-result-object v1

    invoke-virtual {p1}, Lcn/rongcloud/rtc/core/RtpSender;->track()Lcn/rongcloud/rtc/core/MediaStreamTrack;

    move-result-object v2

    invoke-virtual {v2}, Lcn/rongcloud/rtc/core/MediaStreamTrack;->id()Ljava/lang/String;

    move-result-object v2

    invoke-virtual {v0, v1, v2}, Lcn/rongcloud/rtc/crypto/CustomFrameEncryptorFactory;->createCustomVideoFrameEncryptor(Ljava/lang/String;Ljava/lang/String;)Lcn/rongcloud/rtc/crypto/CustomVideoFrameEncryptor;

    move-result-object v1

    invoke-virtual {p1, v1}, Lcn/rongcloud/rtc/core/RtpSender;->setCustomFrameEncryptor(Lcn/rongcloud/rtc/core/FrameEncryptor;)V

    .line 7
    invoke-virtual {p1, v0}, Lcn/rongcloud/rtc/core/RtpSender;->setDisposeObserver(Lcn/rongcloud/rtc/core/RtpSender$DisposeObserver;)V

    :cond_39
    return-void
.end method


# virtual methods
.method public addStream(Lcn/rongcloud/rtc/core/MediaStream;)Z
    .registers 4

    .line 1
    iget-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mConnectionLock:Ljava/lang/Object;

    monitor-enter v0

    .line 2
    :try_start_3
    invoke-virtual {p0}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->isAvailable()Z

    move-result v1

    if-eqz v1, :cond_1c

    .line 3
    iget-object v1, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mConnection:Lcn/rongcloud/rtc/core/PeerConnection;

    invoke-virtual {v1, p1}, Lcn/rongcloud/rtc/core/PeerConnection;->containStream(Lcn/rongcloud/rtc/core/MediaStream;)Z

    move-result v1

    if-eqz v1, :cond_14

    const/4 p1, 0x1

    .line 4
    monitor-exit v0

    return p1

    .line 5
    :cond_14
    iget-object v1, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mConnection:Lcn/rongcloud/rtc/core/PeerConnection;

    invoke-virtual {v1, p1}, Lcn/rongcloud/rtc/core/PeerConnection;->addStream(Lcn/rongcloud/rtc/core/MediaStream;)Z

    move-result p1

    monitor-exit v0

    return p1

    :cond_1c
    const/4 p1, 0x0

    .line 6
    monitor-exit v0

    return p1

    :catchall_1f
    move-exception p1

    .line 7
    monitor-exit v0
    :try_end_21
    .catchall {:try_start_3 .. :try_end_21} :catchall_1f

    throw p1
.end method

.method public bindStreamEncryption(Lcn/rongcloud/rtc/core/MediaStreamTrack;)V
    .registers 4

    .line 1
    iget-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mRTCConfig:Lcn/rongcloud/rtc/center/config/RCRTCConfigImpl;

    invoke-virtual {v0}, Lcn/rongcloud/rtc/center/config/RCRTCConfigImpl;->isAudioEncryptionEnable()Z

    move-result v0

    if-eqz v0, :cond_1c

    invoke-virtual {p1}, Lcn/rongcloud/rtc/core/MediaStreamTrack;->kind()Ljava/lang/String;

    move-result-object v0

    const-string v1, "audio"

    invoke-virtual {v1, v0}, Ljava/lang/String;->equals(Ljava/lang/Object;)Z

    move-result v0

    if-eqz v0, :cond_1c

    .line 2
    invoke-virtual {p1}, Lcn/rongcloud/rtc/core/MediaStreamTrack;->id()Ljava/lang/String;

    move-result-object p1

    invoke-direct {p0, p1}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->setRtpSenderAudioEncryptor(Ljava/lang/String;)V

    return-void

    .line 3
    :cond_1c
    iget-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mRTCConfig:Lcn/rongcloud/rtc/center/config/RCRTCConfigImpl;

    invoke-virtual {v0}, Lcn/rongcloud/rtc/center/config/RCRTCConfigImpl;->isVideoEncryptionEnable()Z

    move-result v0

    if-eqz v0, :cond_38

    invoke-virtual {p1}, Lcn/rongcloud/rtc/core/MediaStreamTrack;->kind()Ljava/lang/String;

    move-result-object v0

    const-string/jumbo v1, "video"

    invoke-virtual {v1, v0}, Ljava/lang/String;->equals(Ljava/lang/Object;)Z

    move-result v0

    if-eqz v0, :cond_38

    .line 4
    invoke-virtual {p1}, Lcn/rongcloud/rtc/core/MediaStreamTrack;->id()Ljava/lang/String;

    move-result-object p1

    invoke-direct {p0, p1}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->setRtpSenderVideoEncryptor(Ljava/lang/String;)V

    :cond_38
    return-void
.end method

.method public everOfferIsCreated()Z
    .registers 2

    .line 1
    iget-boolean v0, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->everOfferIsCreated:Z

    return v0
.end method

.method public getMediaStream(Ljava/lang/String;)Lcn/rongcloud/rtc/core/MediaStream;
    .registers 4

    .line 1
    iget-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mConnectionLock:Ljava/lang/Object;

    monitor-enter v0

    .line 2
    :try_start_3
    invoke-virtual {p0}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->isAvailable()Z

    move-result v1

    if-eqz v1, :cond_11

    .line 3
    iget-object v1, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mConnection:Lcn/rongcloud/rtc/core/PeerConnection;

    invoke-virtual {v1, p1}, Lcn/rongcloud/rtc/core/PeerConnection;->getStream(Ljava/lang/String;)Lcn/rongcloud/rtc/core/MediaStream;

    move-result-object p1

    monitor-exit v0

    return-object p1

    .line 4
    :cond_11
    monitor-exit v0

    const/4 p1, 0x0

    return-object p1

    :catchall_14
    move-exception p1

    monitor-exit v0
    :try_end_16
    .catchall {:try_start_3 .. :try_end_16} :catchall_14

    throw p1
.end method

.method public getPublishedStreamSize()I
    .registers 3

    .line 1
    iget-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mConnectionLock:Ljava/lang/Object;

    monitor-enter v0

    .line 2
    :try_start_3
    invoke-virtual {p0}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->isAvailable()Z

    move-result v1

    if-eqz v1, :cond_11

    .line 3
    iget-object v1, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mConnection:Lcn/rongcloud/rtc/core/PeerConnection;

    invoke-virtual {v1}, Lcn/rongcloud/rtc/core/PeerConnection;->getStreamSize()I

    move-result v1

    monitor-exit v0

    return v1

    .line 4
    :cond_11
    monitor-exit v0

    const/4 v0, 0x0

    return v0

    :catchall_14
    move-exception v1

    monitor-exit v0
    :try_end_16
    .catchall {:try_start_3 .. :try_end_16} :catchall_14

    throw v1
.end method

.method public getStatus(Lcn/rongcloud/rtc/core/StatsObserver;)Z
    .registers 5

    .line 1
    iget-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mConnectionLock:Ljava/lang/Object;

    monitor-enter v0

    .line 2
    :try_start_3
    invoke-virtual {p0}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->isAvailable()Z

    move-result v1

    if-eqz v1, :cond_12

    .line 3
    iget-object v1, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mConnection:Lcn/rongcloud/rtc/core/PeerConnection;

    const/4 v2, 0x0

    invoke-virtual {v1, p1, v2}, Lcn/rongcloud/rtc/core/PeerConnection;->getStats(Lcn/rongcloud/rtc/core/StatsObserver;Lcn/rongcloud/rtc/core/MediaStreamTrack;)Z

    move-result p1

    monitor-exit v0

    return p1

    .line 4
    :cond_12
    monitor-exit v0

    const/4 p1, 0x0

    return p1

    :catchall_15
    move-exception p1

    monitor-exit v0
    :try_end_17
    .catchall {:try_start_3 .. :try_end_17} :catchall_15

    throw p1
.end method

.method public isAvailable()Z
    .registers 2

    .line 1
    iget-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mConnection:Lcn/rongcloud/rtc/core/PeerConnection;

    if-eqz v0, :cond_c

    invoke-virtual {v0}, Lcn/rongcloud/rtc/core/PeerConnection;->isClose()Z

    move-result v0

    if-nez v0, :cond_c

    const/4 v0, 0x1

    goto :goto_d

    :cond_c
    const/4 v0, 0x0

    :goto_d
    return v0
.end method

.method public release()V
    .registers 5

    const-string v0, "RTCConnectionHolder"

    const-string v1, "release start"

    .line 1
    invoke-static {v0, v1}, Lcn/rongcloud/rtc/utils/FinLog;->d(Ljava/lang/String;Ljava/lang/String;)V

    const/4 v0, 0x0

    .line 2
    iput-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->events:Lcn/rongcloud/rtc/webrtc/RTCConnectionEvents;

    .line 3
    iget-object v1, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mConnectionLock:Ljava/lang/Object;

    monitor-enter v1

    .line 4
    :try_start_d
    invoke-virtual {p0}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->isAvailable()Z

    move-result v2

    if-nez v2, :cond_1c

    const-string v0, "RTCConnectionHolder"

    const-string v2, "PeerConnection Not Available"

    .line 5
    invoke-static {v0, v2}, Lcn/rongcloud/rtc/utils/FinLog;->d(Ljava/lang/String;Ljava/lang/String;)V

    .line 6
    monitor-exit v1

    return-void

    :cond_1c
    const-string v2, "RTCConnectionHolder"

    const-string v3, "real release PeerConnection"

    .line 7
    invoke-static {v2, v3}, Lcn/rongcloud/rtc/utils/FinLog;->d(Ljava/lang/String;Ljava/lang/String;)V

    .line 8
    invoke-direct {p0}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->releaseCachedRtpSenders()V

    .line 9
    iget-object v2, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mConnection:Lcn/rongcloud/rtc/core/PeerConnection;

    if-eqz v2, :cond_2f

    .line 10
    iget-object v2, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mConnection:Lcn/rongcloud/rtc/core/PeerConnection;

    invoke-virtual {v2}, Lcn/rongcloud/rtc/core/PeerConnection;->dispose()V

    .line 11
    :cond_2f
    invoke-static {}, Lcn/rongcloud/rtc/crypto/CustomFrameDecryptorFactory;->getInstance()Lcn/rongcloud/rtc/crypto/CustomFrameDecryptorFactory;

    move-result-object v2

    invoke-virtual {v2}, Lcn/rongcloud/rtc/crypto/CustomFrameDecryptorFactory;->release()V

    .line 12
    invoke-static {}, Lcn/rongcloud/rtc/crypto/CustomFrameEncryptorFactory;->getInstance()Lcn/rongcloud/rtc/crypto/CustomFrameEncryptorFactory;

    move-result-object v2

    invoke-virtual {v2}, Lcn/rongcloud/rtc/crypto/CustomFrameEncryptorFactory;->release()V

    .line 13
    iput-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mConnection:Lcn/rongcloud/rtc/core/PeerConnection;

    const/4 v0, 0x0

    .line 14
    iput-boolean v0, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->everOfferIsCreated:Z

    .line 15
    monitor-exit v1
    :try_end_43
    .catchall {:try_start_d .. :try_end_43} :catchall_4b

    const-string v0, "RTCConnectionHolder"

    const-string v1, "release end"

    .line 16
    invoke-static {v0, v1}, Lcn/rongcloud/rtc/utils/FinLog;->d(Ljava/lang/String;Ljava/lang/String;)V

    return-void

    :catchall_4b
    move-exception v0

    .line 17
    :try_start_4c
    monitor-exit v1
    :try_end_4d
    .catchall {:try_start_4c .. :try_end_4d} :catchall_4b

    throw v0
.end method

.method public removeStream(Lcn/rongcloud/rtc/core/MediaStream;)V
    .registers 4

    .line 1
    iget-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mConnectionLock:Ljava/lang/Object;

    monitor-enter v0

    .line 2
    :try_start_3
    invoke-virtual {p0}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->isAvailable()Z

    move-result v1

    if-eqz v1, :cond_e

    .line 3
    iget-object v1, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mConnection:Lcn/rongcloud/rtc/core/PeerConnection;

    invoke-virtual {v1, p1}, Lcn/rongcloud/rtc/core/PeerConnection;->removeStream(Lcn/rongcloud/rtc/core/MediaStream;)V

    .line 4
    :cond_e
    monitor-exit v0

    return-void

    :catchall_10
    move-exception p1

    monitor-exit v0
    :try_end_12
    .catchall {:try_start_3 .. :try_end_12} :catchall_10

    throw p1
.end method

.method public syncCreateAndSetOffer(Ljava/lang/String;ZI)Lcn/rongcloud/rtc/base/AsyncResult;
    .registers 8
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Ljava/lang/String;",
            "ZI)",
            "Lcn/rongcloud/rtc/base/AsyncResult<",
            "Lcn/rongcloud/rtc/core/SessionDescription;",
            ">;"
        }
    .end annotation

    .line 1
    invoke-static {}, Ljava/lang/Thread;->currentThread()Ljava/lang/Thread;

    move-result-object v0

    sget-object v1, Lcn/rongcloud/rtc/base/RTCErrorCode;->CANCEL_OPERATOR:Lcn/rongcloud/rtc/base/RTCErrorCode;

    invoke-static {v0, v1}, Lcn/rongcloud/rtc/base/AsyncResult;->create(Ljava/lang/Thread;Lcn/rongcloud/rtc/base/RTCErrorCode;)Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;

    move-result-object v0

    if-eqz p2, :cond_19

    .line 2
    sget-object v1, Lcn/rongcloud/rtc/utils/ReportUtil$TAG;->RESETICE:Lcn/rongcloud/rtc/utils/ReportUtil$TAG;

    const/4 v2, 0x1

    new-array v2, v2, [Ljava/lang/Object;

    const/4 v3, 0x0

    aput-object p1, v2, v3

    const-string v3, "roomId"

    invoke-static {v1, v3, v2}, Lcn/rongcloud/rtc/utils/ReportUtil;->libTask(Lcn/rongcloud/rtc/utils/ReportUtil$TAG;Ljava/lang/String;[Ljava/lang/Object;)V

    .line 3
    :cond_19
    new-instance v1, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder$1;

    invoke-direct {v1, p0, p2, p1, v0}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder$1;-><init>(Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;ZLjava/lang/String;Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;)V

    invoke-direct {p0, p1, p2, p3, v1}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->createAndSetOffer(Ljava/lang/String;ZILcn/rongcloud/rtc/api/callback/IRCRTCResultDataCallback;)V

    .line 4
    invoke-virtual {v0}, Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;->waitForGetResult()Lcn/rongcloud/rtc/base/AsyncResult;

    move-result-object p1

    return-object p1
.end method

.method public syncCreateAnswer(Ljava/lang/String;)Lcn/rongcloud/rtc/base/AsyncResult;
    .registers 8

    .line 1
    invoke-static {}, Ljava/lang/Thread;->currentThread()Ljava/lang/Thread;

    move-result-object v0

    sget-object v1, Lcn/rongcloud/rtc/base/RTCErrorCode;->CANCEL_OPERATOR:Lcn/rongcloud/rtc/base/RTCErrorCode;

    invoke-static {v0, v1}, Lcn/rongcloud/rtc/base/AsyncResult;->create(Ljava/lang/Thread;Lcn/rongcloud/rtc/base/RTCErrorCode;)Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;

    move-result-object v0

    .line 2
    sget-object v1, Lcn/rongcloud/rtc/utils/ReportUtil$TAG;->CREATEANSWER:Lcn/rongcloud/rtc/utils/ReportUtil$TAG;

    const/4 v2, 0x1

    new-array v3, v2, [Ljava/lang/Object;

    const/4 v4, 0x0

    aput-object p1, v3, v4

    const-string v5, "roomId"

    invoke-static {v1, v5, v3}, Lcn/rongcloud/rtc/utils/ReportUtil;->libTask(Lcn/rongcloud/rtc/utils/ReportUtil$TAG;Ljava/lang/String;[Ljava/lang/Object;)V

    .line 3
    invoke-virtual {p0}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->isAvailable()Z

    move-result v1

    if-eqz v1, :cond_34

    .line 4
    iget-object v1, p0, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->mConnection:Lcn/rongcloud/rtc/core/PeerConnection;

    new-instance v2, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder$AnswerSdpObserver;

    new-instance v3, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder$5;

    invoke-direct {v3, p0, v0}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder$5;-><init>(Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;)V

    invoke-direct {v2, p0, p1, v3}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder$AnswerSdpObserver;-><init>(Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;Ljava/lang/String;Lcn/rongcloud/rtc/api/callback/IRCRTCResultCallback;)V

    .line 5
    invoke-direct {p0, v4}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->getSdpMediaConstraints(Z)Lcn/rongcloud/rtc/core/MediaConstraints;

    move-result-object p1

    .line 6
    invoke-virtual {v1, v2, p1}, Lcn/rongcloud/rtc/core/PeerConnection;->createAnswer(Lcn/rongcloud/rtc/core/SdpObserver;Lcn/rongcloud/rtc/core/MediaConstraints;)V

    .line 7
    invoke-static {}, Ljava/util/concurrent/locks/LockSupport;->park()V

    goto :goto_53

    .line 8
    :cond_34
    sget-object p1, Lcn/rongcloud/rtc/base/RTCErrorCode;->RongRTCCodeRTCTokenIsNull:Lcn/rongcloud/rtc/base/RTCErrorCode;

    invoke-virtual {v0, p1}, Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;->setAndNotify(Lcn/rongcloud/rtc/base/RTCErrorCode;)V

    .line 9
    sget-object p1, Lcn/rongcloud/rtc/utils/ReportUtil$TAG;->CREATEANSWER:Lcn/rongcloud/rtc/utils/ReportUtil$TAG;

    const/4 v1, 0x2

    new-array v1, v1, [Ljava/lang/Object;

    sget-object v3, Lcn/rongcloud/rtc/base/RTCErrorCode;->RongRTCCodeRTCConnectionIsNull:Lcn/rongcloud/rtc/base/RTCErrorCode;

    invoke-virtual {v3}, Lcn/rongcloud/rtc/base/RTCErrorCode;->getValue()I

    move-result v3

    invoke-static {v3}, Ljava/lang/Integer;->valueOf(I)Ljava/lang/Integer;

    move-result-object v3

    aput-object v3, v1, v4

    const-string v3, "PeerConnection Is Released"

    aput-object v3, v1, v2

    const-string v2, "code|errorMsg"

    invoke-static {p1, v2, v1}, Lcn/rongcloud/rtc/utils/ReportUtil;->libError(Lcn/rongcloud/rtc/utils/ReportUtil$TAG;Ljava/lang/String;[Ljava/lang/Object;)V

    .line 10
    :goto_53
    invoke-virtual {v0}, Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;->getResult()Lcn/rongcloud/rtc/base/AsyncResult;

    move-result-object p1

    return-object p1
.end method

.method public syncSetRemoteDescription(Lcn/rongcloud/rtc/core/SessionDescription;II)Lcn/rongcloud/rtc/base/AsyncResult;
    .registers 6

    .line 1
    invoke-static {}, Ljava/lang/Thread;->currentThread()Ljava/lang/Thread;

    move-result-object v0

    sget-object v1, Lcn/rongcloud/rtc/base/RTCErrorCode;->CANCEL_OPERATOR:Lcn/rongcloud/rtc/base/RTCErrorCode;

    invoke-static {v0, v1}, Lcn/rongcloud/rtc/base/AsyncResult;->create(Ljava/lang/Thread;Lcn/rongcloud/rtc/base/RTCErrorCode;)Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;

    move-result-object v0

    .line 2
    new-instance v1, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder$3;

    invoke-direct {v1, p0, v0}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder$3;-><init>(Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;)V

    invoke-direct {p0, p1, p2, p3, v1}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->onSetRemoteDescription(Lcn/rongcloud/rtc/core/SessionDescription;IILcn/rongcloud/rtc/api/callback/IRCRTCResultCallback;)V

    .line 3
    invoke-virtual {v0}, Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;->waitForGetResult()Lcn/rongcloud/rtc/base/AsyncResult;

    move-result-object p1

    return-object p1
.end method