RTCPubSubManager.smali
.class public Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;
.super Ljava/lang/Object;
.source "RTCPubSubManager.java"
# static fields
.field private static final TAG:Ljava/lang/String; = "RTCPubSubManager"
# instance fields
.field private mFactoryManager:Lcn/rongcloud/rtc/webrtc/PeerConnectionFactoryHolder;
.field private mMaxStreamCount:I
.field private mRTCConnection:Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;
.field private mReportManager:Lcn/rongcloud/rtc/api/report/RTCStatusReportManager;
.field private mTaskQueue:Lcn/rongcloud/rtc/webrtc/task/PubSubTaskQueue;
.field private mUserId:Ljava/lang/String;
# direct methods
.method protected constructor <init>(Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;Ljava/lang/String;Lcn/rongcloud/rtc/webrtc/PeerConnectionFactoryHolder;ILcn/rongcloud/rtc/api/report/RTCStatusReportManager;)V
.registers 6
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/lang/NullPointerException;
}
.end annotation
.line 1
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
.line 2
iput-object p1, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mRTCConnection:Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;
.line 3
iput-object p2, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mUserId:Ljava/lang/String;
.line 4
iput-object p3, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mFactoryManager:Lcn/rongcloud/rtc/webrtc/PeerConnectionFactoryHolder;
.line 5
iput p4, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mMaxStreamCount:I
.line 6
new-instance p1, Lcn/rongcloud/rtc/webrtc/task/PubSubTaskQueue;
invoke-direct {p1}, Lcn/rongcloud/rtc/webrtc/task/PubSubTaskQueue;-><init>()V
iput-object p1, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mTaskQueue:Lcn/rongcloud/rtc/webrtc/task/PubSubTaskQueue;
.line 7
iput-object p5, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mReportManager:Lcn/rongcloud/rtc/api/report/RTCStatusReportManager;
return-void
.end method
.method static synthetic access$000(Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;ZLjava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)Lcn/rongcloud/rtc/base/AsyncResult;
.registers 5
.line 1
invoke-direct {p0, p1, p2, p3, p4}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->syncReConnected(ZLjava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p0
return-object p0
.end method
.method static synthetic access$100(Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;ZLjava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)Lcn/rongcloud/rtc/base/AsyncResult;
.registers 5
.line 1
invoke-direct {p0, p1, p2, p3, p4}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->syncExchangeRemoteSDP(ZLjava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p0
return-object p0
.end method
.method static synthetic access$200(Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;Ljava/util/List;Ljava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)Lcn/rongcloud/rtc/base/AsyncResult;
.registers 5
.line 1
invoke-direct {p0, p1, p2, p3, p4}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->syncUnpublishedStreams(Ljava/util/List;Ljava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p0
return-object p0
.end method
.method static synthetic access$300(Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;Ljava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)Lcn/rongcloud/rtc/base/AsyncResult;
.registers 4
.line 1
invoke-direct {p0, p1, p2, p3}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->syncSubscribeStreams(Ljava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p0
return-object p0
.end method
.method static synthetic access$400(Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;Ljava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)Lcn/rongcloud/rtc/base/AsyncResult;
.registers 4
.line 1
invoke-direct {p0, p1, p2, p3}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->syncExchangeVideoSize(Ljava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p0
return-object p0
.end method
.method private getAndCreateLocalMediaStream(Ljava/lang/String;)Lcn/rongcloud/rtc/core/MediaStream;
.registers 3
.line 1
iget-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mRTCConnection:Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;
invoke-virtual {v0, p1}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->getMediaStream(Ljava/lang/String;)Lcn/rongcloud/rtc/core/MediaStream;
move-result-object v0
if-eqz v0, :cond_9
return-object v0
.line 2
:cond_9
iget-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mFactoryManager:Lcn/rongcloud/rtc/webrtc/PeerConnectionFactoryHolder;
invoke-virtual {v0, p1}, Lcn/rongcloud/rtc/webrtc/PeerConnectionFactoryHolder;->createLocalMediaStream(Ljava/lang/String;)Lcn/rongcloud/rtc/core/MediaStream;
move-result-object p1
return-object p1
.end method
.method private getExchangeSDPDataResult(Ljava/lang/String;Lcn/rongcloud/rtc/base/RCRTCRoomType;Lcn/rongcloud/rtc/base/AsyncResult;Ljava/util/List;)Lcn/rongcloud/rtc/base/AsyncResult;
.registers 9
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/lang/String;",
"Lcn/rongcloud/rtc/base/RCRTCRoomType;",
"Lcn/rongcloud/rtc/base/AsyncResult<",
"Landroid/util/Pair<",
"Ljava/util/List<",
"Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;",
">;",
"Lorg/json/JSONObject;",
">;>;",
"Ljava/util/List<",
"Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;",
">;)",
"Lcn/rongcloud/rtc/base/AsyncResult<",
"Landroid/util/Pair<",
"Ljava/util/List<",
"Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;",
">;",
"Lcn/rongcloud/rtc/api/stream/RCRTCLiveInfo;",
">;>;"
}
.end annotation
const-string v0, "liveUrl"
.line 1
invoke-static {}, Lcn/rongcloud/rtc/base/AsyncResult;->create()Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;
move-result-object v1
.line 2
sget-object v2, Lcn/rongcloud/rtc/base/RCRTCRoomType;->MEETING:Lcn/rongcloud/rtc/base/RCRTCRoomType;
const/4 v3, 0x0
if-eq p2, v2, :cond_4c
.line 3
invoke-virtual {p3}, Lcn/rongcloud/rtc/base/AsyncResult;->getData()Ljava/lang/Object;
move-result-object p2
check-cast p2, Landroid/util/Pair;
iget-object p2, p2, Landroid/util/Pair;->second:Ljava/lang/Object;
check-cast p2, Lorg/json/JSONObject;
if-eqz p2, :cond_46
.line 4
:try_start_17
invoke-virtual {p2, v0}, Lorg/json/JSONObject;->has(Ljava/lang/String;)Z
move-result p3
if-eqz p3, :cond_21
invoke-virtual {p2, v0}, Lorg/json/JSONObject;->getString(Ljava/lang/String;)Ljava/lang/String;
move-result-object v3
.line 5
:cond_21
new-instance p3, Lcn/rongcloud/rtc/center/stream/RCRTCLiveInfoImpl;
iget-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mUserId:Ljava/lang/String;
const-string v2, "configUrl"
invoke-virtual {p2, v2}, Lorg/json/JSONObject;->optString(Ljava/lang/String;)Ljava/lang/String;
move-result-object p2
invoke-direct {p3, p1, v3, v0, p2}, Lcn/rongcloud/rtc/center/stream/RCRTCLiveInfoImpl;-><init>(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V
.line 6
invoke-static {p4, p3}, Landroid/util/Pair;->create(Ljava/lang/Object;Ljava/lang/Object;)Landroid/util/Pair;
move-result-object p1
invoke-virtual {v1, p1}, Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;->setAndNotify(Ljava/lang/Object;)V
:try_end_35
.catch Ljava/lang/Exception; {:try_start_17 .. :try_end_35} :catch_36
goto :goto_53
:catch_36
move-exception p1
.line 7
invoke-virtual {p1}, Ljava/lang/Exception;->getMessage()Ljava/lang/String;
move-result-object p1
const-string p2, "RTCPubSubManager"
invoke-static {p2, p1}, Lcn/rongcloud/rtc/utils/FinLog;->e(Ljava/lang/String;Ljava/lang/String;)V
.line 8
sget-object p1, Lcn/rongcloud/rtc/base/RTCErrorCode;->JsonParseError:Lcn/rongcloud/rtc/base/RTCErrorCode;
invoke-virtual {v1, p1}, Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;->setAndNotify(Lcn/rongcloud/rtc/base/RTCErrorCode;)V
goto :goto_53
.line 9
:cond_46
sget-object p1, Lcn/rongcloud/rtc/base/RTCErrorCode;->LiveInfoIsNull:Lcn/rongcloud/rtc/base/RTCErrorCode;
invoke-virtual {v1, p1}, Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;->setAndNotify(Lcn/rongcloud/rtc/base/RTCErrorCode;)V
goto :goto_53
.line 10
:cond_4c
invoke-static {p4, v3}, Landroid/util/Pair;->create(Ljava/lang/Object;Ljava/lang/Object;)Landroid/util/Pair;
move-result-object p1
invoke-virtual {v1, p1}, Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;->setAndNotify(Ljava/lang/Object;)V
.line 11
:goto_53
invoke-virtual {v1}, Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;->getResult()Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p1
return-object p1
.end method
.method private isAllowPubSub()Z
.registers 2
.line 1
iget-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mRTCConnection:Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;
if-eqz v0, :cond_10
invoke-virtual {v0}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->isAvailable()Z
move-result v0
if-eqz v0, :cond_10
iget-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mFactoryManager:Lcn/rongcloud/rtc/webrtc/PeerConnectionFactoryHolder;
if-eqz v0, :cond_10
const/4 v0, 0x1
goto :goto_11
:cond_10
const/4 v0, 0x0
:goto_11
return v0
.end method
.method private isEmpty(Ljava/util/List;)Z
.registers 2
if-eqz p1, :cond_b
.line 1
invoke-interface {p1}, Ljava/util/List;->isEmpty()Z
move-result p1
if-eqz p1, :cond_9
goto :goto_b
:cond_9
const/4 p1, 0x0
goto :goto_c
:cond_b
:goto_b
const/4 p1, 0x1
:goto_c
return p1
.end method
.method private mediaResourceInfoListToJson(Ljava/util/List;)Ljava/lang/String;
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/util/List<",
"Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;",
">;)",
"Ljava/lang/String;"
}
.end annotation
if-eqz p1, :cond_24
.line 1
new-instance v0, Lorg/json/JSONArray;
invoke-direct {v0}, Lorg/json/JSONArray;-><init>()V
.line 2
invoke-interface {p1}, Ljava/util/List;->iterator()Ljava/util/Iterator;
move-result-object p1
:goto_b
invoke-interface {p1}, Ljava/util/Iterator;->hasNext()Z
move-result v1
if-eqz v1, :cond_1f
invoke-interface {p1}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v1
check-cast v1, Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;
.line 3
invoke-virtual {v1}, Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;->getJsonObject()Lorg/json/JSONObject;
move-result-object v1
invoke-virtual {v0, v1}, Lorg/json/JSONArray;->put(Ljava/lang/Object;)Lorg/json/JSONArray;
goto :goto_b
.line 4
:cond_1f
invoke-virtual {v0}, Lorg/json/JSONArray;->toString()Ljava/lang/String;
move-result-object p1
goto :goto_26
:cond_24
const-string p1, "[]"
:goto_26
return-object p1
.end method
.method private onPublishFailed(Ljava/lang/String;Lcn/rongcloud/rtc/base/RTCErrorCode;Ljava/util/List;)Lcn/rongcloud/rtc/base/AsyncResult;
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/lang/String;",
"Lcn/rongcloud/rtc/base/RTCErrorCode;",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;)",
"Lcn/rongcloud/rtc/base/AsyncResult;"
}
.end annotation
.line 1
invoke-direct {p0}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->isAllowPubSub()Z
move-result p1
if-eqz p1, :cond_b
.line 2
iget-object p1, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mRTCConnection:Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;
.line 3
invoke-direct {p0, p3, p1}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->removeStreams(Ljava/util/List;Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;)V
.line 4
:cond_b
invoke-static {p2}, Lcn/rongcloud/rtc/base/AsyncResult;->create(Lcn/rongcloud/rtc/base/RTCErrorCode;)Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;
move-result-object p1
invoke-virtual {p1}, Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;->getResult()Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p1
return-object p1
.end method
.method private removeStreams(Ljava/util/List;Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;)V
.registers 7
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;",
")V"
}
.end annotation
.line 1
invoke-interface {p1}, Ljava/util/List;->iterator()Ljava/util/Iterator;
move-result-object p1
:cond_4
:goto_4
invoke-interface {p1}, Ljava/util/Iterator;->hasNext()Z
move-result v0
if-eqz v0, :cond_39
invoke-interface {p1}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v0
check-cast v0, Lcn/rongcloud/rtc/webrtc/IStreamResource;
.line 2
invoke-interface {v0}, Lcn/rongcloud/rtc/webrtc/IStreamResource;->getStreamId()Ljava/lang/String;
move-result-object v1
invoke-virtual {p2, v1}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->getMediaStream(Ljava/lang/String;)Lcn/rongcloud/rtc/core/MediaStream;
move-result-object v1
.line 3
invoke-interface {v0}, Lcn/rongcloud/rtc/webrtc/IStreamResource;->getTrack()Lcn/rongcloud/rtc/core/MediaStreamTrack;
move-result-object v0
if-eqz v1, :cond_4
if-eqz v0, :cond_2c
.line 4
iget-object v2, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mReportManager:Lcn/rongcloud/rtc/api/report/RTCStatusReportManager;
invoke-virtual {v0}, Lcn/rongcloud/rtc/core/MediaStreamTrack;->id()Ljava/lang/String;
move-result-object v3
invoke-virtual {v2, v3}, Lcn/rongcloud/rtc/api/report/RTCStatusReportManager;->removeReport(Ljava/lang/String;)V
.line 5
invoke-virtual {v1, v0}, Lcn/rongcloud/rtc/core/MediaStream;->removeTrack(Lcn/rongcloud/rtc/core/MediaStreamTrack;)V
.line 6
:cond_2c
invoke-virtual {v1}, Lcn/rongcloud/rtc/core/MediaStream;->getAllTrackSize()I
move-result v0
if-nez v0, :cond_4
.line 7
invoke-virtual {p2, v1}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->removeStream(Lcn/rongcloud/rtc/core/MediaStream;)V
.line 8
invoke-virtual {v1}, Lcn/rongcloud/rtc/core/MediaStream;->dispose()V
goto :goto_4
:cond_39
return-void
.end method
.method private syncExchangeRemoteSDP(ZLjava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)Lcn/rongcloud/rtc/base/AsyncResult;
.registers 20
.annotation system Ldalvik/annotation/Signature;
value = {
"(Z",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Lcn/rongcloud/rtc/webrtc/MediaCommonParams;",
")",
"Lcn/rongcloud/rtc/base/AsyncResult<",
"Landroid/util/Pair<",
"Ljava/util/List<",
"Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;",
">;",
"Lorg/json/JSONObject;",
">;>;"
}
.end annotation
move-object v0, p0
move-object/from16 v1, p4
.line 1
iget-object v2, v0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mRTCConnection:Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;
.line 2
invoke-direct {p0}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->isAllowPubSub()Z
move-result v3
if-nez v3, :cond_16
.line 3
sget-object v1, Lcn/rongcloud/rtc/base/RTCErrorCode;->RongRTCCodeRTCConnectionIsNull:Lcn/rongcloud/rtc/base/RTCErrorCode;
invoke-static {v1}, Lcn/rongcloud/rtc/base/AsyncResult;->create(Lcn/rongcloud/rtc/base/RTCErrorCode;)Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;
move-result-object v1
invoke-virtual {v1}, Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;->getResult()Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object v1
return-object v1
.line 4
:cond_16
invoke-static/range {p2 .. p2}, Lcn/rongcloud/rtc/utils/RTCSDPTools;->getTotalMaxBitRate(Ljava/util/List;)I
move-result v3
.line 5
iget-object v4, v1, Lcn/rongcloud/rtc/webrtc/MediaCommonParams;->roomId:Ljava/lang/String;
move/from16 v5, p1
invoke-virtual {v2, v4, v5, v3}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->syncCreateAndSetOffer(Ljava/lang/String;ZI)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object v4
.line 6
invoke-virtual {v4}, Lcn/rongcloud/rtc/base/AsyncResult;->isFailed()Z
move-result v5
if-eqz v5, :cond_2c
.line 7
invoke-static {v4}, Lcn/rongcloud/rtc/base/AsyncResult;->convert(Lcn/rongcloud/rtc/base/AsyncResult;)Lcn/rongcloud/rtc/base/AsyncResult;
return-object v4
.line 8
:cond_2c
invoke-static {}, Lcn/rongcloud/rtc/signal/SignalManager;->getInstance()Lcn/rongcloud/rtc/signal/SignalManager;
move-result-object v6
iget-object v7, v1, Lcn/rongcloud/rtc/webrtc/MediaCommonParams;->roomId:Ljava/lang/String;
invoke-virtual {v4}, Lcn/rongcloud/rtc/base/AsyncResult;->getData()Ljava/lang/Object;
move-result-object v4
move-object v8, v4
check-cast v8, Lcn/rongcloud/rtc/core/SessionDescription;
iget-object v9, v1, Lcn/rongcloud/rtc/webrtc/MediaCommonParams;->clientSessionId:Ljava/lang/String;
iget-object v12, v1, Lcn/rongcloud/rtc/webrtc/MediaCommonParams;->roomType:Lcn/rongcloud/rtc/base/RCRTCRoomType;
iget-object v13, v1, Lcn/rongcloud/rtc/webrtc/MediaCommonParams;->autoMixJSONInfo:Ljava/lang/String;
iget-object v14, v1, Lcn/rongcloud/rtc/webrtc/MediaCommonParams;->role:Ljava/lang/String;
move-object/from16 v10, p2
move-object/from16 v11, p3
invoke-virtual/range {v6 .. v14}, Lcn/rongcloud/rtc/signal/SignalManager;->syncSendSDPOffer(Ljava/lang/String;Lcn/rongcloud/rtc/core/SessionDescription;Ljava/lang/String;Ljava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/base/RCRTCRoomType;Ljava/lang/String;Ljava/lang/String;)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object v1
.line 9
invoke-virtual {v1}, Lcn/rongcloud/rtc/base/AsyncResult;->isFailed()Z
move-result v4
if-eqz v4, :cond_53
.line 10
invoke-static {v1}, Lcn/rongcloud/rtc/base/AsyncResult;->convert(Lcn/rongcloud/rtc/base/AsyncResult;)Lcn/rongcloud/rtc/base/AsyncResult;
return-object v1
.line 11
:cond_53
invoke-direct {p0}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->isAllowPubSub()Z
move-result v4
if-nez v4, :cond_64
.line 12
sget-object v1, Lcn/rongcloud/rtc/base/RTCErrorCode;->RongRTCCodeRTCConnectionIsNull:Lcn/rongcloud/rtc/base/RTCErrorCode;
invoke-static {v1}, Lcn/rongcloud/rtc/base/AsyncResult;->create(Lcn/rongcloud/rtc/base/RTCErrorCode;)Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;
move-result-object v1
invoke-virtual {v1}, Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;->getResult()Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object v1
return-object v1
.line 13
:cond_64
invoke-virtual {v1}, Lcn/rongcloud/rtc/base/AsyncResult;->getData()Ljava/lang/Object;
move-result-object v4
check-cast v4, [Ljava/lang/Object;
const/4 v5, 0x0
aget-object v4, v4, v5
check-cast v4, Lcn/rongcloud/rtc/core/SessionDescription;
.line 14
invoke-static/range {p2 .. p2}, Lcn/rongcloud/rtc/utils/RTCSDPTools;->getTotalMinBitRate(Ljava/util/List;)I
move-result v5
.line 15
invoke-virtual {v2, v4, v3, v5}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->syncSetRemoteDescription(Lcn/rongcloud/rtc/core/SessionDescription;II)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object v2
.line 16
invoke-virtual {v2}, Lcn/rongcloud/rtc/base/AsyncResult;->isFailed()Z
move-result v3
if-eqz v3, :cond_81
.line 17
invoke-static {v2}, Lcn/rongcloud/rtc/base/AsyncResult;->convert(Lcn/rongcloud/rtc/base/AsyncResult;)Lcn/rongcloud/rtc/base/AsyncResult;
return-object v2
.line 18
:cond_81
invoke-virtual {v1}, Lcn/rongcloud/rtc/base/AsyncResult;->getData()Ljava/lang/Object;
move-result-object v2
check-cast v2, [Ljava/lang/Object;
const/4 v3, 0x1
aget-object v2, v2, v3
check-cast v2, Ljava/util/List;
.line 19
invoke-interface/range {p2 .. p2}, Ljava/util/List;->iterator()Ljava/util/Iterator;
move-result-object v3
:cond_90
:goto_90
invoke-interface {v3}, Ljava/util/Iterator;->hasNext()Z
move-result v4
if-eqz v4, :cond_cc
invoke-interface {v3}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v4
check-cast v4, Lcn/rongcloud/rtc/webrtc/IStreamResource;
.line 20
invoke-interface {v2}, Ljava/util/List;->iterator()Ljava/util/Iterator;
move-result-object v5
:cond_a0
invoke-interface {v5}, Ljava/util/Iterator;->hasNext()Z
move-result v6
if-eqz v6, :cond_90
invoke-interface {v5}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v6
check-cast v6, Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;
.line 21
invoke-virtual {v6}, Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;->getTag()Ljava/lang/String;
move-result-object v7
invoke-interface {v4}, Lcn/rongcloud/rtc/webrtc/IStreamResource;->getTag()Ljava/lang/String;
move-result-object v8
invoke-static {v7, v8}, Landroid/text/TextUtils;->equals(Ljava/lang/CharSequence;Ljava/lang/CharSequence;)Z
move-result v7
if-eqz v7, :cond_a0
invoke-virtual {v6}, Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;->getType()Lcn/rongcloud/rtc/base/RCRTCMediaType;
move-result-object v7
invoke-interface {v4}, Lcn/rongcloud/rtc/webrtc/IStreamResource;->getMediaType()Lcn/rongcloud/rtc/base/RCRTCMediaType;
move-result-object v8
if-ne v7, v8, :cond_a0
.line 22
invoke-interface {v4}, Lcn/rongcloud/rtc/webrtc/IStreamResource;->getResourceState()Lcn/rongcloud/rtc/base/RCRTCResourceState;
move-result-object v4
invoke-virtual {v6, v4}, Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;->setRCRTCResourceState(Lcn/rongcloud/rtc/base/RCRTCResourceState;)V
goto :goto_90
:cond_cc
const/4 v3, 0x0
.line 23
invoke-virtual {v1}, Lcn/rongcloud/rtc/base/AsyncResult;->getData()Ljava/lang/Object;
move-result-object v4
check-cast v4, [Ljava/lang/Object;
array-length v4, v4
const/4 v5, 0x2
if-le v4, v5, :cond_e2
.line 24
invoke-virtual {v1}, Lcn/rongcloud/rtc/base/AsyncResult;->getData()Ljava/lang/Object;
move-result-object v1
check-cast v1, [Ljava/lang/Object;
aget-object v1, v1, v5
move-object v3, v1
check-cast v3, Lorg/json/JSONObject;
.line 25
:cond_e2
invoke-static {v2, v3}, Landroid/util/Pair;->create(Ljava/lang/Object;Ljava/lang/Object;)Landroid/util/Pair;
move-result-object v1
invoke-static {v1}, Lcn/rongcloud/rtc/base/AsyncResult;->create(Ljava/lang/Object;)Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;
move-result-object v1
invoke-virtual {v1}, Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;->getResult()Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object v1
return-object v1
.end method
.method private syncExchangeVideoSize(Ljava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)Lcn/rongcloud/rtc/base/AsyncResult;
.registers 6
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Ljava/util/List<",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Lcn/rongcloud/rtc/webrtc/MediaCommonParams;",
")",
"Lcn/rongcloud/rtc/base/AsyncResult;"
}
.end annotation
const/4 v0, 0x0
.line 1
invoke-direct {p0, v0, p1, p2, p3}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->syncExchangeRemoteSDP(ZLjava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p2
.line 2
invoke-virtual {p2}, Lcn/rongcloud/rtc/base/AsyncResult;->isFailed()Z
move-result v0
if-eqz v0, :cond_c
return-object p2
.line 3
:cond_c
invoke-static {}, Lcn/rongcloud/rtc/signal/SignalManager;->getInstance()Lcn/rongcloud/rtc/signal/SignalManager;
move-result-object p2
iget-object v0, p3, Lcn/rongcloud/rtc/webrtc/MediaCommonParams;->roomId:Ljava/lang/String;
iget-object v1, p3, Lcn/rongcloud/rtc/webrtc/MediaCommonParams;->roomType:Lcn/rongcloud/rtc/base/RCRTCRoomType;
iget-object p3, p3, Lcn/rongcloud/rtc/webrtc/MediaCommonParams;->clientSessionId:Ljava/lang/String;
invoke-virtual {p2, v0, v1, p3, p1}, Lcn/rongcloud/rtc/signal/SignalManager;->syncResolutionChanged(Ljava/lang/String;Lcn/rongcloud/rtc/base/RCRTCRoomType;Ljava/lang/String;Ljava/util/List;)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p1
return-object p1
.end method
.method private syncReConnected(ZLjava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)Lcn/rongcloud/rtc/base/AsyncResult;
.registers 7
.annotation system Ldalvik/annotation/Signature;
value = {
"(Z",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Lcn/rongcloud/rtc/webrtc/MediaCommonParams;",
")",
"Lcn/rongcloud/rtc/base/AsyncResult<",
"Landroid/util/Pair<",
"Ljava/util/List<",
"Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;",
">;",
"Lcn/rongcloud/rtc/api/stream/RCRTCLiveInfo;",
">;>;"
}
.end annotation
const/4 v0, 0x1
.line 1
invoke-direct {p0, v0, p2, p3, p4}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->syncExchangeRemoteSDP(ZLjava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p3
.line 2
invoke-virtual {p3}, Lcn/rongcloud/rtc/base/AsyncResult;->isFailed()Z
move-result v0
if-eqz v0, :cond_f
.line 3
invoke-static {p3}, Lcn/rongcloud/rtc/base/AsyncResult;->convert(Lcn/rongcloud/rtc/base/AsyncResult;)Lcn/rongcloud/rtc/base/AsyncResult;
return-object p3
.line 4
:cond_f
invoke-virtual {p3}, Lcn/rongcloud/rtc/base/AsyncResult;->getData()Ljava/lang/Object;
move-result-object v0
check-cast v0, Landroid/util/Pair;
iget-object v0, v0, Landroid/util/Pair;->first:Ljava/lang/Object;
check-cast v0, Ljava/util/List;
.line 5
iget-object v1, p4, Lcn/rongcloud/rtc/webrtc/MediaCommonParams;->roomId:Ljava/lang/String;
invoke-static {v1, p1, v0, p2}, Lcn/rongcloud/rtc/proxy/ReConnectTool;->sendSourceMessage(Ljava/lang/String;ZLjava/util/List;Ljava/util/List;)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p1
.line 6
invoke-virtual {p1}, Lcn/rongcloud/rtc/base/AsyncResult;->isFailed()Z
move-result p2
if-eqz p2, :cond_29
.line 7
invoke-static {p1}, Lcn/rongcloud/rtc/base/AsyncResult;->convert(Lcn/rongcloud/rtc/base/AsyncResult;)Lcn/rongcloud/rtc/base/AsyncResult;
return-object p1
.line 8
:cond_29
iget-object p1, p4, Lcn/rongcloud/rtc/webrtc/MediaCommonParams;->roomId:Ljava/lang/String;
iget-object p2, p4, Lcn/rongcloud/rtc/webrtc/MediaCommonParams;->roomType:Lcn/rongcloud/rtc/base/RCRTCRoomType;
invoke-direct {p0, p1, p2, p3, v0}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->getExchangeSDPDataResult(Ljava/lang/String;Lcn/rongcloud/rtc/base/RCRTCRoomType;Lcn/rongcloud/rtc/base/AsyncResult;Ljava/util/List;)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p1
return-object p1
.end method
.method private syncSendIMSignal(Ljava/lang/String;Ljava/util/List;Ljava/util/List;Ljava/util/List;)Lcn/rongcloud/rtc/base/AsyncResult;
.registers 12
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/lang/String;",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Ljava/util/List<",
"Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;",
">;)",
"Lcn/rongcloud/rtc/base/AsyncResult;"
}
.end annotation
.line 1
invoke-static {p4, p2}, Lcn/rongcloud/rtc/utils/ResourceTools;->getUnpubJSON(Ljava/util/List;Ljava/util/List;)Lcn/rongcloud/rtc/utils/ResourceTools$RepublishInfo;
move-result-object p2
.line 2
invoke-direct {p0, p4}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mediaResourceInfoListToJson(Ljava/util/List;)Ljava/lang/String;
move-result-object v0
.line 3
new-instance v1, Ljava/util/ArrayList;
invoke-direct {v1}, Ljava/util/ArrayList;-><init>()V
.line 4
invoke-direct {p0, p3}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->isEmpty(Ljava/util/List;)Z
move-result v2
if-nez v2, :cond_4f
.line 5
invoke-interface {p3}, Ljava/util/List;->iterator()Ljava/util/Iterator;
move-result-object p3
:cond_17
:goto_17
invoke-interface {p3}, Ljava/util/Iterator;->hasNext()Z
move-result v2
if-eqz v2, :cond_4f
invoke-interface {p3}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v2
check-cast v2, Lcn/rongcloud/rtc/webrtc/IStreamResource;
.line 6
invoke-interface {p4}, Ljava/util/List;->iterator()Ljava/util/Iterator;
move-result-object v3
:cond_27
invoke-interface {v3}, Ljava/util/Iterator;->hasNext()Z
move-result v4
if-eqz v4, :cond_17
invoke-interface {v3}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v4
check-cast v4, Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;
.line 7
invoke-interface {v2}, Lcn/rongcloud/rtc/webrtc/IStreamResource;->getMediaType()Lcn/rongcloud/rtc/base/RCRTCMediaType;
move-result-object v5
invoke-virtual {v4}, Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;->getType()Lcn/rongcloud/rtc/base/RCRTCMediaType;
move-result-object v6
if-ne v5, v6, :cond_27
invoke-interface {v2}, Lcn/rongcloud/rtc/webrtc/IStreamResource;->getTag()Ljava/lang/String;
move-result-object v5
invoke-virtual {v4}, Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;->getTag()Ljava/lang/String;
move-result-object v6
invoke-static {v5, v6}, Landroid/text/TextUtils;->equals(Ljava/lang/CharSequence;Ljava/lang/CharSequence;)Z
move-result v5
if-eqz v5, :cond_27
.line 8
invoke-virtual {v1, v4}, Ljava/util/ArrayList;->add(Ljava/lang/Object;)Z
goto :goto_17
:cond_4f
const/4 p3, 0x1
.line 9
new-array p4, p3, [Lio/rong/imlib/model/RTCStatusDate;
const-string v2, "uris"
.line 10
invoke-static {v2, v0}, Lcn/rongcloud/rtc/utils/ResourceTools;->getStatusDate(Ljava/lang/String;Ljava/lang/String;)Lio/rong/imlib/model/RTCStatusDate;
move-result-object v0
const/4 v2, 0x0
aput-object v0, p4, v2
const-string v0, ""
const-string v3, "RCRTC:PublishResource"
if-eqz p2, :cond_a6
.line 11
new-instance v4, Ljava/lang/StringBuilder;
invoke-direct {v4}, Ljava/lang/StringBuilder;-><init>()V
const-string v5, "publishResource()->needUnpub:"
invoke-virtual {v4, v5}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {p2}, Lcn/rongcloud/rtc/utils/ResourceTools$RepublishInfo;->getUnpub_JSON()Ljava/lang/String;
move-result-object v5
invoke-virtual {v4, v5}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v4}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v4
const-string v5, "RTCPubSubManager"
invoke-static {v5, v4}, Lcn/rongcloud/rtc/utils/FinLog;->e(Ljava/lang/String;Ljava/lang/String;)V
const/4 v4, 0x2
.line 12
new-array v4, v4, [Lio/rong/imlib/model/RTCStatusDate;
.line 13
invoke-virtual {p2}, Lcn/rongcloud/rtc/utils/ResourceTools$RepublishInfo;->getUnpub_JSON()Ljava/lang/String;
move-result-object v5
const-string v6, "RCRTC:UnpublishResource"
invoke-static {v6, v5}, Lcn/rongcloud/rtc/utils/ResourceTools;->getStatusDate(Ljava/lang/String;Ljava/lang/String;)Lio/rong/imlib/model/RTCStatusDate;
move-result-object v5
aput-object v5, v4, v2
.line 14
invoke-virtual {p2}, Lcn/rongcloud/rtc/utils/ResourceTools$RepublishInfo;->getRepubList()Ljava/util/List;
move-result-object v2
invoke-interface {v2}, Ljava/util/List;->size()I
move-result v2
if-lez v2, :cond_9b
.line 15
invoke-virtual {p2}, Lcn/rongcloud/rtc/utils/ResourceTools$RepublishInfo;->getRepubList()Ljava/util/List;
move-result-object p2
invoke-virtual {v1, p2}, Ljava/util/ArrayList;->addAll(Ljava/util/Collection;)Z
.line 16
:cond_9b
invoke-static {v1, p3, v0}, Lcn/rongcloud/rtc/utils/ResourceTools;->getURIS(Ljava/util/List;ZLjava/lang/String;)Ljava/lang/String;
move-result-object p2
invoke-static {v3, p2}, Lcn/rongcloud/rtc/utils/ResourceTools;->getStatusDate(Ljava/lang/String;Ljava/lang/String;)Lio/rong/imlib/model/RTCStatusDate;
move-result-object p2
aput-object p2, v4, p3
goto :goto_b2
.line 17
:cond_a6
new-array v4, p3, [Lio/rong/imlib/model/RTCStatusDate;
.line 18
invoke-static {v1, p3, v0}, Lcn/rongcloud/rtc/utils/ResourceTools;->getURIS(Ljava/util/List;ZLjava/lang/String;)Ljava/lang/String;
move-result-object p2
invoke-static {v3, p2}, Lcn/rongcloud/rtc/utils/ResourceTools;->getStatusDate(Ljava/lang/String;Ljava/lang/String;)Lio/rong/imlib/model/RTCStatusDate;
move-result-object p2
aput-object p2, v4, v2
.line 19
:goto_b2
invoke-static {}, Lcn/rongcloud/rtc/signal/SignalManager;->getInstance()Lcn/rongcloud/rtc/signal/SignalManager;
move-result-object p2
const-string p3, "RCRTC:TotalContentResources"
invoke-virtual {p2, p1, p4, p3, v4}, Lcn/rongcloud/rtc/signal/SignalManager;->syncRTCSetUserResource(Ljava/lang/String;[Lio/rong/imlib/model/RTCStatusDate;Ljava/lang/String;[Lio/rong/imlib/model/RTCStatusDate;)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p1
return-object p1
.end method
.method private syncSubscribeStreams(Ljava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)Lcn/rongcloud/rtc/base/AsyncResult;
.registers 9
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Lcn/rongcloud/rtc/webrtc/MediaCommonParams;",
")",
"Lcn/rongcloud/rtc/base/AsyncResult;"
}
.end annotation
.line 1
invoke-static {}, Ljava/lang/System;->currentTimeMillis()J
move-result-wide v0
const-string v2, "RTCPubSubManager"
const-string v3, "subscribeResources() run"
.line 2
invoke-static {v2, v3}, Lcn/rongcloud/rtc/utils/FinLog;->d(Ljava/lang/String;Ljava/lang/String;)V
.line 3
invoke-direct {p0}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->isAllowPubSub()Z
move-result v3
if-nez v3, :cond_1c
.line 4
sget-object p1, Lcn/rongcloud/rtc/base/RTCErrorCode;->RongRTCCodeRTCConnectionIsNull:Lcn/rongcloud/rtc/base/RTCErrorCode;
invoke-static {p1}, Lcn/rongcloud/rtc/base/AsyncResult;->create(Lcn/rongcloud/rtc/base/RTCErrorCode;)Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;
move-result-object p1
invoke-virtual {p1}, Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;->getResult()Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p1
return-object p1
:cond_1c
const/4 v3, 0x0
.line 5
invoke-virtual {p0, p1, p2, v3, p3}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->subscribeRemoteSDP(Ljava/util/List;Ljava/util/List;ZLcn/rongcloud/rtc/webrtc/MediaCommonParams;)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p1
.line 6
invoke-virtual {p1}, Lcn/rongcloud/rtc/base/AsyncResult;->isFailed()Z
move-result p2
if-eqz p2, :cond_40
.line 7
new-instance p2, Ljava/lang/StringBuilder;
invoke-direct {p2}, Ljava/lang/StringBuilder;-><init>()V
const-string p3, "subscribeResources onFailed() errorCode: "
invoke-virtual {p2, p3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {p1}, Lcn/rongcloud/rtc/base/AsyncResult;->getErrorCode()Lcn/rongcloud/rtc/base/RTCErrorCode;
move-result-object p3
invoke-virtual {p2, p3}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invoke-virtual {p2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object p2
invoke-static {v2, p2}, Lcn/rongcloud/rtc/utils/FinLog;->e(Ljava/lang/String;Ljava/lang/String;)V
goto :goto_59
.line 8
:cond_40
invoke-static {}, Ljava/lang/System;->currentTimeMillis()J
move-result-wide p2
.line 9
new-instance v3, Ljava/lang/StringBuilder;
invoke-direct {v3}, Ljava/lang/StringBuilder;-><init>()V
const-string v4, "subscribeResources onSuccess() costTime = "
invoke-virtual {v3, v4}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
sub-long/2addr p2, v0
invoke-virtual {v3, p2, p3}, Ljava/lang/StringBuilder;->append(J)Ljava/lang/StringBuilder;
invoke-virtual {v3}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object p2
invoke-static {v2, p2}, Lcn/rongcloud/rtc/utils/FinLog;->d(Ljava/lang/String;Ljava/lang/String;)V
:goto_59
return-object p1
.end method
.method private syncUnpublishedStreams(Ljava/util/List;Ljava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)Lcn/rongcloud/rtc/base/AsyncResult;
.registers 12
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Lcn/rongcloud/rtc/webrtc/MediaCommonParams<",
"Ljava/util/List<",
"Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;",
">;>;)",
"Lcn/rongcloud/rtc/base/AsyncResult<",
"Ljava/util/List<",
"Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;",
">;>;"
}
.end annotation
const-string v0, "RTCPubSubManager"
const-string v1, "syncUnpublishedStreams"
.line 1
invoke-static {v0, v1}, Landroid/util/Log;->i(Ljava/lang/String;Ljava/lang/String;)I
.line 2
invoke-direct {p0}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->isAllowPubSub()Z
move-result v1
if-nez v1, :cond_18
.line 3
sget-object p1, Lcn/rongcloud/rtc/base/RTCErrorCode;->RongRTCCodeRTCConnectionIsNull:Lcn/rongcloud/rtc/base/RTCErrorCode;
invoke-static {p1}, Lcn/rongcloud/rtc/base/AsyncResult;->create(Lcn/rongcloud/rtc/base/RTCErrorCode;)Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;
move-result-object p1
invoke-virtual {p1}, Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;->getResult()Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p1
return-object p1
.line 4
:cond_18
iget-object v1, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mRTCConnection:Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;
invoke-direct {p0, p3, v1}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->removeStreams(Ljava/util/List;Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;)V
const/4 v1, 0x0
.line 5
invoke-direct {p0, v1, p1, p2, p4}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->syncExchangeRemoteSDP(ZLjava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p2
.line 6
invoke-virtual {p2}, Lcn/rongcloud/rtc/base/AsyncResult;->isFailed()Z
move-result v2
if-eqz v2, :cond_2c
.line 7
invoke-static {p2}, Lcn/rongcloud/rtc/base/AsyncResult;->convert(Lcn/rongcloud/rtc/base/AsyncResult;)Lcn/rongcloud/rtc/base/AsyncResult;
return-object p2
.line 8
:cond_2c
invoke-virtual {p2}, Lcn/rongcloud/rtc/base/AsyncResult;->getData()Ljava/lang/Object;
move-result-object p2
check-cast p2, Landroid/util/Pair;
iget-object p2, p2, Landroid/util/Pair;->first:Ljava/lang/Object;
check-cast p2, Ljava/util/List;
.line 9
invoke-direct {p0, p2}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mediaResourceInfoListToJson(Ljava/util/List;)Ljava/lang/String;
move-result-object v2
.line 10
new-instance v3, Ljava/lang/StringBuilder;
invoke-direct {v3}, Ljava/lang/StringBuilder;-><init>()V
const-string v4, "publish = "
invoke-virtual {v3, v4}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v3, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v3}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v3
invoke-static {v0, v3}, Lcn/rongcloud/rtc/utils/FinLog;->d(Ljava/lang/String;Ljava/lang/String;)V
.line 11
invoke-static {p2, p1}, Lcn/rongcloud/rtc/utils/ResourceTools;->getUnpubJSON(Ljava/util/List;Ljava/util/List;)Lcn/rongcloud/rtc/utils/ResourceTools$RepublishInfo;
move-result-object p1
const/4 v0, 0x1
.line 12
new-array v3, v0, [Lio/rong/imlib/model/RTCStatusDate;
const-string v4, "uris"
.line 13
invoke-static {v4, v2}, Lcn/rongcloud/rtc/utils/ResourceTools;->getStatusDate(Ljava/lang/String;Ljava/lang/String;)Lio/rong/imlib/model/RTCStatusDate;
move-result-object v2
aput-object v2, v3, v1
.line 14
new-instance v2, Ljava/util/ArrayList;
invoke-direct {v2}, Ljava/util/ArrayList;-><init>()V
.line 15
invoke-interface {p3}, Ljava/util/List;->iterator()Ljava/util/Iterator;
move-result-object v4
:goto_66
invoke-interface {v4}, Ljava/util/Iterator;->hasNext()Z
move-result v5
if-eqz v5, :cond_7b
invoke-interface {v4}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v5
check-cast v5, Lcn/rongcloud/rtc/webrtc/IStreamResource;
.line 16
new-instance v6, Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;
invoke-direct {v6, v5}, Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;-><init>(Lcn/rongcloud/rtc/webrtc/IStreamResource;)V
invoke-interface {v2, v6}, Ljava/util/List;->add(Ljava/lang/Object;)Z
goto :goto_66
:cond_7b
const-string v4, "RCRTC:UnpublishResource"
const-string v5, ""
if-eqz p1, :cond_a2
const/4 v6, 0x2
.line 17
new-array v6, v6, [Lio/rong/imlib/model/RTCStatusDate;
.line 18
invoke-virtual {p1}, Lcn/rongcloud/rtc/utils/ResourceTools$RepublishInfo;->getNeedUnpublist()Ljava/util/List;
move-result-object p1
invoke-interface {v2, p1}, Ljava/util/List;->addAll(Ljava/util/Collection;)Z
.line 19
invoke-static {v2, v0, v5}, Lcn/rongcloud/rtc/utils/ResourceTools;->getURIS(Ljava/util/List;ZLjava/lang/String;)Ljava/lang/String;
move-result-object p1
invoke-static {v4, p1}, Lcn/rongcloud/rtc/utils/ResourceTools;->getStatusDate(Ljava/lang/String;Ljava/lang/String;)Lio/rong/imlib/model/RTCStatusDate;
move-result-object p1
aput-object p1, v6, v1
.line 20
invoke-static {v2, v0, v5}, Lcn/rongcloud/rtc/utils/ResourceTools;->getURIS(Ljava/util/List;ZLjava/lang/String;)Ljava/lang/String;
move-result-object p1
const-string v2, "RCRTC:PublishResource"
invoke-static {v2, p1}, Lcn/rongcloud/rtc/utils/ResourceTools;->getStatusDate(Ljava/lang/String;Ljava/lang/String;)Lio/rong/imlib/model/RTCStatusDate;
move-result-object p1
aput-object p1, v6, v0
goto :goto_ae
.line 21
:cond_a2
new-array v6, v0, [Lio/rong/imlib/model/RTCStatusDate;
.line 22
invoke-static {v2, v0, v5}, Lcn/rongcloud/rtc/utils/ResourceTools;->getURIS(Ljava/util/List;ZLjava/lang/String;)Ljava/lang/String;
move-result-object p1
invoke-static {v4, p1}, Lcn/rongcloud/rtc/utils/ResourceTools;->getStatusDate(Ljava/lang/String;Ljava/lang/String;)Lio/rong/imlib/model/RTCStatusDate;
move-result-object p1
aput-object p1, v6, v1
.line 23
:goto_ae
invoke-static {}, Lcn/rongcloud/rtc/signal/SignalManager;->getInstance()Lcn/rongcloud/rtc/signal/SignalManager;
move-result-object p1
iget-object p4, p4, Lcn/rongcloud/rtc/webrtc/MediaCommonParams;->roomId:Ljava/lang/String;
const-string v0, "RCRTC:TotalContentResources"
invoke-virtual {p1, p4, v3, v0, v6}, Lcn/rongcloud/rtc/signal/SignalManager;->syncRTCSetUserResource(Ljava/lang/String;[Lio/rong/imlib/model/RTCStatusDate;Ljava/lang/String;[Lio/rong/imlib/model/RTCStatusDate;)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p1
.line 24
invoke-virtual {p1}, Lcn/rongcloud/rtc/base/AsyncResult;->isFailed()Z
move-result p4
if-eqz p4, :cond_c1
return-object p1
.line 25
:cond_c1
sget-object p1, Lcn/rongcloud/rtc/stat/RongRtcStatMagr;->instance:Lcn/rongcloud/rtc/stat/RongRtcStatMagr;
invoke-virtual {p1, v1, p3}, Lcn/rongcloud/rtc/stat/RongRtcStatMagr;->reportPublish(ZLjava/util/List;)V
.line 26
invoke-static {p2}, Lcn/rongcloud/rtc/base/AsyncResult;->create(Ljava/lang/Object;)Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;
move-result-object p1
invoke-virtual {p1}, Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;->getResult()Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p1
return-object p1
.end method
# virtual methods
.method public clearTask()V
.registers 2
.line 1
iget-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mTaskQueue:Lcn/rongcloud/rtc/webrtc/task/PubSubTaskQueue;
if-eqz v0, :cond_7
.line 2
invoke-virtual {v0}, Lcn/rongcloud/rtc/webrtc/task/PubSubTaskQueue;->clearTask()V
:cond_7
return-void
.end method
.method public exchangeRemoteSDP(ZLjava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)V
.registers 13
.annotation system Ldalvik/annotation/Signature;
value = {
"(Z",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Lcn/rongcloud/rtc/webrtc/MediaCommonParams<",
"Landroid/util/Pair<",
"Ljava/util/List<",
"Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;",
">;",
"Lorg/json/JSONObject;",
">;>;)V"
}
.end annotation
.line 1
new-instance v7, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager$3;
iget-object v2, p4, Lcn/rongcloud/rtc/webrtc/MediaCommonParams;->callback:Lcn/rongcloud/rtc/api/callback/IRCRTCFailedCallback;
move-object v0, v7
move-object v1, p0
move v3, p1
move-object v4, p2
move-object v5, p3
move-object v6, p4
invoke-direct/range {v0 .. v6}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager$3;-><init>(Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;Lcn/rongcloud/rtc/api/callback/IRCRTCFailedCallback;ZLjava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)V
invoke-virtual {p0, v7}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->offerTask(Lcn/rongcloud/rtc/webrtc/task/PubSubTask;)V
return-void
.end method
.method public exchangeVideoSize(Ljava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)V
.registers 11
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Ljava/util/List<",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Lcn/rongcloud/rtc/webrtc/MediaCommonParams;",
")V"
}
.end annotation
.line 1
new-instance v6, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager$8;
iget-object v2, p3, Lcn/rongcloud/rtc/webrtc/MediaCommonParams;->callback:Lcn/rongcloud/rtc/api/callback/IRCRTCFailedCallback;
move-object v0, v6
move-object v1, p0
move-object v3, p1
move-object v4, p2
move-object v5, p3
invoke-direct/range {v0 .. v5}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager$8;-><init>(Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;Lcn/rongcloud/rtc/api/callback/IRCRTCFailedCallback;Ljava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)V
invoke-virtual {p0, v6}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->offerTask(Lcn/rongcloud/rtc/webrtc/task/PubSubTask;)V
return-void
.end method
.method public offerTask(Lcn/rongcloud/rtc/webrtc/task/PubSubTask;)V
.registers 3
.line 1
iget-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mTaskQueue:Lcn/rongcloud/rtc/webrtc/task/PubSubTaskQueue;
if-eqz v0, :cond_7
.line 2
invoke-virtual {v0, p1}, Lcn/rongcloud/rtc/webrtc/task/PubSubTaskQueue;->offerTask(Lcn/rongcloud/rtc/webrtc/task/PubSubTask;)V
:cond_7
return-void
.end method
.method public publishStreams(Ljava/util/List;Ljava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)V
.registers 13
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Lcn/rongcloud/rtc/webrtc/MediaCommonParams;",
")V"
}
.end annotation
.line 1
new-instance v7, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager$1;
iget-object v2, p4, Lcn/rongcloud/rtc/webrtc/MediaCommonParams;->callback:Lcn/rongcloud/rtc/api/callback/IRCRTCFailedCallback;
move-object v0, v7
move-object v1, p0
move-object v3, p4
move-object v4, p1
move-object v5, p2
move-object v6, p3
invoke-direct/range {v0 .. v6}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager$1;-><init>(Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;Lcn/rongcloud/rtc/api/callback/IRCRTCFailedCallback;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;Ljava/util/List;Ljava/util/List;Ljava/util/List;)V
invoke-virtual {p0, v7}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->offerTask(Lcn/rongcloud/rtc/webrtc/task/PubSubTask;)V
return-void
.end method
.method public reConnected(ZLjava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)V
.registers 13
.annotation system Ldalvik/annotation/Signature;
value = {
"(Z",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Lcn/rongcloud/rtc/webrtc/MediaCommonParams<",
"Landroid/util/Pair<",
"Ljava/util/List<",
"Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;",
">;",
"Lcn/rongcloud/rtc/api/stream/RCRTCLiveInfo;",
">;>;)V"
}
.end annotation
.line 1
new-instance v7, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager$2;
iget-object v2, p4, Lcn/rongcloud/rtc/webrtc/MediaCommonParams;->callback:Lcn/rongcloud/rtc/api/callback/IRCRTCFailedCallback;
move-object v0, v7
move-object v1, p0
move v3, p1
move-object v4, p2
move-object v5, p3
move-object v6, p4
invoke-direct/range {v0 .. v6}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager$2;-><init>(Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;Lcn/rongcloud/rtc/api/callback/IRCRTCFailedCallback;ZLjava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)V
invoke-virtual {p0, v7}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->offerTask(Lcn/rongcloud/rtc/webrtc/task/PubSubTask;)V
return-void
.end method
.method public release()V
.registers 3
.line 1
iget-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mTaskQueue:Lcn/rongcloud/rtc/webrtc/task/PubSubTaskQueue;
new-instance v1, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager$9;
invoke-direct {v1, p0}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager$9;-><init>(Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;)V
invoke-virtual {v0, v1}, Lcn/rongcloud/rtc/webrtc/task/PubSubTaskQueue;->stop(Ljava/lang/Runnable;)V
const/4 v0, 0x0
.line 2
iput-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mTaskQueue:Lcn/rongcloud/rtc/webrtc/task/PubSubTaskQueue;
.line 3
iget-object v1, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mRTCConnection:Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;
invoke-virtual {v1}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->release()V
.line 4
iput-object v0, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mRTCConnection:Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;
return-void
.end method
.method public subscribeLiveStream(Ljava/lang/String;Lcn/rongcloud/rtc/base/RCRTCAVStreamType;Lcn/rongcloud/rtc/api/callback/IRCRTCResultCallback;)V
.registers 5
.line 1
new-instance v0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager$7;
invoke-direct {v0, p0, p3, p1, p2}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager$7;-><init>(Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;Lcn/rongcloud/rtc/api/callback/IRCRTCFailedCallback;Ljava/lang/String;Lcn/rongcloud/rtc/base/RCRTCAVStreamType;)V
invoke-virtual {p0, v0}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->offerTask(Lcn/rongcloud/rtc/webrtc/task/PubSubTask;)V
return-void
.end method
.method public subscribeRemoteSDP(Ljava/util/List;Ljava/util/List;ZLcn/rongcloud/rtc/webrtc/MediaCommonParams;)Lcn/rongcloud/rtc/base/AsyncResult;
.registers 13
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;Z",
"Lcn/rongcloud/rtc/webrtc/MediaCommonParams;",
")",
"Lcn/rongcloud/rtc/base/AsyncResult;"
}
.end annotation
.line 1
new-instance v0, Ljava/lang/StringBuilder;
invoke-direct {v0}, Ljava/lang/StringBuilder;-><init>()V
const-string v1, "subscribeRemoteSDP . needExchangeSDP :"
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v0, p3}, Ljava/lang/StringBuilder;->append(Z)Ljava/lang/StringBuilder;
invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v0
const-string v1, "RTCPubSubManager"
invoke-static {v1, v0}, Lcn/rongcloud/rtc/utils/FinLog;->i(Ljava/lang/String;Ljava/lang/String;)V
const/4 v0, 0x0
if-eqz p3, :cond_1e
.line 2
invoke-direct {p0, v0, p1, p2, p4}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->syncExchangeRemoteSDP(ZLjava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p1
return-object p1
.line 3
:cond_1e
iget-object p3, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mRTCConnection:Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;
invoke-virtual {p3}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->everOfferIsCreated()Z
move-result p3
if-eqz p3, :cond_ac
.line 4
invoke-static {}, Lcn/rongcloud/rtc/signal/SignalManager;->getInstance()Lcn/rongcloud/rtc/signal/SignalManager;
move-result-object v2
iget-object v3, p4, Lcn/rongcloud/rtc/webrtc/MediaCommonParams;->roomId:Ljava/lang/String;
iget-object v4, p4, Lcn/rongcloud/rtc/webrtc/MediaCommonParams;->roomType:Lcn/rongcloud/rtc/base/RCRTCRoomType;
iget-object v5, p4, Lcn/rongcloud/rtc/webrtc/MediaCommonParams;->clientSessionId:Ljava/lang/String;
move-object v6, p2
move-object v7, p1
invoke-virtual/range {v2 .. v7}, Lcn/rongcloud/rtc/signal/SignalManager;->syncSubscribeSDP(Ljava/lang/String;Lcn/rongcloud/rtc/base/RCRTCRoomType;Ljava/lang/String;Ljava/util/List;Ljava/util/List;)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p2
.line 5
invoke-virtual {p2}, Lcn/rongcloud/rtc/base/AsyncResult;->isFailed()Z
move-result p3
if-eqz p3, :cond_55
.line 6
new-instance p1, Ljava/lang/StringBuilder;
invoke-direct {p1}, Ljava/lang/StringBuilder;-><init>()V
const-string p3, "subscribeSDP error: "
invoke-virtual {p1, p3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {p2}, Lcn/rongcloud/rtc/base/AsyncResult;->getErrorCode()Lcn/rongcloud/rtc/base/RTCErrorCode;
move-result-object p3
invoke-virtual {p1, p3}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invoke-virtual {p1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object p1
invoke-static {v1, p1}, Lcn/rongcloud/rtc/utils/FinLog;->e(Ljava/lang/String;Ljava/lang/String;)V
return-object p2
.line 7
:cond_55
invoke-direct {p0}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->isAllowPubSub()Z
move-result p3
if-nez p3, :cond_66
.line 8
sget-object p1, Lcn/rongcloud/rtc/base/RTCErrorCode;->RongRTCCodeRTCConnectionIsNull:Lcn/rongcloud/rtc/base/RTCErrorCode;
invoke-static {p1}, Lcn/rongcloud/rtc/base/AsyncResult;->create(Lcn/rongcloud/rtc/base/RTCErrorCode;)Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;
move-result-object p1
invoke-virtual {p1}, Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;->getResult()Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p1
return-object p1
:cond_66
const-string p3, "subscribeRemoteSDP subscribeSDP onSuccess"
.line 9
invoke-static {v1, p3}, Lcn/rongcloud/rtc/utils/FinLog;->i(Ljava/lang/String;Ljava/lang/String;)V
.line 10
iget-object p3, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mRTCConnection:Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;
invoke-virtual {p2}, Lcn/rongcloud/rtc/base/AsyncResult;->getData()Ljava/lang/Object;
move-result-object p2
check-cast p2, Lcn/rongcloud/rtc/core/SessionDescription;
invoke-static {p1}, Lcn/rongcloud/rtc/utils/RTCSDPTools;->getTotalMaxBitRate(Ljava/util/List;)I
move-result v0
invoke-static {p1}, Lcn/rongcloud/rtc/utils/RTCSDPTools;->getTotalMinBitRate(Ljava/util/List;)I
move-result p1
invoke-virtual {p3, p2, v0, p1}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->syncSetRemoteDescription(Lcn/rongcloud/rtc/core/SessionDescription;II)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p1
.line 11
invoke-virtual {p1}, Lcn/rongcloud/rtc/base/AsyncResult;->isFailed()Z
move-result p2
if-eqz p2, :cond_9e
.line 12
new-instance p2, Ljava/lang/StringBuilder;
invoke-direct {p2}, Ljava/lang/StringBuilder;-><init>()V
const-string p3, "setRemoteDescription error: "
invoke-virtual {p2, p3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {p1}, Lcn/rongcloud/rtc/base/AsyncResult;->getErrorCode()Lcn/rongcloud/rtc/base/RTCErrorCode;
move-result-object p3
invoke-virtual {p2, p3}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invoke-virtual {p2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object p2
invoke-static {v1, p2}, Lcn/rongcloud/rtc/utils/FinLog;->e(Ljava/lang/String;Ljava/lang/String;)V
return-object p1
:cond_9e
const-string p1, "subscribeRemoteSDP subscribeSDP onRemoteSdpSetSuccess"
.line 13
invoke-static {v1, p1}, Lcn/rongcloud/rtc/utils/FinLog;->i(Ljava/lang/String;Ljava/lang/String;)V
.line 14
iget-object p1, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mRTCConnection:Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;
iget-object p2, p4, Lcn/rongcloud/rtc/webrtc/MediaCommonParams;->roomId:Ljava/lang/String;
invoke-virtual {p1, p2}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->syncCreateAnswer(Ljava/lang/String;)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p1
return-object p1
.line 15
:cond_ac
invoke-direct {p0, v0, p1, p2, p4}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->syncExchangeRemoteSDP(ZLjava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p1
return-object p1
.end method
.method public subscribeStreams(Ljava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)V
.registers 11
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Lcn/rongcloud/rtc/webrtc/MediaCommonParams;",
")V"
}
.end annotation
.line 1
new-instance v6, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager$5;
iget-object v2, p3, Lcn/rongcloud/rtc/webrtc/MediaCommonParams;->callback:Lcn/rongcloud/rtc/api/callback/IRCRTCFailedCallback;
move-object v0, v6
move-object v1, p0
move-object v3, p1
move-object v4, p2
move-object v5, p3
invoke-direct/range {v0 .. v5}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager$5;-><init>(Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;Lcn/rongcloud/rtc/api/callback/IRCRTCFailedCallback;Ljava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)V
invoke-virtual {p0, v6}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->offerTask(Lcn/rongcloud/rtc/webrtc/task/PubSubTask;)V
return-void
.end method
.method public syncPublishStreams(ZLcn/rongcloud/rtc/webrtc/MediaCommonParams;Ljava/util/List;Ljava/util/List;Ljava/util/List;)Lcn/rongcloud/rtc/base/AsyncResult;
.registers 11
.annotation system Ldalvik/annotation/Signature;
value = {
"(Z",
"Lcn/rongcloud/rtc/webrtc/MediaCommonParams;",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;)",
"Lcn/rongcloud/rtc/base/AsyncResult<",
"Landroid/util/Pair<",
"Ljava/util/List<",
"Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;",
">;",
"Lcn/rongcloud/rtc/api/stream/RCRTCLiveInfo;",
">;>;"
}
.end annotation
.line 1
invoke-direct {p0}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->isAllowPubSub()Z
move-result v0
if-nez v0, :cond_11
.line 2
sget-object p1, Lcn/rongcloud/rtc/base/RTCErrorCode;->RongRTCCodeRTCConnectionIsNull:Lcn/rongcloud/rtc/base/RTCErrorCode;
invoke-static {p1}, Lcn/rongcloud/rtc/base/AsyncResult;->create(Lcn/rongcloud/rtc/base/RTCErrorCode;)Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;
move-result-object p1
invoke-virtual {p1}, Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;->getResult()Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p1
return-object p1
.line 3
:cond_11
invoke-direct {p0, p4}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->isEmpty(Ljava/util/List;)Z
move-result v0
if-eqz v0, :cond_22
.line 4
sget-object p1, Lcn/rongcloud/rtc/base/RTCErrorCode;->RongRTCCodeParameterError:Lcn/rongcloud/rtc/base/RTCErrorCode;
invoke-static {p1}, Lcn/rongcloud/rtc/base/AsyncResult;->create(Lcn/rongcloud/rtc/base/RTCErrorCode;)Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;
move-result-object p1
invoke-virtual {p1}, Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;->getResult()Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p1
return-object p1
.line 5
:cond_22
invoke-interface {p4}, Ljava/util/List;->iterator()Ljava/util/Iterator;
move-result-object v0
:goto_26
invoke-interface {v0}, Ljava/util/Iterator;->hasNext()Z
move-result v1
if-eqz v1, :cond_a2
invoke-interface {v0}, Ljava/util/Iterator;->next()Ljava/lang/Object;
move-result-object v1
check-cast v1, Lcn/rongcloud/rtc/webrtc/IStreamResource;
.line 6
iget-object v2, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mRTCConnection:Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;
invoke-virtual {v2}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->getPublishedStreamSize()I
move-result v2
iget v3, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mMaxStreamCount:I
if-le v2, v3, :cond_47
.line 7
sget-object p1, Lcn/rongcloud/rtc/base/RTCErrorCode;->RongRTCCodePublishStreamsHasReachedMaxCount:Lcn/rongcloud/rtc/base/RTCErrorCode;
invoke-static {p1}, Lcn/rongcloud/rtc/base/AsyncResult;->create(Lcn/rongcloud/rtc/base/RTCErrorCode;)Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;
move-result-object p1
invoke-virtual {p1}, Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;->getResult()Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p1
return-object p1
.line 8
:cond_47
invoke-interface {v1}, Lcn/rongcloud/rtc/webrtc/IStreamResource;->getStreamId()Ljava/lang/String;
move-result-object v2
invoke-direct {p0, v2}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->getAndCreateLocalMediaStream(Ljava/lang/String;)Lcn/rongcloud/rtc/core/MediaStream;
move-result-object v2
.line 9
iget-object v3, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mFactoryManager:Lcn/rongcloud/rtc/webrtc/PeerConnectionFactoryHolder;
invoke-virtual {v3, v1}, Lcn/rongcloud/rtc/webrtc/PeerConnectionFactoryHolder;->bindingTrack(Lcn/rongcloud/rtc/webrtc/IStreamResource;)Z
.line 10
iget-object v3, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mRTCConnection:Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;
invoke-virtual {v3, v2}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->addStream(Lcn/rongcloud/rtc/core/MediaStream;)Z
move-result v3
if-nez v3, :cond_67
.line 11
sget-object p1, Lcn/rongcloud/rtc/base/RTCErrorCode;->ConnectionAddStreamFailed:Lcn/rongcloud/rtc/base/RTCErrorCode;
invoke-static {p1}, Lcn/rongcloud/rtc/base/AsyncResult;->create(Lcn/rongcloud/rtc/base/RTCErrorCode;)Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;
move-result-object p1
invoke-virtual {p1}, Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;->getResult()Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p1
return-object p1
.line 12
:cond_67
instance-of v3, v1, Lcn/rongcloud/rtc/webrtc/ILocalVideoStreamResource;
if-eqz v3, :cond_7e
move-object v3, v1
check-cast v3, Lcn/rongcloud/rtc/webrtc/ILocalVideoStreamResource;
invoke-interface {v3}, Lcn/rongcloud/rtc/webrtc/ILocalVideoStreamResource;->isPreserved()Z
move-result v3
if-eqz v3, :cond_7e
.line 13
invoke-interface {v1}, Lcn/rongcloud/rtc/webrtc/IStreamResource;->getTrack()Lcn/rongcloud/rtc/core/MediaStreamTrack;
move-result-object v3
check-cast v3, Lcn/rongcloud/rtc/core/VideoTrack;
.line 14
invoke-virtual {v2, v3}, Lcn/rongcloud/rtc/core/MediaStream;->addPreservedTrack(Lcn/rongcloud/rtc/core/VideoTrack;)Z
goto :goto_85
.line 15
:cond_7e
invoke-interface {v1}, Lcn/rongcloud/rtc/webrtc/IStreamResource;->getTrack()Lcn/rongcloud/rtc/core/MediaStreamTrack;
move-result-object v3
invoke-virtual {v2, v3}, Lcn/rongcloud/rtc/core/MediaStream;->addTrack(Lcn/rongcloud/rtc/core/MediaStreamTrack;)V
.line 16
:goto_85
iget-object v3, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mRTCConnection:Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;
invoke-interface {v1}, Lcn/rongcloud/rtc/webrtc/IStreamResource;->getTrack()Lcn/rongcloud/rtc/core/MediaStreamTrack;
move-result-object v4
invoke-virtual {v3, v4}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->bindStreamEncryption(Lcn/rongcloud/rtc/core/MediaStreamTrack;)V
.line 17
iget-object v3, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mReportManager:Lcn/rongcloud/rtc/api/report/RTCStatusReportManager;
iget-object v4, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mUserId:Ljava/lang/String;
invoke-virtual {v2}, Lcn/rongcloud/rtc/core/MediaStream;->getId()Ljava/lang/String;
move-result-object v2
invoke-interface {v1}, Lcn/rongcloud/rtc/webrtc/IStreamResource;->getTrack()Lcn/rongcloud/rtc/core/MediaStreamTrack;
move-result-object v1
invoke-virtual {v1}, Lcn/rongcloud/rtc/core/MediaStreamTrack;->id()Ljava/lang/String;
move-result-object v1
invoke-virtual {v3, v4, v2, v1}, Lcn/rongcloud/rtc/api/report/RTCStatusReportManager;->addReport(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V
goto :goto_26
.line 18
:cond_a2
invoke-direct {p0, p1, p3, p5, p2}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->syncExchangeRemoteSDP(ZLjava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p1
.line 19
invoke-virtual {p1}, Lcn/rongcloud/rtc/base/AsyncResult;->isFailed()Z
move-result p5
if-eqz p5, :cond_b7
.line 20
iget-object p2, p2, Lcn/rongcloud/rtc/webrtc/MediaCommonParams;->roomId:Ljava/lang/String;
invoke-virtual {p1}, Lcn/rongcloud/rtc/base/AsyncResult;->getErrorCode()Lcn/rongcloud/rtc/base/RTCErrorCode;
move-result-object p1
invoke-direct {p0, p2, p1, p4}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->onPublishFailed(Ljava/lang/String;Lcn/rongcloud/rtc/base/RTCErrorCode;Ljava/util/List;)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p1
return-object p1
.line 21
:cond_b7
invoke-virtual {p1}, Lcn/rongcloud/rtc/base/AsyncResult;->getData()Ljava/lang/Object;
move-result-object p5
check-cast p5, Landroid/util/Pair;
iget-object p5, p5, Landroid/util/Pair;->first:Ljava/lang/Object;
check-cast p5, Ljava/util/List;
const-string v0, "RTCPubSubManager"
const-string v1, "publish-exchangeRemoteSDP success"
.line 22
invoke-static {v0, v1}, Lcn/rongcloud/rtc/utils/FinLog;->i(Ljava/lang/String;Ljava/lang/String;)V
.line 23
iget-object v0, p2, Lcn/rongcloud/rtc/webrtc/MediaCommonParams;->roomId:Ljava/lang/String;
invoke-direct {p0, v0, p3, p4, p5}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->syncSendIMSignal(Ljava/lang/String;Ljava/util/List;Ljava/util/List;Ljava/util/List;)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p3
.line 24
invoke-virtual {p3}, Lcn/rongcloud/rtc/base/AsyncResult;->isFailed()Z
move-result v0
if-eqz v0, :cond_df
.line 25
iget-object p1, p2, Lcn/rongcloud/rtc/webrtc/MediaCommonParams;->roomId:Ljava/lang/String;
invoke-virtual {p3}, Lcn/rongcloud/rtc/base/AsyncResult;->getErrorCode()Lcn/rongcloud/rtc/base/RTCErrorCode;
move-result-object p2
invoke-direct {p0, p1, p2, p4}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->onPublishFailed(Ljava/lang/String;Lcn/rongcloud/rtc/base/RTCErrorCode;Ljava/util/List;)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p1
return-object p1
.line 26
:cond_df
sget-object p3, Lcn/rongcloud/rtc/stat/RongRtcStatMagr;->instance:Lcn/rongcloud/rtc/stat/RongRtcStatMagr;
const/4 v0, 0x1
invoke-virtual {p3, v0, p4}, Lcn/rongcloud/rtc/stat/RongRtcStatMagr;->reportPublish(ZLjava/util/List;)V
.line 27
iget-object p3, p2, Lcn/rongcloud/rtc/webrtc/MediaCommonParams;->roomId:Ljava/lang/String;
iget-object p2, p2, Lcn/rongcloud/rtc/webrtc/MediaCommonParams;->roomType:Lcn/rongcloud/rtc/base/RCRTCRoomType;
invoke-direct {p0, p3, p2, p1, p5}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->getExchangeSDPDataResult(Ljava/lang/String;Lcn/rongcloud/rtc/base/RCRTCRoomType;Lcn/rongcloud/rtc/base/AsyncResult;Ljava/util/List;)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p1
return-object p1
.end method
.method public syncSubscribeLiveStream(Ljava/lang/String;Lcn/rongcloud/rtc/base/RCRTCAVStreamType;)Lcn/rongcloud/rtc/base/AsyncResult;
.registers 9
.line 1
invoke-static {}, Ljava/lang/System;->currentTimeMillis()J
move-result-wide v0
.line 2
new-instance v2, Ljava/lang/StringBuilder;
invoke-direct {v2}, Ljava/lang/StringBuilder;-><init>()V
const-string v3, "subscribeLiveResources() run -- "
invoke-virtual {v2, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v2, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v2
const-string v3, "RTCPubSubManager"
invoke-static {v3, v2}, Lcn/rongcloud/rtc/utils/FinLog;->i(Ljava/lang/String;Ljava/lang/String;)V
.line 3
invoke-direct {p0}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->isAllowPubSub()Z
move-result v2
if-nez v2, :cond_30
const-string p1, "subscribeLiveResources() run -- onFailed RongRTCCodeRTCConnectionIsNull"
.line 4
invoke-static {v3, p1}, Lcn/rongcloud/rtc/utils/FinLog;->i(Ljava/lang/String;Ljava/lang/String;)V
.line 5
sget-object p1, Lcn/rongcloud/rtc/base/RTCErrorCode;->RongRTCCodeRTCConnectionIsNull:Lcn/rongcloud/rtc/base/RTCErrorCode;
invoke-static {p1}, Lcn/rongcloud/rtc/base/AsyncResult;->create(Lcn/rongcloud/rtc/base/RTCErrorCode;)Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;
move-result-object p1
invoke-virtual {p1}, Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;->getResult()Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p1
return-object p1
.line 6
:cond_30
iget-object v2, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mRTCConnection:Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;
const/4 v4, 0x0
const-string v5, ""
invoke-virtual {v2, v5, v4, v4}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->syncCreateAndSetOffer(Ljava/lang/String;ZI)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object v2
.line 7
invoke-virtual {v2}, Lcn/rongcloud/rtc/base/AsyncResult;->isFailed()Z
move-result v5
if-eqz v5, :cond_40
return-object v2
:cond_40
const-string v5, "subscribeLiveSDP onLocalSdpSetSuccess "
.line 8
invoke-static {v3, v5}, Lcn/rongcloud/rtc/utils/FinLog;->d(Ljava/lang/String;Ljava/lang/String;)V
.line 9
invoke-static {}, Lcn/rongcloud/rtc/signal/SignalManager;->getInstance()Lcn/rongcloud/rtc/signal/SignalManager;
move-result-object v5
invoke-virtual {v2}, Lcn/rongcloud/rtc/base/AsyncResult;->getData()Ljava/lang/Object;
move-result-object v2
check-cast v2, Lcn/rongcloud/rtc/core/SessionDescription;
invoke-virtual {v5, v2, p1, p2}, Lcn/rongcloud/rtc/signal/SignalManager;->syncSubscribeLive(Lcn/rongcloud/rtc/core/SessionDescription;Ljava/lang/String;Lcn/rongcloud/rtc/base/RCRTCAVStreamType;)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p1
.line 10
invoke-virtual {p1}, Lcn/rongcloud/rtc/base/AsyncResult;->isFailed()Z
move-result p2
if-eqz p2, :cond_5a
return-object p1
.line 11
:cond_5a
iget-object p2, p0, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->mRTCConnection:Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;
invoke-virtual {p1}, Lcn/rongcloud/rtc/base/AsyncResult;->getData()Ljava/lang/Object;
move-result-object p1
check-cast p1, Lcn/rongcloud/rtc/core/SessionDescription;
invoke-virtual {p2, p1, v4, v4}, Lcn/rongcloud/rtc/webrtc/RTCConnectionHolder;->syncSetRemoteDescription(Lcn/rongcloud/rtc/core/SessionDescription;II)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p1
.line 12
invoke-virtual {p1}, Lcn/rongcloud/rtc/base/AsyncResult;->isFailed()Z
move-result p2
if-eqz p2, :cond_6d
return-object p1
.line 13
:cond_6d
invoke-static {}, Ljava/lang/System;->currentTimeMillis()J
move-result-wide v4
.line 14
new-instance p2, Ljava/lang/StringBuilder;
invoke-direct {p2}, Ljava/lang/StringBuilder;-><init>()V
const-string v2, "subscribeLiveSDP onSuccess() costTime = "
invoke-virtual {p2, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
sub-long/2addr v4, v0
invoke-virtual {p2, v4, v5}, Ljava/lang/StringBuilder;->append(J)Ljava/lang/StringBuilder;
invoke-virtual {p2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object p2
invoke-static {v3, p2}, Lcn/rongcloud/rtc/utils/FinLog;->i(Ljava/lang/String;Ljava/lang/String;)V
return-object p1
.end method
.method public syncUnsubscribeResources(Ljava/util/List;Ljava/util/List;Ljava/util/List;ZLcn/rongcloud/rtc/webrtc/MediaCommonParams;)Lcn/rongcloud/rtc/base/AsyncResult;
.registers 8
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;Z",
"Lcn/rongcloud/rtc/webrtc/MediaCommonParams;",
")",
"Lcn/rongcloud/rtc/base/AsyncResult;"
}
.end annotation
const-string v0, "RTCPubSubManager"
const-string v1, "syncUnsubscribeResources run()"
.line 1
invoke-static {v0, v1}, Lcn/rongcloud/rtc/utils/FinLog;->i(Ljava/lang/String;Ljava/lang/String;)V
.line 2
invoke-direct {p0}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->isAllowPubSub()Z
move-result v1
if-nez v1, :cond_1d
const-string p1, "PeerConnection Is Released"
.line 3
invoke-static {v0, p1}, Lcn/rongcloud/rtc/utils/FinLog;->e(Ljava/lang/String;Ljava/lang/String;)V
.line 4
sget-object p1, Lcn/rongcloud/rtc/base/RTCErrorCode;->RongRTCCodeRTCConnectionIsNull:Lcn/rongcloud/rtc/base/RTCErrorCode;
invoke-static {p1}, Lcn/rongcloud/rtc/base/AsyncResult;->create(Lcn/rongcloud/rtc/base/RTCErrorCode;)Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;
move-result-object p1
invoke-virtual {p1}, Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;->getResult()Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p1
return-object p1
.line 5
:cond_1d
invoke-virtual {p0, p1, p2, p4, p5}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->subscribeRemoteSDP(Ljava/util/List;Ljava/util/List;ZLcn/rongcloud/rtc/webrtc/MediaCommonParams;)Lcn/rongcloud/rtc/base/AsyncResult;
move-result-object p1
.line 6
invoke-virtual {p1}, Lcn/rongcloud/rtc/base/AsyncResult;->isFailed()Z
move-result p2
if-eqz p2, :cond_28
return-object p1
.line 7
:cond_28
sget-object p2, Lcn/rongcloud/rtc/stat/RongRtcStatMagr;->instance:Lcn/rongcloud/rtc/stat/RongRtcStatMagr;
invoke-virtual {p2, p3}, Lcn/rongcloud/rtc/stat/RongRtcStatMagr;->reportUnSubscribe(Ljava/util/List;)V
return-object p1
.end method
.method public unpublishedStreams(Ljava/util/List;Ljava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)V
.registers 13
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Lcn/rongcloud/rtc/webrtc/MediaCommonParams<",
"Ljava/util/List<",
"Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;",
">;>;)V"
}
.end annotation
.line 1
new-instance v7, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager$4;
iget-object v2, p4, Lcn/rongcloud/rtc/webrtc/MediaCommonParams;->callback:Lcn/rongcloud/rtc/api/callback/IRCRTCFailedCallback;
move-object v0, v7
move-object v1, p0
move-object v3, p1
move-object v4, p2
move-object v5, p3
move-object v6, p4
invoke-direct/range {v0 .. v6}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager$4;-><init>(Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;Lcn/rongcloud/rtc/api/callback/IRCRTCFailedCallback;Ljava/util/List;Ljava/util/List;Ljava/util/List;Lcn/rongcloud/rtc/webrtc/MediaCommonParams;)V
invoke-virtual {p0, v7}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->offerTask(Lcn/rongcloud/rtc/webrtc/task/PubSubTask;)V
return-void
.end method
.method public unsubscribeStreams(Ljava/util/List;Ljava/util/List;Ljava/util/List;ZLcn/rongcloud/rtc/webrtc/MediaCommonParams;)V
.registers 15
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;",
"Ljava/util/List<",
"+",
"Lcn/rongcloud/rtc/webrtc/IStreamResource;",
">;Z",
"Lcn/rongcloud/rtc/webrtc/MediaCommonParams;",
")V"
}
.end annotation
.line 1
new-instance v8, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager$6;
iget-object v2, p5, Lcn/rongcloud/rtc/webrtc/MediaCommonParams;->callback:Lcn/rongcloud/rtc/api/callback/IRCRTCFailedCallback;
move-object v0, v8
move-object v1, p0
move-object v3, p1
move-object v4, p2
move-object v5, p3
move v6, p4
move-object v7, p5
invoke-direct/range {v0 .. v7}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager$6;-><init>(Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;Lcn/rongcloud/rtc/api/callback/IRCRTCFailedCallback;Ljava/util/List;Ljava/util/List;Ljava/util/List;ZLcn/rongcloud/rtc/webrtc/MediaCommonParams;)V
invoke-virtual {p0, v8}, Lcn/rongcloud/rtc/webrtc/RTCPubSubManager;->offerTask(Lcn/rongcloud/rtc/webrtc/task/PubSubTask;)V
return-void
.end method