Skip to content

Commit

Permalink
Ups the verbosity (a bit)
Browse files Browse the repository at this point in the history
Adds some more info about what the application is doing at any given
point.
  • Loading branch information
mhemeryck committed Nov 21, 2018
1 parent 51f6542 commit 7254d7a
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 1 deletion.
2 changes: 2 additions & 0 deletions cmd/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -101,6 +101,7 @@ func main() {
if err != nil {
log.Fatal(err)
}
log.Printf("Created %d digital input reader instances from path %s\n", len(readers), sysfsRoot)
for k := range readers {
defer readers[k].Close()
}
Expand All @@ -113,6 +114,7 @@ func main() {

// Start polling
for k := range readers {
log.Printf("Initiate polling for %d readers\n", len(readers))
go readers[k].Poll(events, ticker)
}

Expand Down
9 changes: 8 additions & 1 deletion digital_input.go
Original file line number Diff line number Diff line change
Expand Up @@ -56,16 +56,22 @@ func (d *DigitalInputReader) Update(events chan *DigitalInputReader) (err error)

// Poll continuously updates the instance
func (d *DigitalInputReader) Poll(events chan *DigitalInputReader, ticker *time.Ticker) {
count := 0
for {
select {
case <-ticker.C:
err := d.Update(events)
if err != nil {
d.Err = err
events <- d
log.Println("Error polling the digital input")
log.Printf("Error polling digital input with topic %s\n", d.Topic)
return
}
if count%100 == 0 {
count = 0
log.Printf("Polling digital input %s ...\n", d.Topic)
}
count++
}
}
}
Expand Down Expand Up @@ -108,6 +114,7 @@ func FindDigitalInputReaders(root string) (readers []DigitalInputReader, err err
log.Println(err)
return
}
log.Printf("Found %d matching digital input paths\n", len(paths))
readers = make([]DigitalInputReader, len(paths))
for k, folder := range paths {
// Read topic as the trailing folder path
Expand Down

0 comments on commit 7254d7a

Please sign in to comment.