typedef enum {
SOUP_MESSAGE_IO_STATUS_IDLE,
SOUP_MESSAGE_IO_STATUS_QUEUED,
- SOUP_MESSAGE_IO_STATUS_CONNECTING,
SOUP_MESSAGE_IO_STATUS_RUNNING,
SOUP_MESSAGE_IO_STATUS_FINISHED
} SoupMessageIOStatus;
} SoupMessagePrivate;
#define SOUP_MESSAGE_GET_PRIVATE(o) (G_TYPE_INSTANCE_GET_PRIVATE ((o), SOUP_TYPE_MESSAGE, SoupMessagePrivate))
-#define SOUP_MESSAGE_IS_STARTING(msg) (SOUP_MESSAGE_GET_PRIVATE (msg)->io_status == SOUP_MESSAGE_IO_STATUS_QUEUED || SOUP_MESSAGE_GET_PRIVATE (msg)->io_status == SOUP_MESSAGE_IO_STATUS_CONNECTING)
+#define SOUP_MESSAGE_IS_STARTING(msg) (SOUP_MESSAGE_GET_PRIVATE (msg)->io_status == SOUP_MESSAGE_IO_STATUS_QUEUED)
void soup_message_cleanup_response (SoupMessage *req);
SoupMessageQueueItem *item;
SoupProxyURIResolver *proxy_resolver;
SoupMessage *msg;
- SoupMessageIOStatus cur_io_status = SOUP_MESSAGE_IO_STATUS_CONNECTING;
SoupConnection *conn;
gboolean try_pruning = TRUE, should_prune = FALSE;
if (msg->method == SOUP_METHOD_CONNECT)
continue;
- if (soup_message_get_io_status (msg) != cur_io_status ||
- soup_message_io_in_progress (msg))
+ if (soup_message_io_in_progress (msg))
continue;
if (!item->resolved_proxy_addr) {
if (item)
soup_message_queue_item_unref (item);
- if (cur_io_status == SOUP_MESSAGE_IO_STATUS_CONNECTING) {
- cur_io_status = SOUP_MESSAGE_IO_STATUS_QUEUED;
- goto try_again;
- }
-
if (try_pruning && should_prune) {
/* There is at least one message in the queue that
* could be sent if we pruned an idle connection from