| /dports/databases/pgbackrest/pgbackrest-release-2.35/src/command/archive/ |
| H A D | common.c | 83 ASSERT(walSegment != NULL); in archiveAsyncStatus()
194 const String *errorFile = walSegment == NULL ? STATUS_FILE_GLOBAL_STR : walSegment; in archiveAsyncStatusErrorWrite()
217 ASSERT(walSegment != NULL); in archiveAsyncStatusOkWrite()
303 walIsPartial(const String *walSegment) in walIsPartial() argument
309 ASSERT(walSegment != NULL); in walIsPartial()
310 ASSERT(walIsSegment(walSegment)); in walIsPartial()
379 walIsSegment(const String *walSegment) in walIsSegment() argument
385 ASSERT(walSegment != NULL); in walIsSegment()
415 ASSERT(walSegment != NULL); in walSegmentFind()
416 ASSERT(walIsSegment(walSegment)); in walSegmentFind()
[all …]
|
| H A D | common.h | 74 bool archiveAsyncStatus(ArchiveMode archiveMode, const String *walSegment, bool throwOnError, bool …
77 void archiveAsyncStatusOkWrite(ArchiveMode archiveMode, const String *walSegment, const String *war…
80 void archiveAsyncStatusErrorWrite(ArchiveMode archiveMode, const String *walSegment, int code, cons…
89 bool walIsPartial(const String *walSegment);
92 bool walIsSegment(const String *walSegment);
100 String *walSegmentFind(const Storage *storage, const String *archiveId, const String *walSegment, T…
103 String *walSegmentNext(const String *walSegment, size_t walSegmentSize, unsigned int pgVersion);
|
| /dports/databases/pgbackrest/pgbackrest-release-2.35/src/command/archive/get/ |
| H A D | get.c | 525 FUNCTION_LOG_PARAM(STRING, walSegment); in queueNeed()
532 ASSERT(walSegment != NULL); in queueNeed()
542 found ? walSegmentNext(walSegment, walSegmentSize, pgVersion) : walSegment; in queueNeed()
625 String *walSegment = strBase(strLstGet(commandParam, 0)); in cmdArchiveGet() local
632 if (cfgOptionBool(cfgOptArchiveAsync) && walIsSegment(walSegment)) in cmdArchiveGet()
692 LOG_INFO_FMT(FOUND_IN_ARCHIVE_MSG " asynchronously", strZ(walSegment)); in cmdArchiveGet()
743 archiveAsyncErrorClear(archiveModeGet, walSegment); in cmdArchiveGet()
786 strLstAdd(archiveRequestList, walSegment); in cmdArchiveGet()
821 LOG_INFO_FMT(UNABLE_TO_FIND_IN_ARCHIVE_MSG, strZ(walSegment)); in cmdArchiveGet()
944 const String *walSegment = varStr(protocolParallelJobKey(job)); in cmdArchiveGetAsync() local
[all …]
|
| /dports/databases/pgbackrest/pgbackrest-release-2.35/src/command/check/ |
| H A D | check.c | 149 const String *walSegment = dbWalSwitch(dbGroup.primary); in checkPrimary() local
158 … storageRepo, repoArchiveId[repoIdx], walSegment, cfgOptionUInt64(cfgOptArchiveTimeout)); in checkPrimary()
161 "WAL segment %s successfully archived to '%s' on repo%u", strZ(walSegment), in checkPrimary()
|
| /dports/databases/pgbackrest/pgbackrest-release-2.35/src/command/verify/ |
| H A D | verify.c | 557 String *walSegment = strSubN(strLstGet(walFileList, walFileIdx), 0, WAL_SEGMENT_NAME_SIZE); in verifyCreateArchiveIdRange() local
561 if (archiveIdResult->pgWalInfo.version <= PG_VERSION_92 && strEndsWithZ(walSegment, "FF")) in verifyCreateArchiveIdRange()
564 … errorTypeCode(&FileInvalidError), "invalid WAL '%s' for '%s' exists, skipping", strZ(walSegment), in verifyCreateArchiveIdRange()
577 … if (strEq(walSegment, strSubN(strLstGet(walFileList, walFileIdx + 1), 0, WAL_SEGMENT_NAME_SIZE))) in verifyCreateArchiveIdRange()
590 … if (strEq(walSegment, strSubN(strLstGet(walFileList, walFileIdx), 0, WAL_SEGMENT_NAME_SIZE))) in verifyCreateArchiveIdRange()
604 walSegment)) in verifyCreateArchiveIdRange()
611 .start = strDup(walSegment), in verifyCreateArchiveIdRange()
612 .stop = strDup(walSegment), in verifyCreateArchiveIdRange()
629 walRange->stop = strDup(walSegment); in verifyCreateArchiveIdRange()
1217 ASSERT(walSegment != NULL); in verifyAddInvalidWalFile()
[all …]
|
| /dports/databases/pgbackrest/pgbackrest-release-2.35/test/src/module/command/ |
| H A D | archiveCommonTest.c | 132 const String *walSegment = STRDEF("000000010000000100000001"); in testRun() local
138 …archiveAsyncStatusErrorWrite(archiveModeGet, walSegment, 25, STRDEF("error message")), "write segm… in testRun()
152 … TEST_RESULT_VOID(archiveAsyncStatusOkWrite(archiveModeGet, walSegment, NULL), "write ok file"); in testRun()
156 …TEST_RESULT_VOID(archiveAsyncStatusOkWrite(archiveModeGet, walSegment, STRDEF("WARNING")), "write … in testRun()
|
| /dports/databases/pgbackrest/pgbackrest-release-2.35/src/postgres/ |
| H A D | interface.c | 527 pgLsnFromWalSegment(const String *walSegment, unsigned int walSegmentSize) in pgLsnFromWalSegment() argument
530 FUNCTION_TEST_PARAM(STRING, walSegment); in pgLsnFromWalSegment()
534 ASSERT(walSegment != NULL); in pgLsnFromWalSegment()
535 ASSERT(strSize(walSegment) == 24); in pgLsnFromWalSegment()
539 (cvtZToUInt64Base(strZ(strSubN(walSegment, 8, 8)), 16) << 32) + in pgLsnFromWalSegment()
540 (cvtZToUInt64Base(strZ(strSubN(walSegment, 16, 8)), 16) * walSegmentSize)); in pgLsnFromWalSegment()
|
| H A D | interface.h | 150 uint64_t pgLsnFromWalSegment(const String *walSegment, unsigned int walSegmentSize);
|
| /dports/databases/pgbackrest/pgbackrest-release-2.35/test/lib/pgBackRestTest/Module/Mock/ |
| H A D | MockArchiveTest.pm | 132 my $strSourceFile1 = $self->walSegment(1, 1, 1);
151 my $strSourceFile = $self->walSegment(1, 1, 1);
201 $strSourceFile = $self->walSegment(1, 1, 2);
|
| H A D | MockStanzaTest.pm | 125 my $strArchiveFile = $self->walSegment(1, 1, 1);
148 $strArchiveFile = $self->walSegment(1, 1, 2);
|
| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/prometheus/prometheus/documentation/prometheus-mixin/ |
| H A D | dashboards.libsonnet | 222 local walSegment =
365 .addPanel(walSegment)
|
| /dports/devel/spark/spark-2.1.1/streaming/src/test/scala/org/apache/spark/streaming/ |
| H A D | ReceivedBlockHandlerSuite.scala | 171 val loggedData = walSegments.flatMap { walSegment =>
172 val fileSegment = walSegment.asInstanceOf[FileBasedWriteAheadLogSegment]
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/prometheus/prometheus/documentation/prometheus-mixin/ |
| H A D | dashboards.libsonnet | 229 local walSegment =
375 .addPanel(walSegment)
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/prometheus/prometheus/documentation/prometheus-mixin/ |
| H A D | dashboards.libsonnet | 229 local walSegment =
375 .addPanel(walSegment)
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/documentation/prometheus-mixin/ |
| H A D | dashboards.libsonnet | 229 local walSegment =
375 .addPanel(walSegment)
|
| /dports/databases/pgbackrest/pgbackrest-release-2.35/test/lib/pgBackRestTest/Env/ |
| H A D | HostEnvTest.pm | 412 sub walSegment subroutine
|
| /dports/databases/pgbackrest/pgbackrest-release-2.35/src/command/backup/ |
| H A D | backup.c | 1736 const String *walSegment = strLstGet(walSegmentList, walSegmentIdx); in backupArchiveCheckCopy() local
1740 … storageRepo(), archiveId, walSegment, cfgOptionUInt64(cfgOptArchiveTimeout)); in backupArchiveCheckCopy()
1745 LOG_DETAIL_FMT("copy segment %s to backup", strZ(walSegment)); in backupArchiveCheckCopy()
1783 …FEST_TARGET_PGDATA "/%s/%s", strZ(pgWalPath(manifestData(manifest)->pgVersion)), strZ(walSegment)); in backupArchiveCheckCopy()
|