author Bobby Holley <bobbyholley@gmail.com>
Sun, 19 Jul 2015 19:23:55 -0700
changeset 280067 a37164c4c1bbec3a11efb47e5a4f92034c8843d5
parent 178719 b54fdf8bb4860ced8f64b7540485157b69ebed11
child 362733 413335e6452af2fb0768056b652953ca5da0fe96
permissions -rw-r--r--
Bug 1161831 - Tests. r=billm

/* This Source Code Form is subject to the terms of the Mozilla Public
 * License, v. 2.0. If a copy of the MPL was not distributed with this file,
 * You can obtain one at http://mozilla.org/MPL/2.0/. */

#ifndef mozilla_system_netd_h__
#define mozilla_system_netd_h__

#include "nsISupportsImpl.h"
#include "nsAutoPtr.h"
#include "base/message_loop.h"
#include "mozilla/FileUtils.h"

#define MAX_COMMAND_SIZE  4096

namespace mozilla {
namespace ipc {

 * Represents raw data going to or coming from the Netd socket.
struct NetdCommand
  uint8_t mData[MAX_COMMAND_SIZE];

  // Number of octets in mData.
  size_t mSize;

class NetdConsumer
  virtual ~NetdConsumer() { }


  virtual void MessageReceived(NetdCommand* aMessage) = 0;

class NetdWriteTask : public Task
  virtual void Run();

class NetdClient : public MessageLoopForIO::LineWatcher
  virtual ~NetdClient();

  typedef std::queue<NetdCommand*> NetdCommandQueue;

  static void Start();
  static void SendNetdCommandIOThread(NetdCommand* aMessage);

  void WriteNetdCommand();
  virtual void OnError();
  virtual void OnLineRead(int aFd, nsDependentCSubstring& aMessage);
  virtual void OnFileCanWriteWithoutBlocking(int aFd);
  bool OpenSocket();

  MessageLoopForIO *mIOLoop;
  MessageLoopForIO::FileDescriptorWatcher mReadWatcher;
  MessageLoopForIO::FileDescriptorWatcher mWriteWatcher;
  ScopedClose mSocket;
  NetdCommandQueue mOutgoingQ;
  nsAutoPtr<NetdCommand> mCurrentNetdCommand;
  size_t mCurrentWriteOffset;
  size_t mReConnectTimes;

void StartNetd(NetdConsumer *);
void StopNetd();
void SendNetdCommand(NetdCommand *);

} // namespace ipc
} // namespace mozilla

#endif  // mozilla_system_netd_h__