aboutsummaryrefslogtreecommitdiff
path: root/weed-fs/src/pkg/sequence/sequence.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2013-01-17 00:56:56 -0800
committerChris Lu <chris.lu@gmail.com>2013-01-17 00:56:56 -0800
commitb0c7df0c3b12f4ecd7ff0b317eeb2dd463ca9596 (patch)
treedc3c8c86309de659d55ebd31a770ba3b27bb191a /weed-fs/src/pkg/sequence/sequence.go
parentca9056d673daa9e49e83339ba0fc4b6b03bd9fef (diff)
downloadseaweedfs-b0c7df0c3b12f4ecd7ff0b317eeb2dd463ca9596.tar.xz
seaweedfs-b0c7df0c3b12f4ecd7ff0b317eeb2dd463ca9596.zip
go fmt for all source codes
Diffstat (limited to 'weed-fs/src/pkg/sequence/sequence.go')
-rw-r--r--weed-fs/src/pkg/sequence/sequence.go52
1 files changed, 26 insertions, 26 deletions
diff --git a/weed-fs/src/pkg/sequence/sequence.go b/weed-fs/src/pkg/sequence/sequence.go
index bfdf1b368..c85289468 100644
--- a/weed-fs/src/pkg/sequence/sequence.go
+++ b/weed-fs/src/pkg/sequence/sequence.go
@@ -1,11 +1,11 @@
package sequence
import (
- "encoding/gob"
- "os"
- "path"
- "sync"
+ "encoding/gob"
"log"
+ "os"
+ "path"
+ "sync"
)
const (
@@ -27,21 +27,21 @@ type SequencerImpl struct {
}
func NewSequencer(dirname string, filename string) (m *SequencerImpl) {
- m = &SequencerImpl{dir: dirname, fileName: filename}
+ m = &SequencerImpl{dir: dirname, fileName: filename}
- seqFile, se := os.OpenFile(path.Join(m.dir, m.fileName+".seq"), os.O_RDONLY, 0644)
- if se != nil {
- m.FileIdSequence = FileIdSaveInterval
- log.Println("Setting file id sequence", m.FileIdSequence)
- } else {
- decoder := gob.NewDecoder(seqFile)
- defer seqFile.Close()
- decoder.Decode(&m.FileIdSequence)
- log.Println("Loading file id sequence", m.FileIdSequence, "=>", m.FileIdSequence+FileIdSaveInterval)
- //in case the server stops between intervals
- m.FileIdSequence += FileIdSaveInterval
- }
- return
+ seqFile, se := os.OpenFile(path.Join(m.dir, m.fileName+".seq"), os.O_RDONLY, 0644)
+ if se != nil {
+ m.FileIdSequence = FileIdSaveInterval
+ log.Println("Setting file id sequence", m.FileIdSequence)
+ } else {
+ decoder := gob.NewDecoder(seqFile)
+ defer seqFile.Close()
+ decoder.Decode(&m.FileIdSequence)
+ log.Println("Loading file id sequence", m.FileIdSequence, "=>", m.FileIdSequence+FileIdSaveInterval)
+ //in case the server stops between intervals
+ m.FileIdSequence += FileIdSaveInterval
+ }
+ return
}
//count should be 1 or more
@@ -60,12 +60,12 @@ func (m *SequencerImpl) NextFileId(count int) (uint64, int) {
return m.FileIdSequence - m.fileIdCounter, count
}
func (m *SequencerImpl) saveSequence() {
- log.Println("Saving file id sequence", m.FileIdSequence, "to", path.Join(m.dir, m.fileName+".seq"))
- seqFile, e := os.OpenFile(path.Join(m.dir, m.fileName+".seq"), os.O_CREATE|os.O_WRONLY, 0644)
- if e != nil {
- log.Fatalf("Sequence File Save [ERROR] %s\n", e)
- }
- defer seqFile.Close()
- encoder := gob.NewEncoder(seqFile)
- encoder.Encode(m.FileIdSequence)
+ log.Println("Saving file id sequence", m.FileIdSequence, "to", path.Join(m.dir, m.fileName+".seq"))
+ seqFile, e := os.OpenFile(path.Join(m.dir, m.fileName+".seq"), os.O_CREATE|os.O_WRONLY, 0644)
+ if e != nil {
+ log.Fatalf("Sequence File Save [ERROR] %s\n", e)
+ }
+ defer seqFile.Close()
+ encoder := gob.NewEncoder(seqFile)
+ encoder.Encode(m.FileIdSequence)
}