Imported Upstream version 0.1.17

[platform/upstream/libnice.git] / socket / socket.c

diff --git a/socket/socket.c b/socket/socket.c
index 260a190..860feea 100644 (file)
--- a/socket/socket.c
+++ b/socket/socket.c
@@ -333,7 +333,7 @@ nice_socket_queue_send (GQueue *send_queue, const NiceAddress *to,
       offset += len;
     }
 
-    g_assert (offset == tbs->length);
+    g_assert_cmpint (offset, ==, tbs->length);
   }
 }
 
@@ -358,12 +358,6 @@ void nice_socket_queue_send_with_callback (GQueue *send_queue,
   else
     g_queue_push_tail (send_queue, tbs);
 
-  if (io_source && gsock && context && cb && *io_source == NULL) {
-    *io_source = g_socket_create_source(gsock, G_IO_OUT, NULL);
-    g_source_set_callback (*io_source, (GSourceFunc) G_CALLBACK (cb), user_data, NULL);
-    g_source_attach (*io_source, context);
-  }
-
   /* Move the data into the buffer. */
   for (j = 0;
        (message->n_buffers >= 0 && j < (guint) message->n_buffers) ||
@@ -386,6 +380,12 @@ void nice_socket_queue_send_with_callback (GQueue *send_queue,
     else
       message_offset = 0;
   }
+
+  if (io_source && gsock && context && cb && *io_source == NULL) {
+    *io_source = g_socket_create_source(gsock, G_IO_OUT, NULL);
+    g_source_set_callback (*io_source, (GSourceFunc) G_CALLBACK (cb), user_data, NULL);
+    g_source_attach (*io_source, context);
+  }
 }
 
 void nice_socket_flush_send_queue (NiceSocket *base_socket, GQueue *send_queue)