Reliable sender retaining owning transfer parts and tombstones until application ACK. 更多...

#include <PixelWorldTransport.h>

Public 成员函数
eve::Result< std::vector< PixelChunkTransferPart > >	capture (const eve::pixelworld::PixelWorld &source, eve::pixelworld::PixelChunkRegion interest)
	Capture and enqueue one atomic revision transfer, split into bounded owning parts.

std::vector< PixelChunkTransferPart >	pendingParts () const
	Return every unacknowledged part in canonical transfer/part order for transmission.

eve::Result< PixelChunkAckReceipt >	acknowledge (PixelChunkTransferAck ack)
	Release cumulatively acknowledged transfers and their retained tombstones.

std::size_t	inFlightTransferCount () const noexcept
	Number of unacknowledged atomic transfers.

std::size_t	retainedTombstoneCount () const noexcept
	Number of tombstones retained specifically for possible retransmission.

静态 Public 成员函数
static eve::Result< ReliablePixelChunkSender >	create (std::uint64_t streamId, PixelChunkTransportConfig config={})
	Validate policy and create a fresh nonzero stream session.

详细描述

Reliable sender retaining owning transfer parts and tombstones until application ACK.

The sender is transport-neutral: callers may send pendingParts() through EVNetwork reliable messages, another socket, or deterministic tests. Cursor state advances only after a transfer fits the bounded in-flight window. Repeated pendingParts() calls are intentional retransmits.

在文件 PixelWorldTransport.h 第 66 行定义.

成员函数说明

◆ acknowledge()

eve::Result< PixelChunkAckReceipt > eve::pixelworld_streaming::ReliablePixelChunkSender::acknowledge ( PixelChunkTransferAck ack )

Release cumulatively acknowledged transfers and their retained tombstones.

在文件 PixelWorldTransport.cpp 第 111 行定义.

引用了 eve::pixelworld_streaming::PixelChunkTransferAck::acknowledgedThrough, eve::pixelworld_streaming::PixelChunkAckReceipt::acknowledgedThrough, eve::pixelworld_streaming::PixelChunkTransferAck::appliedRevision, eve::Conflict, eve::Diagnostic::error(), eve::Result< T >::failure(), eve::pixelworld_streaming::PixelChunkTransferAck::streamId, eve::Result< T >::success(), eve::pixelworld_streaming::PixelChunkAckReceipt::tombstonesReleased , 以及 eve::pixelworld_streaming::PixelChunkAckReceipt::transfersReleased.

◆ capture()

eve::Result< std::vector< PixelChunkTransferPart > > eve::pixelworld_streaming::ReliablePixelChunkSender::capture	(	const eve::pixelworld::PixelWorld &	source,
		eve::pixelworld::PixelChunkRegion	interest
	)

Capture and enqueue one atomic revision transfer, split into bounded owning parts.

在文件 PixelWorldTransport.cpp 第 44 行定义.

引用了 eve::pixelworld_streaming::PixelChunkTransferPart::batch, begin, eve::pixelworld::PixelChunkBatch::catalogFingerprint, eve::pixelworld::PixelChunkBatch::chunks, end, eve::Diagnostic::error(), eve::pixelworld::PixelChunkBatch::fullResync, index, eve::pixelworld_streaming::PixelChunkTransferPart::interest, eve::pixelworld_streaming::PixelChunkTransferPart::partCount, eve::pixelworld_streaming::PixelChunkTransferPart::partIndex, parts, eve::PreconditionViolation, source, eve::pixelworld::PixelChunkBatch::sourceLastEditSequence, eve::pixelworld::PixelChunkBatch::sourceRevision, eve::pixelworld::PixelChunkBatch::sourceSeed, eve::pixelworld::PixelChunkBatch::sourceTick, eve::pixelworld_streaming::PixelChunkTransferPart::streamId , 以及 eve::pixelworld_streaming::PixelChunkTransferPart::transferId.

◆ create()

eve::Result< ReliablePixelChunkSender > eve::pixelworld_streaming::ReliablePixelChunkSender::create	(	std::uint64_t	streamId,
		PixelChunkTransportConfig	config = `{}`
	)

static

Validate policy and create a fresh nonzero stream session.

在文件 PixelWorldTransport.cpp 第 34 行定义.

引用了 eve::Diagnostic::error(), eve::Result< T >::failure(), eve::InvalidArgument, eve::Result< T >::success() , 以及 valid.

◆ inFlightTransferCount()

std::size_t eve::pixelworld_streaming::ReliablePixelChunkSender::inFlightTransferCount ( ) const

noexcept

Number of unacknowledged atomic transfers.

在文件 PixelWorldTransport.cpp 第 145 行定义.

◆ pendingParts()

std::vector< PixelChunkTransferPart > eve::pixelworld_streaming::ReliablePixelChunkSender::pendingParts ( ) const

Return every unacknowledged part in canonical transfer/part order for transmission.

在文件 PixelWorldTransport.cpp 第 102 行定义.

引用了 parts.

◆ retainedTombstoneCount()

std::size_t eve::pixelworld_streaming::ReliablePixelChunkSender::retainedTombstoneCount ( ) const

noexcept

Number of tombstones retained specifically for possible retransmission.

在文件 PixelWorldTransport.cpp 第 149 行定义.

引用了 count , 以及 parts.

该类的文档由以下文件生成:

src/modules/pixelworld/streaming/PixelWorldTransport.h
src/modules/pixelworld/streaming/PixelWorldTransport.cpp

Public 成员函数

静态 Public 成员函数