|
Packit Service |
fa4841 |
/**
|
|
Packit Service |
fa4841 |
* FreeRDP: A Remote Desktop Protocol Implementation
|
|
Packit Service |
fa4841 |
* Client Channels
|
|
Packit Service |
fa4841 |
*
|
|
Packit Service |
fa4841 |
* Copyright 2014 Marc-Andre Moreau <marcandre.moreau@gmail.com>
|
|
Packit Service |
fa4841 |
* Copyright 2015 Thincast Technologies GmbH
|
|
Packit Service |
fa4841 |
* Copyright 2015 DI (FH) Martin Haimberger <martin.haimberger@thincast.com>
|
|
Packit Service |
fa4841 |
*
|
|
Packit Service |
fa4841 |
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
Packit Service |
fa4841 |
* you may not use this file except in compliance with the License.
|
|
Packit Service |
fa4841 |
* You may obtain a copy of the License at
|
|
Packit Service |
fa4841 |
*
|
|
Packit Service |
fa4841 |
* http://www.apache.org/licenses/LICENSE-2.0
|
|
Packit Service |
fa4841 |
*
|
|
Packit Service |
fa4841 |
* Unless required by applicable law or agreed to in writing, software
|
|
Packit Service |
fa4841 |
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
Packit Service |
fa4841 |
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
Packit Service |
fa4841 |
* See the License for the specific language governing permissions and
|
|
Packit Service |
fa4841 |
* limitations under the License.
|
|
Packit Service |
fa4841 |
*/
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
#ifdef HAVE_CONFIG_H
|
|
Packit Service |
fa4841 |
#include "config.h"
|
|
Packit Service |
fa4841 |
#endif
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
#include <freerdp/log.h>
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
#include "rdp.h"
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
#include "client.h"
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
#define TAG FREERDP_TAG("core.client")
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
static WINPR_TLS void* g_pInterface = NULL;
|
|
Packit Service |
fa4841 |
static WINPR_TLS rdpChannels* g_channels = NULL; /* use only for VirtualChannelInit hack */
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
static volatile LONG g_OpenHandleSeq =
|
|
Packit Service |
fa4841 |
1; /* use global counter to ensure uniqueness across channel manager instances */
|
|
Packit Service |
fa4841 |
static WINPR_TLS rdpChannelHandles g_ChannelHandles = { NULL, NULL };
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
static BOOL freerdp_channels_process_message_free(wMessage* message, DWORD type);
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
static CHANNEL_OPEN_DATA* freerdp_channels_find_channel_open_data_by_name(rdpChannels* channels,
|
|
Packit Service |
fa4841 |
const char* name)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
int index;
|
|
Packit Service |
fa4841 |
CHANNEL_OPEN_DATA* pChannelOpenData;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
for (index = 0; index < channels->openDataCount; index++)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
pChannelOpenData = &channels->openDataList[index];
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (strncmp(name, pChannelOpenData->name, CHANNEL_NAME_LEN) == 0)
|
|
Packit Service |
fa4841 |
return pChannelOpenData;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
return NULL;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
/* returns rdpChannel for the channel name passed in */
|
|
Packit Service |
fa4841 |
static rdpMcsChannel* freerdp_channels_find_channel_by_name(rdpRdp* rdp, const char* name)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
UINT32 index;
|
|
Packit Service |
fa4841 |
rdpMcsChannel* channel = NULL;
|
|
Packit Service |
fa4841 |
rdpMcs* mcs = NULL;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!rdp)
|
|
Packit Service |
fa4841 |
return NULL;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
mcs = rdp->mcs;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
for (index = 0; index < mcs->channelCount; index++)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
channel = &mcs->channels[index];
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (strncmp(name, channel->Name, CHANNEL_NAME_LEN) == 0)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
return channel;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
return NULL;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
static rdpMcsChannel* freerdp_channels_find_channel_by_id(rdpRdp* rdp, UINT16 channel_id)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
UINT32 index;
|
|
Packit Service |
fa4841 |
rdpMcsChannel* channel = NULL;
|
|
Packit Service |
fa4841 |
rdpMcs* mcs = NULL;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!rdp)
|
|
Packit Service |
fa4841 |
return NULL;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
mcs = rdp->mcs;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
for (index = 0; index < mcs->channelCount; index++)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
channel = &mcs->channels[index];
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (channel->ChannelId == channel_id)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
return channel;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
return NULL;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
static void channel_queue_message_free(wMessage* msg)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
CHANNEL_OPEN_EVENT* ev;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!msg || (msg->id != 0))
|
|
Packit Service |
fa4841 |
return;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
ev = (CHANNEL_OPEN_EVENT*)msg->wParam;
|
|
Packit Service |
fa4841 |
free(ev);
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
static void channel_queue_free(void* obj)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
wMessage* msg = (wMessage*)obj;
|
|
Packit Service |
fa4841 |
freerdp_channels_process_message_free(msg, CHANNEL_EVENT_WRITE_CANCELLED);
|
|
Packit Service |
fa4841 |
channel_queue_message_free(msg);
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
rdpChannels* freerdp_channels_new(freerdp* instance)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
rdpChannels* channels;
|
|
Packit Service |
fa4841 |
channels = (rdpChannels*)calloc(1, sizeof(rdpChannels));
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!channels)
|
|
Packit Service |
fa4841 |
return NULL;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!InitializeCriticalSectionAndSpinCount(&channels->channelsLock, 4000))
|
|
Packit Service |
fa4841 |
goto error;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
channels->instance = instance;
|
|
Packit Service |
fa4841 |
channels->queue = MessageQueue_New(NULL);
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!channels->queue)
|
|
Packit Service |
fa4841 |
goto error;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
channels->queue->object.fnObjectFree = channel_queue_free;
|
|
Packit Service |
fa4841 |
channels->openHandles = HashTable_New(TRUE);
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!channels->openHandles)
|
|
Packit Service |
fa4841 |
goto error;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
return channels;
|
|
Packit Service |
fa4841 |
error:
|
|
Packit Service |
fa4841 |
freerdp_channels_free(channels);
|
|
Packit Service |
fa4841 |
return NULL;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
void freerdp_channels_free(rdpChannels* channels)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
if (!channels)
|
|
Packit Service |
fa4841 |
return;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
DeleteCriticalSection(&channels->channelsLock);
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (channels->queue)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
MessageQueue_Free(channels->queue);
|
|
Packit Service |
fa4841 |
channels->queue = NULL;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (channels->openHandles)
|
|
Packit Service |
fa4841 |
HashTable_Free(channels->openHandles);
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
free(channels);
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
/**
|
|
Packit Service |
fa4841 |
* Function description
|
|
Packit Service |
fa4841 |
*
|
|
Packit Service |
fa4841 |
* @return 0 on success, otherwise a Win32 error code
|
|
Packit Service |
fa4841 |
*/
|
|
Packit Service |
fa4841 |
static UINT freerdp_drdynvc_on_channel_connected(DrdynvcClientContext* context, const char* name,
|
|
Packit Service |
fa4841 |
void* pInterface)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
UINT status = CHANNEL_RC_OK;
|
|
Packit Service |
fa4841 |
ChannelConnectedEventArgs e;
|
|
Packit Service |
fa4841 |
rdpChannels* channels = (rdpChannels*)context->custom;
|
|
Packit Service |
fa4841 |
freerdp* instance = channels->instance;
|
|
Packit Service |
fa4841 |
EventArgsInit(&e, "freerdp");
|
|
Packit Service |
fa4841 |
e.name = name;
|
|
Packit Service |
fa4841 |
e.pInterface = pInterface;
|
|
Packit Service |
fa4841 |
PubSub_OnChannelConnected(instance->context->pubSub, instance->context, &e);
|
|
Packit Service |
fa4841 |
return status;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
/**
|
|
Packit Service |
fa4841 |
* Function description
|
|
Packit Service |
fa4841 |
*
|
|
Packit Service |
fa4841 |
* @return 0 on success, otherwise a Win32 error code
|
|
Packit Service |
fa4841 |
*/
|
|
Packit Service |
fa4841 |
static UINT freerdp_drdynvc_on_channel_disconnected(DrdynvcClientContext* context, const char* name,
|
|
Packit Service |
fa4841 |
void* pInterface)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
UINT status = CHANNEL_RC_OK;
|
|
Packit Service |
fa4841 |
ChannelDisconnectedEventArgs e;
|
|
Packit Service |
fa4841 |
rdpChannels* channels = (rdpChannels*)context->custom;
|
|
Packit Service |
fa4841 |
freerdp* instance = channels->instance;
|
|
Packit Service |
fa4841 |
EventArgsInit(&e, "freerdp");
|
|
Packit Service |
fa4841 |
e.name = name;
|
|
Packit Service |
fa4841 |
e.pInterface = pInterface;
|
|
Packit Service |
fa4841 |
PubSub_OnChannelDisconnected(instance->context->pubSub, instance->context, &e);
|
|
Packit Service |
fa4841 |
return status;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
static UINT freerdp_drdynvc_on_channel_attached(DrdynvcClientContext* context, const char* name,
|
|
Packit Service |
fa4841 |
void* pInterface)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
UINT status = CHANNEL_RC_OK;
|
|
Packit Service |
fa4841 |
ChannelAttachedEventArgs e;
|
|
Packit Service |
fa4841 |
rdpChannels* channels = (rdpChannels*)context->custom;
|
|
Packit Service |
fa4841 |
freerdp* instance = channels->instance;
|
|
Packit Service |
fa4841 |
EventArgsInit(&e, "freerdp");
|
|
Packit Service |
fa4841 |
e.name = name;
|
|
Packit Service |
fa4841 |
e.pInterface = pInterface;
|
|
Packit Service |
fa4841 |
PubSub_OnChannelAttached(instance->context->pubSub, instance->context, &e);
|
|
Packit Service |
fa4841 |
return status;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
static UINT freerdp_drdynvc_on_channel_detached(DrdynvcClientContext* context, const char* name,
|
|
Packit Service |
fa4841 |
void* pInterface)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
UINT status = CHANNEL_RC_OK;
|
|
Packit Service |
fa4841 |
ChannelDetachedEventArgs e;
|
|
Packit Service |
fa4841 |
rdpChannels* channels = (rdpChannels*)context->custom;
|
|
Packit Service |
fa4841 |
freerdp* instance = channels->instance;
|
|
Packit Service |
fa4841 |
EventArgsInit(&e, "freerdp");
|
|
Packit Service |
fa4841 |
e.name = name;
|
|
Packit Service |
fa4841 |
e.pInterface = pInterface;
|
|
Packit Service |
fa4841 |
PubSub_OnChannelDetached(instance->context->pubSub, instance->context, &e);
|
|
Packit Service |
fa4841 |
return status;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
/**
|
|
Packit Service |
fa4841 |
* go through and inform all the libraries that we are initialized
|
|
Packit Service |
fa4841 |
* called only from main thread
|
|
Packit Service |
fa4841 |
*/
|
|
Packit Service |
fa4841 |
UINT freerdp_channels_pre_connect(rdpChannels* channels, freerdp* instance)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
UINT error = CHANNEL_RC_OK;
|
|
Packit Service |
fa4841 |
int index;
|
|
Packit Service |
fa4841 |
CHANNEL_CLIENT_DATA* pChannelClientData;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
for (index = 0; index < channels->clientDataCount; index++)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
pChannelClientData = &channels->clientDataList[index];
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (pChannelClientData->pChannelInitEventProc)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
pChannelClientData->pChannelInitEventProc(pChannelClientData->pInitHandle,
|
|
Packit Service |
fa4841 |
CHANNEL_EVENT_INITIALIZED, 0, 0);
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
else if (pChannelClientData->pChannelInitEventProcEx)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
pChannelClientData->pChannelInitEventProcEx(pChannelClientData->lpUserParam,
|
|
Packit Service |
fa4841 |
pChannelClientData->pInitHandle,
|
|
Packit Service |
fa4841 |
CHANNEL_EVENT_INITIALIZED, 0, 0);
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (CHANNEL_RC_OK != getChannelError(instance->context))
|
|
Packit Service |
fa4841 |
break;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
return error;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
UINT freerdp_channels_attach(freerdp* instance)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
UINT error = CHANNEL_RC_OK;
|
|
Packit Service |
fa4841 |
int index;
|
|
Packit Service |
fa4841 |
char* hostname;
|
|
Packit Service |
fa4841 |
size_t hostnameLength;
|
|
Packit Service |
fa4841 |
rdpChannels* channels;
|
|
Packit Service |
fa4841 |
CHANNEL_CLIENT_DATA* pChannelClientData;
|
|
Packit Service |
fa4841 |
channels = instance->context->channels;
|
|
Packit Service |
fa4841 |
hostname = instance->settings->ServerHostname;
|
|
Packit Service |
fa4841 |
hostnameLength = strlen(hostname);
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
for (index = 0; index < channels->clientDataCount; index++)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
ChannelAttachedEventArgs e;
|
|
Packit Service |
fa4841 |
CHANNEL_OPEN_DATA* pChannelOpenData = NULL;
|
|
Packit Service |
fa4841 |
pChannelClientData = &channels->clientDataList[index];
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (pChannelClientData->pChannelInitEventProc)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
pChannelClientData->pChannelInitEventProc(
|
|
Packit Service |
fa4841 |
pChannelClientData->pInitHandle, CHANNEL_EVENT_ATTACHED, hostname, hostnameLength);
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
else if (pChannelClientData->pChannelInitEventProcEx)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
pChannelClientData->pChannelInitEventProcEx(
|
|
Packit Service |
fa4841 |
pChannelClientData->lpUserParam, pChannelClientData->pInitHandle,
|
|
Packit Service |
fa4841 |
CHANNEL_EVENT_ATTACHED, hostname, hostnameLength);
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (getChannelError(instance->context) != CHANNEL_RC_OK)
|
|
Packit Service |
fa4841 |
goto fail;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
pChannelOpenData = &channels->openDataList[index];
|
|
Packit Service |
fa4841 |
EventArgsInit(&e, "freerdp");
|
|
Packit Service |
fa4841 |
e.name = pChannelOpenData->name;
|
|
Packit Service |
fa4841 |
e.pInterface = pChannelOpenData->pInterface;
|
|
Packit Service |
fa4841 |
PubSub_OnChannelAttached(instance->context->pubSub, instance->context, &e);
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
fail:
|
|
Packit Service |
fa4841 |
return error;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
UINT freerdp_channels_detach(freerdp* instance)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
UINT error = CHANNEL_RC_OK;
|
|
Packit Service |
fa4841 |
int index;
|
|
Packit Service |
fa4841 |
char* hostname;
|
|
Packit Service |
fa4841 |
size_t hostnameLength;
|
|
Packit Service |
fa4841 |
rdpChannels* channels;
|
|
Packit Service |
fa4841 |
CHANNEL_CLIENT_DATA* pChannelClientData;
|
|
Packit Service |
fa4841 |
channels = instance->context->channels;
|
|
Packit Service |
fa4841 |
hostname = instance->settings->ServerHostname;
|
|
Packit Service |
fa4841 |
hostnameLength = strlen(hostname);
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
for (index = 0; index < channels->clientDataCount; index++)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
ChannelDetachedEventArgs e;
|
|
Packit Service |
fa4841 |
CHANNEL_OPEN_DATA* pChannelOpenData;
|
|
Packit Service |
fa4841 |
pChannelClientData = &channels->clientDataList[index];
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (pChannelClientData->pChannelInitEventProc)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
pChannelClientData->pChannelInitEventProc(
|
|
Packit Service |
fa4841 |
pChannelClientData->pInitHandle, CHANNEL_EVENT_DETACHED, hostname, hostnameLength);
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
else if (pChannelClientData->pChannelInitEventProcEx)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
pChannelClientData->pChannelInitEventProcEx(
|
|
Packit Service |
fa4841 |
pChannelClientData->lpUserParam, pChannelClientData->pInitHandle,
|
|
Packit Service |
fa4841 |
CHANNEL_EVENT_DETACHED, hostname, hostnameLength);
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (getChannelError(instance->context) != CHANNEL_RC_OK)
|
|
Packit Service |
fa4841 |
goto fail;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
pChannelOpenData = &channels->openDataList[index];
|
|
Packit Service |
fa4841 |
EventArgsInit(&e, "freerdp");
|
|
Packit Service |
fa4841 |
e.name = pChannelOpenData->name;
|
|
Packit Service |
fa4841 |
e.pInterface = pChannelOpenData->pInterface;
|
|
Packit Service |
fa4841 |
PubSub_OnChannelDetached(instance->context->pubSub, instance->context, &e);
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
fail:
|
|
Packit Service |
fa4841 |
return error;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
/**
|
|
Packit Service |
fa4841 |
* go through and inform all the libraries that we are connected
|
|
Packit Service |
fa4841 |
* this will tell the libraries that its ok to call MyVirtualChannelOpen
|
|
Packit Service |
fa4841 |
* called only from main thread
|
|
Packit Service |
fa4841 |
*/
|
|
Packit Service |
fa4841 |
UINT freerdp_channels_post_connect(rdpChannels* channels, freerdp* instance)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
UINT error = CHANNEL_RC_OK;
|
|
Packit Service |
fa4841 |
int index;
|
|
Packit Service |
fa4841 |
char* hostname;
|
|
Packit Service |
fa4841 |
size_t hostnameLength;
|
|
Packit Service |
fa4841 |
CHANNEL_CLIENT_DATA* pChannelClientData;
|
|
Packit Service |
fa4841 |
channels->connected = TRUE;
|
|
Packit Service |
fa4841 |
hostname = instance->settings->ServerHostname;
|
|
Packit Service |
fa4841 |
hostnameLength = strlen(hostname);
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
for (index = 0; index < channels->clientDataCount; index++)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
ChannelConnectedEventArgs e;
|
|
Packit Service |
fa4841 |
CHANNEL_OPEN_DATA* pChannelOpenData;
|
|
Packit Service |
fa4841 |
pChannelClientData = &channels->clientDataList[index];
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (pChannelClientData->pChannelInitEventProc)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
pChannelClientData->pChannelInitEventProc(
|
|
Packit Service |
fa4841 |
pChannelClientData->pInitHandle, CHANNEL_EVENT_CONNECTED, hostname, hostnameLength);
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
else if (pChannelClientData->pChannelInitEventProcEx)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
pChannelClientData->pChannelInitEventProcEx(
|
|
Packit Service |
fa4841 |
pChannelClientData->lpUserParam, pChannelClientData->pInitHandle,
|
|
Packit Service |
fa4841 |
CHANNEL_EVENT_CONNECTED, hostname, hostnameLength);
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (getChannelError(instance->context) != CHANNEL_RC_OK)
|
|
Packit Service |
fa4841 |
goto fail;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
pChannelOpenData = &channels->openDataList[index];
|
|
Packit Service |
fa4841 |
EventArgsInit(&e, "freerdp");
|
|
Packit Service |
fa4841 |
e.name = pChannelOpenData->name;
|
|
Packit Service |
fa4841 |
e.pInterface = pChannelOpenData->pInterface;
|
|
Packit Service |
fa4841 |
PubSub_OnChannelConnected(instance->context->pubSub, instance->context, &e);
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
channels->drdynvc =
|
|
Packit Service |
fa4841 |
(DrdynvcClientContext*)freerdp_channels_get_static_channel_interface(channels, "drdynvc");
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (channels->drdynvc)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
channels->drdynvc->custom = (void*)channels;
|
|
Packit Service |
fa4841 |
channels->drdynvc->OnChannelConnected = freerdp_drdynvc_on_channel_connected;
|
|
Packit Service |
fa4841 |
channels->drdynvc->OnChannelDisconnected = freerdp_drdynvc_on_channel_disconnected;
|
|
Packit Service |
fa4841 |
channels->drdynvc->OnChannelAttached = freerdp_drdynvc_on_channel_attached;
|
|
Packit Service |
fa4841 |
channels->drdynvc->OnChannelDetached = freerdp_drdynvc_on_channel_detached;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
fail:
|
|
Packit Service |
fa4841 |
return error;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
BOOL freerdp_channels_data(freerdp* instance, UINT16 channelId, const BYTE* cdata, size_t dataSize,
|
|
Packit Service |
fa4841 |
UINT32 flags, size_t totalSize)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
UINT32 index;
|
|
Packit Service |
fa4841 |
rdpMcs* mcs;
|
|
Packit Service |
fa4841 |
rdpChannels* channels;
|
|
Packit Service |
fa4841 |
rdpMcsChannel* channel = NULL;
|
|
Packit Service |
fa4841 |
CHANNEL_OPEN_DATA* pChannelOpenData;
|
|
Packit Service |
fa4841 |
union {
|
|
Packit Service |
fa4841 |
const BYTE* pcb;
|
|
Packit Service |
fa4841 |
BYTE* pb;
|
|
Packit Service |
fa4841 |
} data;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
data.pcb = cdata;
|
|
Packit Service |
fa4841 |
if (!instance || !data.pcb)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
WLog_ERR(TAG, "%s(%p, %" PRIu16 ", %p, 0x%08x): Invalid arguments", __FUNCTION__, instance,
|
|
Packit Service |
fa4841 |
channelId, data, flags);
|
|
Packit Service |
fa4841 |
return FALSE;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
mcs = instance->context->rdp->mcs;
|
|
Packit Service |
fa4841 |
channels = instance->context->channels;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!channels || !mcs)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
return FALSE;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
for (index = 0; index < mcs->channelCount; index++)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
if (mcs->channels[index].ChannelId == channelId)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
channel = &mcs->channels[index];
|
|
Packit Service |
fa4841 |
break;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!channel)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
return FALSE;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
pChannelOpenData = freerdp_channels_find_channel_open_data_by_name(channels, channel->Name);
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!pChannelOpenData)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
return FALSE;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (pChannelOpenData->pChannelOpenEventProc)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
pChannelOpenData->pChannelOpenEventProc(pChannelOpenData->OpenHandle,
|
|
Packit Service |
fa4841 |
CHANNEL_EVENT_DATA_RECEIVED, data.pb, dataSize,
|
|
Packit Service |
fa4841 |
totalSize, flags);
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
else if (pChannelOpenData->pChannelOpenEventProcEx)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
pChannelOpenData->pChannelOpenEventProcEx(
|
|
Packit Service |
fa4841 |
pChannelOpenData->lpUserParam, pChannelOpenData->OpenHandle,
|
|
Packit Service |
fa4841 |
CHANNEL_EVENT_DATA_RECEIVED, data.pb, dataSize, totalSize, flags);
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
return TRUE;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
UINT16 freerdp_channels_get_id_by_name(freerdp* instance, const char* channel_name)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
rdpMcsChannel* mcsChannel;
|
|
Packit Service |
fa4841 |
if (!instance || !channel_name)
|
|
Packit Service |
fa4841 |
return -1;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
mcsChannel = freerdp_channels_find_channel_by_name(instance->context->rdp, channel_name);
|
|
Packit Service |
fa4841 |
if (!mcsChannel)
|
|
Packit Service |
fa4841 |
return -1;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
return mcsChannel->ChannelId;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
const char* freerdp_channels_get_name_by_id(freerdp* instance, UINT16 channelId)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
rdpMcsChannel* mcsChannel;
|
|
Packit Service |
fa4841 |
if (!instance)
|
|
Packit Service |
fa4841 |
return NULL;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
mcsChannel = freerdp_channels_find_channel_by_id(instance->context->rdp, channelId);
|
|
Packit Service |
fa4841 |
if (!mcsChannel)
|
|
Packit Service |
fa4841 |
return NULL;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
return (const char*)mcsChannel->Name;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
BOOL freerdp_channels_process_message_free(wMessage* message, DWORD type)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
if (message->id == WMQ_QUIT)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
return FALSE;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (message->id == 0)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
CHANNEL_OPEN_DATA* pChannelOpenData;
|
|
Packit Service |
fa4841 |
CHANNEL_OPEN_EVENT* item = (CHANNEL_OPEN_EVENT*)message->wParam;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!item)
|
|
Packit Service |
fa4841 |
return FALSE;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
pChannelOpenData = item->pChannelOpenData;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (pChannelOpenData->pChannelOpenEventProc)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
pChannelOpenData->pChannelOpenEventProc(pChannelOpenData->OpenHandle, type,
|
|
Packit Service |
fa4841 |
item->UserData, item->DataLength,
|
|
Packit Service |
fa4841 |
item->DataLength, 0);
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
else if (pChannelOpenData->pChannelOpenEventProcEx)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
pChannelOpenData->pChannelOpenEventProcEx(
|
|
Packit Service |
fa4841 |
pChannelOpenData->lpUserParam, pChannelOpenData->OpenHandle, type, item->UserData,
|
|
Packit Service |
fa4841 |
item->DataLength, item->DataLength, 0);
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
return TRUE;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
static BOOL freerdp_channels_process_message(freerdp* instance, wMessage* message)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
if (message->id == WMQ_QUIT)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
return FALSE;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (message->id == 0)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
rdpMcsChannel* channel;
|
|
Packit Service |
fa4841 |
CHANNEL_OPEN_DATA* pChannelOpenData;
|
|
Packit Service |
fa4841 |
CHANNEL_OPEN_EVENT* item = (CHANNEL_OPEN_EVENT*)message->wParam;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!item)
|
|
Packit Service |
fa4841 |
return FALSE;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
pChannelOpenData = item->pChannelOpenData;
|
|
Packit Service |
fa4841 |
channel =
|
|
Packit Service |
fa4841 |
freerdp_channels_find_channel_by_name(instance->context->rdp, pChannelOpenData->name);
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (channel)
|
|
Packit Service |
fa4841 |
instance->SendChannelData(instance, channel->ChannelId, item->Data, item->DataLength);
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!freerdp_channels_process_message_free(message, CHANNEL_EVENT_WRITE_COMPLETE))
|
|
Packit Service |
fa4841 |
return FALSE;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
IFCALL(message->Free, message);
|
|
Packit Service |
fa4841 |
return TRUE;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
/**
|
|
Packit Service |
fa4841 |
* called only from main thread
|
|
Packit Service |
fa4841 |
*/
|
|
Packit Service |
fa4841 |
static int freerdp_channels_process_sync(rdpChannels* channels, freerdp* instance)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
int status = TRUE;
|
|
Packit Service |
fa4841 |
wMessage message;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
while (MessageQueue_Peek(channels->queue, &message, TRUE))
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
freerdp_channels_process_message(instance, &message);
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
return status;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
/**
|
|
Packit Service |
fa4841 |
* called only from main thread
|
|
Packit Service |
fa4841 |
*/
|
|
Packit Service |
fa4841 |
BOOL freerdp_channels_get_fds(rdpChannels* channels, freerdp* instance, void** read_fds,
|
|
Packit Service |
fa4841 |
int* read_count, void** write_fds, int* write_count)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
void* pfd;
|
|
Packit Service |
fa4841 |
pfd = GetEventWaitObject(MessageQueue_Event(channels->queue));
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (pfd)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
read_fds[*read_count] = pfd;
|
|
Packit Service |
fa4841 |
(*read_count)++;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
return TRUE;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
void* freerdp_channels_get_static_channel_interface(rdpChannels* channels, const char* name)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
void* pInterface = NULL;
|
|
Packit Service |
fa4841 |
CHANNEL_OPEN_DATA* pChannelOpenData;
|
|
Packit Service |
fa4841 |
pChannelOpenData = freerdp_channels_find_channel_open_data_by_name(channels, name);
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (pChannelOpenData)
|
|
Packit Service |
fa4841 |
pInterface = pChannelOpenData->pInterface;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
return pInterface;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
HANDLE freerdp_channels_get_event_handle(freerdp* instance)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
HANDLE event = NULL;
|
|
Packit Service |
fa4841 |
rdpChannels* channels;
|
|
Packit Service |
fa4841 |
channels = instance->context->channels;
|
|
Packit Service |
fa4841 |
event = MessageQueue_Event(channels->queue);
|
|
Packit Service |
fa4841 |
return event;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
int freerdp_channels_process_pending_messages(freerdp* instance)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
rdpChannels* channels;
|
|
Packit Service |
fa4841 |
channels = instance->context->channels;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (WaitForSingleObject(MessageQueue_Event(channels->queue), 0) == WAIT_OBJECT_0)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
return freerdp_channels_process_sync(channels, instance);
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
return TRUE;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
/**
|
|
Packit Service |
fa4841 |
* called only from main thread
|
|
Packit Service |
fa4841 |
*/
|
|
Packit Service |
fa4841 |
BOOL freerdp_channels_check_fds(rdpChannels* channels, freerdp* instance)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
if (WaitForSingleObject(MessageQueue_Event(channels->queue), 0) == WAIT_OBJECT_0)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
freerdp_channels_process_sync(channels, instance);
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
return TRUE;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
UINT freerdp_channels_disconnect(rdpChannels* channels, freerdp* instance)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
UINT error = CHANNEL_RC_OK;
|
|
Packit Service |
fa4841 |
int index;
|
|
Packit Service |
fa4841 |
CHANNEL_OPEN_DATA* pChannelOpenData;
|
|
Packit Service |
fa4841 |
CHANNEL_CLIENT_DATA* pChannelClientData;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!channels->connected)
|
|
Packit Service |
fa4841 |
return 0;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
freerdp_channels_check_fds(channels, instance);
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
/* tell all libraries we are shutting down */
|
|
Packit Service |
fa4841 |
for (index = 0; index < channels->clientDataCount; index++)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
ChannelDisconnectedEventArgs e;
|
|
Packit Service |
fa4841 |
pChannelClientData = &channels->clientDataList[index];
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (pChannelClientData->pChannelInitEventProc)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
pChannelClientData->pChannelInitEventProc(pChannelClientData->pInitHandle,
|
|
Packit Service |
fa4841 |
CHANNEL_EVENT_DISCONNECTED, 0, 0);
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
else if (pChannelClientData->pChannelInitEventProcEx)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
pChannelClientData->pChannelInitEventProcEx(pChannelClientData->lpUserParam,
|
|
Packit Service |
fa4841 |
pChannelClientData->pInitHandle,
|
|
Packit Service |
fa4841 |
CHANNEL_EVENT_DISCONNECTED, 0, 0);
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (getChannelError(instance->context) != CHANNEL_RC_OK)
|
|
Packit Service |
fa4841 |
continue;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
pChannelOpenData = &channels->openDataList[index];
|
|
Packit Service |
fa4841 |
EventArgsInit(&e, "freerdp");
|
|
Packit Service |
fa4841 |
e.name = pChannelOpenData->name;
|
|
Packit Service |
fa4841 |
e.pInterface = pChannelOpenData->pInterface;
|
|
Packit Service |
fa4841 |
PubSub_OnChannelDisconnected(instance->context->pubSub, instance->context, &e);
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
channels->connected = FALSE;
|
|
Packit Service |
fa4841 |
return error;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
void freerdp_channels_close(rdpChannels* channels, freerdp* instance)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
int index;
|
|
Packit Service |
fa4841 |
CHANNEL_OPEN_DATA* pChannelOpenData;
|
|
Packit Service |
fa4841 |
CHANNEL_CLIENT_DATA* pChannelClientData;
|
|
Packit Service |
fa4841 |
freerdp_channels_check_fds(channels, instance);
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
/* tell all libraries we are shutting down */
|
|
Packit Service |
fa4841 |
for (index = 0; index < channels->clientDataCount; index++)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
pChannelClientData = &channels->clientDataList[index];
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (pChannelClientData->pChannelInitEventProc)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
pChannelClientData->pChannelInitEventProc(pChannelClientData->pInitHandle,
|
|
Packit Service |
fa4841 |
CHANNEL_EVENT_TERMINATED, 0, 0);
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
else if (pChannelClientData->pChannelInitEventProcEx)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
pChannelClientData->pChannelInitEventProcEx(pChannelClientData->lpUserParam,
|
|
Packit Service |
fa4841 |
pChannelClientData->pInitHandle,
|
|
Packit Service |
fa4841 |
CHANNEL_EVENT_TERMINATED, 0, 0);
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
channels->clientDataCount = 0;
|
|
Packit Service |
fa4841 |
MessageQueue_PostQuit(channels->queue, 0);
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
for (index = 0; index < channels->openDataCount; index++)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
pChannelOpenData = &channels->openDataList[index];
|
|
Packit Service |
fa4841 |
freerdp_channel_remove_open_handle_data(&g_ChannelHandles, pChannelOpenData->OpenHandle);
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (channels->openHandles)
|
|
Packit Service |
fa4841 |
HashTable_Remove(channels->openHandles, (void*)(UINT_PTR)pChannelOpenData->OpenHandle);
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
channels->openDataCount = 0;
|
|
Packit Service |
fa4841 |
channels->initDataCount = 0;
|
|
Packit Service |
fa4841 |
instance->settings->ChannelCount = 0;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
static UINT VCAPITYPE FreeRDP_VirtualChannelInitEx(
|
|
Packit Service |
fa4841 |
LPVOID lpUserParam, LPVOID clientContext, LPVOID pInitHandle, PCHANNEL_DEF pChannel,
|
|
Packit Service |
fa4841 |
INT channelCount, ULONG versionRequested, PCHANNEL_INIT_EVENT_EX_FN pChannelInitEventProcEx)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
INT index;
|
|
Packit Service |
fa4841 |
CHANNEL_DEF* channel;
|
|
Packit Service |
fa4841 |
rdpSettings* settings;
|
|
Packit Service |
fa4841 |
PCHANNEL_DEF pChannelDef;
|
|
Packit Service |
fa4841 |
CHANNEL_INIT_DATA* pChannelInitData;
|
|
Packit Service |
fa4841 |
CHANNEL_OPEN_DATA* pChannelOpenData;
|
|
Packit Service |
fa4841 |
CHANNEL_CLIENT_DATA* pChannelClientData;
|
|
Packit Service |
fa4841 |
rdpChannels* channels = (rdpChannels*)pInitHandle;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!pInitHandle)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_BAD_INIT_HANDLE;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!pChannel)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_BAD_CHANNEL;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if ((channelCount <= 0) || !pChannelInitEventProcEx)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_INITIALIZATION_ERROR;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
pChannelInitData = (CHANNEL_INIT_DATA*)pInitHandle;
|
|
Packit Service |
fa4841 |
channels = pChannelInitData->channels;
|
|
Packit Service |
fa4841 |
pChannelInitData->pInterface = clientContext;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!channels->can_call_init)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_NOT_IN_VIRTUALCHANNELENTRY;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if ((channels->openDataCount + channelCount) > CHANNEL_MAX_COUNT)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_TOO_MANY_CHANNELS;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (channels->connected)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_ALREADY_CONNECTED;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (versionRequested != VIRTUAL_CHANNEL_VERSION_WIN2000)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
for (index = 0; index < channelCount; index++)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
pChannelDef = &pChannel[index];
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (freerdp_channels_find_channel_open_data_by_name(channels, pChannelDef->name) != 0)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_BAD_CHANNEL;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
pChannelClientData = &channels->clientDataList[channels->clientDataCount];
|
|
Packit Service |
fa4841 |
pChannelClientData->pChannelInitEventProcEx = pChannelInitEventProcEx;
|
|
Packit Service |
fa4841 |
pChannelClientData->pInitHandle = pInitHandle;
|
|
Packit Service |
fa4841 |
pChannelClientData->lpUserParam = lpUserParam;
|
|
Packit Service |
fa4841 |
channels->clientDataCount++;
|
|
Packit Service |
fa4841 |
settings = channels->instance->context->settings;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
for (index = 0; index < channelCount; index++)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
pChannelDef = &pChannel[index];
|
|
Packit Service |
fa4841 |
pChannelOpenData = &channels->openDataList[channels->openDataCount];
|
|
Packit Service |
fa4841 |
pChannelOpenData->OpenHandle = InterlockedIncrement(&g_OpenHandleSeq);
|
|
Packit Service |
fa4841 |
pChannelOpenData->channels = channels;
|
|
Packit Service |
fa4841 |
pChannelOpenData->lpUserParam = lpUserParam;
|
|
Packit Service |
fa4841 |
HashTable_Add(channels->openHandles, (void*)(UINT_PTR)pChannelOpenData->OpenHandle,
|
|
Packit Service |
fa4841 |
(void*)pChannelOpenData);
|
|
Packit Service |
fa4841 |
pChannelOpenData->flags = 1; /* init */
|
|
Packit Service |
fa4841 |
strncpy(pChannelOpenData->name, pChannelDef->name, CHANNEL_NAME_LEN);
|
|
Packit Service |
fa4841 |
pChannelOpenData->options = pChannelDef->options;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (settings->ChannelCount < CHANNEL_MAX_COUNT)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
channel = &settings->ChannelDefArray[settings->ChannelCount];
|
|
Packit Service |
fa4841 |
strncpy(channel->name, pChannelDef->name, 7);
|
|
Packit Service |
fa4841 |
channel->options = pChannelDef->options;
|
|
Packit Service |
fa4841 |
settings->ChannelCount++;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
channels->openDataCount++;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_OK;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
static UINT VCAPITYPE FreeRDP_VirtualChannelInit(LPVOID* ppInitHandle, PCHANNEL_DEF pChannel,
|
|
Packit Service |
fa4841 |
INT channelCount, ULONG versionRequested,
|
|
Packit Service |
fa4841 |
PCHANNEL_INIT_EVENT_FN pChannelInitEventProc)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
INT index;
|
|
Packit Service |
fa4841 |
void* pInterface;
|
|
Packit Service |
fa4841 |
CHANNEL_DEF* channel;
|
|
Packit Service |
fa4841 |
rdpSettings* settings;
|
|
Packit Service |
fa4841 |
PCHANNEL_DEF pChannelDef;
|
|
Packit Service |
fa4841 |
CHANNEL_INIT_DATA* pChannelInitData;
|
|
Packit Service |
fa4841 |
CHANNEL_OPEN_DATA* pChannelOpenData;
|
|
Packit Service |
fa4841 |
CHANNEL_CLIENT_DATA* pChannelClientData;
|
|
Packit Service |
fa4841 |
rdpChannels* channels = g_channels;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!ppInitHandle || !channels)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_BAD_INIT_HANDLE;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!pChannel)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_BAD_CHANNEL;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if ((channelCount <= 0) || !pChannelInitEventProc)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_INITIALIZATION_ERROR;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
pInterface = g_pInterface;
|
|
Packit Service |
fa4841 |
pChannelInitData = &(channels->initDataList[channels->initDataCount]);
|
|
Packit Service |
fa4841 |
*ppInitHandle = pChannelInitData;
|
|
Packit Service |
fa4841 |
channels->initDataCount++;
|
|
Packit Service |
fa4841 |
pChannelInitData->channels = channels;
|
|
Packit Service |
fa4841 |
pChannelInitData->pInterface = pInterface;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!channels->can_call_init)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_NOT_IN_VIRTUALCHANNELENTRY;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (channels->openDataCount + channelCount > CHANNEL_MAX_COUNT)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_TOO_MANY_CHANNELS;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (channels->connected)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_ALREADY_CONNECTED;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (versionRequested != VIRTUAL_CHANNEL_VERSION_WIN2000)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
for (index = 0; index < channelCount; index++)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
pChannelDef = &pChannel[index];
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (freerdp_channels_find_channel_open_data_by_name(channels, pChannelDef->name) != 0)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_BAD_CHANNEL;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
pChannelClientData = &channels->clientDataList[channels->clientDataCount];
|
|
Packit Service |
fa4841 |
pChannelClientData->pChannelInitEventProc = pChannelInitEventProc;
|
|
Packit Service |
fa4841 |
pChannelClientData->pInitHandle = *ppInitHandle;
|
|
Packit Service |
fa4841 |
channels->clientDataCount++;
|
|
Packit Service |
fa4841 |
settings = channels->instance->context->settings;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
for (index = 0; index < channelCount; index++)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
pChannelDef = &pChannel[index];
|
|
Packit Service |
fa4841 |
pChannelOpenData = &channels->openDataList[channels->openDataCount];
|
|
Packit Service |
fa4841 |
pChannelOpenData->OpenHandle = InterlockedIncrement(&g_OpenHandleSeq);
|
|
Packit Service |
fa4841 |
pChannelOpenData->channels = channels;
|
|
Packit Service |
fa4841 |
freerdp_channel_add_open_handle_data(&g_ChannelHandles, pChannelOpenData->OpenHandle,
|
|
Packit Service |
fa4841 |
(void*)channels);
|
|
Packit Service |
fa4841 |
HashTable_Add(channels->openHandles, (void*)(UINT_PTR)pChannelOpenData->OpenHandle,
|
|
Packit Service |
fa4841 |
(void*)pChannelOpenData);
|
|
Packit Service |
fa4841 |
pChannelOpenData->flags = 1; /* init */
|
|
Packit Service |
fa4841 |
strncpy(pChannelOpenData->name, pChannelDef->name, CHANNEL_NAME_LEN);
|
|
Packit Service |
fa4841 |
pChannelOpenData->options = pChannelDef->options;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (settings->ChannelCount < CHANNEL_MAX_COUNT)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
channel = &settings->ChannelDefArray[settings->ChannelCount];
|
|
Packit Service |
fa4841 |
strncpy(channel->name, pChannelDef->name, 7);
|
|
Packit Service |
fa4841 |
channel->options = pChannelDef->options;
|
|
Packit Service |
fa4841 |
settings->ChannelCount++;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
channels->openDataCount++;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_OK;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
static UINT VCAPITYPE
|
|
Packit Service |
fa4841 |
FreeRDP_VirtualChannelOpenEx(LPVOID pInitHandle, LPDWORD pOpenHandle, PCHAR pChannelName,
|
|
Packit Service |
fa4841 |
PCHANNEL_OPEN_EVENT_EX_FN pChannelOpenEventProcEx)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
void* pInterface;
|
|
Packit Service |
fa4841 |
rdpChannels* channels;
|
|
Packit Service |
fa4841 |
CHANNEL_INIT_DATA* pChannelInitData;
|
|
Packit Service |
fa4841 |
CHANNEL_OPEN_DATA* pChannelOpenData;
|
|
Packit Service |
fa4841 |
pChannelInitData = (CHANNEL_INIT_DATA*)pInitHandle;
|
|
Packit Service |
fa4841 |
channels = pChannelInitData->channels;
|
|
Packit Service |
fa4841 |
pInterface = pChannelInitData->pInterface;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!pOpenHandle)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_BAD_CHANNEL_HANDLE;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!pChannelOpenEventProcEx)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_BAD_PROC;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!channels->connected)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_NOT_CONNECTED;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
pChannelOpenData = freerdp_channels_find_channel_open_data_by_name(channels, pChannelName);
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!pChannelOpenData)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_UNKNOWN_CHANNEL_NAME;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (pChannelOpenData->flags == 2)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_ALREADY_OPEN;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
pChannelOpenData->flags = 2; /* open */
|
|
Packit Service |
fa4841 |
pChannelOpenData->pInterface = pInterface;
|
|
Packit Service |
fa4841 |
pChannelOpenData->pChannelOpenEventProcEx = pChannelOpenEventProcEx;
|
|
Packit Service |
fa4841 |
*pOpenHandle = pChannelOpenData->OpenHandle;
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_OK;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
static UINT VCAPITYPE FreeRDP_VirtualChannelOpen(LPVOID pInitHandle, LPDWORD pOpenHandle,
|
|
Packit Service |
fa4841 |
PCHAR pChannelName,
|
|
Packit Service |
fa4841 |
PCHANNEL_OPEN_EVENT_FN pChannelOpenEventProc)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
void* pInterface;
|
|
Packit Service |
fa4841 |
rdpChannels* channels;
|
|
Packit Service |
fa4841 |
CHANNEL_INIT_DATA* pChannelInitData;
|
|
Packit Service |
fa4841 |
CHANNEL_OPEN_DATA* pChannelOpenData;
|
|
Packit Service |
fa4841 |
pChannelInitData = (CHANNEL_INIT_DATA*)pInitHandle;
|
|
Packit Service |
fa4841 |
channels = pChannelInitData->channels;
|
|
Packit Service |
fa4841 |
pInterface = pChannelInitData->pInterface;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!pOpenHandle)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_BAD_CHANNEL_HANDLE;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!pChannelOpenEventProc)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_BAD_PROC;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!channels->connected)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_NOT_CONNECTED;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
pChannelOpenData = freerdp_channels_find_channel_open_data_by_name(channels, pChannelName);
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!pChannelOpenData)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_UNKNOWN_CHANNEL_NAME;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (pChannelOpenData->flags == 2)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_ALREADY_OPEN;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
pChannelOpenData->flags = 2; /* open */
|
|
Packit Service |
fa4841 |
pChannelOpenData->pInterface = pInterface;
|
|
Packit Service |
fa4841 |
pChannelOpenData->pChannelOpenEventProc = pChannelOpenEventProc;
|
|
Packit Service |
fa4841 |
*pOpenHandle = pChannelOpenData->OpenHandle;
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_OK;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
static UINT VCAPITYPE FreeRDP_VirtualChannelCloseEx(LPVOID pInitHandle, DWORD openHandle)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
rdpChannels* channels = NULL;
|
|
Packit Service |
fa4841 |
CHANNEL_INIT_DATA* pChannelInitData = NULL;
|
|
Packit Service |
fa4841 |
CHANNEL_OPEN_DATA* pChannelOpenData = NULL;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!pInitHandle)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_BAD_INIT_HANDLE;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
pChannelInitData = (CHANNEL_INIT_DATA*)pInitHandle;
|
|
Packit Service |
fa4841 |
channels = pChannelInitData->channels;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!channels)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_BAD_CHANNEL_HANDLE;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
pChannelOpenData = HashTable_GetItemValue(channels->openHandles, (void*)(UINT_PTR)openHandle);
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!pChannelOpenData)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_BAD_CHANNEL_HANDLE;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (pChannelOpenData->flags != 2)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_NOT_OPEN;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
pChannelOpenData->flags = 0;
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_OK;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
static UINT VCAPITYPE FreeRDP_VirtualChannelClose(DWORD openHandle)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
rdpChannels* channels;
|
|
Packit Service |
fa4841 |
CHANNEL_OPEN_DATA* pChannelOpenData;
|
|
Packit Service |
fa4841 |
channels = (rdpChannels*)freerdp_channel_get_open_handle_data(&g_ChannelHandles, openHandle);
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!channels)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_BAD_CHANNEL_HANDLE;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
pChannelOpenData = HashTable_GetItemValue(channels->openHandles, (void*)(UINT_PTR)openHandle);
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!pChannelOpenData)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_BAD_CHANNEL_HANDLE;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (pChannelOpenData->flags != 2)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_NOT_OPEN;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
pChannelOpenData->flags = 0;
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_OK;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
static UINT VCAPITYPE FreeRDP_VirtualChannelWriteEx(LPVOID pInitHandle, DWORD openHandle,
|
|
Packit Service |
fa4841 |
LPVOID pData, ULONG dataLength,
|
|
Packit Service |
fa4841 |
LPVOID pUserData)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
rdpChannels* channels = NULL;
|
|
Packit Service |
fa4841 |
CHANNEL_INIT_DATA* pChannelInitData = NULL;
|
|
Packit Service |
fa4841 |
CHANNEL_OPEN_DATA* pChannelOpenData = NULL;
|
|
Packit Service |
fa4841 |
CHANNEL_OPEN_EVENT* pChannelOpenEvent = NULL;
|
|
Packit Service |
fa4841 |
wMessage message;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!pInitHandle)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_BAD_INIT_HANDLE;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
pChannelInitData = (CHANNEL_INIT_DATA*)pInitHandle;
|
|
Packit Service |
fa4841 |
channels = pChannelInitData->channels;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!channels)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_BAD_CHANNEL_HANDLE;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
pChannelOpenData = HashTable_GetItemValue(channels->openHandles, (void*)(UINT_PTR)openHandle);
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!pChannelOpenData)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_BAD_CHANNEL_HANDLE;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!channels->connected)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_NOT_CONNECTED;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!pData)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_NULL_DATA;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!dataLength)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_ZERO_LENGTH;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (pChannelOpenData->flags != 2)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_NOT_OPEN;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
pChannelOpenEvent = (CHANNEL_OPEN_EVENT*)malloc(sizeof(CHANNEL_OPEN_EVENT));
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!pChannelOpenEvent)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_NO_MEMORY;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
pChannelOpenEvent->Data = pData;
|
|
Packit Service |
fa4841 |
pChannelOpenEvent->DataLength = dataLength;
|
|
Packit Service |
fa4841 |
pChannelOpenEvent->UserData = pUserData;
|
|
Packit Service |
fa4841 |
pChannelOpenEvent->pChannelOpenData = pChannelOpenData;
|
|
Packit Service |
fa4841 |
message.context = channels;
|
|
Packit Service |
fa4841 |
message.id = 0;
|
|
Packit Service |
fa4841 |
message.wParam = pChannelOpenEvent;
|
|
Packit Service |
fa4841 |
message.lParam = NULL;
|
|
Packit Service |
fa4841 |
message.Free = channel_queue_message_free;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!MessageQueue_Dispatch(channels->queue, &message))
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
free(pChannelOpenEvent);
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_NO_MEMORY;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_OK;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
static UINT VCAPITYPE FreeRDP_VirtualChannelWrite(DWORD openHandle, LPVOID pData, ULONG dataLength,
|
|
Packit Service |
fa4841 |
LPVOID pUserData)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
wMessage message;
|
|
Packit Service |
fa4841 |
CHANNEL_OPEN_DATA* pChannelOpenData;
|
|
Packit Service |
fa4841 |
CHANNEL_OPEN_EVENT* pChannelOpenEvent;
|
|
Packit Service |
fa4841 |
rdpChannels* channels =
|
|
Packit Service |
fa4841 |
(rdpChannels*)freerdp_channel_get_open_handle_data(&g_ChannelHandles, openHandle);
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!channels)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_BAD_CHANNEL_HANDLE;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
pChannelOpenData = HashTable_GetItemValue(channels->openHandles, (void*)(UINT_PTR)openHandle);
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!pChannelOpenData)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_BAD_CHANNEL_HANDLE;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!channels->connected)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_NOT_CONNECTED;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!pData)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_NULL_DATA;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!dataLength)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_ZERO_LENGTH;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (pChannelOpenData->flags != 2)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_NOT_OPEN;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
pChannelOpenEvent = (CHANNEL_OPEN_EVENT*)malloc(sizeof(CHANNEL_OPEN_EVENT));
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!pChannelOpenEvent)
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_NO_MEMORY;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
pChannelOpenEvent->Data = pData;
|
|
Packit Service |
fa4841 |
pChannelOpenEvent->DataLength = dataLength;
|
|
Packit Service |
fa4841 |
pChannelOpenEvent->UserData = pUserData;
|
|
Packit Service |
fa4841 |
pChannelOpenEvent->pChannelOpenData = pChannelOpenData;
|
|
Packit Service |
fa4841 |
message.context = channels;
|
|
Packit Service |
fa4841 |
message.id = 0;
|
|
Packit Service |
fa4841 |
message.wParam = pChannelOpenEvent;
|
|
Packit Service |
fa4841 |
message.lParam = NULL;
|
|
Packit Service |
fa4841 |
message.Free = channel_queue_message_free;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!MessageQueue_Dispatch(channels->queue, &message))
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
free(pChannelOpenEvent);
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_NO_MEMORY;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
return CHANNEL_RC_OK;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
static BOOL freerdp_channels_is_loaded(rdpChannels* channels, PVIRTUALCHANNELENTRY entry)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
int i;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
for (i = 0; i < channels->clientDataCount; i++)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
CHANNEL_CLIENT_DATA* pChannelClientData = &channels->clientDataList[i];
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (pChannelClientData->entry == entry)
|
|
Packit Service |
fa4841 |
return TRUE;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
return FALSE;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
static BOOL freerdp_channels_is_loaded_ex(rdpChannels* channels, PVIRTUALCHANNELENTRYEX entryEx)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
int i;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
for (i = 0; i < channels->clientDataCount; i++)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
CHANNEL_CLIENT_DATA* pChannelClientData = &channels->clientDataList[i];
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (pChannelClientData->entryEx == entryEx)
|
|
Packit Service |
fa4841 |
return TRUE;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
return FALSE;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
int freerdp_channels_client_load(rdpChannels* channels, rdpSettings* settings,
|
|
Packit Service |
fa4841 |
PVIRTUALCHANNELENTRY entry, void* data)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
int status;
|
|
Packit Service |
fa4841 |
CHANNEL_ENTRY_POINTS_FREERDP EntryPoints;
|
|
Packit Service |
fa4841 |
CHANNEL_CLIENT_DATA* pChannelClientData;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (channels->clientDataCount + 1 > CHANNEL_MAX_COUNT)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
WLog_ERR(TAG, "error: too many channels");
|
|
Packit Service |
fa4841 |
return 1;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (freerdp_channels_is_loaded(channels, entry))
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
WLog_WARN(TAG, "Skipping, channel already loaded");
|
|
Packit Service |
fa4841 |
return 0;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
pChannelClientData = &channels->clientDataList[channels->clientDataCount];
|
|
Packit Service |
fa4841 |
pChannelClientData->entry = entry;
|
|
Packit Service |
fa4841 |
ZeroMemory(&EntryPoints, sizeof(CHANNEL_ENTRY_POINTS_FREERDP));
|
|
Packit Service |
fa4841 |
EntryPoints.cbSize = sizeof(EntryPoints);
|
|
Packit Service |
fa4841 |
EntryPoints.protocolVersion = VIRTUAL_CHANNEL_VERSION_WIN2000;
|
|
Packit Service |
fa4841 |
EntryPoints.pVirtualChannelInit = FreeRDP_VirtualChannelInit;
|
|
Packit Service |
fa4841 |
EntryPoints.pVirtualChannelOpen = FreeRDP_VirtualChannelOpen;
|
|
Packit Service |
fa4841 |
EntryPoints.pVirtualChannelClose = FreeRDP_VirtualChannelClose;
|
|
Packit Service |
fa4841 |
EntryPoints.pVirtualChannelWrite = FreeRDP_VirtualChannelWrite;
|
|
Packit Service |
fa4841 |
EntryPoints.MagicNumber = FREERDP_CHANNEL_MAGIC_NUMBER;
|
|
Packit Service |
fa4841 |
EntryPoints.ppInterface = &g_pInterface;
|
|
Packit Service |
fa4841 |
EntryPoints.pExtendedData = data;
|
|
Packit Service |
fa4841 |
EntryPoints.context = ((freerdp*)settings->instance)->context;
|
|
Packit Service |
fa4841 |
/* enable VirtualChannelInit */
|
|
Packit Service |
fa4841 |
channels->can_call_init = TRUE;
|
|
Packit Service |
fa4841 |
EnterCriticalSection(&channels->channelsLock);
|
|
Packit Service |
fa4841 |
g_pInterface = NULL;
|
|
Packit Service |
fa4841 |
g_channels = channels;
|
|
Packit Service |
fa4841 |
status = pChannelClientData->entry((PCHANNEL_ENTRY_POINTS)&EntryPoints);
|
|
Packit Service |
fa4841 |
LeaveCriticalSection(&channels->channelsLock);
|
|
Packit Service |
fa4841 |
/* disable MyVirtualChannelInit */
|
|
Packit Service |
fa4841 |
channels->can_call_init = FALSE;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!status)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
WLog_ERR(TAG, "error: channel export function call failed");
|
|
Packit Service |
fa4841 |
return 1;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
return 0;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
int freerdp_channels_client_load_ex(rdpChannels* channels, rdpSettings* settings,
|
|
Packit Service |
fa4841 |
PVIRTUALCHANNELENTRYEX entryEx, void* data)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
int status;
|
|
Packit Service |
fa4841 |
void* pInitHandle = NULL;
|
|
Packit Service |
fa4841 |
CHANNEL_ENTRY_POINTS_FREERDP_EX EntryPointsEx;
|
|
Packit Service |
fa4841 |
CHANNEL_INIT_DATA* pChannelInitData = NULL;
|
|
Packit Service |
fa4841 |
CHANNEL_CLIENT_DATA* pChannelClientData = NULL;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (channels->clientDataCount + 1 > CHANNEL_MAX_COUNT)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
WLog_ERR(TAG, "error: too many channels");
|
|
Packit Service |
fa4841 |
return 1;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (freerdp_channels_is_loaded_ex(channels, entryEx))
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
WLog_WARN(TAG, "Skipping, channel already loaded");
|
|
Packit Service |
fa4841 |
return 0;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
pChannelClientData = &channels->clientDataList[channels->clientDataCount];
|
|
Packit Service |
fa4841 |
pChannelClientData->entryEx = entryEx;
|
|
Packit Service |
fa4841 |
pChannelInitData = &(channels->initDataList[channels->initDataCount++]);
|
|
Packit Service |
fa4841 |
pInitHandle = pChannelInitData;
|
|
Packit Service |
fa4841 |
pChannelInitData->channels = channels;
|
|
Packit Service |
fa4841 |
ZeroMemory(&EntryPointsEx, sizeof(CHANNEL_ENTRY_POINTS_FREERDP_EX));
|
|
Packit Service |
fa4841 |
EntryPointsEx.cbSize = sizeof(EntryPointsEx);
|
|
Packit Service |
fa4841 |
EntryPointsEx.protocolVersion = VIRTUAL_CHANNEL_VERSION_WIN2000;
|
|
Packit Service |
fa4841 |
EntryPointsEx.pVirtualChannelInitEx = FreeRDP_VirtualChannelInitEx;
|
|
Packit Service |
fa4841 |
EntryPointsEx.pVirtualChannelOpenEx = FreeRDP_VirtualChannelOpenEx;
|
|
Packit Service |
fa4841 |
EntryPointsEx.pVirtualChannelCloseEx = FreeRDP_VirtualChannelCloseEx;
|
|
Packit Service |
fa4841 |
EntryPointsEx.pVirtualChannelWriteEx = FreeRDP_VirtualChannelWriteEx;
|
|
Packit Service |
fa4841 |
EntryPointsEx.MagicNumber = FREERDP_CHANNEL_MAGIC_NUMBER;
|
|
Packit Service |
fa4841 |
EntryPointsEx.pExtendedData = data;
|
|
Packit Service |
fa4841 |
EntryPointsEx.context = ((freerdp*)settings->instance)->context;
|
|
Packit Service |
fa4841 |
/* enable VirtualChannelInit */
|
|
Packit Service |
fa4841 |
channels->can_call_init = TRUE;
|
|
Packit Service |
fa4841 |
EnterCriticalSection(&channels->channelsLock);
|
|
Packit Service |
fa4841 |
status = pChannelClientData->entryEx((PCHANNEL_ENTRY_POINTS_EX)&EntryPointsEx, pInitHandle);
|
|
Packit Service |
fa4841 |
LeaveCriticalSection(&channels->channelsLock);
|
|
Packit Service |
fa4841 |
/* disable MyVirtualChannelInit */
|
|
Packit Service |
fa4841 |
channels->can_call_init = FALSE;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!status)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
WLog_ERR(TAG, "error: channel export function call failed");
|
|
Packit Service |
fa4841 |
return 1;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
return 0;
|
|
Packit Service |
fa4841 |
}
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
/**
|
|
Packit Service |
fa4841 |
* this is called when processing the command line parameters
|
|
Packit Service |
fa4841 |
* called only from main thread
|
|
Packit Service |
fa4841 |
*/
|
|
Packit Service |
fa4841 |
int freerdp_channels_load_plugin(rdpChannels* channels, rdpSettings* settings, const char* name,
|
|
Packit Service |
fa4841 |
void* data)
|
|
Packit Service |
fa4841 |
{
|
|
Packit Service |
fa4841 |
PVIRTUALCHANNELENTRY entry;
|
|
Packit Service |
fa4841 |
entry = freerdp_load_channel_addin_entry(name, NULL, NULL, FREERDP_ADDIN_CHANNEL_STATIC);
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
if (!entry)
|
|
Packit Service |
fa4841 |
return 1;
|
|
Packit Service |
fa4841 |
|
|
Packit Service |
fa4841 |
return freerdp_channels_client_load(channels, settings, entry, data);
|
|
Packit Service |
fa4841 |
}
|