xssh/ssh_session_tcp

bool xrtSshSessionTcpConfigInit( xsshsessiontcpconfig* pConfig, xsshrole Role );

sshsessiontcpconfiginit obj;
xrtSshSessionTcpConfigInit(&obj, Role);

bool xrtSshSessionTcpInit( xsshsessiontcp* pSession, xnetbufpool* pPool, const xsshsessiontcpconfig* pConfig, uint64 iNowMs );

sshsessiontcpinit obj;
xrtSshSessionTcpInit(&obj, pSession, pPool, iNowMs);

void xrtSshSessionTcpClear(xsshsessiontcp* pSession);

/* 放弃未决事务、释放动态链并清除全部密码状态；不处理 Stream 和外部对象。 */
result = xrtSshSessionTcpClear(pSession);

xsshtransporttcp* xrtSshSessionTcpTransport( xsshsessiontcp* pSession );

/* 返回可直接访问 packet、cipher、rekey 和 TCP 动态缓冲的 transport。 */
result = xrtSshSessionTcpTransport(pSession);

const xsshtransporttcp* xrtSshSessionTcpTransportConst( const xsshsessiontcp* pSession );

/* 返回只读 TCP transport；无效对象返回空。 */
result = xrtSshSessionTcpTransportConst(pSession);

xsshsessioncore* xrtSshSessionTcpCore(xsshsessiontcp* pSession);

/* 返回 KEX、认证和 connection 编排核心，保留全部底层访问能力。 */
result = xrtSshSessionTcpCore(pSession);

const xsshsessioncore* xrtSshSessionTcpCoreConst( const xsshsessiontcp* pSession );

/* 返回只读连接级协议核心；无效对象返回空。 */
result = xrtSshSessionTcpCoreConst(pSession);

xsshsessionphase xrtSshSessionTcpPhase( const xsshsessiontcp* pSession );

/* 返回当前 identification、KEX、认证、connection、rekey 或失败阶段。 */
result = xrtSshSessionTcpPhase(pSession);

xsshsessionaction xrtSshSessionTcpAction( const xsshsessiontcp* pSession );

/* 返回统一的 identification、KEX、认证或 connection 下一动作。 */
result = xrtSshSessionTcpAction(pSession);

xsshcode xrtSshSessionTcpKexBeginWithPrivate( xsshsessiontcp* pSession, xbytesview ServerHostKey, xbytesview PrivateKey );

/* 使用显式 Curve25519 私钥开始当前已就绪的 KEX。 */
result = xrtSshSessionTcpKexBeginWithPrivate(pSession, ServerHostKey, PrivateKey);

xsshcode xrtSshSessionTcpAuthBegin( xsshsessiontcp* pSession, const xsshauthguardpolicy* pPolicy, uint64 iNowMs );

/* 首轮 KEX 完成后开始 USERAUTH；策略和单调时钟仍由调用方提供。 */
result = xrtSshSessionTcpAuthBegin(pSession, pPolicy, iNowMs);

xsshcode xrtSshSessionTcpIdentificationWritePrepare( xsshsessiontcp* pSession, xstrview Version );

/* 同时准备本端版本 transcript 与唯一 identification 线路输出。 */
result = xrtSshSessionTcpIdentificationWritePrepare(pSession, Version);

xsshcode xrtSshSessionTcpWritePrepareWithPadding( xsshsessiontcp* pSession, xbytesview Payload, xsshchannelcore* pChannel, xsshreplyqueue* pReplies, uint64 iReplyToken, xsshpaddingproc pPadding, ptr pPaddingData, uint64 iNowMs, xsshsessionpacketkind* pKind );

/* 同时准备上层协议事务和使用调用方 padding 的唯一 packet 线路输出。 */
result = xrtSshSessionTcpWritePrepareWithPadding(pSession, Payload, pChannel, pReplies, iReplyToken, pPadding, pPaddingData, iNowMs, pKind);

;

/* XRT_API xnetresult xrtSshSessionTcpWriteSubmit( xsshsessiontcp* pSession, xnetstream* pStream, uint64 iNowMs, xsshrekeydecision* pDecision ); */
result = xrtSshSessionTcpWriteSubmit();

xsshcode xrtSshSessionTcpWriteAbort(xsshsessiontcp* pSession);

/* 先回滚上层候选，再放弃尚未进入 TCP 队列的动态输出。 */
result = xrtSshSessionTcpWriteAbort(pSession);

size_t xrtSshSessionTcpWriteSize( const xsshsessiontcp* pSession );

/* 返回当前可直接重试提交的 identification 或 packet 线路字节数。 */
result = xrtSshSessionTcpWriteSize(pSession);

xsshcode xrtSshSessionTcpIdentificationReadPrepare( xsshsessiontcp* pSession, xnetbuf* pInput, xstrview* pVersion );

/* 从分块 TCP 输入准备 peer identification，并同步保存版本 transcript。 */
result = xrtSshSessionTcpIdentificationReadPrepare(pSession, pInput, pVersion);

xsshcode xrtSshSessionTcpReadInspect( const xsshsessiontcp* pSession, const xnetbuf* pInput, xsshpacketneed* pNeed );

/* 只探测下一 packet 的线路尺寸和明文工作区需求，不改变会话状态。 */
result = xrtSshSessionTcpReadInspect(pSession, pInput, pNeed);

;

/* XRT_API xsshcode xrtSshSessionTcpReadPrepare( xsshsessiontcp* pSession, xnetbuf* pInput, void* pPlain, size_t iPlainCapacity, void* pHostKeyStorage, size_t iHostKeyCapacity, size_t* pHostKeySize, uint64 iNowMs, xsshsessiontcppacket* pPacket ); */
result = xrtSshSessionTcpReadPrepare();

xsshcode xrtSshSessionTcpReadCommit( xsshsessiontcp* pSession, uint64 iNowMs, xsshrekeydecision* pDecision );

/* 先消费并提交 transport，再提交版本或协议事务并按需切换读密钥。 */
result = xrtSshSessionTcpReadCommit(pSession, iNowMs, pDecision);

xsshcode xrtSshSessionTcpReadAbort(xsshsessiontcp* pSession);

/* 拒绝当前借用输入，消费对应线路前缀并终止不可继续的 transport 与会话。 */
result = xrtSshSessionTcpReadAbort(pSession);