@@ -117,13 +117,13 @@ def run
117
117
sslmode : ssl_mode ,
118
118
connect_timeout : config [ :timeout ] )
119
119
120
- pg_vsn = conn_master . exec ( "SELECT current_setting('server_version')" ) . getvalue ( 0 , 0 )
121
- master =
122
- if Gem ::Version . new ( pg_vsn ) > Gem ::Version . new ( '9.6' )
123
- conn_master . exec ( 'SELECT pg_current_wal_lsn()' ) . getvalue ( 0 , 0 )
124
- else
125
- conn_master . exec ( 'SELECT pg_current_xlog_location()' ) . getvalue ( 0 , 0 )
126
- end
120
+ pg_vsn = conn_master . exec ( "SELECT current_setting('server_version')" ) . getvalue ( 0 , 0 )
121
+
122
+ master = if Gem ::Version . new ( pg_vsn ) > Gem ::Version . new ( '9.6' )
123
+ conn_master . exec ( 'SELECT pg_current_wal_lsn()' ) . getvalue ( 0 , 0 )
124
+ else
125
+ conn_master . exec ( 'SELECT pg_current_xlog_location()' ) . getvalue ( 0 , 0 )
126
+ end
127
127
m_segbytes = conn_master . exec ( 'SHOW wal_segment_size' ) . getvalue ( 0 , 0 ) . sub ( /\D +/ , '' ) . to_i << 20
128
128
conn_master . close
129
129
@@ -136,12 +136,11 @@ def run
136
136
sslmode : ssl_mode ,
137
137
connect_timeout : config [ :timeout ] )
138
138
139
- slave =
140
- if Gem ::Version . new ( pg_vsn ) > Gem ::Version . new ( '9.6' )
141
- conn_slave . exec ( 'SELECT pg_last_wal_replay_lsn()' ) . getvalue ( 0 , 0 )
142
- else
143
- conn_slave . exec ( 'SELECT pg_last_xlog_receive_location()' ) . getvalue ( 0 , 0 )
144
- end
139
+ slave = if Gem ::Version . new ( pg_vsn ) > Gem ::Version . new ( '9.6' )
140
+ conn_slave . exec ( 'SELECT pg_last_wal_replay_lsn()' ) . getvalue ( 0 , 0 )
141
+ else
142
+ conn_slave . exec ( 'SELECT pg_last_xlog_receive_location()' ) . getvalue ( 0 , 0 )
143
+ end
145
144
conn_slave . close
146
145
147
146
# Computing lag
0 commit comments