efl/src/modules/evas/engines/wayland_shm/evas_dmabuf.c

793 lines
20 KiB
C

#include "evas_common_private.h"
#include "evas_private.h"
#include "evas_engine.h"
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <dlfcn.h>
#include <drm_fourcc.h>
#include <intel_bufmgr.h>
#include <i915_drm.h>
#include <exynos_drm.h>
#include <exynos_drmif.h>
#include <sys/mman.h>
#include "linux-dmabuf-unstable-v1-client-protocol.h"
#define SYM(lib, xx) \
do { \
sym_## xx = dlsym(lib, #xx); \
if (!(sym_ ## xx)) { \
fail = EINA_TRUE; \
} \
} while (0)
static Eina_Bool dmabuf_totally_hosed;
static int drm_fd = -1;
typedef struct _Dmabuf_Surface Dmabuf_Surface;
typedef struct _Dmabuf_Buffer Dmabuf_Buffer;
typedef struct _Buffer_Handle Buffer_Handle;
typedef struct _Buffer_Manager Buffer_Manager;
struct _Buffer_Manager
{
Buffer_Handle *(*alloc)(Buffer_Manager *self, const char *name, int w, int h, unsigned long *stride, int32_t *fd);
struct wl_buffer *(*to_buffer)(Ecore_Wl2_Display *ewd, Dmabuf_Buffer *db);
void *(*map)(Dmabuf_Buffer *buf);
void (*unmap)(Dmabuf_Buffer *buf);
void (*discard)(Dmabuf_Buffer *buf);
void (*manager_destroy)(void);
void *priv;
void *dl_handle;
int refcount;
Eina_Bool destroyed;
};
Buffer_Manager *buffer_manager = NULL;
struct _Dmabuf_Buffer
{
Dmabuf_Surface *surface;
struct wl_buffer *wl_buffer;
int size;
int w, h;
int age;
unsigned long stride;
Buffer_Handle *bh;
int fd;
void *mapping;
int index;
Eina_Bool locked : 1;
Eina_Bool busy : 1;
Eina_Bool used : 1;
Eina_Bool orphaned : 1;
};
struct _Dmabuf_Surface
{
Surface *surface;
int compositor_version;
Dmabuf_Buffer *current;
Dmabuf_Buffer **buffer;
int nbuf;
Eina_Bool alpha : 1;
};
static void _internal_evas_dmabuf_surface_destroy(Dmabuf_Surface *surface);
static void _evas_dmabuf_surface_destroy(Surface *s);
static Dmabuf_Buffer *_evas_dmabuf_buffer_init(Dmabuf_Surface *s, int w, int h);
static void _evas_dmabuf_buffer_destroy(Dmabuf_Buffer *b);
static drm_intel_bufmgr *(*sym_drm_intel_bufmgr_gem_init)(int fd, int batch_size) = NULL;
static int (*sym_drm_intel_bo_unmap)(drm_intel_bo *bo) = NULL;
static int (*sym_drm_intel_bo_map)(drm_intel_bo *bo) = NULL;
static drm_intel_bo *(*sym_drm_intel_bo_alloc_tiled)(drm_intel_bufmgr *mgr, const char *name, int x, int y, int cpp, uint32_t *tile, unsigned long *pitch, unsigned long flags) = NULL;
static void (*sym_drm_intel_bo_unreference)(drm_intel_bo *bo) = NULL;
static int (*sym_drmPrimeHandleToFD)(int fd, uint32_t handle, uint32_t flags, int *prime_fd) = NULL;
static void (*sym_drm_intel_bufmgr_destroy)(drm_intel_bufmgr *) = NULL;
static struct exynos_device *(*sym_exynos_device_create)(int fd) = NULL;
static struct exynos_bo *(*sym_exynos_bo_create)(struct exynos_device *dev, size_t size, uint32_t flags) = NULL;
static void *(*sym_exynos_bo_map)(struct exynos_bo *bo) = NULL;
static void (*sym_exynos_bo_destroy)(struct exynos_bo *bo) = NULL;
static void (*sym_exynos_device_destroy)(struct exynos_device *) = NULL;
static struct wl_buffer * _evas_dmabuf_wl_buffer_from_dmabuf(Ecore_Wl2_Display *disp, Dmabuf_Buffer *db);
static void
buffer_release(void *data, struct wl_buffer *buffer EINA_UNUSED)
{
Dmabuf_Buffer *b = data;
b->busy = EINA_FALSE;
if (b->orphaned) _evas_dmabuf_buffer_destroy(b);
}
static const struct wl_buffer_listener buffer_listener =
{
buffer_release
};
static Buffer_Handle *
_intel_alloc(Buffer_Manager *self, const char *name, int w, int h, unsigned long *stride, int32_t *fd)
{
uint32_t tile = I915_TILING_NONE;
drm_intel_bo *out;
out = sym_drm_intel_bo_alloc_tiled(self->priv, name, w, h, 4, &tile,
stride, 0);
if (!out) return NULL;
if (tile != I915_TILING_NONE) goto err;
/* First try to allocate an mmapable buffer with O_RDWR,
* if that fails retry unmappable - if the compositor is
* using GL it won't need to mmap the buffer and this can
* work - otherwise it'll reject this buffer and we'll
* have to fall back to shm rendering.
*/
if (sym_drmPrimeHandleToFD(drm_fd, out->handle,
DRM_CLOEXEC | O_RDWR, fd) != 0)
if (sym_drmPrimeHandleToFD(drm_fd, out->handle,
DRM_CLOEXEC, fd) != 0) goto err;
return (Buffer_Handle *)out;
err:
sym_drm_intel_bo_unreference(out);
return NULL;
}
static void *
_intel_map(Dmabuf_Buffer *buf)
{
drm_intel_bo *bo;
bo = (drm_intel_bo *)buf->bh;
if (sym_drm_intel_bo_map(bo) != 0) return NULL;
return bo->virtual;
}
static void
_intel_unmap(Dmabuf_Buffer *buf)
{
drm_intel_bo *bo;
bo = (drm_intel_bo *)buf->bh;
sym_drm_intel_bo_unmap(bo);
}
static void
_intel_discard(Dmabuf_Buffer *buf)
{
drm_intel_bo *bo;
bo = (drm_intel_bo *)buf->bh;
sym_drm_intel_bo_unreference(bo);
}
static void
_intel_manager_destroy()
{
sym_drm_intel_bufmgr_destroy(buffer_manager->priv);
}
static Eina_Bool
_intel_buffer_manager_setup(int fd)
{
Eina_Bool fail = EINA_FALSE;
void *drm_intel_lib;
drm_intel_lib = dlopen("libdrm_intel.so", RTLD_LAZY | RTLD_GLOBAL);
if (!drm_intel_lib) return EINA_FALSE;
SYM(drm_intel_lib, drm_intel_bufmgr_gem_init);
SYM(drm_intel_lib, drm_intel_bo_unmap);
SYM(drm_intel_lib, drm_intel_bo_map);
SYM(drm_intel_lib, drm_intel_bo_alloc_tiled);
SYM(drm_intel_lib, drm_intel_bo_unreference);
SYM(drm_intel_lib, drm_intel_bufmgr_destroy);
SYM(drm_intel_lib, drmPrimeHandleToFD);
if (fail) goto err;
buffer_manager->priv = sym_drm_intel_bufmgr_gem_init(fd, 32);
if (!buffer_manager->priv) goto err;
buffer_manager->alloc = _intel_alloc;
buffer_manager->to_buffer = _evas_dmabuf_wl_buffer_from_dmabuf;
buffer_manager->map = _intel_map;
buffer_manager->unmap = _intel_unmap;
buffer_manager->discard = _intel_discard;
buffer_manager->manager_destroy = _intel_manager_destroy;
buffer_manager->dl_handle = drm_intel_lib;
return EINA_TRUE;
err:
dlclose(drm_intel_lib);
return EINA_FALSE;
}
static Buffer_Handle *
_exynos_alloc(Buffer_Manager *self, const char *name EINA_UNUSED, int w, int h, unsigned long *stride, int32_t *fd)
{
size_t size = w * h * 4;
struct exynos_bo *out;
*stride = w * 4;
out = sym_exynos_bo_create(self->priv, size, 0);
if (!out) return NULL;
/* First try to allocate an mmapable buffer with O_RDWR,
* if that fails retry unmappable - if the compositor is
* using GL it won't need to mmap the buffer and this can
* work - otherwise it'll reject this buffer and we'll
* have to fall back to shm rendering.
*/
if (sym_drmPrimeHandleToFD(drm_fd, out->handle,
DRM_CLOEXEC | O_RDWR, fd) != 0)
if (sym_drmPrimeHandleToFD(drm_fd, out->handle,
DRM_CLOEXEC, fd) != 0) goto err;
return (Buffer_Handle *)out;
err:
sym_exynos_bo_destroy(out);
return NULL;
}
static void *
_exynos_map(Dmabuf_Buffer *buf)
{
struct exynos_bo *bo;
void *ptr;
bo = (struct exynos_bo *)buf->bh;
ptr = mmap(0, bo->size, PROT_READ | PROT_WRITE, MAP_SHARED, buf->fd, 0);
if (ptr == MAP_FAILED) return NULL;
return ptr;
}
static void
_exynos_unmap(Dmabuf_Buffer *buf)
{
struct exynos_bo *bo;
bo = (struct exynos_bo *)buf->bh;
munmap(buf->mapping, bo->size);
}
static void
_exynos_discard(Dmabuf_Buffer *buf)
{
struct exynos_bo *bo;
bo = (struct exynos_bo *)buf->bh;
sym_exynos_bo_destroy(bo);
}
static void
_exynos_manager_destroy()
{
sym_exynos_device_destroy(buffer_manager->priv);
}
static Eina_Bool
_exynos_buffer_manager_setup(int fd)
{
Eina_Bool fail = EINA_FALSE;
void *drm_exynos_lib;
struct exynos_bo *bo;
drm_exynos_lib = dlopen("libdrm_exynos.so", RTLD_LAZY | RTLD_GLOBAL);
if (!drm_exynos_lib) return EINA_FALSE;
SYM(drm_exynos_lib, exynos_device_create);
SYM(drm_exynos_lib, exynos_bo_create);
SYM(drm_exynos_lib, exynos_bo_map);
SYM(drm_exynos_lib, exynos_bo_destroy);
SYM(drm_exynos_lib, exynos_device_destroy);
SYM(drm_exynos_lib, drmPrimeHandleToFD);
if (fail) goto err;
buffer_manager->priv = sym_exynos_device_create(fd);
if (!buffer_manager->priv) goto err;
/* _device_create succeeds on any arch, test harder */
bo = sym_exynos_bo_create(buffer_manager->priv, 32, 0);
if (!bo) goto err;
sym_exynos_bo_destroy(bo);
buffer_manager->alloc = _exynos_alloc;
buffer_manager->to_buffer = _evas_dmabuf_wl_buffer_from_dmabuf;
buffer_manager->map = _exynos_map;
buffer_manager->unmap = _exynos_unmap;
buffer_manager->discard = _exynos_discard;
buffer_manager->manager_destroy = _exynos_manager_destroy;
buffer_manager->dl_handle = drm_exynos_lib;
return EINA_TRUE;
err:
dlclose(drm_exynos_lib);
return EINA_FALSE;
}
static Buffer_Handle *
_wl_shm_alloc(Buffer_Manager *self EINA_UNUSED, const char *name EINA_UNUSED, int w, int h, unsigned long *stride, int32_t *fd)
{
Efl_Vpath_File *file_obj;
Eina_Tmpstr *fullname;
size_t size = w * h * 4;
void *out = NULL;
file_obj = efl_vpath_manager_fetch(EFL_VPATH_MANAGER_CLASS,
"(:run:)/evas-wayland_shm-XXXXXX");
*fd = eina_file_mkstemp(efl_vpath_file_result_get(file_obj), &fullname);
efl_del(file_obj);
if (*fd < 0) return NULL;
unlink(fullname);
eina_tmpstr_del(fullname);
*stride = w * 4;
if (ftruncate(*fd, size) < 0) goto err;
out = mmap(NULL, size, (PROT_READ | PROT_WRITE), MAP_SHARED, *fd, 0);
if (out == MAP_FAILED) goto err;
return out;
err:
close(*fd);
return NULL;
}
static void *
_wl_shm_map(Dmabuf_Buffer *buf)
{
return buf->bh;
}
static void
_wl_shm_unmap(Dmabuf_Buffer *buf EINA_UNUSED)
{
/* wl_shm is mapped for its lifetime */
}
static void
_wl_shm_discard(Dmabuf_Buffer *buf)
{
munmap(buf->bh, buf->size);
}
static void
_wl_shm_manager_destroy()
{
/* Nop. */
}
static struct wl_buffer *
_wl_shm_to_buffer(Ecore_Wl2_Display *ewd, Dmabuf_Buffer *db)
{
struct wl_buffer *buf;
struct wl_shm_pool *pool;
struct wl_shm *shm;
shm = ecore_wl2_display_shm_get(ewd);
pool = wl_shm_create_pool(shm, db->fd, db->size);
buf = wl_shm_pool_create_buffer(pool, 0, db->w, db->h, db->stride, 0);
wl_shm_pool_destroy(pool);
close(db->fd);
db->fd = -1;
wl_buffer_add_listener(buf, &buffer_listener, db);
return buf;
}
static Eina_Bool
_wl_shm_buffer_manager_setup(int fd EINA_UNUSED)
{
buffer_manager->alloc = _wl_shm_alloc;
buffer_manager->to_buffer = _wl_shm_to_buffer;
buffer_manager->map = _wl_shm_map;
buffer_manager->unmap = _wl_shm_unmap;
buffer_manager->discard = _wl_shm_discard;
buffer_manager->manager_destroy = _wl_shm_manager_destroy;
return EINA_TRUE;
}
static Buffer_Manager *
_buffer_manager_get(Surface_Type types)
{
int fd;
Eina_Bool dmabuf = types & SURFACE_DMABUF;
Eina_Bool shm = types & SURFACE_SHM;
Eina_Bool success = EINA_FALSE;
if (buffer_manager)
{
buffer_manager->refcount++;
return buffer_manager;
}
buffer_manager = calloc(1, sizeof(Buffer_Manager));
if (!buffer_manager) goto err_alloc;
fd = open("/dev/dri/renderD128", O_RDWR | O_CLOEXEC);
if (fd < 0) goto err_drm;
if (!getenv("EVAS_WAYLAND_SHM_DISABLE_DMABUF"))
{
success = dmabuf && _intel_buffer_manager_setup(fd);
if (!success) success = dmabuf && _exynos_buffer_manager_setup(fd);
}
if (!success) success = shm && _wl_shm_buffer_manager_setup(fd);
if (!success) goto err_bm;
drm_fd = fd;
buffer_manager->refcount = 1;
return buffer_manager;
err_bm:
close(fd);
err_drm:
free(buffer_manager);
err_alloc:
dmabuf_totally_hosed = EINA_TRUE;
return NULL;
}
static void
_buffer_manager_ref(void)
{
buffer_manager->refcount++;
}
static void
_buffer_manager_deref(void)
{
buffer_manager->refcount--;
if (buffer_manager->refcount || !buffer_manager->destroyed) return;
if (buffer_manager->manager_destroy) buffer_manager->manager_destroy();
free(buffer_manager);
buffer_manager = NULL;
close(drm_fd);
}
/* Currently no callers, but that will change...
static void
_buffer_manager_destroy(void)
{
if (buffer_manager->destroyed) return;
buffer_manager->destroyed = EINA_TRUE;
_buffer_manager_deref();
}
*/
static Buffer_Handle *
_buffer_manager_alloc(const char *name, int w, int h, unsigned long *stride, int32_t *fd)
{
Buffer_Handle *out;
_buffer_manager_ref();
out = buffer_manager->alloc(buffer_manager, name, w, h, stride, fd);
if (!out) _buffer_manager_deref();
return out;
}
static struct wl_buffer *
_buffer_manager_buf_to_wl_buffer(Ecore_Wl2_Display *ewd, Dmabuf_Buffer *buf)
{
return buffer_manager->to_buffer(ewd, buf);
}
static void *
_buffer_manager_map(Dmabuf_Buffer *buf)
{
void *out;
_buffer_manager_ref();
out = buffer_manager->map(buf);
if (!out) _buffer_manager_deref();
return out;
}
static void
_buffer_manager_unmap(Dmabuf_Buffer *buf)
{
buffer_manager->unmap(buf);
_buffer_manager_deref();
}
static void
_buffer_manager_discard(Dmabuf_Buffer *buf)
{
buffer_manager->discard(buf);
_buffer_manager_deref();
}
static void
_evas_dmabuf_buffer_unlock(Dmabuf_Buffer *b)
{
_buffer_manager_unmap(b);
b->mapping = NULL;
b->locked = EINA_FALSE;
}
static void
_evas_dmabuf_buffer_destroy(Dmabuf_Buffer *b)
{
if (!b) return;
if (b->locked || b->busy)
{
b->orphaned = EINA_TRUE;
b->surface = NULL;
return;
}
if (b->fd != -1) close(b->fd);
if (b->mapping) _buffer_manager_unmap(b);
_buffer_manager_discard(b);
if (b->wl_buffer) wl_buffer_destroy(b->wl_buffer);
b->wl_buffer = NULL;
free(b);
}
static void
_evas_dmabuf_surface_reconfigure(Surface *s, int w, int h, uint32_t flags EINA_UNUSED, Eina_Bool force)
{
Dmabuf_Buffer *buf;
Dmabuf_Surface *surface;
int i;
if ((!w) || (!h)) return;
surface = s->surf.dmabuf;
for (i = 0; i < surface->nbuf; i++)
{
if (surface->buffer[i])
{
Dmabuf_Buffer *b = surface->buffer[i];
int stride = b->stride;
/* If stride is a little bigger than width we still fit */
if (!force && (w >= b->w) && (w <= stride / 4) && (h == b->h))
{
b->w = w;
continue;
}
_evas_dmabuf_buffer_destroy(b);
}
buf = _evas_dmabuf_buffer_init(surface, w, h);
if (!buf) return;
surface->buffer[i] = buf;
}
}
static void *
_evas_dmabuf_surface_data_get(Surface *s, int *w, int *h)
{
Dmabuf_Surface *surface;
Dmabuf_Buffer *b;
void *ptr;
surface = s->surf.dmabuf;
b = surface->current;
if (!b) return NULL;
/* We return stride/bpp because it may not match the allocated
* width. evas will figure out the clipping
*/
if (w) *w = b->stride / 4;
if (h) *h = b->h;
if (b->locked) return b->mapping;
ptr = _buffer_manager_map(b);
if (!ptr)
return NULL;
b->mapping = ptr;
b->locked = EINA_TRUE;
return b->mapping;
}
static Dmabuf_Buffer *
_evas_dmabuf_surface_wait(Dmabuf_Surface *s)
{
int i = 0, best = -1, best_age = -1;
for (i = 0; i < s->nbuf; i++)
{
if (s->buffer[i]->locked || s->buffer[i]->busy) continue;
if (s->buffer[i]->age > best_age)
{
best = i;
best_age = s->buffer[i]->age;
}
}
if (best >= 0) return s->buffer[best];
return NULL;
}
static int
_evas_dmabuf_surface_assign(Surface *s)
{
Dmabuf_Surface *surface;
int i;
surface = s->surf.dmabuf;
surface->current = _evas_dmabuf_surface_wait(surface);
if (!surface->current)
{
WRN("No free DMAbuf buffers, dropping a frame");
for (i = 0; i < surface->nbuf; i++)
surface->buffer[i]->age = 0;
return 0;
}
for (i = 0; i < surface->nbuf; i++)
if (surface->buffer[i]->used) surface->buffer[i]->age++;
return surface->current->age;
}
static void
_evas_dmabuf_surface_post(Surface *s, Eina_Rectangle *rects, unsigned int count)
{
struct wl_surface *wls;
Dmabuf_Surface *surface;
Dmabuf_Buffer *b;
Ecore_Wl2_Window *win;
surface = s->surf.dmabuf;
b = surface->current;
if (!b) return;
_evas_dmabuf_buffer_unlock(b);
surface->current = NULL;
b->busy = EINA_TRUE;
b->used = EINA_TRUE;
b->age = 0;
win = s->info->info.wl2_win;
wls = ecore_wl2_window_surface_get(win);
ecore_wl2_window_buffer_attach(win, b->wl_buffer, 0, 0, EINA_FALSE);
_evas_surface_damage(wls, surface->compositor_version,
b->w, b->h, rects, count);
ecore_wl2_window_commit(s->info->info.wl2_win, EINA_TRUE);
}
static struct wl_buffer *
_evas_dmabuf_wl_buffer_from_dmabuf(Ecore_Wl2_Display *ewd, Dmabuf_Buffer *db)
{
struct wl_buffer *buf;
struct zwp_linux_dmabuf_v1 *dmabuf;
struct zwp_linux_buffer_params_v1 *dp;
uint32_t flags = 0;
dmabuf = ecore_wl2_display_dmabuf_get(ewd);
dp = zwp_linux_dmabuf_v1_create_params(dmabuf);
zwp_linux_buffer_params_v1_add(dp, db->fd, 0, 0, db->stride, 0, 0);
buf = zwp_linux_buffer_params_v1_create_immed(dp, db->w, db->h,
DRM_FORMAT_ARGB8888, flags);
wl_buffer_add_listener(buf, &buffer_listener, db);
zwp_linux_buffer_params_v1_destroy(dp);
return buf;
}
static Dmabuf_Buffer *
_evas_dmabuf_buffer_init(Dmabuf_Surface *s, int w, int h)
{
Dmabuf_Buffer *out;
out = calloc(1, sizeof(Dmabuf_Buffer));
if (!out) return NULL;
out->fd = -1;
out->surface = s;
out->bh = _buffer_manager_alloc("name", w, h, &out->stride, &out->fd);
if (!out->bh)
{
free(out);
return NULL;
}
out->w = w;
out->h = h;
out->size = out->stride * h;
out->wl_buffer = _buffer_manager_buf_to_wl_buffer(s->surface->ob->ewd, out);
ecore_wl2_display_flush(s->surface->info->info.wl2_display);
return out;
}
static void
_internal_evas_dmabuf_surface_destroy(Dmabuf_Surface *surface)
{
int i;
for (i = 0; i < surface->nbuf; i++)
_evas_dmabuf_buffer_destroy(surface->buffer[i]);
free(surface->buffer);
surface->buffer = NULL;
surface->nbuf = 0;
free(surface);
}
static void
_evas_dmabuf_surface_destroy(Surface *s)
{
if (!s) return;
_internal_evas_dmabuf_surface_destroy(s->surf.dmabuf);
}
Eina_Bool
_evas_dmabuf_surface_create(Surface *s, int w, int h, int num_buff)
{
Surface_Type types = 0;
Dmabuf_Surface *surf = NULL;
int i = 0;
if (dmabuf_totally_hosed) return EINA_FALSE;
if (ecore_wl2_display_shm_get(s->info->info.wl2_display))
types |= SURFACE_SHM;
if (ecore_wl2_display_dmabuf_get(s->info->info.wl2_display))
types |= SURFACE_DMABUF;
if (!(s->surf.dmabuf = calloc(1, sizeof(Dmabuf_Surface)))) return EINA_FALSE;
surf = s->surf.dmabuf;
surf->surface = s;
surf->alpha = s->info->info.destination_alpha;
surf->compositor_version = s->info->info.compositor_version;
/* create surface buffers */
surf->nbuf = num_buff;
surf->buffer = calloc(surf->nbuf, sizeof(Dmabuf_Buffer *));
if (!surf->buffer) goto err;
if (!_buffer_manager_get(types)) goto err;
if (w && h)
{
for (i = 0; i < num_buff; i++)
{
surf->buffer[i] = _evas_dmabuf_buffer_init(surf, w, h);
if (!surf->buffer[i])
{
DBG("Could not create buffers");
/* _init() handled surface cleanup when it failed */
return EINA_FALSE;
}
}
}
s->type = SURFACE_DMABUF;
s->funcs.destroy = _evas_dmabuf_surface_destroy;
s->funcs.reconfigure = _evas_dmabuf_surface_reconfigure;
s->funcs.data_get = _evas_dmabuf_surface_data_get;
s->funcs.assign = _evas_dmabuf_surface_assign;
s->funcs.post = _evas_dmabuf_surface_post;
return EINA_TRUE;
err:
free(surf->buffer);
free(surf);
return EINA_FALSE;
}