Skip to content

Commit fd1e29b

Browse files
committed
add logs
1 parent e6df3b9 commit fd1e29b

1 file changed

Lines changed: 3 additions & 2 deletions

File tree

pkg/server/server.go

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -125,6 +125,7 @@ func determinatePort() string {
125125

126126
func (server CacheServer) CacheHandler(w http.ResponseWriter, r *http.Request) {
127127
ctx := context.TODO()
128+
server.Logger.Info("handle request", zap.String("url", r.URL.String()))
128129
server.Prometheus.TotalRequestCounter.Inc()
129130

130131
defer func() {
@@ -145,7 +146,7 @@ func (server CacheServer) CacheHandler(w http.ResponseWriter, r *http.Request) {
145146
}()
146147

147148
path := strings.Split(r.URL.Path, "/")
148-
key := path[1]
149+
key := "lock:" + path[1]
149150
resultKey := server.HashURL(server.ReorderQueryString(r.URL))
150151

151152
if UseLock {
@@ -166,7 +167,7 @@ func (server CacheServer) CacheHandler(w http.ResponseWriter, r *http.Request) {
166167

167168
// try to acquire the lock
168169
if _, err := server.LockMgr.Lock(ctx, key, LockTtl); err == nil {
169-
server.Logger.Info("lock acquired", zap.String("address", key))
170+
server.Logger.Info("lock acquired", zap.String("key", key))
170171
serve(server, w, r)
171172
return
172173
}

0 commit comments

Comments
 (0)