SurfaceThread.h

Go to the documentation of this file.

/*
 * Copyright 2021 Google Inc.
 *
 * Use of this source code is governed by a BSD-style license that can be
 * found in the LICENSE file.
 */
#ifndef JetSki_SurfaceThread_DEFINED
#define JetSki_SurfaceThread_DEFINED
 
#include <pthread.h>
#include <unistd.h>
#include <android/looper.h>
#include <android/native_window.h>
 
#include "include/core/SkPictureRecorder.h"
 
class WindowSurface;
 
#include "modules/jetski/src/Surface.h"
 
enum MessageType {
    kUndefined,
    kInitialize,
    kDestroy,
    kRenderPicture,
};
 
struct Message {
    MessageType fType = kUndefined;
    ANativeWindow* fNativeWindow = nullptr;
    SkPicture* fPicture = nullptr;
    WindowSurface** fWindowSurface = nullptr;
 
    Message() {}
    Message(MessageType t) : fType(t) {}
};
 
class SurfaceThread {
public:
    SurfaceThread();
 
    void postMessage(const Message& message) const;
    void readMessage(Message* message) const;
    void release();
private:
    static void* pthread_main(void* arg);
    static int message_callback(int fd, int events, void* data);
    // TODO: This has to be static, which is weird now, but fine in a singleton
    // Switch to singleton design or find other way to break out of thread loop
    bool fRunning;
 
    pthread_t fThread;
    int fPipe[2]; // acts as a Message queue, read from [0] write to [1]
};
 
#endif