rkrtechnology/litestream
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix unit tests.

Browse Source
This commit is contained in:
Ben Johnson
2020-12-29 12:56:50 -07:00
parent 41448ceb89
commit 6f604e29b0
4 changed files with 16 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
replicator.go
View File

@@ -238,7 +238,7 @@ func (r *FileReplica) Stop() {
func (r *FileReplica) monitor(ctx context.Context) {
// Clear old temporary files that my have been left from a crash.
if err := removeTmpFiles(r.dst); err != nil {
log.Printf("%s(%s): cannot remove tmp files: %w", r.db.Path(), r.Name(), err)
log.Printf("%s(%s): cannot remove tmp files: %s", r.db.Path(), r.Name(), err)
}
// Continuously check for new data to replicate.
@@ -261,7 +261,7 @@ func (r *FileReplica) monitor(ctx context.Context) {
// Determine position, if necessary.
if pos.IsZero() {
if pos, err = r.pos(); err != nil {
log.Printf("%s(%s): cannot determine position: %w", r.db.Path(), r.Name(), err)
log.Printf("%s(%s): cannot determine position: %s", r.db.Path(), r.Name(), err)
continue
} else if pos.IsZero() {
log.Printf("%s(%s): no generation, waiting for data", r.db.Path(), r.Name())