#include <lib/lib_errors.h>
#include "pimd.h"
+#include "pim_instance.h"
#include "pim_mlag.h"
#include "pim_zebra.h"
* Thsi thread reads the clients data from the Gloabl queue and encodes with
* protobuf and pass on to the MLAG socket.
*/
-static int pim_mlag_zthread_handler(struct thread *event)
+static void pim_mlag_zthread_handler(struct thread *event)
{
struct stream *read_s;
uint32_t wr_count = 0;
__func__, wr_count);
if (wr_count == 0)
- return 0;
+ return;
for (wr_count = 0; wr_count < PIM_MLAG_POST_LIMIT; wr_count++) {
/* FIFO is empty,wait for teh message to be add */
if (wr_count >= PIM_MLAG_POST_LIMIT)
pim_mlag_signal_zpthread();
-
- return 0;
}