libserv/file_channel.cpp at master · 42-serv/libserv · 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
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
/* Any copyright is dedicated to the Public Domain.
 * https://creativecommons.org/publicdomain/zero/1.0/ */

#include "file_channel.hpp"

#include "serv_exception.hpp"
#include "serv_types.hpp"

#include <sys/types.h>
#include <unistd.h>

#include <cstddef>
#include <string>

ft::serv::file_channel::file_channel(ident_t ident, const std::string& host, int serv, std::size_t init_buf_capacity)
    : stream_channel(ident, host, serv, init_buf_capacity)
{
}

ft::serv::file_channel::~file_channel()
{
}

long ft::serv::file_channel::do_read(void* const buf, const std::size_t len) throw()
{
    staticassert(sizeof(long) >= sizeof(::ssize_t));

    const ident_t ident = this->get_ident();
    ::ssize_t value;
    do
    {
        value = ::read(ident, buf, len);
        if (value < 0)
        {
            const syscall_failed e;
            switch (e.error())
            {
            case EINTR:
                continue;

            default:
                return -e.error();
            }
        }
        break;
    } while (!0);

    return value;
}

long ft::serv::file_channel::do_write(const void* const buf, const std::size_t len) throw()
{
    staticassert(sizeof(long) >= sizeof(::ssize_t));

    const ident_t ident = this->get_ident();
    ::ssize_t value;
    do
    {
        value = ::write(ident, buf, len);
        if (value < 0)
        {
            const syscall_failed e;
            switch (e.error())
            {
            case EINTR:
                continue;

            default:
                return -e.error();
            }
        }
        break;
    } while (!0);

    return value;
}