Software Público Brasileiro

/*
 * "Software pw3270, desenvolvido com base nos códigos fontes do WC3270  e X3270
 * (Paul Mattes Paul.Mattes@usa.net), de emulação de terminal 3270 para acesso a
 * aplicativos mainframe. Registro no INPI sob o nome G3270.
 *
 * Copyright (C) <2008> <Banco do Brasil S.A.>
 *
 * Este programa é software livre. Você pode redistribuí-lo e/ou modificá-lo sob
 * os termos da GPL v.2 - Licença Pública Geral  GNU,  conforme  publicado  pela
 * Free Software Foundation.
 *
 * Este programa é distribuído na expectativa de  ser  útil,  mas  SEM  QUALQUER
 * GARANTIA; sem mesmo a garantia implícita de COMERCIALIZAÇÃO ou  de  ADEQUAÇÃO
 * A QUALQUER PROPÓSITO EM PARTICULAR. Consulte a Licença Pública Geral GNU para
 * obter mais detalhes.
 *
 * Você deve ter recebido uma cópia da Licença Pública Geral GNU junto com este
 * programa; se não, escreva para a Free Software Foundation, Inc., 51 Franklin
 * St, Fifth Floor, Boston, MA  02110-1301  USA
 *
 * Este programa está nomeado como - e possui - linhas de código.
 *
 * Contatos:
 *
 * perry.werneck@gmail.com	(Alexandre Perry de Souza Werneck)
 * erico.mendonca@gmail.com	(Erico Mascarenhas Mendonça)
 *
 */

#include <internals.h>
#include <lib3270/log.h>
#include <lib3270/trace.h>
#include <lib3270/keyboard.h>
#include "kybdc.h"
#include "utilc.h"

/*---[ Implement ]------------------------------------------------------------------------------------------*/

static int timer_expired(H3270 GNUC_UNUSED(*hSession), void *userdata) {
	*((int *) userdata) = 1;
	return 0;
}

LIB3270_EXPORT int lib3270_wait_for_update(H3270 GNUC_UNUSED(*hSession), int GNUC_UNUSED(seconds)) {
	return errno = ENOTSUP;
}

LIB3270_EXPORT int lib3270_wait_for_ready(H3270 *hSession, int seconds) {

	debug("%s",__FUNCTION__);
	debug("Session lock state is %d",lib3270_get_lock_status(hSession));

	int rc = 0;
	int timeout = 0;
	void * timer = AddTimer(seconds * 1000, hSession, timer_expired, &timeout);

	while(!rc) {
		if(timeout) {
			// Timeout! The timer was destroyed.
			debug("%s exits with ETIMEDOUT",__FUNCTION__);
			return errno = ETIMEDOUT;
		}

		if(lib3270_get_lock_status(hSession) == LIB3270_MESSAGE_NONE) {
			// Is unlocked, break.

			break;
		}

		if(lib3270_is_disconnected(hSession)) {
			rc = errno = ENOTCONN;
			break;
		}

		if(hSession->kybdlock && KYBDLOCK_IS_OERR(hSession)) {
			rc = errno = EPERM;
			break;
		}

		debug("%s: Waiting",__FUNCTION__);
		lib3270_main_iterate(hSession,1);
	}
	RemoveTimer(hSession,timer);

	debug("%s exits with rc=%d",__FUNCTION__,rc);
	return rc;

}

int lib3270_wait_for_string(H3270 *hSession, const char *key, int seconds) {

	FAIL_IF_NOT_ONLINE(hSession);

	int rc = 0;
	int timeout = 0;
	void * timer = AddTimer(seconds * 1000, hSession, timer_expired, &timeout);

	while(!rc) {
		if(timeout) {
			// Timeout! The timer was destroyed.
			return errno = ETIMEDOUT;
		}

		// Keyboard is locked by operator error, fails!
		if(hSession->kybdlock && KYBDLOCK_IS_OERR(hSession)) {
			rc = errno = EPERM;
			break;
		}

		if(!lib3270_is_connected(hSession)) {
			rc = errno = ENOTCONN;
			break;
		}

		char * contents = lib3270_get_string_at_address(hSession, 0, -1, 0);
		if(!contents) {
			rc = errno;
			break;
		}

		if(strstr(contents,key)) {
			lib3270_free(contents);
			break;
		}

		lib3270_free(contents);

		lib3270_main_iterate(hSession,1);

	}
	RemoveTimer(hSession,timer);

	return rc;

}

