lsm/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2025-09-21 06:57:57 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

log snowflake sequencer nodeid's hex when start, it'll be in part of new assigned fid

Browse Source
This commit is contained in:
李海
2021-03-25 18:59:40 +08:00
parent 69b2dab9c6
commit 06be5dc6c3
2 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
weed/sequence/snowflake_sequencer.go
View File

@@ -5,6 +5,7 @@ import (
"hash/fnv" "hash/fnv"
"github.com/bwmarrin/snowflake" "github.com/bwmarrin/snowflake"
"github.com/chrislusf/seaweedfs/weed/glog"
) )
// a simple snowflake Sequencer // a simple snowflake Sequencer
@@ -13,7 +14,9 @@ type SnowflakeSequencer struct {
} }
func NewSnowflakeSequencer(nodeid string) (*SnowflakeSequencer, error) { func NewSnowflakeSequencer(nodeid string) (*SnowflakeSequencer, error) {
node, err := snowflake.NewNode(int64(hash(nodeid) & 0x3ff)) nodeid_hash := hash(nodeid) & 0x3ff
glog.V(0).Infof("use snowfalke seq id generator, nodeid:%s hex_of_nodeid: %x", nodeid, nodeid_hash)
node, err := snowflake.NewNode(int64(nodeid_hash))
if err != nil { if err != nil {
fmt.Println(err) fmt.Println(err)
return nil, err return nil, err

1
weed/server/master_server.go
View File

@@ -279,7 +279,6 @@ func (ms *MasterServer) createSequencer(option *MasterOption) sequence.Sequencer
} }
case "snowflake": case "snowflake":
var err error var err error
glog.V(0).Infof("use a snowfalke seq id, nodeid %s:%d", option.Host, option.Port)
seq, err = sequence.NewSnowflakeSequencer(fmt.Sprintf("%s:%d", option.Host, option.Port)) seq, err = sequence.NewSnowflakeSequencer(fmt.Sprintf("%s:%d", option.Host, option.Port))
if err != nil { if err != nil {
glog.Error(err) glog.Error(err)