soma_handler_tree_keeper__util.go

package main

import (
	"encoding/json"
	"log"
)

func (tk *treeKeeper) drain(s string) (j int) {
	switch s {
	case "action":
		j = len(tk.actionChan)
		for i := j; i > 0; i-- {
			if SomaCfg.PrintChannels {
				a := <-tk.actionChan
				jBxX, _ := json.Marshal(a)
				log.Printf("TK[%s], drained: %s", tk.repoName, string(jBxX))
				continue
			}
			<-tk.actionChan
		}
	case "error":
		j = len(tk.errChan)
		for i := j; i > 0; i-- {
			<-tk.errChan
		}
	default:
		panic("Requested drain for unknown")
	}
	return j
}

// vim: ts=4 sw=4 sts=4 noet fenc=utf-8 ffs=unix