Tweak group polling concurrency (#1661)

Author: SessionHero01

app/src/main/java/org/session/libsignal/utilities/HTTP.kt

@@ -162,8 +162,8 @@ object HTTP {
     private val httpCallSemaphore = Semaphore(20)
 
     private suspend fun Call.await(): Response {
-        return withContext(Dispatchers.IO) {
-            httpCallSemaphore.withPermit {
+        return httpCallSemaphore.withPermit {
+            withContext(Dispatchers.IO) {
                 execute()
             }
         }

app/src/main/java/org/thoughtcrime/securesms/groups/GroupPoller.kt

@@ -226,6 +226,8 @@ class GroupPoller @AssistedInject constructor(
                     throw NonRetryableException("Group has been kicked")
                 }
 
+                Log.v(TAG, "Start polling group($groupId) message snode = ${snode.ip}")
+
                 val adminKey = group.adminKey
 
                 val pollingTasks = mutableListOf<Pair<String, Deferred<*>>>()
@@ -270,7 +272,6 @@ class GroupPoller @AssistedInject constructor(
                         Namespace.GROUP_MESSAGES()
                     ).orEmpty()
 
-                    Log.v(TAG, "Retrieving group($groupId) message since lastHash = $lastHash, snode = ${snode.publicKeySet}")
 
                     SnodeAPI.sendBatchRequest(
                         snode = snode,
@@ -356,6 +357,8 @@ class GroupPoller @AssistedInject constructor(
             }
         }
 
+        Log.d(TAG, "Group($groupId) polling completed, success = ${result.isSuccess}")
+
         if (result.isFailure) {
             val error = result.exceptionOrNull()
             Log.e(TAG, "Error polling group", error)

app/src/main/java/org/thoughtcrime/securesms/groups/GroupPollerManager.kt

@@ -58,7 +58,7 @@ class GroupPollerManager @Inject constructor(
     pollFactory: GroupPoller.Factory,
     @param:ManagerScope private val managerScope: CoroutineScope,
 ) : OnAppStartupComponent {
-    private val groupPollerSemaphore = Semaphore(5)
+    private val groupPollerSemaphore = Semaphore(20)
 
     @Suppress("OPT_IN_USAGE")
     private val groupPollers: StateFlow<Map<AccountId, GroupPollerHandle>> =