diff --git a/db/db.go b/db/db.go index 6750e03..4824299 100644 --- a/db/db.go +++ b/db/db.go @@ -4,7 +4,6 @@ import ( "bytes" "encoding/hex" "fmt" - "log" "math" "os" "sort" @@ -14,6 +13,8 @@ import ( "github.com/lbryio/hub/db/prefixes" "github.com/lbryio/lbry.go/v2/extras/util" "github.com/linxGnu/grocksdb" + + log "github.com/sirupsen/logrus" ) // @@ -540,6 +541,10 @@ func Advance(db *ReadOnlyDBColumnFamily, height uint32) { return } txCount := txCountObj.TxCount + + if db.TxCounts.GetTip().(uint32) >= txCount { + } + db.TxCounts.Push(txCount) db.Headers.Push(headerObj) } @@ -581,6 +586,9 @@ func DetectChanges(db *ReadOnlyDBColumnFamily) error { return nil } + // log.Printf("db.LastState %#v, state: %#v", db.LastState, state) + log.Debugf("db.LastState %#v, state: %#v", db.LastState, state) + if db.LastState != nil && db.LastState.Height > state.Height { log.Println("reorg detected, waiting until the writer has flushed the new blocks to advance") return nil @@ -595,15 +603,18 @@ func DetectChanges(db *ReadOnlyDBColumnFamily) error { if err != nil { return err } - curHeader := db.Headers.GetTip().(*prefixes.BlockHeaderValue).Header + curHeader := db.Headers.GetTip().([]byte) + log.Debugln("lastHeightHeader: ", hex.EncodeToString(lastHeightHeader)) + log.Debugln("curHeader: ", hex.EncodeToString(curHeader)) if bytes.Equal(curHeader, lastHeightHeader) { - log.Println("connects to block", lastHeight) + log.Traceln("connects to block", lastHeight) break } else { - log.Println("disconnect block", lastHeight) + log.Infoln("disconnect block", lastHeight) Unwind(db) rewound = true lastHeight -= 1 + time.Sleep(time.Second) } } } @@ -617,16 +628,16 @@ func DetectChanges(db *ReadOnlyDBColumnFamily) error { } if db.LastState == nil || lastHeight < state.Height { - for height := lastHeight; height <= state.Height; height++ { + for height := lastHeight + 1; height <= state.Height; height++ { log.Println("advancing to", height) Advance(db, height) - //TODO: ClearCache - db.LastState = state - //TODO: block count metric - - //TODO: update blocked streams - //TODO: update filtered streams } + //TODO: ClearCache + db.LastState = state + //TODO: block count metric + + //TODO: update blocked streams + //TODO: update filtered streams } return nil @@ -728,13 +739,13 @@ func InitHeaders(db *ReadOnlyDBColumnFamily) error { startKeyRaw := startKey.PackKey() endKeyRaw := endKey.PackKey() options := NewIterateOptions().WithPrefix([]byte{prefixes.Header}).WithCfHandle(handle) - options = options.WithIncludeKey(false).WithIncludeValue(true) + options = options.WithIncludeKey(false).WithIncludeValue(true).WithIncludeStop(true) options = options.WithStart(startKeyRaw).WithStop(endKeyRaw) ch := IterCF(db.DB, options) for header := range ch { - db.Headers.Push(header.Value) + db.Headers.Push(header.Value.(*prefixes.BlockHeaderValue).Header) } return nil @@ -761,10 +772,16 @@ func InitTxCounts(db *ReadOnlyDBColumnFamily) error { } duration := time.Since(start) - log.Println("len(db.TxCounts), size(db.TxCounts):", db.TxCounts.Len(), db.TxCounts.Size()) + log.Println("len(db.TxCounts), cap(db.TxCounts):", db.TxCounts.Len(), db.TxCounts.Cap()) log.Println("Time to get txCounts:", duration) - db.Height = db.TxCounts.Len() + // This needs to be len-1 because we start loading with the zero block + // and the txcounts start at one. + if db.TxCounts.Len() > 0 { + db.Height = db.TxCounts.Len() - 1 + } else { + log.Println("db.TxCounts.Len() == 0 ???") + } return nil } diff --git a/db/db_stack/db_stack.go b/db/db_stack/db_stack.go index 29322e9..3ffdf76 100644 --- a/db/db_stack/db_stack.go +++ b/db/db_stack/db_stack.go @@ -47,8 +47,8 @@ func (s *SliceBackedStack) Len() uint32 { return s.len } -func (s *SliceBackedStack) Size() int { - return len(s.slice) +func (s *SliceBackedStack) Cap() int { + return cap(s.slice) } func (s *SliceBackedStack) GetSlice() []interface{} { diff --git a/go.mod b/go.mod index b6b44e9..01b1714 100644 --- a/go.mod +++ b/go.mod @@ -1,6 +1,6 @@ module github.com/lbryio/hub -go 1.16 +go 1.17 require ( github.com/ReneKroon/ttlcache/v2 v2.8.1 @@ -10,9 +10,34 @@ require ( github.com/olivere/elastic/v7 v7.0.24 github.com/prometheus/client_golang v1.11.0 github.com/prometheus/client_model v0.2.0 + github.com/sirupsen/logrus v1.6.0 golang.org/x/text v0.3.6 - google.golang.org/genproto v0.0.0-20210524171403-669157292da3 // indirect google.golang.org/grpc v1.38.0 google.golang.org/protobuf v1.27.1 gopkg.in/karalabe/cookiejar.v1 v1.0.0-20141109175019-e1490cae028c ) + +require ( + github.com/beorn7/perks v1.0.1 // indirect + github.com/cespare/xxhash/v2 v2.1.1 // indirect + github.com/davecgh/go-spew v1.1.1 // indirect + github.com/go-errors/errors v1.1.1 // indirect + github.com/golang/protobuf v1.5.0 // indirect + github.com/gorilla/websocket v1.4.1 // indirect + github.com/josharian/intern v1.0.0 // indirect + github.com/konsorten/go-windows-terminal-sequences v1.0.3 // indirect + github.com/mailru/easyjson v0.7.7 // indirect + github.com/matttproud/golang_protobuf_extensions v1.0.1 // indirect + github.com/nlopes/slack v0.6.0 // indirect + github.com/pkg/errors v0.9.1 // indirect + github.com/pmezard/go-difflib v1.0.0 // indirect + github.com/prometheus/common v0.26.0 // indirect + github.com/prometheus/procfs v0.6.0 // indirect + github.com/stretchr/testify v1.7.0 // indirect + golang.org/x/net v0.0.0-20201110031124-69a78807bb2b // indirect + golang.org/x/sync v0.0.0-20210220032951-036812b2e83c // indirect + golang.org/x/sys v0.0.0-20210603081109-ebe580a85c40 // indirect + google.golang.org/genproto v0.0.0-20200526211855-cb27e3aa2013 // indirect + gopkg.in/nullbio/null.v6 v6.0.0-20161116030900-40264a2e6b79 // indirect + gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b // indirect +) diff --git a/go.sum b/go.sum index f191980..2680cb6 100644 --- a/go.sum +++ b/go.sum @@ -39,7 +39,6 @@ github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSs github.com/envoyproxy/go-control-plane v0.9.0/go.mod h1:YTl/9mNaCwkRvm6d1a2C3ymFceY/DCBVvsKhRF0iEA4= github.com/envoyproxy/go-control-plane v0.9.1-0.20191026205805-5f8ba28d4473/go.mod h1:YTl/9mNaCwkRvm6d1a2C3ymFceY/DCBVvsKhRF0iEA4= github.com/envoyproxy/go-control-plane v0.9.4/go.mod h1:6rpuAdCZL397s3pYoYcLgu1mIlRU8Am5FuJP05cCM98= -github.com/envoyproxy/go-control-plane v0.9.9-0.20201210154907-fd9021fe5dad/go.mod h1:cXg6YxExXjJnVBQHBLXeUAgxn2UodCpnH306RInaBQk= github.com/envoyproxy/go-control-plane v0.9.9-0.20210217033140-668b12f5399d/go.mod h1:cXg6YxExXjJnVBQHBLXeUAgxn2UodCpnH306RInaBQk= github.com/envoyproxy/protoc-gen-validate v0.1.0/go.mod h1:iSmxcyjqTsJpI2R4NaDN7+kN2VEUnK/pcBlmesArF7c= github.com/fatih/structs v1.1.0/go.mod h1:9NiDSp5zOcgEDl+j00MP/WkGVPOlPRLejGD8Ga6PJ7M= @@ -73,9 +72,8 @@ github.com/golang/protobuf v1.4.0/go.mod h1:jodUvKwWbYaEsadDk5Fwe5c77LiNKVO9IDvq github.com/golang/protobuf v1.4.1/go.mod h1:U8fpvMrcmy5pZrNK1lt4xCsGvpyWQ/VVv6QDs8UjoX8= github.com/golang/protobuf v1.4.2/go.mod h1:oDoupMAO8OvCJWAcko0GGGIgR6R6ocIYbsSw735rRwI= github.com/golang/protobuf v1.4.3/go.mod h1:oDoupMAO8OvCJWAcko0GGGIgR6R6ocIYbsSw735rRwI= +github.com/golang/protobuf v1.5.0 h1:LUVKkCeviFUMKqHa4tXIIij/lbhnMbP7Fn5wKdKkRh4= github.com/golang/protobuf v1.5.0/go.mod h1:FsONVRAS9T7sI+LIUmWTfcYkHO4aIWwzhcaSAoJOfIk= -github.com/golang/protobuf v1.5.2 h1:ROPKBNFfQgOUMifHyP+KYbvpjbdoFNs+aK7DXlji0Tw= -github.com/golang/protobuf v1.5.2/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= github.com/google/go-cmp v0.2.0/go.mod h1:oXzfMopK8JAjlY9xF4vHSVASa0yLyX7SntLO5aqRK0M= github.com/google/go-cmp v0.3.0/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU= github.com/google/go-cmp v0.3.1/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU= @@ -229,9 +227,8 @@ golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLL golang.org/x/net v0.0.0-20191009170851-d66e71096ffb/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s= golang.org/x/net v0.0.0-20200625001655-4c5254603344/go.mod h1:/O7V0waA8r7cgGh81Ro3o1hOxt32SMVPicZroKQ2sZA= golang.org/x/net v0.0.0-20201021035429-f5854403a974/go.mod h1:sp8m0HH+o8qH0wwXwYZr8TS3Oi6o0r6Gce1SSxlDquU= +golang.org/x/net v0.0.0-20201110031124-69a78807bb2b h1:uwuIcX0g4Yl1NC5XAz37xsr2lTtcqevgzYNVt49waME= golang.org/x/net v0.0.0-20201110031124-69a78807bb2b/go.mod h1:sp8m0HH+o8qH0wwXwYZr8TS3Oi6o0r6Gce1SSxlDquU= -golang.org/x/net v0.0.0-20210316092652-d523dce5a7f4 h1:b0LrWgu8+q7z4J+0Y3Umo5q1dL7NXBkKBWkaVkAq17E= -golang.org/x/net v0.0.0-20210316092652-d523dce5a7f4/go.mod h1:RBQZq4jEuRlivfhVLdyRGr576XBO4/greRjx4P4O3yc= golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U= golang.org/x/oauth2 v0.0.0-20190226205417-e64efc72b421/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw= golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= @@ -256,18 +253,12 @@ golang.org/x/sys v0.0.0-20200323222414-85ca7c5b95cd/go.mod h1:h1NjWce9XRLGQEsW7w golang.org/x/sys v0.0.0-20200615200032-f1bc736245b1/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20200625212154-ddb9806d33ae/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20200930185726-fdedc70b468f/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= -golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= -golang.org/x/sys v0.0.0-20210119212857-b64e53b001e4/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20210124154548-22da62e12c0c/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= -golang.org/x/sys v0.0.0-20210315160823-c6e025ad8005/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= -golang.org/x/sys v0.0.0-20210320140829-1e4c9ba3b0c4/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20210603081109-ebe580a85c40 h1:JWgyZ1qgdTaF3N3oxC+MdTV7qvEEgHo3otj+HB5CM7Q= golang.org/x/sys v0.0.0-20210603081109-ebe580a85c40/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= -golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo= golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= golang.org/x/text v0.3.2/go.mod h1:bEr9sfX3Q8Zfm5fL9x+3itogRgK3+ptLWKqgva+5dAk= golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= -golang.org/x/text v0.3.5/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= golang.org/x/text v0.3.6 h1:aRYxNxv6iGQlyVaZmk6ZgYEDa+Jg18DxebPSrd6bg1M= golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= golang.org/x/time v0.0.0-20190921001708-c4c64cad1fd0/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ= @@ -280,9 +271,8 @@ golang.org/x/tools v0.0.0-20190524140312-2c0ae7006135/go.mod h1:RgjU9mgBXZiqYHBn golang.org/x/tools v0.0.0-20191108193012-7d206e10da11/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo= golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo= golang.org/x/tools v0.0.0-20200130002326-2f3ba24bd6e7/go.mod h1:TB2adYChydJhpapKDTa4BR/hXlZSLoq2Wpct/0txZ28= +golang.org/x/tools v0.0.0-20210112230658-8b4aab62c064 h1:BmCFkEH4nJrYcAc2L08yX5RhYGD4j58PTMkEUDkpz2I= golang.org/x/tools v0.0.0-20210112230658-8b4aab62c064/go.mod h1:emZCQorbCU4vsT4fOWvOPXz4eW1wZW4PmDk9uLelYpA= -golang.org/x/tools v0.1.0 h1:po9/4sTYwZU9lPhi1tOrb4hCv3qrhiQ77LZfGa2OjwY= -golang.org/x/tools v0.1.0/go.mod h1:xkSsbof2nBLbhDlRMhhhyNLN/zl3eTqcnHD5viDpcZ0= golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= @@ -293,16 +283,14 @@ google.golang.org/appengine v1.4.0/go.mod h1:xpcJRLb0r/rnEns0DIKYYv+WjYCduHsrkT7 google.golang.org/genproto v0.0.0-20180817151627-c66870c02cf8/go.mod h1:JiN7NxoALGmiZfu7CAH4rXhgtRTLTxftemlI0sWmxmc= google.golang.org/genproto v0.0.0-20190819201941-24fa4b261c55/go.mod h1:DMBHOl98Agz4BDEuKkezgsaosCRResVns1a3J2ZsMNc= google.golang.org/genproto v0.0.0-20191009194640-548a555dbc03/go.mod h1:n3cpQtvxv34hfy77yVDNjmbRyujviMdxYliBSkLhpCc= +google.golang.org/genproto v0.0.0-20200526211855-cb27e3aa2013 h1:+kGHl1aib/qcwaRi1CbqBZ1rk19r85MNUf8HaBghugY= google.golang.org/genproto v0.0.0-20200526211855-cb27e3aa2013/go.mod h1:NbSheEEYHJ7i3ixzK3sjbqSGDJWnxyFXZblF3eUsNvo= -google.golang.org/genproto v0.0.0-20210524171403-669157292da3 h1:xFyh6GBb+NO1L0xqb978I3sBPQpk6FrKO0jJGRvdj/0= -google.golang.org/genproto v0.0.0-20210524171403-669157292da3/go.mod h1:P3QM42oQyzQSnHPnZ/vqoCdDmzH28fzWByN9asMeM8A= google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c= google.golang.org/grpc v1.23.0/go.mod h1:Y5yQAOtifL1yxbo5wqy6BxZv8vAUGQwXBOALyacEbxg= google.golang.org/grpc v1.24.0/go.mod h1:XDChyiUovWa60DnaeDeZmSW86xtLtjtZbwvSiRnRtcA= google.golang.org/grpc v1.25.1/go.mod h1:c3i+UQWmh7LiEpx4sFZnkU36qjEYZ0imhYfXVyQciAY= google.golang.org/grpc v1.27.0/go.mod h1:qbnxyOmOxrQa7FizSgH+ReBfzJrCY1pSN7KXBS8abTk= google.golang.org/grpc v1.33.2/go.mod h1:JMHMWHQWaTccqQQlmk3MJZS+GWXOdAesneDmEnv2fbc= -google.golang.org/grpc v1.36.1/go.mod h1:qjiiYl8FncCW8feJPdyg3v6XW24KsRHe+dy9BAGRRjU= google.golang.org/grpc v1.38.0 h1:/9BgsAsa5nWe26HqOlvlgJnqBuktYOLCgjCPqsa56W0= google.golang.org/grpc v1.38.0/go.mod h1:NREThFqKR1f3iQ6oBuvc5LadQuXVGo9rkm5ZGrQdJfM= google.golang.org/protobuf v0.0.0-20200109180630-ec00e32a8dfd/go.mod h1:DFci5gLYBciE7Vtevhsrf46CRTquxDuWsQurQQe4oz8= @@ -315,7 +303,6 @@ google.golang.org/protobuf v1.23.0/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2 google.golang.org/protobuf v1.23.1-0.20200526195155-81db48ad09cc/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU= google.golang.org/protobuf v1.25.0/go.mod h1:9JNX74DMeImyA3h4bdi1ymwjUzf21/xIlbajtzgsN7c= google.golang.org/protobuf v1.26.0-rc.1/go.mod h1:jlhhOSvTdKEhbULTjvd4ARK9grFBp09yW+WbY/TyQbw= -google.golang.org/protobuf v1.26.0/go.mod h1:9q0QmTI4eRPtz6boOQmLYwt+qCgq0jsYwAQnmE0givc= google.golang.org/protobuf v1.27.1 h1:SnqbnDw1V7RiZcXPx5MEeqPv2s79L9i7BJUlG/+RurQ= google.golang.org/protobuf v1.27.1/go.mod h1:9q0QmTI4eRPtz6boOQmLYwt+qCgq0jsYwAQnmE0givc= gopkg.in/alecthomas/kingpin.v2 v2.2.6/go.mod h1:FMv+mEhP44yOT+4EoQTLFTRgOQ1FBLkstjWtayDeSgw= diff --git a/main.go b/main.go index 94cbbed..8bf61bc 100644 --- a/main.go +++ b/main.go @@ -6,9 +6,6 @@ import ( "encoding/hex" "fmt" "log" - "os" - "os/signal" - "syscall" "time" "github.com/lbryio/hub/db" @@ -31,26 +28,27 @@ func main() { ctxWCancel, cancel := context.WithCancel(ctx) defer cancel() - interrupt := make(chan os.Signal, 1) - signal.Notify(interrupt, os.Interrupt, syscall.SIGTERM) - defer signal.Stop(interrupt) + // TODO: Figure out if / where we need signal handling + // interrupt := make(chan os.Signal, 1) + // signal.Notify(interrupt, os.Interrupt, syscall.SIGTERM) + // defer signal.Stop(interrupt) s := server.MakeHubServer(ctxWCancel, args) s.Run() - select { - case <-interrupt: - break - case <-ctx.Done(): - break - } + // select { + // case <-interrupt: + // break + // case <-ctx.Done(): + // break + // } - log.Println("Shutting down server...") + // log.Println("Shutting down server...") - s.EsClient.Stop() - s.GrpcServer.GracefulStop() + // s.EsClient.Stop() + // s.GrpcServer.GracefulStop() - log.Println("Returning from main...") + // log.Println("Returning from main...") return } else if args.CmdType == server.DBCmd { diff --git a/server/args.go b/server/args.go index 4f68e43..0aa8fcb 100644 --- a/server/args.go +++ b/server/args.go @@ -59,8 +59,8 @@ const ( DefaultDisableStartUDP = false DefaultDisableWritePeers = false DefaultDisableFederation = false - DefaultDisableRockDBRefresh = true - DefaultDisableResolve = true + DefaultDisableRockDBRefresh = false + DefaultDisableResolve = false ) // GetEnvironment takes the environment variables as an array of strings diff --git a/server/federation.go b/server/federation.go index 5fb6e29..4944574 100644 --- a/server/federation.go +++ b/server/federation.go @@ -93,6 +93,7 @@ func (s *Server) loadPeers() error { ctx, cancel := context.WithTimeout(context.Background(), time.Second) defer cancel() + // log.Println("loadPeers #### waiting for server to come up") retry: time.Sleep(time.Second * time.Duration(math.Pow(float64(failures), 2))) conn, err := grpc.DialContext(ctx, @@ -113,10 +114,11 @@ retry: log.Println(err) } cancel() + // log.Println("loadPeers #### Past checking for server to come up") f, err := os.Open(peerFile) if err != nil { - log.Println(err) + // log.Println(err) return err } scanner := bufio.NewScanner(f) diff --git a/server/server.go b/server/server.go index 6c9d0ab..8a01f9f 100644 --- a/server/server.go +++ b/server/server.go @@ -129,8 +129,8 @@ func (s *Server) Run() { pb.RegisterHubServer(s.GrpcServer, s) reflection.Register(s.GrpcServer) - log.Printf("listening on %s\n", l.Addr().String()) - log.Println(s.Args) + log.Printf("Server.Run() #### listening on %s\n", l.Addr().String()) + log.Printf("%#v\n", s.Args) if err := s.GrpcServer.Serve(l); err != nil { log.Fatalf("failed to serve: %v", err) }