Function PiuDebugMachine_doCommandAux

tools/xsbug/DebugBehavior.c:1582–1638

}

void PiuDebugMachine_doCommandAux(xsMachine* the, PiuDebugMachine self, void* buffer, size_t length)
{
	if (self) {
	#if mxLinux
		{
			const char* p = (const char*)buffer;
			while (length > 0) {
				GError* error = NULL;
				gssize used = g_socket_send(self->socket, p, length, NULL, &error);
				if (used < 0) {
					if (g_error_matches(error, G_IO_ERROR, G_IO_ERROR_WOULD_BLOCK)) {
						g_error_free(error);
						continue;
					}
					xsUnknownError("g_socket_send: %s", error->message);
				}
				p += used;
				length -= used;
			}
		}
	#elif mxMacOSX
		{
			const char* p = (const char*)buffer;
			while (length > 0) {
				ssize_t used = send(CFSocketGetNative(self->socket), p, length, 0);
				if (used < 0) {
					if ((EINTR == errno) || (EAGAIN == errno))
						continue;
					xsUnknownError("write error: %s", strerror(errno));
				}
				p += used;
				length -= used;
			}
		}
	#elif mxWindows
		if (self->socket != INVALID_SOCKET) {
			const char* p = (const char*)buffer;
			while (length > 0) {
				int used = send(self->socket, p, (int)length, 0);
				if (used < 0) {
					if (WSAEWOULDBLOCK == WSAGetLastError()) {
						WaitMessage();
						continue;
					}
					break;
				}
				p += used;
				length -= used;
			}
		}
	#endif
	}
	else {
		xsResult = xsGet(xsThis, xsID_connection);
		xsCall1(xsResult, xsID_write, xsArrayBuffer(buffer, (xsIntegerValue)length));
	}
}