source: xplcommon/src/xplcommon/posix/Socket.h@ 19:54c3f68d2d46

Last change on this file since 19:54c3f68d2d46 was 19:54c3f68d2d46, checked in by István Váradi <ivaradi@…>, 11 years ago

Fixed problems with non-blocking mode and extended the socket test program to actually communicate

File size: 4.1 KB
Line 
1// Copyright (c) 2012 by István Váradi
2
3// This file is part of libxplcommon, a common utility library for
4// development related to X-Plane
5
6// Redistribution and use in source and binary forms, with or without
7// modification, are permitted provided that the following conditions are met:
8
9// 1. Redistributions of source code must retain the above copyright notice, this
10// list of conditions and the following disclaimer.
11// 2. Redistributions in binary form must reproduce the above copyright notice,
12// this list of conditions and the following disclaimer in the documentation
13// and/or other materials provided with the distribution.
14
15// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
16// ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
17// WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
18// DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR
19// ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
20// (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
21// LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
22// ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
23// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
24// SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
25
26// The views and conclusions contained in the software and documentation are those
27// of the authors and should not be interpreted as representing official policies,
28// either expressed or implied, of the FreeBSD Project.
29
30#ifndef XPLCOMMON_POSIX_SOCKET_H
31#define XPLCOMMON_POSIX_SOCKET_H
32//------------------------------------------------------------------------------
33
34#include "BufferedStream.h"
35
36//------------------------------------------------------------------------------
37
38struct sockaddr;
39
40//------------------------------------------------------------------------------
41
42namespace xplcommon { namespace posix {
43
44//------------------------------------------------------------------------------
45
46/**
47 * A buffered, waitable socket implementation.
48 */
49class Socket : public BufferedStream
50{
51private:
52 /**
53 * Construct a socket with the given parameters.
54 */
55 static int socket(int domain, int type, int protocol);
56
57protected:
58 /**
59 * Construct the socket with the given parameters.
60 */
61 Socket(int domain, int type, Waiter* waiter = 0, int protocol = 0,
62 size_t readingCapacity = DEFAULT_CAPACITY,
63 size_t writingCapacity = DEFAULT_CAPACITY);
64
65 /**
66 * Construct the socket with the given file descriptor.
67 */
68 Socket(int fd, Waiter* waiter = 0,
69 size_t readingCapacity = DEFAULT_CAPACITY,
70 size_t writingCapacity = DEFAULT_CAPACITY);
71
72public:
73 /**
74 * Destroy the socket by closing the file descriptor.
75 */
76 virtual ~Socket();
77
78 friend class ServerSocket;
79};
80
81//------------------------------------------------------------------------------
82// Inline definitions
83//------------------------------------------------------------------------------
84
85inline Socket::Socket(int domain, int type, Waiter* waiter, int protocol,
86 size_t readingCapacity, size_t writingCapacity) :
87 BufferedStream(waiter, socket(domain, type, protocol),
88 readingCapacity, writingCapacity)
89{
90 if (fd<0) setErrorCodeFromErrno();
91 else if (waiter!=0) setNonBlocking(fd);
92}
93
94//------------------------------------------------------------------------------
95
96inline Socket::Socket(int fd, Waiter* waiter,
97 size_t readingCapacity, size_t writingCapacity) :
98 BufferedStream(waiter, fd, readingCapacity, writingCapacity)
99{
100 if (waiter!=0) setNonBlocking(fd);
101}
102
103//------------------------------------------------------------------------------
104
105} /* namespace xplcommon::posix */ } /* namespace xplcommon */
106
107//------------------------------------------------------------------------------
108#endif // XPLCOMMON_POSIX_SOCKET_H
109
110// Local Variables:
111// mode: C++
112// c-basic-offset: 4
113// indent-tabs-mode: nil
114// End:
Note: See TracBrowser for help on using the repository browser.