database/openGauss-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

优化 gs_stat_walrecvwriter字段

Browse Source
This commit is contained in:
laishenghao
2023-11-23 20:49:55 +08:00
parent deadc81ac3
commit 172fcce4ae
5 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/common/backend/catalog/builtin_funcs.ini
View File

@ -4035,7 +4035,7 @@
),
AddFuncGroup(
"gs_stat_walrecvwriter", 1,
AddBuiltinFunc(_0(2868), _1("gs_stat_walrecvwriter"), _2(1), _3(false), _4(true), _5(gs_stat_walrecvwriter), _6(2249), _7(PG_CATALOG_NAMESPACE), _8(BOOTSTRAP_SUPERUSERID), _9(INTERNALlanguageId), _10(1), _11(1), _12(0), _13(0), _14(false), _15(false), _16(false), _17(false), _18('s'), _19(1), _20(1, 23), _21(16, 23, 16, 28, 28, 28, 28, 28, 28, 28, 28, 28, 28, 28, 28, 1184, 1184), _22(16, 'i', 'o', 'o', 'o', 'o', 'o', 'o', 'o', 'o', 'o', 'o', 'o', 'o', 'o', 'o', 'o'), _23(16, "operation", "is_enable_stat", "total_write_bytes", "write_times", "total_write_time", "avg_write_time", "avg_write_bytes", "total_sync_bytes", "sync_times", "total_sync_time", "avg_sync_time", "avg_sync_bytes", "current_xlog_segno", "newest_xlog_segno", "last_reset_time", "cur_time"), _24("({CONST :consttype 23 :consttypmod -1 :constcollid 0 :constlen 4 :constbyval true :constisnull false :ismaxvalue false :location -1 :constvalue 4 [ 2 0 0 0 0 0 0 0 ] :cursor_data :row_count 0 :cur_dno -1 :is_open false :found false :not_found false :null_open false :null_fetch false})"), _25("gs_stat_walrecvwriter"), _26(NULL), _27(NULL), _28(NULL), _29(1, 0), _30(false), _31(NULL), _32(false), _33(NULL), _34('f'), _35(NULL), _36(0), _37(false), _38(NULL), _39(NULL), _40(0))
AddBuiltinFunc(_0(2868), _1("gs_stat_walrecvwriter"), _2(1), _3(false), _4(true), _5(gs_stat_walrecvwriter), _6(2249), _7(PG_CATALOG_NAMESPACE), _8(BOOTSTRAP_SUPERUSERID), _9(INTERNALlanguageId), _10(1), _11(1), _12(0), _13(0), _14(false), _15(false), _16(false), _17(false), _18('s'), _19(1), _20(1, 23), _21(16, 23, 16, 28, 28, 28, 28, 28, 28, 28, 28, 28, 28, 28, 28, 1184, 1184), _22(16, 'i', 'o', 'o', 'o', 'o', 'o', 'o', 'o', 'o', 'o', 'o', 'o', 'o', 'o', 'o', 'o'), _23(16, "operation", "is_enable_stat", "total_write_bytes", "write_times", "total_write_time", "avg_write_time", "avg_write_bytes", "total_sync_bytes", "sync_times", "total_sync_time", "avg_sync_time", "avg_sync_bytes", "current_xlog_segno", "inited_xlog_segno", "last_reset_time", "cur_time"), _24("({CONST :consttype 23 :consttypmod -1 :constcollid 0 :constlen 4 :constbyval true :constisnull false :ismaxvalue false :location -1 :constvalue 4 [ 2 0 0 0 0 0 0 0 ] :cursor_data :row_count 0 :cur_dno -1 :is_open false :found false :not_found false :null_open false :null_fetch false})"), _25("gs_stat_walrecvwriter"), _26(NULL), _27(NULL), _28(NULL), _29(1, 0), _30(false), _31(NULL), _32(false), _33(NULL), _34('f'), _35(NULL), _36(0), _37(false), _38(NULL), _39(NULL), _40(0))
),
AddFuncGroup(
"gs_xlogdump_lsn", 1,

4
src/common/backend/utils/adt/walreceiver_statfuncs.cpp
View File

@ -83,7 +83,7 @@ Datum gs_stat_walreceiver(PG_FUNCTION_ARGS)
* avg_sync_time uint64
* avg_sync_bytes uint64
* current_xlog_segno uint64
* newest_xlog_segno uint64
* inited_xlog_segno uint64
* last_reset_time timestamptz
* cur_time timestamptz
*/
@ -318,7 +318,7 @@ static void BuildRecvWriterStatsTupleValues(TupleDesc tupleDesc, Tuplestorestate
/* current_xlog_segno */
values[colIdx++] = UInt64GetDatum(currentXlogSegno);
/* newest_xlog_segno */
/* inited_xlog_segno */
values[colIdx++] = UInt64GetDatum(GetNewestXLOGSegNo(t_thrd.proc_cxt.DataDir));
/* last_reset_time */
isnulls[colIdx] = (lastResetTime == 0);

2
src/include/catalog/upgrade_sql/upgrade_catalog_maindb/upgrade-post_catalog_maindb_92_917.sql
View File

@ -50,7 +50,7 @@ CREATE FUNCTION pg_catalog.gs_stat_walrecvwriter(
out avg_sync_time xid,
out avg_sync_bytes xid,
out current_xlog_segno xid,
out newest_xlog_segno xid,
out inited_xlog_segno xid,
out last_reset_time timestamptz,
out cur_time timestamptz
)

2
src/include/catalog/upgrade_sql/upgrade_catalog_otherdb/upgrade-post_catalog_otherdb_92_917.sql
View File

@ -50,7 +50,7 @@ CREATE FUNCTION pg_catalog.gs_stat_walrecvwriter(
out avg_sync_time xid,
out avg_sync_bytes xid,
out current_xlog_segno xid,
out newest_xlog_segno xid,
out inited_xlog_segno xid,
out last_reset_time timestamptz,
out cur_time timestamptz
)

6
src/test/regress/output/component_view_enhancements.source
View File

@ -106,19 +106,19 @@ ERROR: illegal value "4" for parameter "operation".
HINT: -1: disable, 0: reset, 1: enable, 2: get
-- wal recvwriter
select * from gs_stat_walrecvwriter();
--? is_enable_stat | total_write_bytes | write_times | total_write_time | avg_write_time | avg_write_bytes | total_sync_bytes | sync_times | total_sync_time | avg_sync_time | avg_sync_bytes | current_xlog_segno | newest_xlog_segno | last_reset_time |.*
--? is_enable_stat | total_write_bytes | write_times | total_write_time | avg_write_time | avg_write_bytes | total_sync_bytes | sync_times | total_sync_time | avg_sync_time | avg_sync_bytes | current_xlog_segno | inited_xlog_segno | last_reset_time |.*
--?.*
--? f | 0 | 0 | 0 | | | 0 | 0 | 0 | | | 0 | 2 | |.*
(1 row)
select * from gs_stat_walrecvwriter(1);
--? is_enable_stat | total_write_bytes | write_times | total_write_time | avg_write_time | avg_write_bytes | total_sync_bytes | sync_times | total_sync_time | avg_sync_time | avg_sync_bytes | current_xlog_segno | newest_xlog_segno | last_reset_time |.*
--? is_enable_stat | total_write_bytes | write_times | total_write_time | avg_write_time | avg_write_bytes | total_sync_bytes | sync_times | total_sync_time | avg_sync_time | avg_sync_bytes | current_xlog_segno | inited_xlog_segno | last_reset_time |.*
--?.*
--? t | 0 | 0 | 0 | | | 0 | 0 | 0 | | | 0 | 2 | |.*
(1 row)
select * from gs_stat_walrecvwriter(2);
--? is_enable_stat | total_write_bytes | write_times | total_write_time | avg_write_time | avg_write_bytes | total_sync_bytes | sync_times | total_sync_time | avg_sync_time | avg_sync_bytes | current_xlog_segno | newest_xlog_segno | last_reset_time |.*
--? is_enable_stat | total_write_bytes | write_times | total_write_time | avg_write_time | avg_write_bytes | total_sync_bytes | sync_times | total_sync_time | avg_sync_time | avg_sync_bytes | current_xlog_segno | inited_xlog_segno | last_reset_time |.*
--?.*
--? t | 0 | 0 | 0 | | | 0 | 0 | 0 | | | 0 | 2 | |.*
(1 row)