File: DriverMock.cpp

package info (click to toggle)
indi 2.1.9%2Bdfsg-1
  • links: PTS, VCS
  • area: main
  • in suites: experimental
  • size: 15,888 kB
  • sloc: cpp: 217,447; ansic: 31,363; xml: 1,195; sh: 311; makefile: 13
file content (84 lines) | stat: -rw-r--r-- 2,286 bytes parent folder | download
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
/*******************************************************************************
  Copyright(c) 2022 Ludovic Pollet. All rights reserved.

 This library is free software; you can redistribute it and/or
 modify it under the terms of the GNU Library General Public
 License version 2 as published by the Free Software Foundation.

 This library is distributed in the hope that it will be useful,
 but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 Library General Public License for more details.

 You should have received a copy of the GNU Library General Public License
 along with this library; see the file COPYING.LIB.  If not, write to
 the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
 Boston, MA 02110-1301, USA.
*******************************************************************************/

#include <system_error>

#include "DriverMock.h"
#include "utils.h"


class FakeDriverListener {
    std::string abstractPath;
    bool ready = false;
public:
    int serverConnection;
    void setup() {
        if (ready) return;
        ready = true;
        // Create a socket that will not have the clo on exec flag ?
        abstractPath = "/tmp/fakedriver-test";
        setenv("FAKEDRIVER_ADDRESS", abstractPath.c_str(), 1);

        serverConnection = unixSocketListen(abstractPath);
    }
};

static FakeDriverListener driverListener;


void DriverMock::setup()
{
    driverListener.setup();
}

void DriverMock::waitEstablish()
{
    driverConnection = socketAccept(driverListener.serverConnection);
    unixSocketRecvFds(driverConnection, 2, driverFds);
    cnx.setFds(driverFds[0], driverFds[1]);
}

void DriverMock::terminateDriver()
{
    cnx.setFds(-1, -1);
    if (driverConnection != -1) close(driverConnection);
    if (driverFds[0] != -1) close(driverFds[0]);
    if (driverFds[1] != -1) close(driverFds[1]);
    driverConnection = -1;
    driverFds[0] = -1;
    driverFds[1] = -1;
}


void DriverMock::ping()
{
    cnx.send("<pingRequest uid='flush'/>\n");
    cnx.expectXml("<pingReply uid=\"flush\"/>");
}

DriverMock::DriverMock()
{
    driverConnection = -1;
    driverFds[0] = -1;
    driverFds[1] = -1;
}

DriverMock::~DriverMock()
{
    terminateDriver();
}