syncbase: more go vet fixes (that do not appear on darwin)
Change-Id: If3cd6efe86b5c924d3a02864aed37ac87b3c4236
diff --git a/x/ref/services/syncbase/server/watchable/transaction.go b/x/ref/services/syncbase/server/watchable/transaction.go
index f557ca7..304c4d6 100644
--- a/x/ref/services/syncbase/server/watchable/transaction.go
+++ b/x/ref/services/syncbase/server/watchable/transaction.go
@@ -75,7 +75,7 @@
tx.mu.Lock()
defer tx.mu.Unlock()
if tx.err != nil {
- return &store.InvalidStream{tx.err}
+ return &store.InvalidStream{Error: tx.err}
}
var it store.Stream
if !tx.st.managesRange(start, limit) {
diff --git a/x/ref/services/syncbase/store/leveldb/db.go b/x/ref/services/syncbase/store/leveldb/db.go
index 4f1ba6c..028b1ad 100644
--- a/x/ref/services/syncbase/store/leveldb/db.go
+++ b/x/ref/services/syncbase/store/leveldb/db.go
@@ -125,7 +125,7 @@
d.mu.RLock()
defer d.mu.RUnlock()
if d.err != nil {
- return &store.InvalidStream{d.err}
+ return &store.InvalidStream{Error: d.err}
}
return newStream(d, d.node, start, limit, d.readOptions)
}
@@ -156,7 +156,7 @@
d.mu.RLock()
defer d.mu.RUnlock()
if d.err != nil {
- return &store.InvalidTransaction{d.err}
+ return &store.InvalidTransaction{Error: d.err}
}
return newTransaction(d, d.node)
}
diff --git a/x/ref/services/syncbase/store/leveldb/snapshot.go b/x/ref/services/syncbase/store/leveldb/snapshot.go
index a07be02..f845fa6 100644
--- a/x/ref/services/syncbase/store/leveldb/snapshot.go
+++ b/x/ref/services/syncbase/store/leveldb/snapshot.go
@@ -76,7 +76,7 @@
s.mu.RLock()
defer s.mu.RUnlock()
if s.err != nil {
- return &store.InvalidStream{s.err}
+ return &store.InvalidStream{Error: s.err}
}
return newStream(s.d, s.node, start, limit, s.cOpts)
}
diff --git a/x/ref/services/syncbase/store/leveldb/transaction.go b/x/ref/services/syncbase/store/leveldb/transaction.go
index 4f03650..b8093f6 100644
--- a/x/ref/services/syncbase/store/leveldb/transaction.go
+++ b/x/ref/services/syncbase/store/leveldb/transaction.go
@@ -114,7 +114,7 @@
tx.mu.Lock()
defer tx.mu.Unlock()
if tx.err != nil {
- return &store.InvalidStream{tx.err}
+ return &store.InvalidStream{Error: tx.err}
}
tx.reads.Ranges = append(tx.reads.Ranges, store.ScanRange{
diff --git a/x/ref/services/syncbase/store/memstore/snapshot.go b/x/ref/services/syncbase/store/memstore/snapshot.go
index 128d127..7d0fff1 100644
--- a/x/ref/services/syncbase/store/memstore/snapshot.go
+++ b/x/ref/services/syncbase/store/memstore/snapshot.go
@@ -68,7 +68,7 @@
s.mu.Lock()
defer s.mu.Unlock()
if s.err != nil {
- return &store.InvalidStream{s.err}
+ return &store.InvalidStream{Error: s.err}
}
return newStream(s, s.node, start, limit)
}
diff --git a/x/ref/services/syncbase/store/memstore/store.go b/x/ref/services/syncbase/store/memstore/store.go
index f4ef644..e246fc4 100644
--- a/x/ref/services/syncbase/store/memstore/store.go
+++ b/x/ref/services/syncbase/store/memstore/store.go
@@ -65,7 +65,7 @@
st.mu.Lock()
defer st.mu.Unlock()
if st.err != nil {
- return &store.InvalidStream{st.err}
+ return &store.InvalidStream{Error: st.err}
}
// TODO(sadovsky): Close snapshot once stream is closed or canceled.
return newSnapshot(st, st.node).Scan(start, limit)
@@ -90,7 +90,7 @@
st.mu.Lock()
defer st.mu.Unlock()
if st.err != nil {
- return &store.InvalidTransaction{st.err}
+ return &store.InvalidTransaction{Error: st.err}
}
st.lastSeq++
return newTransaction(st, st.node, st.lastSeq)
diff --git a/x/ref/services/syncbase/store/memstore/transaction.go b/x/ref/services/syncbase/store/memstore/transaction.go
index a2ed326..5095a5f 100644
--- a/x/ref/services/syncbase/store/memstore/transaction.go
+++ b/x/ref/services/syncbase/store/memstore/transaction.go
@@ -90,7 +90,7 @@
tx.mu.Lock()
defer tx.mu.Unlock()
if err := tx.error(); err != nil {
- return &store.InvalidStream{err}
+ return &store.InvalidStream{Error: err}
}
// Create an array of store.WriteOps as it is needed to merge
