Merge pull request #32 from Anotra/fix_timer

Fix io_poller timer

core/io_poller.c

@@ -104,7 +104,8 @@ io_poller_perform(struct io_poller *io)
     }
     for (int i = 0; i < io->curlm_cnt; i++) {
         struct io_curlm *curlm = io->curlm[i];
-        if (curlm->should_perform || now >= curlm->timeout) {
+        if (curlm->should_perform || 
+            (-1 != curlm->timeout && now >= curlm->timeout)) {
             curlm->should_perform = false;
             int result = curlm->cb ?
                 curlm->cb(curlm->multi, curlm->user_data) :
@@ -312,4 +313,4 @@ io_poller_curlm_enable_perform(struct io_poller *io, CURLM *multi)
         if (io->curlm[i]->multi == multi)
             return (io->curlm[i]->should_perform = true);
     return false;
-}
+}

src/adapter.c

@@ -663,6 +663,9 @@ _discord_adapter_send(struct discord_adapter *adapter,
     /* initiate libcurl transfer */
     mcode = curl_multi_add_handle(adapter->mhandle, ehandle);
 
+    io_poller_curlm_enable_perform(CLIENT(adapter, adapter)->io_poller,
+                                   adapter->mhandle);
+
     QUEUE_INSERT_TAIL(&cxt->bucket->busyq, &cxt->entry);
 
     return mcode ? CCORD_CURLM_INTERNAL : CCORD_OK;

src/client.c

@@ -325,7 +325,8 @@ discord_run(struct discord *client)
             if (next_gateway_run <= now) {
                 if (CCORD_OK != (code = discord_gateway_perform(&client->gw)))
                     break;
-
+                if (CCORD_OK != (code = discord_adapter_perform(&client->adapter)))
+                    break;
                 next_gateway_run = now + 1000;
             }
         }