*/
BOOL freerdp_connect(freerdp* instance)
{
- UINT status2;
+ UINT status2 = CHANNEL_RC_OK;
rdpRdp* rdp;
BOOL status = TRUE;
rdpSettings* settings;
if (status)
status2 = freerdp_channels_pre_connect(instance->context->channels,
- instance);
+ instance);
if (settings->KeyboardLayout == KBD_JAPANESE_INPUT_SYSTEM_MS_IME2002)
{
if (instance->settings->DumpRemoteFx)
{
instance->update->pcap_rfx = pcap_open(instance->settings->DumpRemoteFxFile,
- TRUE);
+ TRUE);
if (instance->update->pcap_rfx)
instance->update->dump_rfx = TRUE;
if (rdp->errorInfo == ERRINFO_SERVER_INSUFFICIENT_PRIVILEGES)
freerdp_set_last_error(instance->context,
- FREERDP_ERROR_INSUFFICIENT_PRIVILEGES);
+ FREERDP_ERROR_INSUFFICIENT_PRIVILEGES);
SetEvent(rdp->transport->connectedEvent);
freerdp_connect_finally:
}
BOOL freerdp_get_fds(freerdp* instance, void** rfds, int* rcount, void** wfds,
- int* wcount)
+ int* wcount)
{
rdpRdp* rdp = instance->context->rdp;
transport_get_fds(rdp->transport, rfds, rcount);
}
DWORD freerdp_get_event_handles(rdpContext* context, HANDLE* events,
- DWORD count)
+ DWORD count)
{
DWORD nCount = 0;
nCount += transport_get_event_handles(context->rdp->transport, events, count);
{
if (nCount >= count)
return 0;
+
events[nCount++] = freerdp_get_message_queue_event_handle(
- context->instance, FREERDP_INPUT_MESSAGE_QUEUE);
+ context->instance, FREERDP_INPUT_MESSAGE_QUEUE);
}
return nCount;
if (context->settings->AsyncInput)
{
status = freerdp_message_queue_process_pending_messages(
- context->instance, FREERDP_INPUT_MESSAGE_QUEUE);
+ context->instance, FREERDP_INPUT_MESSAGE_QUEUE);
}
return status;
}
int freerdp_message_queue_process_message(freerdp* instance, DWORD id,
- wMessage* message)
+ wMessage* message)
{
int status = -1;
}
static int freerdp_send_channel_data(freerdp* instance, UINT16 channelId,
- BYTE* data, int size)
+ BYTE* data, int size)
{
return rdp_send_channel_data(instance->context->rdp, channelId, data, size);
}
if (instance->settings->AsyncInput)
{
wMessageQueue* inputQueue = freerdp_get_message_queue(instance,
- FREERDP_INPUT_MESSAGE_QUEUE);
-
- MessageQueue_PostQuit(inputQueue, 0);
+ FREERDP_INPUT_MESSAGE_QUEUE);
+ MessageQueue_PostQuit(inputQueue, 0);
}
if (freerdp_channels_disconnect(instance->context->channels,
- instance) != CHANNEL_RC_OK)
+ instance) != CHANNEL_RC_OK)
rc = FALSE;
IFCALL(instance->PostDisconnect, instance);
goto fail;
PubSub_AddEventTypes(context->pubSub, FreeRDP_Events,
- sizeof(FreeRDP_Events) / sizeof(wEventType));
+ sizeof(FreeRDP_Events) / sizeof(wEventType));
context->metrics = metrics_new(context);
if (!context->metrics)
{
if (lastError)
WLog_ERR(TAG, "freerdp_set_last_error %s [0x%04X]",
- freerdp_get_last_error_name(lastError), lastError);
+ freerdp_get_last_error_name(lastError), lastError);
context->LastError = lastError;
if (WaitForSingleObject(context->channelErrorEvent, 0) == WAIT_OBJECT_0)
{
WLog_ERR(TAG, "%s. Error was %lu", context->errorDescription,
- context->channelErrorNum);
+ context->channelErrorNum);
return FALSE;
}