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 "../sockets/serialport.h"
37 #include "../util/baudrate.h"
38 #include "../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;
64 void CSerialSocket::Close(void)
68 SocketClose(m_socket
);
69 RemoveLock(m_strName
.c_str());
73 void CSerialSocket::Shutdown(void)
77 SocketClose(m_socket
);
78 RemoveLock(m_strName
.c_str());
82 ssize_t
CSerialSocket::Write(void* data
, size_t len
)
84 return IsOpen() ? SocketWrite(m_socket
, &m_iError
, data
, len
) : -1;
87 ssize_t
CSerialSocket::Read(void* data
, size_t len
, uint64_t iTimeoutMs
/* = 0 */)
89 return IsOpen() ? SocketRead(m_socket
, &m_iError
, data
, len
, iTimeoutMs
) : -1;
92 //setting all this stuff up is a pain in the ass
93 bool CSerialSocket::Open(uint64_t iTimeoutMs
/* = 0 */)
102 if (m_iDatabits
!= SERIAL_DATA_BITS_FIVE
&& m_iDatabits
!= SERIAL_DATA_BITS_SIX
&&
103 m_iDatabits
!= SERIAL_DATA_BITS_SEVEN
&& m_iDatabits
!= SERIAL_DATA_BITS_EIGHT
)
105 m_strError
= "Databits has to be between 5 and 8";
110 if (m_iStopbits
!= SERIAL_STOP_BITS_ONE
&& m_iStopbits
!= SERIAL_STOP_BITS_TWO
)
112 m_strError
= "Stopbits has to be 1 or 2";
117 if (m_iParity
!= SERIAL_PARITY_NONE
&& m_iParity
!= SERIAL_PARITY_EVEN
&& m_iParity
!= SERIAL_PARITY_ODD
)
119 m_strError
= "Parity has to be none, even or odd";
124 #if !defined(__APPLE__) && !defined(__FreeBSD__)
125 if (dev_lock(m_strName
.c_str()) != 0)
127 m_strError
= "Couldn't lock the serial port";
133 m_socket
= open(m_strName
.c_str(), O_RDWR
| O_NOCTTY
| O_NDELAY
);
135 if (m_socket
== INVALID_SERIAL_SOCKET_VALUE
)
137 m_strError
= strerror(errno
);
138 RemoveLock(m_strName
.c_str());
142 SocketSetBlocking(m_socket
, false);
144 if (!SetBaudRate(m_iBaudrate
))
147 m_options
.c_cflag
|= (CLOCAL
| CREAD
);
148 m_options
.c_cflag
&= ~HUPCL
;
150 m_options
.c_cflag
&= ~CSIZE
;
151 if (m_iDatabits
== SERIAL_DATA_BITS_FIVE
) m_options
.c_cflag
|= CS5
;
152 if (m_iDatabits
== SERIAL_DATA_BITS_SIX
) m_options
.c_cflag
|= CS6
;
153 if (m_iDatabits
== SERIAL_DATA_BITS_SEVEN
) m_options
.c_cflag
|= CS7
;
154 if (m_iDatabits
== SERIAL_DATA_BITS_EIGHT
) m_options
.c_cflag
|= CS8
;
156 m_options
.c_cflag
&= ~PARENB
;
157 if (m_iParity
== SERIAL_PARITY_EVEN
|| m_iParity
== SERIAL_PARITY_ODD
)
158 m_options
.c_cflag
|= PARENB
;
159 if (m_iParity
== SERIAL_PARITY_ODD
)
160 m_options
.c_cflag
|= PARODD
;
163 m_options
.c_cflag
&= ~CRTSCTS
;
164 #elif defined(CNEW_RTSCTS)
165 m_options
.c_cflag
&= ~CNEW_RTSCTS
;
168 if (m_iStopbits
== SERIAL_STOP_BITS_ONE
) m_options
.c_cflag
&= ~CSTOPB
;
169 else m_options
.c_cflag
|= CSTOPB
;
171 //I guessed a little here
172 m_options
.c_lflag
&= ~(ICANON
| ECHO
| ECHOE
| ISIG
| XCASE
| ECHOK
| ECHONL
| ECHOCTL
| ECHOPRT
| ECHOKE
| TOSTOP
);
174 if (m_iParity
== SERIAL_PARITY_NONE
)
175 m_options
.c_iflag
&= ~INPCK
;
177 m_options
.c_iflag
|= INPCK
| ISTRIP
;
179 m_options
.c_iflag
&= ~(IXON
| IXOFF
| IXANY
| BRKINT
| INLCR
| IGNCR
| ICRNL
| IUCLC
| IMAXBEL
);
180 m_options
.c_oflag
&= ~(OPOST
| ONLCR
| OCRNL
);
182 if (tcsetattr(m_socket
, TCSANOW
, &m_options
) != 0)
184 m_strError
= strerror(errno
);
185 RemoveLock(m_strName
.c_str());
189 SocketSetBlocking(m_socket
, true);
195 bool CSerialSocket::SetBaudRate(uint32_t baudrate
)
197 int rate
= IntToBaudrate(baudrate
);
201 sprintf(buff
, "%i is not a valid baudrate", baudrate
);
206 //get the current port attributes
207 if (tcgetattr(m_socket
, &m_options
) != 0)
209 m_strError
= strerror(errno
);
213 if (cfsetispeed(&m_options
, rate
) != 0)
215 m_strError
= strerror(errno
);
219 if (cfsetospeed(&m_options
, rate
) != 0)
221 m_strError
= strerror(errno
);