UINT cliprdr_process_format_list(cliprdrPlugin* cliprdr, wStream* s, UINT32 dataLen, UINT16 msgFlags)
{
UINT32 index;
- UINT32 position;
+ size_t position;
BOOL asciiNames;
int formatNameLength;
char* szFormatName;
*/
static UINT cliprdr_packet_send(cliprdrPlugin* cliprdr, wStream* s)
{
- UINT32 pos;
+ size_t pos;
UINT32 dataLen;
UINT status = CHANNEL_RC_OK;
pos = Stream_GetPosition(s);
*/
UINT cliprdr_server_packet_send(CliprdrServerPrivate* cliprdr, wStream* s)
{
- UINT32 pos;
+ size_t pos;
BOOL status;
UINT32 dataLen;
UINT32 written;
{
UINT32 index;
UINT32 dataLen;
- UINT32 position;
+ size_t position;
BOOL asciiNames;
int formatNameLength;
char* szFormatName;
UINT cliprdr_server_read(CliprdrServerContext* context)
{
wStream* s;
- int position;
+ size_t position;
DWORD BytesToRead;
DWORD BytesReturned;
CLIPRDR_HEADER header;
const BYTE* data, UINT32 dataSize)
{
wStream* data_out;
- unsigned long pos;
+ size_t pos;
UINT32 cbChId;
UINT32 cbLen;
unsigned long chunkLength;
static UINT drdynvc_process_create_request(drdynvcPlugin* drdynvc, int Sp,
int cbChId, wStream* s)
{
- unsigned long pos;
+ size_t pos;
UINT status;
UINT32 ChannelId;
wStream* data_out;
{
int i;
BYTE c;
- int pos;
+ size_t pos;
int index;
wStream* s;
UINT32 count;
- int data_len;
- int count_pos;
+ size_t data_len;
+ size_t count_pos;
DEVICE* device;
int keyCount;
ULONG_PTR* pKeys;
Stream_Write_UINT16(s, RDPDR_CTYP_CORE); /* Component (2 bytes) */
Stream_Write_UINT16(s, PAKID_CORE_DEVICELIST_ANNOUNCE); /* PacketId (2 bytes) */
- count_pos = (int) Stream_GetPosition(s);
+ count_pos = Stream_GetPosition(s);
count = 0;
Stream_Seek_UINT32(s); /* deviceCount */
pKeys = NULL;
if ((rdpdr->versionMinor == 0x0005) ||
(device->type == RDPDR_DTYP_SMARTCARD) || userLoggedOn)
{
- data_len = (int)(device->data == NULL ? 0 : Stream_GetPosition(device->data));
+ data_len = (device->data == NULL ? 0 : Stream_GetPosition(device->data));
if (!Stream_EnsureRemainingCapacity(s, 20 + data_len))
{
}
free(pKeys);
- pos = (int) Stream_GetPosition(s);
+ pos = Stream_GetPosition(s);
Stream_SetPosition(s, count_pos);
Stream_Write_UINT32(s, count);
Stream_SetPosition(s, pos);
*/
static UINT rdpgfx_recv_pdu(RDPGFX_CHANNEL_CALLBACK* callback, wStream* s)
{
- int beg, end;
+ size_t beg, end;
RDPGFX_HEADER header;
UINT error;
RDPGFX_PLUGIN* gfx = (RDPGFX_PLUGIN*) callback->plugin;
*/
static UINT rdpgfx_server_receive_pdu(RdpgfxServerContext* context, wStream* s)
{
- int beg, end;
+ size_t beg, end;
RDPGFX_HEADER header;
UINT error = CHANNEL_RC_OK;
beg = Stream_GetPosition(s);
*/
UINT rdpsnd_server_send_formats(RdpsndServerContext* context, wStream* s)
{
- int pos;
+ size_t pos;
UINT16 i;
BOOL status;
ULONG written;
static UINT rdpsnd_server_set_volume(RdpsndServerContext* context, int left,
int right)
{
- int pos;
+ size_t pos;
BOOL status;
ULONG written;
wStream* s = context->priv->rdpsnd_pdu;
+
Stream_Write_UINT8(s, SNDC_SETVOLUME);
Stream_Write_UINT8(s, 0);
Stream_Seek_UINT16(s);
*/
static UINT rdpsnd_server_close(RdpsndServerContext* context)
{
- int pos;
+ size_t pos;
BOOL status;
ULONG written;
wStream* s = context->priv->rdpsnd_pdu;
int num_rects = 0;
UINT error = CHANNEL_RC_OK;
int i;
- int pos;
+ size_t pos;
if (Stream_GetRemainingLength(ifman->input) < GUID_SIZE + 32)
return ERROR_INVALID_DATA;
*/
static UINT tsmf_on_data_received(IWTSVirtualChannelCallback* pChannelCallback, wStream *data)
{
- int length;
+ size_t length;
wStream *input;
wStream *output;
UINT error = CHANNEL_RC_OK;
int bicolor2;
int bicolor_spin;
int end;
- int i;
+ size_t i;
int out_count;
int ypixel;
int last_ypixel;
{
BOOL rc;
int i, close_cnt;
- int pos;
+ size_t pos;
BYTE quant;
RFX_TILE* tile;
UINT32* quants;
UINT32 dstStride, UINT32 dstHeight,
REGION16* invalidRegion)
{
- int pos;
+ size_t pos;
REGION16 updateRegion;
UINT32 blockLen;
UINT32 blockType;
static int rdp_capability_set_start(wStream* s)
{
- int header;
+ size_t header;
+
header = Stream_GetPosition(s);
Stream_Zero(s, CAPSET_HEADER_LENGTH);
return header;
static void rdp_capability_set_finish(wStream* s, int header, UINT16 type)
{
- int footer;
+ size_t footer;
UINT16 length;
+
footer = Stream_GetPosition(s);
length = footer - header;
Stream_SetPosition(s, header);
BOOL rdp_write_demand_active(wStream* s, rdpSettings* settings)
{
- int bm, em, lm;
+ size_t bm, em, lm;
UINT16 numberCapabilities;
UINT16 lengthCombinedCapabilities;
BOOL rdp_write_confirm_active(wStream* s, rdpSettings* settings)
{
- int bm, em, lm;
+ size_t bm, em, lm;
UINT16 numberCapabilities;
UINT16 lengthSourceDescriptor;
UINT16 lengthCombinedCapabilities;
int status;
UINT16 size;
rdpRdp* rdp;
- int next_pos;
+ size_t next_pos;
wStream* cs;
int bulkStatus;
UINT32 totalSize;
int size;
int count;
int status;
- int position;
+ size_t position;
char* line;
char* buffer;
char* header = NULL;
{
UINT16 type;
UINT16 blockLength;
- int begPos, endPos;
+ size_t begPos, endPos;
while (length > 0)
{
BOOL license_send(rdpLicense* license, wStream* s, BYTE type)
{
- int length;
+ size_t length;
BYTE flags;
UINT16 wMsgSize;
rdpRdp* rdp = license->rdp;
static BOOL mcs_write_domain_parameters(wStream* s, DomainParameters* domainParameters)
{
- int length;
+ size_t length;
wStream* tmps;
if (!s || !domainParameters)
BOOL mcs_send_connect_initial(rdpMcs* mcs)
{
int status = -1;
- int length;
+ size_t length;
wStream* s = NULL;
- int bm, em;
+ size_t bm, em;
wStream* gcc_CCrq = NULL;
wStream* client_data = NULL;
BOOL mcs_send_connect_response(rdpMcs* mcs)
{
- int length;
+ size_t length;
int status;
wStream* s;
- int bm, em;
+ size_t bm, em;
wStream* gcc_CCrsp;
wStream* server_data;
BYTE *str = NULL;
UINT16 crlf = 0;
- int pos, len;
+ size_t pos, len;
BOOL result = FALSE;
BOOL isToken = FALSE;
{
wStream* s;
int length;
- int bm, em;
+ size_t bm, em;
BYTE flags = 0;
int cookie_length;
(nego->RoutingToken[nego->RoutingTokenLength - 1] == 0x0A))
{
WLog_DBG(TAG, "Routing token looks correctly terminated - use verbatim");
- length +=nego->RoutingTokenLength;
+ length += nego->RoutingTokenLength;
}
else
{
BOOL nego_send_negotiation_response(rdpNego* nego)
{
int length;
- int bm, em;
+ size_t bm, em;
BOOL status;
wStream* s;
BYTE flags;
{
UINT16 length;
UINT32 sec_bytes;
- int sec_hold;
+ size_t sec_hold;
UINT32 pad;
length = Stream_GetPosition(s);
BOOL rdp_send_data_pdu(rdpRdp* rdp, wStream* s, BYTE type, UINT16 channel_id)
{
- UINT16 length;
+ size_t length;
UINT32 sec_bytes;
- int sec_hold;
+ size_t sec_hold;
UINT32 pad;
length = Stream_GetPosition(s);
Stream_SetPosition(s, length);
Stream_SealLength(s);
- WLog_DBG(TAG, "%s: sending data (type=0x%x size=%d channelId=%d)", __FUNCTION__, type, Stream_Length(s), channel_id);
+ WLog_DBG(TAG, "%s: sending data (type=0x%x size=%"PRIuz" channelId=%"PRIu16")", __FUNCTION__,
+ type, Stream_Length(s), channel_id);
if (transport_write(rdp->transport, s) < 0)
return FALSE;
{
UINT16 length;
UINT32 sec_bytes;
- int sec_hold;
+ size_t sec_hold;
UINT32 pad;
length = Stream_GetPosition(s);
UINT16 pduSource;
UINT16 channelId = 0;
UINT16 securityFlags = 0;
- int nextPosition;
+ size_t nextPosition;
if (!rdp_read_header(rdp, s, &length, &channelId))
{
static BOOL update_recv_surfcmd_surface_bits(rdpUpdate* update, wStream* s, UINT32* length)
{
- int pos;
+ size_t pos;
SURFACE_BITS_COMMAND* cmd = &update->surface_bits_command;
if (Stream_GetRemainingLength(s) < 20)
BOOL tpdu_read_connection_confirm(wStream* s, BYTE* li)
{
BYTE code;
- int position;
- int bytes_read = 0;
+ size_t position;
+ size_t bytes_read = 0;
/* save the position to determine the number of bytes read */
position = Stream_GetPosition(s);
int transport_read_pdu(rdpTransport* transport, wStream* s)
{
int status;
- int position;
+ size_t position;
int pduLength;
BYTE* header;
pduLength = 0;
if (!Stream_EnsureCapacity(s, Stream_GetPosition(s) + pduLength))
return -1;
- status = transport_read_layer_bytes(transport, s,
- pduLength - Stream_GetPosition(s));
+ status = transport_read_layer_bytes(transport, s, pduLength - Stream_GetPosition(s));
if (status != 1)
return status;
int transport_write(rdpTransport* transport, wStream* s)
{
- int length;
+ size_t length;
int status = -1;
int writtenlength = 0;
int update_write_order_info(rdpContext* context, wStream* s,
ORDER_INFO* orderInfo, int offset)
{
- int position;
+ size_t position;
position = Stream_GetPosition(s);
Stream_SetPosition(s, offset);
Stream_Write_UINT8(s, orderInfo->controlFlags); /* controlFlags (1 byte) */
static BOOL update_send_patblt(rdpContext* context, PATBLT_ORDER* patblt)
{
wStream* s;
- int offset;
+ size_t offset;
int headerLength;
ORDER_INFO orderInfo;
rdpUpdate* update = context->update;
const OPAQUE_RECT_ORDER* opaque_rect)
{
wStream* s;
- int offset;
+ size_t offset;
int headerLength;
ORDER_INFO orderInfo;
rdpUpdate* update = context->update;
static BOOL update_send_memblt(rdpContext* context, MEMBLT_ORDER* memblt)
{
wStream* s;
- int offset;
+ size_t offset;
int headerLength;
ORDER_INFO orderInfo;
rdpUpdate* update = context->update;
GLYPH_INDEX_ORDER* glyph_index)
{
wStream* s;
- int offset;
+ size_t offset;
int headerLength;
int inf;
ORDER_INFO orderInfo;
const CACHE_BITMAP_ORDER* cache_bitmap)
{
wStream* s;
- int bm, em;
+ size_t bm, em;
BYTE orderType;
int headerLength;
int inf;
CACHE_BITMAP_V2_ORDER* cache_bitmap_v2)
{
wStream* s;
- int bm, em;
+ size_t bm, em;
BYTE orderType;
int headerLength;
UINT16 extraFlags;
CACHE_BITMAP_V3_ORDER* cache_bitmap_v3)
{
wStream* s;
- int bm, em;
+ size_t bm, em;
BYTE orderType;
int headerLength;
UINT16 extraFlags;
{
wStream* s;
UINT16 flags;
- int bm, em, inf;
+ size_t bm, em, inf;
int headerLength;
INT16 orderLength;
rdpUpdate* update = context->update;
{
wStream* s;
UINT16 flags;
- int bm, em, inf;
+ size_t bm, em, inf;
int headerLength;
INT16 orderLength;
rdpUpdate* update = context->update;
{
wStream* s;
UINT16 flags;
- int bm, em, inf;
+ size_t bm, em, inf;
int headerLength;
INT16 orderLength;
rdpUpdate* update = context->update;
em = Stream_GetPosition(s);
orderLength = (em - bm) - 13;
Stream_SetPosition(s, bm);
- Stream_Write_UINT8(s, ORDER_STANDARD |
- ORDER_SECONDARY); /* controlFlags (1 byte) */
+ Stream_Write_UINT8(s, ORDER_STANDARD | ORDER_SECONDARY); /* controlFlags (1 byte) */
Stream_Write_UINT16(s, orderLength); /* orderLength (2 bytes) */
Stream_Write_UINT16(s, flags); /* extraFlags (2 bytes) */
Stream_Write_UINT8(s, ORDER_TYPE_CACHE_GLYPH); /* orderType (1 byte) */
{
wStream* s;
UINT16 flags;
- int bm, em, inf;
+ size_t bm, em, inf;
int headerLength;
INT16 orderLength;
rdpUpdate* update = context->update;
const CREATE_OFFSCREEN_BITMAP_ORDER* create_offscreen_bitmap)
{
wStream* s;
- int bm, em, inf;
+ size_t bm, em, inf;
BYTE orderType;
BYTE controlFlags;
int headerLength;
const SWITCH_SURFACE_ORDER* switch_surface)
{
wStream* s;
- int bm, em, inf;
+ size_t bm, em, inf;
BYTE orderType;
BYTE controlFlags;
int headerLength;
SECURITY_STATUS ntlm_read_NegotiateMessage(NTLM_CONTEXT* context, PSecBuffer buffer)
{
wStream* s;
- int length;
+ size_t length;
NTLM_NEGOTIATE_MESSAGE* message;
message = &context->NEGOTIATE_MESSAGE;
ZeroMemory(message, sizeof(NTLM_NEGOTIATE_MESSAGE));
SECURITY_STATUS ntlm_write_NegotiateMessage(NTLM_CONTEXT* context, PSecBuffer buffer)
{
wStream* s;
- int length;
+ size_t length;
NTLM_NEGOTIATE_MESSAGE* message;
message = &context->NEGOTIATE_MESSAGE;
ZeroMemory(message, sizeof(NTLM_NEGOTIATE_MESSAGE));
SECURITY_STATUS ntlm_write_ChallengeMessage(NTLM_CONTEXT* context, PSecBuffer buffer)
{
wStream* s;
- int length;
+ size_t length;
UINT32 PayloadOffset;
NTLM_CHALLENGE_MESSAGE* message;
message = &context->CHALLENGE_MESSAGE;
SECURITY_STATUS ntlm_read_AuthenticateMessage(NTLM_CONTEXT* context, PSecBuffer buffer)
{
wStream* s;
- int length;
+ size_t length;
UINT32 flags;
NTLM_AV_PAIR* AvFlags;
UINT32 PayloadBufferOffset;
SECURITY_STATUS ntlm_write_AuthenticateMessage(NTLM_CONTEXT* context, PSecBuffer buffer)
{
wStream* s;
- int length;
+ size_t length;
UINT32 PayloadBufferOffset;
NTLM_AUTHENTICATE_MESSAGE* message;
SSPI_CREDENTIALS* credentials = context->credentials;
#include <winpr/print.h>
#include <winpr/stream.h>
-static BOOL TestStream_Verify(wStream* s, int mincap, int len, int pos)
+static BOOL TestStream_Verify(wStream* s, int mincap, int len, size_t pos)
{
if (Stream_Buffer(s) == NULL)
{