@@ -50,7 +50,7 @@ import (
50
50
"fmt"
51
51
"io"
52
52
"io/ioutil"
53
- "log"
53
+ _log "log"
54
54
"net"
55
55
"net/http"
56
56
"os"
@@ -137,12 +137,12 @@ func registerHandlers() {
137
137
ln, host, err := listen()
138
138
{{end}}
139
139
if err != nil {
140
- log .Fatalf("listen failed, err:%v", err)
140
+ _log .Fatalf("listen failed, err:%v", err)
141
141
}
142
142
{{if not .Singleton}}
143
143
profileAddr := "http://" + host
144
144
if resp, err := registerSelf(profileAddr); err != nil {
145
- log .Fatalf("register address %v failed, err: %v, response: %v", profileAddr, err, string(resp))
145
+ _log .Fatalf("register address %v failed, err: %v, response: %v", profileAddr, err, string(resp))
146
146
}
147
147
148
148
fn := func() {
@@ -152,7 +152,7 @@ func registerHandlers() {
152
152
addresses []string
153
153
)
154
154
if addresses, err = getAllHosts(ln); err != nil {
155
- log .Fatalf("get all host failed, err: %v", err)
155
+ _log .Fatalf("get all host failed, err: %v", err)
156
156
return
157
157
}
158
158
for _, addr := range addresses {
@@ -218,7 +218,7 @@ func registerHandlers() {
218
218
fmt.Fprintln(w, "clear call successfully")
219
219
})
220
220
221
- log .Fatal(http.Serve(ln, mux))
221
+ _log .Fatal(http.Serve(ln, mux))
222
222
}
223
223
224
224
func registerSelf(address string) ([]byte, error) {
@@ -231,13 +231,13 @@ func registerSelf(address string) ([]byte, error) {
231
231
}
232
232
req, err := http.NewRequest("POST", fmt.Sprintf("%s/v1/cover/register?name=%s&address=%s", {{.Center | printf "%q"}}, selfName, address), nil)
233
233
if err != nil {
234
- log .Fatalf("http.NewRequest failed: %v", err)
234
+ _log .Fatalf("http.NewRequest failed: %v", err)
235
235
return nil, err
236
236
}
237
237
238
238
resp, err := http.DefaultClient.Do(req)
239
239
if err != nil && isNetworkError(err) {
240
- log .Printf("[goc][WARN]error occurred:%v, try again", err)
240
+ _log .Printf("[goc][WARN]error occurred:%v, try again", err)
241
241
resp, err = http.DefaultClient.Do(req)
242
242
}
243
243
if err != nil {
@@ -267,14 +267,14 @@ func deregisterSelf(address []string) ([]byte, error) {
267
267
}
268
268
req, err := http.NewRequest("POST", fmt.Sprintf("%s/v1/cover/remove", {{.Center | printf "%q"}}), bytes.NewReader(jsonBody))
269
269
if err != nil {
270
- log .Fatalf("http.NewRequest failed: %v", err)
270
+ _log .Fatalf("http.NewRequest failed: %v", err)
271
271
return nil, err
272
272
}
273
273
req.Header.Set("Content-Type", "application/json")
274
274
275
275
resp, err := http.DefaultClient.Do(req)
276
276
if err != nil && isNetworkError(err) {
277
- log .Printf("[goc][WARN]error occurred:%v, try again", err)
277
+ _log .Printf("[goc][WARN]error occurred:%v, try again", err)
278
278
resp, err = http.DefaultClient.Do(req)
279
279
}
280
280
if err != nil {
@@ -302,7 +302,7 @@ func watchSignal(fn CallbackFunc) {
302
302
signal.Notify(c, syscall.SIGHUP, syscall.SIGQUIT, syscall.SIGTERM, syscall.SIGINT)
303
303
for {
304
304
si := <-c
305
- log .Printf("get a signal %s", si.String())
305
+ _log .Printf("get a signal %s", si.String())
306
306
switch si {
307
307
case syscall.SIGQUIT, syscall.SIGTERM, syscall.SIGINT:
308
308
fn()
@@ -411,7 +411,7 @@ func genProfileAddr(profileAddr string) {
411
411
fn := os.Args[0] + "_profile_listen_addr"
412
412
f, err := os.OpenFile(fn, os.O_RDWR|os.O_CREATE|os.O_TRUNC, 0644)
413
413
if err != nil {
414
- log .Println(err)
414
+ _log .Println(err)
415
415
return
416
416
}
417
417
defer f.Close()
0 commit comments