2016-12-20 20:25:22 +08:00
|
|
|
package aio
|
|
|
|
|
2017-04-02 23:55:49 +08:00
|
|
|
import "sync"
|
|
|
|
|
2016-12-20 20:25:22 +08:00
|
|
|
type aioTestBareAdaptor struct{}
|
|
|
|
|
|
|
|
func (t *aioTestBareAdaptor) Connect() (err error) { return }
|
|
|
|
func (t *aioTestBareAdaptor) Finalize() (err error) { return }
|
|
|
|
func (t *aioTestBareAdaptor) Name() string { return "" }
|
|
|
|
func (t *aioTestBareAdaptor) SetName(n string) {}
|
|
|
|
|
|
|
|
type aioTestAdaptor struct {
|
2017-04-02 23:55:49 +08:00
|
|
|
name string
|
|
|
|
port string
|
|
|
|
mtx sync.Mutex
|
|
|
|
testAdaptorAnalogRead func() (val int, err error)
|
2016-12-20 20:25:22 +08:00
|
|
|
}
|
|
|
|
|
2017-04-02 23:55:49 +08:00
|
|
|
func (t *aioTestAdaptor) TestAdaptorAnalogRead(f func() (val int, err error)) {
|
|
|
|
t.mtx.Lock()
|
|
|
|
defer t.mtx.Unlock()
|
|
|
|
t.testAdaptorAnalogRead = f
|
2016-12-20 20:25:22 +08:00
|
|
|
}
|
|
|
|
|
|
|
|
func (t *aioTestAdaptor) AnalogRead(string) (val int, err error) {
|
2017-04-02 23:55:49 +08:00
|
|
|
t.mtx.Lock()
|
|
|
|
defer t.mtx.Unlock()
|
|
|
|
return t.testAdaptorAnalogRead()
|
2016-12-20 20:25:22 +08:00
|
|
|
}
|
|
|
|
func (t *aioTestAdaptor) Connect() (err error) { return }
|
|
|
|
func (t *aioTestAdaptor) Finalize() (err error) { return }
|
|
|
|
func (t *aioTestAdaptor) Name() string { return t.name }
|
|
|
|
func (t *aioTestAdaptor) SetName(n string) { t.name = n }
|
|
|
|
func (t *aioTestAdaptor) Port() string { return t.port }
|
|
|
|
|
|
|
|
func newAioTestAdaptor() *aioTestAdaptor {
|
|
|
|
return &aioTestAdaptor{
|
|
|
|
port: "/dev/null",
|
2017-04-02 23:55:49 +08:00
|
|
|
testAdaptorAnalogRead: func() (val int, err error) {
|
|
|
|
return 99, nil
|
|
|
|
},
|
2016-12-20 20:25:22 +08:00
|
|
|
}
|
|
|
|
}
|