xssh/ssh_channel_io

void xrtSshChannelIoConfigInit(xsshchannelioconfig* pConfig);

sshchannelioconfiginit obj;
xrtSshChannelIoConfigInit(&obj);

;

sshchannelioinit obj;
xrtSshChannelIoInit(&obj);

void xrtSshChannelIoClear(xsshchannelio* pIo);

/* 释放全部动态块；未读取数据按应用丢弃处理并转入 channel 待返还额度。 */
result = xrtSshChannelIoClear(pIo);

size_t xrtSshChannelIoReadable( const xsshchannelio* pIo, xsshchanneliostream Stream );

/* 返回指定接收流当前已经可靠提交的可读字节数。 */
result = xrtSshChannelIoReadable(pIo, Stream);

const xnetbuf* xrtSshChannelIoReadBuffer( const xsshchannelio* pIo, xsshchanneliostream Stream );

/* 返回指定接收流的借用只读缓冲；对象失效或流类型错误时返回空。 */
result = xrtSshChannelIoReadBuffer(pIo, Stream);

xsshcode xrtSshChannelIoRead( xsshchannelio* pIo, xsshchanneliostream Stream, void* pOutput, size_t iCapacity, size_t* pRead );

/* 复制并消费最多 Capacity 字节，同时把实际消费量转入接收窗口待返还额度。 */
result = xrtSshChannelIoRead(pIo, Stream, pOutput, iCapacity, pRead);

xsshcode xrtSshChannelIoConsume( xsshchannelio* pIo, xsshchanneliostream Stream, size_t iSize );

/* 零复制消费指定接收流的前缀，并更新 channel 接收窗口计数。 */
result = xrtSshChannelIoConsume(pIo, Stream, iSize);

size_t xrtSshChannelIoQueued( const xsshchannelio* pIo, xsshchanneliostream Stream );

/* 返回指定发送流当前排队字节数。 */
result = xrtSshChannelIoQueued(pIo, Stream);

size_t xrtSshChannelIoWritable(const xsshchannelio* pIo);

/* 返回两条发送流共享硬上限中尚可受理的字节数。 */
result = xrtSshChannelIoWritable(pIo);

size_t xrtSshChannelIoSendLimit( const xsshchannelio* pIo, xsshchanneliostream Stream );

/* 返回指定流下一条消息可发送的连续队首字节数，零表示无数据或远端窗口阻塞。 */
result = xrtSshChannelIoSendLimit(pIo, Stream);

xsshcode xrtSshChannelIoWrite( xsshchannelio* pIo, xsshchanneliostream Stream, const void* pData, size_t iSize );

/* 在共享发送预算内追加一份数据副本。 */
result = xrtSshChannelIoWrite(pIo, Stream, pData, iSize);

xsshcode xrtSshChannelIoWriteBorrow( xsshchannelio* pIo, xsshchanneliostream Stream, const void* pData, size_t iSize );

/* 追加借用数据；调用方保证其存活到消费或清理。 */
result = xrtSshChannelIoWriteBorrow(pIo, Stream, pData, iSize);

xsshcode xrtSshChannelIoWriteTake( xsshchannelio* pIo, xsshchanneliostream Stream, void* pData, size_t iSize );

/* 接管由 xrtMalloc 家族分配的数据；失败或零长度不转移所有权。 */
result = xrtSshChannelIoWriteTake(pIo, Stream, pData, iSize);

xsshcode xrtSshChannelIoWriteRef( xsshchannelio* pIo, xsshchanneliostream Stream, const void* pData, size_t iSize, xnetreleaseproc pRelease, ptr pContext );

/* 接管带释放过程的外部数据；失败或零长度不转移所有权。 */
result = xrtSshChannelIoWriteRef(pIo, Stream, pData, iSize, pRelease, pContext);

xsshcode xrtSshChannelIoWriteBuffer( xsshchannelio* pIo, xsshchanneliostream Stream, xnetbuf* pBuffer );

/* 把调用方缓冲链移动到指定发送流；超出共享预算时源缓冲保持不变。 */
result = xrtSshChannelIoWriteBuffer(pIo, Stream, pBuffer);

;

/* XRT_API xsshcode xrtSshChannelIoReceivePrepare( xsshchannelio* pIo, xsshchanneliostream Stream, uint32 iRecipient, xbytesview Data ); */
result = xrtSshChannelIoReceivePrepare();

xsshcode xrtSshChannelIoReceiveCommit(xsshchannelio* pIo);

/* 外层已提交 channel 接收状态后，把预分配块无分配移动到可读缓冲。 */
result = xrtSshChannelIoReceiveCommit(pIo);

xsshcode xrtSshChannelIoReceiveAbort(xsshchannelio* pIo);

/* 在 channel 状态尚未提交时放弃接收预分配。 */
result = xrtSshChannelIoReceiveAbort(pIo);

;

/* XRT_API xsshcode xrtSshChannelIoSendPrepare( xsshchannelio* pIo, xsshchanneliostream Stream, xsshwriter* pWriter, xbytesview* pPayload ); */
result = xrtSshChannelIoSendPrepare();

xsshcode xrtSshChannelIoSendCommit(xsshchannelio* pIo);

/* 外层已提交 channel 发送状态后消费本次发送队首。 */
result = xrtSshChannelIoSendCommit(pIo);

xsshcode xrtSshChannelIoSendAbort(xsshchannelio* pIo);

/* 在 channel 状态尚未提交时放弃发送事务，排队数据保持不变。 */
result = xrtSshChannelIoSendAbort(pIo);