File tree 1 file changed +7
-3
lines changed
1 file changed +7
-3
lines changed Original file line number Diff line number Diff line change @@ -971,6 +971,7 @@ mtm_join_node(PG_FUNCTION_ARGS)
971
971
PGresult * res ;
972
972
MtmConfig * cfg = MtmLoadConfig ();
973
973
XLogRecPtr curr_lsn ;
974
+ int i ;
974
975
975
976
if (SPI_connect () != SPI_OK_CONNECT )
976
977
mtm_log (ERROR , "could not connect using SPI" );
@@ -1030,7 +1031,7 @@ mtm_join_node(PG_FUNCTION_ARGS)
1030
1031
/* as we going to write that lsn on a new node, let's sync it */
1031
1032
XLogFlush (curr_lsn );
1032
1033
1033
- for (int i = 0 ; i < cfg -> n_nodes ; i ++ )
1034
+ for (i = 0 ; i < cfg -> n_nodes ; i ++ )
1034
1035
{
1035
1036
char * ro_name ;
1036
1037
RepOriginId ro_id ;
@@ -1051,8 +1052,11 @@ mtm_join_node(PG_FUNCTION_ARGS)
1051
1052
LogLogicalMessage ("S" , msg , strlen (msg ) + 1 , false);
1052
1053
replorigin_session_origin = InvalidRepOriginId ;
1053
1054
}
1054
- char * msg = psprintf (UINT64_FORMAT , (XLogRecPtr ) InvalidXLogRecPtr );
1055
- LogLogicalMessage ("S" , msg , strlen (msg ) + 1 , false);
1055
+
1056
+ {
1057
+ char * msg = psprintf (UINT64_FORMAT , (XLogRecPtr ) InvalidXLogRecPtr );
1058
+ LogLogicalMessage ("S" , msg , strlen (msg ) + 1 , false);
1059
+ }
1056
1060
1057
1061
/* fill MTM_NODES with a adjusted list of nodes */
1058
1062
query = psprintf ("insert into " MTM_NODES
You can’t perform that action at this time.
0 commit comments