File tree 2 files changed +11
-9
lines changed 2 files changed +11
-9
lines changed Original file line number Diff line number Diff line change @@ -185,14 +185,14 @@ impl Connection for PgConnection {
185
185
186
186
self . wait_until_ready ( ) . await ?;
187
187
188
- while let Some ( ( id, _) ) = self . inner . cache_statement . remove_lru ( ) {
189
- self . inner . stream . write_msg ( Close :: Statement ( id) ) ?;
190
- cleared += 1 ;
191
- }
188
+ while let Some ( ( id, _) ) = self . inner . cache_statement . remove_lru ( ) {
189
+ self . inner . stream . write_msg ( Close :: Statement ( id) ) ?;
190
+ cleared += 1 ;
191
+ }
192
192
193
- if cleared > 0 {
194
- self . write_sync ( ) ;
195
- self . inner . stream . flush ( ) . await ?;
193
+ if cleared > 0 {
194
+ self . write_sync ( ) ;
195
+ self . inner . stream . flush ( ) . await ?;
196
196
197
197
self . wait_for_close_complete ( cleared) . await ?;
198
198
self . recv_ready_for_query ( ) . await ?;
Original file line number Diff line number Diff line change @@ -35,8 +35,10 @@ impl TransactionManager for PgTransactionManager {
35
35
36
36
async fn rollback ( conn : & mut PgConnection ) -> Result < ( ) , Error > {
37
37
if conn. inner . transaction_depth > 0 {
38
- conn. execute ( & * rollback_ansi_transaction_sql ( conn. inner . transaction_depth ) )
39
- . await ?;
38
+ conn. execute ( & * rollback_ansi_transaction_sql (
39
+ conn. inner . transaction_depth ,
40
+ ) )
41
+ . await ?;
40
42
41
43
conn. inner . transaction_depth -= 1 ;
42
44
}
You can’t perform that action at this time.
0 commit comments