Function rtpe_function_call

modules/rtpengine/rtpengine.c:2872–3022

}

static bencode_item_t *rtpe_function_call(bencode_buffer_t *bencbuf, struct sip_msg *msg,
	enum rtpe_operation op, str *flags_str, str *body_in, pv_spec_t *spvar,
	struct rtpe_set *set, str *snode, bencode_item_t *extra_dict)
{
	struct ng_flags_parse ng_flags;
	bencode_item_t *resp;
	str error;
	struct rtpe_node *node, *failed_node;
	char *cp, *err = NULL;
	pv_value_t val, socket_val;
	struct rtpe_ignore_node *ignore_list = NULL;
	int ret, forced_socket;
	memset(&ng_flags, 0, sizeof(ng_flags));
	error.len = 0;
	error.s = "";

	/*** get & init basic stuff needed ***/
	if (rtpe_function_call_prepare(bencbuf, msg, op, &ng_flags, flags_str, body_in, extra_dict,&err) < 0)
		goto error;

	/*** set can be passed into this routine. If it is NULL, then attempt to determine it. ***/
	if (!set) {
		if ((set=rtpe_ctx_set_get())==NULL)
			set = *default_rtpe_set;
	}

	/*** If the spvar "sock_var" has been specified, parse it into a (socket_val) STR variable ***/
	memset(&socket_val, 0, sizeof(pv_value_t));
	if (spvar)
		pv_get_spec_value(msg, spvar, &socket_val);
	forced_socket = socket_val.rs.len > 0;

	failed_node = NULL;

	RTPE_START_READ();
	do {
		/*
		 * Many rtpengine_* commands allow a "sock_var" to be specified by the script writer.
		 * The "sock_var" will be populated by the rtpengine_* command with the RTPEngine that
		 * was chosen for the operation.
		 *
		 * The "sock_var" can be used by subsequent rtpengine_* commands to direct the command
		 * toward a specific RTPEngine instance.
		 */
		if (spvar && (socket_val.rs.len > 0)) {
			LM_DBG("Sending command [%d] to RTPEngine socket: [%.*s] set id: [%d]\n", op, (int)(socket_val.rs.len), (char *)(socket_val.rs.s), set->id_set);
			node = lookup_rtpe_node(set, &socket_val.rs);
			socket_val.rs.s = NULL;
			socket_val.rs.len = 0;
			if (node && ((node->rn_disabled = rtpe_test(node, node->rn_disabled, 0)) ||
					rtpe_is_ignore_node(ignore_list, node))) {
				LM_DBG("RTPEngine socket [%.*s] is not available\n",
						node->rn_url.len, node->rn_url.s);
				node = NULL;
			}

			if (node == NULL && op == OP_OFFER)
				node = select_rtpe_node(ng_flags.call_id, set, ignore_list);