Function dev_thread

src/sana2.cpp:1530–1571

}

static int dev_thread (void *devs)
{
	struct s2devstruct *dev = (struct s2devstruct*)devs;

	uae_set_thread_priority (NULL, 1);
	dev->thread_running = 1;
	uae_sem_post (&dev->sync_sem);
	for (;;) {
		TrapContext *ctx = (TrapContext*)read_comm_pipe_pvoid_blocking(&dev->requests);
		uae_u8 *iobuf = (uae_u8*)read_comm_pipe_pvoid_blocking(&dev->requests);
		uaecptr request = (uaecptr)read_comm_pipe_u32_blocking (&dev->requests);
		uae_sem_wait (&change_sem);
		if (!request) {
			dev->thread_running = 0;
			uae_sem_post (&dev->sync_sem);
			uae_sem_post (&change_sem);
			write_log (_T("%s: dev_thread killed\n"), getdevname ());
			return 0;
		}
		struct priv_s2devstruct *pdev = getps2devstruct(ctx, iobuf, request);
		asyncreq *ar = get_async_request (dev, request, 1);
		if (ar) {
			storerequest(ctx, ar->request, request);
			uae_ReplyMsg (request);
			release_async_request (dev, request);
			rem_async_packet (dev, request);
		} else if (dev_do_io(ctx, dev, iobuf, request, 0) == 0) {
			storerequest(ctx, iobuf, request);
			uae_ReplyMsg (request);
			rem_async_packet (dev, request);
		} else {
			add_async_request (dev, iobuf, request);
			dev->ctx = ctx;
			ethernet_trigger (pdev->td, dev->sysdata);
			dev->ctx = NULL;
			iobuf = NULL;
		}
		trap_background_set_complete(ctx);
		uae_sem_post (&change_sem);
	}
	return 0;
}

static uae_u32 REGPARAM2 dev_init_2 (TrapContext *ctx)
{