Skip to content

Commit

Permalink
1
Browse files Browse the repository at this point in the history
  • Loading branch information
chobits committed Dec 11, 2024
1 parent b618ea6 commit c8d7637
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions kong/clustering/rpc/socket.lua
Original file line number Diff line number Diff line change
Expand Up @@ -98,7 +98,7 @@ function _M:start()
while not exiting() do
local data, typ, err = self.wb:recv_frame()

ngx.log(ngx.INFO, "xxx reading from websocket: ", data, " typ:", typ, " err:", err)
--ngx.log(ngx.INFO, "xxx reading from websocket: ", data, " typ:", typ, " err:", err)

if err then
if not is_timeout(err) then
Expand Down Expand Up @@ -202,10 +202,10 @@ function _M:start()
while not exiting() do
local payload, err = self.outgoing:pop(5)

ngx.log(ngx.INFO, "xxx socket write_thread: outgoing:pop: ", payload and payload.method, " err:", err)
--ngx.log(ngx.INFO, "xxx socket write_thread: outgoing:pop: ", payload and payload.method, " err:", err)

if err then
ngx.log(ngx.ERR, "xxx socket write thread quit!!!!!!!!!!!!!!!!!! ", err)
--ngx.log(ngx.ERR, "xxx socket write thread quit!!!!!!!!!!!!!!!!!! ", err)
return nil, err
end

Expand Down

0 comments on commit c8d7637

Please sign in to comment.