i$a.smali
.class final Lcom/yysdk/mobile/vpsdk/i$a;
.super Ljava/lang/Thread;
.source "SourceFile"
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Lcom/yysdk/mobile/vpsdk/i;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x0
name = "a"
.end annotation
# instance fields
.field public a:I
.field b:[B
.field c:[B
.field d:Z
.field e:J
.field public f:Z
.field final g:Ljava/lang/Object;
.field h:Z
.field i:Ljava/util/concurrent/ConcurrentLinkedQueue;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/concurrent/ConcurrentLinkedQueue<",
"Lcom/yysdk/mobile/vpsdk/i$b;",
">;"
}
.end annotation
.end field
.field final synthetic j:Lcom/yysdk/mobile/vpsdk/i;
.field private k:[B
.field private l:Ljava/util/concurrent/LinkedBlockingQueue;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/concurrent/LinkedBlockingQueue<",
"Lcom/yysdk/mobile/vpsdk/i$b;",
">;"
}
.end annotation
.end field
# direct methods
.method constructor <init>(Lcom/yysdk/mobile/vpsdk/i;)V
.registers 5
.line 126
iput-object p1, p0, Lcom/yysdk/mobile/vpsdk/i$a;->j:Lcom/yysdk/mobile/vpsdk/i;
invoke-direct {p0}, Ljava/lang/Thread;-><init>()V
const/4 p1, -0x1
.line 127
iput p1, p0, Lcom/yysdk/mobile/vpsdk/i$a;->a:I
const/4 p1, 0x0
.line 128
iput-object p1, p0, Lcom/yysdk/mobile/vpsdk/i$a;->b:[B
.line 129
iput-object p1, p0, Lcom/yysdk/mobile/vpsdk/i$a;->c:[B
const/4 v0, 0x1
.line 130
iput-boolean v0, p0, Lcom/yysdk/mobile/vpsdk/i$a;->d:Z
const-wide/16 v1, 0x0
.line 131
iput-wide v1, p0, Lcom/yysdk/mobile/vpsdk/i$a;->e:J
.line 132
iput-boolean v0, p0, Lcom/yysdk/mobile/vpsdk/i$a;->f:Z
.line 133
new-instance v0, Ljava/lang/Object;
invoke-direct {v0}, Ljava/lang/Object;-><init>()V
iput-object v0, p0, Lcom/yysdk/mobile/vpsdk/i$a;->g:Ljava/lang/Object;
const/4 v0, 0x0
.line 134
iput-boolean v0, p0, Lcom/yysdk/mobile/vpsdk/i$a;->h:Z
.line 136
iput-object p1, p0, Lcom/yysdk/mobile/vpsdk/i$a;->k:[B
.line 138
new-instance p1, Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-direct {p1}, Ljava/util/concurrent/ConcurrentLinkedQueue;-><init>()V
iput-object p1, p0, Lcom/yysdk/mobile/vpsdk/i$a;->i:Ljava/util/concurrent/ConcurrentLinkedQueue;
.line 139
new-instance p1, Ljava/util/concurrent/LinkedBlockingQueue;
invoke-direct {p1}, Ljava/util/concurrent/LinkedBlockingQueue;-><init>()V
iput-object p1, p0, Lcom/yysdk/mobile/vpsdk/i$a;->l:Ljava/util/concurrent/LinkedBlockingQueue;
return-void
.end method
# virtual methods
.method public final a(Lcom/yysdk/mobile/vpsdk/i$b;)V
.registers 3
.annotation system Ldalvik/annotation/Throws;
value = {
Ljava/lang/InterruptedException;
}
.end annotation
.line 146
iget-object v0, p0, Lcom/yysdk/mobile/vpsdk/i$a;->l:Ljava/util/concurrent/LinkedBlockingQueue;
invoke-virtual {v0, p1}, Ljava/util/concurrent/LinkedBlockingQueue;->put(Ljava/lang/Object;)V
return-void
.end method
.method public final run()V
.registers 25
move-object/from16 v1, p0
.line 166
:cond_2
:goto_2
iget-boolean v0, v1, Lcom/yysdk/mobile/vpsdk/i$a;->d:Z
if-eqz v0, :cond_146
const/4 v0, 0x0
.line 170
:try_start_7
iget-object v2, v1, Lcom/yysdk/mobile/vpsdk/i$a;->l:Ljava/util/concurrent/LinkedBlockingQueue;
invoke-virtual {v2}, Ljava/util/concurrent/LinkedBlockingQueue;->take()Ljava/lang/Object;
move-result-object v2
check-cast v2, Lcom/yysdk/mobile/vpsdk/i$b;
:try_end_f
.catch Ljava/lang/InterruptedException; {:try_start_7 .. :try_end_f} :catch_11
move-object v0, v2
goto :goto_18
.line 173
:catch_11
invoke-static {}, Ljava/lang/Thread;->currentThread()Ljava/lang/Thread;
move-result-object v2
invoke-virtual {v2}, Ljava/lang/Thread;->interrupt()V
:goto_18
if-eqz v0, :cond_2
.line 179
iget-boolean v2, v0, Lcom/yysdk/mobile/vpsdk/i$b;->c:Z
if-nez v2, :cond_146
.line 183
iget-boolean v2, v0, Lcom/yysdk/mobile/vpsdk/i$b;->j:Z
const/4 v3, 0x1
if-eqz v2, :cond_32
.line 185
iget-object v2, v1, Lcom/yysdk/mobile/vpsdk/i$a;->g:Ljava/lang/Object;
monitor-enter v2
.line 186
:try_start_26
iput-boolean v3, v1, Lcom/yysdk/mobile/vpsdk/i$a;->h:Z
.line 187
iget-object v0, v1, Lcom/yysdk/mobile/vpsdk/i$a;->g:Ljava/lang/Object;
invoke-virtual {v0}, Ljava/lang/Object;->notifyAll()V
.line 188
monitor-exit v2
goto :goto_2
:catchall_2f
move-exception v0
monitor-exit v2
:try_end_31
.catchall {:try_start_26 .. :try_end_31} :catchall_2f
throw v0
:cond_32
const/4 v2, 0x0
.line 191
iput-boolean v2, v1, Lcom/yysdk/mobile/vpsdk/i$a;->h:Z
.line 193
iget-object v4, v1, Lcom/yysdk/mobile/vpsdk/i$a;->b:[B
iput-object v4, v1, Lcom/yysdk/mobile/vpsdk/i$a;->c:[B
.line 194
iget-object v4, v0, Lcom/yysdk/mobile/vpsdk/i$b;->a:[B
iput-object v4, v1, Lcom/yysdk/mobile/vpsdk/i$a;->b:[B
.line 195
iget-object v4, v1, Lcom/yysdk/mobile/vpsdk/i$a;->c:[B
iput-object v4, v0, Lcom/yysdk/mobile/vpsdk/i$b;->a:[B
.line 196
iget-wide v14, v0, Lcom/yysdk/mobile/vpsdk/i$b;->b:J
.line 197
iget v10, v0, Lcom/yysdk/mobile/vpsdk/i$b;->d:I
.line 198
iget v11, v0, Lcom/yysdk/mobile/vpsdk/i$b;->e:I
.line 199
iget v12, v0, Lcom/yysdk/mobile/vpsdk/i$b;->f:I
.line 200
iget-boolean v4, v0, Lcom/yysdk/mobile/vpsdk/i$b;->g:Z
.line 201
iget-boolean v13, v0, Lcom/yysdk/mobile/vpsdk/i$b;->h:Z
.line 203
iget v9, v0, Lcom/yysdk/mobile/vpsdk/i$b;->i:F
.line 204
iget v5, v0, Lcom/yysdk/mobile/vpsdk/i$b;->k:I
.line 205
iget-boolean v6, v1, Lcom/yysdk/mobile/vpsdk/i$a;->f:Z
if-nez v6, :cond_5a
.line 206
iget-wide v6, v1, Lcom/yysdk/mobile/vpsdk/i$a;->e:J
sub-long v6, v14, v6
goto :goto_5c
:cond_5a
const-wide/16 v6, 0x0
:goto_5c
move-wide/from16 v17, v6
.line 210
iget-boolean v8, v1, Lcom/yysdk/mobile/vpsdk/i$a;->f:Z
.line 211
iput-boolean v2, v1, Lcom/yysdk/mobile/vpsdk/i$a;->f:Z
.line 212
iput-wide v14, v1, Lcom/yysdk/mobile/vpsdk/i$a;->e:J
.line 213
iget-object v6, v1, Lcom/yysdk/mobile/vpsdk/i$a;->i:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-virtual {v6, v0}, Ljava/util/concurrent/ConcurrentLinkedQueue;->add(Ljava/lang/Object;)Z
if-eqz v4, :cond_2
.line 216
iget-boolean v0, v1, Lcom/yysdk/mobile/vpsdk/i$a;->h:Z
if-nez v0, :cond_2
.line 218
iget-object v0, v1, Lcom/yysdk/mobile/vpsdk/i$a;->b:[B
const/16 v4, 0x12
const/4 v7, 0x2
if-ne v5, v4, :cond_a5
.line 220
iget-object v0, v1, Lcom/yysdk/mobile/vpsdk/i$a;->k:[B
if-eqz v0, :cond_82
array-length v0, v0
mul-int v4, v10, v11
mul-int/lit8 v4, v4, 0x3
div-int/2addr v4, v7
if-ge v0, v4, :cond_8b
:cond_82
mul-int v0, v10, v11
mul-int/lit8 v0, v0, 0x3
.line 221
div-int/2addr v0, v7
new-array v0, v0, [B
iput-object v0, v1, Lcom/yysdk/mobile/vpsdk/i$a;->k:[B
.line 223
:cond_8b
iget-object v4, v1, Lcom/yysdk/mobile/vpsdk/i$a;->k:[B
iget-object v0, v1, Lcom/yysdk/mobile/vpsdk/i$a;->b:[B
invoke-static {v0}, Ljava/nio/ByteBuffer;->wrap([B)Ljava/nio/ByteBuffer;
move-result-object v5
const/16 v0, 0x259
move v6, v10
const/4 v3, 0x2
move v7, v11
move/from16 v22, v8
move v8, v10
move/from16 v23, v9
move v9, v0
invoke-static/range {v4 .. v9}, Lcom/yysdk/mobile/vpsdk/AutoToucherWrapper;->bigo_rgbaToYuv420([BLjava/nio/ByteBuffer;IIII)V
.line 224
iget-object v0, v1, Lcom/yysdk/mobile/vpsdk/i$a;->k:[B
const/4 v8, 0x0
goto :goto_ab
:cond_a5
move/from16 v22, v8
move/from16 v23, v9
const/4 v3, 0x2
move v8, v5
.line 228
:goto_ab
iget-object v4, v1, Lcom/yysdk/mobile/vpsdk/i$a;->j:Lcom/yysdk/mobile/vpsdk/i;
.line 1010
iget-object v4, v4, Lcom/yysdk/mobile/vpsdk/i;->c:Lcom/yysdk/mobile/vpsdk/i$c;
.line 228
invoke-interface {v4, v14, v15}, Lcom/yysdk/mobile/vpsdk/i$c;->c(J)J
move-result-wide v4
cmp-long v6, v14, v4
if-lez v6, :cond_d5
.line 230
sget-object v0, Ljava/util/Locale;->US:Ljava/util/Locale;
new-array v3, v3, [Ljava/lang/Object;
invoke-static {v14, v15}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;
move-result-object v6
aput-object v6, v3, v2
invoke-static {v4, v5}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long;
move-result-object v2
const/4 v6, 0x1
aput-object v2, v3, v6
const-string v2, "[FramePushingThreadMgr] video timestamp %d exceed captureTs %d"
invoke-static {v0, v2, v3}, Ljava/lang/String;->format(Ljava/util/Locale;Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
move-result-object v0
const-string v2, "FramePushingThreadMgr"
invoke-static {v2, v0}, Lcom/yysdk/mobile/vpsdk/p;->a(Ljava/lang/String;Ljava/lang/String;)I
move-wide v14, v4
goto :goto_105
.line 233
:cond_d5
sget-object v2, Lcom/yysdk/mobile/vpsdk/p;->a:Ljava/lang/String;
new-instance v3, Ljava/lang/StringBuilder;
const-string v4, "[FramePushingThreadMgr] push video "
invoke-direct {v3, v4}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
invoke-virtual {v3, v14, v15}, Ljava/lang/StringBuilder;->append(J)Ljava/lang/StringBuilder;
const-string v4, " background "
invoke-virtual {v3, v4}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v3, v13}, Ljava/lang/StringBuilder;->append(Z)Ljava/lang/StringBuilder;
const-string v4, " speed "
invoke-virtual {v3, v4}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
move/from16 v4, v23
invoke-virtual {v3, v4}, Ljava/lang/StringBuilder;->append(F)Ljava/lang/StringBuilder;
invoke-virtual {v3}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v3
invoke-static {v2, v3}, Lcom/yysdk/mobile/vpsdk/p;->a(Ljava/lang/String;Ljava/lang/String;)I
const/4 v5, 0x1
move-wide v6, v14
move v9, v10
move v10, v11
move-object v11, v0
move-wide v2, v14
move v14, v4
.line 234
invoke-static/range {v5 .. v14}, Lcom/yysdk/mobile/vpsdk/VPSDKNativeLibrary;->vpPushVideo(IJIII[BIZF)I
move-wide v14, v2
:goto_105
const/4 v0, 0x1
.line 237
invoke-static {v0}, Lcom/yysdk/mobile/vpsdk/VPSDKNativeLibrary;->vpGetVideoFrameNum(I)I
move-result v0
.line 238
iget-object v2, v1, Lcom/yysdk/mobile/vpsdk/i$a;->j:Lcom/yysdk/mobile/vpsdk/i;
.line 2010
iget-object v2, v2, Lcom/yysdk/mobile/vpsdk/i;->c:Lcom/yysdk/mobile/vpsdk/i$c;
move-object/from16 v16, v2
move/from16 v19, v0
move-wide/from16 v20, v14
.line 238
invoke-interface/range {v16 .. v21}, Lcom/yysdk/mobile/vpsdk/i$c;->a(JIJ)V
.line 240
invoke-static {v0}, Ljava/lang/String;->valueOf(I)Ljava/lang/String;
move-result-object v2
const-string v3, "callback frame push index = "
invoke-virtual {v3, v2}, Ljava/lang/String;->concat(Ljava/lang/String;)Ljava/lang/String;
move-result-object v2
const-string v3, "FramePushingThreadMgr"
invoke-static {v3, v2}, Lcom/yysdk/mobile/vpsdk/p;->a(Ljava/lang/String;Ljava/lang/String;)I
if-eqz v22, :cond_2
.line 242
new-instance v2, Ljava/lang/StringBuilder;
const-string v3, "[FramePushingThreadMgr] FirstReport "
invoke-direct {v2, v3}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
invoke-virtual {v2, v0}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
const-string v0, " "
invoke-virtual {v2, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
long-to-int v0, v14
invoke-virtual {v2, v0}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
invoke-virtual {v2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v0
const-string v2, "FramePushingThreadMgr"
invoke-static {v2, v0}, Lcom/yysdk/mobile/vpsdk/p;->c(Ljava/lang/String;Ljava/lang/String;)I
goto/16 :goto_2
.line 254
:cond_146
new-instance v0, Ljava/lang/StringBuilder;
const-string v2, "[FramePushingThreadMgr] Thread "
invoke-direct {v0, v2}, Ljava/lang/StringBuilder;-><init>(Ljava/lang/String;)V
iget v2, v1, Lcom/yysdk/mobile/vpsdk/i$a;->a:I
invoke-virtual {v0, v2}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder;
const-string v2, " end"
invoke-virtual {v0, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v0
const-string v2, "FramePush"
invoke-static {v2, v0}, Lcom/yysdk/mobile/vpsdk/p;->a(Ljava/lang/String;Ljava/lang/String;)I
return-void
.end method