2 * This file is part of the libCEC(R) library.
4 * libCEC(R) is Copyright (C) 2011-2012 Pulse-Eight Limited. All rights reserved.
5 * libCEC(R) is an original work, containing original code.
7 * libCEC(R) is a trademark of Pulse-Eight Limited.
9 * This program is dual-licensed; you can redistribute it and/or modify
10 * it under the terms of the GNU General Public License as published by
11 * the Free Software Foundation; either version 2 of the License, or
12 * (at your option) any later version.
14 * This program is distributed in the hope that it will be useful,
15 * but WITHOUT ANY WARRANTY; without even the implied warranty of
16 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
17 * GNU General Public License for more details.
19 * You should have received a copy of the GNU General Public License
20 * along with this program; if not, write to the Free Software
21 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
24 * Alternatively, you can license this library under a commercial license,
25 * please contact Pulse-Eight Licensing for more information.
27 * For more information contact:
28 * Pulse-Eight Licensing <license@pulse-eight.com>
29 * http://www.pulse-eight.com/
30 * http://www.pulse-eight.net/
36 #include "lib/platform/sockets/serialport.h"
37 #include "lib/platform/util/baudrate.h"
38 #include "lib/platform/posix/os-socket.h"
40 #if defined(__APPLE__) || defined(__FreeBSD__)
55 using namespace PLATFORM
;
57 inline bool RemoveLock(const char *strDeviceName
)
59 #if !defined(__APPLE__) && !defined(__FreeBSD__)
60 return dev_unlock(strDeviceName
, 0) == 0;
62 void *tmp
= (void*)strDeviceName
; // silence unused warning
67 void CSerialSocket::Close(void)
71 SocketClose(m_socket
);
72 RemoveLock(m_strName
.c_str());
76 void CSerialSocket::Shutdown(void)
80 SocketClose(m_socket
);
81 RemoveLock(m_strName
.c_str());
85 ssize_t
CSerialSocket::Write(void* data
, size_t len
)
87 return IsOpen() ? SocketWrite(m_socket
, &m_iError
, data
, len
) : -1;
90 ssize_t
CSerialSocket::Read(void* data
, size_t len
, uint64_t iTimeoutMs
/* = 0 */)
92 return IsOpen() ? SocketRead(m_socket
, &m_iError
, data
, len
, iTimeoutMs
) : -1;
95 //setting all this stuff up is a pain in the ass
96 bool CSerialSocket::Open(uint64_t iTimeoutMs
/* = 0 */)
105 if (m_iDatabits
!= SERIAL_DATA_BITS_FIVE
&& m_iDatabits
!= SERIAL_DATA_BITS_SIX
&&
106 m_iDatabits
!= SERIAL_DATA_BITS_SEVEN
&& m_iDatabits
!= SERIAL_DATA_BITS_EIGHT
)
108 m_strError
= "Databits has to be between 5 and 8";
113 if (m_iStopbits
!= SERIAL_STOP_BITS_ONE
&& m_iStopbits
!= SERIAL_STOP_BITS_TWO
)
115 m_strError
= "Stopbits has to be 1 or 2";
120 if (m_iParity
!= SERIAL_PARITY_NONE
&& m_iParity
!= SERIAL_PARITY_EVEN
&& m_iParity
!= SERIAL_PARITY_ODD
)
122 m_strError
= "Parity has to be none, even or odd";
127 #if !defined(__APPLE__) && !defined(__FreeBSD__)
128 if (dev_lock(m_strName
.c_str()) != 0)
130 m_strError
= "Couldn't lock the serial port";
136 m_socket
= open(m_strName
.c_str(), O_RDWR
| O_NOCTTY
| O_NDELAY
);
138 if (m_socket
== INVALID_SERIAL_SOCKET_VALUE
)
140 m_strError
= strerror(errno
);
141 RemoveLock(m_strName
.c_str());
145 SocketSetBlocking(m_socket
, false);
147 if (!SetBaudRate(m_iBaudrate
))
150 m_options
.c_cflag
|= (CLOCAL
| CREAD
);
151 m_options
.c_cflag
&= ~HUPCL
;
153 m_options
.c_cflag
&= ~CSIZE
;
154 if (m_iDatabits
== SERIAL_DATA_BITS_FIVE
) m_options
.c_cflag
|= CS5
;
155 if (m_iDatabits
== SERIAL_DATA_BITS_SIX
) m_options
.c_cflag
|= CS6
;
156 if (m_iDatabits
== SERIAL_DATA_BITS_SEVEN
) m_options
.c_cflag
|= CS7
;
157 if (m_iDatabits
== SERIAL_DATA_BITS_EIGHT
) m_options
.c_cflag
|= CS8
;
159 m_options
.c_cflag
&= ~PARENB
;
160 if (m_iParity
== SERIAL_PARITY_EVEN
|| m_iParity
== SERIAL_PARITY_ODD
)
161 m_options
.c_cflag
|= PARENB
;
162 if (m_iParity
== SERIAL_PARITY_ODD
)
163 m_options
.c_cflag
|= PARODD
;
166 m_options
.c_cflag
&= ~CRTSCTS
;
167 #elif defined(CNEW_RTSCTS)
168 m_options
.c_cflag
&= ~CNEW_RTSCTS
;
171 if (m_iStopbits
== SERIAL_STOP_BITS_ONE
) m_options
.c_cflag
&= ~CSTOPB
;
172 else m_options
.c_cflag
|= CSTOPB
;
174 //I guessed a little here
175 m_options
.c_lflag
&= ~(ICANON
| ECHO
| ECHOE
| ISIG
| XCASE
| ECHOK
| ECHONL
| ECHOCTL
| ECHOPRT
| ECHOKE
| TOSTOP
);
177 if (m_iParity
== SERIAL_PARITY_NONE
)
178 m_options
.c_iflag
&= ~INPCK
;
180 m_options
.c_iflag
|= INPCK
| ISTRIP
;
182 m_options
.c_iflag
&= ~(IXON
| IXOFF
| IXANY
| BRKINT
| INLCR
| IGNCR
| ICRNL
| IUCLC
| IMAXBEL
);
183 m_options
.c_oflag
&= ~(OPOST
| ONLCR
| OCRNL
);
185 if (tcsetattr(m_socket
, TCSANOW
, &m_options
) != 0)
187 m_strError
= strerror(errno
);
188 RemoveLock(m_strName
.c_str());
192 SocketSetBlocking(m_socket
, true);
198 bool CSerialSocket::SetBaudRate(uint32_t baudrate
)
200 int rate
= IntToBaudrate(baudrate
);
204 sprintf(buff
, "%i is not a valid baudrate", baudrate
);
209 //get the current port attributes
210 if (tcgetattr(m_socket
, &m_options
) != 0)
212 m_strError
= strerror(errno
);
216 if (cfsetispeed(&m_options
, rate
) != 0)
218 m_strError
= strerror(errno
);
222 if (cfsetospeed(&m_options
, rate
) != 0)
224 m_strError
= strerror(errno
);