qemu

FORK: QEMU emulator
git clone https://git.neptards.moe/neptards/qemu.git
Log | Files | Refs | Submodules | LICENSE

test-io-channel-null.c (2890B)

      1 /*
      2  * QEMU I/O channel null test
      3  *
      4  * Copyright (c) 2022 Red Hat, Inc.
      5  *
      6  * This library is free software; you can redistribute it and/or
      7  * modify it under the terms of the GNU Lesser General Public
      8  * License as published by the Free Software Foundation; either
      9  * version 2.1 of the License, or (at your option) any later version.
     10  *
     11  * This library is distributed in the hope that it will be useful,
     12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
     13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
     14  * Lesser General Public License for more details.
     15  *
     16  * You should have received a copy of the GNU Lesser General Public
     17  * License along with this library; if not, see <http://www.gnu.org/licenses/>.
     18  *
     19  */
     20 
     21 #include "qemu/osdep.h"
     22 #include "io/channel-null.h"
     23 #include "qapi/error.h"
     24 
     25 static gboolean test_io_channel_watch(QIOChannel *ioc,
     26                                       GIOCondition condition,
     27                                       gpointer opaque)
     28 {
     29     GIOCondition *gotcond = opaque;
     30     *gotcond = condition;
     31     return G_SOURCE_REMOVE;
     32 }
     33 
     34 static void test_io_channel_null_io(void)
     35 {
     36     g_autoptr(QIOChannelNull) null = qio_channel_null_new();
     37     char buf[1024];
     38     GIOCondition gotcond = 0;
     39     Error *local_err = NULL;
     40 
     41     g_assert(qio_channel_write(QIO_CHANNEL(null),
     42                                "Hello World", 11,
     43                                &error_abort) == 11);
     44 
     45     g_assert(qio_channel_read(QIO_CHANNEL(null),
     46                               buf, sizeof(buf),
     47                               &error_abort) == 0);
     48 
     49     qio_channel_add_watch(QIO_CHANNEL(null),
     50                           G_IO_IN,
     51                           test_io_channel_watch,
     52                           &gotcond,
     53                           NULL);
     54 
     55     g_main_context_iteration(NULL, false);
     56 
     57     g_assert(gotcond == G_IO_IN);
     58 
     59     qio_channel_add_watch(QIO_CHANNEL(null),
     60                           G_IO_IN | G_IO_OUT,
     61                           test_io_channel_watch,
     62                           &gotcond,
     63                           NULL);
     64 
     65     g_main_context_iteration(NULL, false);
     66 
     67     g_assert(gotcond == (G_IO_IN | G_IO_OUT));
     68 
     69     qio_channel_close(QIO_CHANNEL(null), &error_abort);
     70 
     71     g_assert(qio_channel_write(QIO_CHANNEL(null),
     72                                "Hello World", 11,
     73                                &local_err) == -1);
     74     g_assert_nonnull(local_err);
     75 
     76     g_clear_pointer(&local_err, error_free);
     77 
     78     g_assert(qio_channel_read(QIO_CHANNEL(null),
     79                               buf, sizeof(buf),
     80                               &local_err) == -1);
     81     g_assert_nonnull(local_err);
     82 
     83     g_clear_pointer(&local_err, error_free);
     84 }
     85 
     86 int main(int argc, char **argv)
     87 {
     88     module_call_init(MODULE_INIT_QOM);
     89 
     90     g_test_init(&argc, &argv, NULL);
     91 
     92     g_test_add_func("/io/channel/null/io", test_io_channel_null_io);
     93 
     94     return g_test_run();
     95 }