Function xs_tcp_constructor

modules/io/socket/lwip/tcp.c:96–234

};

void xs_tcp_constructor(xsMachine *the)
{
	TCP tcp;
	uint8_t create = xsmcArgc > 0;
	uint8_t connect = 0, triggerable = 0, triggered = 0, nodelay = 0, format = kIOFormatBuffer, ready = 0;
	xsSlot *onReadable, *onWritable, *onError;
	int port;
	struct tcp_pcb *skt;
	TCPBuffer buffers = NULL;
	ip_addr_t address;

	xsmcVars(1);

	if (create) {
		CHECK_NETWORK_SAFE();

		builtinInitIO();

		format = builtinInitializeFormat(the, format);
		if ((kIOFormatNumber != format) && (kIOFormatBuffer != format))
			xsRangeError("unimplemented");

		onReadable = builtinGetCallback(the, xsID_onReadable);
		if (onReadable)
			triggerable |= kTCPReadable;

		onWritable = builtinGetCallback(the, xsID_onWritable);
		if (onWritable)
			triggerable |= kTCPWritable;

		onError = builtinGetCallback(the, xsID_onError);
		if (onError)
			triggerable |= kTCPError;

		if (xsmcGet(xsVar(0), xsArg(0), xsID_nodelay))
			nodelay = xsmcToBoolean(xsVar(0)) ? 2 : 1;

		if (xsmcGet(xsVar(0), xsArg(0), xsID_from)) {
			TCP from;

			from = xsmcGetHostDataValidate(xsVar(0), (void *)&xsTCPHooks);
			if (!from->skt)
				xsUnknownError("invalid from");

			skt = from->skt;
			buffers = from->buffers;
			triggered = from->triggered;
			ready = from->ready;
			if ((triggerable & kTCPWritable) && tcp_sndbuf(skt))
				triggered |= kTCPWritable;
			if ((triggerable & kTCPReadable) && buffers)
				triggered |= kTCPReadable;
			from->skt = NULL;
			from->buffers = NULL;
			from->triggered = 0;
			doClose(the, &xsVar(0));
		}
		else {