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 #include //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" // OS dependent values const devFolder = "" const regexFilter = "(ttyS|ttyUSB|ttyACM|ttyAMA|rfcomm|ttyO)[0-9]{1,3}" // opaque type that implements SerialPort interface for linux type windowsSerialPort struct { Handle int } 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 nil } func (port *windowsSerialPort) Read(p []byte) (n int, err error) { return syscall.Read(port.Handle, p) } func (port *windowsSerialPort) Write(p []byte) (n int, err error) { return syscall.Write(port.Handle, p) } func OpenPort(portName string, useTIOCEXCL bool) (SerialPort, error) { portName = "\\\\.\\" + portName handle, err := syscall.CreateFile(portName, syscall.GENERIC_READ|syscall.GENERIC_WRITE, 0, nil, syscall.OPEN_EXISTING, syscall.FILE_FLAG_OVERLAPPED, 0) //handle := C.CreateFile(C.CString(portName), C.GENERIC_READ | C.GENERIC_WRITE, 0, 0, C.OPEN_EXISTING, C.FILE_FLAG_OVERLAPPED, 0) /* JNIEXPORT jlong JNICALL Java_jssc_SerialNativeInterface_openPort(JNIEnv *env, jobject object, jstring portName, jboolean useTIOCEXCL){ char prefix[] = "\\\\.\\"; const char* port = env->GetStringUTFChars(portName, JNI_FALSE); //since 2.1.0 -> string concat fix char portFullName[strlen(prefix) + strlen(port) + 1]; strcpy(portFullName, prefix); strcat(portFullName, port); //<- since 2.1.0 HANDLE hComm = CreateFile(portFullName, GENERIC_READ | GENERIC_WRITE, 0, 0, OPEN_EXISTING, FILE_FLAG_OVERLAPPED, 0); env->ReleaseStringUTFChars(portName, port); */ /* if handle != syscall.INVALID_HANDLE_VALUE { var dcb C.DCB if C.GetCommState(handle, &dcb) != 0 { C.CloseHandle(handle) return nil, } } */ /* //since 2.3.0 -> if(hComm != INVALID_HANDLE_VALUE){ DCB *dcb = new DCB(); if(!GetCommState(hComm, dcb)){ CloseHandle(hComm);//since 2.7.0 hComm = (HANDLE)jssc_SerialNativeInterface_ERR_INCORRECT_SERIAL_PORT;//(-4)Incorrect serial port } delete dcb; } else { DWORD errorValue = GetLastError(); if(errorValue == ERROR_ACCESS_DENIED){ hComm = (HANDLE)jssc_SerialNativeInterface_ERR_PORT_BUSY;//(-1)Port busy } else if(errorValue == ERROR_FILE_NOT_FOUND){ hComm = (HANDLE)jssc_SerialNativeInterface_ERR_PORT_NOT_FOUND;//(-2)Port not found } } //<- since 2.3.0 return (jlong)hComm;//since 2.4.0 changed to jlong }; */ } // vi:ts=2