← Back to branch summary

~ubuntu-branches/ubuntu/trusty/qemu/trusty

« back to all changes in this revision

Viewing changes to .pc/1.6.1.patch/qemu-coroutine.c

  • Committer: Package Import Robot
  • Author(s): Serge Hallyn
  • Date: 2013-10-22 22:47:07 UTC
  • mfrom: (1.8.3) (10.1.42 sid)
  • Revision ID: package-import@ubuntu.com-20131022224707-1lya34fw3k3f24tv
Tags: 1.6.0+dfsg-2ubuntu1
http://bugs.debian.org/709241
* Merge 1.6.0~rc0+dfsg-2exp from debian experimental.  Remaining changes:
  - debian/control
    * update maintainer
    * remove libiscsi, usb-redir, vde, vnc-jpeg, and libssh2-1-dev
      from build-deps
    * enable rbd
    * add qemu-system and qemu-common B/R to qemu-keymaps
    * add D:udev, R:qemu, R:qemu-common and B:qemu-common to
      qemu-system-common
    * qemu-system-arm, qemu-system-ppc, qemu-system-sparc:
      - add qemu-kvm to Provides
      - add qemu-common, qemu-kvm, kvm to B/R
      - remove openbios-sparc from qemu-system-sparc D
      - drop openbios-ppc and openhackware Depends to Suggests (for now)
    * qemu-system-x86:
      - add qemu-common to Breaks/Replaces.
      - add cpu-checker to Recommends.
    * qemu-user: add B/R:qemu-kvm
    * qemu-kvm:
      - add armhf armel powerpc sparc to Architecture
      - C/R/P: qemu-kvm-spice
    * add qemu-common package
    * drop qemu-slof which is not packaged in ubuntu
  - add qemu-system-common.links for tap ifup/down scripts and OVMF link.
  - qemu-system-x86.links:
    * remove pxe rom links which are in kvm-ipxe
    * add symlink for kvm.1 manpage
  - debian/rules
    * add kvm-spice symlink to qemu-kvm
    * call dh_installmodules for qemu-system-x86
    * update dh_installinit to install upstart script
    * run dh_installman (Closes: #709241) (cherrypicked from 1.5.0+dfsg-2)
  - Add qemu-utils.links for kvm-* symlinks.
  - Add qemu-system-x86.qemu-kvm.upstart and .default
  - Add qemu-system-x86.modprobe to set nesting=1
  - Add qemu-system-common.preinst to add kvm group
  - qemu-system-common.postinst: remove bad group acl if there, then have
    udev relabel /dev/kvm.
  - New linaro patches from qemu-linaro rebasing branch
  - Dropped patches:
    * xen-simplify-xen_enabled.patch
    * sparc-linux-user-fix-missing-symbols-in-.rel-.rela.plt-sections.patch
    * main_loop-do-not-set-nonblocking-if-xen_enabled.patch
    * xen_machine_pv-do-not-create-a-dummy-CPU-in-machine-.patch
    * virtio-rng-fix-crash
  - Kept patches:
    * expose_vms_qemu64cpu.patch - updated
    * linaro arm patches from qemu-linaro rebasing branch
  - New patches:
    * fix-pci-add: change CONFIG variable in ifdef to make sure that
      pci_add is defined.
* Add linaro patches
* Add experimental mach-virt patches for arm virtualization.
* qemu-system-common.install: add debian/tmp/usr/lib to install the
  qemu-bridge-helper

Show diffs side-by-side

added added

removed removed

Lines of Context:
.pc/1.6.1.patch/qemu-coroutine.c
 
1
/*
 
2
 * QEMU coroutines
 
3
 *
 
4
 * Copyright IBM, Corp. 2011
 
5
 *
 
6
 * Authors:
 
7
 *  Stefan Hajnoczi    <stefanha@linux.vnet.ibm.com>
 
8
 *  Kevin Wolf         <kwolf@redhat.com>
 
9
 *
 
10
 * This work is licensed under the terms of the GNU LGPL, version 2 or later.
 
11
 * See the COPYING.LIB file in the top-level directory.
 
12
 *
 
13
 */
 
14
 
 
15
#include "trace.h"
 
16
#include "qemu-common.h"
 
17
#include "qemu/thread.h"
 
18
#include "block/coroutine.h"
 
19
#include "block/coroutine_int.h"
 
20
 
 
21
enum {
 
22
    /* Maximum free pool size prevents holding too many freed coroutines */
 
23
    POOL_MAX_SIZE = 64,
 
24
};
 
25
 
 
26
/** Free list to speed up creation */
 
27
static QemuMutex pool_lock;
 
28
static QSLIST_HEAD(, Coroutine) pool = QSLIST_HEAD_INITIALIZER(pool);
 
29
static unsigned int pool_size;
 
30
 
 
31
Coroutine *qemu_coroutine_create(CoroutineEntry *entry)
 
32
{
 
33
    Coroutine *co;
 
34
 
 
35
    qemu_mutex_lock(&pool_lock);
 
36
    co = QSLIST_FIRST(&pool);
 
37
    if (co) {
 
38
        QSLIST_REMOVE_HEAD(&pool, pool_next);
 
39
        pool_size--;
 
40
    }
 
41
    qemu_mutex_unlock(&pool_lock);
 
42
 
 
43
    if (!co) {
 
44
        co = qemu_coroutine_new();
 
45
    }
 
46
 
 
47
    co->entry = entry;
 
48
    QTAILQ_INIT(&co->co_queue_wakeup);
 
49
    return co;
 
50
}
 
51
 
 
52
static void coroutine_delete(Coroutine *co)
 
53
{
 
54
    qemu_mutex_lock(&pool_lock);
 
55
    if (pool_size < POOL_MAX_SIZE) {
 
56
        QSLIST_INSERT_HEAD(&pool, co, pool_next);
 
57
        co->caller = NULL;
 
58
        pool_size++;
 
59
        qemu_mutex_unlock(&pool_lock);
 
60
        return;
 
61
    }
 
62
    qemu_mutex_unlock(&pool_lock);
 
63
 
 
64
    qemu_coroutine_delete(co);
 
65
}
 
66
 
 
67
static void __attribute__((constructor)) coroutine_pool_init(void)
 
68
{
 
69
    qemu_mutex_init(&pool_lock);
 
70
}
 
71
 
 
72
static void __attribute__((destructor)) coroutine_pool_cleanup(void)
 
73
{
 
74
    Coroutine *co;
 
75
    Coroutine *tmp;
 
76
 
 
77
    QSLIST_FOREACH_SAFE(co, &pool, pool_next, tmp) {
 
78
        QSLIST_REMOVE_HEAD(&pool, pool_next);
 
79
        qemu_coroutine_delete(co);
 
80
    }
 
81
 
 
82
    qemu_mutex_destroy(&pool_lock);
 
83
}
 
84
 
 
85
static void coroutine_swap(Coroutine *from, Coroutine *to)
 
86
{
 
87
    CoroutineAction ret;
 
88
 
 
89
    ret = qemu_coroutine_switch(from, to, COROUTINE_YIELD);
 
90
 
 
91
    qemu_co_queue_run_restart(to);
 
92
 
 
93
    switch (ret) {
 
94
    case COROUTINE_YIELD:
 
95
        return;
 
96
    case COROUTINE_TERMINATE:
 
97
        trace_qemu_coroutine_terminate(to);
 
98
        coroutine_delete(to);
 
99
        return;
 
100
    default:
 
101
        abort();
 
102
    }
 
103
}
 
104
 
 
105
void qemu_coroutine_enter(Coroutine *co, void *opaque)
 
106
{
 
107
    Coroutine *self = qemu_coroutine_self();
 
108
 
 
109
    trace_qemu_coroutine_enter(self, co, opaque);
 
110
 
 
111
    if (co->caller) {
 
112
        fprintf(stderr, "Co-routine re-entered recursively\n");
 
113
        abort();
 
114
    }
 
115
 
 
116
    co->caller = self;
 
117
    co->entry_arg = opaque;
 
118
    coroutine_swap(self, co);
 
119
}
 
120
 
 
121
void coroutine_fn qemu_coroutine_yield(void)
 
122
{
 
123
    Coroutine *self = qemu_coroutine_self();
 
124
    Coroutine *to = self->caller;
 
125
 
 
126
    trace_qemu_coroutine_yield(self, to);
 
127
 
 
128
    if (!to) {
 
129
        fprintf(stderr, "Co-routine is yielding to no one\n");
 
130
        abort();
 
131
    }
 
132
 
 
133
    self->caller = NULL;
 
134
    coroutine_swap(self, to);
 
135
}