include/sysemu/iothread.h

   1 /*
   2  * Event loop thread
   3  *
   4  * Copyright Red Hat Inc., 2013
   5  *
   6  * Authors:
   7  *  Stefan Hajnoczi   <stefanha@redhat.com>
   8  *
   9  * This work is licensed under the terms of the GNU GPL, version 2 or later.
  10  * See the COPYING file in the top-level directory.
  11  *
  12  */
  13
  14 #ifndef IOTHREAD_H
  15 #define IOTHREAD_H
  16
  17 #include "block/aio.h"
  18 #include "qemu/thread.h"
  19 #include "qom/object.h"
  20
  21 #define TYPE_IOTHREAD "iothread"
  22
  23 struct IOThread {
  24     Object parent_obj;
  25
  26     QemuThread thread;
  27     AioContext *ctx;
  28     bool run_gcontext;          /* whether we should run gcontext */
  29     GMainContext *worker_context;
  30     GMainLoop *main_loop;
  31     QemuSemaphore init_done_sem; /* is thread init done? */
  32     bool stopping;              /* has iothread_stop() been called? */
  33     bool running;               /* should iothread_run() continue? */
  34     int thread_id;
  35
  36     /* AioContext poll parameters */
  37     int64_t poll_max_ns;
  38     int64_t poll_grow;
  39     int64_t poll_shrink;
  40
  41     /* AioContext AIO engine parameters */
  42     int64_t aio_max_batch;
  43 };
  44 typedef struct IOThread IOThread;
  45
  46 DECLARE_INSTANCE_CHECKER(IOThread, IOTHREAD,
  47                          TYPE_IOTHREAD)
  48
  49 char *iothread_get_id(IOThread *iothread);
  50 IOThread *iothread_by_id(const char *id);
  51 AioContext *iothread_get_aio_context(IOThread *iothread);
  52 GMainContext *iothread_get_g_main_context(IOThread *iothread);
  53
  54 /*
  55  * Helpers used to allocate iothreads for internal use.  These
  56  * iothreads will not be seen by monitor clients when query using
  57  * "query-iothreads".
  58  */
  59 IOThread *iothread_create(const char *id, Error **errp);
  60 void iothread_stop(IOThread *iothread);
  61 void iothread_destroy(IOThread *iothread);
  62
  63 /*
  64  * Returns true if executing withing IOThread context,
  65  * false otherwise.
  66  */
  67 bool qemu_in_iothread(void);
  68
  69 #endif /* IOTHREAD_H */