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

use atomic increments

Browse Source
This commit is contained in:
Fabrizio (Misto) Milo
2013-08-06 18:49:10 -07:00
parent a15b4bb687
commit 15de3fa3ff
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
store/store.go
View File

@@ -5,6 +5,7 @@ import (
"fmt"
"path"
"strconv"
"sync/atomic"
"time"
)
@@ -103,7 +104,7 @@ var PERMANENT = time.Unix(0, 0)
//------------------------------------------------------------------------------
// Create a new stroe
// Arguement max is the max number of response we want to record
// Argument max is the max number of response we want to record
func CreateStore(max int) *Store {
s := new(Store)
@@ -143,7 +144,7 @@ func (s *Store) Set(key string, value string, expireTime time.Time, index uint64
s.Index = index
//Update stats
s.BasicStats.Sets++
atomic.AddUint64(&s.BasicStats.Sets, 1)
key = path.Clean("/" + key)
@@ -305,7 +306,7 @@ func (s *Store) Get(key string) ([]byte, error) {
func (s *Store) RawGet(key string) ([]*Response, error) {
// Update stats
s.BasicStats.Gets++
atomic.AddUint64(&s.BasicStats.Gets, 1)
key = path.Clean("/" + key)
@@ -352,7 +353,7 @@ func (s *Store) RawGet(key string) ([]*Response, error) {
func (s *Store) Delete(key string, index uint64) ([]byte, error) {
// Update stats
s.BasicStats.Deletes++
atomic.AddUint64(&s.BasicStats.Deletes, 1)
key = path.Clean("/" + key)
@@ -405,7 +406,7 @@ func (s *Store) Delete(key string, index uint64) ([]byte, error) {
// Set the value of the key to the value if the given prevValue is equal to the value of the key
func (s *Store) TestAndSet(key string, prevValue string, value string, expireTime time.Time, index uint64) ([]byte, error) {
// Update stats
s.BasicStats.TestAndSets++
atomic.AddUint64(&s.BasicStats.TestAndSets, 1)
resp := s.internalGet(key)