| // |
| // detail/impl/reactive_serial_port_service.ipp |
| // ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ |
| // |
| // Copyright (c) 2003-2010 Christopher M. Kohlhoff (chris at kohlhoff dot com) |
| // Copyright (c) 2008 Rep Invariant Systems, Inc. (info@repinvariant.com) |
| // |
| // Distributed under the Boost Software License, Version 1.0. (See accompanying |
| // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt) |
| // |
| |
| #ifndef BOOST_ASIO_DETAIL_IMPL_REACTIVE_SERIAL_PORT_SERVICE_IPP |
| #define BOOST_ASIO_DETAIL_IMPL_REACTIVE_SERIAL_PORT_SERVICE_IPP |
| |
| #if defined(_MSC_VER) && (_MSC_VER >= 1200) |
| # pragma once |
| #endif // defined(_MSC_VER) && (_MSC_VER >= 1200) |
| |
| #include <boost/asio/detail/config.hpp> |
| |
| #if defined(BOOST_ASIO_HAS_SERIAL_PORT) |
| #if !defined(BOOST_WINDOWS) && !defined(__CYGWIN__) |
| |
| #include <cstring> |
| #include <boost/asio/detail/reactive_serial_port_service.hpp> |
| |
| #include <boost/asio/detail/push_options.hpp> |
| |
| namespace boost { |
| namespace asio { |
| namespace detail { |
| |
| reactive_serial_port_service::reactive_serial_port_service( |
| boost::asio::io_service& io_service) |
| : descriptor_service_(io_service) |
| { |
| } |
| |
| void reactive_serial_port_service::shutdown_service() |
| { |
| descriptor_service_.shutdown_service(); |
| } |
| |
| boost::system::error_code reactive_serial_port_service::open( |
| reactive_serial_port_service::implementation_type& impl, |
| const std::string& device, boost::system::error_code& ec) |
| { |
| if (is_open(impl)) |
| { |
| ec = boost::asio::error::already_open; |
| return ec; |
| } |
| |
| descriptor_ops::state_type state = 0; |
| int fd = descriptor_ops::open(device.c_str(), |
| O_RDWR | O_NONBLOCK | O_NOCTTY, ec); |
| if (fd < 0) |
| return ec; |
| |
| int s = descriptor_ops::fcntl(fd, F_GETFL, ec); |
| if (s >= 0) |
| s = descriptor_ops::fcntl(fd, F_SETFL, s | O_NONBLOCK, ec); |
| if (s < 0) |
| { |
| boost::system::error_code ignored_ec; |
| descriptor_ops::close(fd, state, ignored_ec); |
| return ec; |
| } |
| |
| // Set up default serial port options. |
| termios ios; |
| errno = 0; |
| s = descriptor_ops::error_wrapper(::tcgetattr(fd, &ios), ec); |
| if (s >= 0) |
| { |
| #if defined(_BSD_SOURCE) |
| ::cfmakeraw(&ios); |
| #else |
| ios.c_iflag &= ~(IGNBRK | BRKINT | PARMRK |
| | ISTRIP | INLCR | IGNCR | ICRNL | IXON); |
| ios.c_oflag &= ~OPOST; |
| ios.c_lflag &= ~(ECHO | ECHONL | ICANON | ISIG | IEXTEN); |
| ios.c_cflag &= ~(CSIZE | PARENB); |
| ios.c_cflag |= CS8; |
| #endif |
| ios.c_iflag |= IGNPAR; |
| ios.c_cflag |= CREAD | CLOCAL; |
| errno = 0; |
| s = descriptor_ops::error_wrapper(::tcsetattr(fd, TCSANOW, &ios), ec); |
| } |
| if (s < 0) |
| { |
| boost::system::error_code ignored_ec; |
| descriptor_ops::close(fd, state, ignored_ec); |
| return ec; |
| } |
| |
| // We're done. Take ownership of the serial port descriptor. |
| if (descriptor_service_.assign(impl, fd, ec)) |
| { |
| boost::system::error_code ignored_ec; |
| descriptor_ops::close(fd, state, ignored_ec); |
| } |
| |
| return ec; |
| } |
| |
| boost::system::error_code reactive_serial_port_service::do_set_option( |
| reactive_serial_port_service::implementation_type& impl, |
| reactive_serial_port_service::store_function_type store, |
| const void* option, boost::system::error_code& ec) |
| { |
| termios ios; |
| errno = 0; |
| descriptor_ops::error_wrapper(::tcgetattr( |
| descriptor_service_.native(impl), &ios), ec); |
| if (ec) |
| return ec; |
| |
| if (store(option, ios, ec)) |
| return ec; |
| |
| errno = 0; |
| descriptor_ops::error_wrapper(::tcsetattr( |
| descriptor_service_.native(impl), TCSANOW, &ios), ec); |
| return ec; |
| } |
| |
| boost::system::error_code reactive_serial_port_service::do_get_option( |
| const reactive_serial_port_service::implementation_type& impl, |
| reactive_serial_port_service::load_function_type load, |
| void* option, boost::system::error_code& ec) const |
| { |
| termios ios; |
| errno = 0; |
| descriptor_ops::error_wrapper(::tcgetattr( |
| descriptor_service_.native(impl), &ios), ec); |
| if (ec) |
| return ec; |
| |
| return load(option, ios, ec); |
| } |
| |
| } // namespace detail |
| } // namespace asio |
| } // namespace boost |
| |
| #include <boost/asio/detail/pop_options.hpp> |
| |
| #endif // !defined(BOOST_WINDOWS) && !defined(__CYGWIN__) |
| #endif // defined(BOOST_ASIO_HAS_SERIAL_PORT) |
| |
| #endif // BOOST_ASIO_DETAIL_IMPL_REACTIVE_SERIAL_PORT_SERVICE_IPP |