mirror of
https://gitlab.uni-freiburg.de/opensourcevdi/spice
synced 2025-12-26 22:48:19 +00:00
The objects RedsStream and RedsSASL are currently using the namespace "Reds" rather than the standard "Red" namespace used throughout the rest of the project. Change these to be consistent. This also means changing method names and some related enumeration types. The files were also renamed to reflect the change: reds-stream.[ch] -> red-stream.[ch] Signed-off-by: Jonathon Jongsma <jjongsma@redhat.com> Acked-by: Frediano Ziglio <fziglio@redhat.com>
127 lines
3.9 KiB
C
127 lines
3.9 KiB
C
/* -*- Mode: C; c-basic-offset: 4; indent-tabs-mode: nil -*- */
|
|
/*
|
|
Copyright (C) 2009-2016 Red Hat, Inc.
|
|
|
|
This library is free software; you can redistribute it and/or
|
|
modify it under the terms of the GNU Lesser General Public
|
|
License as published by the Free Software Foundation; either
|
|
version 2.1 of the License, or (at your option) any later version.
|
|
|
|
This library is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
Lesser General Public License for more details.
|
|
|
|
You should have received a copy of the GNU Lesser General Public
|
|
License along with this library; if not, see <http://www.gnu.org/licenses/>.
|
|
*/
|
|
#ifdef HAVE_CONFIG_H
|
|
#include <config.h>
|
|
#endif
|
|
|
|
#include <common/generated_server_marshallers.h>
|
|
|
|
#include "common-graphics-channel.h"
|
|
#include "red-channel-client.h"
|
|
#include "cache-item.h"
|
|
#include "cursor-channel.h"
|
|
#include "cursor-channel-client.h"
|
|
|
|
#define CLIENT_CURSOR_CACHE_SIZE 256
|
|
|
|
#define CURSOR_CACHE_HASH_SHIFT 8
|
|
#define CURSOR_CACHE_HASH_SIZE (1 << CURSOR_CACHE_HASH_SHIFT)
|
|
#define CURSOR_CACHE_HASH_MASK (CURSOR_CACHE_HASH_SIZE - 1)
|
|
#define CURSOR_CACHE_HASH_KEY(id) ((id) & CURSOR_CACHE_HASH_MASK)
|
|
#define CURSOR_CLIENT_TIMEOUT 30000000000ULL //nano
|
|
|
|
G_DEFINE_TYPE(CursorChannelClient, cursor_channel_client, TYPE_COMMON_GRAPHICS_CHANNEL_CLIENT)
|
|
|
|
#define CURSOR_CHANNEL_CLIENT_PRIVATE(o) \
|
|
(G_TYPE_INSTANCE_GET_PRIVATE((o), TYPE_CURSOR_CHANNEL_CLIENT, CursorChannelClientPrivate))
|
|
|
|
struct CursorChannelClientPrivate
|
|
{
|
|
RedCacheItem *cursor_cache[CURSOR_CACHE_HASH_SIZE];
|
|
Ring cursor_cache_lru;
|
|
long cursor_cache_available;
|
|
uint32_t cursor_cache_items;
|
|
};
|
|
|
|
static void cursor_channel_client_on_disconnect(RedChannelClient *rcc);
|
|
|
|
static void
|
|
cursor_channel_client_class_init(CursorChannelClientClass *klass)
|
|
{
|
|
RedChannelClientClass *client_class = RED_CHANNEL_CLIENT_CLASS(klass);
|
|
|
|
g_type_class_add_private(klass, sizeof(CursorChannelClientPrivate));
|
|
|
|
client_class->on_disconnect = cursor_channel_client_on_disconnect;
|
|
}
|
|
|
|
static void
|
|
cursor_channel_client_init(CursorChannelClient *self)
|
|
{
|
|
self->priv = CURSOR_CHANNEL_CLIENT_PRIVATE(self);
|
|
ring_init(&self->priv->cursor_cache_lru);
|
|
self->priv->cursor_cache_available = CLIENT_CURSOR_CACHE_SIZE;
|
|
}
|
|
|
|
#define CLIENT_CURSOR_CACHE
|
|
#include "cache-item.tmpl.c"
|
|
#undef CLIENT_CURSOR_CACHE
|
|
|
|
#ifdef DEBUG_CURSORS
|
|
static int _cursor_count = 0;
|
|
#endif
|
|
|
|
void cursor_channel_client_reset_cursor_cache(RedChannelClient *rcc)
|
|
{
|
|
red_cursor_cache_reset(CURSOR_CHANNEL_CLIENT(rcc), CLIENT_CURSOR_CACHE_SIZE);
|
|
}
|
|
|
|
static void cursor_channel_client_on_disconnect(RedChannelClient *rcc)
|
|
{
|
|
if (!rcc) {
|
|
return;
|
|
}
|
|
cursor_channel_client_reset_cursor_cache(rcc);
|
|
}
|
|
|
|
void cursor_channel_client_migrate(RedChannelClient *rcc)
|
|
{
|
|
spice_return_if_fail(rcc);
|
|
|
|
red_channel_client_pipe_add_type(rcc, RED_PIPE_ITEM_TYPE_INVAL_CURSOR_CACHE);
|
|
red_channel_client_default_migrate(rcc);
|
|
}
|
|
|
|
CursorChannelClient* cursor_channel_client_new(CursorChannel *cursor, RedClient *client, RedStream *stream,
|
|
int mig_target,
|
|
RedChannelCapabilities *caps)
|
|
{
|
|
CursorChannelClient *rcc;
|
|
|
|
rcc = g_initable_new(TYPE_CURSOR_CHANNEL_CLIENT,
|
|
NULL, NULL,
|
|
"channel", cursor,
|
|
"client", client,
|
|
"stream", stream,
|
|
"caps", caps,
|
|
NULL);
|
|
common_graphics_channel_set_during_target_migrate(COMMON_GRAPHICS_CHANNEL(cursor), mig_target);
|
|
|
|
return rcc;
|
|
}
|
|
|
|
RedCacheItem* cursor_channel_client_cache_find(CursorChannelClient *ccc, uint64_t id)
|
|
{
|
|
return red_cursor_cache_find(ccc, id);
|
|
}
|
|
|
|
int cursor_channel_client_cache_add(CursorChannelClient *ccc, uint64_t id, size_t size)
|
|
{
|
|
return red_cursor_cache_add(ccc, id, size);
|
|
}
|