CompressUtils/pipe_ipc_clt.h at master · nlitsme/CompressUtils · GitHub

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
#ifndef __PIPE_IPC_CLT_H__
#define __PIPE_IPC_CLT_H__
#include <stdio.h>
#include <unistd.h>
#include "stringutils.h"
#include "err/posix.h"
#include "readwriter.h"
#include "forkchild.h"
#include "ipclog.h"


class pipe_ipc_client : public readwriter, public fork_child {
    int _fds2c[2];
    int _fdc2s[2];
public:
    pipe_ipc_client(const std::string& svrname, const StringList& args)
    {
        if (-1==pipe(_fds2c))
            throw posixerror("pipe-s2c");
        ipclog("s2c: %d, %d\n", _fds2c[0], _fds2c[1]);
        if (-1==pipe(_fdc2s))
            throw posixerror("pipe-c2s");
        ipclog("c2s: %d, %d\n", _fdc2s[0], _fdc2s[1]);

        run_child(svrname, args);

        // parent

//      close(_fdc2s[0]);
//      close(_fds2c[1]);
    }
    ~pipe_ipc_client()
    {
    }
    virtual void initialize_child()
    {
        if (-1==dup2(_fdc2s[0],STDIN_FILENO))
            throw posixerror("dup2(stdin)");
        if (-1==dup2(_fds2c[1],STDOUT_FILENO))
            throw posixerror("dup2(stdout)");
        ipclog("svr: %d->stdin, %d->stdout\n", _fdc2s[0], _fds2c[1]);

        close(_fdc2s[0]);
        close(_fdc2s[1]);
        close(_fds2c[0]);
        close(_fds2c[1]);
    }

    virtual size_t readsome(void*p, size_t n)
    {
        return ::read(_fds2c[0], p, n);
    }

    virtual size_t writesome(const void*p, size_t n)
    {
        return ::write(_fdc2s[1], p, n);
    }
};
#endif