We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2ceec6a commit 7ea3b1cCopy full SHA for 7ea3b1c
src/flb_upstream.c
@@ -187,9 +187,6 @@ static struct flb_upstream_conn *get_conn(struct flb_upstream *u)
187
{
188
struct flb_upstream_conn *conn;
189
190
-#ifdef FLB_HAVE_FLUSH_PTHREADS
191
- pthread_mutex_lock(&u->mutex_queue);
192
-#endif
193
/* Get the first available connection and increase the counter */
194
conn = mk_list_entry_first(&u->av_queue,
195
struct flb_upstream_conn, _head);
@@ -199,10 +196,6 @@ static struct flb_upstream_conn *get_conn(struct flb_upstream *u)
199
196
mk_list_del(&conn->_head);
200
197
mk_list_add(&conn->_head, &u->busy_queue);
201
198
202
203
- pthread_mutex_unlock(&u->mutex_queue);
204
205
-
206
return conn;
207
}
208
0 commit comments