/*
 * =====================================================================================
 *
 *       Filename:  failed_msg.cpp
 *
 *    Description:  
 *
 *        Version:  1.0
 *        Created:  2021年04月12日 16时10分53秒
 *       Revision:  none
 *       Compiler:  gcc
 *
 *         Author:  Li Chao (), lichao@aiotlink.com
 *   Organization:  
 *
 * =====================================================================================
 */
#include "failed_msg.h"

FailedMsgQ::Func FailedMsgQ::PrepareSender(const std::string &remote, Msg const &msg)
{
	msg.AddRef();
	return [remote, msg](void *valid_sock) {
		assert(valid_sock);
		ShmSocket &sock = *static_cast<ShmSocket *>(valid_sock);
		bool r = sock.Send(remote.data(), msg);
		//TODO check remote removed.
		if (r && msg.IsCounted()) {
			auto tmp = msg; // Release() is not const, but it's safe to release.
			tmp.Release(sock.shm());
		}
		return r;
	};
}