.class public final Lio/reactivex/rxjava3/internal/util/b; .super Ljava/lang/Object; .source "BackpressureHelper.java" # direct methods .method public constructor ()V .locals 2 .line 1 invoke-direct {p0}, Ljava/lang/Object;->()V .line 2 new-instance v0, Ljava/lang/IllegalStateException; const-string v1, "No instances!" invoke-direct {v0, v1}, Ljava/lang/IllegalStateException;->(Ljava/lang/String;)V throw v0 .end method .method public static a(Ljava/util/concurrent/atomic/AtomicLong;J)J .locals 5 .param p0 # Ljava/util/concurrent/atomic/AtomicLong; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "requested", "n" } .end annotation .line 1 :cond_0 invoke-virtual {p0}, Ljava/util/concurrent/atomic/AtomicLong;->get()J move-result-wide v0 const-wide v2, 0x7fffffffffffffffL cmp-long v4, v0, v2 if-nez v4, :cond_1 return-wide v2 .line 2 :cond_1 invoke-static {v0, v1, p1, p2}, Lio/reactivex/rxjava3/internal/util/b;->c(JJ)J move-result-wide v2 .line 3 invoke-virtual {p0, v0, v1, v2, v3}, Ljava/util/concurrent/atomic/AtomicLong;->compareAndSet(JJ)Z move-result v2 if-eqz v2, :cond_0 return-wide v0 .end method .method public static b(Ljava/util/concurrent/atomic/AtomicLong;J)J .locals 5 .param p0 # Ljava/util/concurrent/atomic/AtomicLong; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "requested", "n" } .end annotation .line 1 :cond_0 invoke-virtual {p0}, Ljava/util/concurrent/atomic/AtomicLong;->get()J move-result-wide v0 const-wide/high16 v2, -0x8000000000000000L cmp-long v4, v0, v2 if-nez v4, :cond_1 return-wide v2 :cond_1 const-wide v2, 0x7fffffffffffffffL cmp-long v4, v0, v2 if-nez v4, :cond_2 return-wide v2 .line 2 :cond_2 invoke-static {v0, v1, p1, p2}, Lio/reactivex/rxjava3/internal/util/b;->c(JJ)J move-result-wide v2 .line 3 invoke-virtual {p0, v0, v1, v2, v3}, Ljava/util/concurrent/atomic/AtomicLong;->compareAndSet(JJ)Z move-result v2 if-eqz v2, :cond_0 return-wide v0 .end method .method public static c(JJ)J .locals 0 .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "a", "b" } .end annotation add-long/2addr p0, p2 const-wide/16 p2, 0x0 cmp-long p2, p0, p2 if-gez p2, :cond_0 const-wide p0, 0x7fffffffffffffffL :cond_0 return-wide p0 .end method .method public static d(JJ)J .locals 6 .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "a", "b" } .end annotation mul-long v0, p0, p2 or-long v2, p0, p2 const/16 v4, 0x1f ushr-long/2addr v2, v4 const-wide/16 v4, 0x0 cmp-long v2, v2, v4 if-eqz v2, :cond_0 .line 1 div-long p0, v0, p0 cmp-long p0, p0, p2 if-eqz p0, :cond_0 const-wide p0, 0x7fffffffffffffffL return-wide p0 :cond_0 return-wide v0 .end method .method public static e(Ljava/util/concurrent/atomic/AtomicLong;J)J .locals 8 .param p0 # Ljava/util/concurrent/atomic/AtomicLong; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "requested", "n" } .end annotation .line 1 :cond_0 invoke-virtual {p0}, Ljava/util/concurrent/atomic/AtomicLong;->get()J move-result-wide v0 const-wide v2, 0x7fffffffffffffffL cmp-long v4, v0, v2 if-nez v4, :cond_1 return-wide v2 :cond_1 sub-long v2, v0, p1 const-wide/16 v4, 0x0 cmp-long v6, v2, v4 if-gez v6, :cond_2 .line 2 new-instance v6, Ljava/lang/IllegalStateException; const-string v7, "More produced than requested: " invoke-static {v7, v2, v3}, Landroidx/camera/core/l1;->a(Ljava/lang/String;J)Ljava/lang/String; move-result-object v2 invoke-direct {v6, v2}, Ljava/lang/IllegalStateException;->(Ljava/lang/String;)V invoke-static {v6}, Lji/a;->Y(Ljava/lang/Throwable;)V move-wide v2, v4 .line 3 :cond_2 invoke-virtual {p0, v0, v1, v2, v3}, Ljava/util/concurrent/atomic/AtomicLong;->compareAndSet(JJ)Z move-result v0 if-eqz v0, :cond_0 return-wide v2 .end method .method public static f(Ljava/util/concurrent/atomic/AtomicLong;J)J .locals 8 .param p0 # Ljava/util/concurrent/atomic/AtomicLong; .annotation build Lio/reactivex/rxjava3/annotations/NonNull; .end annotation .end param .annotation system Ldalvik/annotation/MethodParameters; accessFlags = { 0x0, 0x0 } names = { "requested", "n" } .end annotation .line 1 :cond_0 invoke-virtual {p0}, Ljava/util/concurrent/atomic/AtomicLong;->get()J move-result-wide v0 const-wide/high16 v2, -0x8000000000000000L cmp-long v4, v0, v2 if-nez v4, :cond_1 return-wide v2 :cond_1 const-wide v2, 0x7fffffffffffffffL cmp-long v4, v0, v2 if-nez v4, :cond_2 return-wide v2 :cond_2 sub-long v2, v0, p1 const-wide/16 v4, 0x0 cmp-long v6, v2, v4 if-gez v6, :cond_3 .line 2 new-instance v6, Ljava/lang/IllegalStateException; const-string v7, "More produced than requested: " invoke-static {v7, v2, v3}, Landroidx/camera/core/l1;->a(Ljava/lang/String;J)Ljava/lang/String; move-result-object v2 invoke-direct {v6, v2}, Ljava/lang/IllegalStateException;->(Ljava/lang/String;)V invoke-static {v6}, Lji/a;->Y(Ljava/lang/Throwable;)V move-wide v2, v4 .line 3 :cond_3 invoke-virtual {p0, v0, v1, v2, v3}, Ljava/util/concurrent/atomic/AtomicLong;->compareAndSet(JJ)Z move-result v0 if-eqz v0, :cond_0 return-wide v2 .end method