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
  20 #define TYPE_IOTHREAD "iothread"
  21
  22 typedef struct {
  23     Object parent_obj;
  24
  25     QemuThread thread;
  26     AioContext *ctx;
  27     GMainContext *worker_context;
  28     GMainLoop *main_loop;
  29     GOnce once;
  30     QemuMutex init_done_lock;
  31     QemuCond init_done_cond;    /* is thread initialization done? */
  32     bool stopping;
  33     int thread_id;
  34
  35     /* AioContext poll parameters */
  36     int64_t poll_max_ns;
  37     int64_t poll_grow;
  38     int64_t poll_shrink;
  39 } IOThread;
  40
  41 #define IOTHREAD(obj) \
  42    OBJECT_CHECK(IOThread, obj, TYPE_IOTHREAD)
  43
  44 char *iothread_get_id(IOThread *iothread);
  45 AioContext *iothread_get_aio_context(IOThread *iothread);
  46 void iothread_stop_all(void);
  47 GMainContext *iothread_get_g_main_context(IOThread *iothread);
  48
  49 /*
  50  * Helpers used to allocate iothreads for internal use.  These
  51  * iothreads will not be seen by monitor clients when query using
  52  * "query-iothreads".
  53  */
  54 IOThread *iothread_create(const char *id, Error **errp);
  55 void iothread_destroy(IOThread *iothread);
  56
  57 #endif /* IOTHREAD_H */