quickfix-ffi 0.2.1

Low level binding to quickfix C++ library
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100

/* -*- C++ -*- */

/****************************************************************************
** Copyright (c) 2001-2014
**
** This file is part of the QuickFIX FIX Engine
**
** This file may be distributed under the terms of the quickfixengine.org
** license as defined by quickfixengine.org and appearing in the file
** LICENSE included in the packaging of this file.
**
** This file is provided AS IS with NO WARRANTY OF ANY KIND, INCLUDING THE
** WARRANTY OF DESIGN, MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE.
**
** See http://www.quickfixengine.org/LICENSE for licensing information.
**
** Contact ask@quickfixengine.org if any conditions of this licensing are
** not clear to you.
**
****************************************************************************/

#ifndef FIX_SOCKETSERVER_H
#define FIX_SOCKETSERVER_H

#ifdef _MSC_VER
#pragma warning(disable : 4503 4355 4786 4290)
#endif

#include "Exceptions.h"
#include "SocketMonitor.h"
#include <map>
#include <queue>
#include <set>

namespace FIX {
/// Information about listening socket
struct SocketInfo {
  SocketInfo()
      : m_socket(INVALID_SOCKET_HANDLE),
        m_port(0),
        m_noDelay(false),
        m_sendBufSize(0),
        m_rcvBufSize(0) {}

  SocketInfo(socket_handle socket, short port, bool noDelay, int sendBufSize, int rcvBufSize)
      : m_socket(socket),
        m_port(port),
        m_noDelay(noDelay),
        m_sendBufSize(sendBufSize),
        m_rcvBufSize(rcvBufSize) {}

  socket_handle m_socket;
  short m_port;
  bool m_noDelay;
  int m_sendBufSize;
  int m_rcvBufSize;
};

/// Listens for and accepts incoming socket connections on a port.
class SocketServer {
public:
  class Strategy;

  SocketServer(int timeout = 0);

  socket_handle add(int port, bool reuse = false, bool noDelay = false, int sendBufSize = 0, int rcvBufSize = 0)
      EXCEPT(SocketException &);
  socket_handle accept(socket_handle socket);
  void close();
  bool block(Strategy &strategy, bool poll = 0, double timeout = 0.0);

  size_t numConnections() { return m_monitor.numSockets() - 1; }
  SocketMonitor &getMonitor() { return m_monitor; }

  int socketToPort(socket_handle socket);
  socket_handle portToSocket(int port);

private:
  typedef std::map<socket_handle, SocketInfo> SocketToInfo;
  typedef std::map<int, SocketInfo> PortToInfo;

  SocketToInfo m_socketToInfo;
  PortToInfo m_portToInfo;
  SocketMonitor m_monitor;

public:
  class Strategy {
  public:
    virtual ~Strategy() {}
    virtual void onConnect(SocketServer &, socket_handle acceptSocket, socket_handle socket) = 0;
    virtual void onWrite(SocketServer &, socket_handle socket) = 0;
    virtual bool onData(SocketServer &, socket_handle socket) = 0;
    virtual void onDisconnect(SocketServer &, socket_handle socket) = 0;
    virtual void onError(SocketServer &) = 0;
    virtual void onTimeout(SocketServer &) {};
  };
};
} // namespace FIX

#endif // FIX_SOCKETSERVER_H