X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fafb-websock.c;h=f9c9dd018653344b1977cb619727479bcd333c0b;hb=7a31f839633c9192c98be1061792b8482f181990;hp=0247aae6948a47a315caaf595092edbe3639c717;hpb=f1b901ed676b2d45ec8e6ae3d6ef2f94d79f9ee6;p=src%2Fapp-framework-binder.git diff --git a/src/afb-websock.c b/src/afb-websock.c index 0247aae6..f9c9dd01 100644 --- a/src/afb-websock.c +++ b/src/afb-websock.c @@ -25,12 +25,11 @@ #include #include -#include "afb-ws-json.h" - #include "afb-method.h" #include "afb-context.h" #include "afb-hreq.h" #include "afb-websock.h" +#include "afb-ws-json1.h" /**************** WebSocket connection upgrade ****************************/ @@ -118,6 +117,7 @@ static const struct protodef *search_proto(const struct protodef *protodefs, con static int check_websocket_upgrade(struct MHD_Connection *con, const struct protodef *protodefs, void *context, void **websock) { + const union MHD_ConnectionInfo *info; struct MHD_Response *response; const char *connection, *upgrade, *key, *version, *protocols; char acceptval[29]; @@ -163,10 +163,14 @@ static int check_websocket_upgrade(struct MHD_Connection *con, const struct prot } /* create the web socket */ - ws = proto->create(MHD_get_connection_info(con, MHD_CONNECTION_INFO_CONNECTION_FD)->connect_fd, - context, - (void*)MHD_resume_connection, - con); + info = MHD_get_connection_info(con, MHD_CONNECTION_INFO_CONNECTION_FD); + if (info == NULL) { + response = MHD_create_response_from_buffer(0, NULL, MHD_RESPMEM_PERSISTENT); + MHD_queue_response(con, MHD_HTTP_INTERNAL_SERVER_ERROR, response); + MHD_destroy_response(response); + return 1; + } + ws = proto->create(info->connect_fd, context, (void*)MHD_resume_connection, con); if (ws == NULL) { response = MHD_create_response_from_buffer(0, NULL, MHD_RESPMEM_PERSISTENT); MHD_queue_response(con, MHD_HTTP_INTERNAL_SERVER_ERROR, response); @@ -189,7 +193,7 @@ static int check_websocket_upgrade(struct MHD_Connection *con, const struct prot } static const struct protodef protodefs[] = { - { "x-afb-ws-json1", (void*)afb_ws_json_create }, + { "x-afb-ws-json1", (void*)afb_ws_json1_create }, { NULL, NULL } };