diff options
Diffstat (limited to 'pkg/ttymididrv')
-rw-r--r-- | pkg/ttymididrv/driver.go | 73 | ||||
-rw-r--r-- | pkg/ttymididrv/out.go | 79 |
2 files changed, 152 insertions, 0 deletions
diff --git a/pkg/ttymididrv/driver.go b/pkg/ttymididrv/driver.go new file mode 100644 index 0000000..cc7b1fd --- /dev/null +++ b/pkg/ttymididrv/driver.go @@ -0,0 +1,73 @@ +package ttymididrv + +import ( + "sync" + + "gitlab.com/gomidi/midi/mid" +) + +type driver struct { + mu sync.RWMutex + outs []mid.Out + opened []mid.Port + closed bool +} + +func New(name string, baud int) mid.Driver { + d := &driver{} + d.outs = []mid.Out{ + &out{ + name: name, + baud: baud, + number: 0, + driver: d, + }, + } + + return d +} + +func (d *driver) String() string { + return "ttymididrv" +} + +func (d *driver) Close() (err error) { + d.mu.RLock() + if d.closed { + d.mu.RUnlock() + return mid.ErrClosed + } + d.mu.RUnlock() + + d.mu.Lock() + d.closed = true + d.mu.Unlock() + + for _, p := range d.opened { + err = p.Close() + } + + return +} + +func (d *driver) Ins() ([]mid.In, error) { + d.mu.Lock() + defer d.mu.Unlock() + + if d.closed { + return nil, mid.ErrClosed + } + + return nil, nil +} + +func (d *driver) Outs() ([]mid.Out, error) { + d.mu.Lock() + defer d.mu.Unlock() + + if d.closed { + return nil, mid.ErrClosed + } + + return d.outs, nil +} diff --git a/pkg/ttymididrv/out.go b/pkg/ttymididrv/out.go new file mode 100644 index 0000000..3e16cff --- /dev/null +++ b/pkg/ttymididrv/out.go @@ -0,0 +1,79 @@ +package ttymididrv + +import ( + "sync" + + "github.com/tarm/serial" +) + +type out struct { + mu sync.RWMutex + driver *driver + port *serial.Port + name string + baud int + closed bool + number int +} + +func (o *out) Open() (err error) { + o.mu.RLock() + if o.closed || o.port != nil { + o.mu.RUnlock() + return nil + } + o.mu.RUnlock() + + o.mu.Lock() + defer o.mu.Unlock() + + c := &serial.Config{Name: o.name, Baud: o.baud} + o.port, err = serial.OpenPort(c) + if err != nil { + return err + } + + o.driver.mu.Lock() + o.driver.opened = append(o.driver.opened, o) + o.driver.mu.Unlock() + + return nil +} + +func (o *out) Close() error { + o.mu.RLock() + if o.closed || o.port == nil { + o.mu.RUnlock() + return nil + } + o.mu.RUnlock() + + o.mu.Lock() + o.closed = true + o.mu.Unlock() + + return o.port.Close() +} + +func (o *out) IsOpen() bool { + o.mu.RLock() + defer o.mu.RUnlock() + return !o.closed && o.port != nil +} + +func (o *out) Number() int { + return o.number +} + +func (o *out) String() string { + return o.name +} + +func (o *out) Underlying() interface{} { + return o.port +} + +func (o *out) Send(b []byte) error { + _, err := o.port.Write(b) + return err +} |