Function notify_thread

app/master/daemon/master/master_warning.cpp:67–110

}

static void notify_thread(void *arg)
{
	const char *myname = "notify_thread";
	WARN_INFO *info = (WARN_INFO*) arg;
	ACL_VSTREAM *client;
	ACL_VSTRING *buf;
	int   ret;

	buf = acl_vstring_alloc(256);
	add_str(buf, "path", info->path);
	add_str(buf, "conf", info->conf);
	add_str(buf, "ver", info->ver);
	add_num(buf, "pid", info->pid);
	add_str(buf, "rcpt", info->notify_recipients);
	add_str(buf, "info", info->desc);
	acl_vstring_strcat(buf, "\r\n");

	client = acl_vstream_connect(info->notify_addr,
		ACL_BLOCKING, 60, 60, 1024);
	if (client == NULL) {
		acl_msg_error("%s(%d): connect %s error, info(%s)", myname,
			__LINE__, info->notify_addr, acl_vstring_str(buf));
		acl_vstring_free(buf);
		warn_info_free(info);
		return;
	}

	/* ��ֹ���þ�����ݸ��ӽ��� */
	acl_close_on_exec(ACL_VSTREAM_SOCK(client), ACL_CLOSE_ON_EXEC);

	//acl_msg_info(">>>>Notify=[%s]<<<<<", acl_vstring_str(buf));
	ret = acl_vstream_writen(client, acl_vstring_str(buf),
		ACL_VSTRING_LEN(buf));
	if (ret == ACL_VSTREAM_EOF)
		acl_msg_error("%s(%d): write to notify server error, info(%s)",
			myname, __LINE__, acl_vstring_str(buf));
	else
		acl_msg_info("%s(%d): notify %s ok!",
			myname, __LINE__, info->notify_addr);

	acl_vstream_close(client);
	acl_vstring_free(buf);
	warn_info_free(info);
}

void master_warning(const char *notify_addr, const char *recipients,
	const char *path, const char *conf, const char *ver,