aboutsummaryrefslogtreecommitdiffstats
path: root/android/framebuffer-core.c
diff options
context:
space:
mode:
Diffstat (limited to 'android/framebuffer-core.c')
-rw-r--r--android/framebuffer-core.c258
1 files changed, 258 insertions, 0 deletions
diff --git a/android/framebuffer-core.c b/android/framebuffer-core.c
new file mode 100644
index 0000000..a473415
--- /dev/null
+++ b/android/framebuffer-core.c
@@ -0,0 +1,258 @@
+/* Copyright (C) 2010 The Android Open Source Project
+**
+** This software is licensed under the terms of the GNU General Public
+** License version 2, as published by the Free Software Foundation, and
+** may be copied, distributed, and modified under those terms.
+**
+** 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.
+*/
+
+/*
+ * Contains core-side framebuffer service that sends framebuffer updates
+ * to the UI connected to the core.
+ */
+
+#include "console.h"
+#include "framebuffer.h"
+#include "android/looper.h"
+#include "android/display-core.h"
+#include "android/async-utils.h"
+#include "android/framebuffer-common.h"
+#include "android/framebuffer-core.h"
+#include "android/utils/system.h"
+#include "android/utils/debug.h"
+
+/* Core framebuffer descriptor. */
+struct CoreFramebuffer {
+ /* Writer used to send FB update notification messages. */
+ AsyncWriter fb_update_writer;
+
+ /* I/O associated with this descriptor. */
+ LoopIo io;
+
+ /* Looper used to communicate framebuffer updates. */
+ Looper* looper;
+
+ /* Head of the list of pending FB update notifications. */
+ struct FBUpdateNotify* fb_update_head;
+
+ /* Tail of the list of pending FB update notifications. */
+ struct FBUpdateNotify* fb_update_tail;
+
+ /* Socket used to communicate framebuffer updates. */
+ int sock;
+};
+
+/* Framebuffer update notification descriptor to the core. */
+typedef struct FBUpdateNotify {
+ /* Links all pending FB update notifications. */
+ struct FBUpdateNotify* next_fb_update;
+
+ /* Core framebuffer instance that owns the message. */
+ CoreFramebuffer* core_fb;
+
+ /* Size of the message to transfer. */
+ size_t message_size;
+
+ /* Update message. */
+ FBUpdateMessage message;
+} FBUpdateNotify;
+
+/*
+ * Gets pointer in framebuffer's pixels for the given pixel.
+ * Param:
+ * fb Framebuffer containing pixels.
+ * x, and y identify the pixel to get pointer for.
+ * Return:
+ * Pointer in framebuffer's pixels for the given pixel.
+ */
+static const uint8_t*
+_pixel_offset(const QFrameBuffer* fb, int x, int y)
+{
+ return (const uint8_t*)fb->pixels + y * fb->pitch + x * fb->bytes_per_pixel;
+}
+
+/*
+ * Copies pixels from a framebuffer rectangle.
+ * Param:
+ * rect - Buffer where to copy pixel.
+ * fb - Framebuffer containing the rectangle to copy.
+ * x, y, w, and h - dimensions of the rectangle to copy.
+ */
+static void
+_copy_fb_rect(uint8_t* rect, const QFrameBuffer* fb, int x, int y, int w, int h)
+{
+ const uint8_t* start = _pixel_offset(fb, x, y);
+ for (; h > 0; h--) {
+ memcpy(rect, start, w * fb->bytes_per_pixel);
+ start += fb->pitch;
+ rect += w * fb->bytes_per_pixel;
+ }
+}
+
+/*
+ * Allocates and initializes framebuffer update notification descriptor.
+ * Param:
+ * ds - Display state for the framebuffer.
+ * fb Framebuffer containing pixels.
+ * x, y, w, and h identify the rectangle that is being updated.
+ * Return:
+ * Initialized framebuffer update notification descriptor.
+ */
+static FBUpdateNotify*
+fbupdatenotify_create(CoreFramebuffer* core_fb, const QFrameBuffer* fb,
+ int x, int y, int w, int h)
+{
+ const size_t rect_size = w * h * fb->bytes_per_pixel;
+ FBUpdateNotify* ret = malloc(sizeof(FBUpdateNotify) + rect_size);
+
+ ret->next_fb_update = NULL;
+ ret->core_fb = core_fb;
+ ret->message_size = sizeof(FBUpdateMessage) + rect_size;
+ ret->message.x = x;
+ ret->message.y = y;
+ ret->message.w = w;
+ ret->message.h = h;
+ ret->message.bits_per_pixel = fb->bits_per_pixel;
+ _copy_fb_rect(ret->message.rect, fb, x, y, w, h);
+ return ret;
+}
+
+/*
+ * Deletes FBUpdateNotify descriptor, created with fbupdatenotify_create.
+ * Param:
+ * desc - Descreptor to delete.
+ */
+static void
+fbupdatenotify_delete(FBUpdateNotify* desc)
+{
+ if (desc != NULL) {
+ free(desc);
+ }
+}
+
+/*
+ * Asynchronous I/O callback launched when writing framebuffer notifications
+ * to the socket.
+ * Param:
+ * opaque - CoreFramebuffer instance.
+ */
+static void
+corefb_io_func(void* opaque, int fd, unsigned events)
+{
+ CoreFramebuffer* core_fb = opaque;
+
+ while (core_fb->fb_update_head != NULL) {
+ FBUpdateNotify* current_update = core_fb->fb_update_head;
+ // Lets continue writing of the current notification.
+ const AsyncStatus status =
+ asyncWriter_write(&core_fb->fb_update_writer, &core_fb->io);
+ switch (status) {
+ case ASYNC_COMPLETE:
+ // Done with the current update. Move on to the next one.
+ break;
+ case ASYNC_ERROR:
+ // Done with the current update. Move on to the next one.
+ loopIo_dontWantWrite(&core_fb->io);
+ break;
+
+ case ASYNC_NEED_MORE:
+ // Transfer will eventually come back into this routine.
+ return;
+ }
+
+ // Advance the list of updates
+ core_fb->fb_update_head = current_update->next_fb_update;
+ if (core_fb->fb_update_head == NULL) {
+ core_fb->fb_update_tail = NULL;
+ }
+ fbupdatenotify_delete(current_update);
+
+ if (core_fb->fb_update_head != NULL) {
+ // Schedule the next one.
+ asyncWriter_init(&core_fb->fb_update_writer,
+ &core_fb->fb_update_head->message,
+ core_fb->fb_update_head->message_size,
+ &core_fb->io);
+ }
+ }
+}
+
+CoreFramebuffer*
+corefb_create(int sock, const char* protocol)
+{
+ // At this point we're implementing the -raw protocol only.
+ CoreFramebuffer* ret;
+ ANEW0(ret);
+ ret->sock = sock;
+ ret->looper = looper_newCore();
+ loopIo_init(&ret->io, ret->looper, sock, corefb_io_func, ret);
+ ret->fb_update_head = NULL;
+ ret->fb_update_tail = NULL;
+ return ret;
+}
+
+void
+corefb_destroy(CoreFramebuffer* core_fb)
+{
+ if (core_fb != NULL) {
+ if (core_fb->looper != NULL) {
+ // Stop all I/O that may still be going on.
+ loopIo_done(&core_fb->io);
+ // Delete all pending frame updates.
+ while (core_fb->fb_update_head != NULL) {
+ FBUpdateNotify* pending_update = core_fb->fb_update_head;
+ core_fb->fb_update_head = pending_update->next_fb_update;
+ fbupdatenotify_delete(pending_update);
+ }
+ core_fb->fb_update_tail = NULL;
+ looper_free(core_fb->looper);
+ core_fb->looper = NULL;
+ }
+ }
+}
+
+void
+corefb_update(CoreFramebuffer* core_fb, struct DisplayState* ds,
+ struct QFrameBuffer* fb, int x, int y, int w, int h)
+{
+ AsyncStatus status;
+ FBUpdateNotify* descr = fbupdatenotify_create(core_fb, fb, x, y, w, h);
+
+ printf("Update framebuffer (%u bytes): %d:%d - %d:%d ",
+ descr->message_size, x, y, w, h);
+
+ // Lets see if we should list it behind other pending updates.
+ if (core_fb->fb_update_tail != NULL) {
+ core_fb->fb_update_tail->next_fb_update = descr;
+ core_fb->fb_update_tail = descr;
+ printf("PENDED\n");
+ return;
+ }
+
+ // We're first in the list. Just send it now.
+ core_fb->fb_update_head = core_fb->fb_update_tail = descr;
+ asyncWriter_init(&core_fb->fb_update_writer,
+ &core_fb->fb_update_head->message,
+ core_fb->fb_update_head->message_size, &core_fb->io);
+ status = asyncWriter_write(&core_fb->fb_update_writer, &core_fb->io);
+ switch (status) {
+ case ASYNC_COMPLETE:
+ fbupdatenotify_delete(descr);
+ core_fb->fb_update_head = core_fb->fb_update_tail = NULL;
+ printf("COMPLETED\n");
+ return;
+ case ASYNC_ERROR:
+ printf("FAILED: %s\n", errno_str);
+ fbupdatenotify_delete(descr);
+ core_fb->fb_update_head = core_fb->fb_update_tail = NULL;
+ return;
+ case ASYNC_NEED_MORE:
+ // Update transfer will eventually complete in corefb_io_func
+ printf("PARTIAL\n");
+ return;
+ }
+}
generated by cgit v1.1 at 2024-06-23 09:57:44 +0000