fb_mqtt_write: fix unreachable input_add (priv->wev was always 0)

This was the only line that assigned anything to priv->wev, and it was
behind an (incorrect) condition that checked if it's nonzero.

That would have replaced priv->wev if the condition was ever true, but
since it wasn't, the only result is potentially delayed writes
(for example, filling the write buffer and only writing the rest a
minute later when pinging the server)

The new condition also checks the return value of fb_mqtt_cb_write(),
which is true if it should continue writing, or false otherwise.

1 files changed, 1 insertions, 2 deletions

diff --git a/facebook/facebook-mqtt.c b/facebook/facebook-mqtt.c
index de0fee6..ab3589c 100644
--- a/facebook/facebook-mqtt.c
+++ b/facebook/facebook-mqtt.c
@@ -549,9 +549,8 @@ fb_mqtt_write(FbMqtt *mqtt, FbMqttMessage *msg)
 
     fd = ssl_getfd(priv->ssl);
     g_byte_array_append(priv->wbuf, bytes->data, bytes->len);
-    fb_mqtt_cb_write(mqtt, fd, B_EV_IO_WRITE);
 
-    if (priv->wev > 0) {
+    if (fb_mqtt_cb_write(mqtt, fd, B_EV_IO_WRITE) && (priv->wev < 1)) {
         priv->wev = b_input_add(fd, B_EV_IO_WRITE, fb_mqtt_cb_write, mqtt);
     }
 }