Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #5261 from gyuho/typo

Browse Source 
*: typo, remove string type assertions
This commit is contained in:
Gyu-Ho Lee 2016-05-03 11:29:13 -07:00
commit 864cbd36bf
3 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
etcdserver/api/v3rpc/maintenance.go
View File

@ -60,7 +60,7 @@ func (ms *maintenanceServer) Defragment(ctx context.Context, sr *pb.DefragmentRe
plog.Noticef("starting to defragment the storage backend...")
err := ms.bg.Backend().Defrag()
if err != nil {
plog.Errorf("failed to deframent the storage backend (%v)", err)
plog.Errorf("failed to defragment the storage backend (%v)", err)
return nil, err
}
plog.Noticef("finished defragmenting the storage backend")

8
mvcc/backend/batch_tx.go
View File

@ -52,7 +52,7 @@ func newBatchTx(backend *backend) *batchTx {
func (t *batchTx) UnsafeCreateBucket(name []byte) {
_, err := t.tx.CreateBucket(name)
if err != nil && err != bolt.ErrBucketExists {
log.Fatalf("mvcc: cannot create bucket %s (%v)", string(name), err)
log.Fatalf("mvcc: cannot create bucket %s (%v)", name, err)
}
t.pending++
}
@ -70,7 +70,7 @@ func (t *batchTx) UnsafeSeqPut(bucketName []byte, key []byte, value []byte) {
func (t *batchTx) unsafePut(bucketName []byte, key []byte, value []byte, seq bool) {
bucket := t.tx.Bucket(bucketName)
if bucket == nil {
log.Fatalf("mvcc: bucket %s does not exist", string(bucketName))
log.Fatalf("mvcc: bucket %s does not exist", bucketName)
}
if seq {
// it is useful to increase fill percent when the workloads are mostly append-only.
@ -87,7 +87,7 @@ func (t *batchTx) unsafePut(bucketName []byte, key []byte, value []byte, seq boo
func (t *batchTx) UnsafeRange(bucketName []byte, key, endKey []byte, limit int64) (keys [][]byte, vs [][]byte) {
bucket := t.tx.Bucket(bucketName)
if bucket == nil {
log.Fatalf("mvcc: bucket %s does not exist", string(bucketName))
log.Fatalf("mvcc: bucket %s does not exist", bucketName)
}
if len(endKey) == 0 {
@ -114,7 +114,7 @@ func (t *batchTx) UnsafeRange(bucketName []byte, key, endKey []byte, limit int64
func (t *batchTx) UnsafeDelete(bucketName []byte, key []byte) {
bucket := t.tx.Bucket(bucketName)
if bucket == nil {
log.Fatalf("mvcc: bucket %s does not exist", string(bucketName))
log.Fatalf("mvcc: bucket %s does not exist", bucketName)
}
err := bucket.Delete(key)
if err != nil {

2
mvcc/key_index.go
View File

@ -24,7 +24,7 @@ import (
)
var (
ErrRevisionNotFound = errors.New("stroage: revision not found")
ErrRevisionNotFound = errors.New("mvcc: revision not found")
)
// keyIndex stores the revisions of a key in the backend.