ChanEndpoint.cpp

// Copyright (c) 2011, Richard Osborne, All rights reserved
// This software is freely distributable under a derivative of the
// University of Illinois/NCSA Open Source License posted in
// LICENSE.txt and at <http://github.xcore.com/>

#include "ChanEndpoint.h"

ChanEndpoint::ChanEndpoint() :
  junkIncoming(true),
  source(0)
{
}

bool ChanEndpoint::claim(ChanEndpoint *newSource, bool &junkPacket)
{
  if (junkIncoming) {
    junkPacket = true;
    return true;
  }
  // Check if the route is already open.
  if (source == newSource) {
    return true;
  }
  // Check if we are already in the middle of a packet.
  if (source) {
    queue.push(newSource);
    return false;
  }
  // Claim the channel
  source = newSource;
  return true;
}

void ChanEndpoint::release(ticks_t time)
{
  if (queue.empty()) {
    source = 0;
    return;
  }
  source = queue.front();
  queue.pop();
  source->notifyDestClaimed(time);
}