Ticket #1190: fix_osplugin_plugin_queue_v2.diff

opensync/ipc/opensync_queue_internals.h

@@ -90 +90 @@
 OSYNC_TEST_EXPORT void osync_queue_set_message_handler(OSyncQueue *queue, OSyncMessageHandler handler, gpointer user_data);
 
 /**
- * @brief Cross links command queue and reply queue
- * 
- * Stores the queue used for replies in the command queue object so
- * that timeout responses can be sent if necessary.
- * And stores the command queue in the reply queue object so that
- * replies can remove pending messages before they time out.
- * 
- * @param cmd_queue The command queue used to receive incoming commands
- * @param reply_queue The queue used to send replies 
- * 
- */
-OSYNC_TEST_EXPORT void osync_queue_cross_link(OSyncQueue *cmd_queue, OSyncQueue *reply_queue);
-
-/**
  * @brief Remove cross links between command queues and reply queues
  * 
  * Removes the cross-links from this queue and all queues linked

opensync/ipc/opensync_queue.h

@@ -120 +120 @@
  */
 OSYNC_EXPORT osync_bool osync_queue_disconnect(OSyncQueue *queue, OSyncError **error);
 
+/**
+ * @brief Cross links command queue and reply queue
+ * 
+ * Stores the queue used for replies in the command queue object so
+ * that timeout responses can be sent if necessary.
+ * And stores the command queue in the reply queue object so that
+ * replies can remove pending messages before they time out.
+ * 
+ * @param cmd_queue The command queue used to receive incoming commands
+ * @param reply_queue The queue used to send replies 
+ * 
+ */
+OSYNC_EXPORT void osync_queue_cross_link(OSyncQueue *cmd_queue, OSyncQueue *reply_queue);
+
 /*@}*/
 #endif /* _OPENSYNC_QUEUE_H */
 

opensync/client/osplugin.c

@@ -22 +22 @@
 #include "opensync_internals.h"
 
 #include "opensync-ipc.h"
+
 #include "opensync-client.h"
+#include "opensync_client_internals.h"
 
 static void usage (int ecode)
 {
@@ -99 +101 @@
                 if (!osync_client_set_incoming_queue(client, incoming, &error))
                         goto error;
 
-                osync_queue_unref(incoming);
                 if (!osync_client_set_outgoing_queue(client, outgoing, &error))
                         goto error;
 
+                osync_queue_cross_link(incoming, outgoing);
+
+                osync_queue_unref(incoming);
                 osync_queue_unref(outgoing);
         } else {
                 /* Create connection pipes **/

opensync.sym

@@ -654 +654 @@
 osync_plugin_unref
 osync_queue_connect
 osync_queue_create
+osync_queue_cross_link
 osync_queue_disconnect
 osync_queue_new
 osync_queue_new_from_fd