diff --git a/src/libipc/ipc.cpp b/src/libipc/ipc.cpp index e89f435..26bf1e9 100755 --- a/src/libipc/ipc.cpp +++ b/src/libipc/ipc.cpp @@ -588,8 +588,9 @@ static bool send(F&& gen_push, ipc::handle_t h, void const * data, std::size_t s } static bool send(ipc::handle_t h, void const * data, std::size_t size, std::uint64_t tm) { - return send([tm](auto *info, auto *que, auto msg_id) { - return [tm, info, que, msg_id](std::int32_t remain, void const * data, std::size_t size) { + LIBIPC_LOG(); + return send([tm, &log](auto *info, auto *que, auto msg_id) { + return [tm, &log, info, que, msg_id](std::int32_t remain, void const * data, std::size_t size) { if (!wait_for(info->wt_waiter_, [&] { return !que->push( [](void*) { return true; }, diff --git a/src/libipc/prod_cons.h b/src/libipc/prod_cons.h index 482f058..ca00b7c 100755 --- a/src/libipc/prod_cons.h +++ b/src/libipc/prod_cons.h @@ -365,6 +365,7 @@ struct prod_cons_impl> { template bool force_push(W* wrapper, F&& f, E* elems) { + LIBIPC_LOG(); E* el; circ::u2_t cur_ct; rc_t epoch = epoch_.fetch_add(ep_incr, std::memory_order_release) + ep_incr;