errors: Avoid interleaved errors from parallel threads
[nbdkit/ericb.git] / src / errors.c
blobc1efae6e23300fd93eaf5a04aacfdb2cba741700
1 /* nbdkit
2 * Copyright (C) 2013-2017 Red Hat Inc.
3 * All rights reserved.
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions are
7 * met:
9 * * Redistributions of source code must retain the above copyright
10 * notice, this list of conditions and the following disclaimer.
12 * * Redistributions in binary form must reproduce the above copyright
13 * notice, this list of conditions and the following disclaimer in the
14 * documentation and/or other materials provided with the distribution.
16 * * Neither the name of Red Hat nor the names of its contributors may be
17 * used to endorse or promote products derived from this software without
18 * specific prior written permission.
20 * THIS SOFTWARE IS PROVIDED BY RED HAT AND CONTRIBUTORS ''AS IS'' AND
21 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO,
22 * THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A
23 * PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL RED HAT OR
24 * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
25 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
26 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
27 * USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
28 * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
29 * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
30 * OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
31 * SUCH DAMAGE.
34 #include <config.h>
36 #include <stdio.h>
37 #include <stdlib.h>
38 #include <stdarg.h>
39 #include <string.h>
40 #include <errno.h>
41 #include <assert.h>
42 #include <pthread.h>
44 #include "nbdkit-plugin.h"
45 #include "internal.h"
47 /* Used to group piecemeal message construction into atomic output. */
48 static pthread_mutex_t errors_lock = PTHREAD_MUTEX_INITIALIZER;
50 static void
51 lock (void)
53 int r = pthread_mutex_lock (&errors_lock);
54 assert (!r);
57 static void
58 unlock (void)
60 int r = pthread_mutex_unlock (&errors_lock);
61 assert (!r);
64 /* Called with lock taken. */
65 static void
66 prologue (const char *type)
68 const char *name = threadlocal_get_name ();
69 size_t instance_num = threadlocal_get_instance_num ();
71 fprintf (stderr, "%s: ", program_name);
73 if (name) {
74 fprintf (stderr, "%s", name);
75 if (instance_num > 0)
76 fprintf (stderr, "[%zu]", instance_num);
77 fprintf (stderr, ": ");
80 fprintf (stderr, "%s: ", type);
83 /* Note: preserves the previous value of errno. */
84 void
85 nbdkit_vdebug (const char *fs, va_list args)
87 int err = errno;
89 if (!verbose)
90 return;
92 lock ();
93 prologue ("debug");
95 vfprintf (stderr, fs, args);
97 fprintf (stderr, "\n");
98 unlock ();
100 errno = err;
103 /* Note: preserves the previous value of errno. */
104 void
105 nbdkit_debug (const char *fs, ...)
107 va_list args;
108 int err = errno;
110 if (!verbose)
111 return;
113 lock ();
114 prologue ("debug");
116 va_start (args, fs);
117 vfprintf (stderr, fs, args);
118 va_end (args);
120 fprintf (stderr, "\n");
121 unlock ();
123 errno = err;
126 /* Note: preserves the previous value of errno. */
127 void
128 nbdkit_verror (const char *fs, va_list args)
130 int err = errno;
132 lock ();
133 prologue ("error");
135 vfprintf (stderr, fs, args);
137 fprintf (stderr, "\n");
138 unlock ();
140 errno = err;
143 /* Note: preserves the previous value of errno. */
144 void
145 nbdkit_error (const char *fs, ...)
147 va_list args;
148 int err = errno;
150 lock ();
151 prologue ("error");
153 va_start (args, fs);
154 vfprintf (stderr, fs, args);
155 va_end (args);
157 fprintf (stderr, "\n");
158 unlock ();
160 errno = err;
163 void
164 nbdkit_set_error (int err)
166 threadlocal_set_error (err);