/cvmfs/atlas.cern.ch/repo/sw/ASG/AnalysisBase/2.4.31/EventLoop/EventLoop/BackgroundSocket.h

#ifndef EVENT_LOOP__BACKGROUND_SOCKET_H
#define EVENT_LOOP__BACKGROUND_SOCKET_H

//        Copyright Iowa State University 2015.
//                  Author: Nils Krumnack
// Distributed under the Boost Software License, Version 1.0.
//    (See accompanying file LICENSE_1_0.txt or copy at
//          http://www.boost.org/LICENSE_1_0.txt)

// Please feel free to contact me (nils.erik.krumnack@cern.ch) for bug
// reports, feature suggestions, praise and complaints.


#include <EventLoop/Global.h>

#include <memory>
#include <string>

namespace EL
{

  class BackgroundSocket
  {
    //
    // public interface
    //

  public:
    enum Type
    {
      T_START_JOB,

      T_SET_INPUT_FILE,

      T_SET_ENTRY,

      T_EXECUTE,

      T_EXECUTE_CONFIRM,

      T_END_JOB,

      T_END_JOB_CONFIRM,

      T_INVALID
    };



  public:
    void testInvariant () const;


  public:
    BackgroundSocket (int val_socket);


  public:
    ~BackgroundSocket ();


  public:
    void write (Type type, const std::string& payload);


  public:
    void read (Type& type, std::string& payload);


  public:
    static void makeSockets (int sockets [2]);

  public:
    static std::auto_ptr<BackgroundSocket>
    startWorker (const BackgroundJob& job);



    //
    // private interface
    //

  private:
    int m_socket;

  private:
    std::string m_inputBuffer;

  private:
    std::string m_outputBuffer;
  };
}

#endif

---