Function stream_parse

modules/event_stream/event_stream.c:169–284

* This is the parsing function * The socket grammar should be: * ip ':' port ['/'method] */

 * 		 ip ':' port ['/'method]
 */
static evi_reply_sock* stream_parse(str socket)
{
	evi_reply_sock *sock = NULL;
	unsigned short port = 0;
	char *p = NULL;
	str *method;
	str host;
	struct hostent *hentity;
	int len, err;

	if (!socket.len || !socket.s) {
		LM_ERR("no socket specified\n");
		return NULL;
	}

	/* extract host */
	host.s = socket.s;
	p = memchr(socket.s, COLON_C, socket.len);
	if (!p || p == socket.s) {
		LM_ERR("port not specified <%.*s>\n", socket.len, socket.s);
		return NULL;
	}
	host.len = p - socket.s;

	/* used to resolve host */
	*p = '\0';
	/* skip colon */
	socket.s += host.len + 1;
	socket.len -= host.len + 1;

	LM_DBG("host is %.*s - remaining <%.*s>[%d]\n", host.len, host.s,
			socket.len, socket.s, socket.len);

	if (!socket.len || *socket.s == '\0') {
		LM_ERR("invalid port number\n");
		return NULL;
	}

	p = memchr(socket.s, SLASH_C, socket.len);
	if (!p) {
		/* if we do not have a method, we use the event's name */
		p = socket.s + socket.len;
	}

	port = str2s(socket.s, p - socket.s, &err);
	if (port == 0 || err != 0) {
		LM_ERR("malformed port: %.*s\n",(int)(p - socket.s), socket.s);
		return NULL;
	}

	/* jump over ':' */
	socket.len = socket.len - (p - socket.s);
	socket.s = p;

	LM_DBG("port is %hu - remains <%.*s>[%d]\n",
			port, socket.len, socket.s, socket.len);

	if (socket.len) {