file->MachinePorts = (UINT32*) calloc(count, sizeof(UINT32));
if (!file->MachineAddresses || !file->MachinePorts)
+ {
+ free(file->MachineAddresses);
+ free(file->MachinePorts);
+ free(tokens);
return -1;
+ }
for (i = 0; i < count; i++)
{
if (rpc->VirtualConnection->DefaultOutChannel->ReceiverAvailableWindow < (rpc->ReceiveWindow / 2))
{
- rts_send_flow_control_ack_pdu(rpc);
+ if (rts_send_flow_control_ack_pdu(rpc) < 0)
+ return -1;
}
if (!rpc_get_stub_data_info(rpc, buffer, &StubOffset, &StubLength))
return -1;
Stream_Write(pdu->s, buffer, Stream_Length(fragment));
Stream_SealLength(pdu->s);
- rpc_client_recv_pdu(rpc, pdu);
+ if (rpc_client_recv_pdu(rpc, pdu) < 0)
+ return -1;
rpc_pdu_reset(pdu);
}
else
if (rpc->VirtualConnection->State < VIRTUAL_CONNECTION_STATE_OPENED)
WLog_ERR(TAG, "warning: unhandled RTS PDU");
- rts_recv_out_of_sequence_pdu(rpc, buffer, header->common.frag_length);
+ if (rts_recv_out_of_sequence_pdu(rpc, buffer, header->common.frag_length) < 0)
+ return -1;
}
return 1;
return -1;
Stream_Write(pdu->s, buffer, Stream_Length(fragment));
Stream_SealLength(pdu->s);
- rpc_client_recv_pdu(rpc, pdu);
+ if (rpc_client_recv_pdu(rpc, pdu) < 0)
+ return -1;
rpc_pdu_reset(pdu);
return 1;