// Does the system allows us to place a lock on this file descriptor
if (fcntl(sp->fd, F_SETLK, &fl) == -1) {
// A conflicting lock is held by another process
+ free(sp);
return CLAIMED_SERIAL_PORT;
}
fl.l_start = 0;
fl.l_len = 0;
fl.l_pid = getpid();
- fcntl(spu->fd, F_SETLK, &fl);
+
+ // Does the system allows us to place a lock on this file descriptor
+ int err = fcntl(spu->fd, F_SETLK, &fl);
+ if ( err == -1) {
+ //perror("fcntl");
+ }
close(spu->fd);
free(sp);
}
if (res < 0) {
return false;
}
-
+
// Read time-out
if (res == 0) {
if (*pszRxLen == 0) {
return true;
}
}
-
+
// Retrieve the count of the incoming bytes
res = ioctl(((serial_port_unix*)sp)->fd, FIONREAD, &byteCount);
if (res < 0) return false;
-
+
// There is something available, read the data
res = read(((serial_port_unix*)sp)->fd,pbtRx+(*pszRxLen),byteCount);
-
+
// Stop if the OS has some troubles reading the data
if (res <= 0) return false;
-
+
*pszRxLen += res;
+
+ if(res==byteCount)
+ return true;
} while (byteCount);
-
+
return true;
}
// Prepare the device control
memset(&sp->dcb, 0, sizeof(DCB));
sp->dcb.DCBlength = sizeof(DCB);
- if(!BuildCommDCBA("baud=9600 data=8 parity=N stop=1",&sp->dcb)) {
- uart_close(sp);
- return INVALID_SERIAL_PORT;
- }
+ if(!BuildCommDCBA("baud=115200 parity=N data=8 stop=1",&sp->dcb)) {
+ uart_close(sp);
+ return INVALID_SERIAL_PORT;
+ }
// Update the active serial port
if(!SetCommState(sp->hPort,&sp->dcb)) {
return INVALID_SERIAL_PORT;
}
- sp->ct.ReadIntervalTimeout = 0;
- sp->ct.ReadTotalTimeoutMultiplier = 0;
+ sp->ct.ReadIntervalTimeout = 1;
+ sp->ct.ReadTotalTimeoutMultiplier = 1;
sp->ct.ReadTotalTimeoutConstant = 30;
- sp->ct.WriteTotalTimeoutMultiplier = 0;
+ sp->ct.WriteTotalTimeoutMultiplier = 1;
sp->ct.WriteTotalTimeoutConstant = 30;
if(!SetCommTimeouts(sp->hPort,&sp->ct)) {