File tree 4 files changed +9
-11
lines changed
4 files changed +9
-11
lines changed Original file line number Diff line number Diff line change 3
3
4
4
#define BIT_CHECK (mask , bit ) (((mask) & ((nodemask_t)1 << (bit))) != 0)
5
5
#define BIT_SET (mask , bit ) (mask |= ((nodemask_t)1 << (bit)))
6
+ typedef uint64 nodemask_t ;
6
7
7
8
/*
8
9
* Bron–Kerbosch algorithm to find maximum clique in graph
Original file line number Diff line number Diff line change 4
4
#ifndef __BKB_H__
5
5
#define __BKB_H__
6
6
7
- #include "postgres.h" /* nodemask_t */
7
+ #include "postgres.h"
8
8
9
- #define MAX_NODES sizeof(nodemask_t)
10
- typedef uint64 nodemask_t ;
9
+ #define MAX_NODES sizeof(uint64)
11
10
12
- extern nodemask_t MtmFindMaxClique (nodemask_t * matrix , int n_modes , int * clique_size );
11
+ extern uint64 MtmFindMaxClique (uint64 * matrix , int n_modes , int * clique_size );
13
12
14
13
#endif
Original file line number Diff line number Diff line change @@ -903,7 +903,6 @@ mtm_init_node(PG_FUNCTION_ARGS)
903
903
904
904
for (i = 0 ; i < n_nodes ; i ++ )
905
905
{
906
- RepOriginId origin_id ;
907
906
char * origin_name ;
908
907
char * recovery_slot ;
909
908
@@ -912,7 +911,7 @@ mtm_init_node(PG_FUNCTION_ARGS)
912
911
913
912
/* create origin for this neighbour */
914
913
origin_name = psprintf (MULTIMASTER_SLOT_PATTERN , i + 1 );
915
- origin_id = replorigin_create (origin_name );
914
+ replorigin_create (origin_name );
916
915
917
916
/* Create recovery slot to hold WAL files that we may need during recovery */
918
917
recovery_slot = psprintf (MULTIMASTER_RECOVERY_SLOT_PATTERN , i + 1 );
Original file line number Diff line number Diff line change @@ -1012,7 +1012,6 @@ MtmMonitor(Datum arg)
1012
1012
for (i = 0 ; i < mtm_cfg -> n_nodes ; i ++ )
1013
1013
{
1014
1014
char * connstr_with_appname ;
1015
- int destination_id ;
1016
1015
1017
1016
if (i + 1 == Mtm -> my_node_id )
1018
1017
continue ;
@@ -1021,10 +1020,10 @@ MtmMonitor(Datum arg)
1021
1020
mtm_cfg -> nodes [i ].conninfo ,
1022
1021
MULTIMASTER_BROADCAST_SERVICE );
1023
1022
1024
- destination_id = dmq_destination_add (connstr_with_appname ,
1025
- psprintf ("node%d" , mtm_cfg -> my_node_id ),
1026
- psprintf ("node%d" , i + 1 ),
1027
- MtmHeartbeatSendTimeout );
1023
+ dmq_destination_add (connstr_with_appname ,
1024
+ psprintf ("node%d" , mtm_cfg -> my_node_id ),
1025
+ psprintf ("node%d" , i + 1 ),
1026
+ MtmHeartbeatSendTimeout );
1028
1027
1029
1028
pfree (connstr_with_appname );
1030
1029
}
You can’t perform that action at this time.
0 commit comments