@@ -209,27 +209,27 @@ func (r *InstanceImpl) serv(netconn net.Conn, pt port.RouterPortType) (uint, err
209
209
210
210
spqrlog .Zero .Info ().Msg ("console.ProcClient start" )
211
211
212
- for {
213
- msg , err := routerClient .Receive ()
212
+ msg , err := routerClient .Receive ()
214
213
215
- if err != nil {
216
- return routerClient .ID (), err
217
- }
214
+ if err != nil {
215
+ return routerClient .ID (), err
216
+ }
218
217
219
- switch v := msg .(type ) {
220
- case * pgproto3.Query :
221
- if err := clientinteractor .NewPSQLInteractor (routerClient ).Ping (context .Background ()); err != nil {
222
- _ = routerClient .ReplyErr (err )
223
- // continue to consume input
224
- }
225
- case * pgproto3.Terminate :
226
- return routerClient .ID (), nil
227
- default :
228
- spqrlog .Zero .Info ().
229
- Type ("message type" , v ).
230
- Msg ("got unexpected postgresql proto message with type" )
218
+ switch v := msg .(type ) {
219
+ case * pgproto3.Query :
220
+ if err := clientinteractor .NewPSQLInteractor (routerClient ).Ping (context .Background ()); err != nil {
221
+ _ = routerClient .ReplyErr (err )
222
+ // continue to consume input
231
223
}
224
+ case * pgproto3.Terminate :
225
+ return routerClient .ID (), nil
226
+ default :
227
+ spqrlog .Zero .Info ().
228
+ Type ("message type" , v ).
229
+ Msg ("got unexpected postgresql proto message with type" )
232
230
}
231
+
232
+ return routerClient .ID (), nil
233
233
}
234
234
235
235
if pt == port .ADMRouterPortType || routerClient .DB () == "spqr-console" {
0 commit comments