* 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>
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;
}
