mirror of
https://github.com/libguestfs/libguestfs.git
synced 2026-03-21 22:53:37 +00:00
72cfaff5c5
Automated using this command: perl -pi.bak -e 's/(20[012][0-9])-20[12][01234]/$1-2025/g' `git ls-files`
134 lines
3.5 KiB
C
134 lines
3.5 KiB
C
/* libguestfs
|
|
* Copyright (C) 2015-2025 Red Hat Inc.
|
|
*
|
|
* This program is free software; you can redistribute it and/or modify
|
|
* it under the terms of the GNU General Public License as published by
|
|
* the Free Software Foundation; either version 2 of the License, or
|
|
* (at your option) any later version.
|
|
*
|
|
* This program 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 General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License along
|
|
* with this program; if not, write to the Free Software Foundation, Inc.,
|
|
* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
|
|
*/
|
|
|
|
/* Test that we can make API calls safely from multiple threads. */
|
|
|
|
#include <config.h>
|
|
|
|
#include <stdio.h>
|
|
#include <stdlib.h>
|
|
#include <stdint.h>
|
|
#include <string.h>
|
|
#include <assert.h>
|
|
|
|
#include <pthread.h>
|
|
|
|
#include "guestfs.h"
|
|
#include "guestfs-utils.h"
|
|
|
|
static guestfs_h *g;
|
|
|
|
#define RUN_TIME 60 /* seconds */
|
|
#define NR_CONCURRENT_THREADS 4
|
|
|
|
static void *start_thread (void *nullv);
|
|
|
|
int
|
|
main (int argc, char *argv[])
|
|
{
|
|
time_t start_t, t;
|
|
pthread_t threads[NR_CONCURRENT_THREADS];
|
|
void *ret;
|
|
int i, r;
|
|
|
|
/* Because we rely on error message content below, force LC_ALL=C. */
|
|
setenv ("LC_ALL", "C", 1);
|
|
|
|
g = guestfs_create ();
|
|
if (!g) {
|
|
perror ("guestfs_create");
|
|
exit (EXIT_FAILURE);
|
|
}
|
|
|
|
time (&start_t);
|
|
|
|
while (time (&t), t - start_t < RUN_TIME) {
|
|
for (i = 0; i < NR_CONCURRENT_THREADS; ++i) {
|
|
r = pthread_create (&threads[i], NULL, start_thread, NULL);
|
|
if (r != 0) {
|
|
fprintf (stderr, "pthread_create: %s\n", strerror (r));
|
|
exit (EXIT_FAILURE);
|
|
}
|
|
}
|
|
|
|
for (i = 0; i < NR_CONCURRENT_THREADS; ++i) {
|
|
r = pthread_join (threads[i], &ret);
|
|
if (r != 0) {
|
|
fprintf (stderr, "pthread_join: %s\n", strerror (r));
|
|
exit (EXIT_FAILURE);
|
|
}
|
|
if (ret != NULL) {
|
|
fprintf (stderr, "thread[%d] failed\n", i);
|
|
exit (EXIT_FAILURE);
|
|
}
|
|
}
|
|
}
|
|
|
|
guestfs_close (g);
|
|
|
|
exit (EXIT_SUCCESS);
|
|
}
|
|
|
|
static void *
|
|
start_thread (void *nullv)
|
|
{
|
|
char *p;
|
|
const char *err;
|
|
int iterations;
|
|
|
|
for (iterations = 0; iterations < 1000; ++iterations) {
|
|
guestfs_set_hv (g, "test");
|
|
p = guestfs_get_hv (g);
|
|
if (!p || STRNEQ (p, "test")) {
|
|
fprintf (stderr, "invalid return from guestfs_get_hv\n");
|
|
pthread_exit ((void *)-1);
|
|
}
|
|
free (p);
|
|
|
|
guestfs_push_error_handler (g, NULL, NULL);
|
|
guestfs_set_hv (g, "test");
|
|
p = guestfs_get_hv (g);
|
|
guestfs_pop_error_handler (g);
|
|
if (!p || STRNEQ (p, "test")) {
|
|
fprintf (stderr, "invalid return from guestfs_get_hv\n");
|
|
pthread_exit ((void *)-1);
|
|
}
|
|
free (p);
|
|
|
|
guestfs_push_error_handler (g, NULL, NULL);
|
|
guestfs_set_program (g, NULL); /* deliberately cause an error */
|
|
guestfs_pop_error_handler (g);
|
|
err = guestfs_last_error (g);
|
|
if (!err || !STRPREFIX (err, "set_program: program: ")) {
|
|
fprintf (stderr, "invalid error message: %s\n", err ? err : "NULL");
|
|
pthread_exit ((void *)-1);
|
|
}
|
|
|
|
guestfs_push_error_handler (g, NULL, NULL);
|
|
guestfs_set_memsize (g, 1); /* deliberately cause an error */
|
|
guestfs_pop_error_handler (g);
|
|
err = guestfs_last_error (g);
|
|
if (!err || strstr (err, "memsize") == NULL) {
|
|
fprintf (stderr, "invalid error message: %s\n", err ? err : "NULL");
|
|
pthread_exit ((void *)-1);
|
|
}
|
|
}
|
|
|
|
pthread_exit (NULL);
|
|
}
|