@@ -18,7 +18,6 @@ package main
18
18
19
19
import (
20
20
"flag"
21
- "fmt"
22
21
"net"
23
22
_ "net/http/pprof"
24
23
"os"
@@ -53,6 +52,13 @@ type flags struct {
53
52
init string
54
53
}
55
54
55
+ var logger = logging .MustGetLogger ("orderer/main" )
56
+
57
+ // TODO move to_test after integration with common components
58
+ func init () {
59
+ logging .SetLevel (logging .DEBUG , "" )
60
+ }
61
+
56
62
func main () {
57
63
var c flags
58
64
@@ -70,14 +76,14 @@ func main() {
70
76
71
77
level , err := logging .LogLevel (c .verbose )
72
78
if err != nil {
73
- panic ( err )
79
+ logger . Panicf ( "Failed to set loglevel: %s" , err )
74
80
}
75
81
logging .SetLevel (level , "" )
76
82
77
83
if c .init != "" {
78
84
err = initInstance (c )
79
85
if err != nil {
80
- panic ( err )
86
+ logger . Panicf ( "Failed to initialize SBFT instance: %s" , err )
81
87
}
82
88
return
83
89
}
@@ -102,26 +108,24 @@ func initInstance(c flags) error {
102
108
return err
103
109
}
104
110
105
- fmt . Println ( fmt . Sprintf ( "initialized new peer: listening at %v GRPC at %v" , c .listenAddr , c .grpcAddr ) )
111
+ logger . Infof ( "Initialized new peer: listening at %v GRPC at %v" , c .listenAddr , c .grpcAddr )
106
112
return nil
107
113
}
108
114
109
115
func serve (c flags ) {
110
116
if c .dataDir == "" {
111
- fmt .Fprintln (os .Stderr , "need data directory" )
112
- os .Exit (1 )
117
+ logger .Panic ("No data directory was given." )
113
118
}
114
119
115
120
persist := persist .New (c .dataDir )
116
121
config , err := sbft .RestoreConfig (persist )
117
122
if err != nil {
118
- panic ( err )
123
+ logger . Panicf ( "Failed to restore configuration: %s" , err )
119
124
}
120
125
121
126
conn , err := connection .New (c .listenAddr , c .certFile , c .keyFile )
122
127
if err != nil {
123
- fmt .Fprintln (os .Stderr , "Connection error." )
124
- panic (err )
128
+ logger .Panicf ("Error when trying to connect: %s" , err )
125
129
}
126
130
s := & consensusStack {
127
131
persist : nil ,
@@ -134,7 +138,7 @@ func serve(c flags) {
134
138
_ , ledger := fileledger .New (c .dataDir , genesisBlock )
135
139
s .backend , err = backend .NewBackend (config .Peers , conn , ledger , persist )
136
140
if err != nil {
137
- panic ( err )
141
+ logger . Panicf ( "Failed to create a new backend instance: %s" , err )
138
142
}
139
143
140
144
sbft , _ := pb .New (s .backend .GetMyId (), config .Consensus , s .backend )
@@ -143,7 +147,7 @@ func serve(c flags) {
143
147
grpcServer := grpc .NewServer ()
144
148
lis , err := net .Listen ("tcp" , c .grpcAddr )
145
149
if err != nil {
146
- panic ( fmt . Sprintf ("Failed to listen: %s" , err ) )
150
+ logger . Panicf ("Failed to listen: %s" , err )
147
151
}
148
152
broadcastab := backend .NewBackendAB (s .backend )
149
153
ab .RegisterAtomicBroadcastServer (grpcServer , broadcastab )
0 commit comments