Reorganized repository
This commit is contained in:
Cristian Maglie
284
serial_windows.go
Normal file
284
serial_windows.go
Normal file
@@ -0,0 +1,284 @@
|
||||
package serial
|
||||
|
||||
/*
|
||||
|
||||
// MSDN article on Serial Communications:
|
||||
// http://msdn.microsoft.com/en-us/library/ff802693.aspx
|
||||
|
||||
// Arduino Playground article on serial communication with Windows API:
|
||||
// http://playground.arduino.cc/Interfacing/CPPWindows
|
||||
|
||||
#include <stdlib.h>
|
||||
#include <windows.h>
|
||||
|
||||
//HANDLE invalid = INVALID_HANDLE_VALUE;
|
||||
|
||||
HKEY INVALID_PORT_LIST = 0;
|
||||
|
||||
HKEY openPortList() {
|
||||
HKEY handle;
|
||||
LPCSTR lpSubKey = "HARDWARE\\DEVICEMAP\\SERIALCOMM\\";
|
||||
DWORD res = RegOpenKeyExA(HKEY_LOCAL_MACHINE, lpSubKey, 0, KEY_READ, &handle);
|
||||
if (res != ERROR_SUCCESS)
|
||||
return INVALID_PORT_LIST;
|
||||
else
|
||||
return handle;
|
||||
}
|
||||
|
||||
int countPortList(HKEY handle) {
|
||||
int count = 0;
|
||||
for (;;) {
|
||||
char name[256];
|
||||
DWORD nameSize = 256;
|
||||
DWORD res = RegEnumValueA(handle, count, name, &nameSize, NULL, NULL, NULL, NULL);
|
||||
if (res != ERROR_SUCCESS)
|
||||
return count;
|
||||
count++;
|
||||
}
|
||||
}
|
||||
|
||||
char *getInPortList(HKEY handle, int i) {
|
||||
byte *data = (byte *) malloc(256);
|
||||
DWORD dataSize = 256;
|
||||
char name[256];
|
||||
DWORD nameSize = 256;
|
||||
DWORD res = RegEnumValueA(handle, i, name, &nameSize, NULL, NULL, data, &dataSize);
|
||||
if (res != ERROR_SUCCESS) {
|
||||
free(data);
|
||||
return NULL;
|
||||
}
|
||||
return data;
|
||||
}
|
||||
|
||||
void closePortList(HKEY handle) {
|
||||
CloseHandle(handle);
|
||||
}
|
||||
|
||||
*/
|
||||
import "C"
|
||||
import "syscall"
|
||||
import "unsafe"
|
||||
|
||||
// opaque type that implements SerialPort interface for Windows
|
||||
type windowsSerialPort struct {
|
||||
Handle syscall.Handle
|
||||
}
|
||||
|
||||
func GetPortsList() ([]string, error) {
|
||||
portList := C.openPortList()
|
||||
if portList == C.INVALID_PORT_LIST {
|
||||
return nil, &SerialPortError{code: ERROR_ENUMERATING_PORTS}
|
||||
}
|
||||
n := C.countPortList(portList)
|
||||
|
||||
list := make([]string, n)
|
||||
for i := range list {
|
||||
portName := C.getInPortList(portList, C.int(i))
|
||||
list[i] = C.GoString(portName)
|
||||
C.free(unsafe.Pointer(portName))
|
||||
}
|
||||
|
||||
C.closePortList(portList)
|
||||
return list, nil
|
||||
}
|
||||
|
||||
func (port windowsSerialPort) Close() error {
|
||||
return syscall.CloseHandle(port.Handle)
|
||||
}
|
||||
|
||||
func (port windowsSerialPort) Read(p []byte) (int, error) {
|
||||
var readed uint32
|
||||
params := &DCB{}
|
||||
for {
|
||||
if err := syscall.ReadFile(port.Handle, p, &readed, nil); err != nil {
|
||||
return int(readed), err
|
||||
}
|
||||
if readed > 0 {
|
||||
return int(readed), nil
|
||||
}
|
||||
|
||||
// At the moment it seems that the only reliable way to check if
|
||||
// a serial port is alive in Windows is to check if the SetCommState
|
||||
// function fails.
|
||||
|
||||
GetCommState(port.Handle, params)
|
||||
if err := SetCommState(port.Handle, params); err != nil {
|
||||
port.Close()
|
||||
return 0, err
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
func (port windowsSerialPort) Write(p []byte) (int, error) {
|
||||
var writed uint32
|
||||
err := syscall.WriteFile(port.Handle, p, &writed, nil)
|
||||
return int(writed), err
|
||||
}
|
||||
|
||||
const (
|
||||
DCB_BINARY = 0x00000001
|
||||
DCB_PARITY = 0x00000002
|
||||
DCB_OUT_X_CTS_FLOW = 0x00000004
|
||||
DCB_OUT_X_DSR_FLOW = 0x00000008
|
||||
DCB_DTR_CONTROL_DISABLE_MASK = ^0x00000030
|
||||
DCB_DTR_CONTROL_ENABLE = 0x00000010
|
||||
DCB_DTR_CONTROL_HANDSHAKE = 0x00000020
|
||||
DCB_DSR_SENSITIVITY = 0x00000040
|
||||
DCB_TX_CONTINUE_ON_XOFF = 0x00000080
|
||||
DCB_OUT_X = 0x00000100
|
||||
DCB_IN_X = 0x00000200
|
||||
DCB_ERROR_CHAR = 0x00000400
|
||||
DCB_NULL = 0x00000800
|
||||
DCB_RTS_CONTROL_DISABLE_MASK = ^0x00003000
|
||||
DCB_RTS_CONTROL_ENABLE = 0x00001000
|
||||
DCB_RTS_CONTROL_HANDSHAKE = 0x00002000
|
||||
DCB_RTS_CONTROL_TOGGLE = 0x00003000
|
||||
DCB_ABORT_ON_ERROR = 0x00004000
|
||||
)
|
||||
|
||||
type DCB struct {
|
||||
DCBlength uint32
|
||||
BaudRate uint32
|
||||
|
||||
// Flags field is a bitfield
|
||||
// fBinary :1
|
||||
// fParity :1
|
||||
// fOutxCtsFlow :1
|
||||
// fOutxDsrFlow :1
|
||||
// fDtrControl :2
|
||||
// fDsrSensitivity :1
|
||||
// fTXContinueOnXoff :1
|
||||
// fOutX :1
|
||||
// fInX :1
|
||||
// fErrorChar :1
|
||||
// fNull :1
|
||||
// fRtsControl :2
|
||||
// fAbortOnError :1
|
||||
// fDummy2 :17
|
||||
Flags uint32
|
||||
|
||||
wReserved uint16
|
||||
XonLim uint16
|
||||
XoffLim uint16
|
||||
ByteSize byte
|
||||
Parity byte
|
||||
StopBits byte
|
||||
XonChar byte
|
||||
XoffChar byte
|
||||
ErrorChar byte
|
||||
EofChar byte
|
||||
EvtChar byte
|
||||
wReserved1 uint16
|
||||
}
|
||||
|
||||
type COMMTIMEOUTS struct {
|
||||
ReadIntervalTimeout uint32
|
||||
ReadTotalTimeoutMultiplier uint32
|
||||
ReadTotalTimeoutConstant uint32
|
||||
WriteTotalTimeoutMultiplier uint32
|
||||
WriteTotalTimeoutConstant uint32
|
||||
}
|
||||
|
||||
//sys GetCommState(handle syscall.Handle, dcb *DCB) (err error)
|
||||
//sys SetCommState(handle syscall.Handle, dcb *DCB) (err error)
|
||||
//sys SetCommTimeouts(handle syscall.Handle, timeouts *COMMTIMEOUTS) (err error)
|
||||
|
||||
const (
|
||||
NOPARITY = 0
|
||||
ODDPARITY = 1
|
||||
EVENPARITY = 2
|
||||
MARKPARITY = 3
|
||||
SPACEPARITY = 4
|
||||
)
|
||||
|
||||
const (
|
||||
ONESTOPBIT = 0
|
||||
ONE5STOPBITS = 1
|
||||
TWOSTOPBITS = 2
|
||||
)
|
||||
|
||||
func (port windowsSerialPort) SetSpeed(baudrate int) error {
|
||||
params := DCB{}
|
||||
if err := GetCommState(port.Handle, ¶ms); err != nil {
|
||||
port.Close()
|
||||
return &SerialPortError{code: ERROR_INVALID_SERIAL_PORT}
|
||||
}
|
||||
params.BaudRate = uint32(baudrate)
|
||||
params.ByteSize = 8
|
||||
params.StopBits = ONESTOPBIT
|
||||
params.Parity = NOPARITY
|
||||
if err := SetCommState(port.Handle, ¶ms); err != nil {
|
||||
port.Close()
|
||||
return &SerialPortError{code: ERROR_INVALID_SERIAL_PORT}
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func OpenPort(portName string, useTIOCEXCL bool) (SerialPort, error) {
|
||||
portName = "\\\\.\\" + portName
|
||||
path, err := syscall.UTF16PtrFromString(portName)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
handle, err := syscall.CreateFile(
|
||||
path,
|
||||
syscall.GENERIC_READ|syscall.GENERIC_WRITE,
|
||||
0, nil,
|
||||
syscall.OPEN_EXISTING,
|
||||
0, //syscall.FILE_FLAG_OVERLAPPED,
|
||||
0)
|
||||
if err != nil {
|
||||
switch err {
|
||||
case syscall.ERROR_ACCESS_DENIED:
|
||||
return nil, &SerialPortError{code: ERROR_PORT_BUSY}
|
||||
case syscall.ERROR_FILE_NOT_FOUND:
|
||||
return nil, &SerialPortError{code: ERROR_PORT_NOT_FOUND}
|
||||
}
|
||||
return nil, err
|
||||
}
|
||||
// Create the serial port
|
||||
port := &windowsSerialPort{
|
||||
Handle: handle,
|
||||
}
|
||||
|
||||
params := &DCB{}
|
||||
err = GetCommState(port.Handle, params)
|
||||
if err != nil {
|
||||
port.Close()
|
||||
return nil, &SerialPortError{code: ERROR_INVALID_SERIAL_PORT}
|
||||
}
|
||||
params.Flags |= DCB_RTS_CONTROL_ENABLE | DCB_DTR_CONTROL_ENABLE
|
||||
params.Flags &= ^uint32(DCB_OUT_X_CTS_FLOW)
|
||||
params.Flags &= ^uint32(DCB_OUT_X_DSR_FLOW)
|
||||
params.Flags &= ^uint32(DCB_DSR_SENSITIVITY)
|
||||
params.Flags |= DCB_TX_CONTINUE_ON_XOFF
|
||||
params.Flags &= ^uint32(DCB_IN_X | DCB_OUT_X)
|
||||
params.Flags &= ^uint32(DCB_ERROR_CHAR)
|
||||
params.Flags &= ^uint32(DCB_NULL)
|
||||
params.Flags &= ^uint32(DCB_ABORT_ON_ERROR)
|
||||
params.XonLim = 2048
|
||||
params.XoffLim = 512
|
||||
params.XonChar = 17 // DC1
|
||||
params.XoffChar = 19 // C3
|
||||
err = SetCommState(port.Handle, params)
|
||||
if err != nil {
|
||||
port.Close()
|
||||
return nil, &SerialPortError{code: ERROR_INVALID_SERIAL_PORT}
|
||||
}
|
||||
|
||||
timeouts := &COMMTIMEOUTS{
|
||||
ReadIntervalTimeout: 0xFFFFFFFF,
|
||||
ReadTotalTimeoutMultiplier: 0xFFFFFFFF,
|
||||
ReadTotalTimeoutConstant: 1000, // 1 sec
|
||||
WriteTotalTimeoutConstant: 0,
|
||||
WriteTotalTimeoutMultiplier: 0,
|
||||
}
|
||||
if err := SetCommTimeouts(port.Handle, timeouts); err != nil {
|
||||
port.Close()
|
||||
return nil, &SerialPortError{code: ERROR_INVALID_SERIAL_PORT}
|
||||
}
|
||||
|
||||
return port, nil
|
||||
}
|
||||
|
||||
// vi:ts=2
|
||||
Reference in New Issue
Block a user