From 2bf3bc3e10662f1b27af0b2a702b1a8131535cd4 Mon Sep 17 00:00:00 2001
From: Max Kellermann <max@duempel.org>
Date: Thu, 15 Sep 2011 08:18:50 +0200
Subject: input/curl: add assertions on io_thread_inside()
---
src/input/curl_input_plugin.c | 9 +++++++++
1 file changed, 9 insertions(+)
(limited to 'src/input')
diff --git a/src/input/curl_input_plugin.c b/src/input/curl_input_plugin.c
index d06125f94..0aee4a044 100644
--- a/src/input/curl_input_plugin.c
+++ b/src/input/curl_input_plugin.c
@@ -245,6 +245,8 @@ input_curl_fd_events(int fd, fd_set *rfds, fd_set *wfds, fd_set *efds)
static void
curl_update_fds(void)
{
+ assert(io_thread_inside());
+
fd_set rfds, wfds, efds;
FD_ZERO(&rfds);
@@ -305,6 +307,7 @@ curl_update_fds(void)
static gboolean
input_curl_dirty_callback(G_GNUC_UNUSED gpointer data)
{
+ assert(io_thread_inside());
g_static_mutex_lock(&curl.mutex);
assert(curl.dirty_source_id != 0 || curl.requests == NULL);
@@ -420,6 +423,7 @@ input_curl_easy_free_indirect(struct input_curl *c)
static void
input_curl_abort_all_requests(GError *error)
{
+ assert(io_thread_inside());
assert(error != NULL);
while (curl.requests != NULL) {
@@ -443,6 +447,7 @@ input_curl_abort_all_requests(GError *error)
static void
input_curl_request_done(struct input_curl *c, CURLcode result, long status)
{
+ assert(io_thread_inside());
assert(c != NULL);
assert(c->easy == NULL);
assert(c->base.ready);
@@ -482,6 +487,8 @@ input_curl_handle_done(CURL *easy_handle, CURLcode result)
static void
input_curl_info_read(void)
{
+ assert(io_thread_inside());
+
CURLMsg *msg;
int msgs_in_queue;
@@ -500,6 +507,8 @@ input_curl_info_read(void)
static bool
input_curl_perform(void)
{
+ assert(io_thread_inside());
+
CURLMcode mcode;
do {
--
cgit v1.2.3