File: serversocket.yo

package info (click to toggle)
bobcat 6.02.02-1
  • links: PTS, VCS
  • area: main
  • in suites: bookworm
  • size: 13,960 kB
  • sloc: cpp: 18,954; fortran: 5,617; makefile: 2,787; sh: 659; perl: 401; ansic: 26
file content (177 lines) | stat: -rw-r--r-- 6,808 bytes parent folder | download | duplicates (3)
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
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
includefile(include/header)

COMMENT(manpage, section, releasedate, archive, short name)
manpage(FBB::ServerSocket)(3bobcat)
    (_CurYrs_)(libbobcat-dev__CurVers_)
                    (Server Socket)

manpagename(FBB::ServerSocket)
            (Server socket accepting Internet connection requests)

manpagesynopsis()
    bf(#include <bobcat/serversocket>)nl()
    Linking option: tt(-lbobcat)

manpagedescription()
    An bf(FBB::ServerSocket) may be constructed to listen for connection
requests from the Internet or from the local host. Connection requests may be
accepted in either em(blocking) or em(non-blocking) modes. When a connection
is accepted a socket is returned which may be used to read information from or
write information to the client that requested the connection. The socket that
is made available is a em(file descriptor) which may be used to initialize a
bf(std::istream) and/or bf(std::ostream). The bf(std::istream) is used to read
information from the client process; the bf(std::ostream) is used to send
information to the client process.  Since a socket may be considered a em(file
descriptor) the available bf(FBB::IFdStream), bf(FBB::IFdStreamBuf),
bf(FBB::OFdStream), and bf(FBB::OFdStreamBuf) classes may be used profitably
here. Note that having available a socket does not mean that this defines the
communication protocol. It is (still) the responsibility of the programmer to
comply with an existing protocol or to implement a tailor-made protocol. The
latter situation implies that the sequence of input- and output operations is
defined by the programmer.

    A Unix Domain server socket can be defined using
tt(FBB::LocalServerSocket).

includefile(include/namespace)

manpagesection(INHERITS FROM)
    bf(FBB::SocketBase)

manpagesection(CONSTRUCTOR)
    itemization(
    itb(ServerSocket(size_t  port))
        This constructor initializes an bf(FBB::ServerSocket) object, which
will listen for connections at the specified port.  The construction of the
socket does not mean that the bf(FBB::ServerSocket) object is actually
listening for connections. To start listening, the member bf(listen()) should
be used.
    )

    Copy and move constructors (and assignment operators) are not available.

manpagesection(MEMBER FUNCTIONS)
     All members of bf(FBB::SocketBase) (and thus of bf(FBB::InetAddress)) are
available, as bf(FBB::ServerSocket) inherits from bf(FBB::SocketBase).
    itemization(
    itb(void listen(size_t backlog = 5, bool blocking = true))
        The bf(listen()) member defines the way the bf(FBB::ServerSocket) will
listen for clients requesting a connection.  It can be used only once with a
bf(FBB::ServerSocket). An bf(FBB::Exception) object is thrown if listening
fails, if the constructor could not create a socket, or if the bf(SocketBase)
base class could not properly be constructed.

     The bf(listen()) member's tt(backlog) parameter defines the size of the
bf(FBB::ServerSocket)'s internal queue in which connection requests may be
stored waiting for their turn to be serviced. When tt(backlog) requests are
waiting and another request arrives, then that request is lost.

    The member's second parameter, tt(blocking), is used to control the
blocking mode. By default, blocking is used, and tt(listen()) will wait until
a connection is established. This is ok in situations where clients connect
infrquently and for relatively short time intervals. Otherwise, in more
complex programs, an bf(FBB::Selector) object can be used to sense input on
the server socket and/or on various client sockets.

    itb(SocketBase accept())
        The bf(accept()) member returns an bf(FBB::SocketBase) object
containing information about the client whose connection request was
accepted. The bf(FBB::SocketBase) object's socket value may be used to
initialize streams that can be used to communicate with the client. In more
complex programs the bf(FBB::SocketBase) could be passed to a class derived
from bf(FBB::Fork), handling the communication with the child as a separate
(child) process.
    )


manpagesection(EXAMPLE)
    See also the bf(clientsocket)(3bobcat) example.
        verb(
    #include <iostream>
    #include <string>
    #include <bobcat/serversocket>
    #include <bobcat/ifdstream>
    #include <bobcat/ofdstream>

    using namespace std;
    using namespace FBB;

    int main(int argc, char **argv)
    try
    {
        if (argc == 1)
        {
            cerr << "Provide server port number\n";
            return 1;
        }

        size_t portnr = stoul(argv[1]);

        ServerSocket server(portnr);

        cerr << "server listens on port " << argv[1] << endl;

        cerr << "serversocket returns:\n" <<
            "address = " << server.dottedDecimalAddress() << "\n"
            "port    = " << server.port() << endl;

        int fd = server.socket();       // open the socket's descriptor

        cout << "File descriptor of the socket is " << fd << "\n"
            "The server terminates when it receives a "
                                        "single `q' on a line\n"
            "A connection is terminated when no input "
                                        "is received anymore.\n"
            "Then another connection is possible" << endl;

        server.listen();                // listen in blocking mode

        while (true)
        {
            SocketBase fdb = server.accept();
            int fd = fdb.socket();

            cerr << "Client FD = " << fd << ", " << endl <<
                    "address = " << fdb.dottedDecimalAddress() << ", " <<
                    endl <<
                    "communication through port " << fdb.port() << endl;

            IFdStream in(fd);           // stream to read from client
            OFdStream out(fd);          // stream to write to client
            string cmd;

            while (getline(in, cmd))
            {
                cout << "Got: " << cmd << endl;
                out << "Got: " << cmd << "\r" << endl;

                if (cmd[0] == 'q')
                    return 0;
            }
            cout << "Ready for another connection\n";
        }
    }
    catch (Exception const &err)
    {
        cerr <<
            err.what() << endl <<
            "Server socket on port " << argv[1] <<
            " can't be opened" << endl;
        return -1;
    }
        )

manpagefiles()
    em(bobcat/serversocket) - defines the class interface

manpageseealso()
    bf(bobcat)(7), bf(clientsocket)(3bobcat), bf(fork)(3bobcat),
bf(ifdstream)(3bobcat), bf(ifdbuf)(3bobcat), bf(inetaddress)(3bobcat),
bf(localserversocket)(3bobcat), bf(ofdstream)(3bobcat),
bf(ofdstream)(3bobcat), bf(select)(2), bf(selector)(3bobcat),
bf(socketbase)(3bobcat)

manpagebugs()
    None Reported.

includefile(include/trailer)