summaryrefslogtreecommitdiffstats
path: root/qemu/tests/test-io-task.c
diff options
context:
space:
mode:
authorRajithaY <rajithax.yerrumsetty@intel.com>2017-04-25 03:31:15 -0700
committerRajitha Yerrumchetty <rajithax.yerrumsetty@intel.com>2017-05-22 06:48:08 +0000
commitbb756eebdac6fd24e8919e2c43f7d2c8c4091f59 (patch)
treeca11e03542edf2d8f631efeca5e1626d211107e3 /qemu/tests/test-io-task.c
parenta14b48d18a9ed03ec191cf16b162206998a895ce (diff)
Adding qemu as a submodule of KVMFORNFV
This Patch includes the changes to add qemu as a submodule to kvmfornfv repo and make use of the updated latest qemu for the execution of all testcase Change-Id: I1280af507a857675c7f81d30c95255635667bdd7 Signed-off-by:RajithaY<rajithax.yerrumsetty@intel.com>
Diffstat (limited to 'qemu/tests/test-io-task.c')
-rw-r--r--qemu/tests/test-io-task.c270
1 files changed, 0 insertions, 270 deletions
diff --git a/qemu/tests/test-io-task.c b/qemu/tests/test-io-task.c
deleted file mode 100644
index 5a9775086..000000000
--- a/qemu/tests/test-io-task.c
+++ /dev/null
@@ -1,270 +0,0 @@
-/*
- * QEMU I/O task tests
- *
- * Copyright (c) 2015 Red Hat, Inc.
- *
- * This library is free software; you can redistribute it and/or
- * modify it under the terms of the GNU Lesser General Public
- * License as published by the Free Software Foundation; either
- * version 2 of the License, or (at your option) any later version.
- *
- * This library 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
- * Lesser General Public License for more details.
- *
- * You should have received a copy of the GNU Lesser General Public
- * License along with this library; if not, see <http://www.gnu.org/licenses/>.
- *
- */
-
-#include "qemu/osdep.h"
-#include <glib.h>
-
-#include "io/task.h"
-#include "qapi/error.h"
-
-#define TYPE_DUMMY "qemu:dummy"
-
-typedef struct DummyObject DummyObject;
-typedef struct DummyObjectClass DummyObjectClass;
-
-struct DummyObject {
- Object parent;
-};
-
-struct DummyObjectClass {
- ObjectClass parent;
-};
-
-static const TypeInfo dummy_info = {
- .parent = TYPE_OBJECT,
- .name = TYPE_DUMMY,
- .instance_size = sizeof(DummyObject),
- .class_size = sizeof(DummyObjectClass),
-};
-
-struct TestTaskData {
- Object *source;
- Error *err;
- bool freed;
-};
-
-
-static void task_callback(Object *source,
- Error *err,
- gpointer opaque)
-{
- struct TestTaskData *data = opaque;
-
- data->source = source;
- data->err = err;
-}
-
-
-static void test_task_complete(void)
-{
- QIOTask *task;
- Object *obj = object_new(TYPE_DUMMY);
- Object *src;
- struct TestTaskData data = { NULL, NULL, false };
-
- task = qio_task_new(obj, task_callback, &data, NULL);
- src = qio_task_get_source(task);
-
- qio_task_complete(task);
-
- g_assert(obj == src);
-
- object_unref(obj);
- object_unref(src);
-
- g_assert(data.source == obj);
- g_assert(data.err == NULL);
- g_assert(data.freed == false);
-}
-
-
-static void task_data_free(gpointer opaque)
-{
- struct TestTaskData *data = opaque;
-
- data->freed = true;
-}
-
-
-static void test_task_data_free(void)
-{
- QIOTask *task;
- Object *obj = object_new(TYPE_DUMMY);
- struct TestTaskData data = { NULL, NULL, false };
-
- task = qio_task_new(obj, task_callback, &data, task_data_free);
-
- qio_task_complete(task);
-
- object_unref(obj);
-
- g_assert(data.source == obj);
- g_assert(data.err == NULL);
- g_assert(data.freed == true);
-}
-
-
-static void test_task_error(void)
-{
- QIOTask *task;
- Object *obj = object_new(TYPE_DUMMY);
- struct TestTaskData data = { NULL, NULL, false };
- Error *err = NULL;
-
- task = qio_task_new(obj, task_callback, &data, NULL);
-
- error_setg(&err, "Some error");
-
- qio_task_abort(task, err);
-
- error_free(err);
- object_unref(obj);
-
- g_assert(data.source == obj);
- g_assert(data.err == err);
- g_assert(data.freed == false);
-
-}
-
-
-struct TestThreadWorkerData {
- Object *source;
- Error *err;
- bool fail;
- GThread *worker;
- GThread *complete;
- GMainLoop *loop;
-};
-
-static int test_task_thread_worker(QIOTask *task,
- Error **errp,
- gpointer opaque)
-{
- struct TestThreadWorkerData *data = opaque;
-
- data->worker = g_thread_self();
-
- if (data->fail) {
- error_setg(errp, "Testing fail");
- return -1;
- }
-
- return 0;
-}
-
-
-static void test_task_thread_callback(Object *source,
- Error *err,
- gpointer opaque)
-{
- struct TestThreadWorkerData *data = opaque;
-
- data->source = source;
- data->err = err;
-
- data->complete = g_thread_self();
-
- g_main_loop_quit(data->loop);
-}
-
-
-static void test_task_thread_complete(void)
-{
- QIOTask *task;
- Object *obj = object_new(TYPE_DUMMY);
- struct TestThreadWorkerData data = { 0 };
- GThread *self;
-
- data.loop = g_main_loop_new(g_main_context_default(),
- TRUE);
-
- task = qio_task_new(obj,
- test_task_thread_callback,
- &data,
- NULL);
-
- qio_task_run_in_thread(task,
- test_task_thread_worker,
- &data,
- NULL);
-
- g_main_loop_run(data.loop);
-
- g_main_loop_unref(data.loop);
- object_unref(obj);
-
- g_assert(data.source == obj);
- g_assert(data.err == NULL);
-
- self = g_thread_self();
-
- /* Make sure the test_task_thread_worker actually got
- * run in a different thread */
- g_assert(data.worker != self);
-
- /* And that the test_task_thread_callback got rnu in
- * the main loop thread (ie this one) */
- g_assert(data.complete == self);
-}
-
-
-static void test_task_thread_error(void)
-{
- QIOTask *task;
- Object *obj = object_new(TYPE_DUMMY);
- struct TestThreadWorkerData data = { 0 };
- GThread *self;
-
- data.loop = g_main_loop_new(g_main_context_default(),
- TRUE);
- data.fail = true;
-
- task = qio_task_new(obj,
- test_task_thread_callback,
- &data,
- NULL);
-
- qio_task_run_in_thread(task,
- test_task_thread_worker,
- &data,
- NULL);
-
- g_main_loop_run(data.loop);
-
- g_main_loop_unref(data.loop);
- object_unref(obj);
-
- g_assert(data.source == obj);
- g_assert(data.err != NULL);
-
- self = g_thread_self();
-
- /* Make sure the test_task_thread_worker actually got
- * run in a different thread */
- g_assert(data.worker != self);
-
- /* And that the test_task_thread_callback got rnu in
- * the main loop thread (ie this one) */
- g_assert(data.complete == self);
-}
-
-
-int main(int argc, char **argv)
-{
- g_test_init(&argc, &argv, NULL);
- module_call_init(MODULE_INIT_QOM);
- type_register_static(&dummy_info);
- g_test_add_func("/crypto/task/complete", test_task_complete);
- g_test_add_func("/crypto/task/datafree", test_task_data_free);
- g_test_add_func("/crypto/task/error", test_task_error);
- g_test_add_func("/crypto/task/thread_complete", test_task_thread_complete);
- g_test_add_func("/crypto/task/thread_error", test_task_thread_error);
- return g_test_run();
-}