1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
|
/*
* Psychtoolbox3/PsychSourceGL/Source/Common/IOPort/PsychSerialUnixGlue.h
*
* PROJECTS:
*
* IOPort for now.
*
* AUTHORS:
*
* mario.kleiner.de@gmail.com mk
*
* PLATFORMS:
*
* All Unix (aka Posix) systems: OS/X and Linux.
*
* HISTORY:
*
* 04/10/2008 mk Initial implementation.
* 04/03/2011 mk Audited (but not tested) to be 64-bit safe. Doesn't take advantage of > 2 GB
* buffers yet. This will require some minor changes.
*
* DESCRIPTION:
*
* This is the operating system dependent "glue code" layer for access to serial ports for the
* Unices, ie., for GNU/Linux and Apple MacOS/X. It is used by the higher-level serial port
* routines to abstract out operating system dependencies.
*
* The code is shared and #ifdef'ed if needed, because most of it is identical for Linux and OS/X.
*/
#ifndef PSYCH_IS_INCLUDED_SerialUnixGlue
#define PSYCH_IS_INCLUDED_SerialUnixGlue
#include <unistd.h>
#include <fcntl.h>
#include <sys/ioctl.h>
#include <errno.h>
#include <paths.h>
#include <termios.h>
#include <sysexits.h>
#include <sys/param.h>
#include <sys/select.h>
#include <sys/time.h>
#include <time.h>
#include <pthread.h>
// OS/X specific includes and structures:
#if PSYCH_SYSTEM == PSYCH_OSX
#include <AvailabilityMacros.h>
#include <CoreFoundation/CoreFoundation.h>
#include <IOKit/IOKitLib.h>
#include <IOKit/serial/IOSerialKeys.h>
#include <IOKit/serial/ioss.h>
#include <IOKit/IOBSD.h>
// End OS/X specific includes...
#endif
// Linux specific includes and structures:
#if PSYCH_SYSTEM == PSYCH_LINUX
// None yet.
#endif
typedef struct PsychSerialDeviceRecord {
char portSpec[1000]; // Name string of the device file.
int fileDescriptor; // Device handle.
struct termios OriginalTTYAttrs; // Stores original settings of device to allow restore on close.
unsigned char* readBuffer; // Pointer to memory buffer for reading data.
unsigned int readBufferSize; // Size of readbuffer.
double readTimeout; // Backup copy of current read timeout value.
double pollLatency; // Seconds to sleep between spin-wait polls in 'Read'.
pthread_t readerThread; // Thread handle for background reading thread.
pthread_mutex_t readerLock; // Primary lock.
int readerThreadWritePos; // Position of next data write for readerThread.
int clientThreadReadPos; // Position of next data read from main thread.
int readGranularity; // Amount of bytes to request per blocking read call in readerThread.
int isBlockingBackgroundRead; // 1 = Blocking background read, 0 = Polling operation.
double* timeStamps; // Buffer for async-read timestamps. Size = readBufferSize / readGranularity Bytes.
int bounceBufferSize; // Size of bounceBuffer in Bytes.
unsigned char* bounceBuffer; // Bouncebuffer.
unsigned int readFilterFlags; // Special flags to enable certain postprocessing operations on read data.
int asyncReadBytesCount; // Counter of total bytes read via async thread so far. [Updates not mutex protected!]
unsigned char lineTerminator; // Line terminator byte, if any.
unsigned char cookedMode; // Cooked input processing mode active? Set to 1 if so.
int dontFlushOnWrite; // If set to 1, don't tcdrain() after blocking writes, otherwise do.
double triggerWhen; // Target time for trigger byte emission.
} PsychSerialDeviceRecord;
#endif
|
