summaryrefslogtreecommitdiff
path: root/pkg
diff options
context:
space:
mode:
Diffstat (limited to 'pkg')
-rw-r--r--pkg/ttymididrv/driver.go73
-rw-r--r--pkg/ttymididrv/out.go79
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
+}