@@ -3992,10 +3992,20 @@ mtm_get_nodes_state(PG_FUNCTION_ARGS)
39923992usrfctx -> values [7 ]= Int64GetDatum (Mtm -> transCount ?Mtm -> nodes [usrfctx -> nodeId - 1 ].transDelay /Mtm -> transCount :0 );
39933993usrfctx -> values [8 ]= TimestampTzGetDatum (time_t_to_timestamptz (Mtm -> nodes [usrfctx -> nodeId - 1 ].lastStatusChangeTime /USECS_PER_SEC ));
39943994usrfctx -> values [9 ]= Int64GetDatum (Mtm -> nodes [usrfctx -> nodeId - 1 ].oldestSnapshot );
3995+
39953996usrfctx -> values [10 ]= Int32GetDatum (Mtm -> nodes [usrfctx -> nodeId - 1 ].senderPid );
39963997usrfctx -> values [11 ]= TimestampTzGetDatum (time_t_to_timestamptz (Mtm -> nodes [usrfctx -> nodeId - 1 ].senderStartTime /USECS_PER_SEC ));
39973998usrfctx -> values [12 ]= Int32GetDatum (Mtm -> nodes [usrfctx -> nodeId - 1 ].receiverPid );
3998- usrfctx -> values [13 ]= TimestampTzGetDatum (time_t_to_timestamptz (Mtm -> nodes [usrfctx -> nodeId - 1 ].receiverStartTime /USECS_PER_SEC ));
3999+ usrfctx -> values [13 ]= TimestampTzGetDatum (time_t_to_timestamptz (Mtm -> nodes [usrfctx -> nodeId - 1 ].receiverStartTime /USECS_PER_SEC ));
4000+
4001+ if (usrfctx -> nodeId == MtmNodeId )
4002+ {
4003+ usrfctx -> nulls [10 ]= true;
4004+ usrfctx -> nulls [11 ]= true;
4005+ usrfctx -> nulls [12 ]= true;
4006+ usrfctx -> nulls [13 ]= true;
4007+ }
4008+
39994009usrfctx -> values [14 ]= CStringGetTextDatum (Mtm -> nodes [usrfctx -> nodeId - 1 ].con .connStr );
40004010usrfctx -> values [15 ]= Int64GetDatum (Mtm -> nodes [usrfctx -> nodeId - 1 ].connectivityMask );
40014011usrfctx -> values [16 ]= Int64GetDatum (Mtm -> nodes [usrfctx -> nodeId - 1 ].nHeartbeats );