作者:付汉杰,hankf@xilinx.com,文章转载自:赛灵思中文社区论坛
在OpenAMP的应用程序中,经常看到地址被设置成RPMSG_ADDR_ANY。在通信过程中,为什么可以把源地址、目的地址设置成任意值?
这个宏的名字不够清楚,它的本意是让系统自动选择。如果设置源地址为RPMSG_ADDR_ANY,则系统自动选择一个空闲的源地址。如果设置目的地址为RPMSG_ADDR_ANY,则系统会自动发送一个查询消息,根据名称查询对方的地址,相当于TCP/IP中的域名解析。
查看代码,我们可以确认以上结论。第一个函数是rpmsg_create_ept(),提供源地址、目的地址后,它创建rpmsg endpoint(节点)。
下面代码显示,如果调用rpmsg_create_ept()时指定了源地址,会调用rpmsg_is_address_set设置源地址,相当于TCP/IP中的Bind。如果调用rpmsg_create_ept()时没有指定源地址,则会调用rpmsg_get_address(),自动从设备中没有使用的地址中取一个地址。
// rpmsg.c int rpmsg_create_ept(struct rpmsg_endpoint *ept, struct rpmsg_device *rdev, const char *name, uint32_t src, uint32_t dest, rpmsg_ept_cb cb, rpmsg_ns_unbind_cb unbind_cb) { ... ... if (src != RPMSG_ADDR_ANY) { status = rpmsg_is_address_set(rdev->bitmap, RPMSG_ADDR_BMP_SIZE, src); if (!status) { /* Mark the address as used in the address bitmap. */ rpmsg_set_address(rdev->bitmap, RPMSG_ADDR_BMP_SIZE, src); } else if (status > 0) { status = RPMSG_SUCCESS; goto ret_status; } else { goto ret_status; } } else { addr = rpmsg_get_address(rdev->bitmap, RPMSG_ADDR_BMP_SIZE); } ... ... return status; } // rpmsg.c static uint32_t rpmsg_get_address(unsigned long *bitmap, int size) { unsigned int addr = RPMSG_ADDR_ANY; unsigned int nextbit; nextbit = metal_bitmap_next_clear_bit(bitmap, 0, size); if (nextbit < (uint32_t)size) { addr = nextbit; metal_bitmap_set_bit(bitmap, nextbit); } return addr; }
如果调用rpmsg_create_ept()时没有指定目的地址,会调用rpmsg_send_ns_message()发送消息,之后就会返回。如果另外一侧返回消息后,会触发的调用rpmsg_virtio_rx_callback()。在rpmsg_virtio_rx_callback中,从消息中得到entpoint信息,检查其中的目的地址,如果目的地址是ANY,就会从消息中提取出远端地址,赋值给本地endpoint的目的地址。
// rpmsg.c int rpmsg_create_ept(struct rpmsg_endpoint *ept, struct rpmsg_device *rdev, const char *name, uint32_t src, uint32_t dest, rpmsg_ept_cb cb, rpmsg_ns_unbind_cb unbind_cb) { ... ... if (!status && ept- > dest_addr == RPMSG_ADDR_ANY) { /* Send NS announcement to remote processor */ metal_mutex_release(&rdev- > lock); status = rpmsg_send_ns_message(ept, RPMSG_NS_CREATE); metal_mutex_acquire(&rdev- > lock); if (status) rpmsg_unregister_endpoint(ept); } ... ... return status; } // rpmsg_virtio.c static void rpmsg_virtio_rx_callback(struct virtqueue *vq) { ... ... /* Process the received data from remote node */ rp_hdr = (struct rpmsg_hdr *)rpmsg_virtio_get_rx_buffer(rvdev, &len, &idx); while (rp_hdr) { ept = rpmsg_get_ept_from_addr(rdev, rp_hdr->dst); if (ept->dest_addr == RPMSG_ADDR_ANY) { /* * First message received from the remote side, * update channel destination address */ ept->dest_addr = rp_hdr->src; } status = ept->cb(ept, (void *)RPMSG_LOCATE_DATA(rp_hdr), rp_hdr->len, ept->addr, ept->priv); } ... ... }