Function xs_udp_constructor

modules/io/socket/lwip/udp.c:73–133

};

void xs_udp_constructor(xsMachine *the)
{
	UDP udp;
	int port = 0;
	int ttl = -1;
	struct udp_pcb *skt;
	xsSlot *onReadable = builtinGetCallback(the, xsID_onReadable);

	CHECK_NETWORK_SAFE();

	xsmcVars(1);

	if (xsmcGet(xsVar(0), xsArg(0), xsID_port)) {
		port = xsmcToInteger(xsVar(0));
		if ((port < 0) || (port > 65535))
			xsRangeError("invalid port");
	}

	if (xsmcGet(xsVar(0), xsArg(0), xsID_timeToLive)) {
		ttl = xsmcToInteger(xsVar(0));
		if ((ttl <= 0) || (ttl > 255))
			xsRangeError("invalid timeToLive");
	}

	builtinInitIO();
	builtinInitializeTarget(the);
	if (kIOFormatBuffer != builtinInitializeFormat(the, kIOFormatBuffer))
		xsRangeError("invalid format");

	skt = udp_new_safe();
	if (!skt)
		xsRangeError("no socket");

	if (udp_bind_safe(skt, IP_ADDR_ANY, port)) {
		udp_remove_safe(skt);
		xsUnknownError("bind failed");
	}

	udp = c_calloc(1, sizeof(UDPRecord));
	if (!udp) {
		udp_remove_safe(skt);
		xsRangeError("no memory");
	}

	xsmcSetHostData(xsThis, udp);
	udp->skt = skt;
	udp->obj = xsThis;
	udp->the = the;
	xsRemember(udp->obj);

	udp_recv(skt, (udp_recv_fn)udpReceive, udp);

	if (ttl > 0)
		skt->ttl = ttl;

	udp->onReadable = onReadable;

	xsSetHostHooks(xsThis, (xsHostHooks *)&xsUDPHooks);