Function rtpproxy_get_stream_index

modules/rtpproxy/rtpproxy.c:5789–5834

}

static struct rtpproxy_copy_stream *rtpproxy_get_stream_index(
		struct rtpproxy_copy_ctx *ctx, unsigned int *leg, sdp_stream_cell_t *stream)
{
	struct rtpproxy_copy_stream *rtp_stream;
	struct list_head *it;
	unsigned int label;
	sdp_attr_t *attr;
	/* if we are in SIPREC mode, we need to search based on index */
	if (ctx->flags & RTP_COPY_MODE_SIPREC) {
		for (attr = stream->attr; attr; attr = attr->next) {
			if (attr->value.len &&
					str_match(&attr->attribute, const_str("label"))) {
				if (str2int(&attr->value, &label) < 0) {
					LM_ERR("invalid label number: %.*s - should have been numeric\n",
							attr->value.len, attr->value.s);
					continue;
				} else {
					break;
				}
			}
		}
		if (attr != NULL) {
			/* search for the proper label */
			for (*leg = RTP_RELAY_CALLER; *leg <= RTP_RELAY_CALLEE; (*leg)++) {
				list_for_each(it, &ctx->streams[*leg]) {
					rtp_stream = list_entry(it, struct rtpproxy_copy_stream, list);
					if (rtp_stream->index == label)
						return rtp_stream;
				}
			}
			LM_WARN("label %u not found - match based on media index %d\n",
					label, stream->stream_num);
		} else {
			LM_WARN("label not found - match based on media index %d\n",
					stream->stream_num);
		}
	}
	for (*leg = RTP_RELAY_CALLER; *leg <= RTP_RELAY_CALLEE; (*leg)++) {
		list_for_each(it, &ctx->streams[*leg]) {
			rtp_stream = list_entry(it, struct rtpproxy_copy_stream, list);
			if (rtp_stream->medianum == stream->stream_num)
				return rtp_stream;
		}
	}
	return NULL;
}

static int rtpproxy_handle_recording(struct rtpproxy_copy_ctx *ctx,
		struct rtpp_args *args, str *flags, str *body)