int lib3270_wait_for_string_at_address(H3270 *hSession, int baddr, const char *key, int seconds) {
	FAIL_IF_NOT_ONLINE(hSession);

	if(baddr < 0)
		baddr = lib3270_get_cursor_address(hSession);

	int rc = 0;
	int timeout = 0;
	void * timer = AddTimer(seconds * 1000, hSession, timer_expired, &timeout);

	while(!rc) {
		if(timeout) {
			// Timeout! The timer was destroyed.
			return errno = ETIMEDOUT;
		}

		// Keyboard is locked by operator error, fails!
		if(hSession->kybdlock && KYBDLOCK_IS_OERR(hSession)) {
			rc = errno = EPERM;
			break;
		}

		if(!lib3270_is_connected(hSession)) {
			rc = errno = ENOTCONN;
			break;
		}

		if(lib3270_cmp_string_at_address(hSession, baddr, key, 0) == 0) {
			break;
		}

		lib3270_main_iterate(hSession,1);

	}
	RemoveTimer(hSession,timer);

	return rc;

}

LIB3270_EXPORT int lib3270_wait_for_string_at(H3270 *hSession, unsigned int row, unsigned int col, const char *key, int seconds) {
	int baddr = lib3270_translate_to_address(hSession,row,col);
	if(baddr < 0)
		return errno;

	return lib3270_wait_for_string_at_address(hSession,baddr,key,seconds);
}

LIB3270_EXPORT int lib3270_wait_for_connected(H3270 *hSession, int seconds) {

	int rc = -1;
	int timeout = 0;
	void * timer = AddTimer(seconds * 1000, hSession, timer_expired, &timeout);

	while(rc == -1) {
		if(timeout) {
			// Timeout! The timer was destroyed.
			return errno = ETIMEDOUT;
		}

		if(hSession->connection.state == LIB3270_NOT_CONNECTED) {
			rc = ENOTCONN;
			break;
		}

		if(!hSession->starting && hSession->connection.state >= (int)LIB3270_CONNECTED_INITIAL) {
			rc = 0;
			break;
		}

		lib3270_main_iterate(hSession,1);

	}
	RemoveTimer(hSession,timer);

	return errno = rc;
}


LIB3270_EXPORT int lib3270_wait_for_cstate(H3270 *hSession, LIB3270_CSTATE cstate, int seconds) {

	int rc = -1;
	int timeout = 0;
	void * timer = AddTimer(seconds * 1000, hSession, timer_expired, &timeout);

	while(rc == -1) {
		if(timeout) {
			// Timeout! The timer was destroyed.
			return errno = ETIMEDOUT;
		}

		if(hSession->connection.state == LIB3270_NOT_CONNECTED) {
			rc = ENOTCONN;
			break;
		}

		if(!hSession->starting && hSession->connection.state == cstate) {
			rc = 0;
			break;
		}

		lib3270_main_iterate(hSession,1);

	}
	RemoveTimer(hSession,timer);

	return errno = rc;
}

LIB3270_EXPORT LIB3270_KEYBOARD_LOCK_STATE lib3270_wait_for_keyboard_unlock(H3270 *hSession, int seconds) {
	debug("Session lock state is %d",lib3270_get_lock_status(hSession));

	int rc = 0;
	int timeout = 0;
	void * timer = AddTimer(seconds * 1000, hSession, timer_expired, &timeout);

	while(!rc) {
		if(timeout) {
			// Timeout! The timer was destroyed.
			debug("%s exits with ETIMEDOUT",__FUNCTION__);
			errno = ETIMEDOUT;
			break;
		}

		if(hSession->kybdlock == LIB3270_KL_NOT_CONNECTED) {
			errno = ENOTCONN;
			break;
		}

		if(KYBDLOCK_IS_OERR(hSession)) {
			errno = EPERM;
			break;
		}

		if(hSession->kybdlock == LIB3270_KL_UNLOCKED)
			break;

		debug("%s: Waiting",__FUNCTION__);
		lib3270_main_iterate(hSession,1);

	}

	RemoveTimer(hSession,timer);

	debug("%s exits with rc=%d",__FUNCTION__,rc);
	return (LIB3270_KEYBOARD_LOCK_STATE) hSession->kybdlock;

}