Skip to content
Snippets Groups Projects
context.c 38.8 KiB
Newer Older
  • Learn to ignore specific revisions
  • /*
     * libwebsockets - small server side websockets and web server implementation
     *
    
    Andy Green's avatar
    Andy Green committed
     * Copyright (C) 2010-2017 Andy Green <andy@warmcat.com>
    
     *
     *  This library is free software; you can redistribute it and/or
     *  modify it under the terms of the GNU Lesser General Public
     *  License as published by the Free Software Foundation:
     *  version 2.1 of the License.
     *
     *  This library is distributed in the hope that it will be useful,
     *  but WITHOUT ANY WARRANTY; without even the implied warranty of
     *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
     *  Lesser General Public License for more details.
     *
     *  You should have received a copy of the GNU Lesser General Public
     *  License along with this library; if not, write to the Free Software
     *  Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
     *  MA  02110-1301  USA
     */
    
    #include "private-libwebsockets.h"
    
    #ifndef LWS_BUILD_HASH
    #define LWS_BUILD_HASH "unknown-build-hash"
    #endif
    
    static const char *library_version = LWS_LIBRARY_VERSION " " LWS_BUILD_HASH;
    
    /**
     * lws_get_library_version: get version and git hash library built from
     *
     *	returns a const char * to a string like "1.1 178d78c"
     *	representing the library version followed by the git head hash it
     *	was built from
     */
    LWS_VISIBLE const char *
    lws_get_library_version(void)
    {
    	return library_version;
    }
    
    
    Andy Green's avatar
    Andy Green committed
    static const char * const mount_protocols[] = {
    	"http://",
    	"https://",
    	"file://",
    
    	"cgi://",
    	">http://",
    	">https://",
    
    	"callback://"
    
    Andy Green's avatar
    Andy Green committed
    };
    
    
    Andy Green's avatar
    Andy Green committed
    LWS_VISIBLE void *
    
    Andy Green's avatar
    Andy Green committed
    lws_protocol_vh_priv_zalloc(struct lws_vhost *vhost,
    			    const struct lws_protocols *prot, int size)
    
    Andy Green's avatar
    Andy Green committed
    {
    	int n = 0;
    
    	/* allocate the vh priv array only on demand */
    	if (!vhost->protocol_vh_privs) {
    		vhost->protocol_vh_privs = (void **)lws_zalloc(
    
    Andy Green's avatar
    Andy Green committed
    				vhost->count_protocols * sizeof(void *), "protocol_vh_privs");
    
    Andy Green's avatar
    Andy Green committed
    		if (!vhost->protocol_vh_privs)
    			return NULL;
    	}
    
    	while (n < vhost->count_protocols && &vhost->protocols[n] != prot)
    		n++;
    
    
    Andy Green's avatar
    Andy Green committed
    	if (n == vhost->count_protocols) {
    		n = 0;
    		while (n < vhost->count_protocols &&
    		       strcmp(vhost->protocols[n].name, prot->name))
    			n++;
    
    		if (n == vhost->count_protocols)
    			return NULL;
    	}
    
    Andy Green's avatar
    Andy Green committed
    
    
    Andy Green's avatar
    Andy Green committed
    	vhost->protocol_vh_privs[n] = lws_zalloc(size, "vh priv");
    
    Andy Green's avatar
    Andy Green committed
    	return vhost->protocol_vh_privs[n];
    }
    
    LWS_VISIBLE void *
    
    Andy Green's avatar
    Andy Green committed
    lws_protocol_vh_priv_get(struct lws_vhost *vhost,
    			 const struct lws_protocols *prot)
    
    Andy Green's avatar
    Andy Green committed
    {
    	int n = 0;
    
    
    	if (!vhost || !vhost->protocol_vh_privs)
    
    Andy Green's avatar
    Andy Green committed
    		return NULL;
    
    	while (n < vhost->count_protocols && &vhost->protocols[n] != prot)
    		n++;
    
    	if (n == vhost->count_protocols) {
    
    Andy Green's avatar
    Andy Green committed
    		n = 0;
    		while (n < vhost->count_protocols &&
    		       strcmp(vhost->protocols[n].name, prot->name))
    			n++;
    
    		if (n == vhost->count_protocols) {
    			lwsl_err("%s: unknown protocol %p\n", __func__, prot);
    			return NULL;
    		}
    
    Andy Green's avatar
    Andy Green committed
    	}
    
    	return vhost->protocol_vh_privs[n];
    }
    
    
    static const struct lws_protocol_vhost_options *
    
    lws_vhost_protocol_options(struct lws_vhost *vh, const char *name)
    {
    
    	const struct lws_protocol_vhost_options *pvo = vh->pvo;
    
    	while (pvo) {
    		if (!strcmp(pvo->name, name))
    			return pvo;
    		pvo = pvo->next;
    	}
    
    	return NULL;
    }
    
    
    /*
     * inform every vhost that hasn't already done it, that
     * his protocols are initializing
     */
    
    Andy Green's avatar
    Andy Green committed
    LWS_VISIBLE int
    
    Andy Green's avatar
    Andy Green committed
    lws_protocol_init(struct lws_context *context)
    {
    	struct lws_vhost *vh = context->vhost_list;
    
    	const struct lws_protocol_vhost_options *pvo, *pvo1;
    
    Andy Green's avatar
    Andy Green committed
    	struct lws wsi;
    	int n;
    
    	memset(&wsi, 0, sizeof(wsi));
    	wsi.context = context;
    
    
    	lwsl_info("%s\n", __func__);
    
    Andy Green's avatar
    Andy Green committed
    	while (vh) {
    		wsi.vhost = vh;
    
    
    		/* only do the protocol init once for a given vhost */
    		if (vh->created_vhost_protocols)
    			goto next;
    
    
    Andy Green's avatar
    Andy Green committed
    		/* initialize supported protocols on this vhost */
    
    		for (n = 0; n < vh->count_protocols; n++) {
    			wsi.protocol = &vh->protocols[n];
    
    Andy Green's avatar
    Andy Green committed
    			if (!vh->protocols[n].name)
    				continue;
    
    			pvo = lws_vhost_protocol_options(vh,
    							 vh->protocols[n].name);
    
    			if (pvo) {
    
    				/*
    				 * linked list of options specific to
    				 * vh + protocol
    				 */
    
    				pvo1 = pvo;
    				pvo = pvo1->options;
    
    				while (pvo) {
    
    					lwsl_notice(
    						"    vhost \"%s\", protocol \"%s\", option \"%s\"\n",
    
    							vh->name,
    							vh->protocols[n].name,
    							pvo->name);
    
    					if (!strcmp(pvo->name, "default")) {
    						lwsl_notice("Setting default "
    						   "protocol for vh %s to %s\n",
    						   vh->name,
    						   vh->protocols[n].name);
    						vh->default_protocol_index = n;
    					}
    
    					if (!strcmp(pvo->name, "raw")) {
    						lwsl_notice("Setting raw "
    						   "protocol for vh %s to %s\n",
    						   vh->name,
    						   vh->protocols[n].name);
    						vh->raw_protocol_index = n;
    					}
    
    					pvo = pvo->next;
    				}
    
    				pvo = pvo1->options;
    			}
    
    Andy Green's avatar
    Andy Green committed
    			/*
    
    Andy Green's avatar
    Andy Green committed
    			 * inform all the protocols that they are doing their
    			 * one-time initialization if they want to.
    
    Andy Green's avatar
    Andy Green committed
    			 *
    
    Andy Green's avatar
    Andy Green committed
    			 * NOTE the wsi is all zeros except for the context, vh
    			 * + protocol ptrs so lws_get_context(wsi) etc can work
    
    Andy Green's avatar
    Andy Green committed
    			 */
    
    Andy Green's avatar
    Andy Green committed
    			if (vh->protocols[n].callback(&wsi,
    
    Andy Green's avatar
    Andy Green committed
    					LWS_CALLBACK_PROTOCOL_INIT, NULL,
    					(void *)pvo, 0))
    
    Andy Green's avatar
    Andy Green committed
    				return 1;
    
    Andy Green's avatar
    Andy Green committed
    		}
    
    
    		vh->created_vhost_protocols = 1;
    next:
    
    Andy Green's avatar
    Andy Green committed
    		vh = vh->vhost_next;
    	}
    
    
    	if (!context->protocol_init_done)
    		lws_finalize_startup(context);
    
    
    Andy Green's avatar
    Andy Green committed
    	context->protocol_init_done = 1;
    
    	return 0;
    }
    
    
    Andy Green's avatar
    Andy Green committed
    LWS_VISIBLE int
    lws_callback_http_dummy(struct lws *wsi, enum lws_callback_reasons reason,
    
    		    void *user, void *in, size_t len)
    
    Andy Green's avatar
    Andy Green committed
    	struct lws_ssl_info *si;
    
    #ifdef LWS_WITH_CGI
    	struct lws_cgi_args *args;
    
    Andy Green's avatar
    Andy Green committed
    #endif
    #if defined(LWS_WITH_CGI) || defined(LWS_WITH_HTTP_PROXY)
    	char buf[512];
    
    	int n;
    #endif
    
    	switch (reason) {
    	case LWS_CALLBACK_HTTP:
    #ifndef LWS_NO_SERVER
    
    		if (lws_return_http_status(wsi, HTTP_STATUS_NOT_FOUND, NULL))
    			return -1;
    
    
    		if (lws_http_transaction_completed(wsi))
    #endif
    			return -1;
    		break;
    
    #if !defined(LWS_NO_SERVER)
    	case LWS_CALLBACK_HTTP_FILE_COMPLETION:
    		if (lws_http_transaction_completed(wsi))
    			return -1;
    		break;
    #endif
    
    
    	case LWS_CALLBACK_HTTP_WRITEABLE:
    #ifdef LWS_WITH_CGI
    
    Andy Green's avatar
    Andy Green committed
    		if (wsi->reason_bf & (LWS_CB_REASON_AUX_BF__CGI_HEADERS |
    				      LWS_CB_REASON_AUX_BF__CGI)) {
    
    			n = lws_cgi_write_split_stdout_headers(wsi);
    			if (n < 0) {
    				lwsl_debug("LWS_CB_REASON_AUX_BF__CGI forcing close\n");
    
    			}
    			if (!n)
    				lws_rx_flow_control(wsi->cgi->stdwsi[LWS_STDOUT], 1);
    
    			if (wsi->reason_bf & LWS_CB_REASON_AUX_BF__CGI_HEADERS)
    				wsi->reason_bf &= ~LWS_CB_REASON_AUX_BF__CGI_HEADERS;
    
    				wsi->reason_bf &= ~LWS_CB_REASON_AUX_BF__CGI;
    
    		if (wsi->reason_bf & LWS_CB_REASON_AUX_BF__CGI_CHUNK_END) {
    
    			lwsl_debug("writing chunk terminator and exiting\n");
    
    			n = lws_write(wsi, (unsigned char *)"0\x0d\x0a\x0d\x0a",
    				      5, LWS_WRITE_HTTP);
    
    			/* always close after sending it */
    			return -1;
    
    Andy Green's avatar
    Andy Green committed
    #if defined(LWS_WITH_HTTP_PROXY)
    
    		if (wsi->reason_bf & LWS_CB_REASON_AUX_BF__PROXY) {
    
    Andy Green's avatar
    Andy Green committed
    			char *px = buf + LWS_PRE;
    			int lenx = sizeof(buf) - LWS_PRE;
    
    Andy Green's avatar
    Andy Green committed
    
    
    Andy Green's avatar
    Andy Green committed
    			/*
    			 * our sink is writeable and our source has something
    			 * to read.  So read a lump of source material of
    			 * suitable size to send or what's available, whichever
    			 * is the smaller.
    			 */
    
    			wsi->reason_bf &= ~LWS_CB_REASON_AUX_BF__PROXY;
    
    Andy Green's avatar
    Andy Green committed
    			if (!lws_get_child(wsi))
    				break;
    			if (lws_http_client_read(lws_get_child(wsi), &px, &lenx) < 0)
    				return -1;
    			break;
    		}
    #endif
    		break;
    
    #if defined(LWS_WITH_HTTP_PROXY)
    	case LWS_CALLBACK_RECEIVE_CLIENT_HTTP:
    		assert(lws_get_parent(wsi));
    		if (!lws_get_parent(wsi))
    			break;
    
    		lws_get_parent(wsi)->reason_bf |= LWS_CB_REASON_AUX_BF__PROXY;
    
    Andy Green's avatar
    Andy Green committed
    		lws_callback_on_writable(lws_get_parent(wsi));
    
    Andy Green's avatar
    Andy Green committed
    	case LWS_CALLBACK_RECEIVE_CLIENT_HTTP_READ:
    		assert(lws_get_parent(wsi));
    		n = lws_write(lws_get_parent(wsi), (unsigned char *)in,
    				len, LWS_WRITE_HTTP);
    		if (n < 0)
    			return -1;
    		break;
    
    	case LWS_CALLBACK_ESTABLISHED_CLIENT_HTTP: {
    		unsigned char *p, *end;
    		char ctype[64], ctlen = 0;
    	
    		p = (unsigned char *)buf + LWS_PRE;
    		end = p + sizeof(buf) - LWS_PRE;
    
    
    Andy Green's avatar
    Andy Green committed
    		if (lws_add_http_header_status(lws_get_parent(wsi),
    					       HTTP_STATUS_OK, &p, end))
    
    Andy Green's avatar
    Andy Green committed
    			return 1;
    		if (lws_add_http_header_by_token(lws_get_parent(wsi),
    				WSI_TOKEN_HTTP_SERVER,
    			    	(unsigned char *)"libwebsockets",
    				13, &p, end))
    			return 1;
    
    
    Andy Green's avatar
    Andy Green committed
    		ctlen = lws_hdr_copy(wsi, ctype, sizeof(ctype),
    				     WSI_TOKEN_HTTP_CONTENT_TYPE);
    
    Andy Green's avatar
    Andy Green committed
    		if (ctlen > 0) {
    			if (lws_add_http_header_by_token(lws_get_parent(wsi),
    				WSI_TOKEN_HTTP_CONTENT_TYPE,
    				(unsigned char *)ctype, ctlen, &p, end))
    				return 1;
    		}
    
    Andy Green's avatar
    Andy Green committed
    
    
    Andy Green's avatar
    Andy Green committed
    		if (lws_finalize_http_header(lws_get_parent(wsi), &p, end))
    			return 1;
    
    		*p = '\0';
    
    Andy Green's avatar
    Andy Green committed
    		n = lws_write(lws_get_parent(wsi),
    			      (unsigned char *)buf + LWS_PRE,
    
    Andy Green's avatar
    Andy Green committed
    			      p - ((unsigned char *)buf + LWS_PRE),
    			      LWS_WRITE_HTTP_HEADERS);
    		if (n < 0)
    			return -1;
    
    		break; }
    
    #endif
    
    
    #ifdef LWS_WITH_CGI
    	/* CGI IO events (POLLIN/OUT) appear here, our default policy is:
    	 *
    	 *  - POST data goes on subprocess stdin
    	 *  - subprocess stdout goes on http via writeable callback
    	 *  - subprocess stderr goes to the logs
    	 */
    	case LWS_CALLBACK_CGI:
    		args = (struct lws_cgi_args *)in;
    		switch (args->ch) { /* which of stdin/out/err ? */
    		case LWS_STDIN:
    			/* TBD stdin rx flow control */
    			break;
    		case LWS_STDOUT:
    
    			/* quench POLLIN on STDOUT until MASTER got writeable */
    			lws_rx_flow_control(args->stdwsi[LWS_STDOUT], 0);
    
    			wsi->reason_bf |= LWS_CB_REASON_AUX_BF__CGI;
    
    			/* when writing to MASTER would not block */
    			lws_callback_on_writable(wsi);
    			break;
    		case LWS_STDERR:
    
    Andy Green's avatar
    Andy Green committed
    			n = lws_get_socket_fd(args->stdwsi[LWS_STDERR]);
    			if (n < 0)
    				break;
    			n = read(n, buf, sizeof(buf) - 2);
    
    			if (n > 0) {
    				if (buf[n - 1] != '\n')
    					buf[n++] = '\n';
    				buf[n] = '\0';
    				lwsl_notice("CGI-stderr: %s\n", buf);
    			}
    			break;
    		}
    		break;
    
    	case LWS_CALLBACK_CGI_TERMINATED:
    
    		lwsl_debug("LWS_CALLBACK_CGI_TERMINATED: %d %" PRIu64 "\n",
    
    Andy Green's avatar
    Andy Green committed
    				wsi->cgi->explicitly_chunked,
    				(uint64_t)wsi->cgi->content_length);
    
    		if (!wsi->cgi->explicitly_chunked && !wsi->cgi->content_length) {
    			/* send terminating chunk */
    
    Andy Green's avatar
    Andy Green committed
    			lwsl_debug("LWS_CALLBACK_CGI_TERMINATED: ending\n");
    
    			wsi->reason_bf |= LWS_CB_REASON_AUX_BF__CGI_CHUNK_END;
    
    			lws_callback_on_writable(wsi);
    
    			lws_set_timeout(wsi, PENDING_TIMEOUT_CGI, 3);
    			break;
    
    		return -1;
    
    	case LWS_CALLBACK_CGI_STDIN_DATA:  /* POST body for stdin */
    		args = (struct lws_cgi_args *)in;
    		args->data[args->len] = '\0';
    
    Andy Green's avatar
    Andy Green committed
    		n = lws_get_socket_fd(args->stdwsi[LWS_STDIN]);
    		if (n < 0)
    			return -1;
    		n = write(n, args->data, args->len);
    
    		if (n < args->len)
    			lwsl_notice("LWS_CALLBACK_CGI_STDIN_DATA: "
    				    "sent %d only %d went", n, args->len);
    		return n;
    #endif
    
    
    	case LWS_CALLBACK_SSL_INFO:
    
    Andy Green's avatar
    Andy Green committed
    		si = in;
    
    Andy Green's avatar
    Andy Green committed
    		(void)si;
    		lwsl_notice("LWS_CALLBACK_SSL_INFO: where: 0x%x, ret: 0x%x\n",
    			    si->where, si->ret);
    
    	return 0;
    }
    
    /* list of supported protocols and callbacks */
    
    static const struct lws_protocols protocols_dummy[] = {
    	/* first protocol must always be HTTP handler */
    
    	{
    		"http-only",		/* name */
    
    Andy Green's avatar
    Andy Green committed
    		lws_callback_http_dummy,		/* callback */
    
    		0,			/* max frame size / rx buffer */
    
    		0, NULL, 0
    
    	},
    	/*
    	 * the other protocols are provided by lws plugins
    	 */
    
    	{ NULL, NULL, 0, 0, 0, NULL, 0} /* terminator */
    
    #ifdef LWS_PLAT_OPTEE
    #undef LWS_HAVE_GETENV
    #endif
    
    
    Andy Green's avatar
    Andy Green committed
    LWS_VISIBLE struct lws_vhost *
    lws_create_vhost(struct lws_context *context,
    
    		 struct lws_context_creation_info *info)
    
    Andy Green's avatar
    Andy Green committed
    {
    
    Andy Green's avatar
    Andy Green committed
    	struct lws_vhost *vh = lws_zalloc(sizeof(*vh), "create vhost"),
    
    Andy Green's avatar
    Andy Green committed
    			 **vh1 = &context->vhost_list;
    
    	const struct lws_http_mount *mounts;
    
    Andy Green's avatar
    Andy Green committed
    	const struct lws_protocol_vhost_options *pvo;
    
    Andy Green's avatar
    Andy Green committed
    #ifdef LWS_WITH_PLUGINS
    	struct lws_plugin *plugin = context->plugin_list;
    
    Andy Green's avatar
    Andy Green committed
    #endif
    
    Andy Green's avatar
    Andy Green committed
    	struct lws_protocols *lwsp;
    
    Andy Green's avatar
    Andy Green committed
    	int m, f = !info->pvo;
    
    Andy Green's avatar
    Andy Green committed
    #ifdef LWS_HAVE_GETENV
    
    Andy Green's avatar
    Andy Green committed
    	char *p;
    
    Andy Green's avatar
    Andy Green committed
    #endif
    
    Andy Green's avatar
    Andy Green committed
    	int n;
    
    Andy Green's avatar
    Andy Green committed
    
    	if (!vh)
    		return NULL;
    
    
    	if (!info->protocols)
    		info->protocols = &protocols_dummy[0];
    
    
    Andy Green's avatar
    Andy Green committed
    	vh->context = context;
    	if (!info->vhost_name)
    		vh->name = "default";
    	else
    		vh->name = info->vhost_name;
    
    
    	if (info->options & LWS_SERVER_OPTION_ONLY_RAW)
    		lwsl_info("%s set to only support RAW\n", vh->name);
    
    
    Andy Green's avatar
    Andy Green committed
    	vh->iface = info->iface;
    
    #if !defined(LWS_WITH_ESP8266) && !defined(LWS_WITH_ESP32) && !defined(OPTEE_TA) && !defined(WIN32)
    	vh->bind_iface = info->bind_iface;
    #endif
    
    
    Andy Green's avatar
    Andy Green committed
    	for (vh->count_protocols = 0;
    	     info->protocols[vh->count_protocols].callback;
    	     vh->count_protocols++)
    		;
    
    	vh->pvo = info->pvo;
    
    	vh->headers = info->headers;
    
    	vh->ssl_info_event_mask = info->ssl_info_event_mask;
    
    Andy Green's avatar
    Andy Green committed
    	if (info->keepalive_timeout)
    		vh->keepalive_timeout = info->keepalive_timeout;
    	else
    		vh->keepalive_timeout = 5;
    
    	if (info->timeout_secs_ah_idle)
    		vh->timeout_secs_ah_idle = info->timeout_secs_ah_idle;
    	else
    		vh->timeout_secs_ah_idle = 10;
    
    
    Andy Green's avatar
    Andy Green committed
    	/*
    	 * give the vhost a unified list of protocols including the
    	 * ones that came from plugins
    	 */
    	lwsp = lws_zalloc(sizeof(struct lws_protocols) *
    				   (vh->count_protocols +
    
    Andy Green's avatar
    Andy Green committed
    				   context->plugin_protocol_count + 1), "vhost-specific plugin table");
    
    Andy Green's avatar
    Andy Green committed
    	if (!lwsp) {
    		lwsl_err("OOM\n");
    		return NULL;
    	}
    
    Andy Green's avatar
    Andy Green committed
    
    
    Andy Green's avatar
    Andy Green committed
    	m = vh->count_protocols;
    	memcpy(lwsp, info->protocols, sizeof(struct lws_protocols) * m);
    
    Andy Green's avatar
    Andy Green committed
    	/* for compatibility, all protocols enabled on vhost if only
    	 * the default vhost exists.  Otherwise only vhosts who ask
    	 * for a protocol get it enabled.
    	 */
    
    	if (context->options & LWS_SERVER_OPTION_EXPLICIT_VHOSTS)
    
    Andy Green's avatar
    Andy Green committed
    		f = 0;
    	(void)f;
    #ifdef LWS_WITH_PLUGINS
    	if (plugin) {
    
    Andy Green's avatar
    Andy Green committed
    		while (plugin) {
    
    			for (n = 0; n < plugin->caps.count_protocols; n++) {
    				/*
    				 * for compatibility's sake, no pvo implies
    				 * allow all protocols
    				 */
    
    				if (f || lws_vhost_protocol_options(vh,
    
    				    plugin->caps.protocols[n].name)) {
    					memcpy(&lwsp[m],
    					       &plugin->caps.protocols[n],
    					       sizeof(struct lws_protocols));
    					m++;
    					vh->count_protocols++;
    				}
    			}
    
    Andy Green's avatar
    Andy Green committed
    			plugin = plugin->list;
    		}
    
    Andy Green's avatar
    Andy Green committed
    	}
    
    Andy Green's avatar
    Andy Green committed
    #endif
    
    Andy Green's avatar
    Andy Green committed
    
    
    Andy Green's avatar
    Andy Green committed
    	if (
    #ifdef LWS_WITH_PLUGINS
    	    (context->plugin_list) ||
    #endif
    
    	    context->options & LWS_SERVER_OPTION_EXPLICIT_VHOSTS)
    
    Andy Green's avatar
    Andy Green committed
    		vh->protocols = lwsp;
    
    Andy Green's avatar
    Andy Green committed
    		vh->protocols = info->protocols;
    
    		lws_free(lwsp);
    
    Andy Green's avatar
    Andy Green committed
    
    
    	vh->same_vh_protocol_list = (struct lws **)
    
    Andy Green's avatar
    Andy Green committed
    			lws_zalloc(sizeof(struct lws *) * vh->count_protocols, "same vh list");
    
    	vh->mount_list = info->mounts;
    
    Andy Green's avatar
    Andy Green committed
    
    
    #ifdef LWS_WITH_UNIX_SOCK
    
    Yeonjun Lim's avatar
    Yeonjun Lim committed
    	if (LWS_UNIX_SOCK_ENABLED(context)) {
    		lwsl_notice("Creating Vhost '%s' path \"%s\", %d protocols\n",
    				vh->name, info->iface, vh->count_protocols);
    	} else
    #endif
    
    Denis Osvald's avatar
    Denis Osvald committed
    	lwsl_notice("Creating Vhost '%s' port %d, %d protocols, IPv6 %s\n",
    
    Andy Green's avatar
    Andy Green committed
    			vh->name, info->port, vh->count_protocols,
    			LWS_IPV6_ENABLED(vh) ? "on" : "off");
    
    Andy Green's avatar
    Andy Green committed
    
    
    	mounts = info->mounts;
    
    Andy Green's avatar
    Andy Green committed
    	while (mounts) {
    
    Sergey Kovalevich's avatar
    Sergey Kovalevich committed
    		(void)mount_protocols[0];
    
    Andy Green's avatar
    Andy Green committed
    		lwsl_notice("   mounting %s%s to %s\n",
    				mount_protocols[mounts->origin_protocol],
    				mounts->origin, mounts->mountpoint);
    
    Andy Green's avatar
    Andy Green committed
    
    		/* convert interpreter protocol names to pointers */
    		pvo = mounts->interpret;
    		while (pvo) {
    			for (n = 0; n < vh->count_protocols; n++)
    				if (!strcmp(pvo->value, vh->protocols[n].name)) {
    					((struct lws_protocol_vhost_options *)pvo)->value =
    
    Andy Green's avatar
    Andy Green committed
    							(const char *)(lws_intptr_t)n;
    
    Andy Green's avatar
    Andy Green committed
    					break;
    				}
    			if (n == vh->count_protocols)
    
    Andy Green's avatar
    Andy Green committed
    				lwsl_err("ignoring unknown interpret protocol %s\n",
    					 pvo->value);
    
    Andy Green's avatar
    Andy Green committed
    			pvo = pvo->next;
    		}
    
    
    Andy Green's avatar
    Andy Green committed
    		mounts = mounts->mount_next;
    	}
    
    #ifndef LWS_NO_EXTENSIONS
    
    Andy Green's avatar
    Andy Green committed
    #ifdef LWS_WITH_PLUGINS
    	if (context->plugin_extension_count) {
    
    		m = 0;
    		while (info->extensions && info->extensions[m].callback)
    			m++;
    
    		/*
    		 * give the vhost a unified list of extensions including the
    		 * ones that came from plugins
    		 */
    		vh->extensions = lws_zalloc(sizeof(struct lws_extension) *
    					   (m +
    
    Andy Green's avatar
    Andy Green committed
    					   context->plugin_extension_count + 1), "extensions");
    
    Andy Green's avatar
    Andy Green committed
    		if (!vh->extensions)
    			return NULL;
    
    		memcpy((struct lws_extension *)vh->extensions, info->extensions,
    		       sizeof(struct lws_extension) * m);
    
    Andy Green's avatar
    Andy Green committed
    		plugin = context->plugin_list;
    
    Andy Green's avatar
    Andy Green committed
    		while (plugin) {
    
    Andy Green's avatar
    Andy Green committed
    			memcpy((struct lws_extension *)&vh->extensions[m],
    				plugin->caps.extensions,
    
    Andy Green's avatar
    Andy Green committed
    			       sizeof(struct lws_extension) *
    			       plugin->caps.count_extensions);
    			m += plugin->caps.count_extensions;
    			plugin = plugin->list;
    		}
    	} else
    #endif
    		vh->extensions = info->extensions;
    
    Andy Green's avatar
    Andy Green committed
    #endif
    
    	vh->listen_port = info->port;
    
    Andy Green's avatar
    Andy Green committed
    #if !defined(LWS_WITH_ESP8266)
    
    Andy Green's avatar
    Andy Green committed
    	vh->http_proxy_port = 0;
    	vh->http_proxy_address[0] = '\0';
    
    #if defined(LWS_WITH_SOCKS5)
    	vh->socks_proxy_port = 0;
    	vh->socks_proxy_address[0] = '\0';
    #endif
    
    Andy Green's avatar
    Andy Green committed
    
    	/* either use proxy from info, or try get it from env var */
    
    
    	/* http proxy */
    
    Andy Green's avatar
    Andy Green committed
    	if (info->http_proxy_address) {
    		/* override for backwards compatibility */
    		if (info->http_proxy_port)
    			vh->http_proxy_port = info->http_proxy_port;
    		lws_set_proxy(vh, info->http_proxy_address);
    	} else {
    #ifdef LWS_HAVE_GETENV
    		p = getenv("http_proxy");
    		if (p)
    			lws_set_proxy(vh, p);
    #endif
    	}
    
    #if defined(LWS_WITH_SOCKS5)
    	/* socks proxy */
    	if (info->socks_proxy_address) {
    		/* override for backwards compatibility */
    		if (info->socks_proxy_port)
    			vh->socks_proxy_port = info->socks_proxy_port;
    		lws_set_socks(vh, info->socks_proxy_address);
    	} else {
    #ifdef LWS_HAVE_GETENV
    		p = getenv("socks_proxy");
    		if (p)
    			lws_set_socks(vh, p);
    
    Andy Green's avatar
    Andy Green committed
    #endif
    
    Andy Green's avatar
    Andy Green committed
    	vh->ka_time = info->ka_time;
    	vh->ka_interval = info->ka_interval;
    	vh->ka_probes = info->ka_probes;
    
    
    	if (vh->options & LWS_SERVER_OPTION_STS)
    		lwsl_notice("   STS enabled\n");
    
    
    #ifdef LWS_WITH_ACCESS_LOG
    	if (info->log_filepath) {
    
    Andy Green's avatar
    Andy Green committed
    		vh->log_fd = open(info->log_filepath,
    				  O_CREAT | O_APPEND | O_RDWR, 0600);
    
    		if (vh->log_fd == (int)LWS_INVALID_FILE) {
    
    			lwsl_err("unable to open log filepath %s\n",
    				 info->log_filepath);
    			goto bail;
    		}
    
    #ifndef WIN32
    
    		if (context->uid != -1)
    			if (chown(info->log_filepath, context->uid,
    				  context->gid) == -1)
    				lwsl_err("unable to chown log file %s\n",
    						info->log_filepath);
    
    		vh->log_fd = (int)LWS_INVALID_FILE;
    
    Andy Green's avatar
    Andy Green committed
    	if (lws_context_init_server_ssl(info, vh))
    		goto bail;
    	if (lws_context_init_client_ssl(info, vh))
    		goto bail;
    
    Andy Green's avatar
    Andy Green committed
    	if (lws_context_init_server(info, vh)) {
    		lwsl_err("init server failed\n");
    
    Andy Green's avatar
    Andy Green committed
    		goto bail;
    
    Andy Green's avatar
    Andy Green committed
    	}
    
    Andy Green's avatar
    Andy Green committed
    
    	while (1) {
    		if (!(*vh1)) {
    			*vh1 = vh;
    			break;
    		}
    		vh1 = &(*vh1)->vhost_next;
    	};
    
    	/* for the case we are adding a vhost much later, after server init */
    
    	if (context->protocol_init_done)
    		lws_protocol_init(context);
    
    
    Andy Green's avatar
    Andy Green committed
    	return vh;
    
    bail:
    	lws_free(vh);
    
    	return NULL;
    }
    
    
    LWS_VISIBLE int
    lws_init_vhost_client_ssl(const struct lws_context_creation_info *info,
    			  struct lws_vhost *vhost)
    {
    	struct lws_context_creation_info i;
    
    	memcpy(&i, info, sizeof(i));
    	i.port = CONTEXT_PORT_NO_LISTEN;
    
    	return lws_context_init_client_ssl(&i, vhost);
    }
    
    
    LWS_VISIBLE struct lws_context *
    
    lws_create_context(struct lws_context_creation_info *info)
    
    	struct lws_context *context = NULL;
    
    Andy Green's avatar
    Andy Green committed
    	struct lws_plat_file_ops *prev;
    
    #ifndef LWS_NO_DAEMONIZE
    
    	int pid_daemon = get_daemonize_pid();
    
    Andy Green's avatar
    Andy Green committed
    #endif
    
    Andy Green's avatar
    Andy Green committed
    	int n, m;
    
    Galen Ma's avatar
    Galen Ma committed
    #if defined(__ANDROID__)
    	struct rlimit rt;
    #endif
    
    
    	lwsl_info("Initial logging level %d\n", log_level);
    	lwsl_info("Libwebsockets version: %s\n", library_version);
    
    #if defined(GCC_VER)
    
    	lwsl_info("Compiled with  %s\n", GCC_VER);
    
    Andy Green's avatar
    Andy Green committed
    #if LWS_POSIX
    
    #ifdef LWS_WITH_IPV6
    
    	if (!lws_check_opt(info->options, LWS_SERVER_OPTION_DISABLE_IPV6))
    
    		lwsl_info("IPV6 compiled in and enabled\n");
    
    		lwsl_info("IPV6 compiled in but disabled\n");
    
    	lwsl_info("IPV6 not compiled in\n");
    
    Andy Green's avatar
    Andy Green committed
    #if !defined(LWS_PLAT_OPTEE) && !defined(LWS_PLAT_ESP32)
    
    	lws_feature_status_libev(info);
    
    Andy Green's avatar
    Andy Green committed
    	lws_feature_status_libuv(info);
    
    Andy Green's avatar
    Andy Green committed
    	lwsl_info(" LWS_DEF_HEADER_LEN    : %u\n", LWS_DEF_HEADER_LEN);
    
    Andy Green's avatar
    Andy Green committed
    	lwsl_info(" LWS_MAX_PROTOCOLS     : %u\n", LWS_MAX_PROTOCOLS);
    	lwsl_info(" LWS_MAX_SMP           : %u\n", LWS_MAX_SMP);
    
    	lwsl_info(" sizeof (*info)        : %ld\n", (long)sizeof(*info));
    
    Andy Green's avatar
    Andy Green committed
    #if defined(LWS_WITH_STATS)
    
    	lwsl_info(" LWS_WITH_STATS        : on\n");
    
    Andy Green's avatar
    Andy Green committed
    #endif
    
    	lwsl_info(" SYSTEM_RANDOM_FILEPATH: '%s'\n", SYSTEM_RANDOM_FILEPATH);
    
    	if (lws_plat_context_early_init())
    		return NULL;
    
    
    Andy Green's avatar
    Andy Green committed
    	context = lws_zalloc(sizeof(struct lws_context), "context");
    
    	if (!context) {
    		lwsl_err("No memory for websocket context\n");
    		return NULL;
    	}
    
    	if (info->pt_serv_buf_size)
    		context->pt_serv_buf_size = info->pt_serv_buf_size;
    	else
    		context->pt_serv_buf_size = 4096;
    
    
    Andy Green's avatar
    Andy Green committed
    #if LWS_MAX_SMP > 1
    	pthread_mutex_init(&context->lock, NULL);
    #endif
    
    
    Andy Green's avatar
    Andy Green committed
    #if defined(LWS_WITH_ESP32)
    	context->last_free_heap = esp_get_free_heap_size();
    #endif
    
    
    	/* default to just the platform fops implementation */
    
    
    	context->fops_platform.LWS_FOP_OPEN	= _lws_plat_file_open;
    	context->fops_platform.LWS_FOP_CLOSE	= _lws_plat_file_close;
    	context->fops_platform.LWS_FOP_SEEK_CUR	= _lws_plat_file_seek_cur;
    	context->fops_platform.LWS_FOP_READ	= _lws_plat_file_read;
    	context->fops_platform.LWS_FOP_WRITE	= _lws_plat_file_write;
    
    Andy Green's avatar
    Andy Green committed
    	context->fops_platform.fi[0].sig	= NULL;
    
    Andy Green's avatar
    Andy Green committed
    	/*
    	 *  arrange a linear linked-list of fops starting from context->fops
    	 *
    	 * platform fops
    	 * [ -> fops_zip (copied into context so .next settable) ]
    	 * [ -> info->fops ]
    	 */
    
    	context->fops = &context->fops_platform;
    	prev = (struct lws_plat_file_ops *)context->fops;
    
    Andy Green's avatar
    Andy Green committed
    #if defined(LWS_WITH_ZIP_FOPS)
    	/* make a soft copy so we can set .next */
    	context->fops_zip = fops_zip;
    	prev->next = &context->fops_zip;
    	prev = (struct lws_plat_file_ops *)prev->next;
    #endif
    
    	/* if user provided fops, tack them on the end of the list */
    
    Andy Green's avatar
    Andy Green committed
    		prev->next = info->fops;
    
    	context->reject_service_keywords = info->reject_service_keywords;
    
    	if (info->external_baggage_free_on_destroy)
    		context->external_baggage_free_on_destroy =
    			info->external_baggage_free_on_destroy;
    
    Andy Green's avatar
    Andy Green committed
    	context->time_up = time(NULL);
    
    Andy Green's avatar
    Andy Green committed
    
    
    	context->simultaneous_ssl_restriction = info->simultaneous_ssl_restriction;
    
    
    #ifndef LWS_NO_DAEMONIZE
    
    	if (pid_daemon) {
    		context->started_with_parent = pid_daemon;
    
    		lwsl_info(" Started with daemon pid %d\n", pid_daemon);
    
    Andy Green's avatar
    Andy Green committed
    #endif
    
    Galen Ma's avatar
    Galen Ma committed
    #if defined(__ANDROID__)
    		n = getrlimit ( RLIMIT_NOFILE,&rt);
    		if (-1 == n) {
    			lwsl_err("Get RLIMIT_NOFILE failed!\n");
    			return NULL;
    		}
    		context->max_fds = rt.rlim_cur;
    #else
    		context->max_fds = getdtablesize();
    #endif
    
    Andy Green's avatar
    Andy Green committed
    
    	if (info->count_threads)
    		context->count_threads = info->count_threads;
    	else
    		context->count_threads = 1;
    
    	if (context->count_threads > LWS_MAX_SMP)
    		context->count_threads = LWS_MAX_SMP;
    
    
    	context->token_limits = info->token_limits;
    
    Andy Green's avatar
    Andy Green committed
    
    
    	context->options = info->options;
    
    Andy Green's avatar
    Andy Green committed
    
    
    Andy Green's avatar
    Andy Green committed
    	if (info->timeout_secs)
    		context->timeout_secs = info->timeout_secs;
    	else
    		context->timeout_secs = AWAITING_TIMEOUT;
    
    
    	context->ws_ping_pong_interval = info->ws_ping_pong_interval;
    
    
    Andy Green's avatar
    Andy Green committed
    	lwsl_info(" default timeout (secs): %u\n", context->timeout_secs);
    
    Andy Green's avatar
    Andy Green committed
    	if (info->max_http_header_data)
    		context->max_http_header_data = info->max_http_header_data;
    	else
    
    		if (info->max_http_header_data2)
    			context->max_http_header_data =
    					info->max_http_header_data2;
    		else
    			context->max_http_header_data = LWS_DEF_HEADER_LEN;
    
    Andy Green's avatar
    Andy Green committed
    	if (info->max_http_header_pool)
    		context->max_http_header_pool = info->max_http_header_pool;
    	else
    		context->max_http_header_pool = LWS_DEF_HEADER_POOL;
    
    	/*
    	 * Allocate the per-thread storage for scratchpad buffers,
    	 * and header data pool
    
    Andy Green's avatar
    Andy Green committed
    	 */
    	for (n = 0; n < context->count_threads; n++) {
    
    Andy Green's avatar
    Andy Green committed
    		context->pt[n].serv_buf = lws_zalloc(context->pt_serv_buf_size, "pt_serv_buf");
    
    Andy Green's avatar
    Andy Green committed
    		if (!context->pt[n].serv_buf) {
    			lwsl_err("OOM\n");
    			return NULL;
    		}
    
    #ifdef LWS_WITH_LIBUV
    
    		context->pt[n].context = context;
    
    		context->pt[n].tid = n;
    
    Andy Green's avatar
    Andy Green committed
    		context->pt[n].http_header_data = lws_malloc(context->max_http_header_data *
    
    Andy Green's avatar
    Andy Green committed
    						       context->max_http_header_pool, "context ah hdr data");
    
    Andy Green's avatar
    Andy Green committed
    		if (!context->pt[n].http_header_data)
    			goto bail;
    
    		context->pt[n].ah_pool = lws_zalloc(sizeof(struct allocated_headers) *
    
    Andy Green's avatar
    Andy Green committed
    					      context->max_http_header_pool, "context ah hdr pool");
    
    Andy Green's avatar
    Andy Green committed
    		for (m = 0; m < context->max_http_header_pool; m++)
    			context->pt[n].ah_pool[m].data =
    				(char *)context->pt[n].http_header_data +
    				(m * context->max_http_header_data);
    		if (!context->pt[n].ah_pool)
    			goto bail;
    
    		lws_pt_mutex_init(&context->pt[n]);
    
    Andy Green's avatar
    Andy Green committed
    	}
    
    	if (info->fd_limit_per_thread)
    		context->fd_limit_per_thread = info->fd_limit_per_thread;
    	else
    		context->fd_limit_per_thread = context->max_fds /
    					       context->count_threads;
    
    
    	lwsl_info(" Threads: %d each %d fds\n", context->count_threads,
    
    Andy Green's avatar
    Andy Green committed
    		    context->fd_limit_per_thread);
    
    
    	if (!info->ka_interval && info->ka_time > 0) {
    		lwsl_err("info->ka_interval can't be 0 if ka_time used\n");
    		return NULL;
    	}
    
    #ifdef LWS_WITH_LIBEV
    
    	/* (Issue #264) In order to *avoid breaking backwards compatibility*, we
    	 * enable libev mediated SIGINT handling with a default handler of
    
    	 * lws_sigint_cb. The handler can be overridden or disabled
    	 * by invoking lws_sigint_cfg after creating the context, but
    	 * before invoking lws_initloop:
    
    	 */
    	context->use_ev_sigint = 1;
    
    Andy Green's avatar
    Andy Green committed
    	context->lws_ev_sigint_cb = &lws_ev_sigint_cb;
    
    #endif /* LWS_WITH_LIBEV */
    #ifdef LWS_WITH_LIBUV
    
    Andy Green's avatar
    Andy Green committed
    	/* (Issue #264) In order to *avoid breaking backwards compatibility*, we
    	 * enable libev mediated SIGINT handling with a default handler of
    	 * lws_sigint_cb. The handler can be overridden or disabled
    	 * by invoking lws_sigint_cfg after creating the context, but
    	 * before invoking lws_initloop:
    	 */
    	context->use_ev_sigint = 1;
    	context->lws_uv_sigint_cb = &lws_uv_sigint_cb;
    #endif
    
    #ifdef LWS_WITH_LIBEVENT
    
    	/* (Issue #264) In order to *avoid breaking backwards compatibility*, we
    	 * enable libev mediated SIGINT handling with a default handler of
    	 * lws_sigint_cb. The handler can be overridden or disabled
    	 * by invoking lws_sigint_cfg after creating the context, but
    	 * before invoking lws_initloop:
    	 */
    	context->use_ev_sigint = 1;
    	context->lws_event_sigint_cb = &lws_event_sigint_cb;
    
    #endif /* LWS_WITH_LIBEVENT */
    
    Andy Green's avatar
    Andy Green committed
    #if defined(LWS_WITH_PEER_LIMITS)
    	/* scale the peer hash table according to the max fds for the process,
    	 * so that the max list depth averages 16.  Eg, 1024 fd -> 64,
    	 * 102400 fd -> 6400
    	 */
    	context->pl_hash_elements =
    		(context->count_threads * context->fd_limit_per_thread) / 16;
    	context->pl_hash_table = lws_zalloc(sizeof(struct lws_peer *) *
    
    Andy Green's avatar
    Andy Green committed
    			context->pl_hash_elements, "peer limits hash table");
    
    Andy Green's avatar
    Andy Green committed
    	context->ip_limit_ah = info->ip_limit_ah;
    	context->ip_limit_wsi = info->ip_limit_wsi;
    #endif
    
    
    	lwsl_info(" mem: context:         %5lu bytes (%ld ctx + (%ld thr x %d))\n",
    		  (long)sizeof(struct lws_context) +
    
    		  (context->count_threads * context->pt_serv_buf_size),
    
    		  (long)sizeof(struct lws_context),
    		  (long)context->count_threads,