豆豆网 > 技术应用 > 操作系统 > Linux/Unix > Linux/Unix编程 > 正文

Heartbeat的可靠消息通信实现分析

http://tech.ddvip.com 2007年05月21日社区交流

关键字： ARM linux 内核栈 zImage ktype AWK

本文详细介绍Heartbeat的可靠消息通信实现分析

　　Heartbeat在process_outbound_packet()函数里实现了一个可靠的多播协议，它利用一个循环队列来存放历史消息，对于带有序列号的心跳消息，先存放到历史消息队列里然后发送，接收者可以请求发送传重传该消息，对于不带序列号的控制消息，不会进行重传。下面是这个函数的实现代码。

static int process_outbound_packet(struct msg_xmit_hist *hist,
struct ha_msg *msg)
{
...
const char *cseq;
seqno_t seqno = -1;
const char *to;
int IsToUs;
size_t len;
...
if ((type = ha_msg_value(msg, F_TYPE)) == NULL) {
...
return HA_FAIL;
}
if ((cseq = ha_msg_value(msg, F_SEQ)) != NULL) {
if (sscanf(cseq, “%lx”, &seqno) != 1 || seqno <= 0) {
...
return HA_FAIL;
}
}
to = ha_msg_value(msg, F_TO);
IsToUs = (to != NULL) && (strcmp(to, curnode->nodename) == 0);
/*把消息转换成字符串*/
smsg = msg2wirefmt(msg, &len);
...
if (cseq != NULL) {
/*存放到历史消息队列里，通过序列号记录，如果需要，则进行重传*/
add2_xmit_hist(hist, msg, seqno);
}
...
/*通过write子进程发送到所有的网络接口上*/
send_to_all_media(smsg, len);
...
return HA_OK;
}

　　add2_xmit_hist()函数把发送的消息发到一个历史消息队列里去，队列的最大长度为200。如果接收者请求重传消息，发送者通过序列号在该队列里查找要重传的消息，如果找到则进行重传。下面是相关代码。

责编：豆豆技术应用

正在加载评论...