Function fix_bond_socket_list

socket_info.c:266–376

int fix_bond_socket_list(struct socket_id *list)
{
	struct socket_id *sid;
	struct socket_id *next_sid;
	struct socket_bond_elem *be;
	struct socket_info_full *sif = NULL;
	struct socket_info_full *orig_sif;
	struct socket_info_ref *ref;
	const struct socket_info *bond_si;
	str bond_spec, host;
	int port, proto, found_any;

	for (sid = list; sid; sid = next_sid) {

		next_sid = sid->next;

		if (sid->proto!=PROTO_BOND) {
			LM_BUG("non-bond socket found in the list\n");
			goto error;
		}

		sif = new_sock_info(sid, NULL);
		if (!sif) {
			LM_ERR("failed to build socket info for bond <%s>\n", sid->name);
			goto error;
		}

		for (be = sid->bond_list; be; be = be->next) {
			bond_spec.s = be->name;
			bond_spec.len = strlen(be->name);
			found_any = 0;
			if (parse_phostport(bond_spec.s, bond_spec.len, &host.s, &host.len,
					&port, &proto) != 0) {
				LM_WARN("failed to parse bond member <%s> for bond <%s>\n",
					be->name, sid->name);
				continue;
			}

			bond_si = grep_internal_sock_info(&host, (unsigned short)port,
				(unsigned short)proto);
			if (bond_si) {
				found_any = 1;
				ref = pkg_malloc(sizeof(*ref));
				if (!ref) {
					LM_ERR("pkg memory allocation failed while building "
						"bond <%s>\n", sid->name);
					goto error;
				}
				ref->si = bond_si;
				ref->next = sif->socket_info.bond_sis;
				sif->socket_info.bond_sis = ref;

				LM_DBG("bond socket [%.*s] including real socket [%.*s]\n",
					sif->socket_info.name.len, sif->socket_info.name.s,
					bond_si->sock_str.len, bond_si->sock_str.s);
				continue;
			}