/*
 * Copyright 2003-2007, Waldemar Kornewald <wkornew@gmx.net>
 * Distributed under the terms of the MIT License.
 */

#include <OS.h>

#include <KPPPUtils.h>
#include <KPPPInterface.h>


//!	Returns if this protocol is allowed to handle packets in the current state.
bool
IsProtocolAllowed(const KPPPProtocol& protocol)
{
	if (protocol.ProtocolNumber() == PPP_LCP_PROTOCOL)
		return true;
	else if (protocol.Interface().State() != PPP_OPENED_STATE)
		return false;
	else if (protocol.Interface().Phase() > PPP_AUTHENTICATION_PHASE
			|| (protocol.Interface().Phase() >= PPP_ESTABLISHMENT_PHASE
				&& protocol.Flags() & PPP_ALWAYS_ALLOWED))
		return true;
	else
		return false;
}


status_t
send_data_with_timeout(thread_id thread, int32 code, void *buffer,
	size_t buffer_size, uint32 timeout)
{
	for (uint32 tries = 0; tries < timeout; tries += 5) {
		if (has_data(thread))
			snooze(5000);
		else
			break;
	}
	
	if (!has_data(thread))
		return send_data(thread, code, buffer, buffer_size);
	else
		return B_TIMED_OUT;
}


status_t
receive_data_with_timeout(thread_id *sender, int32 *code, void *buffer,
	size_t buffer_size, uint32 timeout)
{
	thread_id me = find_thread(NULL);
	for (uint32 tries = 0; tries < timeout; tries += 5) {
		if (!has_data(me))
			snooze(5000);
		else
			break;
	}
	
	if (has_data(find_thread(NULL))) {
		*code = receive_data(sender, buffer, buffer_size);
		return B_OK;
	} else
		return B_TIMED_OUT;
}