/*********************************************************/

/*  ptycon: a pty-console bridge                         */

/*  Copyright (C) 2016--2017  Z. Gilboa                  */

/*  Released under GPLv2 and GPLv3; see COPYING.PTYCON.  */

/*********************************************************/

#include <psxtypes/psxtypes.h>

#include <ntcon/ntcon.h>

#include <ntapi/ntapi.h>

#include <gdi/gdi.h>

#include <ptycon/ptycon.h>

#include "ptycon_driver_impl.h"

int __stdcall ptyc_dbg_raw(struct ptyc_driver_ctx_impl * ictx)

{

	int32_t		status;

	void *		hwait;

	char *		ch;

	nt_iosb		iosb;

	size_t		nbytes;

	unsigned char	uch;

	unsigned int	keyval;

	char		xch[6] = {0,0,0,0,0,0};

	if ((status = ntapi->tt_create_private_event(

			&hwait,

			NT_NOTIFICATION_EVENT,

			NT_EVENT_NOT_SIGNALED)))

		return status;

	do {

		status = ntapi->pty_read(

			ictx->cctx.hpts,

			hwait,0,0,

			&iosb,

			&uch,1,

			0,0);

		if (status == NT_STATUS_PENDING)

			status = ntapi->zw_wait_for_single_object(

				hwait,NT_SYNC_ALERTABLE,0);

		if (status || iosb.status) {

			ntapi->zw_close(hwait);

			return status ? status : iosb.status;

		}

		ntapi->sprintf(xch,"0x%02x ",(keyval = uch));

		nbytes = sizeof(xch) - 1;

		for (ch=xch; nbytes; ) {

			status = ntapi->pty_write(

				ictx->cctx.hpts,

				hwait,0,0,&iosb,

				ch,(uint32_t)nbytes,

				0,0);

			if (status == NT_STATUS_PENDING)

				status = ntapi->zw_wait_for_single_object(

					hwait,NT_SYNC_ALERTABLE,0);

			if (status || iosb.status) {

				ntapi->zw_close(hwait);

				return status ? status : iosb.status;

			}

			ch     += iosb.info;

			nbytes -= iosb.info;

		}

	} while (1);

}