readDataFrom string
)
+type DataFetcher func(arvLogger *logger.Logger,
+ readCollections *collection.ReadCollections,
+ keepServerInfo *keep.ReadServers)
+
func init() {
flag.StringVar(&writeDataTo,
"write-data-to",
}
}
+func ShouldReadData() bool {
+ return readDataFrom != ""
+}
+
// Reads data that we've written to a file.
//
// This is useful for development, so that we don't need to read all
//
// This should not be used outside of development, since you'll be
// working with stale data.
-func MaybeReadData(arvLogger *logger.Logger,
+func ReadData(arvLogger *logger.Logger,
readCollections *collection.ReadCollections,
- keepServerInfo *keep.ReadServers) bool {
+ keepServerInfo *keep.ReadServers) {
if readDataFrom == "" {
- return false
+ loggerutil.FatalWithMessage(arvLogger,
+ "ReadData() called with empty filename.")
} else {
summaryFile, err := os.Open(readDataFrom)
if err != nil {
// re-summarize data, so that we can update our summarizing
// functions without needing to do all our network i/o
- data.ReadCollections.Summarize()
- keep.ComputeBlockReplicationCounts(&data.KeepServerInfo)
+ data.ReadCollections.Summarize(arvLogger)
+ data.KeepServerInfo.Summarize(arvLogger)
*readCollections = data.ReadCollections
*keepServerInfo = data.KeepServerInfo
log.Printf("Read summary data from: %s", readDataFrom)
- return true
}
}