Function xs_tcp_constructor

modules/io/socket/lin/tcp.c:88–217

};

void xs_tcp_constructor(xsMachine *the)
{
	TCP tcp;
	uint8_t create = xsmcArgc > 0;
	uint8_t triggerable = 0, triggered = 0, nodelay = 0, format = kIOFormatBuffer;
	xsSlot *onReadable, *onWritable, *onError;
	int port = 0;
	struct sockaddr_in addr = {0};

	xsmcVars(1);

	tcp = c_calloc(1, sizeof(TCPRecord));
	if (!tcp)
		xsRangeError("no memory");
	tcp->skt = -1;

	modInstrumentationAdjust(NetworkSockets, +1);

	xsmcSetHostData(xsThis, tcp);

	if (create) {
		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");

			triggered = from->triggered;
			modTimerRemove(from->task);
			from->task = NULL;
			tcp->task = modTimerAdd(kTaskInterval, kTaskInterval, tcpTask, &tcp, sizeof(tcp));
			tcp->skt = from->skt;
			tcp->port = from->port;
			tcp->bytesWritable = from->bytesWritable;
			tcp->bytesReadable = from->bytesReadable;
			tcp->readPosition = from->readPosition;
			memmove(tcp->readBuf, from->readBuf, sizeof(from->readBuf)); 
			tcp->error = from->error;