.class public final Lcom/vk/api/base/persistent/PersistentRequestManager; .super Ljava/lang/Object; .source "PersistentRequestManager.kt" # static fields .field public static final a:Lcom/vk/api/base/persistent/PersistentRequestManager; .field private static final b:Ljava/util/concurrent/ExecutorService; .field private static c:J # direct methods .method static constructor ()V .locals 1 .line 17 new-instance v0, Lcom/vk/api/base/persistent/PersistentRequestManager; invoke-direct {v0}, Lcom/vk/api/base/persistent/PersistentRequestManager;->()V sput-object v0, Lcom/vk/api/base/persistent/PersistentRequestManager;->a:Lcom/vk/api/base/persistent/PersistentRequestManager; .line 26 invoke-static {}, Ljava/util/concurrent/Executors;->newSingleThreadExecutor()Ljava/util/concurrent/ExecutorService; move-result-object v0 sput-object v0, Lcom/vk/api/base/persistent/PersistentRequestManager;->b:Ljava/util/concurrent/ExecutorService; return-void .end method .method private constructor ()V .locals 0 .line 17 invoke-direct {p0}, Ljava/lang/Object;->()V return-void .end method .method public static final synthetic a(Lcom/vk/api/base/persistent/PersistentRequestManager;)V .locals 0 .line 17 invoke-direct {p0}, Lcom/vk/api/base/persistent/PersistentRequestManager;->c()V return-void .end method .method public static final synthetic a(Lcom/vk/api/base/persistent/PersistentRequestManager;Lcom/vk/api/base/persistent/PersistentRequest;)V .locals 0 .line 17 invoke-direct {p0, p1}, Lcom/vk/api/base/persistent/PersistentRequestManager;->b(Lcom/vk/api/base/persistent/PersistentRequest;)V return-void .end method .method private final a(Ljava/lang/String;)V .locals 0 return-void .end method .method private final a(Lcom/vk/api/base/persistent/PersistentRequest;)Z .locals 7 .line 61 invoke-virtual {p1}, Lcom/vk/api/base/persistent/PersistentRequest;->a()Lcom/vk/api/base/ApiRequest; move-result-object v0 const/4 v1, 0x0 const/4 v2, 0x1 .line 63 :try_start_0 invoke-virtual {v0}, Lcom/vk/api/base/ApiRequest;->f()Ljava/lang/Object; move-result-object v3 check-cast v3, Lorg/json/JSONObject; if-eqz v3, :cond_1 .line 64 new-instance v4, Ljava/lang/StringBuilder; invoke-direct {v4}, Ljava/lang/StringBuilder;->()V const-string v5, "Request " invoke-virtual {v4, v5}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v0}, Lcom/vk/api/base/ApiRequest;->v()Ljava/lang/String; move-result-object v5 invoke-virtual {v4, v5}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; const-string v5, " finished: " invoke-virtual {v4, v5}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v4, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder; invoke-virtual {v4}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object v4 invoke-direct {p0, v4}, Lcom/vk/api/base/persistent/PersistentRequestManager;->a(Ljava/lang/String;)V .line 65 invoke-virtual {p1}, Lcom/vk/api/base/persistent/PersistentRequest;->b()Ljava/lang/reflect/Method; move-result-object v4 :try_end_0 .catch Lcom/vk/api/sdk/exceptions/VKApiExecutionException; {:try_start_0 .. :try_end_0} :catch_2 .catch Ljava/lang/Throwable; {:try_start_0 .. :try_end_0} :catch_1 if-eqz v4, :cond_0 .line 67 :try_start_1 invoke-virtual {p1}, Lcom/vk/api/base/persistent/PersistentRequest;->b()Ljava/lang/reflect/Method; move-result-object v4 const/4 v5, 0x0 new-array v6, v2, [Ljava/lang/Object; aput-object v3, v6, v1 invoke-virtual {v4, v5, v6}, Ljava/lang/reflect/Method;->invoke(Ljava/lang/Object;[Ljava/lang/Object;)Ljava/lang/Object; .line 68 new-instance v3, Ljava/lang/StringBuilder; invoke-direct {v3}, Ljava/lang/StringBuilder;->()V const-string v4, "Callback (" invoke-virtual {v3, v4}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {p1}, Lcom/vk/api/base/persistent/PersistentRequest;->b()Ljava/lang/reflect/Method; move-result-object v4 invoke-virtual {v3, v4}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder; const-string v4, ") call success" invoke-virtual {v3, v4}, 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-direct {p0, v3}, Lcom/vk/api/base/persistent/PersistentRequestManager;->a(Ljava/lang/String;)V :try_end_1 .catch Ljava/lang/Throwable; {:try_start_1 .. :try_end_1} :catch_0 .catch Lcom/vk/api/sdk/exceptions/VKApiExecutionException; {:try_start_1 .. :try_end_1} :catch_2 goto :goto_0 :catch_0 move-exception v3 .line 70 :try_start_2 new-instance v4, Ljava/lang/StringBuilder; invoke-direct {v4}, Ljava/lang/StringBuilder;->()V const-string v5, "Callback (" invoke-virtual {v4, v5}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {p1}, Lcom/vk/api/base/persistent/PersistentRequest;->b()Ljava/lang/reflect/Method; move-result-object p1 invoke-virtual {v4, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder; const-string p1, ") call fail" invoke-virtual {v4, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v4}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object p1 invoke-direct {p0, p1}, Lcom/vk/api/base/persistent/PersistentRequestManager;->a(Ljava/lang/String;)V .line 71 sget-object p1, Lcom/vk/analytics/eventtracking/VkTracker;->b:Lcom/vk/analytics/eventtracking/VkTracker; invoke-virtual {p1, v3}, Lcom/vk/analytics/eventtracking/VkTracker;->a(Ljava/lang/Throwable;)V goto :goto_0 :cond_0 const-string p1, "No callback to call" .line 74 invoke-direct {p0, p1}, Lcom/vk/api/base/persistent/PersistentRequestManager;->a(Ljava/lang/String;)V :goto_0 return v2 .line 63 :cond_1 new-instance p1, Ljava/io/IOException; invoke-direct {p1}, Ljava/io/IOException;->()V check-cast p1, Ljava/lang/Throwable; throw p1 :try_end_2 .catch Lcom/vk/api/sdk/exceptions/VKApiExecutionException; {:try_start_2 .. :try_end_2} :catch_2 .catch Ljava/lang/Throwable; {:try_start_2 .. :try_end_2} :catch_1 .line 86 :catch_1 new-instance p1, Ljava/lang/StringBuilder; invoke-direct {p1}, Ljava/lang/StringBuilder;->()V const-string v2, "Request " invoke-virtual {p1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v0}, Lcom/vk/api/base/ApiRequest;->v()Ljava/lang/String; move-result-object v0 invoke-virtual {p1, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; const-string v0, " failed" invoke-virtual {p1, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {p1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object p1 invoke-direct {p0, p1}, Lcom/vk/api/base/persistent/PersistentRequestManager;->a(Ljava/lang/String;)V return v1 :catch_2 move-exception p1 .line 78 invoke-virtual {p1}, Lcom/vk/api/sdk/exceptions/VKApiExecutionException;->o()I move-result p1 if-eq p1, v2, :cond_2 const/4 v3, 0x6 if-eq p1, v3, :cond_2 const/16 v3, 0xa if-eq p1, v3, :cond_2 if-lez p1, :cond_2 const/4 v1, 0x1 .line 83 :cond_2 new-instance v2, Ljava/lang/StringBuilder; invoke-direct {v2}, Ljava/lang/StringBuilder;->()V const-string v3, "Request " invoke-virtual {v2, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v0}, Lcom/vk/api/base/ApiRequest;->v()Ljava/lang/String; move-result-object v0 invoke-virtual {v2, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; const-string v0, " failed with code " invoke-virtual {v2, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v2, p1}, Ljava/lang/StringBuilder;->append(I)Ljava/lang/StringBuilder; const-string p1, ". Continue?: " invoke-virtual {v2, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v2, v1}, Ljava/lang/StringBuilder;->append(Z)Ljava/lang/StringBuilder; invoke-virtual {v2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object p1 invoke-direct {p0, p1}, Lcom/vk/api/base/persistent/PersistentRequestManager;->a(Ljava/lang/String;)V return v1 .end method .method private final b(Lcom/vk/api/base/persistent/PersistentRequest;)V .locals 3 .line 107 sget-object v0, Lcom/vk/common/cache/SerializerCache;->a:Lcom/vk/common/cache/SerializerCache; const-string v1, "persistent_request_queue" invoke-virtual {v0, v1}, Lcom/vk/common/cache/SerializerCache;->b(Ljava/lang/String;)Lio/reactivex/Observable; move-result-object v0 .line 108 invoke-static {v0}, Lcom/vk/core/extensions/RxExt2;->a(Lio/reactivex/Observable;)Ljava/lang/Object; move-result-object v0 check-cast v0, Ljava/util/List; if-eqz v0, :cond_0 new-instance v1, Ljava/util/LinkedList; check-cast v0, Ljava/util/Collection; invoke-direct {v1, v0}, Ljava/util/LinkedList;->(Ljava/util/Collection;)V goto :goto_0 :cond_0 new-instance v1, Ljava/util/LinkedList; invoke-direct {v1}, Ljava/util/LinkedList;->()V .line 109 :goto_0 invoke-virtual {v1, p1}, Ljava/util/LinkedList;->add(Ljava/lang/Object;)Z .line 110 sget-object v0, Lcom/vk/common/cache/SerializerCache;->a:Lcom/vk/common/cache/SerializerCache; const-string v2, "persistent_request_queue" check-cast v1, Ljava/util/List; invoke-virtual {v0, v2, v1}, Lcom/vk/common/cache/SerializerCache;->a(Ljava/lang/String;Ljava/util/List;)V .line 111 new-instance v0, Ljava/lang/StringBuilder; invoke-direct {v0}, Ljava/lang/StringBuilder;->()V const-string v1, "Request persisted " invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v0, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder; invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object p1 invoke-direct {p0, p1}, Lcom/vk/api/base/persistent/PersistentRequestManager;->a(Ljava/lang/String;)V return-void .end method .method private final c()V .locals 3 .line 51 invoke-direct {p0}, Lcom/vk/api/base/persistent/PersistentRequestManager;->d()Lcom/vk/api/base/persistent/PersistentRequest; move-result-object v0 .line 52 new-instance v1, Ljava/lang/StringBuilder; invoke-direct {v1}, Ljava/lang/StringBuilder;->()V const-string v2, "Got " invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v1, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder; const-string v2, " from queue" invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object v1 invoke-direct {p0, v1}, Lcom/vk/api/base/persistent/PersistentRequestManager;->a(Ljava/lang/String;)V if-eqz v0, :cond_0 .line 53 invoke-direct {p0, v0}, Lcom/vk/api/base/persistent/PersistentRequestManager;->a(Lcom/vk/api/base/persistent/PersistentRequest;)Z move-result v0 if-eqz v0, :cond_0 .line 54 invoke-direct {p0}, Lcom/vk/api/base/persistent/PersistentRequestManager;->e()V const-wide/16 v0, 0xbb8 .line 55 invoke-static {v0, v1}, Ljava/lang/Thread;->sleep(J)V .line 56 sget-object v0, Lcom/vk/api/base/persistent/PersistentRequestManager;->b:Ljava/util/concurrent/ExecutorService; sget-object v1, Lcom/vk/api/base/persistent/PersistentRequestManager$d;->a:Lcom/vk/api/base/persistent/PersistentRequestManager$d; check-cast v1, Ljava/lang/Runnable; invoke-interface {v0, v1}, Ljava/util/concurrent/ExecutorService;->submit(Ljava/lang/Runnable;)Ljava/util/concurrent/Future; :cond_0 return-void .end method .method private final d()Lcom/vk/api/base/persistent/PersistentRequest; .locals 2 .line 92 sget-object v0, Lcom/vk/common/cache/SerializerCache;->a:Lcom/vk/common/cache/SerializerCache; const-string v1, "persistent_request_queue" invoke-virtual {v0, v1}, Lcom/vk/common/cache/SerializerCache;->b(Ljava/lang/String;)Lio/reactivex/Observable; move-result-object v0 invoke-static {v0}, Lcom/vk/core/extensions/RxExt2;->a(Lio/reactivex/Observable;)Ljava/lang/Object; move-result-object v0 check-cast v0, Ljava/util/List; if-eqz v0, :cond_1 .line 93 invoke-interface {v0}, Ljava/util/List;->isEmpty()Z move-result v1 if-eqz v1, :cond_0 goto :goto_0 :cond_0 const/4 v1, 0x0 .line 94 invoke-interface {v0, v1}, Ljava/util/List;->get(I)Ljava/lang/Object; move-result-object v0 check-cast v0, Lcom/vk/api/base/persistent/PersistentRequest; return-object v0 :cond_1 :goto_0 const/4 v0, 0x0 return-object v0 .end method .method private final e()V .locals 4 .line 98 sget-object v0, Lcom/vk/common/cache/SerializerCache;->a:Lcom/vk/common/cache/SerializerCache; const-string v1, "persistent_request_queue" invoke-virtual {v0, v1}, Lcom/vk/common/cache/SerializerCache;->b(Ljava/lang/String;)Lio/reactivex/Observable; move-result-object v0 .line 99 invoke-static {v0}, Lcom/vk/core/extensions/RxExt2;->a(Lio/reactivex/Observable;)Ljava/lang/Object; move-result-object v0 check-cast v0, Ljava/util/List; if-eqz v0, :cond_0 new-instance v1, Ljava/util/LinkedList; check-cast v0, Ljava/util/Collection; invoke-direct {v1, v0}, Ljava/util/LinkedList;->(Ljava/util/Collection;)V goto :goto_0 :cond_0 const/4 v1, 0x0 :goto_0 if-eqz v1, :cond_2 .line 100 invoke-virtual {v1}, Ljava/util/LinkedList;->isEmpty()Z move-result v0 if-eqz v0, :cond_1 goto :goto_1 .line 101 :cond_1 invoke-virtual {v1}, Ljava/util/LinkedList;->removeFirst()Ljava/lang/Object; move-result-object v0 check-cast v0, Lcom/vk/api/base/persistent/PersistentRequest; .line 102 sget-object v2, Lcom/vk/common/cache/SerializerCache;->a:Lcom/vk/common/cache/SerializerCache; const-string v3, "persistent_request_queue" check-cast v1, Ljava/util/List; invoke-virtual {v2, v3, v1}, Lcom/vk/common/cache/SerializerCache;->a(Ljava/lang/String;Ljava/util/List;)V .line 103 new-instance v1, Ljava/lang/StringBuilder; invoke-direct {v1}, Ljava/lang/StringBuilder;->()V const-string v2, "Request removed " invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v1, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder; invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object v0 invoke-direct {p0, v0}, Lcom/vk/api/base/persistent/PersistentRequestManager;->a(Ljava/lang/String;)V return-void :cond_2 :goto_1 return-void .end method # virtual methods .method public final a()V .locals 4 .line 35 new-instance v0, Landroid/os/Handler; invoke-static {}, Landroid/os/Looper;->getMainLooper()Landroid/os/Looper; move-result-object v1 invoke-direct {v0, v1}, Landroid/os/Handler;->(Landroid/os/Looper;)V sget-object v1, Lcom/vk/api/base/persistent/PersistentRequestManager$c;->a:Lcom/vk/api/base/persistent/PersistentRequestManager$c; check-cast v1, Ljava/lang/Runnable; const-wide/16 v2, 0x2710 invoke-virtual {v0, v1, v2, v3}, Landroid/os/Handler;->postDelayed(Ljava/lang/Runnable;J)Z return-void .end method .method public final a(Lcom/vk/api/base/ApiRequest;)V .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lcom/vk/api/base/ApiRequest<", "*>;)V" } .end annotation const-string v0, "request" invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->b(Ljava/lang/Object;Ljava/lang/String;)V .line 30 new-instance v0, Ljava/lang/StringBuilder; invoke-direct {v0}, Ljava/lang/StringBuilder;->()V const-string v1, "Persist request " invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {p1}, Lcom/vk/api/base/ApiRequest;->v()Ljava/lang/String; move-result-object v1 invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object v0 invoke-direct {p0, v0}, Lcom/vk/api/base/persistent/PersistentRequestManager;->a(Ljava/lang/String;)V .line 31 sget-object v0, Lcom/vk/api/base/persistent/PersistentRequestManager;->b:Ljava/util/concurrent/ExecutorService; new-instance v1, Lcom/vk/api/base/persistent/PersistentRequestManager$a; invoke-direct {v1, p1}, Lcom/vk/api/base/persistent/PersistentRequestManager$a;->(Lcom/vk/api/base/ApiRequest;)V check-cast v1, Ljava/lang/Runnable; invoke-interface {v0, v1}, Ljava/util/concurrent/ExecutorService;->submit(Ljava/lang/Runnable;)Ljava/util/concurrent/Future; return-void .end method .method public final b()V .locals 7 const-string v0, "Persisted requests run" .line 39 invoke-direct {p0, v0}, Lcom/vk/api/base/persistent/PersistentRequestManager;->a(Ljava/lang/String;)V .line 40 invoke-static {}, Landroid/os/SystemClock;->elapsedRealtime()J move-result-wide v0 sget-wide v2, Lcom/vk/api/base/persistent/PersistentRequestManager;->c:J sub-long v4, v0, v2 const-wide/16 v0, 0x2710 cmp-long v2, v4, v0 if-gez v2, :cond_0 .line 41 new-instance v0, Ljava/lang/StringBuilder; invoke-direct {v0}, Ljava/lang/StringBuilder;->()V const-string v1, "Do nothing, run threshold. " invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-static {}, Landroid/os/SystemClock;->elapsedRealtime()J move-result-wide v1 sget-wide v3, Lcom/vk/api/base/persistent/PersistentRequestManager;->c:J sub-long v5, v1, v3 invoke-virtual {v0, v5, v6}, Ljava/lang/StringBuilder;->append(J)Ljava/lang/StringBuilder; const-string v1, "ms elapsed" invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object v0 invoke-direct {p0, v0}, Lcom/vk/api/base/persistent/PersistentRequestManager;->a(Ljava/lang/String;)V .line 43 :cond_0 invoke-static {}, Landroid/os/SystemClock;->elapsedRealtime()J move-result-wide v0 sput-wide v0, Lcom/vk/api/base/persistent/PersistentRequestManager;->c:J .line 44 sget-object v0, Lcom/vk/api/base/persistent/PersistentRequestManager;->b:Ljava/util/concurrent/ExecutorService; sget-object v1, Lcom/vk/api/base/persistent/PersistentRequestManager$b;->a:Lcom/vk/api/base/persistent/PersistentRequestManager$b; check-cast v1, Ljava/lang/Runnable; invoke-interface {v0, v1}, Ljava/util/concurrent/ExecutorService;->submit(Ljava/lang/Runnable;)Ljava/util/concurrent/Future; return-void .end method