1 //
2 // socket_base.hpp
3 // ~~~~~~~~~~~~~~~
4 //
5 // Copyright (c) 2003-2015 Christopher M. Kohlhoff (chris at kohlhoff dot com)
6 //
7 // Distributed under the Boost Software License, Version 1.0. (See accompanying
8 // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
9 //
10 
11 #ifndef ASIO_SOCKET_BASE_HPP
12 #define ASIO_SOCKET_BASE_HPP
13 
14 
15 #include "asio/detail/config.hpp"
16 #include "asio/detail/io_control.hpp"
17 #include "asio/detail/socket_option.hpp"
18 #include "asio/detail/socket_types.hpp"
19 
20 #include "asio/detail/push_options.hpp"
21 
22 namespace asio {
23 
24 /// The socket_base class is used as a base for the basic_stream_socket and
25 /// basic_datagram_socket class templates so that we have a common place to
26 /// define the shutdown_type and enum.
27 class socket_base
28 {
29 public:
30   /// Different ways a socket may be shutdown.
31   enum shutdown_type
32   {
33     shutdown_receive = ASIO_OS_DEF(SHUT_RD),
34     shutdown_send = ASIO_OS_DEF(SHUT_WR),
35     shutdown_both = ASIO_OS_DEF(SHUT_RDWR)
36   };
37 
38   /// Bitmask type for flags that can be passed to send and receive operations.
39   typedef int message_flags;
40 
41   ASIO_STATIC_CONSTANT(int,
42       message_peek = ASIO_OS_DEF(MSG_PEEK));
43   ASIO_STATIC_CONSTANT(int,
44       message_out_of_band = ASIO_OS_DEF(MSG_OOB));
45   ASIO_STATIC_CONSTANT(int,
46       message_do_not_route = ASIO_OS_DEF(MSG_DONTROUTE));
47   ASIO_STATIC_CONSTANT(int,
48       message_end_of_record = ASIO_OS_DEF(MSG_EOR));
49 
50   /// Socket option to permit sending of broadcast messages.
51   /**
52    * Implements the SOL_SOCKET/SO_BROADCAST socket option.
53    *
54    * @par Examples
55    * Setting the option:
56    * @code
57    * asio::ip::udp::socket socket(io_service);
58    * ...
59    * asio::socket_base::broadcast option(true);
60    * socket.set_option(option);
61    * @endcode
62    *
63    * @par
64    * Getting the current option value:
65    * @code
66    * asio::ip::udp::socket socket(io_service);
67    * ...
68    * asio::socket_base::broadcast option;
69    * socket.get_option(option);
70    * bool is_set = option.value();
71    * @endcode
72    *
73    * @par Concepts:
74    * Socket_Option, Boolean_Socket_Option.
75    */
76   typedef asio::detail::socket_option::boolean<
77     ASIO_OS_DEF(SOL_SOCKET), ASIO_OS_DEF(SO_BROADCAST)>
78       broadcast;
79 
80   /// Socket option to enable socket-level debugging.
81   /**
82    * Implements the SOL_SOCKET/SO_DEBUG socket option.
83    *
84    * @par Examples
85    * Setting the option:
86    * @code
87    * asio::ip::tcp::socket socket(io_service);
88    * ...
89    * asio::socket_base::debug option(true);
90    * socket.set_option(option);
91    * @endcode
92    *
93    * @par
94    * Getting the current option value:
95    * @code
96    * asio::ip::tcp::socket socket(io_service);
97    * ...
98    * asio::socket_base::debug option;
99    * socket.get_option(option);
100    * bool is_set = option.value();
101    * @endcode
102    *
103    * @par Concepts:
104    * Socket_Option, Boolean_Socket_Option.
105    */
106   typedef asio::detail::socket_option::boolean<
107     ASIO_OS_DEF(SOL_SOCKET), ASIO_OS_DEF(SO_DEBUG)> debug;
108 
109   /// Socket option to prevent routing, use local interfaces only.
110   /**
111    * Implements the SOL_SOCKET/SO_DONTROUTE socket option.
112    *
113    * @par Examples
114    * Setting the option:
115    * @code
116    * asio::ip::udp::socket socket(io_service);
117    * ...
118    * asio::socket_base::do_not_route option(true);
119    * socket.set_option(option);
120    * @endcode
121    *
122    * @par
123    * Getting the current option value:
124    * @code
125    * asio::ip::udp::socket socket(io_service);
126    * ...
127    * asio::socket_base::do_not_route option;
128    * socket.get_option(option);
129    * bool is_set = option.value();
130    * @endcode
131    *
132    * @par Concepts:
133    * Socket_Option, Boolean_Socket_Option.
134    */
135   typedef asio::detail::socket_option::boolean<
136     ASIO_OS_DEF(SOL_SOCKET), ASIO_OS_DEF(SO_DONTROUTE)>
137       do_not_route;
138 
139   /// Socket option to send keep-alives.
140   /**
141    * Implements the SOL_SOCKET/SO_KEEPALIVE socket option.
142    *
143    * @par Examples
144    * Setting the option:
145    * @code
146    * asio::ip::tcp::socket socket(io_service);
147    * ...
148    * asio::socket_base::keep_alive option(true);
149    * socket.set_option(option);
150    * @endcode
151    *
152    * @par
153    * Getting the current option value:
154    * @code
155    * asio::ip::tcp::socket socket(io_service);
156    * ...
157    * asio::socket_base::keep_alive option;
158    * socket.get_option(option);
159    * bool is_set = option.value();
160    * @endcode
161    *
162    * @par Concepts:
163    * Socket_Option, Boolean_Socket_Option.
164    */
165   typedef asio::detail::socket_option::boolean<
166     ASIO_OS_DEF(SOL_SOCKET), ASIO_OS_DEF(SO_KEEPALIVE)> keep_alive;
167 
168   /// Socket option for the send buffer size of a socket.
169   /**
170    * Implements the SOL_SOCKET/SO_SNDBUF socket option.
171    *
172    * @par Examples
173    * Setting the option:
174    * @code
175    * asio::ip::tcp::socket socket(io_service);
176    * ...
177    * asio::socket_base::send_buffer_size option(8192);
178    * socket.set_option(option);
179    * @endcode
180    *
181    * @par
182    * Getting the current option value:
183    * @code
184    * asio::ip::tcp::socket socket(io_service);
185    * ...
186    * asio::socket_base::send_buffer_size option;
187    * socket.get_option(option);
188    * int size = option.value();
189    * @endcode
190    *
191    * @par Concepts:
192    * Socket_Option, Integer_Socket_Option.
193    */
194   typedef asio::detail::socket_option::integer<
195     ASIO_OS_DEF(SOL_SOCKET), ASIO_OS_DEF(SO_SNDBUF)>
196       send_buffer_size;
197 
198   /// Socket option for the send low watermark.
199   /**
200    * Implements the SOL_SOCKET/SO_SNDLOWAT socket option.
201    *
202    * @par Examples
203    * Setting the option:
204    * @code
205    * asio::ip::tcp::socket socket(io_service);
206    * ...
207    * asio::socket_base::send_low_watermark option(1024);
208    * socket.set_option(option);
209    * @endcode
210    *
211    * @par
212    * Getting the current option value:
213    * @code
214    * asio::ip::tcp::socket socket(io_service);
215    * ...
216    * asio::socket_base::send_low_watermark option;
217    * socket.get_option(option);
218    * int size = option.value();
219    * @endcode
220    *
221    * @par Concepts:
222    * Socket_Option, Integer_Socket_Option.
223    */
224   typedef asio::detail::socket_option::integer<
225     ASIO_OS_DEF(SOL_SOCKET), ASIO_OS_DEF(SO_SNDLOWAT)>
226       send_low_watermark;
227 
228   /// Socket option for the receive buffer size of a socket.
229   /**
230    * Implements the SOL_SOCKET/SO_RCVBUF socket option.
231    *
232    * @par Examples
233    * Setting the option:
234    * @code
235    * asio::ip::tcp::socket socket(io_service);
236    * ...
237    * asio::socket_base::receive_buffer_size option(8192);
238    * socket.set_option(option);
239    * @endcode
240    *
241    * @par
242    * Getting the current option value:
243    * @code
244    * asio::ip::tcp::socket socket(io_service);
245    * ...
246    * asio::socket_base::receive_buffer_size option;
247    * socket.get_option(option);
248    * int size = option.value();
249    * @endcode
250    *
251    * @par Concepts:
252    * Socket_Option, Integer_Socket_Option.
253    */
254   typedef asio::detail::socket_option::integer<
255     ASIO_OS_DEF(SOL_SOCKET), ASIO_OS_DEF(SO_RCVBUF)>
256       receive_buffer_size;
257 
258   /// Socket option for the receive low watermark.
259   /**
260    * Implements the SOL_SOCKET/SO_RCVLOWAT socket option.
261    *
262    * @par Examples
263    * Setting the option:
264    * @code
265    * asio::ip::tcp::socket socket(io_service);
266    * ...
267    * asio::socket_base::receive_low_watermark option(1024);
268    * socket.set_option(option);
269    * @endcode
270    *
271    * @par
272    * Getting the current option value:
273    * @code
274    * asio::ip::tcp::socket socket(io_service);
275    * ...
276    * asio::socket_base::receive_low_watermark option;
277    * socket.get_option(option);
278    * int size = option.value();
279    * @endcode
280    *
281    * @par Concepts:
282    * Socket_Option, Integer_Socket_Option.
283    */
284   typedef asio::detail::socket_option::integer<
285     ASIO_OS_DEF(SOL_SOCKET), ASIO_OS_DEF(SO_RCVLOWAT)>
286       receive_low_watermark;
287 
288   /// Socket option to allow the socket to be bound to an address that is
289   /// already in use.
290   /**
291    * Implements the SOL_SOCKET/SO_REUSEADDR socket option.
292    *
293    * @par Examples
294    * Setting the option:
295    * @code
296    * asio::ip::tcp::acceptor acceptor(io_service);
297    * ...
298    * asio::socket_base::reuse_address option(true);
299    * acceptor.set_option(option);
300    * @endcode
301    *
302    * @par
303    * Getting the current option value:
304    * @code
305    * asio::ip::tcp::acceptor acceptor(io_service);
306    * ...
307    * asio::socket_base::reuse_address option;
308    * acceptor.get_option(option);
309    * bool is_set = option.value();
310    * @endcode
311    *
312    * @par Concepts:
313    * Socket_Option, Boolean_Socket_Option.
314    */
315   typedef asio::detail::socket_option::boolean<
316     ASIO_OS_DEF(SOL_SOCKET), ASIO_OS_DEF(SO_REUSEADDR)>
317       reuse_address;
318 
319   /// Socket option to specify whether the socket lingers on close if unsent
320   /// data is present.
321   /**
322    * Implements the SOL_SOCKET/SO_LINGER socket option.
323    *
324    * @par Examples
325    * Setting the option:
326    * @code
327    * asio::ip::tcp::socket socket(io_service);
328    * ...
329    * asio::socket_base::linger option(true, 30);
330    * socket.set_option(option);
331    * @endcode
332    *
333    * @par
334    * Getting the current option value:
335    * @code
336    * asio::ip::tcp::socket socket(io_service);
337    * ...
338    * asio::socket_base::linger option;
339    * socket.get_option(option);
340    * bool is_set = option.enabled();
341    * unsigned short timeout = option.timeout();
342    * @endcode
343    *
344    * @par Concepts:
345    * Socket_Option, Linger_Socket_Option.
346    */
347   typedef asio::detail::socket_option::linger<
348     ASIO_OS_DEF(SOL_SOCKET), ASIO_OS_DEF(SO_LINGER)>
349       linger;
350 
351   /// Socket option to report aborted connections on accept.
352   /**
353    * Implements a custom socket option that determines whether or not an accept
354    * operation is permitted to fail with asio::error::connection_aborted.
355    * By default the option is false.
356    *
357    * @par Examples
358    * Setting the option:
359    * @code
360    * asio::ip::tcp::acceptor acceptor(io_service);
361    * ...
362    * asio::socket_base::enable_connection_aborted option(true);
363    * acceptor.set_option(option);
364    * @endcode
365    *
366    * @par
367    * Getting the current option value:
368    * @code
369    * asio::ip::tcp::acceptor acceptor(io_service);
370    * ...
371    * asio::socket_base::enable_connection_aborted option;
372    * acceptor.get_option(option);
373    * bool is_set = option.value();
374    * @endcode
375    *
376    * @par Concepts:
377    * Socket_Option, Boolean_Socket_Option.
378    */
379   typedef asio::detail::socket_option::boolean<
380     asio::detail::custom_socket_option_level,
381     asio::detail::enable_connection_aborted_option>
382     enable_connection_aborted;
383 
384   /// (Deprecated: Use non_blocking().) IO control command to
385   /// set the blocking mode of the socket.
386   /**
387    * Implements the FIONBIO IO control command.
388    *
389    * @par Example
390    * @code
391    * asio::ip::tcp::socket socket(io_service);
392    * ...
393    * asio::socket_base::non_blocking_io command(true);
394    * socket.io_control(command);
395    * @endcode
396    *
397    * @par Concepts:
398    * IO_Control_Command, Boolean_IO_Control_Command.
399    */
400   typedef asio::detail::io_control::non_blocking_io non_blocking_io;
401 
402   /// IO control command to get the amount of data that can be read without
403   /// blocking.
404   /**
405    * Implements the FIONREAD IO control command.
406    *
407    * @par Example
408    * @code
409    * asio::ip::tcp::socket socket(io_service);
410    * ...
411    * asio::socket_base::bytes_readable command(true);
412    * socket.io_control(command);
413    * std::size_t bytes_readable = command.get();
414    * @endcode
415    *
416    * @par Concepts:
417    * IO_Control_Command, Size_IO_Control_Command.
418    */
419   typedef asio::detail::io_control::bytes_readable bytes_readable;
420 
421   /// The maximum length of the queue of pending incoming connections.
422   ASIO_STATIC_CONSTANT(int, max_connections
423       = ASIO_OS_DEF(SOMAXCONN));
424 
425 protected:
426   /// Protected destructor to prevent deletion through this type.
~socket_base()427   ~socket_base()
428   {
429   }
430 };
431 
432 } // namespace asio
433 
434 #include "asio/detail/pop_options.hpp"
435 
436 #endif // ASIO_SOCKET_BASE_HPP
437