| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/angle/src/libANGLE/renderer/vulkan/ |
| H A D | SecondaryCommandBuffer.h | 767 uint8_t *writePtr; in bindDescriptorSets() local
777 writePtr = storePointerParameter(writePtr, descriptorSets, descSize); in bindDescriptorSets()
804 uint8_t *writePtr; in bindTransformFeedbackBuffers() local
825 uint8_t *writePtr; in bindVertexBuffers() local
872 uint8_t *writePtr; in clearAttachments() local
918 uint8_t *writePtr; in copyBuffer() local
1162 uint8_t *writePtr; in pipelineBarrier() local
1187 uint8_t *writePtr; in pushConstants() local
1252 uint8_t *writePtr; in waitEvents() local
1259 &writePtr); in waitEvents()
[all …]
|
| /dports/databases/postgresql13-server/postgresql-13.5/src/backend/replication/ |
| H A D | syncrep.c | 104 static bool SyncRepGetSyncRecPtr(XLogRecPtr *writePtr,
432 XLogRecPtr writePtr; in SyncRepReleaseWaiters() local
506 if (walsndctl->lsn[SYNC_REP_WAIT_WRITE] < writePtr) in SyncRepReleaseWaiters()
508 walsndctl->lsn[SYNC_REP_WAIT_WRITE] = writePtr; in SyncRepReleaseWaiters()
525 numwrite, (uint32) (writePtr >> 32), (uint32) writePtr, in SyncRepReleaseWaiters()
549 *writePtr = InvalidXLogRecPtr; in SyncRepGetSyncRecPtr()
615 SyncRepGetOldestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetOldestSyncRecPtr() argument
634 if (XLogRecPtrIsInvalid(*writePtr) || *writePtr > write) in SyncRepGetOldestSyncRecPtr()
635 *writePtr = write; in SyncRepGetOldestSyncRecPtr()
648 SyncRepGetNthLatestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetNthLatestSyncRecPtr() argument
[all …]
|
| /dports/databases/postgresql13-pltcl/postgresql-13.5/src/backend/replication/ |
| H A D | syncrep.c | 104 static bool SyncRepGetSyncRecPtr(XLogRecPtr *writePtr,
432 XLogRecPtr writePtr; in SyncRepReleaseWaiters() local
506 if (walsndctl->lsn[SYNC_REP_WAIT_WRITE] < writePtr) in SyncRepReleaseWaiters()
508 walsndctl->lsn[SYNC_REP_WAIT_WRITE] = writePtr; in SyncRepReleaseWaiters()
525 numwrite, (uint32) (writePtr >> 32), (uint32) writePtr, in SyncRepReleaseWaiters()
549 *writePtr = InvalidXLogRecPtr; in SyncRepGetSyncRecPtr()
615 SyncRepGetOldestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetOldestSyncRecPtr() argument
634 if (XLogRecPtrIsInvalid(*writePtr) || *writePtr > write) in SyncRepGetOldestSyncRecPtr()
635 *writePtr = write; in SyncRepGetOldestSyncRecPtr()
648 SyncRepGetNthLatestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetNthLatestSyncRecPtr() argument
[all …]
|
| /dports/databases/postgresql13-client/postgresql-13.5/src/backend/replication/ |
| H A D | syncrep.c | 104 static bool SyncRepGetSyncRecPtr(XLogRecPtr *writePtr,
432 XLogRecPtr writePtr;
506 if (walsndctl->lsn[SYNC_REP_WAIT_WRITE] < writePtr)
508 walsndctl->lsn[SYNC_REP_WAIT_WRITE] = writePtr;
525 numwrite, (uint32) (writePtr >> 32), (uint32) writePtr,
549 *writePtr = InvalidXLogRecPtr;
615 SyncRepGetOldestSyncRecPtr(XLogRecPtr *writePtr,
634 if (XLogRecPtrIsInvalid(*writePtr) || *writePtr > write)
635 *writePtr = write;
648 SyncRepGetNthLatestSyncRecPtr(XLogRecPtr *writePtr,
[all …]
|
| /dports/databases/postgresql13-contrib/postgresql-13.5/src/backend/replication/ |
| H A D | syncrep.c | 104 static bool SyncRepGetSyncRecPtr(XLogRecPtr *writePtr,
432 XLogRecPtr writePtr;
506 if (walsndctl->lsn[SYNC_REP_WAIT_WRITE] < writePtr)
508 walsndctl->lsn[SYNC_REP_WAIT_WRITE] = writePtr;
525 numwrite, (uint32) (writePtr >> 32), (uint32) writePtr,
549 *writePtr = InvalidXLogRecPtr;
615 SyncRepGetOldestSyncRecPtr(XLogRecPtr *writePtr,
634 if (XLogRecPtrIsInvalid(*writePtr) || *writePtr > write)
635 *writePtr = write;
648 SyncRepGetNthLatestSyncRecPtr(XLogRecPtr *writePtr,
[all …]
|
| /dports/databases/postgresql13-docs/postgresql-13.5/src/backend/replication/ |
| H A D | syncrep.c | 104 static bool SyncRepGetSyncRecPtr(XLogRecPtr *writePtr,
432 XLogRecPtr writePtr; in SyncRepReleaseWaiters() local
506 if (walsndctl->lsn[SYNC_REP_WAIT_WRITE] < writePtr) in SyncRepReleaseWaiters()
508 walsndctl->lsn[SYNC_REP_WAIT_WRITE] = writePtr; in SyncRepReleaseWaiters()
525 numwrite, (uint32) (writePtr >> 32), (uint32) writePtr, in SyncRepReleaseWaiters()
549 *writePtr = InvalidXLogRecPtr; in SyncRepGetSyncRecPtr()
615 SyncRepGetOldestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetOldestSyncRecPtr() argument
634 if (XLogRecPtrIsInvalid(*writePtr) || *writePtr > write) in SyncRepGetOldestSyncRecPtr()
635 *writePtr = write; in SyncRepGetOldestSyncRecPtr()
648 SyncRepGetNthLatestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetNthLatestSyncRecPtr() argument
[all …]
|
| /dports/databases/postgresql13-plpython/postgresql-13.5/src/backend/replication/ |
| H A D | syncrep.c | 104 static bool SyncRepGetSyncRecPtr(XLogRecPtr *writePtr,
432 XLogRecPtr writePtr; in SyncRepReleaseWaiters() local
506 if (walsndctl->lsn[SYNC_REP_WAIT_WRITE] < writePtr) in SyncRepReleaseWaiters()
508 walsndctl->lsn[SYNC_REP_WAIT_WRITE] = writePtr; in SyncRepReleaseWaiters()
525 numwrite, (uint32) (writePtr >> 32), (uint32) writePtr, in SyncRepReleaseWaiters()
549 *writePtr = InvalidXLogRecPtr; in SyncRepGetSyncRecPtr()
615 SyncRepGetOldestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetOldestSyncRecPtr() argument
634 if (XLogRecPtrIsInvalid(*writePtr) || *writePtr > write) in SyncRepGetOldestSyncRecPtr()
635 *writePtr = write; in SyncRepGetOldestSyncRecPtr()
648 SyncRepGetNthLatestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetNthLatestSyncRecPtr() argument
[all …]
|
| /dports/databases/postgresql13-plperl/postgresql-13.5/src/backend/replication/ |
| H A D | syncrep.c | 104 static bool SyncRepGetSyncRecPtr(XLogRecPtr *writePtr,
432 XLogRecPtr writePtr; in SyncRepReleaseWaiters() local
506 if (walsndctl->lsn[SYNC_REP_WAIT_WRITE] < writePtr) in SyncRepReleaseWaiters()
508 walsndctl->lsn[SYNC_REP_WAIT_WRITE] = writePtr; in SyncRepReleaseWaiters()
525 numwrite, (uint32) (writePtr >> 32), (uint32) writePtr, in SyncRepReleaseWaiters()
549 *writePtr = InvalidXLogRecPtr; in SyncRepGetSyncRecPtr()
615 SyncRepGetOldestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetOldestSyncRecPtr() argument
634 if (XLogRecPtrIsInvalid(*writePtr) || *writePtr > write) in SyncRepGetOldestSyncRecPtr()
635 *writePtr = write; in SyncRepGetOldestSyncRecPtr()
648 SyncRepGetNthLatestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetNthLatestSyncRecPtr() argument
[all …]
|
| /dports/databases/postgresql14-pltcl/postgresql-14.1/src/backend/replication/ |
| H A D | syncrep.c | 104 static bool SyncRepGetSyncRecPtr(XLogRecPtr *writePtr,
443 XLogRecPtr writePtr; in SyncRepReleaseWaiters() local
517 if (walsndctl->lsn[SYNC_REP_WAIT_WRITE] < writePtr) in SyncRepReleaseWaiters()
519 walsndctl->lsn[SYNC_REP_WAIT_WRITE] = writePtr; in SyncRepReleaseWaiters()
536 numwrite, LSN_FORMAT_ARGS(writePtr), in SyncRepReleaseWaiters()
560 *writePtr = InvalidXLogRecPtr; in SyncRepGetSyncRecPtr()
626 SyncRepGetOldestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetOldestSyncRecPtr() argument
645 if (XLogRecPtrIsInvalid(*writePtr) || *writePtr > write) in SyncRepGetOldestSyncRecPtr()
646 *writePtr = write; in SyncRepGetOldestSyncRecPtr()
659 SyncRepGetNthLatestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetNthLatestSyncRecPtr() argument
[all …]
|
| /dports/databases/postgresql14-server/postgresql-14.1/src/backend/replication/ |
| H A D | syncrep.c | 104 static bool SyncRepGetSyncRecPtr(XLogRecPtr *writePtr,
443 XLogRecPtr writePtr; in SyncRepReleaseWaiters() local
517 if (walsndctl->lsn[SYNC_REP_WAIT_WRITE] < writePtr) in SyncRepReleaseWaiters()
519 walsndctl->lsn[SYNC_REP_WAIT_WRITE] = writePtr; in SyncRepReleaseWaiters()
536 numwrite, LSN_FORMAT_ARGS(writePtr), in SyncRepReleaseWaiters()
560 *writePtr = InvalidXLogRecPtr; in SyncRepGetSyncRecPtr()
626 SyncRepGetOldestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetOldestSyncRecPtr() argument
645 if (XLogRecPtrIsInvalid(*writePtr) || *writePtr > write) in SyncRepGetOldestSyncRecPtr()
646 *writePtr = write; in SyncRepGetOldestSyncRecPtr()
659 SyncRepGetNthLatestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetNthLatestSyncRecPtr() argument
[all …]
|
| /dports/databases/postgresql14-plpython/postgresql-14.1/src/backend/replication/ |
| H A D | syncrep.c | 104 static bool SyncRepGetSyncRecPtr(XLogRecPtr *writePtr,
443 XLogRecPtr writePtr; in SyncRepReleaseWaiters() local
517 if (walsndctl->lsn[SYNC_REP_WAIT_WRITE] < writePtr) in SyncRepReleaseWaiters()
519 walsndctl->lsn[SYNC_REP_WAIT_WRITE] = writePtr; in SyncRepReleaseWaiters()
536 numwrite, LSN_FORMAT_ARGS(writePtr), in SyncRepReleaseWaiters()
560 *writePtr = InvalidXLogRecPtr; in SyncRepGetSyncRecPtr()
626 SyncRepGetOldestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetOldestSyncRecPtr() argument
645 if (XLogRecPtrIsInvalid(*writePtr) || *writePtr > write) in SyncRepGetOldestSyncRecPtr()
646 *writePtr = write; in SyncRepGetOldestSyncRecPtr()
659 SyncRepGetNthLatestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetNthLatestSyncRecPtr() argument
[all …]
|
| /dports/databases/postgresql14-docs/postgresql-14.1/src/backend/replication/ |
| H A D | syncrep.c | 104 static bool SyncRepGetSyncRecPtr(XLogRecPtr *writePtr,
443 XLogRecPtr writePtr; in SyncRepReleaseWaiters() local
517 if (walsndctl->lsn[SYNC_REP_WAIT_WRITE] < writePtr) in SyncRepReleaseWaiters()
519 walsndctl->lsn[SYNC_REP_WAIT_WRITE] = writePtr; in SyncRepReleaseWaiters()
536 numwrite, LSN_FORMAT_ARGS(writePtr), in SyncRepReleaseWaiters()
560 *writePtr = InvalidXLogRecPtr; in SyncRepGetSyncRecPtr()
626 SyncRepGetOldestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetOldestSyncRecPtr() argument
645 if (XLogRecPtrIsInvalid(*writePtr) || *writePtr > write) in SyncRepGetOldestSyncRecPtr()
646 *writePtr = write; in SyncRepGetOldestSyncRecPtr()
659 SyncRepGetNthLatestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetNthLatestSyncRecPtr() argument
[all …]
|
| /dports/databases/postgresql14-plperl/postgresql-14.1/src/backend/replication/ |
| H A D | syncrep.c | 104 static bool SyncRepGetSyncRecPtr(XLogRecPtr *writePtr,
443 XLogRecPtr writePtr; in SyncRepReleaseWaiters() local
517 if (walsndctl->lsn[SYNC_REP_WAIT_WRITE] < writePtr) in SyncRepReleaseWaiters()
519 walsndctl->lsn[SYNC_REP_WAIT_WRITE] = writePtr; in SyncRepReleaseWaiters()
536 numwrite, LSN_FORMAT_ARGS(writePtr), in SyncRepReleaseWaiters()
560 *writePtr = InvalidXLogRecPtr; in SyncRepGetSyncRecPtr()
626 SyncRepGetOldestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetOldestSyncRecPtr() argument
645 if (XLogRecPtrIsInvalid(*writePtr) || *writePtr > write) in SyncRepGetOldestSyncRecPtr()
646 *writePtr = write; in SyncRepGetOldestSyncRecPtr()
659 SyncRepGetNthLatestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetNthLatestSyncRecPtr() argument
[all …]
|
| /dports/databases/postgresql14-client/postgresql-14.1/src/backend/replication/ |
| H A D | syncrep.c | 104 static bool SyncRepGetSyncRecPtr(XLogRecPtr *writePtr,
443 XLogRecPtr writePtr; in SyncRepReleaseWaiters() local
517 if (walsndctl->lsn[SYNC_REP_WAIT_WRITE] < writePtr) in SyncRepReleaseWaiters()
519 walsndctl->lsn[SYNC_REP_WAIT_WRITE] = writePtr; in SyncRepReleaseWaiters()
536 numwrite, LSN_FORMAT_ARGS(writePtr), in SyncRepReleaseWaiters()
560 *writePtr = InvalidXLogRecPtr; in SyncRepGetSyncRecPtr()
626 SyncRepGetOldestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetOldestSyncRecPtr() argument
645 if (XLogRecPtrIsInvalid(*writePtr) || *writePtr > write) in SyncRepGetOldestSyncRecPtr()
646 *writePtr = write; in SyncRepGetOldestSyncRecPtr()
659 SyncRepGetNthLatestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetNthLatestSyncRecPtr() argument
[all …]
|
| /dports/databases/postgresql14-contrib/postgresql-14.1/src/backend/replication/ |
| H A D | syncrep.c | 104 static bool SyncRepGetSyncRecPtr(XLogRecPtr *writePtr,
443 XLogRecPtr writePtr; in SyncRepReleaseWaiters() local
517 if (walsndctl->lsn[SYNC_REP_WAIT_WRITE] < writePtr) in SyncRepReleaseWaiters()
519 walsndctl->lsn[SYNC_REP_WAIT_WRITE] = writePtr; in SyncRepReleaseWaiters()
536 numwrite, LSN_FORMAT_ARGS(writePtr), in SyncRepReleaseWaiters()
560 *writePtr = InvalidXLogRecPtr; in SyncRepGetSyncRecPtr()
626 SyncRepGetOldestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetOldestSyncRecPtr() argument
645 if (XLogRecPtrIsInvalid(*writePtr) || *writePtr > write) in SyncRepGetOldestSyncRecPtr()
646 *writePtr = write; in SyncRepGetOldestSyncRecPtr()
659 SyncRepGetNthLatestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetNthLatestSyncRecPtr() argument
[all …]
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/les/flowcontrol/ |
| H A D | logger.go | 30 writePtr, delPtr uint64 member
51 for l.delPtr < l.writePtr && l.events[l.delPtr].time <= keepAfter {
55 l.events[l.writePtr] = logEvent{now, event}
56 l.writePtr++
61 for i := l.delPtr; i < l.writePtr; i++ {
|
| /dports/converters/wkhtmltopdf/qt-5db36ec/src/3rdparty/webkit/Source/JavaScriptCore/assembler/ |
| H A D | LinkBuffer.h | 232 int writePtr = 0; in linkCode() local
236 int offset = readPtr - writePtr; in linkCode()
241 memcpy(outData + writePtr, inData + readPtr, regionSize); in linkCode()
244 writePtr += regionSize; in linkCode()
254 …mpLinkType jumpLinkType = m_assembler->computeJumpType(jumpsToLink[i], outData + writePtr, target); in linkCode()
260 writePtr -= delta; in linkCode()
261 … m_assembler->recordLinkOffsets(jumpsToLink[i].from() - delta, readPtr, readPtr - writePtr); in linkCode()
264 jumpsToLink[i].setFrom(writePtr); in linkCode()
267 memcpy(outData + writePtr, inData + readPtr, initialSize - readPtr); in linkCode()
268 m_assembler->recordLinkOffsets(readPtr, initialSize, readPtr - writePtr); in linkCode()
[all …]
|
| /dports/lang/smalltalk/smalltalk-3.2.5/kernel/ |
| H A D | FileStream.st | 268 writePtr isNil
271 writePtr := ptr.
300 writePtr notNil
317 writePtr := nil
584 [writePtr notNil
593 [writePtr notNil
605 writePtr := nil
614 writePtr := nil
621 ^writePtr notNil
636 writePtr isNil
[all …]
|
| /dports/biology/velvet/velvet_1.2.10/contrib/MetaVelvet-1.2.01/Velvet-1.1.06/ |
| H A D | preGraph.c | 551 writePtr = _new; in mergeDescriptors_pg()
578 writePtr++; in mergeDescriptors_pg()
618 writePtr++; in mergeDescriptors_pg()
668 writePtr = _new; in mergeDescriptorsH2H_pg()
697 writePtr++; in mergeDescriptorsH2H_pg()
743 writePtr++; in mergeDescriptorsH2H_pg()
790 writePtr = _new; in mergeDescriptorsF2F_pg()
829 writePtr++; in mergeDescriptorsF2F_pg()
873 writePtr++; in mergeDescriptorsF2F_pg()
1326 (*writePtr)++; in appendPositiveDescriptor_pg()
[all …]
|
| /dports/biology/velvet/velvet_1.2.10/src/ |
| H A D | preGraph.c | 545 writePtr = new; in mergeDescriptors_pg()
572 writePtr++; in mergeDescriptors_pg()
612 writePtr++; in mergeDescriptors_pg()
662 writePtr = new; in mergeDescriptorsH2H_pg()
691 writePtr++; in mergeDescriptorsH2H_pg()
737 writePtr++; in mergeDescriptorsH2H_pg()
784 writePtr = new; in mergeDescriptorsF2F_pg()
823 writePtr++; in mergeDescriptorsF2F_pg()
867 writePtr++; in mergeDescriptorsF2F_pg()
1329 (*writePtr)++; in appendPositiveDescriptor_pg()
[all …]
|
| /dports/databases/postgresql10-plperl/postgresql-10.19/src/backend/replication/ |
| H A D | syncrep.c | 104 static bool SyncRepGetSyncRecPtr(XLogRecPtr *writePtr,
428 XLogRecPtr writePtr; in SyncRepReleaseWaiters() local
502 if (walsndctl->lsn[SYNC_REP_WAIT_WRITE] < writePtr) in SyncRepReleaseWaiters()
504 walsndctl->lsn[SYNC_REP_WAIT_WRITE] = writePtr; in SyncRepReleaseWaiters()
521 numwrite, (uint32) (writePtr >> 32), (uint32) writePtr, in SyncRepReleaseWaiters()
545 *writePtr = InvalidXLogRecPtr; in SyncRepGetSyncRecPtr()
611 SyncRepGetOldestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetOldestSyncRecPtr() argument
630 if (XLogRecPtrIsInvalid(*writePtr) || *writePtr > write) in SyncRepGetOldestSyncRecPtr()
631 *writePtr = write; in SyncRepGetOldestSyncRecPtr()
644 SyncRepGetNthLatestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetNthLatestSyncRecPtr() argument
[all …]
|
| /dports/databases/postgresql10-pltcl/postgresql-10.19/src/backend/replication/ |
| H A D | syncrep.c | 104 static bool SyncRepGetSyncRecPtr(XLogRecPtr *writePtr,
428 XLogRecPtr writePtr; in SyncRepReleaseWaiters() local
502 if (walsndctl->lsn[SYNC_REP_WAIT_WRITE] < writePtr) in SyncRepReleaseWaiters()
504 walsndctl->lsn[SYNC_REP_WAIT_WRITE] = writePtr; in SyncRepReleaseWaiters()
521 numwrite, (uint32) (writePtr >> 32), (uint32) writePtr, in SyncRepReleaseWaiters()
545 *writePtr = InvalidXLogRecPtr; in SyncRepGetSyncRecPtr()
611 SyncRepGetOldestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetOldestSyncRecPtr() argument
630 if (XLogRecPtrIsInvalid(*writePtr) || *writePtr > write) in SyncRepGetOldestSyncRecPtr()
631 *writePtr = write; in SyncRepGetOldestSyncRecPtr()
644 SyncRepGetNthLatestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetNthLatestSyncRecPtr() argument
[all …]
|
| /dports/databases/postgresql11-client/postgresql-11.14/src/backend/replication/ |
| H A D | syncrep.c | 104 static bool SyncRepGetSyncRecPtr(XLogRecPtr *writePtr,
426 XLogRecPtr writePtr; in SyncRepReleaseWaiters() local
500 if (walsndctl->lsn[SYNC_REP_WAIT_WRITE] < writePtr) in SyncRepReleaseWaiters()
502 walsndctl->lsn[SYNC_REP_WAIT_WRITE] = writePtr; in SyncRepReleaseWaiters()
519 numwrite, (uint32) (writePtr >> 32), (uint32) writePtr, in SyncRepReleaseWaiters()
543 *writePtr = InvalidXLogRecPtr; in SyncRepGetSyncRecPtr()
609 SyncRepGetOldestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetOldestSyncRecPtr() argument
628 if (XLogRecPtrIsInvalid(*writePtr) || *writePtr > write) in SyncRepGetOldestSyncRecPtr()
629 *writePtr = write; in SyncRepGetOldestSyncRecPtr()
642 SyncRepGetNthLatestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetNthLatestSyncRecPtr() argument
[all …]
|
| /dports/databases/postgresql10-client/postgresql-10.19/src/backend/replication/ |
| H A D | syncrep.c | 104 static bool SyncRepGetSyncRecPtr(XLogRecPtr *writePtr,
428 XLogRecPtr writePtr; in SyncRepReleaseWaiters() local
502 if (walsndctl->lsn[SYNC_REP_WAIT_WRITE] < writePtr) in SyncRepReleaseWaiters()
504 walsndctl->lsn[SYNC_REP_WAIT_WRITE] = writePtr; in SyncRepReleaseWaiters()
521 numwrite, (uint32) (writePtr >> 32), (uint32) writePtr, in SyncRepReleaseWaiters()
545 *writePtr = InvalidXLogRecPtr; in SyncRepGetSyncRecPtr()
611 SyncRepGetOldestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetOldestSyncRecPtr() argument
630 if (XLogRecPtrIsInvalid(*writePtr) || *writePtr > write) in SyncRepGetOldestSyncRecPtr()
631 *writePtr = write; in SyncRepGetOldestSyncRecPtr()
644 SyncRepGetNthLatestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetNthLatestSyncRecPtr() argument
[all …]
|
| /dports/databases/postgresql10-contrib/postgresql-10.19/src/backend/replication/ |
| H A D | syncrep.c | 104 static bool SyncRepGetSyncRecPtr(XLogRecPtr *writePtr,
428 XLogRecPtr writePtr; in SyncRepReleaseWaiters() local
502 if (walsndctl->lsn[SYNC_REP_WAIT_WRITE] < writePtr) in SyncRepReleaseWaiters()
504 walsndctl->lsn[SYNC_REP_WAIT_WRITE] = writePtr; in SyncRepReleaseWaiters()
521 numwrite, (uint32) (writePtr >> 32), (uint32) writePtr, in SyncRepReleaseWaiters()
545 *writePtr = InvalidXLogRecPtr; in SyncRepGetSyncRecPtr()
611 SyncRepGetOldestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetOldestSyncRecPtr() argument
630 if (XLogRecPtrIsInvalid(*writePtr) || *writePtr > write) in SyncRepGetOldestSyncRecPtr()
631 *writePtr = write; in SyncRepGetOldestSyncRecPtr()
644 SyncRepGetNthLatestSyncRecPtr(XLogRecPtr *writePtr, in SyncRepGetNthLatestSyncRecPtr() argument
[all …]
|