Make exclusive access optional

serial.go

@@ -101,6 +101,7 @@ type Mode struct {
 	Parity            Parity           // Parity (see Parity type for more info)
 	StopBits          StopBits         // Stop bits (see StopBits type for more info)
 	InitialStatusBits *ModemOutputBits // Initial output modem bits status (if nil defaults to DTR=true and RTS=true)
+	AccessMode        AccessMode       // Access mode on unix systems (Default: Exclusive)
 }
 
 // Parity describes a serial port parity setting
@@ -131,6 +132,14 @@ const (
 	TwoStopBits
 )
 
+// AccessMode whether to access the port exclusively
+type AccessMode int
+
+const (
+	Exclusive = 0
+	Shared    = 1
+)
+
 // PortError is a platform independent error type for serial ports
 type PortError struct {
 	code     PortErrorCode

serial_linux_test.go

@@ -12,6 +12,7 @@ package serial
 import (
 	"context"
 	"os/exec"
+	"syscall"
 	"testing"
 	"time"
 
@@ -62,3 +63,46 @@ func TestDoubleCloseIsNoop(t *testing.T) {
 	require.NoError(t, port.Close())
 	require.NoError(t, port.Close())
 }
+
+func TestAccessModeDefault(t *testing.T) {
+	AccessModeExclusive(t, &Mode{})
+}
+
+func TestAccessModeExclusive(t *testing.T) {
+	mode := &Mode{
+		AccessMode: Exclusive,
+	}
+
+	AccessModeExclusive(t, mode)
+}
+
+func AccessModeExclusive(t *testing.T, mode *Mode) {
+	ctx, cancel := context.WithCancel(context.Background())
+	defer cancel()
+	cmd := startSocatAndWaitForPort(t, ctx)
+	go cmd.Wait()
+
+	port, err := Open("/tmp/faketty", mode)
+	require.NoError(t, err)
+	_, err2 := Open("/tmp/faketty", mode)
+	require.Error(t, err2, syscall.ENOENT)
+	require.NoError(t, port.Close())
+}
+
+func TestAccessModeShared(t *testing.T) {
+	ctx, cancel := context.WithCancel(context.Background())
+	defer cancel()
+	cmd := startSocatAndWaitForPort(t, ctx)
+	go cmd.Wait()
+
+	mode := &Mode{
+		AccessMode: Shared,
+	}
+
+	port, err := Open("/tmp/faketty", mode)
+	require.NoError(t, err)
+	port2, err2 := Open("/tmp/faketty", mode)
+	require.NoError(t, err2)
+	require.NoError(t, port.Close())
+	require.NoError(t, port2.Close())
+}

serial_unix.go

@@ -275,7 +275,9 @@ func nativeOpen(portName string, mode *Mode) (*unixPort, error) {
 
 	unix.SetNonblock(h, false)
 
-	port.acquireExclusiveAccess()
+	if mode.AccessMode == Exclusive {
+		port.acquireExclusiveAccess()
+	}
 
 	// This pipe is used as a signal to cancel blocking Read
 	pipe := &unixutils.Pipe{}