Function call_callbacks

bin_interface.c:448–505

* main binary packet receiver loop */

 * main binary packet receiver loop
 */
void call_callbacks(char* buffer, struct receive_info *rcv)
{
	struct packet_cb_list *p;
	unsigned int pkg_len;
	bin_packet_t packet;
	str capability;

	memcpy(&pkg_len, buffer + BIN_PACKET_MARKER_SIZE, sizeof(unsigned int));
	if (pkg_len < HEADER_SIZE + LEN_FIELD_SIZE + CMD_FIELD_SIZE) {
		LM_ERR("invalid BIN packet size %u\n", pkg_len);
		return;
	}
	if (pkg_len > BIN_MAX_BUF_LEN) {
		LM_ERR("BIN packet size %u exceeds max size %zu\n",
				pkg_len, (size_t)BIN_MAX_BUF_LEN);
		return;
	}

	//add extra size so a realloc wont trigger after small altering of the packet 
	packet.buffer.s = pkg_malloc(pkg_len + 50);
	if (!packet.buffer.s) {
		LM_ERR("oom\n");
		return;
	}

	packet.buffer.len = pkg_len;
	packet.size = pkg_len + 50;
	packet.flags = 0;
	memcpy(packet.buffer.s, buffer, pkg_len);

	bin_get_capability(&packet, &capability);
	if ((unsigned int)capability.len >
			pkg_len - HEADER_SIZE - LEN_FIELD_SIZE - CMD_FIELD_SIZE) {
		LM_ERR("invalid BIN packet capability length %d for packet size %u\n",
				capability.len, pkg_len);
		bin_free_packet(&packet);
		return;
	}

	packet.front_pointer = capability.s + capability.len + CMD_FIELD_SIZE;
	memcpy(&packet.type, capability.s + capability.len, sizeof(int));

	/* packet will be now processed for a specific capability */
	for (p = reg_cbs; p; p = p->next) {
		if (p->capability.len == capability.len &&
		    memcmp(capability.s, p->capability.s, capability.len) == 0) {

			LM_DBG("binary Packet CMD: %d. Capability: %.*s\n",
					packet.type, capability.len, capability.s);

			p->cbf(&packet, packet.type, rcv,p->att);

			break;
		}
	}

	bin_free_packet(&packet);
}