mirror of
https://github.com/gnif/LookingGlass.git
synced 2024-12-24 14:41:53 +00:00
484 lines
13 KiB
C
484 lines
13 KiB
C
/*
|
|
Looking Glass - KVM FrameRelay (KVMFR) Client
|
|
Copyright (C) 2017-2019 Geoffrey McRae <geoff@hostfission.com>
|
|
https://looking-glass.hostfission.com
|
|
|
|
This program is free software; you can redistribute it and/or modify it under
|
|
the terms of the GNU General Public License as published by the Free Software
|
|
Foundation; either version 2 of the License, or (at your option) any later
|
|
version.
|
|
|
|
This program 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 General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License along with
|
|
this program; if not, write to the Free Software Foundation, Inc., 59 Temple
|
|
Place, Suite 330, Boston, MA 02111-1307 USA
|
|
*/
|
|
|
|
#include "texture.h"
|
|
#include "common/debug.h"
|
|
#include "common/framebuffer.h"
|
|
#include "debug.h"
|
|
#include "utils.h"
|
|
|
|
#include <stdlib.h>
|
|
#include <string.h>
|
|
#include <stdio.h>
|
|
#include <stdatomic.h>
|
|
|
|
#include <SDL2/SDL_egl.h>
|
|
|
|
#define TEXTURE_COUNT 3
|
|
|
|
struct Tex
|
|
{
|
|
GLuint t[3];
|
|
bool hasPBO;
|
|
GLuint pbo;
|
|
void * map;
|
|
GLsync sync;
|
|
};
|
|
|
|
union TexState
|
|
{
|
|
_Atomic(uint32_t) v;
|
|
struct
|
|
{
|
|
/*
|
|
* w = write
|
|
* u = upload
|
|
* s = schedule
|
|
* d = display
|
|
*/
|
|
_Atomic(int8_t) w, u, s, d;
|
|
};
|
|
};
|
|
|
|
struct EGL_Texture
|
|
{
|
|
enum EGL_PixelFormat pixFmt;
|
|
size_t width, height, stride;
|
|
size_t bpp;
|
|
bool streaming;
|
|
bool ready;
|
|
|
|
int planeCount;
|
|
GLuint samplers[3];
|
|
size_t planes [3][3];
|
|
GLintptr offsets [3];
|
|
GLenum intFormat;
|
|
GLenum format;
|
|
GLenum dataType;
|
|
size_t pboBufferSize;
|
|
|
|
union TexState state;
|
|
struct Tex tex[TEXTURE_COUNT];
|
|
};
|
|
|
|
bool egl_texture_init(EGL_Texture ** texture)
|
|
{
|
|
*texture = (EGL_Texture *)malloc(sizeof(EGL_Texture));
|
|
if (!*texture)
|
|
{
|
|
DEBUG_ERROR("Failed to malloc EGL_Texture");
|
|
return false;
|
|
}
|
|
|
|
memset(*texture, 0, sizeof(EGL_Texture));
|
|
return true;
|
|
}
|
|
|
|
void egl_texture_free(EGL_Texture ** texture)
|
|
{
|
|
if (!*texture)
|
|
return;
|
|
|
|
if ((*texture)->planeCount > 0)
|
|
glDeleteSamplers((*texture)->planeCount, (*texture)->samplers);
|
|
|
|
for(int i = 0; i < ((*texture)->streaming ? TEXTURE_COUNT : 1); ++i)
|
|
{
|
|
struct Tex * t = &(*texture)->tex[i];
|
|
if (t->hasPBO)
|
|
{
|
|
glBindBuffer(GL_PIXEL_UNPACK_BUFFER, t->pbo);
|
|
if ((*texture)->tex[i].map)
|
|
{
|
|
glUnmapBuffer(GL_PIXEL_UNPACK_BUFFER);
|
|
(*texture)->tex[i].map = NULL;
|
|
}
|
|
glDeleteBuffers(1, &t->pbo);
|
|
if (t->sync)
|
|
glDeleteSync(t->sync);
|
|
}
|
|
|
|
if ((*texture)->planeCount > 0)
|
|
glDeleteTextures((*texture)->planeCount, t->t);
|
|
}
|
|
glBindBuffer(GL_PIXEL_UNPACK_BUFFER, 0);
|
|
|
|
free(*texture);
|
|
*texture = NULL;
|
|
}
|
|
|
|
static bool egl_texture_map(EGL_Texture * texture, uint8_t i)
|
|
{
|
|
glBindBuffer(GL_PIXEL_UNPACK_BUFFER, texture->tex[i].pbo);
|
|
texture->tex[i].map = glMapBufferRange(
|
|
GL_PIXEL_UNPACK_BUFFER,
|
|
0,
|
|
texture->pboBufferSize,
|
|
GL_MAP_WRITE_BIT |
|
|
GL_MAP_UNSYNCHRONIZED_BIT |
|
|
GL_MAP_INVALIDATE_BUFFER_BIT
|
|
);
|
|
|
|
if (!texture->tex[i].map)
|
|
{
|
|
EGL_ERROR("glMapBufferRange failed for %d of %lu bytes", i, texture->pboBufferSize);
|
|
return false;
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
static bool egl_texture_map_all(EGL_Texture * texture)
|
|
{
|
|
// release old PBOs and delete and re-create the buffers
|
|
for(int i = 0; i < TEXTURE_COUNT; ++i)
|
|
if (!egl_texture_map(texture, i))
|
|
return false;
|
|
|
|
glBindBuffer(GL_PIXEL_UNPACK_BUFFER, 0);
|
|
return true;
|
|
}
|
|
|
|
static void egl_texture_unmap(EGL_Texture * texture, uint8_t i)
|
|
{
|
|
if (!texture->tex[i].map)
|
|
return;
|
|
|
|
glBindBuffer(GL_PIXEL_UNPACK_BUFFER, texture->tex[i].pbo);
|
|
glUnmapBuffer(GL_PIXEL_UNPACK_BUFFER);
|
|
texture->tex[i].map = NULL;
|
|
}
|
|
|
|
static void egl_texture_unmap_all(EGL_Texture * texture)
|
|
{
|
|
for(int i = 0; i < TEXTURE_COUNT; ++i)
|
|
egl_texture_unmap(texture, i);
|
|
}
|
|
|
|
bool egl_texture_setup(EGL_Texture * texture, enum EGL_PixelFormat pixFmt, size_t width, size_t height, size_t stride, bool streaming)
|
|
{
|
|
int planeCount;
|
|
|
|
texture->pixFmt = pixFmt;
|
|
texture->width = width;
|
|
texture->height = height;
|
|
texture->stride = stride;
|
|
texture->streaming = streaming;
|
|
texture->ready = false;
|
|
atomic_store_explicit(&texture->state.v, 0, memory_order_relaxed);
|
|
|
|
switch(pixFmt)
|
|
{
|
|
case EGL_PF_BGRA:
|
|
planeCount = 1;
|
|
texture->bpp = 4;
|
|
texture->format = GL_BGRA;
|
|
texture->planes[0][0] = width;
|
|
texture->planes[0][1] = height;
|
|
texture->planes[0][2] = stride / 4;
|
|
texture->offsets[0] = 0;
|
|
texture->intFormat = GL_BGRA;
|
|
texture->dataType = GL_UNSIGNED_BYTE;
|
|
texture->pboBufferSize = height * stride;
|
|
break;
|
|
|
|
case EGL_PF_RGBA:
|
|
planeCount = 1;
|
|
texture->bpp = 4;
|
|
texture->format = GL_RGBA;
|
|
texture->planes[0][0] = width;
|
|
texture->planes[0][1] = height;
|
|
texture->planes[0][2] = stride / 4;
|
|
texture->offsets[0] = 0;
|
|
texture->intFormat = GL_BGRA;
|
|
texture->dataType = GL_UNSIGNED_BYTE;
|
|
texture->pboBufferSize = height * stride;
|
|
break;
|
|
|
|
case EGL_PF_RGBA10:
|
|
planeCount = 1;
|
|
texture->bpp = 4;
|
|
texture->format = GL_RGBA;
|
|
texture->planes[0][0] = width;
|
|
texture->planes[0][1] = height;
|
|
texture->planes[0][2] = stride / 4;
|
|
texture->offsets[0] = 0;
|
|
texture->intFormat = GL_RGB10_A2;
|
|
texture->dataType = GL_UNSIGNED_INT_2_10_10_10_REV;
|
|
texture->pboBufferSize = height * stride;
|
|
break;
|
|
|
|
case EGL_PF_YUV420:
|
|
planeCount = 3;
|
|
texture->bpp = 4;
|
|
texture->format = GL_RED;
|
|
texture->planes[0][0] = width;
|
|
texture->planes[0][1] = height;
|
|
texture->planes[0][2] = stride;
|
|
texture->planes[1][0] = width / 2;
|
|
texture->planes[1][1] = height / 2;
|
|
texture->planes[1][2] = stride / 2;
|
|
texture->planes[2][0] = width / 2;
|
|
texture->planes[2][1] = height / 2;
|
|
texture->planes[2][2] = stride / 2;
|
|
texture->offsets[0] = 0;
|
|
texture->offsets[1] = stride * height;
|
|
texture->offsets[2] = texture->offsets[1] + (texture->offsets[1] / 4);
|
|
texture->dataType = GL_UNSIGNED_BYTE;
|
|
texture->pboBufferSize = texture->offsets[2] + (texture->offsets[1] / 4);
|
|
break;
|
|
|
|
default:
|
|
DEBUG_ERROR("Unsupported pixel format");
|
|
return false;
|
|
}
|
|
|
|
if (planeCount > texture->planeCount)
|
|
{
|
|
if (texture->planeCount > 0)
|
|
glDeleteSamplers(texture->planeCount, texture->samplers);
|
|
|
|
for(int i = 0; i < TEXTURE_COUNT; ++i)
|
|
{
|
|
if (texture->planeCount > 0)
|
|
glDeleteTextures(texture->planeCount, texture->tex[i].t);
|
|
glGenTextures(planeCount, texture->tex[i].t);
|
|
}
|
|
|
|
glGenSamplers(planeCount, texture->samplers);
|
|
for(int p = 0; p < planeCount; ++p)
|
|
{
|
|
glSamplerParameteri(texture->samplers[p], GL_TEXTURE_MIN_FILTER, GL_LINEAR);
|
|
glSamplerParameteri(texture->samplers[p], GL_TEXTURE_MAG_FILTER, GL_LINEAR);
|
|
glSamplerParameteri(texture->samplers[p], GL_TEXTURE_WRAP_S , GL_CLAMP_TO_EDGE);
|
|
glSamplerParameteri(texture->samplers[p], GL_TEXTURE_WRAP_T , GL_CLAMP_TO_EDGE);
|
|
}
|
|
|
|
texture->planeCount = planeCount;
|
|
}
|
|
|
|
for(int i = 0; i < (streaming ? TEXTURE_COUNT : 1); ++i)
|
|
{
|
|
for(int p = 0; p < planeCount; ++p)
|
|
{
|
|
glBindTexture(GL_TEXTURE_2D, texture->tex[i].t[p]);
|
|
glTexImage2D(GL_TEXTURE_2D, 0, texture->intFormat, texture->planes[p][0],
|
|
texture->planes[p][1], 0, texture->format, texture->dataType, NULL);
|
|
}
|
|
}
|
|
glBindTexture(GL_TEXTURE_2D, 0);
|
|
|
|
egl_texture_unmap_all(texture);
|
|
|
|
// release old PBOs and delete and re-create the buffers
|
|
for(int i = 0; i < TEXTURE_COUNT; ++i)
|
|
{
|
|
if (texture->tex[i].hasPBO)
|
|
glDeleteBuffers(1, &texture->tex[i].pbo);
|
|
|
|
glGenBuffers(1, &texture->tex[i].pbo);
|
|
texture->tex[i].hasPBO = true;
|
|
|
|
glBindBuffer(GL_PIXEL_UNPACK_BUFFER, texture->tex[i].pbo);
|
|
glBufferStorage(
|
|
GL_PIXEL_UNPACK_BUFFER,
|
|
texture->pboBufferSize,
|
|
NULL,
|
|
GL_MAP_WRITE_BIT
|
|
);
|
|
}
|
|
|
|
if (!egl_texture_map_all(texture))
|
|
return false;
|
|
|
|
return true;
|
|
}
|
|
|
|
static void egl_warn_slow()
|
|
{
|
|
static bool warnDone = false;
|
|
if (!warnDone)
|
|
{
|
|
warnDone = true;
|
|
DEBUG_BREAK();
|
|
DEBUG_WARN("The guest is providing updates faster then your computer can display them");
|
|
DEBUG_WARN("This is a hardware limitation, expect microstutters & frame skips");
|
|
DEBUG_BREAK();
|
|
}
|
|
}
|
|
|
|
bool egl_texture_update(EGL_Texture * texture, const uint8_t * buffer)
|
|
{
|
|
if (texture->streaming)
|
|
{
|
|
union TexState s;
|
|
s.v = atomic_load_explicit(&texture->state.v, memory_order_acquire);
|
|
|
|
const uint8_t next = (s.w + 1) % TEXTURE_COUNT;
|
|
if (next == s.u)
|
|
{
|
|
egl_warn_slow();
|
|
return true;
|
|
}
|
|
|
|
memcpy(texture->tex[s.w].map, buffer, texture->pboBufferSize);
|
|
atomic_store_explicit(&texture->state.w, next, memory_order_release);
|
|
}
|
|
else
|
|
{
|
|
/* Non streaming, this is NOT thread safe */
|
|
|
|
for(int p = 0; p < texture->planeCount; ++p)
|
|
{
|
|
glBindTexture(GL_TEXTURE_2D, texture->tex[0].t[p]);
|
|
glPixelStorei(GL_UNPACK_ROW_LENGTH, texture->planes[p][0]);
|
|
glTexSubImage2D(GL_TEXTURE_2D, 0, 0, 0, texture->planes[p][0], texture->planes[p][1],
|
|
texture->format, texture->dataType, buffer + texture->offsets[p]);
|
|
}
|
|
glBindTexture(GL_TEXTURE_2D, 0);
|
|
}
|
|
return true;
|
|
}
|
|
|
|
bool egl_texture_update_from_frame(EGL_Texture * texture, const FrameBuffer * frame)
|
|
{
|
|
if (!texture->streaming)
|
|
return false;
|
|
|
|
union TexState s;
|
|
s.v = atomic_load_explicit(&texture->state.v, memory_order_acquire);
|
|
|
|
const uint8_t next = (s.w + 1) % TEXTURE_COUNT;
|
|
if (next == s.u)
|
|
{
|
|
egl_warn_slow();
|
|
return true;
|
|
}
|
|
|
|
framebuffer_read(
|
|
frame,
|
|
texture->tex[s.w].map,
|
|
texture->stride,
|
|
texture->height,
|
|
texture->width,
|
|
texture->bpp,
|
|
texture->stride
|
|
);
|
|
|
|
atomic_store_explicit(&texture->state.w, next, memory_order_release);
|
|
return true;
|
|
}
|
|
|
|
enum EGL_TexStatus egl_texture_process(EGL_Texture * texture)
|
|
{
|
|
if (!texture->streaming)
|
|
return EGL_TEX_STATUS_OK;
|
|
|
|
union TexState s;
|
|
s.v = atomic_load_explicit(&texture->state.v, memory_order_acquire);
|
|
|
|
const uint8_t nextu = (s.u + 1) % TEXTURE_COUNT;
|
|
if (s.u == s.w || nextu == s.s || nextu == s.d)
|
|
return texture->ready ? EGL_TEX_STATUS_OK : EGL_TEX_STATUS_NOTREADY;
|
|
|
|
/* update the texture */
|
|
egl_texture_unmap(texture, s.u);
|
|
glBindBuffer(GL_PIXEL_UNPACK_BUFFER, texture->tex[s.u].pbo);
|
|
for(int p = 0; p < texture->planeCount; ++p)
|
|
{
|
|
glBindTexture(GL_TEXTURE_2D, texture->tex[s.u].t[p]);
|
|
glPixelStorei(GL_UNPACK_ROW_LENGTH, texture->planes[p][2]);
|
|
glTexSubImage2D(GL_TEXTURE_2D, 0, 0, 0, texture->planes[p][0], texture->planes[p][1],
|
|
texture->format, texture->dataType, (const void *)texture->offsets[p]);
|
|
|
|
}
|
|
|
|
/* create a fence to prevent usage before the update is complete */
|
|
texture->tex[s.u].sync =
|
|
glFenceSync(GL_SYNC_GPU_COMMANDS_COMPLETE, 0);
|
|
|
|
/* we must flush to ensure the sync is in the command buffer */
|
|
glFlush();
|
|
|
|
texture->ready = true;
|
|
atomic_store_explicit(&texture->state.u, nextu, memory_order_release);
|
|
|
|
/* remap the for the next update */
|
|
egl_texture_map(texture, s.u);
|
|
|
|
return EGL_TEX_STATUS_OK;
|
|
}
|
|
|
|
enum EGL_TexStatus egl_texture_bind(EGL_Texture * texture)
|
|
{
|
|
union TexState s;
|
|
s.v = atomic_load_explicit(&texture->state.v, memory_order_acquire);
|
|
|
|
if (texture->streaming)
|
|
{
|
|
if (!texture->ready)
|
|
return EGL_TEX_STATUS_NOTREADY;
|
|
|
|
if (texture->tex[s.s].sync != 0)
|
|
{
|
|
switch(glClientWaitSync(texture->tex[s.s].sync, 0, 20000000)) // 20ms
|
|
{
|
|
case GL_ALREADY_SIGNALED:
|
|
case GL_CONDITION_SATISFIED:
|
|
glDeleteSync(texture->tex[s.s].sync);
|
|
texture->tex[s.s].sync = 0;
|
|
|
|
s.s = (s.s + 1) % TEXTURE_COUNT;
|
|
atomic_store_explicit(&texture->state.s, s.s, memory_order_release);
|
|
break;
|
|
|
|
case GL_TIMEOUT_EXPIRED:
|
|
break;
|
|
|
|
case GL_WAIT_FAILED:
|
|
case GL_INVALID_VALUE:
|
|
glDeleteSync(texture->tex[s.s].sync);
|
|
texture->tex[s.s].sync = 0;
|
|
EGL_ERROR("glClientWaitSync failed");
|
|
return EGL_TEX_STATUS_ERROR;
|
|
}
|
|
}
|
|
|
|
const int8_t nextd = (s.d + 1) % TEXTURE_COUNT;
|
|
if (s.d != s.s && nextd != s.s)
|
|
{
|
|
s.d = nextd;
|
|
atomic_store_explicit(&texture->state.d, nextd, memory_order_release);
|
|
}
|
|
}
|
|
|
|
for(int i = 0; i < texture->planeCount; ++i)
|
|
{
|
|
glActiveTexture(GL_TEXTURE0 + i);
|
|
glBindTexture(GL_TEXTURE_2D, texture->tex[s.d].t[i]);
|
|
glBindSampler(i, texture->samplers[i]);
|
|
}
|
|
|
|
return EGL_TEX_STATUS_OK;
|
|
}
|
|
|
|
int egl_texture_count(EGL_Texture * texture)
|
|
{
|
|
return texture->planeCount;
|
|
}
|