root/native_client_sdk/src/libraries/nacl_io/socket/udp_event_emitter.cc

DEFINITIONS

1. out_fifo_
2. ReadRXPacket_Locked
3. WriteRXPacket_Locked
4. ReadTXPacket_Locked
5. WriteTXPacket_Locked

// Copyright 2013 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#include "nacl_io/socket/udp_event_emitter.h"

#include "sdk_util/auto_lock.h"

namespace nacl_io {

UdpEventEmitter::UdpEventEmitter(size_t rsize, size_t wsize)
    : in_fifo_(rsize), out_fifo_(wsize) {
  UpdateStatus_Locked();
}

Packet* UdpEventEmitter::ReadRXPacket_Locked() {
  Packet* packet = in_fifo_.ReadPacket();

  UpdateStatus_Locked();
  return packet;
}

void UdpEventEmitter::WriteRXPacket_Locked(Packet* packet) {
  in_fifo_.WritePacket(packet);

  UpdateStatus_Locked();
}

Packet* UdpEventEmitter::ReadTXPacket_Locked() {
  Packet* packet = out_fifo_.ReadPacket();

  UpdateStatus_Locked();
  return packet;
}

void UdpEventEmitter::WriteTXPacket_Locked(Packet* packet) {
  out_fifo_.WritePacket(packet);

  UpdateStatus_Locked();
}

}  // namespace nacl_io