mirror
/
av
mirror of https://bitbucket.org/ausocean/av.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

setup ticker

This commit is contained in:
Russell Stanley 2022-01-06 16:54:30 +10:30 committed by Saxon Nelson-Milton
parent bdb44214a1
commit 0c6d9d0132
1 changed files with 19 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
cmd/rv/main.go
View File

@ -11,6 +11,7 @@ AUTHORS
Jack Richardson <jack@ausocean.org> Jack Richardson <jack@ausocean.org>
Trek Hopton <trek@ausocean.org> Trek Hopton <trek@ausocean.org>
Scott Barnard <scott@ausocean.org> Scott Barnard <scott@ausocean.org>
Russell Stanley <russell@ausocean.org>
LICENSE LICENSE
Copyright (C) 2020 the Australian Ocean Lab (AusOcean) Copyright (C) 2020 the Australian Ocean Lab (AusOcean)
@ -103,14 +104,15 @@ const (
profilePath = "rv.prof" profilePath = "rv.prof"
pkg = "rv: " pkg = "rv: "
runPreDelay = 20 * time.Second runPreDelay = 20 * time.Second
turbidity
) )
// Software define pin values. // Software define pin values.
// See https://netreceiver.appspot.com/help, External Pin Assignments. // See https://netreceiver.appspot.com/help, External Pin Assignments.
const ( const (
bitratePin = "X36" bitratePin = "X36"
saturationPin = "X38" saturationPin = "X38"
contrastPin = "X39" contrastPin = "X39"
) )
// This is set to true if the 'profile' build tag is provided on build. // This is set to true if the 'profile' build tag is provided on build.
@ -122,6 +124,18 @@ type turbidityProbe struct {
// TODO(Russell): complete this implementation of Write. // TODO(Russell): complete this implementation of Write.
func (tp *turbidityProbe) Write(p []byte) (int, error) { func (tp *turbidityProbe) Write(p []byte) (int, error) {
ticker := time.NewTicker(500 * time.Millisecond)
go func() {
for {
select {
case <-ticker.C:
// Implementation here
}
}
}()
return len(p), nil return len(p), nil
} }
@ -156,7 +170,7 @@ func main() {
var ( var (
rv *revid.Revid rv *revid.Revid
p *turbidityProbe p *turbidityProbe
) )
log.Log(logger.Debug, "initialising netsender client") log.Log(logger.Debug, "initialising netsender client")
@ -171,9 +185,9 @@ func main() {
log.Log(logger.Fatal, pkg+"could not initialise revid", "error", err.Error()) log.Log(logger.Fatal, pkg+"could not initialise revid", "error", err.Error())
} }
err = rv.SetProbe(p) err = rv.SetProbe(p)
if err != nil { if err != nil {
log.Log(logger.Error, pkg+"could not set probe","error",err.Error()) log.Log(logger.Error, pkg+"could not set probe", "error", err.Error())
} }
// NB: Problems were encountered with communicating with RTSP inputs. When trying to // NB: Problems were encountered with communicating with RTSP inputs. When trying to