mirror of
https://github.com/FreeRDP/FreeRDP.git
synced 2024-12-12 03:06:34 +08:00
libfreerdp-rfx: modify public API for easier external usage
This commit is contained in:
Marc-André Moreau
parent
4f94b1d449
commit
24a7011fcc
@ -707,19 +707,15 @@ void xf_gdi_cache_brush(rdpUpdate* update, CACHE_BRUSH_ORDER* cache_brush)
|
||||
|
||||
void xf_gdi_surface_bits(rdpUpdate* update, SURFACE_BITS_COMMAND* surface_bits_command)
|
||||
{
|
||||
STREAM* s;
|
||||
XImage* image;
|
||||
int i, tx, ty;
|
||||
XImage* image;
|
||||
RFX_MESSAGE* message;
|
||||
xfInfo* xfi = GET_XFI(update);
|
||||
RFX_CONTEXT* context = (RFX_CONTEXT*) xfi->rfx_context;
|
||||
|
||||
if (surface_bits_command->codecID == CODEC_ID_REMOTEFX)
|
||||
{
|
||||
s = stream_new(0);
|
||||
stream_attach(s, surface_bits_command->bitmapData, surface_bits_command->bitmapDataLength);
|
||||
|
||||
message = rfx_process_message(context, s);
|
||||
message = rfx_process_message(context, surface_bits_command->bitmapData, surface_bits_command->bitmapDataLength);
|
||||
|
||||
XSetFunction(xfi->display, xfi->gc, GXcopy);
|
||||
XSetFillStyle(xfi->display, xfi->gc, FillSolid);
|
||||
@ -753,8 +749,6 @@ void xf_gdi_surface_bits(rdpUpdate* update, SURFACE_BITS_COMMAND* surface_bits_c
|
||||
|
||||
XSetClipMask(xfi->display, xfi->gc, None);
|
||||
rfx_message_free(context, message);
|
||||
stream_detach(s);
|
||||
stream_free(s);
|
||||
}
|
||||
else if (surface_bits_command->codecID == CODEC_ID_NONE)
|
||||
{
|
||||
|
||||
@ -393,7 +393,7 @@ void test_message(void)
|
||||
stream_seal(s);
|
||||
/*hexdump(buffer, size);*/
|
||||
stream_set_pos(s, 0);
|
||||
message = rfx_process_message(context, s);
|
||||
message = rfx_process_message(context, s->p, s->size);
|
||||
if (i == 0)
|
||||
{
|
||||
for (j = 0; j < message->num_tiles; j++)
|
||||
|
||||
@ -130,11 +130,15 @@ FREERDP_API void rfx_context_free(RFX_CONTEXT* context);
|
||||
FREERDP_API void rfx_context_set_pixel_format(RFX_CONTEXT* context, RFX_PIXEL_FORMAT pixel_format);
|
||||
FREERDP_API void rfx_context_reset(RFX_CONTEXT* context);
|
||||
|
||||
FREERDP_API RFX_MESSAGE* rfx_process_message(RFX_CONTEXT* context, STREAM* data_in);
|
||||
FREERDP_API RFX_MESSAGE* rfx_process_message(RFX_CONTEXT* context, uint8* data, uint32 length);
|
||||
FREERDP_API uint16 rfx_message_get_tile_count(RFX_MESSAGE* message);
|
||||
FREERDP_API RFX_TILE* rfx_message_get_tile(RFX_MESSAGE* message, int index);
|
||||
FREERDP_API uint16 rfx_message_get_rect_count(RFX_MESSAGE* message);
|
||||
FREERDP_API RFX_RECT* rfx_message_get_rect(RFX_MESSAGE* message, int index);
|
||||
FREERDP_API void rfx_message_free(RFX_CONTEXT* context, RFX_MESSAGE* message);
|
||||
|
||||
FREERDP_API void rfx_compose_message_header(RFX_CONTEXT* context, STREAM* data_out);
|
||||
FREERDP_API void rfx_compose_message(RFX_CONTEXT* context, STREAM* data_out,
|
||||
FREERDP_API void rfx_compose_message_header(RFX_CONTEXT* context, STREAM* s);
|
||||
FREERDP_API void rfx_compose_message(RFX_CONTEXT* context, STREAM* s,
|
||||
const RFX_RECT* rects, int num_rects, uint8* image_data, int width, int height, int rowstride);
|
||||
|
||||
#ifdef __cplusplus
|
||||
|
||||
@ -853,7 +853,6 @@ void gdi_surface_bits(rdpUpdate* update, SURFACE_BITS_COMMAND* surface_bits_comm
|
||||
{
|
||||
int i, j;
|
||||
int tx, ty;
|
||||
STREAM* s;
|
||||
char* tile_bitmap;
|
||||
RFX_MESSAGE* message;
|
||||
GDI* gdi = GET_GDI(update);
|
||||
@ -871,10 +870,7 @@ void gdi_surface_bits(rdpUpdate* update, SURFACE_BITS_COMMAND* surface_bits_comm
|
||||
|
||||
if (surface_bits_command->codecID == CODEC_ID_REMOTEFX)
|
||||
{
|
||||
s = stream_new(0);
|
||||
stream_attach(s, surface_bits_command->bitmapData, surface_bits_command->bitmapDataLength);
|
||||
|
||||
message = rfx_process_message(context, s);
|
||||
message = rfx_process_message(context, surface_bits_command->bitmapData, surface_bits_command->bitmapDataLength);
|
||||
|
||||
DEBUG_GDI("num_rects %d num_tiles %d", message->num_rects, message->num_tiles);
|
||||
|
||||
@ -904,9 +900,6 @@ void gdi_surface_bits(rdpUpdate* update, SURFACE_BITS_COMMAND* surface_bits_comm
|
||||
|
||||
gdi_SetNullClipRgn(gdi->primary->hdc);
|
||||
rfx_message_free(context, message);
|
||||
|
||||
stream_detach(s);
|
||||
stream_free(s);
|
||||
}
|
||||
else if (surface_bits_command->codecID == CODEC_ID_NONE)
|
||||
{
|
||||
|
||||
@ -211,12 +211,12 @@ void rfx_context_reset(RFX_CONTEXT* context)
|
||||
context->frame_idx = 0;
|
||||
}
|
||||
|
||||
static void rfx_process_message_sync(RFX_CONTEXT* context, STREAM* data_in)
|
||||
static void rfx_process_message_sync(RFX_CONTEXT* context, STREAM* s)
|
||||
{
|
||||
uint32 magic;
|
||||
|
||||
/* RFX_SYNC */
|
||||
stream_read_uint32(data_in, magic); /* magic (4 bytes), 0xCACCACCA */
|
||||
stream_read_uint32(s, magic); /* magic (4 bytes), 0xCACCACCA */
|
||||
|
||||
if (magic != WF_MAGIC)
|
||||
{
|
||||
@ -224,7 +224,7 @@ static void rfx_process_message_sync(RFX_CONTEXT* context, STREAM* data_in)
|
||||
return;
|
||||
}
|
||||
|
||||
stream_read_uint16(data_in, context->version); /* version (2 bytes), WF_VERSION_1_0 (0x0100) */
|
||||
stream_read_uint16(s, context->version); /* version (2 bytes), WF_VERSION_1_0 (0x0100) */
|
||||
|
||||
if (context->version != WF_VERSION_1_0)
|
||||
{
|
||||
@ -235,11 +235,11 @@ static void rfx_process_message_sync(RFX_CONTEXT* context, STREAM* data_in)
|
||||
DEBUG_RFX("version 0x%X", context->version);
|
||||
}
|
||||
|
||||
static void rfx_process_message_codec_versions(RFX_CONTEXT* context, STREAM* data_in)
|
||||
static void rfx_process_message_codec_versions(RFX_CONTEXT* context, STREAM* s)
|
||||
{
|
||||
uint8 numCodecs;
|
||||
|
||||
stream_read_uint8(data_in, numCodecs); /* numCodecs (1 byte), must be set to 0x01 */
|
||||
stream_read_uint8(s, numCodecs); /* numCodecs (1 byte), must be set to 0x01 */
|
||||
|
||||
if (numCodecs != 1)
|
||||
{
|
||||
@ -248,18 +248,18 @@ static void rfx_process_message_codec_versions(RFX_CONTEXT* context, STREAM* dat
|
||||
}
|
||||
|
||||
/* RFX_CODEC_VERSIONT */
|
||||
stream_read_uint8(data_in, context->codec_id); /* codecId (1 byte) */
|
||||
stream_read_uint8(data_in, context->codec_version); /* version (2 bytes) */
|
||||
stream_read_uint8(s, context->codec_id); /* codecId (1 byte) */
|
||||
stream_read_uint8(s, context->codec_version); /* version (2 bytes) */
|
||||
|
||||
DEBUG_RFX("id %d version 0x%X.", context->codec_id, context->codec_version);
|
||||
}
|
||||
|
||||
static void rfx_process_message_channels(RFX_CONTEXT* context, STREAM* data_in)
|
||||
static void rfx_process_message_channels(RFX_CONTEXT* context, STREAM* s)
|
||||
{
|
||||
uint8 channelId;
|
||||
uint8 numChannels;
|
||||
|
||||
stream_read_uint8(data_in, numChannels); /* numChannels (1 byte), must bet set to 0x01 */
|
||||
stream_read_uint8(s, numChannels); /* numChannels (1 byte), must bet set to 0x01 */
|
||||
|
||||
if (numChannels != 1)
|
||||
{
|
||||
@ -268,23 +268,23 @@ static void rfx_process_message_channels(RFX_CONTEXT* context, STREAM* data_in)
|
||||
}
|
||||
|
||||
/* RFX_CHANNELT */
|
||||
stream_read_uint8(data_in, channelId); /* channelId (1 byte) */
|
||||
stream_read_uint16(data_in, context->width); /* width (2 bytes) */
|
||||
stream_read_uint16(data_in, context->height); /* height (2 bytes) */
|
||||
stream_read_uint8(s, channelId); /* channelId (1 byte) */
|
||||
stream_read_uint16(s, context->width); /* width (2 bytes) */
|
||||
stream_read_uint16(s, context->height); /* height (2 bytes) */
|
||||
|
||||
DEBUG_RFX("numChannels %d id %d, %dx%d.",
|
||||
numChannels, channelId, context->width, context->height);
|
||||
}
|
||||
|
||||
static void rfx_process_message_context(RFX_CONTEXT* context, STREAM* data_in)
|
||||
static void rfx_process_message_context(RFX_CONTEXT* context, STREAM* s)
|
||||
{
|
||||
uint8 ctxId;
|
||||
uint16 tileSize;
|
||||
uint16 properties;
|
||||
|
||||
stream_read_uint8(data_in, ctxId); /* ctxId (1 byte), must be set to 0x00 */
|
||||
stream_read_uint16(data_in, tileSize); /* tileSize (2 bytes), must be set to CT_TILE_64x64 (0x0040) */
|
||||
stream_read_uint16(data_in, properties); /* properties (2 bytes) */
|
||||
stream_read_uint8(s, ctxId); /* ctxId (1 byte), must be set to 0x00 */
|
||||
stream_read_uint16(s, tileSize); /* tileSize (2 bytes), must be set to CT_TILE_64x64 (0x0040) */
|
||||
stream_read_uint16(s, properties); /* properties (2 bytes) */
|
||||
|
||||
DEBUG_RFX("ctxId %d tileSize %d properties 0x%X.", ctxId, tileSize, properties);
|
||||
|
||||
@ -314,28 +314,28 @@ static void rfx_process_message_context(RFX_CONTEXT* context, STREAM* data_in)
|
||||
}
|
||||
}
|
||||
|
||||
static void rfx_process_message_frame_begin(RFX_CONTEXT* context, RFX_MESSAGE* message, STREAM* data_in)
|
||||
static void rfx_process_message_frame_begin(RFX_CONTEXT* context, RFX_MESSAGE* message, STREAM* s)
|
||||
{
|
||||
uint32 frameIdx;
|
||||
uint16 numRegions;
|
||||
|
||||
stream_read_uint32(data_in, frameIdx); /* frameIdx (4 bytes), if codec is in video mode, must be ignored */
|
||||
stream_read_uint16(data_in, numRegions); /* numRegions (2 bytes) */
|
||||
stream_read_uint32(s, frameIdx); /* frameIdx (4 bytes), if codec is in video mode, must be ignored */
|
||||
stream_read_uint16(s, numRegions); /* numRegions (2 bytes) */
|
||||
|
||||
DEBUG_RFX("RFX_FRAME_BEGIN: frameIdx:%d numRegions:%d", frameIdx, numRegions);
|
||||
}
|
||||
|
||||
static void rfx_process_message_frame_end(RFX_CONTEXT* context, RFX_MESSAGE* message, STREAM* data_in)
|
||||
static void rfx_process_message_frame_end(RFX_CONTEXT* context, RFX_MESSAGE* message, STREAM* s)
|
||||
{
|
||||
DEBUG_RFX("RFX_FRAME_END");
|
||||
}
|
||||
|
||||
static void rfx_process_message_region(RFX_CONTEXT* context, RFX_MESSAGE* message, STREAM* data_in)
|
||||
static void rfx_process_message_region(RFX_CONTEXT* context, RFX_MESSAGE* message, STREAM* s)
|
||||
{
|
||||
int i;
|
||||
|
||||
stream_seek_uint8(data_in); /* regionFlags (1 byte) */
|
||||
stream_read_uint16(data_in, message->num_rects); /* numRects (2 bytes) */
|
||||
stream_seek_uint8(s); /* regionFlags (1 byte) */
|
||||
stream_read_uint16(s, message->num_rects); /* numRects (2 bytes) */
|
||||
|
||||
if (message->num_rects < 1)
|
||||
{
|
||||
@ -352,17 +352,17 @@ static void rfx_process_message_region(RFX_CONTEXT* context, RFX_MESSAGE* messag
|
||||
for (i = 0; i < message->num_rects; i++)
|
||||
{
|
||||
/* RFX_RECT */
|
||||
stream_read_uint16(data_in, message->rects[i].x); /* x (2 bytes) */
|
||||
stream_read_uint16(data_in, message->rects[i].y); /* y (2 bytes) */
|
||||
stream_read_uint16(data_in, message->rects[i].width); /* width (2 bytes) */
|
||||
stream_read_uint16(data_in, message->rects[i].height); /* height (2 bytes) */
|
||||
stream_read_uint16(s, message->rects[i].x); /* x (2 bytes) */
|
||||
stream_read_uint16(s, message->rects[i].y); /* y (2 bytes) */
|
||||
stream_read_uint16(s, message->rects[i].width); /* width (2 bytes) */
|
||||
stream_read_uint16(s, message->rects[i].height); /* height (2 bytes) */
|
||||
|
||||
DEBUG_RFX("rect %d (%d %d %d %d).",
|
||||
i, message->rects[i].x, message->rects[i].y, message->rects[i].width, message->rects[i].height);
|
||||
}
|
||||
}
|
||||
|
||||
static void rfx_process_message_tile(RFX_CONTEXT* context, RFX_TILE* tile, STREAM* data_in)
|
||||
static void rfx_process_message_tile(RFX_CONTEXT* context, RFX_TILE* tile, STREAM* s)
|
||||
{
|
||||
uint8 quantIdxY;
|
||||
uint8 quantIdxCb;
|
||||
@ -371,14 +371,14 @@ static void rfx_process_message_tile(RFX_CONTEXT* context, RFX_TILE* tile, STREA
|
||||
uint16 YLen, CbLen, CrLen;
|
||||
|
||||
/* RFX_TILE */
|
||||
stream_read_uint8(data_in, quantIdxY); /* quantIdxY (1 byte) */
|
||||
stream_read_uint8(data_in, quantIdxCb); /* quantIdxCb (1 byte) */
|
||||
stream_read_uint8(data_in, quantIdxCr); /* quantIdxCr (1 byte) */
|
||||
stream_read_uint16(data_in, xIdx); /* xIdx (2 bytes) */
|
||||
stream_read_uint16(data_in, yIdx); /* yIdx (2 bytes) */
|
||||
stream_read_uint16(data_in, YLen); /* YLen (2 bytes) */
|
||||
stream_read_uint16(data_in, CbLen); /* CbLen (2 bytes) */
|
||||
stream_read_uint16(data_in, CrLen); /* CrLen (2 bytes) */
|
||||
stream_read_uint8(s, quantIdxY); /* quantIdxY (1 byte) */
|
||||
stream_read_uint8(s, quantIdxCb); /* quantIdxCb (1 byte) */
|
||||
stream_read_uint8(s, quantIdxCr); /* quantIdxCr (1 byte) */
|
||||
stream_read_uint16(s, xIdx); /* xIdx (2 bytes) */
|
||||
stream_read_uint16(s, yIdx); /* yIdx (2 bytes) */
|
||||
stream_read_uint16(s, YLen); /* YLen (2 bytes) */
|
||||
stream_read_uint16(s, CbLen); /* CbLen (2 bytes) */
|
||||
stream_read_uint16(s, CrLen); /* CrLen (2 bytes) */
|
||||
|
||||
DEBUG_RFX("quantIdxY:%d quantIdxCb:%d quantIdxCr:%d xIdx:%d yIdx:%d YLen:%d CbLen:%d CrLen:%d",
|
||||
quantIdxY, quantIdxCb, quantIdxCr, xIdx, yIdx, YLen, CbLen, CrLen);
|
||||
@ -386,14 +386,14 @@ static void rfx_process_message_tile(RFX_CONTEXT* context, RFX_TILE* tile, STREA
|
||||
tile->x = xIdx * 64;
|
||||
tile->y = yIdx * 64;
|
||||
|
||||
rfx_decode_rgb(context, data_in,
|
||||
rfx_decode_rgb(context, s,
|
||||
YLen, context->quants + (quantIdxY * 10),
|
||||
CbLen, context->quants + (quantIdxCb * 10),
|
||||
CrLen, context->quants + (quantIdxCr * 10),
|
||||
tile->data);
|
||||
}
|
||||
|
||||
static void rfx_process_message_tileset(RFX_CONTEXT* context, RFX_MESSAGE* message, STREAM* data_in)
|
||||
static void rfx_process_message_tileset(RFX_CONTEXT* context, RFX_MESSAGE* message, STREAM* s)
|
||||
{
|
||||
int i;
|
||||
uint16 subtype;
|
||||
@ -404,7 +404,7 @@ static void rfx_process_message_tileset(RFX_CONTEXT* context, RFX_MESSAGE* messa
|
||||
uint8 quant;
|
||||
int pos;
|
||||
|
||||
stream_read_uint16(data_in, subtype); /* subtype (2 bytes) must be set to CBT_TILESET (0xCAC2) */
|
||||
stream_read_uint16(s, subtype); /* subtype (2 bytes) must be set to CBT_TILESET (0xCAC2) */
|
||||
|
||||
if (subtype != CBT_TILESET)
|
||||
{
|
||||
@ -412,11 +412,11 @@ static void rfx_process_message_tileset(RFX_CONTEXT* context, RFX_MESSAGE* messa
|
||||
return;
|
||||
}
|
||||
|
||||
stream_seek_uint16(data_in); /* idx (2 bytes), must be set to 0x0000 */
|
||||
stream_seek_uint16(data_in); /* properties (2 bytes) */
|
||||
stream_seek_uint16(s); /* idx (2 bytes), must be set to 0x0000 */
|
||||
stream_seek_uint16(s); /* properties (2 bytes) */
|
||||
|
||||
stream_read_uint8(data_in, context->num_quants); /* numQuant (1 byte) */
|
||||
stream_seek_uint8(data_in); /* tileSize (1 byte), must be set to 0x40 */
|
||||
stream_read_uint8(s, context->num_quants); /* numQuant (1 byte) */
|
||||
stream_seek_uint8(s); /* tileSize (1 byte), must be set to 0x40 */
|
||||
|
||||
if (context->num_quants < 1)
|
||||
{
|
||||
@ -424,7 +424,7 @@ static void rfx_process_message_tileset(RFX_CONTEXT* context, RFX_MESSAGE* messa
|
||||
return;
|
||||
}
|
||||
|
||||
stream_read_uint16(data_in, message->num_tiles); /* numTiles (2 bytes) */
|
||||
stream_read_uint16(s, message->num_tiles); /* numTiles (2 bytes) */
|
||||
|
||||
if (message->num_tiles < 1)
|
||||
{
|
||||
@ -432,7 +432,7 @@ static void rfx_process_message_tileset(RFX_CONTEXT* context, RFX_MESSAGE* messa
|
||||
return;
|
||||
}
|
||||
|
||||
stream_read_uint32(data_in, tilesDataSize); /* tilesDataSize (4 bytes) */
|
||||
stream_read_uint32(s, tilesDataSize); /* tilesDataSize (4 bytes) */
|
||||
|
||||
if (context->quants != NULL)
|
||||
context->quants = (uint32*) xrealloc((void*) context->quants, context->num_quants * 10 * sizeof(uint32));
|
||||
@ -444,19 +444,19 @@ static void rfx_process_message_tileset(RFX_CONTEXT* context, RFX_MESSAGE* messa
|
||||
for (i = 0; i < context->num_quants; i++)
|
||||
{
|
||||
/* RFX_CODEC_QUANT */
|
||||
stream_read_uint8(data_in, quant);
|
||||
stream_read_uint8(s, quant);
|
||||
*quants++ = (quant & 0x0F);
|
||||
*quants++ = (quant >> 4);
|
||||
stream_read_uint8(data_in, quant);
|
||||
stream_read_uint8(s, quant);
|
||||
*quants++ = (quant & 0x0F);
|
||||
*quants++ = (quant >> 4);
|
||||
stream_read_uint8(data_in, quant);
|
||||
stream_read_uint8(s, quant);
|
||||
*quants++ = (quant & 0x0F);
|
||||
*quants++ = (quant >> 4);
|
||||
stream_read_uint8(data_in, quant);
|
||||
stream_read_uint8(s, quant);
|
||||
*quants++ = (quant & 0x0F);
|
||||
*quants++ = (quant >> 4);
|
||||
stream_read_uint8(data_in, quant);
|
||||
stream_read_uint8(s, quant);
|
||||
*quants++ = (quant & 0x0F);
|
||||
*quants++ = (quant >> 4);
|
||||
|
||||
@ -474,10 +474,10 @@ static void rfx_process_message_tileset(RFX_CONTEXT* context, RFX_MESSAGE* messa
|
||||
for (i = 0; i < message->num_tiles; i++)
|
||||
{
|
||||
/* RFX_TILE */
|
||||
stream_read_uint16(data_in, blockType); /* blockType (2 bytes), must be set to CBT_TILE (0xCAC3) */
|
||||
stream_read_uint32(data_in, blockLen); /* blockLen (4 bytes) */
|
||||
stream_read_uint16(s, blockType); /* blockType (2 bytes), must be set to CBT_TILE (0xCAC3) */
|
||||
stream_read_uint32(s, blockLen); /* blockLen (4 bytes) */
|
||||
|
||||
pos = stream_get_pos(data_in) - 6 + blockLen;
|
||||
pos = stream_get_pos(s) - 6 + blockLen;
|
||||
|
||||
if (blockType != CBT_TILE)
|
||||
{
|
||||
@ -485,26 +485,29 @@ static void rfx_process_message_tileset(RFX_CONTEXT* context, RFX_MESSAGE* messa
|
||||
break;
|
||||
}
|
||||
|
||||
rfx_process_message_tile(context, message->tiles[i], data_in);
|
||||
rfx_process_message_tile(context, message->tiles[i], s);
|
||||
|
||||
stream_set_pos(data_in, pos);
|
||||
stream_set_pos(s, pos);
|
||||
}
|
||||
}
|
||||
|
||||
RFX_MESSAGE* rfx_process_message(RFX_CONTEXT* context, STREAM* data_in)
|
||||
RFX_MESSAGE* rfx_process_message(RFX_CONTEXT* context, uint8* data, uint32 length)
|
||||
{
|
||||
int pos;
|
||||
STREAM* s;
|
||||
uint32 blockLen;
|
||||
uint32 blockType;
|
||||
RFX_MESSAGE* message;
|
||||
int pos;
|
||||
|
||||
s = stream_new(0);
|
||||
message = xnew(RFX_MESSAGE);
|
||||
stream_attach(s, data, length);
|
||||
|
||||
while (stream_get_left(data_in) > 6)
|
||||
while (stream_get_left(s) > 6)
|
||||
{
|
||||
/* RFX_BLOCKT */
|
||||
stream_read_uint16(data_in, blockType); /* blockType (2 bytes) */
|
||||
stream_read_uint32(data_in, blockLen); /* blockLen (4 bytes) */
|
||||
stream_read_uint16(s, blockType); /* blockType (2 bytes) */
|
||||
stream_read_uint32(s, blockLen); /* blockLen (4 bytes) */
|
||||
|
||||
DEBUG_RFX("blockType 0x%X blockLen %d", blockType, blockLen);
|
||||
|
||||
@ -514,48 +517,48 @@ RFX_MESSAGE* rfx_process_message(RFX_CONTEXT* context, STREAM* data_in)
|
||||
break;
|
||||
}
|
||||
|
||||
pos = stream_get_pos(data_in) - 6 + blockLen;
|
||||
pos = stream_get_pos(s) - 6 + blockLen;
|
||||
|
||||
if (blockType >= WBT_CONTEXT && blockType <= WBT_EXTENSION)
|
||||
{
|
||||
/* RFX_CODEC_CHANNELT */
|
||||
/* codecId (1 byte) must be set to 0x01 */
|
||||
/* channelId (1 byte) must be set to 0x00 */
|
||||
stream_seek(data_in, 2);
|
||||
stream_seek(s, 2);
|
||||
}
|
||||
|
||||
switch (blockType)
|
||||
{
|
||||
case WBT_SYNC:
|
||||
rfx_process_message_sync(context, data_in);
|
||||
rfx_process_message_sync(context, s);
|
||||
break;
|
||||
|
||||
case WBT_CODEC_VERSIONS:
|
||||
rfx_process_message_codec_versions(context, data_in);
|
||||
rfx_process_message_codec_versions(context, s);
|
||||
break;
|
||||
|
||||
case WBT_CHANNELS:
|
||||
rfx_process_message_channels(context, data_in);
|
||||
rfx_process_message_channels(context, s);
|
||||
break;
|
||||
|
||||
case WBT_CONTEXT:
|
||||
rfx_process_message_context(context, data_in);
|
||||
rfx_process_message_context(context, s);
|
||||
break;
|
||||
|
||||
case WBT_FRAME_BEGIN:
|
||||
rfx_process_message_frame_begin(context, message, data_in);
|
||||
rfx_process_message_frame_begin(context, message, s);
|
||||
break;
|
||||
|
||||
case WBT_FRAME_END:
|
||||
rfx_process_message_frame_end(context, message, data_in);
|
||||
rfx_process_message_frame_end(context, message, s);
|
||||
break;
|
||||
|
||||
case WBT_REGION:
|
||||
rfx_process_message_region(context, message, data_in);
|
||||
rfx_process_message_region(context, message, s);
|
||||
break;
|
||||
|
||||
case WBT_EXTENSION:
|
||||
rfx_process_message_tileset(context, message, data_in);
|
||||
rfx_process_message_tileset(context, message, s);
|
||||
break;
|
||||
|
||||
default:
|
||||
@ -563,12 +566,32 @@ RFX_MESSAGE* rfx_process_message(RFX_CONTEXT* context, STREAM* data_in)
|
||||
break;
|
||||
}
|
||||
|
||||
stream_set_pos(data_in, pos);
|
||||
stream_set_pos(s, pos);
|
||||
}
|
||||
|
||||
return message;
|
||||
}
|
||||
|
||||
uint16 rfx_message_get_tile_count(RFX_MESSAGE* message)
|
||||
{
|
||||
return message->num_tiles;
|
||||
}
|
||||
|
||||
RFX_TILE* rfx_message_get_tile(RFX_MESSAGE* message, int index)
|
||||
{
|
||||
return message->tiles[index];
|
||||
}
|
||||
|
||||
uint16 rfx_message_get_rect_count(RFX_MESSAGE* message)
|
||||
{
|
||||
return message->num_rects;
|
||||
}
|
||||
|
||||
RFX_RECT* rfx_message_get_rect(RFX_MESSAGE* message, int index)
|
||||
{
|
||||
return &message->rects[index];
|
||||
}
|
||||
|
||||
void rfx_message_free(RFX_CONTEXT* context, RFX_MESSAGE* message)
|
||||
{
|
||||
if (message != NULL)
|
||||
@ -585,43 +608,43 @@ void rfx_message_free(RFX_CONTEXT* context, RFX_MESSAGE* message)
|
||||
}
|
||||
}
|
||||
|
||||
static void rfx_compose_message_sync(RFX_CONTEXT* context, STREAM* data_out)
|
||||
static void rfx_compose_message_sync(RFX_CONTEXT* context, STREAM* s)
|
||||
{
|
||||
stream_write_uint16(data_out, WBT_SYNC); /* BlockT.blockType */
|
||||
stream_write_uint32(data_out, 12); /* BlockT.blockLen */
|
||||
stream_write_uint32(data_out, WF_MAGIC); /* magic */
|
||||
stream_write_uint16(data_out, WF_VERSION_1_0); /* version */
|
||||
stream_write_uint16(s, WBT_SYNC); /* BlockT.blockType */
|
||||
stream_write_uint32(s, 12); /* BlockT.blockLen */
|
||||
stream_write_uint32(s, WF_MAGIC); /* magic */
|
||||
stream_write_uint16(s, WF_VERSION_1_0); /* version */
|
||||
}
|
||||
|
||||
static void rfx_compose_message_codec_versions(RFX_CONTEXT* context, STREAM* data_out)
|
||||
static void rfx_compose_message_codec_versions(RFX_CONTEXT* context, STREAM* s)
|
||||
{
|
||||
stream_write_uint16(data_out, WBT_CODEC_VERSIONS); /* BlockT.blockType */
|
||||
stream_write_uint32(data_out, 10); /* BlockT.blockLen */
|
||||
stream_write_uint8(data_out, 1); /* numCodecs */
|
||||
stream_write_uint8(data_out, 1); /* codecs.codecId */
|
||||
stream_write_uint16(data_out, WF_VERSION_1_0); /* codecs.version */
|
||||
stream_write_uint16(s, WBT_CODEC_VERSIONS); /* BlockT.blockType */
|
||||
stream_write_uint32(s, 10); /* BlockT.blockLen */
|
||||
stream_write_uint8(s, 1); /* numCodecs */
|
||||
stream_write_uint8(s, 1); /* codecs.codecId */
|
||||
stream_write_uint16(s, WF_VERSION_1_0); /* codecs.version */
|
||||
}
|
||||
|
||||
static void rfx_compose_message_channels(RFX_CONTEXT* context, STREAM* data_out)
|
||||
static void rfx_compose_message_channels(RFX_CONTEXT* context, STREAM* s)
|
||||
{
|
||||
stream_write_uint16(data_out, WBT_CHANNELS); /* BlockT.blockType */
|
||||
stream_write_uint32(data_out, 12); /* BlockT.blockLen */
|
||||
stream_write_uint8(data_out, 1); /* numChannels */
|
||||
stream_write_uint8(data_out, 0); /* Channel.channelId */
|
||||
stream_write_uint16(data_out, context->width); /* Channel.width */
|
||||
stream_write_uint16(data_out, context->height); /* Channel.height */
|
||||
stream_write_uint16(s, WBT_CHANNELS); /* BlockT.blockType */
|
||||
stream_write_uint32(s, 12); /* BlockT.blockLen */
|
||||
stream_write_uint8(s, 1); /* numChannels */
|
||||
stream_write_uint8(s, 0); /* Channel.channelId */
|
||||
stream_write_uint16(s, context->width); /* Channel.width */
|
||||
stream_write_uint16(s, context->height); /* Channel.height */
|
||||
}
|
||||
|
||||
static void rfx_compose_message_context(RFX_CONTEXT* context, STREAM* data_out)
|
||||
static void rfx_compose_message_context(RFX_CONTEXT* context, STREAM* s)
|
||||
{
|
||||
uint16 properties;
|
||||
|
||||
stream_write_uint16(data_out, WBT_CONTEXT); /* CodecChannelT.blockType */
|
||||
stream_write_uint32(data_out, 13); /* CodecChannelT.blockLen */
|
||||
stream_write_uint8(data_out, 1); /* CodecChannelT.codecId */
|
||||
stream_write_uint8(data_out, 0); /* CodecChannelT.channelId */
|
||||
stream_write_uint8(data_out, 0); /* ctxId */
|
||||
stream_write_uint16(data_out, CT_TILE_64x64); /* tileSize */
|
||||
stream_write_uint16(s, WBT_CONTEXT); /* CodecChannelT.blockType */
|
||||
stream_write_uint32(s, 13); /* CodecChannelT.blockLen */
|
||||
stream_write_uint8(s, 1); /* CodecChannelT.codecId */
|
||||
stream_write_uint8(s, 0); /* CodecChannelT.channelId */
|
||||
stream_write_uint8(s, 0); /* ctxId */
|
||||
stream_write_uint16(s, CT_TILE_64x64); /* tileSize */
|
||||
|
||||
/* properties */
|
||||
properties = context->flags; /* flags */
|
||||
@ -629,7 +652,7 @@ static void rfx_compose_message_context(RFX_CONTEXT* context, STREAM* data_out)
|
||||
properties |= (CLW_XFORM_DWT_53_A << 5); /* xft */
|
||||
properties |= ((context->mode == RLGR1 ? CLW_ENTROPY_RLGR1 : CLW_ENTROPY_RLGR3) << 9); /* et */
|
||||
properties |= (SCALAR_QUANTIZATION << 13); /* qt */
|
||||
stream_write_uint16(data_out, properties);
|
||||
stream_write_uint16(s, properties);
|
||||
|
||||
/* properties in tilesets: note that this has different format from the one in TS_RFX_CONTEXT */
|
||||
properties = 1; /* lt */
|
||||
@ -641,61 +664,61 @@ static void rfx_compose_message_context(RFX_CONTEXT* context, STREAM* data_out)
|
||||
context->properties = properties;
|
||||
}
|
||||
|
||||
void rfx_compose_message_header(RFX_CONTEXT* context, STREAM* data_out)
|
||||
void rfx_compose_message_header(RFX_CONTEXT* context, STREAM* s)
|
||||
{
|
||||
stream_check_size(data_out, 12 + 10 + 12 + 13);
|
||||
stream_check_size(s, 12 + 10 + 12 + 13);
|
||||
|
||||
rfx_compose_message_sync(context, data_out);
|
||||
rfx_compose_message_context(context, data_out);
|
||||
rfx_compose_message_codec_versions(context, data_out);
|
||||
rfx_compose_message_channels(context, data_out);
|
||||
rfx_compose_message_sync(context, s);
|
||||
rfx_compose_message_context(context, s);
|
||||
rfx_compose_message_codec_versions(context, s);
|
||||
rfx_compose_message_channels(context, s);
|
||||
|
||||
context->header_processed = True;
|
||||
}
|
||||
|
||||
static void rfx_compose_message_frame_begin(RFX_CONTEXT* context, STREAM* data_out)
|
||||
static void rfx_compose_message_frame_begin(RFX_CONTEXT* context, STREAM* s)
|
||||
{
|
||||
stream_check_size(data_out, 14);
|
||||
stream_check_size(s, 14);
|
||||
|
||||
stream_write_uint16(data_out, WBT_FRAME_BEGIN); /* CodecChannelT.blockType */
|
||||
stream_write_uint32(data_out, 14); /* CodecChannelT.blockLen */
|
||||
stream_write_uint8(data_out, 1); /* CodecChannelT.codecId */
|
||||
stream_write_uint8(data_out, 0); /* CodecChannelT.channelId */
|
||||
stream_write_uint32(data_out, context->frame_idx); /* frameIdx */
|
||||
stream_write_uint16(data_out, 1); /* numRegions */
|
||||
stream_write_uint16(s, WBT_FRAME_BEGIN); /* CodecChannelT.blockType */
|
||||
stream_write_uint32(s, 14); /* CodecChannelT.blockLen */
|
||||
stream_write_uint8(s, 1); /* CodecChannelT.codecId */
|
||||
stream_write_uint8(s, 0); /* CodecChannelT.channelId */
|
||||
stream_write_uint32(s, context->frame_idx); /* frameIdx */
|
||||
stream_write_uint16(s, 1); /* numRegions */
|
||||
|
||||
context->frame_idx++;
|
||||
}
|
||||
|
||||
static void rfx_compose_message_region(RFX_CONTEXT* context, STREAM* data_out,
|
||||
static void rfx_compose_message_region(RFX_CONTEXT* context, STREAM* s,
|
||||
const RFX_RECT* rects, int num_rects)
|
||||
{
|
||||
int size;
|
||||
int i;
|
||||
|
||||
size = 15 + num_rects * 8;
|
||||
stream_check_size(data_out, size);
|
||||
stream_check_size(s, size);
|
||||
|
||||
stream_write_uint16(data_out, WBT_REGION); /* CodecChannelT.blockType */
|
||||
stream_write_uint32(data_out, size); /* set CodecChannelT.blockLen later */
|
||||
stream_write_uint8(data_out, 1); /* CodecChannelT.codecId */
|
||||
stream_write_uint8(data_out, 0); /* CodecChannelT.channelId */
|
||||
stream_write_uint8(data_out, 1); /* regionFlags */
|
||||
stream_write_uint16(data_out, num_rects); /* numRects */
|
||||
stream_write_uint16(s, WBT_REGION); /* CodecChannelT.blockType */
|
||||
stream_write_uint32(s, size); /* set CodecChannelT.blockLen later */
|
||||
stream_write_uint8(s, 1); /* CodecChannelT.codecId */
|
||||
stream_write_uint8(s, 0); /* CodecChannelT.channelId */
|
||||
stream_write_uint8(s, 1); /* regionFlags */
|
||||
stream_write_uint16(s, num_rects); /* numRects */
|
||||
|
||||
for (i = 0; i < num_rects; i++)
|
||||
{
|
||||
stream_write_uint16(data_out, rects[i].x);
|
||||
stream_write_uint16(data_out, rects[i].y);
|
||||
stream_write_uint16(data_out, rects[i].width);
|
||||
stream_write_uint16(data_out, rects[i].height);
|
||||
stream_write_uint16(s, rects[i].x);
|
||||
stream_write_uint16(s, rects[i].y);
|
||||
stream_write_uint16(s, rects[i].width);
|
||||
stream_write_uint16(s, rects[i].height);
|
||||
}
|
||||
|
||||
stream_write_uint16(data_out, CBT_REGION); /* regionType */
|
||||
stream_write_uint16(data_out, 1); /* numTilesets */
|
||||
stream_write_uint16(s, CBT_REGION); /* regionType */
|
||||
stream_write_uint16(s, 1); /* numTilesets */
|
||||
}
|
||||
|
||||
static void rfx_compose_message_tile(RFX_CONTEXT* context, STREAM* data_out,
|
||||
static void rfx_compose_message_tile(RFX_CONTEXT* context, STREAM* s,
|
||||
uint8* tile_data, int tile_width, int tile_height, int rowstride,
|
||||
const uint32* quantVals, int quantIdxY, int quantIdxCb, int quantIdxCr,
|
||||
int xIdx, int yIdx)
|
||||
@ -705,39 +728,39 @@ static void rfx_compose_message_tile(RFX_CONTEXT* context, STREAM* data_out,
|
||||
int CrLen = 0;
|
||||
int start_pos, end_pos;
|
||||
|
||||
stream_check_size(data_out, 19);
|
||||
start_pos = stream_get_pos(data_out);
|
||||
stream_check_size(s, 19);
|
||||
start_pos = stream_get_pos(s);
|
||||
|
||||
stream_write_uint16(data_out, CBT_TILE); /* BlockT.blockType */
|
||||
stream_seek_uint32(data_out); /* set BlockT.blockLen later */
|
||||
stream_write_uint8(data_out, quantIdxY);
|
||||
stream_write_uint8(data_out, quantIdxCb);
|
||||
stream_write_uint8(data_out, quantIdxCr);
|
||||
stream_write_uint16(data_out, xIdx);
|
||||
stream_write_uint16(data_out, yIdx);
|
||||
stream_write_uint16(s, CBT_TILE); /* BlockT.blockType */
|
||||
stream_seek_uint32(s); /* set BlockT.blockLen later */
|
||||
stream_write_uint8(s, quantIdxY);
|
||||
stream_write_uint8(s, quantIdxCb);
|
||||
stream_write_uint8(s, quantIdxCr);
|
||||
stream_write_uint16(s, xIdx);
|
||||
stream_write_uint16(s, yIdx);
|
||||
|
||||
stream_seek(data_out, 6); /* YLen, CbLen, CrLen */
|
||||
stream_seek(s, 6); /* YLen, CbLen, CrLen */
|
||||
|
||||
rfx_encode_rgb(context, tile_data, tile_width, tile_height, rowstride,
|
||||
quantVals + quantIdxY * 10, quantVals + quantIdxCb * 10, quantVals + quantIdxCr * 10,
|
||||
data_out, &YLen, &CbLen, &CrLen);
|
||||
s, &YLen, &CbLen, &CrLen);
|
||||
|
||||
DEBUG_RFX("xIdx=%d yIdx=%d width=%d height=%d YLen=%d CbLen=%d CrLen=%d",
|
||||
xIdx, yIdx, tile_width, tile_height, YLen, CbLen, CrLen);
|
||||
|
||||
end_pos = stream_get_pos(data_out);
|
||||
end_pos = stream_get_pos(s);
|
||||
|
||||
stream_set_pos(data_out, start_pos + 2);
|
||||
stream_write_uint32(data_out, 19 + YLen + CbLen + CrLen); /* BlockT.blockLen */
|
||||
stream_set_pos(data_out, start_pos + 13);
|
||||
stream_write_uint16(data_out, YLen);
|
||||
stream_write_uint16(data_out, CbLen);
|
||||
stream_write_uint16(data_out, CrLen);
|
||||
stream_set_pos(s, start_pos + 2);
|
||||
stream_write_uint32(s, 19 + YLen + CbLen + CrLen); /* BlockT.blockLen */
|
||||
stream_set_pos(s, start_pos + 13);
|
||||
stream_write_uint16(s, YLen);
|
||||
stream_write_uint16(s, CbLen);
|
||||
stream_write_uint16(s, CrLen);
|
||||
|
||||
stream_set_pos(data_out, end_pos);
|
||||
stream_set_pos(s, end_pos);
|
||||
}
|
||||
|
||||
static void rfx_compose_message_tileset(RFX_CONTEXT* context, STREAM* data_out,
|
||||
static void rfx_compose_message_tileset(RFX_CONTEXT* context, STREAM* s,
|
||||
uint8* image_data, int width, int height, int rowstride)
|
||||
{
|
||||
int size;
|
||||
@ -778,80 +801,80 @@ static void rfx_compose_message_tileset(RFX_CONTEXT* context, STREAM* data_out,
|
||||
numTiles = numTilesX * numTilesY;
|
||||
|
||||
size = 22 + numQuants * 5;
|
||||
stream_check_size(data_out, size);
|
||||
start_pos = stream_get_pos(data_out);
|
||||
stream_check_size(s, size);
|
||||
start_pos = stream_get_pos(s);
|
||||
|
||||
stream_write_uint16(data_out, WBT_EXTENSION); /* CodecChannelT.blockType */
|
||||
stream_seek_uint32(data_out); /* set CodecChannelT.blockLen later */
|
||||
stream_write_uint8(data_out, 1); /* CodecChannelT.codecId */
|
||||
stream_write_uint8(data_out, 0); /* CodecChannelT.channelId */
|
||||
stream_write_uint16(data_out, CBT_TILESET); /* subtype */
|
||||
stream_write_uint16(data_out, 0); /* idx */
|
||||
stream_write_uint16(data_out, context->properties); /* properties */
|
||||
stream_write_uint8(data_out, numQuants); /* numQuants */
|
||||
stream_write_uint8(data_out, 0x40); /* tileSize */
|
||||
stream_write_uint16(data_out, numTiles); /* numTiles */
|
||||
stream_seek_uint32(data_out); /* set tilesDataSize later */
|
||||
stream_write_uint16(s, WBT_EXTENSION); /* CodecChannelT.blockType */
|
||||
stream_seek_uint32(s); /* set CodecChannelT.blockLen later */
|
||||
stream_write_uint8(s, 1); /* CodecChannelT.codecId */
|
||||
stream_write_uint8(s, 0); /* CodecChannelT.channelId */
|
||||
stream_write_uint16(s, CBT_TILESET); /* subtype */
|
||||
stream_write_uint16(s, 0); /* idx */
|
||||
stream_write_uint16(s, context->properties); /* properties */
|
||||
stream_write_uint8(s, numQuants); /* numQuants */
|
||||
stream_write_uint8(s, 0x40); /* tileSize */
|
||||
stream_write_uint16(s, numTiles); /* numTiles */
|
||||
stream_seek_uint32(s); /* set tilesDataSize later */
|
||||
|
||||
quantValsPtr = quantVals;
|
||||
for (i = 0; i < numQuants * 5; i++)
|
||||
{
|
||||
stream_write_uint8(data_out, quantValsPtr[0] + (quantValsPtr[1] << 4));
|
||||
stream_write_uint8(s, quantValsPtr[0] + (quantValsPtr[1] << 4));
|
||||
quantValsPtr += 2;
|
||||
}
|
||||
|
||||
DEBUG_RFX("width:%d height:%d rowstride:%d", width, height, rowstride);
|
||||
|
||||
end_pos = stream_get_pos(data_out);
|
||||
end_pos = stream_get_pos(s);
|
||||
for (yIdx = 0; yIdx < numTilesY; yIdx++)
|
||||
{
|
||||
for (xIdx = 0; xIdx < numTilesX; xIdx++)
|
||||
{
|
||||
rfx_compose_message_tile(context, data_out,
|
||||
rfx_compose_message_tile(context, s,
|
||||
image_data + yIdx * 64 * rowstride + xIdx * 8 * context->bits_per_pixel,
|
||||
xIdx < numTilesX - 1 ? 64 : width - xIdx * 64,
|
||||
yIdx < numTilesY - 1 ? 64 : height - yIdx * 64,
|
||||
rowstride, quantVals, quantIdxY, quantIdxCb, quantIdxCr, xIdx, yIdx);
|
||||
}
|
||||
}
|
||||
tilesDataSize = stream_get_pos(data_out) - end_pos;
|
||||
tilesDataSize = stream_get_pos(s) - end_pos;
|
||||
size += tilesDataSize;
|
||||
end_pos = stream_get_pos(data_out);
|
||||
end_pos = stream_get_pos(s);
|
||||
|
||||
stream_set_pos(data_out, start_pos + 2);
|
||||
stream_write_uint32(data_out, size); /* CodecChannelT.blockLen */
|
||||
stream_set_pos(data_out, start_pos + 18);
|
||||
stream_write_uint32(data_out, tilesDataSize);
|
||||
stream_set_pos(s, start_pos + 2);
|
||||
stream_write_uint32(s, size); /* CodecChannelT.blockLen */
|
||||
stream_set_pos(s, start_pos + 18);
|
||||
stream_write_uint32(s, tilesDataSize);
|
||||
|
||||
stream_set_pos(data_out, end_pos);
|
||||
stream_set_pos(s, end_pos);
|
||||
}
|
||||
|
||||
static void rfx_compose_message_frame_end(RFX_CONTEXT* context, STREAM* data_out)
|
||||
static void rfx_compose_message_frame_end(RFX_CONTEXT* context, STREAM* s)
|
||||
{
|
||||
stream_check_size(data_out, 8);
|
||||
stream_check_size(s, 8);
|
||||
|
||||
stream_write_uint16(data_out, WBT_FRAME_END); /* CodecChannelT.blockType */
|
||||
stream_write_uint32(data_out, 8); /* CodecChannelT.blockLen */
|
||||
stream_write_uint8(data_out, 1); /* CodecChannelT.codecId */
|
||||
stream_write_uint8(data_out, 0); /* CodecChannelT.channelId */
|
||||
stream_write_uint16(s, WBT_FRAME_END); /* CodecChannelT.blockType */
|
||||
stream_write_uint32(s, 8); /* CodecChannelT.blockLen */
|
||||
stream_write_uint8(s, 1); /* CodecChannelT.codecId */
|
||||
stream_write_uint8(s, 0); /* CodecChannelT.channelId */
|
||||
}
|
||||
|
||||
static void rfx_compose_message_data(RFX_CONTEXT* context, STREAM* data_out,
|
||||
static void rfx_compose_message_data(RFX_CONTEXT* context, STREAM* s,
|
||||
const RFX_RECT* rects, int num_rects, uint8* image_data, int width, int height, int rowstride)
|
||||
{
|
||||
rfx_compose_message_frame_begin(context, data_out);
|
||||
rfx_compose_message_region(context, data_out, rects, num_rects);
|
||||
rfx_compose_message_tileset(context, data_out, image_data, width, height, rowstride);
|
||||
rfx_compose_message_frame_end(context, data_out);
|
||||
rfx_compose_message_frame_begin(context, s);
|
||||
rfx_compose_message_region(context, s, rects, num_rects);
|
||||
rfx_compose_message_tileset(context, s, image_data, width, height, rowstride);
|
||||
rfx_compose_message_frame_end(context, s);
|
||||
}
|
||||
|
||||
FREERDP_API void rfx_compose_message(RFX_CONTEXT* context, STREAM* data_out,
|
||||
FREERDP_API void rfx_compose_message(RFX_CONTEXT* context, STREAM* s,
|
||||
const RFX_RECT* rects, int num_rects, uint8* image_data, int width, int height, int rowstride)
|
||||
{
|
||||
/* Only the first frame should send the RemoteFX header */
|
||||
if (context->frame_idx == 0 && !context->header_processed)
|
||||
rfx_compose_message_header(context, data_out);
|
||||
rfx_compose_message_header(context, s);
|
||||
|
||||
rfx_compose_message_data(context, data_out, rects, num_rects, image_data, width, height, rowstride);
|
||||
rfx_compose_message_data(context, s, rects, num_rects, image_data, width, height, rowstride);
|
||||
}
|
||||
|
||||
|
||||
Loading…
Reference in New Issue
Block a user