summaryrefslogtreecommitdiff
path: root/libsoup/soup-session.c
diff options
context:
space:
mode:
Diffstat (limited to 'libsoup/soup-session.c')
-rw-r--r--libsoup/soup-session.c10
1 files changed, 10 insertions, 0 deletions
diff --git a/libsoup/soup-session.c b/libsoup/soup-session.c
index 5ecae857..e6a4c918 100644
--- a/libsoup/soup-session.c
+++ b/libsoup/soup-session.c
@@ -4868,6 +4868,7 @@ soup_session_websocket_connect_async (SoupSession *session,
SoupSessionPrivate *priv = soup_session_get_instance_private (session);
SoupMessageQueueItem *item;
GTask *task;
+ SoupMessageFlags flags;
g_return_if_fail (SOUP_IS_SESSION (session));
g_return_if_fail (priv->use_thread_context);
@@ -4875,6 +4876,15 @@ soup_session_websocket_connect_async (SoupSession *session,
soup_websocket_client_prepare_handshake (msg, origin, protocols);
+ /* When the client is to _Establish a WebSocket Connection_ given a set
+ * of (/host/, /port/, /resource name/, and /secure/ flag), along with a
+ * list of /protocols/ and /extensions/ to be used, and an /origin/ in
+ * the case of web browsers, it MUST open a connection, send an opening
+ * handshake, and read the server's handshake in response.
+ */
+ flags = soup_message_get_flags (msg);
+ soup_message_set_flags (msg, flags | SOUP_MESSAGE_NEW_CONNECTION);
+
task = g_task_new (session, cancellable, callback, user_data);
item = soup_session_append_queue_item (session, msg, TRUE, FALSE,
websocket_connect_async_complete, task);