_ZN3uWS12TemplatedAppILb0EEC2ENS_20SocketContextOptionsE: 217| 5.84k| TemplatedApp(SocketContextOptions options = {}) { 218| 5.84k| httpContext = HttpContext::create(Loop::get(), options); 219| | 220| | /* Register default handler for 404 (can be overridden by user) */ 221| 5.84k| this->any("/*", [](auto *res, auto */*req*/) { 222| 5.84k| res->writeStatus("404 File Not Found"); 223| 5.84k| res->end("

File Not Found

uWebSockets/20 Server"); 224| 5.84k| }); 225| 5.84k| } _ZNK3uWS20SocketContextOptionscv27us_socket_context_options_tEv: 71| 5.84k| operator struct us_socket_context_options_t() const { 72| 5.84k| struct us_socket_context_options_t socket_context_options; 73| 5.84k| memcpy(&socket_context_options, this, sizeof(SocketContextOptions)); 74| 5.84k| return socket_context_options; 75| 5.84k| } _ZN3uWS12TemplatedAppILb0EE3anyENSt3__112basic_stringIcNS2_11char_traitsIcEENS2_9allocatorIcEEEEON5ofats13any_invocableIFvPNS_12HttpResponseILb0EEEPNS_11HttpRequestEEEE: 529| 5.84k| TemplatedApp &&any(std::string pattern, MoveOnlyFunction *, HttpRequest *)> &&handler) { 530| 5.84k| if (httpContext) { ------------------ | Branch (530:13): [True: 5.84k, False: 0] ------------------ 531| 5.84k| httpContext->onHttp("*", pattern, std::move(handler)); 532| 5.84k| } 533| 5.84k| return std::move(*this); 534| 5.84k| } _ZZN3uWS12TemplatedAppILb0EEC1ENS_20SocketContextOptionsEENKUlPT_PT0_E_clINS_12HttpResponseILb0EEENS_11HttpRequestEEEDaS4_S6_: 221| 7.55k| this->any("/*", [](auto *res, auto */*req*/) { 222| 7.55k| res->writeStatus("404 File Not Found"); 223| 7.55k| res->end("

File Not Found

uWebSockets/20 Server"); 224| 7.55k| }); _ZN3uWS12TemplatedAppILb0EED2Ev: 177| 11.6k| ~TemplatedApp() { 178| | /* Let's just put everything here */ 179| 11.6k| if (httpContext) { ------------------ | Branch (179:13): [True: 5.84k, False: 5.84k] ------------------ 180| 5.84k| httpContext->free(); 181| | 182| | /* Free all our webSocketContexts in a type less way */ 183| 11.6k| for (auto &webSocketContextDeleter : webSocketContextDeleters) { ------------------ | Branch (183:48): [True: 11.6k, False: 5.84k] ------------------ 184| 11.6k| webSocketContextDeleter(); 185| 11.6k| } 186| 5.84k| } 187| | 188| | /* Delete TopicTree */ 189| 11.6k| if (topicTree) { ------------------ | Branch (189:13): [True: 5.84k, False: 5.84k] ------------------ 190| 5.84k| delete topicTree; 191| | 192| | /* And unregister loop callbacks */ 193| | /* We must unregister any loop post handler here */ 194| 5.84k| Loop::get()->removePostHandler(topicTree); 195| 5.84k| Loop::get()->removePreHandler(topicTree); 196| 5.84k| } 197| 11.6k| } EpollEchoServer.cpp:_ZN3uWS12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOS1_NSt3__112basic_stringIcNS5_11char_traitsIcEENS5_9allocatorIcEEEEONS1_17WebSocketBehaviorIT_EE: 270| 11.6k| TemplatedApp &&ws(std::string pattern, WebSocketBehavior &&behavior) { 271| | /* Don't compile if alignment rules cannot be satisfied */ 272| 11.6k| static_assert(alignof(UserData) <= LIBUS_EXT_ALIGNMENT, 273| 11.6k| "µWebSockets cannot satisfy UserData alignment requirements. You need to recompile µSockets with LIBUS_EXT_ALIGNMENT adjusted accordingly."); 274| | 275| 11.6k| if (!httpContext) { ------------------ | Branch (275:13): [True: 0, False: 11.6k] ------------------ 276| 0| return std::move(*this); 277| 0| } 278| | 279| | /* Terminate on misleading idleTimeout values */ 280| 11.6k| if (behavior.idleTimeout && behavior.idleTimeout < 8) { ------------------ | Branch (280:13): [True: 11.6k, False: 0] | Branch (280:37): [True: 0, False: 11.6k] ------------------ 281| 0| std::cerr << "Error: idleTimeout must be either 0 or greater than 8!" << std::endl; 282| 0| std::terminate(); 283| 0| } 284| | 285| | /* Maximum idleTimeout is 16 minutes */ 286| 11.6k| if (behavior.idleTimeout > 240 * 4) { ------------------ | Branch (286:13): [True: 0, False: 11.6k] ------------------ 287| 0| std::cerr << "Error: idleTimeout must not be greater than 960 seconds!" << std::endl; 288| 0| std::terminate(); 289| 0| } 290| | 291| | /* Maximum maxLifetime is 4 hours */ 292| 11.6k| if (behavior.maxLifetime > 240) { ------------------ | Branch (292:13): [True: 0, False: 11.6k] ------------------ 293| 0| std::cerr << "Error: maxLifetime must not be greater than 240 minutes!" << std::endl; 294| 0| std::terminate(); 295| 0| } 296| | 297| | /* If we don't have a TopicTree yet, create one now */ 298| 11.6k| if (!topicTree) { ------------------ | Branch (298:13): [True: 5.84k, False: 5.84k] ------------------ 299| | 300| 5.84k| bool needsUncork = false; 301| 5.84k| topicTree = new TopicTree([needsUncork](Subscriber *s, TopicTreeMessage &message, TopicTree::IteratorFlags flags) mutable { 302| | /* Subscriber's user is the socket */ 303| | /* Unfortunately we need to cast is to PerSocketData = int 304| | * since many different WebSocketContexts use the same 305| | * TopicTree now */ 306| 5.84k| auto *ws = (WebSocket *) s->user; 307| | 308| | /* If this is the first message we try and cork */ 309| 5.84k| if (flags & TopicTree::IteratorFlags::FIRST) { 310| 5.84k| if (ws->canCork() && !ws->isCorked()) { 311| 5.84k| ((AsyncSocket *)ws)->cork(); 312| 5.84k| needsUncork = true; 313| 5.84k| } 314| 5.84k| } 315| | 316| | /* If we ever overstep maxBackpresure, exit immediately */ 317| 5.84k| if (WebSocket::SendStatus::DROPPED == ws->send(message.message, (OpCode)message.opCode, message.compress)) { 318| 5.84k| if (needsUncork) { 319| 5.84k| ((AsyncSocket *)ws)->uncork(); 320| 5.84k| needsUncork = false; 321| 5.84k| } 322| | /* Stop draining */ 323| 5.84k| return true; 324| 5.84k| } 325| | 326| | /* If this is the last message we uncork if we are corked */ 327| 5.84k| if (flags & TopicTree::IteratorFlags::LAST) { 328| | /* We should not uncork in all cases? */ 329| 5.84k| if (needsUncork) { 330| 5.84k| ((AsyncSocket *)ws)->uncork(); 331| 5.84k| } 332| 5.84k| } 333| | 334| | /* Success */ 335| 5.84k| return false; 336| 5.84k| }); 337| | 338| | /* And hook it up with the loop */ 339| | /* We empty for both pre and post just to make sure */ 340| 5.84k| Loop::get()->addPostHandler(topicTree, [topicTree = topicTree](Loop */*loop*/) { 341| | /* Commit pub/sub batches every loop iteration */ 342| 5.84k| topicTree->drain(); 343| 5.84k| }); 344| | 345| 5.84k| Loop::get()->addPreHandler(topicTree, [topicTree = topicTree](Loop */*loop*/) { 346| | /* Commit pub/sub batches every loop iteration */ 347| 5.84k| topicTree->drain(); 348| 5.84k| }); 349| 5.84k| } 350| | 351| | /* Every route has its own websocket context with its own behavior and user data type */ 352| 11.6k| auto *webSocketContext = WebSocketContext::create(Loop::get(), (us_socket_context_t *) httpContext, topicTree); 353| | 354| | /* We need to clear this later on */ 355| 11.6k| webSocketContextDeleters.push_back([webSocketContext]() { 356| 11.6k| webSocketContext->free(); 357| 11.6k| }); 358| | 359| | /* We also keep this list for easy closing */ 360| 11.6k| webSocketContexts.push_back((void *)webSocketContext); 361| | 362| | /* Quick fix to disable any compression if set */ 363| |#ifdef UWS_NO_ZLIB 364| | behavior.compression = DISABLED; 365| |#endif 366| | 367| | /* If we are the first one to use compression, initialize it */ 368| 11.6k| if (behavior.compression) { ------------------ | Branch (368:13): [True: 11.1k, False: 574] ------------------ 369| 11.1k| LoopData *loopData = (LoopData *) us_loop_ext(us_socket_context_loop(SSL, webSocketContext->getSocketContext())); 370| | 371| | /* Initialize loop's deflate inflate streams */ 372| 11.1k| if (!loopData->zlibContext) { ------------------ | Branch (372:17): [True: 5.56k, False: 5.56k] ------------------ 373| 5.56k| loopData->zlibContext = new ZlibContext; 374| 5.56k| loopData->inflationStream = new InflationStream(CompressOptions::DEDICATED_DECOMPRESSOR); 375| 5.56k| loopData->deflationStream = new DeflationStream(CompressOptions::DEDICATED_COMPRESSOR); 376| 5.56k| } 377| 11.1k| } 378| | 379| | /* Copy all handlers */ 380| 11.6k| webSocketContext->getExt()->openHandler = std::move(behavior.open); 381| 11.6k| webSocketContext->getExt()->messageHandler = std::move(behavior.message); 382| 11.6k| webSocketContext->getExt()->droppedHandler = std::move(behavior.dropped); 383| 11.6k| webSocketContext->getExt()->drainHandler = std::move(behavior.drain); 384| 11.6k| webSocketContext->getExt()->subscriptionHandler = std::move(behavior.subscription); 385| 11.6k| webSocketContext->getExt()->closeHandler = std::move([closeHandler = std::move(behavior.close)](WebSocket *ws, int code, std::string_view message) mutable { 386| 11.6k| if (closeHandler) { 387| 11.6k| closeHandler(ws, code, message); 388| 11.6k| } 389| | 390| | /* Destruct user data after returning from close handler */ 391| 11.6k| ((UserData *) ws->getUserData())->~UserData(); 392| 11.6k| }); 393| 11.6k| webSocketContext->getExt()->pingHandler = std::move(behavior.ping); 394| 11.6k| webSocketContext->getExt()->pongHandler = std::move(behavior.pong); 395| | 396| | /* Copy settings */ 397| 11.6k| webSocketContext->getExt()->maxPayloadLength = behavior.maxPayloadLength; 398| 11.6k| webSocketContext->getExt()->maxBackpressure = behavior.maxBackpressure; 399| 11.6k| webSocketContext->getExt()->closeOnBackpressureLimit = behavior.closeOnBackpressureLimit; 400| 11.6k| webSocketContext->getExt()->resetIdleTimeoutOnSend = behavior.resetIdleTimeoutOnSend; 401| 11.6k| webSocketContext->getExt()->sendPingsAutomatically = behavior.sendPingsAutomatically; 402| 11.6k| webSocketContext->getExt()->maxLifetime = behavior.maxLifetime; 403| 11.6k| webSocketContext->getExt()->compression = behavior.compression; 404| | 405| | /* Calculate idleTimeoutCompnents */ 406| 11.6k| webSocketContext->getExt()->calculateIdleTimeoutCompnents(behavior.idleTimeout); 407| | 408| 11.6k| httpContext->onHttp("GET", pattern, [webSocketContext, behavior = std::move(behavior)](auto *res, auto *req) mutable { 409| | 410| | /* If we have this header set, it's a websocket */ 411| 11.6k| std::string_view secWebSocketKey = req->getHeader("sec-websocket-key"); 412| 11.6k| if (secWebSocketKey.length() == 24) { 413| | 414| | /* Emit upgrade handler */ 415| 11.6k| if (behavior.upgrade) { 416| | 417| | /* Nasty, ugly Safari 15 hack */ 418| 11.6k| if (hasBrokenCompression(req->getHeader("user-agent"))) { 419| 11.6k| std::string_view secWebSocketExtensions = req->getHeader("sec-websocket-extensions"); 420| 11.6k| memset((void *) secWebSocketExtensions.data(), ' ', secWebSocketExtensions.length()); 421| 11.6k| } 422| | 423| 11.6k| behavior.upgrade(res, req, (struct us_socket_context_t *) webSocketContext); 424| 11.6k| } else { 425| | /* Default handler upgrades to WebSocket */ 426| 11.6k| std::string_view secWebSocketProtocol = req->getHeader("sec-websocket-protocol"); 427| 11.6k| std::string_view secWebSocketExtensions = req->getHeader("sec-websocket-extensions"); 428| | 429| | /* Safari 15 hack */ 430| 11.6k| if (hasBrokenCompression(req->getHeader("user-agent"))) { 431| 11.6k| secWebSocketExtensions = ""; 432| 11.6k| } 433| | 434| 11.6k| res->template upgrade({}, secWebSocketKey, secWebSocketProtocol, secWebSocketExtensions, (struct us_socket_context_t *) webSocketContext); 435| 11.6k| } 436| | 437| | /* We are going to get uncorked by the Http get return */ 438| | 439| | /* We do not need to check for any close or shutdown here as we immediately return from get handler */ 440| | 441| 11.6k| } else { 442| | /* Tell the router that we did not handle this request */ 443| 11.6k| req->setYield(true); 444| 11.6k| } 445| 11.6k| }, true); 446| 11.6k| return std::move(*this); 447| 11.6k| } EpollEchoServer.cpp:_ZZN3uWS12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOS1_NSt3__112basic_stringIcNS5_11char_traitsIcEENS5_9allocatorIcEEEEONS1_17WebSocketBehaviorIT_EEENUlPNS_10SubscriberERNS_16TopicTreeMessageENS_9TopicTreeISI_NS_19TopicTreeBigMessageEE13IteratorFlagsEE_clESH_SJ_SN_: 301| 34.2k| topicTree = new TopicTree([needsUncork](Subscriber *s, TopicTreeMessage &message, TopicTree::IteratorFlags flags) mutable { 302| | /* Subscriber's user is the socket */ 303| | /* Unfortunately we need to cast is to PerSocketData = int 304| | * since many different WebSocketContexts use the same 305| | * TopicTree now */ 306| 34.2k| auto *ws = (WebSocket *) s->user; 307| | 308| | /* If this is the first message we try and cork */ 309| 34.2k| if (flags & TopicTree::IteratorFlags::FIRST) { ------------------ | Branch (309:21): [True: 4.99k, False: 29.2k] ------------------ 310| 4.99k| if (ws->canCork() && !ws->isCorked()) { ------------------ | Branch (310:25): [True: 2.59k, False: 2.39k] | Branch (310:42): [True: 2.59k, False: 0] ------------------ 311| 2.59k| ((AsyncSocket *)ws)->cork(); 312| 2.59k| needsUncork = true; 313| 2.59k| } 314| 4.99k| } 315| | 316| | /* If we ever overstep maxBackpresure, exit immediately */ 317| 34.2k| if (WebSocket::SendStatus::DROPPED == ws->send(message.message, (OpCode)message.opCode, message.compress)) { ------------------ | Branch (317:21): [True: 0, False: 34.2k] ------------------ 318| 0| if (needsUncork) { ------------------ | Branch (318:25): [True: 0, False: 0] ------------------ 319| 0| ((AsyncSocket *)ws)->uncork(); 320| 0| needsUncork = false; 321| 0| } 322| | /* Stop draining */ 323| 0| return true; 324| 0| } 325| | 326| | /* If this is the last message we uncork if we are corked */ 327| 34.2k| if (flags & TopicTree::IteratorFlags::LAST) { ------------------ | Branch (327:21): [True: 4.99k, False: 29.2k] ------------------ 328| | /* We should not uncork in all cases? */ 329| 4.99k| if (needsUncork) { ------------------ | Branch (329:25): [True: 3.75k, False: 1.23k] ------------------ 330| 3.75k| ((AsyncSocket *)ws)->uncork(); 331| 3.75k| } 332| 4.99k| } 333| | 334| | /* Success */ 335| 34.2k| return false; 336| 34.2k| }); EpollEchoServer.cpp:_ZZN3uWS12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOS1_NSt3__112basic_stringIcNS5_11char_traitsIcEENS5_9allocatorIcEEEEONS1_17WebSocketBehaviorIT_EEENKUlPNS_4LoopEE_clESH_: 340| 2.18M| Loop::get()->addPostHandler(topicTree, [topicTree = topicTree](Loop */*loop*/) { 341| | /* Commit pub/sub batches every loop iteration */ 342| 2.18M| topicTree->drain(); 343| 2.18M| }); EpollEchoServer.cpp:_ZZN3uWS12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOS1_NSt3__112basic_stringIcNS5_11char_traitsIcEENS5_9allocatorIcEEEEONS1_17WebSocketBehaviorIT_EEENKUlPNS_4LoopEE0_clESH_: 345| 2.18M| Loop::get()->addPreHandler(topicTree, [topicTree = topicTree](Loop */*loop*/) { 346| | /* Commit pub/sub batches every loop iteration */ 347| 2.18M| topicTree->drain(); 348| 2.18M| }); EpollEchoServer.cpp:_ZZN3uWS12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOS1_NSt3__112basic_stringIcNS5_11char_traitsIcEENS5_9allocatorIcEEEEONS1_17WebSocketBehaviorIT_EEENKUlvE_clEv: 355| 11.6k| webSocketContextDeleters.push_back([webSocketContext]() { 356| 11.6k| webSocketContext->free(); 357| 11.6k| }); EpollEchoServer.cpp:_ZZN3uWS12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOS1_NSt3__112basic_stringIcNS5_11char_traitsIcEENS5_9allocatorIcEEEEONS1_17WebSocketBehaviorIT_EEENUlPNS_9WebSocketILb0ELb1ES3_EEiNS5_17basic_string_viewIcS8_EEE_clESI_iSK_: 385| 164k| webSocketContext->getExt()->closeHandler = std::move([closeHandler = std::move(behavior.close)](WebSocket *ws, int code, std::string_view message) mutable { 386| 164k| if (closeHandler) { ------------------ | Branch (386:17): [True: 164k, False: 0] ------------------ 387| 164k| closeHandler(ws, code, message); 388| 164k| } 389| | 390| | /* Destruct user data after returning from close handler */ 391| 164k| ((UserData *) ws->getUserData())->~UserData(); 392| 164k| }); EpollEchoServer.cpp:_ZZN3uWS12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOS1_NSt3__112basic_stringIcNS5_11char_traitsIcEENS5_9allocatorIcEEEEONS1_17WebSocketBehaviorIT_EEENUlPSD_PT0_E_clINS_12HttpResponseILb0EEENS_11HttpRequestEEEDaSG_SI_: 408| 169k| httpContext->onHttp("GET", pattern, [webSocketContext, behavior = std::move(behavior)](auto *res, auto *req) mutable { 409| | 410| | /* If we have this header set, it's a websocket */ 411| 169k| std::string_view secWebSocketKey = req->getHeader("sec-websocket-key"); 412| 169k| if (secWebSocketKey.length() == 24) { ------------------ | Branch (412:17): [True: 164k, False: 4.79k] ------------------ 413| | 414| | /* Emit upgrade handler */ 415| 164k| if (behavior.upgrade) { ------------------ | Branch (415:21): [True: 0, False: 164k] ------------------ 416| | 417| | /* Nasty, ugly Safari 15 hack */ 418| 0| if (hasBrokenCompression(req->getHeader("user-agent"))) { ------------------ | Branch (418:25): [True: 0, False: 0] ------------------ 419| 0| std::string_view secWebSocketExtensions = req->getHeader("sec-websocket-extensions"); 420| 0| memset((void *) secWebSocketExtensions.data(), ' ', secWebSocketExtensions.length()); 421| 0| } 422| | 423| 0| behavior.upgrade(res, req, (struct us_socket_context_t *) webSocketContext); 424| 164k| } else { 425| | /* Default handler upgrades to WebSocket */ 426| 164k| std::string_view secWebSocketProtocol = req->getHeader("sec-websocket-protocol"); 427| 164k| std::string_view secWebSocketExtensions = req->getHeader("sec-websocket-extensions"); 428| | 429| | /* Safari 15 hack */ 430| 164k| if (hasBrokenCompression(req->getHeader("user-agent"))) { ------------------ | Branch (430:25): [True: 247, False: 164k] ------------------ 431| 247| secWebSocketExtensions = ""; 432| 247| } 433| | 434| 164k| res->template upgrade({}, secWebSocketKey, secWebSocketProtocol, secWebSocketExtensions, (struct us_socket_context_t *) webSocketContext); 435| 164k| } 436| | 437| | /* We are going to get uncorked by the Http get return */ 438| | 439| | /* We do not need to check for any close or shutdown here as we immediately return from get handler */ 440| | 441| 164k| } else { 442| | /* Tell the router that we did not handle this request */ 443| 4.79k| req->setYield(true); 444| 4.79k| } 445| 169k| }, true); _ZN3uWS20hasBrokenCompressionENSt3__117basic_string_viewIcNS0_11char_traitsIcEEEE: 29| 164k| inline bool hasBrokenCompression(std::string_view userAgent) { 30| 164k| size_t posStart = userAgent.find(" Version/15."); 31| 164k| if (posStart == std::string_view::npos) return false; ------------------ | Branch (31:13): [True: 156k, False: 8.08k] ------------------ 32| 8.08k| posStart += 12; 33| | 34| 8.08k| size_t posEnd = userAgent.find(' ', posStart); 35| 8.08k| if (posEnd == std::string_view::npos) return false; ------------------ | Branch (35:13): [True: 771, False: 7.31k] ------------------ 36| | 37| 7.31k| unsigned int minorVersion = 0; 38| 7.31k| auto result = std::from_chars(userAgent.data() + posStart, userAgent.data() + posEnd, minorVersion); 39| 7.31k| if (result.ec != std::errc()) return false; ------------------ | Branch (39:13): [True: 1.15k, False: 6.15k] ------------------ 40| 6.15k| if (result.ptr != userAgent.data() + posEnd) return false; // do not accept trailing chars ------------------ | Branch (40:13): [True: 2.92k, False: 3.23k] ------------------ 41| 3.23k| if (minorVersion > 3) return false; // we target just Safari 15.0 - 15.3 ------------------ | Branch (41:13): [True: 2.32k, False: 908] ------------------ 42| | 43| 908| if (userAgent.find(" Safari/", posEnd) == std::string_view::npos) return false; ------------------ | Branch (43:13): [True: 661, False: 247] ------------------ 44| | 45| 247| return true; 46| 908| } _ZN3uWS12TemplatedAppILb0EE6listenEiON5ofats13any_invocableIFvP18us_listen_socket_tEEE: 555| 5.84k| TemplatedApp &&listen(int port, MoveOnlyFunction &&handler) { 556| 5.84k| handler(httpContext ? httpContext->listen(nullptr, port, 0) : nullptr); ------------------ | Branch (556:17): [True: 5.84k, False: 0] ------------------ 557| 5.84k| return std::move(*this); 558| 5.84k| } _ZN3uWS12TemplatedAppILb0EEC2EOS1_: 202| 5.84k| TemplatedApp(TemplatedApp &&other) { 203| | /* Move HttpContext */ 204| 5.84k| httpContext = other.httpContext; 205| 5.84k| other.httpContext = nullptr; 206| | 207| | /* Move webSocketContextDeleters */ 208| 5.84k| webSocketContextDeleters = std::move(other.webSocketContextDeleters); 209| | 210| 5.84k| webSocketContexts = std::move(other.webSocketContexts); 211| | 212| | /* Move TopicTree */ 213| 5.84k| topicTree = other.topicTree; 214| 5.84k| other.topicTree = nullptr; 215| 5.84k| } _ZN3uWS12TemplatedAppILb0EE3runEv: 590| 5.84k| TemplatedApp &&run() { 591| 5.84k| uWS::run(); 592| 5.84k| return std::move(*this); 593| 5.84k| } _ZN3uWS11AsyncSocketILb0EE4corkEv: 133| 642k| void cork() { 134| | /* Extra check for invalid corking of others */ 135| 642k| if (getLoopData()->corkOffset && getLoopData()->corkedSocket != this) { ------------------ | Branch (135:13): [True: 0, False: 642k] | Branch (135:42): [True: 0, False: 0] ------------------ 136| 0| std::cerr << "Error: Cork buffer must not be acquired without checking canCork!" << std::endl; 137| 0| std::terminate(); 138| 0| } 139| | 140| | /* What if another socket is corked? */ 141| 642k| getLoopData()->corkedSocket = this; 142| 642k| } _ZN3uWS11AsyncSocketILb0EE11getLoopDataEv: 85| 7.16M| LoopData *getLoopData() { 86| 7.16M| return (LoopData *) us_loop_ext(us_socket_context_loop(SSL, us_socket_context(SSL, (us_socket_t *) this))); 87| 7.16M| } _ZN3uWS11AsyncSocketILb0EE6uncorkEPKcib: 327| 643k| std::pair uncork(const char *src = nullptr, int length = 0, bool optionally = false) { 328| 643k| LoopData *loopData = getLoopData(); 329| | 330| 643k| if (loopData->corkedSocket == this) { ------------------ | Branch (330:13): [True: 642k, False: 1.15k] ------------------ 331| 642k| loopData->corkedSocket = nullptr; 332| | 333| 642k| if (loopData->corkOffset) { ------------------ | Branch (333:17): [True: 176k, False: 465k] ------------------ 334| | /* Corked data is already accounted for via its write call */ 335| 176k| auto [written, failed] = write(loopData->corkBuffer, (int) loopData->corkOffset, false, length); 336| 176k| loopData->corkOffset = 0; 337| | 338| 176k| if (failed) { ------------------ | Branch (338:21): [True: 161k, False: 14.9k] ------------------ 339| | /* We do not need to care for buffering here, write does that */ 340| 161k| return {0, true}; 341| 161k| } 342| 176k| } 343| | 344| | /* We should only return with new writes, not things written to cork already */ 345| 480k| return write(src, length, optionally, 0); 346| 642k| } else { 347| | /* We are not even corked! */ 348| 1.15k| return {0, false}; 349| 1.15k| } 350| 643k| } _ZN3uWS11AsyncSocketILb0EE5writeEPKcibi: 236| 4.83M| std::pair write(const char *src, int length, bool optionally = false, int nextLength = 0) { 237| | /* Fake success if closed, simple fix to allow uncork of closed socket to succeed */ 238| 4.83M| if (us_socket_is_closed(SSL, (us_socket_t *) this)) { ------------------ | Branch (238:13): [True: 424k, False: 4.40M] ------------------ 239| 424k| return {length, false}; 240| 424k| } 241| | 242| 4.40M| LoopData *loopData = getLoopData(); 243| 4.40M| AsyncSocketData *asyncSocketData = getAsyncSocketData(); 244| | 245| | /* We are limited if we have a per-socket buffer */ 246| 4.40M| if (asyncSocketData->buffer.length()) { ------------------ | Branch (246:13): [True: 124k, False: 4.28M] ------------------ 247| | /* Write off as much as we can */ 248| 124k| int written = us_socket_write(SSL, (us_socket_t *) this, asyncSocketData->buffer.data(), (int) asyncSocketData->buffer.length(), /*nextLength != 0 | */length); 249| | 250| | /* On failure return, otherwise continue down the function */ 251| 124k| if ((unsigned int) written < asyncSocketData->buffer.length()) { ------------------ | Branch (251:17): [True: 110k, False: 14.3k] ------------------ 252| | 253| | /* Update buffering (todo: we can do better here if we keep track of what happens to this guy later on) */ 254| 110k| asyncSocketData->buffer.erase((unsigned int) written); 255| | 256| 110k| if (optionally) { ------------------ | Branch (256:21): [True: 1.11k, False: 109k] ------------------ 257| | /* Thankfully we can exit early here */ 258| 1.11k| return {0, true}; 259| 109k| } else { 260| | /* This path is horrible and points towards erroneous usage */ 261| 109k| asyncSocketData->buffer.append(src, (unsigned int) length); 262| | 263| 109k| return {length, true}; 264| 109k| } 265| 110k| } 266| | 267| | /* At this point we simply have no buffer and can continue as normal */ 268| 14.3k| asyncSocketData->buffer.clear(); 269| 14.3k| } 270| | 271| 4.29M| if (length) { ------------------ | Branch (271:13): [True: 4.23M, False: 56.9k] ------------------ 272| 4.23M| if (loopData->corkedSocket == this) { ------------------ | Branch (272:17): [True: 4.06M, False: 173k] ------------------ 273| | /* We are corked */ 274| 4.06M| if (LoopData::CORK_BUFFER_SIZE - loopData->corkOffset >= (unsigned int) length) { ------------------ | Branch (274:21): [True: 4.06M, False: 0] ------------------ 275| | /* If the entire chunk fits in cork buffer */ 276| 4.06M| memcpy(loopData->corkBuffer + loopData->corkOffset, src, (unsigned int) length); 277| 4.06M| loopData->corkOffset += (unsigned int) length; 278| | /* Fall through to default return */ 279| 4.06M| } else { 280| | /* Strategy differences between SSL and non-SSL regarding syscall minimizing */ 281| 0| if constexpr (false) { ------------------ | Branch (281:35): [Folded - Ignored] ------------------ 282| | /* Cork up as much as we can */ 283| 0| unsigned int stripped = LoopData::CORK_BUFFER_SIZE - loopData->corkOffset; 284| 0| memcpy(loopData->corkBuffer + loopData->corkOffset, src, stripped); 285| 0| loopData->corkOffset = LoopData::CORK_BUFFER_SIZE; 286| | 287| 0| auto [written, failed] = uncork(src + stripped, length - (int) stripped, optionally); 288| 0| return {written + (int) stripped, failed}; 289| 0| } 290| | 291| | /* For non-SSL we take the penalty of two syscalls */ 292| 0| return uncork(src, length, optionally); 293| 0| } 294| 4.06M| } else { 295| | /* We are not corked */ 296| 173k| int written = us_socket_write(SSL, (us_socket_t *) this, src, length, nextLength != 0); 297| | 298| | /* Did we fail? */ 299| 173k| if (written < length) { ------------------ | Branch (299:21): [True: 162k, False: 10.5k] ------------------ 300| | /* If the write was optional then just bail out */ 301| 162k| if (optionally) { ------------------ | Branch (301:25): [True: 0, False: 162k] ------------------ 302| 0| return {written, true}; 303| 0| } 304| | 305| | /* Fall back to worst possible case (should be very rare for HTTP) */ 306| | /* At least we can reserve room for next chunk if we know it up front */ 307| 162k| if (nextLength) { ------------------ | Branch (307:25): [True: 0, False: 162k] ------------------ 308| 0| asyncSocketData->buffer.reserve(asyncSocketData->buffer.length() + (size_t) (length - written + nextLength)); 309| 0| } 310| | 311| | /* Buffer this chunk */ 312| 162k| asyncSocketData->buffer.append(src + written, (size_t) (length - written)); 313| | 314| | /* Return the failure */ 315| 162k| return {length, true}; 316| 162k| } 317| | /* Fall through to default return */ 318| 173k| } 319| 4.23M| } 320| | 321| | /* Default fall through return */ 322| 4.13M| return {length, false}; 323| 4.29M| } _ZN3uWS11AsyncSocketILb0EE7timeoutEj: 95| 253k| void timeout(unsigned int seconds) { 96| 253k| us_socket_timeout(SSL, (us_socket_t *) this, seconds); 97| 253k| } _ZN3uWS11AsyncSocketILb0EE17getBufferedAmountEv: 193| 203k| unsigned int getBufferedAmount() { 194| | /* We return the actual amount of bytes in backbuffer, including pendingRemoval */ 195| 203k| return (unsigned int) getAsyncSocketData()->buffer.totalLength(); 196| 203k| } _ZN3uWS11AsyncSocketILb0EE8shutdownEv: 100| 2.78k| void shutdown() { 101| 2.78k| us_socket_shutdown(SSL, (us_socket_t *) this); 102| 2.78k| } _ZN3uWS11AsyncSocketILb0EE5closeEv: 117| 90.8k| us_socket_t *close() { 118| 90.8k| return us_socket_close(SSL, (us_socket_t *) this, 0, nullptr); 119| 90.8k| } _ZN3uWS11AsyncSocketILb0EE18getAsyncSocketDataEv: 90| 6.48M| AsyncSocketData *getAsyncSocketData() { 91| 6.48M| return (AsyncSocketData *) us_socket_ext(SSL, (us_socket_t *) this); 92| 6.48M| } _ZN3uWS11AsyncSocketILb0EE8isCorkedEv: 145| 419k| bool isCorked() { 146| 419k| return getLoopData()->corkedSocket == this; 147| 419k| } _ZN3uWS11AsyncSocketILb0EE7canCorkEv: 150| 7.76k| bool canCork() { 151| 7.76k| return getLoopData()->corkedSocket == nullptr; 152| 7.76k| } _ZN3uWS11AsyncSocketILb0EE13getSendBufferEm: 155| 62.5k| std::pair getSendBuffer(size_t size) { 156| | /* First step is to determine if we already have backpressure or not */ 157| 62.5k| LoopData *loopData = getLoopData(); 158| 62.5k| BackPressure &backPressure = getAsyncSocketData()->buffer; 159| 62.5k| size_t existingBackpressure = backPressure.length(); 160| 62.5k| if ((!existingBackpressure) && (isCorked() || canCork()) && (loopData->corkOffset + size < LoopData::CORK_BUFFER_SIZE)) { ------------------ | Branch (160:13): [True: 12.0k, False: 50.4k] | Branch (160:41): [True: 9.32k, False: 2.76k] | Branch (160:55): [True: 1.80k, False: 966] | Branch (160:69): [True: 11.1k, False: 0] ------------------ 161| | /* Cork automatically if we can */ 162| 11.1k| if (isCorked()) { ------------------ | Branch (162:17): [True: 9.32k, False: 1.80k] ------------------ 163| 9.32k| char *sendBuffer = loopData->corkBuffer + loopData->corkOffset; 164| 9.32k| loopData->corkOffset += (unsigned int) size; 165| 9.32k| return {sendBuffer, SendBufferAttribute::NEEDS_NOTHING}; 166| 9.32k| } else { 167| 1.80k| cork(); 168| 1.80k| char *sendBuffer = loopData->corkBuffer + loopData->corkOffset; 169| 1.80k| loopData->corkOffset += (unsigned int) size; 170| 1.80k| return {sendBuffer, SendBufferAttribute::NEEDS_UNCORK}; 171| 1.80k| } 172| 51.4k| } else { 173| | 174| | /* If we are corked and there is already data in the cork buffer, 175| | mark how much is ours and reset it */ 176| 51.4k| unsigned int ourCorkOffset = 0; 177| 51.4k| if (isCorked() && loopData->corkOffset) { ------------------ | Branch (177:17): [True: 26.4k, False: 25.0k] | Branch (177:31): [True: 0, False: 26.4k] ------------------ 178| 0| ourCorkOffset = loopData->corkOffset; 179| 0| loopData->corkOffset = 0; 180| 0| } 181| | 182| | /* Fallback is to use the backpressure as buffer */ 183| 51.4k| backPressure.resize(ourCorkOffset + existingBackpressure + size); 184| | 185| | /* And copy corkbuffer in front */ 186| 51.4k| memcpy((char *) backPressure.data() + existingBackpressure, loopData->corkBuffer, ourCorkOffset); 187| | 188| 51.4k| return {(char *) backPressure.data() + ourCorkOffset + existingBackpressure, SendBufferAttribute::NEEDS_DRAIN}; 189| 51.4k| } 190| 62.5k| } _ZN3uWS11AsyncSocketILb0EE13corkUncheckedEv: 121| 164k| void corkUnchecked() { 122| | /* What if another socket is corked? */ 123| 164k| getLoopData()->corkedSocket = this; 124| 164k| } _ZN3uWS15AsyncSocketDataILb0EEC2Ev: 82| 1.63M| AsyncSocketData() = default; _ZN3uWS12BackPressureC2Ev: 32| 1.63M| BackPressure() = default; _ZN3uWS12BackPressure6lengthEv: 44| 4.71M| size_t length() { 45| 4.71M| return buffer.length() - pendingRemoval; 46| 4.71M| } _ZN3uWS12BackPressure4dataEv: 57| 227k| const char *data() { 58| 227k| return buffer.data() + pendingRemoval; 59| 227k| } _ZN3uWS12BackPressure5eraseEj: 36| 110k| void erase(unsigned int length) { 37| 110k| pendingRemoval += length; 38| | /* Always erase a minimum of 1/32th the current backpressure */ 39| 110k| if (pendingRemoval > (buffer.length() >> 5)) { ------------------ | Branch (39:13): [True: 73.5k, False: 36.8k] ------------------ 40| 73.5k| buffer.erase(0, pendingRemoval); 41| 73.5k| pendingRemoval = 0; 42| 73.5k| } 43| 110k| } _ZN3uWS12BackPressure6appendEPKcm: 33| 272k| void append(const char *data, size_t length) { 34| 272k| buffer.append(data, length); 35| 272k| } _ZN3uWS12BackPressure5clearEv: 47| 14.3k| void clear() { 48| 14.3k| pendingRemoval = 0; 49| 14.3k| buffer.clear(); 50| 14.3k| } _ZN3uWS12BackPressure11totalLengthEv: 64| 203k| size_t totalLength() { 65| 203k| return buffer.length(); 66| 203k| } _ZN3uWS12BackPressure6resizeEm: 54| 51.4k| void resize(size_t length) { 55| 51.4k| buffer.resize(length + pendingRemoval); 56| 51.4k| } _ZN3uWS12BackPressureC2EOS0_: 28| 328k| BackPressure(BackPressure &&other) { 29| 328k| buffer = std::move(other.buffer); 30| 328k| pendingRemoval = other.pendingRemoval; 31| 328k| } _ZN3uWS15AsyncSocketDataILb0EEC2EONS_12BackPressureE: 77| 164k| AsyncSocketData(BackPressure &&backpressure) : buffer(std::move(backpressure)) { 78| | 79| 164k| } _ZN3uWS11BloomFilter5resetEv: 75| 172k| void reset() { 76| 172k| filter.reset(); 77| 172k| } _ZN3uWS11BloomFilter3addENSt3__117basic_string_viewIcNS1_11char_traitsIcEEEE: 64| 509k| void add(std::string_view key) { 65| 509k| if (key.length() >= 2) { ------------------ | Branch (65:13): [True: 389k, False: 119k] ------------------ 66| 389k| ScrambleArea s = getFeatures(key); 67| 389k| s.val = perfectHash(s.val); 68| 389k| filter[s.p[0]] = 1; 69| 389k| filter[s.p[1]] = 1; 70| 389k| filter[s.p[2]] = 1; 71| 389k| filter[s.p[3]] = 1; 72| 389k| } 73| 509k| } _ZN3uWS11BloomFilter11getFeaturesENSt3__117basic_string_viewIcNS1_11char_traitsIcEEEE: 41| 1.91M| ScrambleArea getFeatures(std::string_view key) { 42| 1.91M| ScrambleArea s; 43| 1.91M| s.p[0] = reinterpret_cast(key[0]); 44| 1.91M| s.p[1] = reinterpret_cast(key[key.length() - 1]); 45| 1.91M| s.p[2] = reinterpret_cast(key[key.length() - 2]); 46| 1.91M| s.p[3] = reinterpret_cast(key[key.length() >> 1]); 47| 1.91M| return s; 48| 1.91M| } _ZN3uWS11BloomFilter11perfectHashEj: 32| 1.91M| static inline uint32_t perfectHash(uint32_t features) { 33| 1.91M| return features *= 1843993368; 34| 1.91M| } _ZN3uWS11BloomFilter9mightHaveENSt3__117basic_string_viewIcNS1_11char_traitsIcEEEE: 51| 1.52M| bool mightHave(std::string_view key) { 52| 1.52M| if (key.length() < 2) { ------------------ | Branch (52:13): [True: 0, False: 1.52M] ------------------ 53| 0| return true; 54| 0| } 55| | 56| 1.52M| ScrambleArea s = getFeatures(key); 57| 1.52M| s.val = perfectHash(s.val); 58| 1.52M| return filter[s.p[0]] && ------------------ | Branch (58:16): [True: 682k, False: 844k] ------------------ 59| 1.52M| filter[s.p[1]] && ------------------ | Branch (59:9): [True: 365k, False: 317k] ------------------ 60| 1.52M| filter[s.p[2]] && ------------------ | Branch (60:9): [True: 364k, False: 1.26k] ------------------ 61| 1.52M| filter[s.p[3]]; ------------------ | Branch (61:9): [True: 359k, False: 5.30k] ------------------ 62| 1.52M| } _ZN3uWS11HttpContextILb0EE6createEPNS_4LoopE27us_socket_context_options_t: 394| 5.84k| static HttpContext *create(Loop *loop, us_socket_context_options_t options = {}) { 395| 5.84k| HttpContext *httpContext; 396| | 397| 5.84k| httpContext = (HttpContext *) us_create_socket_context(SSL, (us_loop_t *) loop, sizeof(HttpContextData), options); 398| | 399| 5.84k| if (!httpContext) { ------------------ | Branch (399:13): [True: 0, False: 5.84k] ------------------ 400| 0| return nullptr; 401| 0| } 402| | 403| | /* Init socket context data */ 404| 5.84k| new ((HttpContextData *) us_socket_context_ext(SSL, (us_socket_context_t *) httpContext)) HttpContextData(); 405| 5.84k| return httpContext->init(); 406| 5.84k| } _ZN3uWS11HttpContextILb0EE4initEv: 70| 5.84k| HttpContext *init() { 71| | /* Handle socket connections */ 72| 5.84k| us_socket_context_on_open(SSL, getSocketContext(), [](us_socket_t *s, int /*is_client*/, char */*ip*/, int /*ip_length*/) { 73| | /* Any connected socket should timeout until it has a request */ 74| 5.84k| us_socket_timeout(SSL, s, HTTP_IDLE_TIMEOUT_S); 75| | 76| | /* Init socket ext */ 77| 5.84k| new (us_socket_ext(SSL, s)) HttpResponseData; 78| | 79| | /* Call filter */ 80| 5.84k| HttpContextData *httpContextData = getSocketContextDataS(s); 81| 5.84k| for (auto &f : httpContextData->filterHandlers) { 82| 5.84k| f((HttpResponse *) s, 1); 83| 5.84k| } 84| | 85| 5.84k| return s; 86| 5.84k| }); 87| | 88| | /* Handle socket disconnections */ 89| 5.84k| us_socket_context_on_close(SSL, getSocketContext(), [](us_socket_t *s, int /*code*/, void */*reason*/) { 90| | /* Get socket ext */ 91| 5.84k| HttpResponseData *httpResponseData = (HttpResponseData *) us_socket_ext(SSL, s); 92| | 93| | /* Call filter */ 94| 5.84k| HttpContextData *httpContextData = getSocketContextDataS(s); 95| 5.84k| for (auto &f : httpContextData->filterHandlers) { 96| 5.84k| f((HttpResponse *) s, -1); 97| 5.84k| } 98| | 99| | /* Signal broken HTTP request only if we have a pending request */ 100| 5.84k| if (httpResponseData->onAborted) { 101| 5.84k| httpResponseData->onAborted(); 102| 5.84k| } 103| | 104| | /* Destruct socket ext */ 105| 5.84k| httpResponseData->~HttpResponseData(); 106| | 107| 5.84k| return s; 108| 5.84k| }); 109| | 110| | /* Handle HTTP data streams */ 111| 5.84k| us_socket_context_on_data(SSL, getSocketContext(), [](us_socket_t *s, char *data, int length) { 112| | 113| | // total overhead is about 210k down to 180k 114| | // ~210k req/sec is the original perf with write in data 115| | // ~200k req/sec is with cork and formatting 116| | // ~190k req/sec is with http parsing 117| | // ~180k - 190k req/sec is with varying routing 118| | 119| 5.84k| HttpContextData *httpContextData = getSocketContextDataS(s); 120| | 121| | /* Do not accept any data while in shutdown state */ 122| 5.84k| if (us_socket_is_shut_down(SSL, (us_socket_t *) s)) { 123| 5.84k| return s; 124| 5.84k| } 125| | 126| 5.84k| HttpResponseData *httpResponseData = (HttpResponseData *) us_socket_ext(SSL, s); 127| | 128| | /* Cork this socket */ 129| 5.84k| ((AsyncSocket *) s)->cork(); 130| | 131| | /* Mark that we are inside the parser now */ 132| 5.84k| httpContextData->isParsingHttp = true; 133| | 134| | // clients need to know the cursor after http parse, not servers! 135| | // how far did we read then? we need to know to continue with websocket parsing data? or? 136| | 137| 5.84k| void *proxyParser = nullptr; 138| |#ifdef UWS_WITH_PROXY 139| | proxyParser = &httpResponseData->proxyParser; 140| |#endif 141| | 142| | /* The return value is entirely up to us to interpret. The HttpParser only care for whether the returned value is DIFFERENT or not from passed user */ 143| 5.84k| auto [err, returnedSocket] = httpResponseData->consumePostPadded(data, (unsigned int) length, s, proxyParser, [httpContextData](void *s, HttpRequest *httpRequest) -> void * { 144| | /* For every request we reset the timeout and hang until user makes action */ 145| | /* Warning: if we are in shutdown state, resetting the timer is a security issue! */ 146| 5.84k| us_socket_timeout(SSL, (us_socket_t *) s, 0); 147| | 148| | /* Reset httpResponse */ 149| 5.84k| HttpResponseData *httpResponseData = (HttpResponseData *) us_socket_ext(SSL, (us_socket_t *) s); 150| 5.84k| httpResponseData->offset = 0; 151| | 152| | /* Are we not ready for another request yet? Terminate the connection. */ 153| 5.84k| if (httpResponseData->state & HttpResponseData::HTTP_RESPONSE_PENDING) { 154| 5.84k| us_socket_close(SSL, (us_socket_t *) s, 0, nullptr); 155| 5.84k| return nullptr; 156| 5.84k| } 157| | 158| | /* Mark pending request and emit it */ 159| 5.84k| httpResponseData->state = HttpResponseData::HTTP_RESPONSE_PENDING; 160| | 161| | /* Mark this response as connectionClose if ancient or connection: close */ 162| 5.84k| if (httpRequest->isAncient() || httpRequest->getHeader("connection").length() == 5) { 163| 5.84k| httpResponseData->state |= HttpResponseData::HTTP_CONNECTION_CLOSE; 164| 5.84k| } 165| | 166| | /* Select the router based on SNI (only possible for SSL) */ 167| 5.84k| auto *selectedRouter = &httpContextData->router; 168| 5.84k| if constexpr (SSL) { 169| 5.84k| void *domainRouter = us_socket_server_name_userdata(SSL, (struct us_socket_t *) s); 170| 5.84k| if (domainRouter) { 171| 5.84k| selectedRouter = (decltype(selectedRouter)) domainRouter; 172| 5.84k| } 173| 5.84k| } 174| | 175| | /* Route the method and URL */ 176| 5.84k| selectedRouter->getUserData() = {(HttpResponse *) s, httpRequest}; 177| 5.84k| if (!selectedRouter->route(httpRequest->getCaseSensitiveMethod(), httpRequest->getUrl())) { 178| | /* We have to force close this socket as we have no handler for it */ 179| 5.84k| us_socket_close(SSL, (us_socket_t *) s, 0, nullptr); 180| 5.84k| return nullptr; 181| 5.84k| } 182| | 183| | /* First of all we need to check if this socket was deleted due to upgrade */ 184| 5.84k| if (httpContextData->upgradedWebSocket) { 185| | /* We differ between closed and upgraded below */ 186| 5.84k| return nullptr; 187| 5.84k| } 188| | 189| | /* Was the socket closed? */ 190| 5.84k| if (us_socket_is_closed(SSL, (struct us_socket_t *) s)) { 191| 5.84k| return nullptr; 192| 5.84k| } 193| | 194| | /* We absolutely have to terminate parsing if shutdown */ 195| 5.84k| if (us_socket_is_shut_down(SSL, (us_socket_t *) s)) { 196| 5.84k| return nullptr; 197| 5.84k| } 198| | 199| | /* Returning from a request handler without responding or attaching an onAborted handler is ill-use */ 200| 5.84k| if (!((HttpResponse *) s)->hasResponded() && !httpResponseData->onAborted) { 201| | /* Throw exception here? */ 202| 5.84k| std::cerr << "Error: Returning from a request handler without responding or attaching an abort handler is forbidden!" << std::endl; 203| 5.84k| std::terminate(); 204| 5.84k| } 205| | 206| | /* If we have not responded and we have a data handler, we need to timeout to enfore client sending the data */ 207| 5.84k| if (!((HttpResponse *) s)->hasResponded() && httpResponseData->inStream) { 208| 5.84k| us_socket_timeout(SSL, (us_socket_t *) s, HTTP_IDLE_TIMEOUT_S); 209| 5.84k| } 210| | 211| | /* Continue parsing */ 212| 5.84k| return s; 213| | 214| 5.84k| }, [httpResponseData](void *user, std::string_view data, bool fin) -> void * { 215| | /* We always get an empty chunk even if there is no data */ 216| 5.84k| if (httpResponseData->inStream) { 217| | 218| | /* Todo: can this handle timeout for non-post as well? */ 219| 5.84k| if (fin) { 220| | /* If we just got the last chunk (or empty chunk), disable timeout */ 221| 5.84k| us_socket_timeout(SSL, (struct us_socket_t *) user, 0); 222| 5.84k| } else { 223| | /* We still have some more data coming in later, so reset timeout */ 224| | /* Only reset timeout if we got enough bytes (16kb/sec) since last time we reset here */ 225| 5.84k| httpResponseData->received_bytes_per_timeout += (unsigned int) data.length(); 226| 5.84k| if (httpResponseData->received_bytes_per_timeout >= HTTP_RECEIVE_THROUGHPUT_BYTES * HTTP_IDLE_TIMEOUT_S) { 227| 5.84k| us_socket_timeout(SSL, (struct us_socket_t *) user, HTTP_IDLE_TIMEOUT_S); 228| 5.84k| httpResponseData->received_bytes_per_timeout = 0; 229| 5.84k| } 230| 5.84k| } 231| | 232| | /* We might respond in the handler, so do not change timeout after this */ 233| 5.84k| httpResponseData->inStream(data, fin); 234| | 235| | /* Was the socket closed? */ 236| 5.84k| if (us_socket_is_closed(SSL, (struct us_socket_t *) user)) { 237| 5.84k| return nullptr; 238| 5.84k| } 239| | 240| | /* We absolutely have to terminate parsing if shutdown */ 241| 5.84k| if (us_socket_is_shut_down(SSL, (us_socket_t *) user)) { 242| 5.84k| return nullptr; 243| 5.84k| } 244| | 245| | /* If we were given the last data chunk, reset data handler to ensure following 246| | * requests on the same socket won't trigger any previously registered behavior */ 247| 5.84k| if (fin) { 248| 5.84k| httpResponseData->inStream = nullptr; 249| 5.84k| } 250| 5.84k| } 251| 5.84k| return user; 252| 5.84k| }); 253| | 254| | /* Mark that we are no longer parsing Http */ 255| 5.84k| httpContextData->isParsingHttp = false; 256| | 257| | /* If we got fullptr that means the parser wants us to close the socket from error (same as calling the errorHandler) */ 258| 5.84k| if (returnedSocket == FULLPTR) { 259| | /* For errors, we only deliver them "at most once". We don't care if they get halfways delivered or not. */ 260| 5.84k| us_socket_write(SSL, s, httpErrorResponses[err].data(), (int) httpErrorResponses[err].length(), false); 261| 5.84k| us_socket_shutdown(SSL, s); 262| | /* Close any socket on HTTP errors */ 263| 5.84k| us_socket_close(SSL, s, 0, nullptr); 264| | /* This just makes the following code act as if the socket was closed from error inside the parser. */ 265| 5.84k| returnedSocket = nullptr; 266| 5.84k| } 267| | 268| | /* We need to uncork in all cases, except for nullptr (closed socket, or upgraded socket) */ 269| 5.84k| if (returnedSocket != nullptr) { 270| | /* Timeout on uncork failure */ 271| 5.84k| auto [written, failed] = ((AsyncSocket *) returnedSocket)->uncork(); 272| 5.84k| if (failed) { 273| | /* All Http sockets timeout by this, and this behavior match the one in HttpResponse::cork */ 274| | /* Warning: both HTTP_IDLE_TIMEOUT_S and HTTP_TIMEOUT_S are 10 seconds and both are used the same */ 275| 5.84k| ((AsyncSocket *) s)->timeout(HTTP_IDLE_TIMEOUT_S); 276| 5.84k| } 277| | 278| | /* We need to check if we should close this socket here now */ 279| 5.84k| if (httpResponseData->state & HttpResponseData::HTTP_CONNECTION_CLOSE) { 280| 5.84k| if ((httpResponseData->state & HttpResponseData::HTTP_RESPONSE_PENDING) == 0) { 281| 5.84k| if (((AsyncSocket *) s)->getBufferedAmount() == 0) { 282| 5.84k| ((AsyncSocket *) s)->shutdown(); 283| | /* We need to force close after sending FIN since we want to hinder 284| | * clients from keeping to send their huge data */ 285| 5.84k| ((AsyncSocket *) s)->close(); 286| 5.84k| } 287| 5.84k| } 288| 5.84k| } 289| | 290| 5.84k| return (us_socket_t *) returnedSocket; 291| 5.84k| } 292| | 293| | /* If we upgraded, check here (differ between nullptr close and nullptr upgrade) */ 294| 5.84k| if (httpContextData->upgradedWebSocket) { 295| | /* This path is only for upgraded websockets */ 296| 5.84k| AsyncSocket *asyncSocket = (AsyncSocket *) httpContextData->upgradedWebSocket; 297| | 298| | /* Uncork here as well (note: what if we failed to uncork and we then pub/sub before we even upgraded?) */ 299| 5.84k| auto [written, failed] = asyncSocket->uncork(); 300| | 301| | /* If we succeeded in uncorking, check if we have sent WebSocket FIN */ 302| 5.84k| if (!failed) { 303| 5.84k| WebSocketData *webSocketData = (WebSocketData *) asyncSocket->getAsyncSocketData(); 304| 5.84k| if (webSocketData->isShuttingDown) { 305| | /* In that case, also send TCP FIN (this is similar to what we have in ws drain handler) */ 306| 5.84k| asyncSocket->shutdown(); 307| 5.84k| } 308| 5.84k| } 309| | 310| | /* Reset upgradedWebSocket before we return */ 311| 5.84k| httpContextData->upgradedWebSocket = nullptr; 312| | 313| | /* Return the new upgraded websocket */ 314| 5.84k| return (us_socket_t *) asyncSocket; 315| 5.84k| } 316| | 317| | /* It is okay to uncork a closed socket and we need to */ 318| 5.84k| ((AsyncSocket *) s)->uncork(); 319| | 320| | /* We cannot return nullptr to the underlying stack in any case */ 321| 5.84k| return s; 322| 5.84k| }); 323| | 324| | /* Handle HTTP write out (note: SSL_read may trigger this spuriously, the app need to handle spurious calls) */ 325| 5.84k| us_socket_context_on_writable(SSL, getSocketContext(), [](us_socket_t *s) { 326| | 327| 5.84k| AsyncSocket *asyncSocket = (AsyncSocket *) s; 328| 5.84k| HttpResponseData *httpResponseData = (HttpResponseData *) asyncSocket->getAsyncSocketData(); 329| | 330| | /* Ask the developer to write data and return success (true) or failure (false), OR skip sending anything and return success (true). */ 331| 5.84k| if (httpResponseData->onWritable) { 332| | /* We are now writable, so hang timeout again, the user does not have to do anything so we should hang until end or tryEnd rearms timeout */ 333| 5.84k| us_socket_timeout(SSL, s, 0); 334| | 335| | /* We expect the developer to return whether or not write was successful (true). 336| | * If write was never called, the developer should still return true so that we may drain. */ 337| 5.84k| bool success = httpResponseData->callOnWritable(httpResponseData->offset); 338| | 339| | /* The developer indicated that their onWritable failed. */ 340| 5.84k| if (!success) { 341| | /* Skip testing if we can drain anything since that might perform an extra syscall */ 342| 5.84k| return s; 343| 5.84k| } 344| | 345| | /* We don't want to fall through since we don't want to mess with timeout. 346| | * It makes little sense to drain any backpressure when the user has registered onWritable. */ 347| 5.84k| return s; 348| 5.84k| } 349| | 350| | /* Drain any socket buffer, this might empty our backpressure and thus finish the request */ 351| 5.84k| /*auto [written, failed] = */asyncSocket->write(nullptr, 0, true, 0); 352| | 353| | /* Should we close this connection after a response - and is this response really done? */ 354| 5.84k| if (httpResponseData->state & HttpResponseData::HTTP_CONNECTION_CLOSE) { 355| 5.84k| if ((httpResponseData->state & HttpResponseData::HTTP_RESPONSE_PENDING) == 0) { 356| 5.84k| if (asyncSocket->getBufferedAmount() == 0) { 357| 5.84k| asyncSocket->shutdown(); 358| | /* We need to force close after sending FIN since we want to hinder 359| | * clients from keeping to send their huge data */ 360| 5.84k| asyncSocket->close(); 361| 5.84k| } 362| 5.84k| } 363| 5.84k| } 364| | 365| | /* Expect another writable event, or another request within the timeout */ 366| 5.84k| asyncSocket->timeout(HTTP_IDLE_TIMEOUT_S); 367| | 368| 5.84k| return s; 369| 5.84k| }); 370| | 371| | /* Handle FIN, HTTP does not support half-closed sockets, so simply close */ 372| 5.84k| us_socket_context_on_end(SSL, getSocketContext(), [](us_socket_t *s) { 373| | 374| | /* We do not care for half closed sockets */ 375| 5.84k| AsyncSocket *asyncSocket = (AsyncSocket *) s; 376| 5.84k| return asyncSocket->close(); 377| | 378| 5.84k| }); 379| | 380| | /* Handle socket timeouts, simply close them so to not confuse client with FIN */ 381| 5.84k| us_socket_context_on_timeout(SSL, getSocketContext(), [](us_socket_t *s) { 382| | 383| | /* Force close rather than gracefully shutdown and risk confusing the client with a complete download */ 384| 5.84k| AsyncSocket *asyncSocket = (AsyncSocket *) s; 385| 5.84k| return asyncSocket->close(); 386| | 387| 5.84k| }); 388| | 389| 5.84k| return this; 390| 5.84k| } _ZN3uWS11HttpContextILb0EE16getSocketContextEv: 53| 234k| us_socket_context_t *getSocketContext() { 54| 234k| return (us_socket_context_t *) this; 55| 234k| } _ZZN3uWS11HttpContextILb0EE4initEvENKUlP11us_socket_tiPciE_clES3_iS4_i: 72| 1.63M| us_socket_context_on_open(SSL, getSocketContext(), [](us_socket_t *s, int /*is_client*/, char */*ip*/, int /*ip_length*/) { 73| | /* Any connected socket should timeout until it has a request */ 74| 1.63M| us_socket_timeout(SSL, s, HTTP_IDLE_TIMEOUT_S); 75| | 76| | /* Init socket ext */ 77| 1.63M| new (us_socket_ext(SSL, s)) HttpResponseData; 78| | 79| | /* Call filter */ 80| 1.63M| HttpContextData *httpContextData = getSocketContextDataS(s); 81| 1.63M| for (auto &f : httpContextData->filterHandlers) { ------------------ | Branch (81:26): [True: 0, False: 1.63M] ------------------ 82| 0| f((HttpResponse *) s, 1); 83| 0| } 84| | 85| 1.63M| return s; 86| 1.63M| }); _ZN3uWS11HttpContextILb0EE21getSocketContextDataSEP11us_socket_t: 65| 3.69M| static HttpContextData *getSocketContextDataS(us_socket_t *s) { 66| 3.69M| return (HttpContextData *) us_socket_context_ext(SSL, getSocketContext(s)); 67| 3.69M| } _ZN3uWS11HttpContextILb0EE16getSocketContextEP11us_socket_t: 57| 3.69M| static us_socket_context_t *getSocketContext(us_socket_t *s) { 58| 3.69M| return (us_socket_context_t *) us_socket_context(SSL, s); 59| 3.69M| } _ZZN3uWS11HttpContextILb0EE4initEvENKUlP11us_socket_tiPvE_clES3_iS4_: 89| 1.46M| us_socket_context_on_close(SSL, getSocketContext(), [](us_socket_t *s, int /*code*/, void */*reason*/) { 90| | /* Get socket ext */ 91| 1.46M| HttpResponseData *httpResponseData = (HttpResponseData *) us_socket_ext(SSL, s); 92| | 93| | /* Call filter */ 94| 1.46M| HttpContextData *httpContextData = getSocketContextDataS(s); 95| 1.46M| for (auto &f : httpContextData->filterHandlers) { ------------------ | Branch (95:26): [True: 0, False: 1.46M] ------------------ 96| 0| f((HttpResponse *) s, -1); 97| 0| } 98| | 99| | /* Signal broken HTTP request only if we have a pending request */ 100| 1.46M| if (httpResponseData->onAborted) { ------------------ | Branch (100:17): [True: 0, False: 1.46M] ------------------ 101| 0| httpResponseData->onAborted(); 102| 0| } 103| | 104| | /* Destruct socket ext */ 105| 1.46M| httpResponseData->~HttpResponseData(); 106| | 107| 1.46M| return s; 108| 1.46M| }); _ZZN3uWS11HttpContextILb0EE4initEvENKUlP11us_socket_tPciE_clES3_S4_i: 111| 592k| us_socket_context_on_data(SSL, getSocketContext(), [](us_socket_t *s, char *data, int length) { 112| | 113| | // total overhead is about 210k down to 180k 114| | // ~210k req/sec is the original perf with write in data 115| | // ~200k req/sec is with cork and formatting 116| | // ~190k req/sec is with http parsing 117| | // ~180k - 190k req/sec is with varying routing 118| | 119| 592k| HttpContextData *httpContextData = getSocketContextDataS(s); 120| | 121| | /* Do not accept any data while in shutdown state */ 122| 592k| if (us_socket_is_shut_down(SSL, (us_socket_t *) s)) { ------------------ | Branch (122:17): [True: 0, False: 592k] ------------------ 123| 0| return s; 124| 0| } 125| | 126| 592k| HttpResponseData *httpResponseData = (HttpResponseData *) us_socket_ext(SSL, s); 127| | 128| | /* Cork this socket */ 129| 592k| ((AsyncSocket *) s)->cork(); 130| | 131| | /* Mark that we are inside the parser now */ 132| 592k| httpContextData->isParsingHttp = true; 133| | 134| | // clients need to know the cursor after http parse, not servers! 135| | // how far did we read then? we need to know to continue with websocket parsing data? or? 136| | 137| 592k| void *proxyParser = nullptr; 138| |#ifdef UWS_WITH_PROXY 139| | proxyParser = &httpResponseData->proxyParser; 140| |#endif 141| | 142| | /* The return value is entirely up to us to interpret. The HttpParser only care for whether the returned value is DIFFERENT or not from passed user */ 143| 592k| auto [err, returnedSocket] = httpResponseData->consumePostPadded(data, (unsigned int) length, s, proxyParser, [httpContextData](void *s, HttpRequest *httpRequest) -> void * { 144| | /* For every request we reset the timeout and hang until user makes action */ 145| | /* Warning: if we are in shutdown state, resetting the timer is a security issue! */ 146| 592k| us_socket_timeout(SSL, (us_socket_t *) s, 0); 147| | 148| | /* Reset httpResponse */ 149| 592k| HttpResponseData *httpResponseData = (HttpResponseData *) us_socket_ext(SSL, (us_socket_t *) s); 150| 592k| httpResponseData->offset = 0; 151| | 152| | /* Are we not ready for another request yet? Terminate the connection. */ 153| 592k| if (httpResponseData->state & HttpResponseData::HTTP_RESPONSE_PENDING) { 154| 592k| us_socket_close(SSL, (us_socket_t *) s, 0, nullptr); 155| 592k| return nullptr; 156| 592k| } 157| | 158| | /* Mark pending request and emit it */ 159| 592k| httpResponseData->state = HttpResponseData::HTTP_RESPONSE_PENDING; 160| | 161| | /* Mark this response as connectionClose if ancient or connection: close */ 162| 592k| if (httpRequest->isAncient() || httpRequest->getHeader("connection").length() == 5) { 163| 592k| httpResponseData->state |= HttpResponseData::HTTP_CONNECTION_CLOSE; 164| 592k| } 165| | 166| | /* Select the router based on SNI (only possible for SSL) */ 167| 592k| auto *selectedRouter = &httpContextData->router; 168| 592k| if constexpr (SSL) { 169| 592k| void *domainRouter = us_socket_server_name_userdata(SSL, (struct us_socket_t *) s); 170| 592k| if (domainRouter) { 171| 592k| selectedRouter = (decltype(selectedRouter)) domainRouter; 172| 592k| } 173| 592k| } 174| | 175| | /* Route the method and URL */ 176| 592k| selectedRouter->getUserData() = {(HttpResponse *) s, httpRequest}; 177| 592k| if (!selectedRouter->route(httpRequest->getCaseSensitiveMethod(), httpRequest->getUrl())) { 178| | /* We have to force close this socket as we have no handler for it */ 179| 592k| us_socket_close(SSL, (us_socket_t *) s, 0, nullptr); 180| 592k| return nullptr; 181| 592k| } 182| | 183| | /* First of all we need to check if this socket was deleted due to upgrade */ 184| 592k| if (httpContextData->upgradedWebSocket) { 185| | /* We differ between closed and upgraded below */ 186| 592k| return nullptr; 187| 592k| } 188| | 189| | /* Was the socket closed? */ 190| 592k| if (us_socket_is_closed(SSL, (struct us_socket_t *) s)) { 191| 592k| return nullptr; 192| 592k| } 193| | 194| | /* We absolutely have to terminate parsing if shutdown */ 195| 592k| if (us_socket_is_shut_down(SSL, (us_socket_t *) s)) { 196| 592k| return nullptr; 197| 592k| } 198| | 199| | /* Returning from a request handler without responding or attaching an onAborted handler is ill-use */ 200| 592k| if (!((HttpResponse *) s)->hasResponded() && !httpResponseData->onAborted) { 201| | /* Throw exception here? */ 202| 592k| std::cerr << "Error: Returning from a request handler without responding or attaching an abort handler is forbidden!" << std::endl; 203| 592k| std::terminate(); 204| 592k| } 205| | 206| | /* If we have not responded and we have a data handler, we need to timeout to enfore client sending the data */ 207| 592k| if (!((HttpResponse *) s)->hasResponded() && httpResponseData->inStream) { 208| 592k| us_socket_timeout(SSL, (us_socket_t *) s, HTTP_IDLE_TIMEOUT_S); 209| 592k| } 210| | 211| | /* Continue parsing */ 212| 592k| return s; 213| | 214| 592k| }, [httpResponseData](void *user, std::string_view data, bool fin) -> void * { 215| | /* We always get an empty chunk even if there is no data */ 216| 592k| if (httpResponseData->inStream) { 217| | 218| | /* Todo: can this handle timeout for non-post as well? */ 219| 592k| if (fin) { 220| | /* If we just got the last chunk (or empty chunk), disable timeout */ 221| 592k| us_socket_timeout(SSL, (struct us_socket_t *) user, 0); 222| 592k| } else { 223| | /* We still have some more data coming in later, so reset timeout */ 224| | /* Only reset timeout if we got enough bytes (16kb/sec) since last time we reset here */ 225| 592k| httpResponseData->received_bytes_per_timeout += (unsigned int) data.length(); 226| 592k| if (httpResponseData->received_bytes_per_timeout >= HTTP_RECEIVE_THROUGHPUT_BYTES * HTTP_IDLE_TIMEOUT_S) { 227| 592k| us_socket_timeout(SSL, (struct us_socket_t *) user, HTTP_IDLE_TIMEOUT_S); 228| 592k| httpResponseData->received_bytes_per_timeout = 0; 229| 592k| } 230| 592k| } 231| | 232| | /* We might respond in the handler, so do not change timeout after this */ 233| 592k| httpResponseData->inStream(data, fin); 234| | 235| | /* Was the socket closed? */ 236| 592k| if (us_socket_is_closed(SSL, (struct us_socket_t *) user)) { 237| 592k| return nullptr; 238| 592k| } 239| | 240| | /* We absolutely have to terminate parsing if shutdown */ 241| 592k| if (us_socket_is_shut_down(SSL, (us_socket_t *) user)) { 242| 592k| return nullptr; 243| 592k| } 244| | 245| | /* If we were given the last data chunk, reset data handler to ensure following 246| | * requests on the same socket won't trigger any previously registered behavior */ 247| 592k| if (fin) { 248| 592k| httpResponseData->inStream = nullptr; 249| 592k| } 250| 592k| } 251| 592k| return user; 252| 592k| }); 253| | 254| | /* Mark that we are no longer parsing Http */ 255| 592k| httpContextData->isParsingHttp = false; 256| | 257| | /* If we got fullptr that means the parser wants us to close the socket from error (same as calling the errorHandler) */ 258| 592k| if (returnedSocket == FULLPTR) { ------------------ | Branch (258:17): [True: 398k, False: 194k] ------------------ 259| | /* For errors, we only deliver them "at most once". We don't care if they get halfways delivered or not. */ 260| 398k| us_socket_write(SSL, s, httpErrorResponses[err].data(), (int) httpErrorResponses[err].length(), false); 261| 398k| us_socket_shutdown(SSL, s); 262| | /* Close any socket on HTTP errors */ 263| 398k| us_socket_close(SSL, s, 0, nullptr); 264| | /* This just makes the following code act as if the socket was closed from error inside the parser. */ 265| 398k| returnedSocket = nullptr; 266| 398k| } 267| | 268| | /* We need to uncork in all cases, except for nullptr (closed socket, or upgraded socket) */ 269| 592k| if (returnedSocket != nullptr) { ------------------ | Branch (269:17): [True: 29.8k, False: 562k] ------------------ 270| | /* Timeout on uncork failure */ 271| 29.8k| auto [written, failed] = ((AsyncSocket *) returnedSocket)->uncork(); 272| 29.8k| if (failed) { ------------------ | Branch (272:21): [True: 2.89k, False: 26.9k] ------------------ 273| | /* All Http sockets timeout by this, and this behavior match the one in HttpResponse::cork */ 274| | /* Warning: both HTTP_IDLE_TIMEOUT_S and HTTP_TIMEOUT_S are 10 seconds and both are used the same */ 275| 2.89k| ((AsyncSocket *) s)->timeout(HTTP_IDLE_TIMEOUT_S); 276| 2.89k| } 277| | 278| | /* We need to check if we should close this socket here now */ 279| 29.8k| if (httpResponseData->state & HttpResponseData::HTTP_CONNECTION_CLOSE) { ------------------ | Branch (279:21): [True: 1.00k, False: 28.8k] ------------------ 280| 1.00k| if ((httpResponseData->state & HttpResponseData::HTTP_RESPONSE_PENDING) == 0) { ------------------ | Branch (280:25): [True: 1.00k, False: 0] ------------------ 281| 1.00k| if (((AsyncSocket *) s)->getBufferedAmount() == 0) { ------------------ | Branch (281:29): [True: 341, False: 662] ------------------ 282| 341| ((AsyncSocket *) s)->shutdown(); 283| | /* We need to force close after sending FIN since we want to hinder 284| | * clients from keeping to send their huge data */ 285| 341| ((AsyncSocket *) s)->close(); 286| 341| } 287| 1.00k| } 288| 1.00k| } 289| | 290| 29.8k| return (us_socket_t *) returnedSocket; 291| 29.8k| } 292| | 293| | /* If we upgraded, check here (differ between nullptr close and nullptr upgrade) */ 294| 562k| if (httpContextData->upgradedWebSocket) { ------------------ | Branch (294:17): [True: 164k, False: 398k] ------------------ 295| | /* This path is only for upgraded websockets */ 296| 164k| AsyncSocket *asyncSocket = (AsyncSocket *) httpContextData->upgradedWebSocket; 297| | 298| | /* Uncork here as well (note: what if we failed to uncork and we then pub/sub before we even upgraded?) */ 299| 164k| auto [written, failed] = asyncSocket->uncork(); 300| | 301| | /* If we succeeded in uncorking, check if we have sent WebSocket FIN */ 302| 164k| if (!failed) { ------------------ | Branch (302:21): [True: 8.07k, False: 156k] ------------------ 303| 8.07k| WebSocketData *webSocketData = (WebSocketData *) asyncSocket->getAsyncSocketData(); 304| 8.07k| if (webSocketData->isShuttingDown) { ------------------ | Branch (304:25): [True: 0, False: 8.07k] ------------------ 305| | /* In that case, also send TCP FIN (this is similar to what we have in ws drain handler) */ 306| 0| asyncSocket->shutdown(); 307| 0| } 308| 8.07k| } 309| | 310| | /* Reset upgradedWebSocket before we return */ 311| 164k| httpContextData->upgradedWebSocket = nullptr; 312| | 313| | /* Return the new upgraded websocket */ 314| 164k| return (us_socket_t *) asyncSocket; 315| 164k| } 316| | 317| | /* It is okay to uncork a closed socket and we need to */ 318| 398k| ((AsyncSocket *) s)->uncork(); 319| | 320| | /* We cannot return nullptr to the underlying stack in any case */ 321| 398k| return s; 322| 562k| }); _ZZZN3uWS11HttpContextILb0EE4initEvENKUlP11us_socket_tPciE_clES3_S4_iENKUlPvPNS_11HttpRequestEE_clES6_S8_: 143| 171k| auto [err, returnedSocket] = httpResponseData->consumePostPadded(data, (unsigned int) length, s, proxyParser, [httpContextData](void *s, HttpRequest *httpRequest) -> void * { 144| | /* For every request we reset the timeout and hang until user makes action */ 145| | /* Warning: if we are in shutdown state, resetting the timer is a security issue! */ 146| 171k| us_socket_timeout(SSL, (us_socket_t *) s, 0); 147| | 148| | /* Reset httpResponse */ 149| 171k| HttpResponseData *httpResponseData = (HttpResponseData *) us_socket_ext(SSL, (us_socket_t *) s); 150| 171k| httpResponseData->offset = 0; 151| | 152| | /* Are we not ready for another request yet? Terminate the connection. */ 153| 171k| if (httpResponseData->state & HttpResponseData::HTTP_RESPONSE_PENDING) { ------------------ | Branch (153:21): [True: 0, False: 171k] ------------------ 154| 0| us_socket_close(SSL, (us_socket_t *) s, 0, nullptr); 155| 0| return nullptr; 156| 0| } 157| | 158| | /* Mark pending request and emit it */ 159| 171k| httpResponseData->state = HttpResponseData::HTTP_RESPONSE_PENDING; 160| | 161| | /* Mark this response as connectionClose if ancient or connection: close */ 162| 171k| if (httpRequest->isAncient() || httpRequest->getHeader("connection").length() == 5) { ------------------ | Branch (162:21): [True: 0, False: 171k] | Branch (162:21): [True: 843, False: 170k] | Branch (162:49): [True: 843, False: 170k] ------------------ 163| 843| httpResponseData->state |= HttpResponseData::HTTP_CONNECTION_CLOSE; 164| 843| } 165| | 166| | /* Select the router based on SNI (only possible for SSL) */ 167| 171k| auto *selectedRouter = &httpContextData->router; 168| 171k| if constexpr (SSL) { ------------------ | Branch (168:31): [Folded - Ignored] ------------------ 169| 171k| void *domainRouter = us_socket_server_name_userdata(SSL, (struct us_socket_t *) s); 170| 171k| if (domainRouter) { 171| 171k| selectedRouter = (decltype(selectedRouter)) domainRouter; 172| 171k| } 173| 171k| } 174| | 175| | /* Route the method and URL */ 176| 171k| selectedRouter->getUserData() = {(HttpResponse *) s, httpRequest}; 177| 171k| if (!selectedRouter->route(httpRequest->getCaseSensitiveMethod(), httpRequest->getUrl())) { ------------------ | Branch (177:21): [True: 0, False: 171k] ------------------ 178| | /* We have to force close this socket as we have no handler for it */ 179| 0| us_socket_close(SSL, (us_socket_t *) s, 0, nullptr); 180| 0| return nullptr; 181| 0| } 182| | 183| | /* First of all we need to check if this socket was deleted due to upgrade */ 184| 171k| if (httpContextData->upgradedWebSocket) { ------------------ | Branch (184:21): [True: 164k, False: 7.55k] ------------------ 185| | /* We differ between closed and upgraded below */ 186| 164k| return nullptr; 187| 164k| } 188| | 189| | /* Was the socket closed? */ 190| 7.55k| if (us_socket_is_closed(SSL, (struct us_socket_t *) s)) { ------------------ | Branch (190:21): [True: 0, False: 7.55k] ------------------ 191| 0| return nullptr; 192| 0| } 193| | 194| | /* We absolutely have to terminate parsing if shutdown */ 195| 7.55k| if (us_socket_is_shut_down(SSL, (us_socket_t *) s)) { ------------------ | Branch (195:21): [True: 0, False: 7.55k] ------------------ 196| 0| return nullptr; 197| 0| } 198| | 199| | /* Returning from a request handler without responding or attaching an onAborted handler is ill-use */ 200| 7.55k| if (!((HttpResponse *) s)->hasResponded() && !httpResponseData->onAborted) { ------------------ | Branch (200:21): [True: 0, False: 7.55k] | Branch (200:67): [True: 0, False: 0] ------------------ 201| | /* Throw exception here? */ 202| 0| std::cerr << "Error: Returning from a request handler without responding or attaching an abort handler is forbidden!" << std::endl; 203| 0| std::terminate(); 204| 0| } 205| | 206| | /* If we have not responded and we have a data handler, we need to timeout to enfore client sending the data */ 207| 7.55k| if (!((HttpResponse *) s)->hasResponded() && httpResponseData->inStream) { ------------------ | Branch (207:21): [True: 0, False: 7.55k] | Branch (207:67): [True: 0, False: 0] ------------------ 208| 0| us_socket_timeout(SSL, (us_socket_t *) s, HTTP_IDLE_TIMEOUT_S); 209| 0| } 210| | 211| | /* Continue parsing */ 212| 7.55k| return s; 213| | 214| 7.55k| }, [httpResponseData](void *user, std::string_view data, bool fin) -> void * { _ZZZN3uWS11HttpContextILb0EE4initEvENKUlP11us_socket_tPciE_clES3_S4_iENKUlPvNSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEbE_clES6_SB_b: 214| 7.55k| }, [httpResponseData](void *user, std::string_view data, bool fin) -> void * { 215| | /* We always get an empty chunk even if there is no data */ 216| 7.55k| if (httpResponseData->inStream) { ------------------ | Branch (216:21): [True: 0, False: 7.55k] ------------------ 217| | 218| | /* Todo: can this handle timeout for non-post as well? */ 219| 0| if (fin) { ------------------ | Branch (219:25): [True: 0, False: 0] ------------------ 220| | /* If we just got the last chunk (or empty chunk), disable timeout */ 221| 0| us_socket_timeout(SSL, (struct us_socket_t *) user, 0); 222| 0| } else { 223| | /* We still have some more data coming in later, so reset timeout */ 224| | /* Only reset timeout if we got enough bytes (16kb/sec) since last time we reset here */ 225| 0| httpResponseData->received_bytes_per_timeout += (unsigned int) data.length(); 226| 0| if (httpResponseData->received_bytes_per_timeout >= HTTP_RECEIVE_THROUGHPUT_BYTES * HTTP_IDLE_TIMEOUT_S) { ------------------ | Branch (226:29): [True: 0, False: 0] ------------------ 227| 0| us_socket_timeout(SSL, (struct us_socket_t *) user, HTTP_IDLE_TIMEOUT_S); 228| 0| httpResponseData->received_bytes_per_timeout = 0; 229| 0| } 230| 0| } 231| | 232| | /* We might respond in the handler, so do not change timeout after this */ 233| 0| httpResponseData->inStream(data, fin); 234| | 235| | /* Was the socket closed? */ 236| 0| if (us_socket_is_closed(SSL, (struct us_socket_t *) user)) { ------------------ | Branch (236:25): [True: 0, False: 0] ------------------ 237| 0| return nullptr; 238| 0| } 239| | 240| | /* We absolutely have to terminate parsing if shutdown */ 241| 0| if (us_socket_is_shut_down(SSL, (us_socket_t *) user)) { ------------------ | Branch (241:25): [True: 0, False: 0] ------------------ 242| 0| return nullptr; 243| 0| } 244| | 245| | /* If we were given the last data chunk, reset data handler to ensure following 246| | * requests on the same socket won't trigger any previously registered behavior */ 247| 0| if (fin) { ------------------ | Branch (247:25): [True: 0, False: 0] ------------------ 248| 0| httpResponseData->inStream = nullptr; 249| 0| } 250| 0| } 251| 7.55k| return user; 252| 7.55k| }); _ZZN3uWS11HttpContextILb0EE4initEvENKUlP11us_socket_tE_clES3_: 325| 1.33k| us_socket_context_on_writable(SSL, getSocketContext(), [](us_socket_t *s) { 326| | 327| 1.33k| AsyncSocket *asyncSocket = (AsyncSocket *) s; 328| 1.33k| HttpResponseData *httpResponseData = (HttpResponseData *) asyncSocket->getAsyncSocketData(); 329| | 330| | /* Ask the developer to write data and return success (true) or failure (false), OR skip sending anything and return success (true). */ 331| 1.33k| if (httpResponseData->onWritable) { ------------------ | Branch (331:17): [True: 0, False: 1.33k] ------------------ 332| | /* We are now writable, so hang timeout again, the user does not have to do anything so we should hang until end or tryEnd rearms timeout */ 333| 0| us_socket_timeout(SSL, s, 0); 334| | 335| | /* We expect the developer to return whether or not write was successful (true). 336| | * If write was never called, the developer should still return true so that we may drain. */ 337| 0| bool success = httpResponseData->callOnWritable(httpResponseData->offset); 338| | 339| | /* The developer indicated that their onWritable failed. */ 340| 0| if (!success) { ------------------ | Branch (340:21): [True: 0, False: 0] ------------------ 341| | /* Skip testing if we can drain anything since that might perform an extra syscall */ 342| 0| return s; 343| 0| } 344| | 345| | /* We don't want to fall through since we don't want to mess with timeout. 346| | * It makes little sense to drain any backpressure when the user has registered onWritable. */ 347| 0| return s; 348| 0| } 349| | 350| | /* Drain any socket buffer, this might empty our backpressure and thus finish the request */ 351| 1.33k| /*auto [written, failed] = */asyncSocket->write(nullptr, 0, true, 0); 352| | 353| | /* Should we close this connection after a response - and is this response really done? */ 354| 1.33k| if (httpResponseData->state & HttpResponseData::HTTP_CONNECTION_CLOSE) { ------------------ | Branch (354:17): [True: 870, False: 462] ------------------ 355| 870| if ((httpResponseData->state & HttpResponseData::HTTP_RESPONSE_PENDING) == 0) { ------------------ | Branch (355:21): [True: 870, False: 0] ------------------ 356| 870| if (asyncSocket->getBufferedAmount() == 0) { ------------------ | Branch (356:25): [True: 203, False: 667] ------------------ 357| 203| asyncSocket->shutdown(); 358| | /* We need to force close after sending FIN since we want to hinder 359| | * clients from keeping to send their huge data */ 360| 203| asyncSocket->close(); 361| 203| } 362| 870| } 363| 870| } 364| | 365| | /* Expect another writable event, or another request within the timeout */ 366| 1.33k| asyncSocket->timeout(HTTP_IDLE_TIMEOUT_S); 367| | 368| 1.33k| return s; 369| 1.33k| }); _ZZN3uWS11HttpContextILb0EE4initEvENKUlP11us_socket_tE0_clES3_: 372| 82.8k| us_socket_context_on_end(SSL, getSocketContext(), [](us_socket_t *s) { 373| | 374| | /* We do not care for half closed sockets */ 375| 82.8k| AsyncSocket *asyncSocket = (AsyncSocket *) s; 376| 82.8k| return asyncSocket->close(); 377| | 378| 82.8k| }); _ZZN3uWS11HttpContextILb0EE4initEvENKUlP11us_socket_tE1_clES3_: 381| 7.40k| us_socket_context_on_timeout(SSL, getSocketContext(), [](us_socket_t *s) { 382| | 383| | /* Force close rather than gracefully shutdown and risk confusing the client with a complete download */ 384| 7.40k| AsyncSocket *asyncSocket = (AsyncSocket *) s; 385| 7.40k| return asyncSocket->close(); 386| | 387| 7.40k| }); _ZN3uWS11HttpContextILb0EE6onHttpENSt3__112basic_stringIcNS2_11char_traitsIcEENS2_9allocatorIcEEEES8_ON5ofats13any_invocableIFvPNS_12HttpResponseILb0EEEPNS_11HttpRequestEEEEb: 423| 17.5k| void onHttp(std::string method, std::string pattern, MoveOnlyFunction *, HttpRequest *)> &&handler, bool upgrade = false) { 424| 17.5k| HttpContextData *httpContextData = getSocketContextData(); 425| | 426| | /* Todo: This is ugly, fix */ 427| 17.5k| std::vector methods; 428| 17.5k| if (method == "*") { ------------------ | Branch (428:13): [True: 5.84k, False: 11.6k] ------------------ 429| 5.84k| methods = {"*"}; 430| 11.6k| } else { 431| 11.6k| methods = {method}; 432| 11.6k| } 433| | 434| 17.5k| uint32_t priority = method == "*" ? httpContextData->currentRouter->LOW_PRIORITY : (upgrade ? httpContextData->currentRouter->HIGH_PRIORITY : httpContextData->currentRouter->MEDIUM_PRIORITY); ------------------ | Branch (434:29): [True: 5.84k, False: 11.6k] | Branch (434:93): [True: 11.6k, False: 0] ------------------ 435| | 436| | /* If we are passed nullptr then remove this */ 437| 17.5k| if (!handler) { ------------------ | Branch (437:13): [True: 0, False: 17.5k] ------------------ 438| 0| httpContextData->currentRouter->remove(methods[0], pattern, priority); 439| 0| return; 440| 0| } 441| | 442| | /* Record this route's parameter offsets */ 443| 17.5k| std::map> parameterOffsets; 444| 17.5k| unsigned short offset = 0; 445| 99.4k| for (unsigned int i = 0; i < pattern.length(); i++) { ------------------ | Branch (445:34): [True: 81.8k, False: 17.5k] ------------------ 446| 81.8k| if (pattern[i] == ':') { ------------------ | Branch (446:17): [True: 0, False: 81.8k] ------------------ 447| 0| i++; 448| 0| unsigned int start = i; 449| 0| while (i < pattern.length() && pattern[i] != '/') { ------------------ | Branch (449:24): [True: 0, False: 0] | Branch (449:48): [True: 0, False: 0] ------------------ 450| 0| i++; 451| 0| } 452| 0| parameterOffsets[std::string(pattern.data() + start, i - start)] = offset; 453| | //std::cout << "<" << std::string(pattern.data() + start, i - start) << "> is offset " << offset; 454| 0| offset++; 455| 0| } 456| 81.8k| } 457| | 458| 17.5k| httpContextData->currentRouter->add(methods, pattern, [handler = std::move(handler), parameterOffsets = std::move(parameterOffsets)](auto *r) mutable { 459| 17.5k| auto user = r->getUserData(); 460| 17.5k| user.httpRequest->setYield(false); 461| 17.5k| user.httpRequest->setParameters(r->getParameters()); 462| 17.5k| user.httpRequest->setParameterOffsets(¶meterOffsets); 463| | 464| | /* Middleware? Automatically respond to expectations */ 465| 17.5k| std::string_view expect = user.httpRequest->getHeader("expect"); 466| 17.5k| if (expect.length() && expect == "100-continue") { 467| 17.5k| user.httpResponse->writeContinue(); 468| 17.5k| } 469| | 470| 17.5k| handler(user.httpResponse, user.httpRequest); 471| | 472| | /* If any handler yielded, the router will keep looking for a suitable handler. */ 473| 17.5k| if (user.httpRequest->getYield()) { 474| 17.5k| return false; 475| 17.5k| } 476| 17.5k| return true; 477| 17.5k| }, priority); 478| 17.5k| } _ZN3uWS11HttpContextILb0EE20getSocketContextDataEv: 61| 187k| HttpContextData *getSocketContextData() { 62| 187k| return (HttpContextData *) us_socket_context_ext(SSL, getSocketContext()); 63| 187k| } _ZZN3uWS11HttpContextILb0EE6onHttpENSt3__112basic_stringIcNS2_11char_traitsIcEENS2_9allocatorIcEEEES8_ON5ofats13any_invocableIFvPNS_12HttpResponseILb0EEEPNS_11HttpRequestEEEEbENUlPT_E_clINS_10HttpRouterINS_15HttpContextDataILb0EE10RouterDataEEEEEDaSK_: 458| 176k| httpContextData->currentRouter->add(methods, pattern, [handler = std::move(handler), parameterOffsets = std::move(parameterOffsets)](auto *r) mutable { 459| 176k| auto user = r->getUserData(); 460| 176k| user.httpRequest->setYield(false); 461| 176k| user.httpRequest->setParameters(r->getParameters()); 462| 176k| user.httpRequest->setParameterOffsets(¶meterOffsets); 463| | 464| | /* Middleware? Automatically respond to expectations */ 465| 176k| std::string_view expect = user.httpRequest->getHeader("expect"); 466| 176k| if (expect.length() && expect == "100-continue") { ------------------ | Branch (466:17): [True: 753, False: 175k] | Branch (466:36): [True: 197, False: 556] ------------------ 467| 197| user.httpResponse->writeContinue(); 468| 197| } 469| | 470| 176k| handler(user.httpResponse, user.httpRequest); 471| | 472| | /* If any handler yielded, the router will keep looking for a suitable handler. */ 473| 176k| if (user.httpRequest->getYield()) { ------------------ | Branch (473:17): [True: 4.79k, False: 171k] ------------------ 474| 4.79k| return false; 475| 4.79k| } 476| 171k| return true; 477| 176k| }, priority); _ZN3uWS11HttpContextILb0EE4freeEv: 409| 5.84k| void free() { 410| | /* Destruct socket context data */ 411| 5.84k| HttpContextData *httpContextData = getSocketContextData(); 412| 5.84k| httpContextData->~HttpContextData(); 413| | 414| | /* Free the socket context in whole */ 415| 5.84k| us_socket_context_free(SSL, getSocketContext()); 416| 5.84k| } _ZN3uWS11HttpContextILb0EE6listenEPKcii: 481| 5.84k| us_listen_socket_t *listen(const char *host, int port, int options) { 482| 5.84k| return us_socket_context_listen(SSL, getSocketContext(), host, port, options, sizeof(HttpResponseData)); 483| 5.84k| } _ZN3uWS12optional_ptrIcEENSt3__18optionalIPT_EES4_: 47| 2|std::optional optional_ptr(T *ptr) { 48| 2| return ptr ? std::optional(ptr) : std::nullopt; ------------------ | Branch (48:12): [True: 0, False: 2] ------------------ 49| 2|} _ZN3uWS10HttpParser17consumePostPaddedEPcjPvS2_ON5ofats13any_invocableIFS2_S2_PNS_11HttpRequestEEEEONS4_IFS2_S2_NSt3__117basic_string_viewIcNSA_11char_traitsIcEEEEbEEE: 583| 592k| std::pair consumePostPadded(char *data, unsigned int length, void *user, void *reserved, MoveOnlyFunction &&requestHandler, MoveOnlyFunction &&dataHandler) { 584| | 585| | /* This resets BloomFilter by construction, but later we also reset it again. 586| | * Optimize this to skip resetting twice (req could be made global) */ 587| 592k| HttpRequest req; 588| | 589| 592k| if (remainingStreamingBytes) { ------------------ | Branch (589:13): [True: 0, False: 592k] ------------------ 590| | 591| | /* It's either chunked or with a content-length */ 592| 0| if (isParsingChunkedEncoding(remainingStreamingBytes)) { ------------------ | Branch (592:17): [True: 0, False: 0] ------------------ 593| 0| std::string_view dataToConsume(data, length); 594| 0| for (auto chunk : uWS::ChunkIterator(&dataToConsume, &remainingStreamingBytes)) { ------------------ | Branch (594:33): [True: 0, False: 0] ------------------ 595| 0| dataHandler(user, chunk, chunk.length() == 0); 596| 0| } 597| 0| if (isParsingInvalidChunkedEncoding(remainingStreamingBytes)) { ------------------ | Branch (597:21): [True: 0, False: 0] ------------------ 598| 0| return {HTTP_ERROR_400_BAD_REQUEST, FULLPTR}; 599| 0| } 600| 0| data = (char *) dataToConsume.data(); 601| 0| length = (unsigned int) dataToConsume.length(); 602| 0| } else { 603| | // this is exactly the same as below! 604| | // todo: refactor this 605| 0| if (remainingStreamingBytes >= length) { ------------------ | Branch (605:21): [True: 0, False: 0] ------------------ 606| 0| void *returnedUser = dataHandler(user, std::string_view(data, length), remainingStreamingBytes == length); 607| 0| remainingStreamingBytes -= length; 608| 0| return {0, returnedUser}; 609| 0| } else { 610| 0| void *returnedUser = dataHandler(user, std::string_view(data, remainingStreamingBytes), true); 611| | 612| 0| data += (unsigned int) remainingStreamingBytes; 613| 0| length -= (unsigned int) remainingStreamingBytes; 614| | 615| 0| remainingStreamingBytes = 0; 616| | 617| 0| if (returnedUser != user) { ------------------ | Branch (617:25): [True: 0, False: 0] ------------------ 618| 0| return {0, returnedUser}; 619| 0| } 620| 0| } 621| 0| } 622| | 623| 592k| } else if (fallback.length()) { ------------------ | Branch (623:20): [True: 16.2k, False: 576k] ------------------ 624| 16.2k| unsigned int had = (unsigned int) fallback.length(); 625| | 626| 16.2k| size_t maxCopyDistance = std::min(MAX_FALLBACK_SIZE - fallback.length(), (size_t) length); 627| | 628| | /* We don't want fallback to be short string optimized, since we want to move it */ 629| 16.2k| fallback.reserve(fallback.length() + maxCopyDistance + std::max(MINIMUM_HTTP_POST_PADDING, sizeof(std::string))); 630| 16.2k| fallback.append(data, maxCopyDistance); 631| | 632| | // break here on break 633| 16.2k| std::pair consumed = fenceAndConsumePostPadded(fallback.data(), (unsigned int) fallback.length(), user, reserved, &req, requestHandler, dataHandler); 634| 16.2k| if (consumed.second != user) { ------------------ | Branch (634:17): [True: 1.80k, False: 14.4k] ------------------ 635| 1.80k| return consumed; 636| 1.80k| } 637| | 638| 14.4k| if (consumed.first) { ------------------ | Branch (638:17): [True: 1.60k, False: 12.8k] ------------------ 639| | 640| | /* This logic assumes that we consumed everything in fallback buffer. 641| | * This is critically important, as we will get an integer overflow in case 642| | * of "had" being larger than what we consumed, and that we would drop data */ 643| 1.60k| fallback.clear(); 644| 1.60k| data += consumed.first - had; 645| 1.60k| length -= consumed.first - had; 646| | 647| 1.60k| if (remainingStreamingBytes) { ------------------ | Branch (647:21): [True: 0, False: 1.60k] ------------------ 648| | /* It's either chunked or with a content-length */ 649| 0| if (isParsingChunkedEncoding(remainingStreamingBytes)) { ------------------ | Branch (649:25): [True: 0, False: 0] ------------------ 650| 0| std::string_view dataToConsume(data, length); 651| 0| for (auto chunk : uWS::ChunkIterator(&dataToConsume, &remainingStreamingBytes)) { ------------------ | Branch (651:41): [True: 0, False: 0] ------------------ 652| 0| dataHandler(user, chunk, chunk.length() == 0); 653| 0| } 654| 0| if (isParsingInvalidChunkedEncoding(remainingStreamingBytes)) { ------------------ | Branch (654:29): [True: 0, False: 0] ------------------ 655| 0| return {HTTP_ERROR_400_BAD_REQUEST, FULLPTR}; 656| 0| } 657| 0| data = (char *) dataToConsume.data(); 658| 0| length = (unsigned int) dataToConsume.length(); 659| 0| } else { 660| | // this is exactly the same as above! 661| 0| if (remainingStreamingBytes >= (unsigned int) length) { ------------------ | Branch (661:29): [True: 0, False: 0] ------------------ 662| 0| void *returnedUser = dataHandler(user, std::string_view(data, length), remainingStreamingBytes == (unsigned int) length); 663| 0| remainingStreamingBytes -= length; 664| 0| return {0, returnedUser}; 665| 0| } else { 666| 0| void *returnedUser = dataHandler(user, std::string_view(data, remainingStreamingBytes), true); 667| | 668| 0| data += (unsigned int) remainingStreamingBytes; 669| 0| length -= (unsigned int) remainingStreamingBytes; 670| | 671| 0| remainingStreamingBytes = 0; 672| | 673| 0| if (returnedUser != user) { ------------------ | Branch (673:33): [True: 0, False: 0] ------------------ 674| 0| return {0, returnedUser}; 675| 0| } 676| 0| } 677| 0| } 678| 0| } 679| | 680| 12.8k| } else { 681| 12.8k| if (fallback.length() == MAX_FALLBACK_SIZE) { ------------------ | Branch (681:21): [True: 196, False: 12.6k] ------------------ 682| 196| return {HTTP_ERROR_431_REQUEST_HEADER_FIELDS_TOO_LARGE, FULLPTR}; 683| 196| } 684| 12.6k| return {0, user}; 685| 12.8k| } 686| 14.4k| } 687| | 688| 578k| std::pair consumed = fenceAndConsumePostPadded(data, length, user, reserved, &req, requestHandler, dataHandler); 689| 578k| if (consumed.second != user) { ------------------ | Branch (689:13): [True: 560k, False: 17.2k] ------------------ 690| 560k| return consumed; 691| 560k| } 692| | 693| 17.2k| data += consumed.first; 694| 17.2k| length -= consumed.first; 695| | 696| 17.2k| if (length) { ------------------ | Branch (696:13): [True: 15.4k, False: 1.81k] ------------------ 697| 15.4k| if (length < MAX_FALLBACK_SIZE) { ------------------ | Branch (697:17): [True: 15.4k, False: 0] ------------------ 698| 15.4k| fallback.append(data, length); 699| 15.4k| } else { 700| 0| return {HTTP_ERROR_431_REQUEST_HEADER_FIELDS_TOO_LARGE, FULLPTR}; 701| 0| } 702| 15.4k| } 703| | 704| | // added for now 705| 17.2k| return {0, user}; 706| 17.2k| } _ZN3uWS10HttpParser25fenceAndConsumePostPaddedILi1EEENSt3__14pairIjPvEEPcjS4_S4_PNS_11HttpRequestERN5ofats13any_invocableIFS4_S4_S8_EEERNSA_IFS4_S4_NS2_17basic_string_viewIcNS2_11char_traitsIcEEEEbEEE: 448| 16.2k| std::pair fenceAndConsumePostPadded(char *data, unsigned int length, void *user, void *reserved, HttpRequest *req, MoveOnlyFunction &requestHandler, MoveOnlyFunction &dataHandler) { 449| | 450| | /* How much data we CONSUMED (to throw away) */ 451| 16.2k| unsigned int consumedTotal = 0; 452| 16.2k| unsigned int err = 0; 453| | 454| | /* Fence two bytes past end of our buffer (buffer has post padded margins). 455| | * This is to always catch scan for \r but not for \r\n. */ 456| 16.2k| data[length] = '\r'; 457| 16.2k| data[length + 1] = 'a'; /* Anything that is not \n, to trigger "invalid request" */ 458| | 459| 16.2k| for (unsigned int consumed; length && (consumed = getHeaders(data, data + length, req->headers, reserved, err)); ) { ------------------ | Branch (459:37): [True: 16.2k, False: 0] | Branch (459:47): [True: 3.40k, False: 12.8k] ------------------ 460| 3.40k| data += consumed; 461| 3.40k| length -= consumed; 462| 3.40k| consumedTotal += consumed; 463| | 464| | /* Even if we could parse it, check for length here as well */ 465| 3.40k| if (consumed > MAX_FALLBACK_SIZE) { ------------------ | Branch (465:17): [True: 0, False: 3.40k] ------------------ 466| 0| return {HTTP_ERROR_431_REQUEST_HEADER_FIELDS_TOO_LARGE, FULLPTR}; 467| 0| } 468| | 469| | /* Store HTTP version (ancient 1.0 or 1.1) */ 470| 3.40k| req->ancientHttp = false; 471| | 472| | /* Add all headers to bloom filter */ 473| 3.40k| req->bf.reset(); 474| 11.1k| for (HttpRequest::Header *h = req->headers; (++h)->key.length(); ) { ------------------ | Branch (474:57): [True: 7.69k, False: 3.40k] ------------------ 475| 7.69k| req->bf.add(h->key); 476| 7.69k| } 477| | 478| | /* Break if no host header (but we can have empty string which is different from nullptr) */ 479| 3.40k| if (!req->getHeader("host").data()) { ------------------ | Branch (479:17): [True: 481, False: 2.92k] ------------------ 480| 481| return {HTTP_ERROR_400_BAD_REQUEST, FULLPTR}; 481| 481| } 482| | 483| | /* RFC 9112 6.3 484| | * If a message is received with both a Transfer-Encoding and a Content-Length header field, 485| | * the Transfer-Encoding overrides the Content-Length. Such a message might indicate an attempt 486| | * to perform request smuggling (Section 11.2) or response splitting (Section 11.1) and 487| | * ought to be handled as an error. */ 488| 2.92k| std::string_view transferEncodingString = req->getHeader("transfer-encoding"); 489| 2.92k| std::string_view contentLengthString = req->getHeader("content-length"); 490| 2.92k| if (transferEncodingString.length() && contentLengthString.length()) { ------------------ | Branch (490:17): [True: 0, False: 2.92k] | Branch (490:52): [True: 0, False: 0] ------------------ 491| | /* Returning fullptr is the same as calling the errorHandler */ 492| | /* We could be smart and set an error in the context along with this, to indicate what 493| | * http error response we might want to return */ 494| 0| return {HTTP_ERROR_400_BAD_REQUEST, FULLPTR}; 495| 0| } 496| | 497| | /* Parse query */ 498| 2.92k| const char *querySeparatorPtr = (const char *) memchr(req->headers->value.data(), '?', req->headers->value.length()); 499| 2.92k| req->querySeparator = (unsigned int) ((querySeparatorPtr ? querySeparatorPtr : req->headers->value.data() + req->headers->value.length()) - req->headers->value.data()); ------------------ | Branch (499:52): [True: 1.05k, False: 1.87k] ------------------ 500| | 501| | /* If returned socket is not what we put in we need 502| | * to break here as we either have upgraded to 503| | * WebSockets or otherwise closed the socket. */ 504| 2.92k| void *returnedUser = requestHandler(user, req); 505| 2.92k| if (returnedUser != user) { ------------------ | Branch (505:17): [True: 1.32k, False: 1.60k] ------------------ 506| | /* We are upgraded to WebSocket or otherwise broken */ 507| 1.32k| return {consumedTotal, returnedUser}; 508| 1.32k| } 509| | 510| | /* The rules at play here according to RFC 9112 for requests are essentially: 511| | * If both content-length and transfer-encoding then invalid message; must break. 512| | * If has transfer-encoding then must be chunked regardless of value. 513| | * If content-length then fixed length even if 0. 514| | * If none of the above then fixed length is 0. */ 515| | 516| | /* RFC 9112 6.3 517| | * If a message is received with both a Transfer-Encoding and a Content-Length header field, 518| | * the Transfer-Encoding overrides the Content-Length. */ 519| 1.60k| if (transferEncodingString.length()) { ------------------ | Branch (519:17): [True: 0, False: 1.60k] ------------------ 520| | 521| | /* If a proxy sent us the transfer-encoding header that 100% means it must be chunked or else the proxy is 522| | * not RFC 9112 compliant. Therefore it is always better to assume this is the case, since that entirely eliminates 523| | * all forms of transfer-encoding obfuscation tricks. We just rely on the header. */ 524| | 525| | /* RFC 9112 6.3 526| | * If a Transfer-Encoding header field is present in a request and the chunked transfer coding is not the 527| | * final encoding, the message body length cannot be determined reliably; the server MUST respond with the 528| | * 400 (Bad Request) status code and then close the connection. */ 529| | 530| | /* In this case we fail later by having the wrong interpretation (assuming chunked). 531| | * This could be made stricter but makes no difference either way, unless forwarding the identical message as a proxy. */ 532| | 533| 0| remainingStreamingBytes = STATE_IS_CHUNKED; 534| | /* If consume minimally, we do not want to consume anything but we want to mark this as being chunked */ 535| 0| if (!CONSUME_MINIMALLY) { ------------------ | Branch (535:21): [Folded - Ignored] ------------------ 536| | /* Go ahead and parse it (todo: better heuristics for emitting FIN to the app level) */ 537| 0| std::string_view dataToConsume(data, length); 538| 0| for (auto chunk : uWS::ChunkIterator(&dataToConsume, &remainingStreamingBytes)) { ------------------ | Branch (538:37): [True: 0, False: 0] ------------------ 539| 0| dataHandler(user, chunk, chunk.length() == 0); 540| 0| } 541| 0| if (isParsingInvalidChunkedEncoding(remainingStreamingBytes)) { ------------------ | Branch (541:25): [True: 0, False: 0] ------------------ 542| 0| return {HTTP_ERROR_400_BAD_REQUEST, FULLPTR}; 543| 0| } 544| 0| unsigned int consumed = (length - (unsigned int) dataToConsume.length()); 545| 0| data = (char *) dataToConsume.data(); 546| 0| length = (unsigned int) dataToConsume.length(); 547| 0| consumedTotal += consumed; 548| 0| } 549| 1.60k| } else if (contentLengthString.length()) { ------------------ | Branch (549:24): [True: 0, False: 1.60k] ------------------ 550| 0| remainingStreamingBytes = toUnsignedInteger(contentLengthString); 551| 0| if (remainingStreamingBytes == UINT64_MAX) { ------------------ | Branch (551:21): [True: 0, False: 0] ------------------ 552| | /* Parser error */ 553| 0| return {HTTP_ERROR_400_BAD_REQUEST, FULLPTR}; 554| 0| } 555| | 556| 0| if (!CONSUME_MINIMALLY) { ------------------ | Branch (556:21): [Folded - Ignored] ------------------ 557| 0| unsigned int emittable = (unsigned int) std::min(remainingStreamingBytes, length); 558| 0| dataHandler(user, std::string_view(data, emittable), emittable == remainingStreamingBytes); 559| 0| remainingStreamingBytes -= emittable; 560| | 561| 0| data += emittable; 562| 0| length -= emittable; 563| 0| consumedTotal += emittable; 564| 0| } 565| 1.60k| } else { 566| | /* If we came here without a body; emit an empty data chunk to signal no data */ 567| 1.60k| dataHandler(user, {}, true); 568| 1.60k| } 569| | 570| | /* Consume minimally should break as easrly as possible */ 571| 1.60k| if (CONSUME_MINIMALLY) { ------------------ | Branch (571:17): [Folded - Ignored] ------------------ 572| 1.60k| break; 573| 1.60k| } 574| 1.60k| } 575| | /* Whenever we return FULLPTR, the interpretation of "consumed" should be the HttpError enum. */ 576| 14.4k| if (err) { ------------------ | Branch (576:13): [True: 0, False: 14.4k] ------------------ 577| 0| return {err, FULLPTR}; 578| 0| } 579| 14.4k| return {consumedTotal, user}; 580| 14.4k| } _ZN3uWS10HttpParser10getHeadersEPcS1_PNS_11HttpRequest6HeaderEPvRj: 337| 598k| static unsigned int getHeaders(char *postPaddedBuffer, char *end, struct HttpRequest::Header *headers, void *reserved, unsigned int &err) { 338| 598k| char *preliminaryKey, *preliminaryValue, *start = postPaddedBuffer; 339| | 340| | #ifdef UWS_WITH_PROXY 341| | /* ProxyParser is passed as reserved parameter */ 342| | ProxyParser *pp = (ProxyParser *) reserved; 343| | 344| | /* Parse PROXY protocol */ 345| | auto [done, offset] = pp->parse({postPaddedBuffer, (size_t) (end - postPaddedBuffer)}); 346| | if (!done) { 347| | /* We do not reset the ProxyParser (on filure) since it is tied to this 348| | * connection, which is really only supposed to ever get one PROXY frame 349| | * anyways. We do however allow multiple PROXY frames to be sent (overwrites former). */ 350| | return 0; 351| | } else { 352| | /* We have consumed this data so skip it */ 353| | postPaddedBuffer += offset; 354| | } 355| | #else 356| | /* This one is unused */ 357| 598k| (void) reserved; 358| 598k| (void) end; 359| 598k| #endif 360| | 361| | /* It is critical for fallback buffering logic that we only return with success 362| | * if we managed to parse a complete HTTP request (minus data). Returning success 363| | * for PROXY means we can end up succeeding, yet leaving bytes in the fallback buffer 364| | * which is then removed, and our counters to flip due to overflow and we end up with a crash */ 365| | 366| | /* The request line is different from the field names / field values */ 367| 598k| if (!(postPaddedBuffer = consumeRequestLine(postPaddedBuffer, headers[0]))) { ------------------ | Branch (367:13): [True: 397k, False: 201k] ------------------ 368| | /* Error - invalid request line */ 369| | /* Assuming it is 505 HTTP Version Not Supported */ 370| 397k| err = HTTP_ERROR_505_HTTP_VERSION_NOT_SUPPORTED; 371| 397k| return 0; 372| 397k| } 373| 201k| headers++; 374| | 375| 603k| for (unsigned int i = 1; i < UWS_HTTP_MAX_HEADERS_COUNT - 1; i++) { ------------------ | | 53| 603k|#define UWS_HTTP_MAX_HEADERS_COUNT 100 ------------------ | Branch (375:34): [True: 603k, False: 66] ------------------ 376| | /* Lower case and consume the field name */ 377| 603k| preliminaryKey = postPaddedBuffer; 378| 603k| postPaddedBuffer = (char *) consumeFieldName(postPaddedBuffer); 379| 603k| headers->key = std::string_view(preliminaryKey, (size_t) (postPaddedBuffer - preliminaryKey)); 380| | 381| | /* We should not accept whitespace between key and colon, so colon must foloow immediately */ 382| 603k| if (postPaddedBuffer[0] != ':') { ------------------ | Branch (382:17): [True: 6.29k, False: 596k] ------------------ 383| | /* Error: invalid chars in field name */ 384| 6.29k| return 0; 385| 6.29k| } 386| 596k| postPaddedBuffer++; 387| | 388| 596k| preliminaryValue = postPaddedBuffer; 389| | /* The goal of this call is to find next "\r\n", or any invalid field value chars, fast */ 390| 598k| while (true) { ------------------ | Branch (390:20): [Folded - Ignored] ------------------ 391| 598k| postPaddedBuffer = (char *) tryConsumeFieldValue(postPaddedBuffer); 392| | /* If this is not CR then we caught some stinky invalid char on the way */ 393| 598k| if (postPaddedBuffer[0] != '\r') { ------------------ | Branch (393:21): [True: 4.37k, False: 593k] ------------------ 394| | /* If TAB then keep searching */ 395| 4.37k| if (postPaddedBuffer[0] == '\t') { ------------------ | Branch (395:25): [True: 1.50k, False: 2.86k] ------------------ 396| 1.50k| postPaddedBuffer++; 397| 1.50k| continue; 398| 1.50k| } 399| | /* Error - invalid chars in field value */ 400| 2.86k| return 0; 401| 4.37k| } 402| 593k| break; 403| 598k| } 404| | /* We fence end[0] with \r, followed by end[1] being something that is "not \n", to signify "not found". 405| | * This way we can have this one single check to see if we found \r\n WITHIN our allowed search space. */ 406| 593k| if (postPaddedBuffer[1] == '\n') { ------------------ | Branch (406:17): [True: 576k, False: 17.2k] ------------------ 407| | /* Store this header, it is valid */ 408| 576k| headers->value = std::string_view(preliminaryValue, (size_t) (postPaddedBuffer - preliminaryValue)); 409| 576k| postPaddedBuffer += 2; 410| | 411| | /* Trim trailing whitespace (SP, HTAB) */ 412| 740k| while (headers->value.length() && headers->value.back() < 33) { ------------------ | Branch (412:24): [True: 700k, False: 39.9k] | Branch (412:51): [True: 163k, False: 536k] ------------------ 413| 163k| headers->value.remove_suffix(1); 414| 163k| } 415| | 416| | /* Trim initial whitespace (SP, HTAB) */ 417| 616k| while (headers->value.length() && headers->value.front() < 33) { ------------------ | Branch (417:24): [True: 576k, False: 39.9k] | Branch (417:51): [True: 39.3k, False: 536k] ------------------ 418| 39.3k| headers->value.remove_prefix(1); 419| 39.3k| } 420| | 421| 576k| headers++; 422| | 423| | /* We definitely have at least one header (or request line), so check if we are done */ 424| 576k| if (*postPaddedBuffer == '\r') { ------------------ | Branch (424:21): [True: 174k, False: 401k] ------------------ 425| 174k| if (postPaddedBuffer[1] == '\n') { ------------------ | Branch (425:25): [True: 172k, False: 1.76k] ------------------ 426| | /* This cann take the very last header space */ 427| 172k| headers->key = std::string_view(nullptr, 0); 428| 172k| return (unsigned int) ((postPaddedBuffer + 2) - start); 429| 172k| } else { 430| | /* \r\n\r plus non-\n letter is malformed request, or simply out of search space */ 431| 1.76k| return 0; 432| 1.76k| } 433| 174k| } 434| 576k| } else { 435| | /* We are either out of search space or this is a malformed request */ 436| 17.2k| return 0; 437| 17.2k| } 438| 593k| } 439| | /* We ran out of header space, too large request */ 440| 66| return 0; 441| 201k| } _ZN3uWS10HttpParser18consumeRequestLineEPcRNS_11HttpRequest6HeaderE: 293| 598k| static inline char *consumeRequestLine(char *data, HttpRequest::Header &header) { 294| | /* Scan until single SP, assume next is / (origin request) */ 295| 598k| char *start = data; 296| | /* This catches the post padded CR and fails */ 297| 1.97M| while (data[0] > 32) data++; ------------------ | Branch (297:16): [True: 1.37M, False: 598k] ------------------ 298| 598k| if (data[0] == 32 && data[1] == '/') { ------------------ | Branch (298:13): [True: 239k, False: 359k] | Branch (298:30): [True: 209k, False: 29.4k] ------------------ 299| 209k| header.key = {start, (size_t) (data - start)}; 300| 209k| data++; 301| | /* Scan for less than 33 (catches post padded CR and fails) */ 302| 209k| start = data; 303| 364k| for (; true; data += 8) { ------------------ | Branch (303:20): [Folded - Ignored] ------------------ 304| 364k| uint64_t word; 305| 364k| memcpy(&word, data, sizeof(uint64_t)); 306| 364k| if (hasLess(word, 33)) { ------------------ | Branch (306:21): [True: 209k, False: 154k] ------------------ 307| 776k| while (*(unsigned char *)data > 32) data++; ------------------ | Branch (307:28): [True: 567k, False: 209k] ------------------ 308| | /* Now we stand on space */ 309| 209k| header.value = {start, (size_t) (data - start)}; 310| | /* Check that the following is http 1.1 */ 311| 209k| if (memcmp(" HTTP/1.1\r\n", data, 11) == 0) { ------------------ | Branch (311:25): [True: 201k, False: 8.42k] ------------------ 312| 201k| return data + 11; 313| 201k| } 314| 8.42k| return nullptr; 315| 209k| } 316| 364k| } 317| 209k| } 318| 388k| return nullptr; 319| 598k| } _ZN3uWS10HttpParser7hasLessEmm: 220| 1.80M| static inline uint64_t hasLess(uint64_t x, uint64_t n) { 221| 1.80M| return (((x)-~0ULL/255*(n))&~(x)&~0ULL/255*128); 222| 1.80M| } _ZN3uWS10HttpParser16consumeFieldNameEPc: 264| 603k| static inline void *consumeFieldName(char *p) { 265| | /* Best case fast path (particularly useful with clang) */ 266| 1.03M| while (true) { ------------------ | Branch (266:16): [Folded - Ignored] ------------------ 267| 1.03M| while ((*p >= 65) & (*p <= 90)) [[likely]] { ------------------ | Branch (267:20): [True: 5.31k, False: 1.03M] ------------------ 268| 5.31k| *p |= 32; 269| 5.31k| p++; 270| 5.31k| } 271| 5.39M| while (((*p >= 97) & (*p <= 122))) [[likely]] { ------------------ | Branch (271:20): [True: 4.36M, False: 1.03M] ------------------ 272| 4.36M| p++; 273| 4.36M| } 274| 1.03M| if (*p == ':') { ------------------ | Branch (274:17): [True: 593k, False: 437k] ------------------ 275| 593k| return (void *)p; 276| 593k| } 277| 437k| if (*p == '-') { ------------------ | Branch (277:17): [True: 425k, False: 12.5k] ------------------ 278| 425k| p++; 279| 425k| } else if (!((*p >= 65) & (*p <= 90))) { ------------------ | Branch (279:24): [True: 9.24k, False: 3.31k] ------------------ 280| | /* Exit fast path parsing */ 281| 9.24k| break; 282| 9.24k| } 283| 437k| } 284| | 285| | /* Generic */ 286| 97.0k| while (isFieldNameByteFastLowercased(*(unsigned char *)p)) { ------------------ | Branch (286:16): [True: 87.8k, False: 9.24k] ------------------ 287| 87.8k| p++; 288| 87.8k| } 289| 9.24k| return (void *)p; 290| 603k| } _ZN3uWS10HttpParser29isFieldNameByteFastLowercasedERh: 249| 97.0k| static inline bool isFieldNameByteFastLowercased(unsigned char &in) { 250| | /* Most common is lowercase alpha and hyphen */ 251| 97.0k| if (((in >= 97) & (in <= 122)) | (in == '-')) [[likely]] { ------------------ | Branch (251:13): [True: 79.5k, False: 17.4k] ------------------ 252| 79.5k| return true; 253| | /* Second is upper case alpha */ 254| 79.5k| } else if ((in >= 65) & (in <= 90)) [[unlikely]] { ------------------ | Branch (254:20): [True: 687, False: 16.8k] ------------------ 255| 687| in |= 32; 256| 687| return true; 257| | /* These are rarely used but still valid */ 258| 16.8k| } else if (isUnlikelyFieldNameByte(in)) [[unlikely]] { ------------------ | Branch (258:20): [True: 7.56k, False: 9.24k] ------------------ 259| 7.56k| return true; 260| 7.56k| } 261| 9.24k| return false; 262| 97.0k| } _ZN3uWS10HttpParser23isUnlikelyFieldNameByteEh: 243| 16.8k| { 244| | /* Digits and 14 of the 15 non-alphanum characters (lacking hyphen) */ 245| 16.8k| return ((c == '~') | (c == '|') | (c == '`') | (c == '_') | (c == '^') | (c == '.') | (c == '+') ------------------ | Branch (245:16): [True: 1.83k, False: 14.9k] ------------------ 246| 16.8k| | (c == '*') | (c == '!')) || ((c >= 48) & (c <= 57)) || ((c <= 39) & (c >= 35)); ------------------ | Branch (246:43): [True: 4.35k, False: 10.6k] | Branch (246:70): [True: 1.37k, False: 9.24k] ------------------ 247| 16.8k| } _ZN3uWS10HttpParser20tryConsumeFieldValueEPc: 325| 598k| static inline void *tryConsumeFieldValue(char *p) { 326| 1.44M| for (; true; p += 8) { ------------------ | Branch (326:16): [Folded - Ignored] ------------------ 327| 1.44M| uint64_t word; 328| 1.44M| memcpy(&word, p, sizeof(uint64_t)); 329| 1.44M| if (hasLess(word, 32)) { ------------------ | Branch (329:17): [True: 598k, False: 842k] ------------------ 330| 2.11M| while (*(unsigned char *)p > 31) p++; ------------------ | Branch (330:24): [True: 1.52M, False: 598k] ------------------ 331| 598k| return (void *)p; 332| 598k| } 333| 1.44M| } 334| 598k| } _ZN3uWS11HttpRequest9getHeaderENSt3__117basic_string_viewIcNS1_11char_traitsIcEEEE: 115| 1.52M| std::string_view getHeader(std::string_view lowerCasedHeader) { 116| 1.52M| if (bf.mightHave(lowerCasedHeader)) { ------------------ | Branch (116:13): [True: 359k, False: 1.16M] ------------------ 117| 862k| for (Header *h = headers; (++h)->key.length(); ) { ------------------ | Branch (117:39): [True: 859k, False: 2.79k] ------------------ 118| 859k| if (h->key.length() == lowerCasedHeader.length() && !strncmp(h->key.data(), lowerCasedHeader.data(), lowerCasedHeader.length())) { ------------------ | Branch (118:21): [True: 359k, False: 500k] | Branch (118:69): [True: 356k, False: 2.83k] ------------------ 119| 356k| return h->value; 120| 356k| } 121| 859k| } 122| 359k| } 123| 1.17M| return std::string_view(nullptr, 0); 124| 1.52M| } _ZN3uWS10HttpParser25fenceAndConsumePostPaddedILi0EEENSt3__14pairIjPvEEPcjS4_S4_PNS_11HttpRequestERN5ofats13any_invocableIFS4_S4_S8_EEERNSA_IFS4_S4_NS2_17basic_string_viewIcNS2_11char_traitsIcEEEEbEEE: 448| 578k| std::pair fenceAndConsumePostPadded(char *data, unsigned int length, void *user, void *reserved, HttpRequest *req, MoveOnlyFunction &requestHandler, MoveOnlyFunction &dataHandler) { 449| | 450| | /* How much data we CONSUMED (to throw away) */ 451| 578k| unsigned int consumedTotal = 0; 452| 578k| unsigned int err = 0; 453| | 454| | /* Fence two bytes past end of our buffer (buffer has post padded margins). 455| | * This is to always catch scan for \r but not for \r\n. */ 456| 578k| data[length] = '\r'; 457| 578k| data[length + 1] = 'a'; /* Anything that is not \n, to trigger "invalid request" */ 458| | 459| 584k| for (unsigned int consumed; length && (consumed = getHeaders(data, data + length, req->headers, reserved, err)); ) { ------------------ | Branch (459:37): [True: 582k, False: 1.81k] | Branch (459:47): [True: 169k, False: 412k] ------------------ 460| 169k| data += consumed; 461| 169k| length -= consumed; 462| 169k| consumedTotal += consumed; 463| | 464| | /* Even if we could parse it, check for length here as well */ 465| 169k| if (consumed > MAX_FALLBACK_SIZE) { ------------------ | Branch (465:17): [True: 0, False: 169k] ------------------ 466| 0| return {HTTP_ERROR_431_REQUEST_HEADER_FIELDS_TOO_LARGE, FULLPTR}; 467| 0| } 468| | 469| | /* Store HTTP version (ancient 1.0 or 1.1) */ 470| 169k| req->ancientHttp = false; 471| | 472| | /* Add all headers to bloom filter */ 473| 169k| req->bf.reset(); 474| 671k| for (HttpRequest::Header *h = req->headers; (++h)->key.length(); ) { ------------------ | Branch (474:57): [True: 501k, False: 169k] ------------------ 475| 501k| req->bf.add(h->key); 476| 501k| } 477| | 478| | /* Break if no host header (but we can have empty string which is different from nullptr) */ 479| 169k| if (!req->getHeader("host").data()) { ------------------ | Branch (479:17): [True: 607, False: 168k] ------------------ 480| 607| return {HTTP_ERROR_400_BAD_REQUEST, FULLPTR}; 481| 607| } 482| | 483| | /* RFC 9112 6.3 484| | * If a message is received with both a Transfer-Encoding and a Content-Length header field, 485| | * the Transfer-Encoding overrides the Content-Length. Such a message might indicate an attempt 486| | * to perform request smuggling (Section 11.2) or response splitting (Section 11.1) and 487| | * ought to be handled as an error. */ 488| 168k| std::string_view transferEncodingString = req->getHeader("transfer-encoding"); 489| 168k| std::string_view contentLengthString = req->getHeader("content-length"); 490| 168k| if (transferEncodingString.length() && contentLengthString.length()) { ------------------ | Branch (490:17): [True: 0, False: 168k] | Branch (490:52): [True: 0, False: 0] ------------------ 491| | /* Returning fullptr is the same as calling the errorHandler */ 492| | /* We could be smart and set an error in the context along with this, to indicate what 493| | * http error response we might want to return */ 494| 0| return {HTTP_ERROR_400_BAD_REQUEST, FULLPTR}; 495| 0| } 496| | 497| | /* Parse query */ 498| 168k| const char *querySeparatorPtr = (const char *) memchr(req->headers->value.data(), '?', req->headers->value.length()); 499| 168k| req->querySeparator = (unsigned int) ((querySeparatorPtr ? querySeparatorPtr : req->headers->value.data() + req->headers->value.length()) - req->headers->value.data()); ------------------ | Branch (499:52): [True: 21.5k, False: 147k] ------------------ 500| | 501| | /* If returned socket is not what we put in we need 502| | * to break here as we either have upgraded to 503| | * WebSockets or otherwise closed the socket. */ 504| 168k| void *returnedUser = requestHandler(user, req); 505| 168k| if (returnedUser != user) { ------------------ | Branch (505:17): [True: 162k, False: 5.95k] ------------------ 506| | /* We are upgraded to WebSocket or otherwise broken */ 507| 162k| return {consumedTotal, returnedUser}; 508| 162k| } 509| | 510| | /* The rules at play here according to RFC 9112 for requests are essentially: 511| | * If both content-length and transfer-encoding then invalid message; must break. 512| | * If has transfer-encoding then must be chunked regardless of value. 513| | * If content-length then fixed length even if 0. 514| | * If none of the above then fixed length is 0. */ 515| | 516| | /* RFC 9112 6.3 517| | * If a message is received with both a Transfer-Encoding and a Content-Length header field, 518| | * the Transfer-Encoding overrides the Content-Length. */ 519| 5.95k| if (transferEncodingString.length()) { ------------------ | Branch (519:17): [True: 0, False: 5.95k] ------------------ 520| | 521| | /* If a proxy sent us the transfer-encoding header that 100% means it must be chunked or else the proxy is 522| | * not RFC 9112 compliant. Therefore it is always better to assume this is the case, since that entirely eliminates 523| | * all forms of transfer-encoding obfuscation tricks. We just rely on the header. */ 524| | 525| | /* RFC 9112 6.3 526| | * If a Transfer-Encoding header field is present in a request and the chunked transfer coding is not the 527| | * final encoding, the message body length cannot be determined reliably; the server MUST respond with the 528| | * 400 (Bad Request) status code and then close the connection. */ 529| | 530| | /* In this case we fail later by having the wrong interpretation (assuming chunked). 531| | * This could be made stricter but makes no difference either way, unless forwarding the identical message as a proxy. */ 532| | 533| 0| remainingStreamingBytes = STATE_IS_CHUNKED; 534| | /* If consume minimally, we do not want to consume anything but we want to mark this as being chunked */ 535| 0| if (!CONSUME_MINIMALLY) { ------------------ | Branch (535:21): [Folded - Ignored] ------------------ 536| | /* Go ahead and parse it (todo: better heuristics for emitting FIN to the app level) */ 537| 0| std::string_view dataToConsume(data, length); 538| 0| for (auto chunk : uWS::ChunkIterator(&dataToConsume, &remainingStreamingBytes)) { ------------------ | Branch (538:37): [True: 0, False: 0] ------------------ 539| 0| dataHandler(user, chunk, chunk.length() == 0); 540| 0| } 541| 0| if (isParsingInvalidChunkedEncoding(remainingStreamingBytes)) { ------------------ | Branch (541:25): [True: 0, False: 0] ------------------ 542| 0| return {HTTP_ERROR_400_BAD_REQUEST, FULLPTR}; 543| 0| } 544| 0| unsigned int consumed = (length - (unsigned int) dataToConsume.length()); 545| 0| data = (char *) dataToConsume.data(); 546| 0| length = (unsigned int) dataToConsume.length(); 547| 0| consumedTotal += consumed; 548| 0| } 549| 5.95k| } else if (contentLengthString.length()) { ------------------ | Branch (549:24): [True: 0, False: 5.95k] ------------------ 550| 0| remainingStreamingBytes = toUnsignedInteger(contentLengthString); 551| 0| if (remainingStreamingBytes == UINT64_MAX) { ------------------ | Branch (551:21): [True: 0, False: 0] ------------------ 552| | /* Parser error */ 553| 0| return {HTTP_ERROR_400_BAD_REQUEST, FULLPTR}; 554| 0| } 555| | 556| 0| if (!CONSUME_MINIMALLY) { ------------------ | Branch (556:21): [Folded - Ignored] ------------------ 557| 0| unsigned int emittable = (unsigned int) std::min(remainingStreamingBytes, length); 558| 0| dataHandler(user, std::string_view(data, emittable), emittable == remainingStreamingBytes); 559| 0| remainingStreamingBytes -= emittable; 560| | 561| 0| data += emittable; 562| 0| length -= emittable; 563| 0| consumedTotal += emittable; 564| 0| } 565| 5.95k| } else { 566| | /* If we came here without a body; emit an empty data chunk to signal no data */ 567| 5.95k| dataHandler(user, {}, true); 568| 5.95k| } 569| | 570| | /* Consume minimally should break as easrly as possible */ 571| 5.95k| if (CONSUME_MINIMALLY) { ------------------ | Branch (571:17): [Folded - Ignored] ------------------ 572| 0| break; 573| 0| } 574| 5.95k| } 575| | /* Whenever we return FULLPTR, the interpretation of "consumed" should be the HttpError enum. */ 576| 414k| if (err) { ------------------ | Branch (576:13): [True: 397k, False: 17.2k] ------------------ 577| 397k| return {err, FULLPTR}; 578| 397k| } 579| 17.2k| return {consumedTotal, user}; 580| 414k| } _ZN3uWS11HttpRequest9isAncientEv: 72| 171k| bool isAncient() { 73| 171k| return ancientHttp; 74| 171k| } _ZN3uWS11HttpRequest22getCaseSensitiveMethodEv: 135| 171k| std::string_view getCaseSensitiveMethod() { 136| 171k| return std::string_view(headers->key.data(), headers->key.length()); 137| 171k| } _ZN3uWS11HttpRequest6getUrlEv: 126| 171k| std::string_view getUrl() { 127| 171k| return std::string_view(headers->value.data(), querySeparator); 128| 171k| } _ZN3uWS11HttpRequest8setYieldEb: 111| 181k| void setYield(bool yield) { 112| 181k| didYield = yield; 113| 181k| } _ZN3uWS11HttpRequest13setParametersENSt3__14pairIiPNS1_17basic_string_viewIcNS1_11char_traitsIcEEEEEE: 166| 176k| void setParameters(std::pair parameters) { 167| 176k| currentParameters = parameters; 168| 176k| } _ZN3uWS11HttpRequest19setParameterOffsetsEPNSt3__13mapINS1_12basic_stringIcNS1_11char_traitsIcEENS1_9allocatorIcEEEEtNS1_4lessIvEENS6_INS1_4pairIKS8_tEEEEEE: 170| 176k| void setParameterOffsets(std::map> *offsets) { 171| 176k| currentParameterOffsets = offsets; 172| 176k| } _ZN3uWS11HttpRequest8getYieldEv: 76| 176k| bool getYield() { 77| 176k| return didYield; 78| 176k| } _ZN3uWS12HttpResponseILb0EE12hasRespondedEv: 490| 15.1k| bool hasResponded() { 491| 15.1k| HttpResponseData *httpResponseData = getHttpResponseData(); 492| | 493| 15.1k| return !(httpResponseData->state & HttpResponseData::HTTP_RESPONSE_PENDING); 494| 15.1k| } _ZN3uWS12HttpResponseILb0EE19getHttpResponseDataEv: 52| 1.69M| HttpResponseData *getHttpResponseData() { 53| 1.69M| return (HttpResponseData *) Super::getAsyncSocketData(); 54| 1.69M| } _ZN3uWS12HttpResponseILb0EE13writeContinueEv: 377| 197| HttpResponse *writeContinue() { 378| 197| Super::write("HTTP/1.1 100 Continue\r\n\r\n", 25); 379| 197| return this; 380| 197| } _ZN3uWS12HttpResponseILb0EE11writeStatusENSt3__117basic_string_viewIcNS2_11char_traitsIcEEEE: 383| 1.18M| HttpResponse *writeStatus(std::string_view status) { 384| 1.18M| HttpResponseData *httpResponseData = getHttpResponseData(); 385| | 386| | /* Do not allow writing more than one status */ 387| 1.18M| if (httpResponseData->state & HttpResponseData::HTTP_STATUS_CALLED) { ------------------ | Branch (387:13): [True: 1.01M, False: 171k] ------------------ 388| 1.01M| return this; 389| 1.01M| } 390| | 391| | /* Update status */ 392| 171k| httpResponseData->state |= HttpResponseData::HTTP_STATUS_CALLED; 393| | 394| 171k| Super::write("HTTP/1.1 ", 9); 395| 171k| Super::write(status.data(), (int) status.length()); 396| 171k| Super::write("\r\n", 2); 397| 171k| return this; 398| 1.18M| } _ZN3uWS12HttpResponseILb0EE3endENSt3__117basic_string_viewIcNS2_11char_traitsIcEEEEb: 432| 7.55k| void end(std::string_view data = {}, bool closeConnection = false) { 433| 7.55k| internalEnd(data, data.length(), false, true, closeConnection); 434| 7.55k| } _ZN3uWS12HttpResponseILb0EE11internalEndENSt3__117basic_string_viewIcNS2_11char_traitsIcEEEEmbbb: 92| 171k| bool internalEnd(std::string_view data, uintmax_t totalSize, bool optional, bool allowContentLength = true, bool closeConnection = false) { 93| | /* Write status if not already done */ 94| 171k| writeStatus(HTTP_200_OK); 95| | 96| | /* If no total size given then assume this chunk is everything */ 97| 171k| if (!totalSize) { ------------------ | Branch (97:13): [True: 164k, False: 7.55k] ------------------ 98| 164k| totalSize = data.length(); 99| 164k| } 100| | 101| 171k| HttpResponseData *httpResponseData = getHttpResponseData(); 102| | 103| | /* In some cases, such as when refusing huge data we want to close the connection when drained */ 104| 171k| if (closeConnection) { ------------------ | Branch (104:13): [True: 0, False: 171k] ------------------ 105| | 106| | /* HTTP 1.1 must send this back unless the client already sent it to us. 107| | * It is a connection close when either of the two parties say so but the 108| | * one party must tell the other one so. 109| | * 110| | * This check also serves to limit writing the header only once. */ 111| 0| if ((httpResponseData->state & HttpResponseData::HTTP_CONNECTION_CLOSE) == 0) { ------------------ | Branch (111:17): [True: 0, False: 0] ------------------ 112| 0| writeHeader("Connection", "close"); 113| 0| } 114| | 115| 0| httpResponseData->state |= HttpResponseData::HTTP_CONNECTION_CLOSE; 116| 0| } 117| | 118| 171k| if (httpResponseData->state & HttpResponseData::HTTP_WRITE_CALLED) { ------------------ | Branch (118:13): [True: 0, False: 171k] ------------------ 119| | 120| | /* We do not have tryWrite-like functionalities, so ignore optional in this path */ 121| | 122| | /* Do not allow sending 0 chunk here */ 123| 0| if (data.length()) { ------------------ | Branch (123:17): [True: 0, False: 0] ------------------ 124| 0| Super::write("\r\n", 2); 125| 0| writeUnsignedHex((unsigned int) data.length()); 126| 0| Super::write("\r\n", 2); 127| | 128| | /* Ignoring optional for now */ 129| 0| Super::write(data.data(), (int) data.length()); 130| 0| } 131| | 132| | /* Terminating 0 chunk */ 133| 0| Super::write("\r\n0\r\n\r\n", 7); 134| | 135| 0| httpResponseData->markDone(); 136| | 137| | /* We need to check if we should close this socket here now */ 138| 0| if (!Super::isCorked()) { ------------------ | Branch (138:17): [True: 0, False: 0] ------------------ 139| 0| if (httpResponseData->state & HttpResponseData::HTTP_CONNECTION_CLOSE) { ------------------ | Branch (139:21): [True: 0, False: 0] ------------------ 140| 0| if ((httpResponseData->state & HttpResponseData::HTTP_RESPONSE_PENDING) == 0) { ------------------ | Branch (140:25): [True: 0, False: 0] ------------------ 141| 0| if (((AsyncSocket *) this)->getBufferedAmount() == 0) { ------------------ | Branch (141:29): [True: 0, False: 0] ------------------ 142| 0| ((AsyncSocket *) this)->shutdown(); 143| | /* We need to force close after sending FIN since we want to hinder 144| | * clients from keeping to send their huge data */ 145| 0| ((AsyncSocket *) this)->close(); 146| 0| return true; 147| 0| } 148| 0| } 149| 0| } 150| 0| } 151| | 152| | /* tryEnd can never fail when in chunked mode, since we do not have tryWrite (yet), only write */ 153| 0| Super::timeout(HTTP_TIMEOUT_S); 154| 0| return true; 155| 171k| } else { 156| | /* Write content-length on first call */ 157| 171k| if (!(httpResponseData->state & HttpResponseData::HTTP_END_CALLED)) { ------------------ | Branch (157:17): [True: 171k, False: 0] ------------------ 158| | /* Write mark, this propagates to WebSockets too */ 159| 171k| writeMark(); 160| | 161| | /* WebSocket upgrades does not allow content-length */ 162| 171k| if (allowContentLength) { ------------------ | Branch (162:21): [True: 7.55k, False: 164k] ------------------ 163| | /* Even zero is a valid content-length */ 164| 7.55k| Super::write("Content-Length: ", 16); 165| 7.55k| writeUnsigned64(totalSize); 166| 7.55k| Super::write("\r\n\r\n", 4); 167| 164k| } else { 168| 164k| Super::write("\r\n", 2); 169| 164k| } 170| | 171| | /* Mark end called */ 172| 171k| httpResponseData->state |= HttpResponseData::HTTP_END_CALLED; 173| 171k| } 174| | 175| | /* Even if we supply no new data to write, its failed boolean is useful to know 176| | * if it failed to drain any prior failed header writes */ 177| | 178| | /* Write as much as possible without causing backpressure */ 179| 171k| size_t written = 0; 180| 171k| bool failed = false; 181| 179k| while (written < data.length() && !failed) { ------------------ | Branch (181:20): [True: 7.55k, False: 171k] | Branch (181:47): [True: 7.55k, False: 0] ------------------ 182| | /* uSockets only deals with int sizes, so pass chunks of max signed int size */ 183| 7.55k| auto writtenFailed = Super::write(data.data() + written, (int) std::min(data.length() - written, INT_MAX), optional); 184| | 185| 7.55k| written += (size_t) writtenFailed.first; 186| 7.55k| failed = writtenFailed.second; 187| 7.55k| } 188| | 189| 171k| httpResponseData->offset += written; 190| | 191| | /* Success is when we wrote the entire thing without any failures */ 192| 171k| bool success = written == data.length() && !failed; ------------------ | Branch (192:28): [True: 171k, False: 0] | Branch (192:56): [True: 171k, False: 453] ------------------ 193| | 194| | /* If we are now at the end, start a timeout. Also start a timeout if we failed. */ 195| 171k| if (!success || httpResponseData->offset == totalSize) { ------------------ | Branch (195:17): [True: 453, False: 171k] | Branch (195:29): [True: 171k, False: 0] ------------------ 196| 171k| Super::timeout(HTTP_TIMEOUT_S); 197| 171k| } 198| | 199| | /* Remove onAborted function if we reach the end */ 200| 171k| if (httpResponseData->offset == totalSize) { ------------------ | Branch (200:17): [True: 171k, False: 0] ------------------ 201| 171k| httpResponseData->markDone(); 202| | 203| | /* We need to check if we should close this socket here now */ 204| 171k| if (!Super::isCorked()) { ------------------ | Branch (204:21): [True: 0, False: 171k] ------------------ 205| 0| if (httpResponseData->state & HttpResponseData::HTTP_CONNECTION_CLOSE) { ------------------ | Branch (205:25): [True: 0, False: 0] ------------------ 206| 0| if ((httpResponseData->state & HttpResponseData::HTTP_RESPONSE_PENDING) == 0) { ------------------ | Branch (206:29): [True: 0, False: 0] ------------------ 207| 0| if (((AsyncSocket *) this)->getBufferedAmount() == 0) { ------------------ | Branch (207:33): [True: 0, False: 0] ------------------ 208| 0| ((AsyncSocket *) this)->shutdown(); 209| | /* We need to force close after sending FIN since we want to hinder 210| | * clients from keeping to send their huge data */ 211| 0| ((AsyncSocket *) this)->close(); 212| 0| } 213| 0| } 214| 0| } 215| 0| } 216| 171k| } 217| | 218| 171k| return success; 219| 171k| } 220| 171k| } _ZN3uWS12HttpResponseILb0EE11writeHeaderENSt3__117basic_string_viewIcNS2_11char_traitsIcEEEES6_: 401| 840k| HttpResponse *writeHeader(std::string_view key, std::string_view value) { 402| 840k| writeStatus(HTTP_200_OK); 403| | 404| 840k| Super::write(key.data(), (int) key.length()); 405| 840k| Super::write(": ", 2); 406| 840k| Super::write(value.data(), (int) value.length()); 407| 840k| Super::write("\r\n", 2); 408| 840k| return this; 409| 840k| } _ZN3uWS12HttpResponseILb0EE9writeMarkEv: 77| 171k| void writeMark() { 78| | /* Date is always written */ 79| 171k| writeHeader("Date", std::string_view(((LoopData *) us_loop_ext(us_socket_context_loop(SSL, (us_socket_context(SSL, (us_socket_t *) this)))))->date, 29)); 80| | 81| | /* You can disable this altogether */ 82| 171k|#ifndef UWS_HTTPRESPONSE_NO_WRITEMARK 83| 171k| if (!Super::getLoopData()->noMark) { ------------------ | Branch (83:13): [True: 171k, False: 0] ------------------ 84| | /* We only expose major version */ 85| 171k| writeHeader("uWebSockets", "20"); 86| 171k| } 87| 171k|#endif 88| 171k| } _ZN3uWS12HttpResponseILb0EE15writeUnsigned64Em: 68| 7.55k| void writeUnsigned64(uint64_t value) { 69| 7.55k| char buf[20]; 70| 7.55k| int length = utils::u64toa(value, buf); 71| | 72| | /* For now we do this copy */ 73| 7.55k| Super::write(buf, length); 74| 7.55k| } EpollEchoServer.cpp:_ZN3uWS12HttpResponseILb0EE7upgradeIZ4testvE13PerSocketDataEEvOT_NSt3__117basic_string_viewIcNS6_11char_traitsIcEEEESA_SA_P19us_socket_context_t: 239| 164k| struct us_socket_context_t *webSocketContext) { 240| | 241| | /* Extract needed parameters from WebSocketContextData */ 242| 164k| WebSocketContextData *webSocketContextData = (WebSocketContextData *) us_socket_context_ext(SSL, webSocketContext); 243| | 244| | /* Note: OpenSSL can be used here to speed this up somewhat */ 245| 164k| char secWebSocketAccept[29] = {}; 246| 164k| WebSocketHandshake::generate(secWebSocketKey.data(), secWebSocketAccept); 247| | 248| 164k| writeStatus("101 Switching Protocols") 249| 164k| ->writeHeader("Upgrade", "websocket") 250| 164k| ->writeHeader("Connection", "Upgrade") 251| 164k| ->writeHeader("Sec-WebSocket-Accept", secWebSocketAccept); 252| | 253| | /* Select first subprotocol if present */ 254| 164k| if (secWebSocketProtocol.length()) { ------------------ | Branch (254:13): [True: 411, False: 163k] ------------------ 255| 411| writeHeader("Sec-WebSocket-Protocol", secWebSocketProtocol.substr(0, secWebSocketProtocol.find(','))); 256| 411| } 257| | 258| | /* Negotiate compression */ 259| 164k| bool perMessageDeflate = false; 260| 164k| CompressOptions compressOptions = CompressOptions::DISABLED; 261| 164k| if (secWebSocketExtensions.length() && webSocketContextData->compression != DISABLED) { ------------------ | Branch (261:13): [True: 8.44k, False: 155k] | Branch (261:48): [True: 8.07k, False: 374] ------------------ 262| | 263| | /* Make sure to map SHARED_DECOMPRESSOR to windowBits = 0, not 1 */ 264| 8.07k| int wantedInflationWindow = 0; 265| 8.07k| if ((webSocketContextData->compression & CompressOptions::_DECOMPRESSOR_MASK) != CompressOptions::SHARED_DECOMPRESSOR) { ------------------ | Branch (265:17): [True: 8.07k, False: 0] ------------------ 266| 8.07k| wantedInflationWindow = (webSocketContextData->compression & CompressOptions::_DECOMPRESSOR_MASK) >> 8; 267| 8.07k| } 268| | 269| | /* Map from selected compressor (this automatically maps SHARED_COMPRESSOR to windowBits 0, not 1) */ 270| 8.07k| int wantedCompressionWindow = (webSocketContextData->compression & CompressOptions::_COMPRESSOR_MASK) >> 4; 271| | 272| 8.07k| auto [negCompression, negCompressionWindow, negInflationWindow, negResponse] = 273| 8.07k| negotiateCompression(true, wantedCompressionWindow, wantedInflationWindow, 274| 8.07k| secWebSocketExtensions); 275| | 276| 8.07k| if (negCompression) { ------------------ | Branch (276:17): [True: 3.71k, False: 4.36k] ------------------ 277| 3.71k| perMessageDeflate = true; 278| | 279| | /* Map from negotiated windowBits to compressor and decompressor */ 280| 3.71k| if (negCompressionWindow == 0) { ------------------ | Branch (280:21): [True: 1.50k, False: 2.21k] ------------------ 281| 1.50k| compressOptions = CompressOptions::SHARED_COMPRESSOR; 282| 2.21k| } else { 283| 2.21k| compressOptions = (CompressOptions) ((uint32_t) (negCompressionWindow << 4) 284| 2.21k| | (uint32_t) (negCompressionWindow - 7)); 285| | 286| | /* If we are dedicated and have the 3kb then correct any 4kb to 3kb, 287| | * (they both share the windowBits = 9) */ 288| 2.21k| if (webSocketContextData->compression & DEDICATED_COMPRESSOR_3KB) { ------------------ | Branch (288:25): [True: 2.21k, False: 0] ------------------ 289| 2.21k| compressOptions = DEDICATED_COMPRESSOR_3KB; 290| 2.21k| } 291| 2.21k| } 292| | 293| | /* Here we modify the above compression with negotiated decompressor */ 294| 3.71k| if (negInflationWindow == 0) { ------------------ | Branch (294:21): [True: 3.71k, False: 0] ------------------ 295| 3.71k| compressOptions = CompressOptions(compressOptions | CompressOptions::SHARED_DECOMPRESSOR); 296| 3.71k| } else { 297| 0| compressOptions = CompressOptions(compressOptions | (negInflationWindow << 8)); 298| 0| } 299| | 300| 3.71k| writeHeader("Sec-WebSocket-Extensions", negResponse); 301| 3.71k| } 302| 8.07k| } 303| | 304| 164k| internalEnd({nullptr, 0}, 0, false, false); 305| | 306| | /* Grab the httpContext from res */ 307| 164k| HttpContext *httpContext = (HttpContext *) us_socket_context(SSL, (struct us_socket_t *) this); 308| | 309| | /* Move any backpressure out of HttpResponse */ 310| 164k| BackPressure backpressure(std::move(((AsyncSocketData *) getHttpResponseData())->buffer)); 311| | 312| | /* Destroy HttpResponseData */ 313| 164k| getHttpResponseData()->~HttpResponseData(); 314| | 315| | /* Before we adopt and potentially change socket, check if we are corked */ 316| 164k| bool wasCorked = Super::isCorked(); 317| | 318| | /* Adopting a socket invalidates it, do not rely on it directly to carry any data */ 319| 164k| WebSocket *webSocket = (WebSocket *) us_socket_context_adopt_socket(SSL, 320| 164k| (us_socket_context_t *) webSocketContext, (us_socket_t *) this, sizeof(WebSocketData) + sizeof(UserData)); 321| | 322| | /* For whatever reason we were corked, update cork to the new socket */ 323| 164k| if (wasCorked) { ------------------ | Branch (323:13): [True: 164k, False: 0] ------------------ 324| 164k| webSocket->AsyncSocket::corkUnchecked(); 325| 164k| } 326| | 327| | /* Initialize websocket with any moved backpressure intact */ 328| 164k| webSocket->init(perMessageDeflate, compressOptions, std::move(backpressure)); 329| | 330| | /* We should only mark this if inside the parser; if upgrading "async" we cannot set this */ 331| 164k| HttpContextData *httpContextData = httpContext->getSocketContextData(); 332| 164k| if (httpContextData->isParsingHttp) { ------------------ | Branch (332:13): [True: 164k, False: 0] ------------------ 333| | /* We need to tell the Http parser that we changed socket */ 334| 164k| httpContextData->upgradedWebSocket = webSocket; 335| 164k| } 336| | 337| | /* Arm maxLifetime timeout */ 338| 164k| us_socket_long_timeout(SSL, (us_socket_t *) webSocket, webSocketContextData->maxLifetime); 339| | 340| | /* Arm idleTimeout */ 341| 164k| us_socket_timeout(SSL, (us_socket_t *) webSocket, webSocketContextData->idleTimeoutComponents.first); 342| | 343| | /* Move construct the UserData right before calling open handler */ 344| 164k| new (webSocket->getUserData()) UserData(std::move(userData)); 345| | 346| | /* Emit open event and start the timeout */ 347| 164k| if (webSocketContextData->openHandler) { ------------------ | Branch (347:13): [True: 164k, False: 0] ------------------ 348| 164k| webSocketContextData->openHandler(webSocket); 349| 164k| } 350| 164k| } _ZN3uWS16HttpResponseDataILb0EE8markDoneEv: 37| 171k| void markDone() { 38| 171k| onAborted = nullptr; 39| | /* Also remove onWritable so that we do not emit when draining behind the scenes. */ 40| 171k| onWritable = nullptr; 41| | 42| | /* We are done with this request */ 43| 171k| state &= ~HttpResponseData::HTTP_RESPONSE_PENDING; 44| 171k| } _ZN3uWS10HttpRouterINS_15HttpContextDataILb0EE10RouterDataEEC2Ev: 243| 5.84k| HttpRouter() { 244| | /* Always have ANY route */ 245| 5.84k| getNode(&root, std::string(ANY_METHOD_TOKEN.data(), ANY_METHOD_TOKEN.length()), false); 246| 5.84k| } _ZN3uWS10HttpRouterINS_15HttpContextDataILb0EE10RouterDataEE4NodeC2ENSt3__112basic_stringIcNS6_11char_traitsIcEENS6_9allocatorIcEEEE: 63| 35.0k| Node(std::string name) : name(name) {} _ZN3uWS10HttpRouterINS_15HttpContextDataILb0EE10RouterDataEE7getNodeEPNS4_4NodeENSt3__112basic_stringIcNS7_11char_traitsIcEENS7_9allocatorIcEEEEb: 81| 40.9k| Node *getNode(Node *parent, std::string child, bool isHighPriority) { 82| 40.9k| for (std::unique_ptr &node : parent->children) { ------------------ | Branch (82:42): [True: 23.3k, False: 29.2k] ------------------ 83| 23.3k| if (node->name == child && node->isHighPriority == isHighPriority) { ------------------ | Branch (83:17): [True: 11.6k, False: 11.6k] | Branch (83:40): [True: 11.6k, False: 0] ------------------ 84| 11.6k| return node.get(); 85| 11.6k| } 86| 23.3k| } 87| | 88| | /* Insert sorted, but keep order if parent is root (we sort methods by priority elsewhere) */ 89| 29.2k| std::unique_ptr newNode(new Node(child)); 90| 29.2k| newNode->isHighPriority = isHighPriority; 91| 29.2k| return parent->children.emplace(std::upper_bound(parent->children.begin(), parent->children.end(), newNode, [parent, this](auto &a, auto &b) { 92| | 93| 29.2k| if (a->isHighPriority != b->isHighPriority) { 94| 29.2k| return a->isHighPriority; 95| 29.2k| } 96| | 97| 29.2k| return b->name.length() && (parent != &root) && (lexicalOrder(b->name) < lexicalOrder(a->name)); 98| 29.2k| }), std::move(newNode))->get(); 99| 40.9k| } _ZZN3uWS10HttpRouterINS_15HttpContextDataILb0EE10RouterDataEE7getNodeEPNS4_4NodeENSt3__112basic_stringIcNS7_11char_traitsIcEENS7_9allocatorIcEEEEbENKUlRT_RT0_E_clIKNS7_10unique_ptrIS5_NS7_14default_deleteIS5_EEEESN_EEDaSF_SH_: 91| 11.6k| return parent->children.emplace(std::upper_bound(parent->children.begin(), parent->children.end(), newNode, [parent, this](auto &a, auto &b) { 92| | 93| 11.6k| if (a->isHighPriority != b->isHighPriority) { ------------------ | Branch (93:17): [True: 0, False: 11.6k] ------------------ 94| 0| return a->isHighPriority; 95| 0| } 96| | 97| 11.6k| return b->name.length() && (parent != &root) && (lexicalOrder(b->name) < lexicalOrder(a->name)); ------------------ | Branch (97:20): [True: 11.6k, False: 0] | Branch (97:40): [True: 5.84k, False: 5.84k] | Branch (97:61): [True: 0, False: 5.84k] ------------------ 98| 11.6k| }), std::move(newNode))->get(); _ZN3uWS10HttpRouterINS_15HttpContextDataILb0EE10RouterDataEE12lexicalOrderERNSt3__112basic_stringIcNS5_11char_traitsIcEENS5_9allocatorIcEEEE: 67| 11.6k| int lexicalOrder(std::string &name) { 68| 11.6k| if (!name.length()) { ------------------ | Branch (68:13): [True: 0, False: 11.6k] ------------------ 69| 0| return 2; 70| 0| } 71| 11.6k| if (name[0] == ':') { ------------------ | Branch (71:13): [True: 0, False: 11.6k] ------------------ 72| 0| return 1; 73| 0| } 74| 11.6k| if (name[0] == '*') { ------------------ | Branch (74:13): [True: 5.84k, False: 5.84k] ------------------ 75| 5.84k| return 0; 76| 5.84k| } 77| 5.84k| return 2; 78| 11.6k| } _ZN3uWS10HttpRouterINS_15HttpContextDataILb0EE10RouterDataEE11getUserDataEv: 252| 348k| USERDATA &getUserData() { 253| 348k| return userData; 254| 348k| } _ZN3uWS10HttpRouterINS_15HttpContextDataILb0EE10RouterDataEE5routeENSt3__117basic_string_viewIcNS5_11char_traitsIcEEEES9_: 257| 171k| bool route(std::string_view method, std::string_view url) { 258| | /* Reset url parsing cache */ 259| 171k| setUrl(url); 260| 171k| routeParameters.reset(); 261| | 262| | /* Begin by finding the method node */ 263| 176k| for (auto &p : root.children) { ------------------ | Branch (263:22): [True: 176k, False: 4.59k] ------------------ 264| 176k| if (p->name == method) { ------------------ | Branch (264:17): [True: 167k, False: 9.18k] ------------------ 265| | /* Then route the url */ 266| 167k| if (executeHandlers(p.get(), 0, userData)) { ------------------ | Branch (266:21): [True: 164k, False: 2.95k] ------------------ 267| 164k| return true; 268| 164k| } else { 269| 2.95k| break; 270| 2.95k| } 271| 167k| } 272| 176k| } 273| | 274| | /* Always test any route last */ 275| 7.55k| return executeHandlers(root.children.back().get(), 0, userData); 276| 171k| } _ZN3uWS10HttpRouterINS_15HttpContextDataILb0EE10RouterDataEE6setUrlENSt3__117basic_string_viewIcNS5_11char_traitsIcEEEE: 124| 201k| inline void setUrl(std::string_view url) { 125| | 126| | /* Todo: URL may also start with "http://domain/" or "*", not only "/" */ 127| | 128| | /* We expect to stand on a slash */ 129| 201k| currentUrl = url; 130| 201k| urlSegmentTop = -1; 131| 201k| } _ZN3uWS10HttpRouterINS_15HttpContextDataILb0EE10RouterDataEE15RouteParameters5resetEv: 108| 171k| void reset() { 109| 171k| paramsTop = -1; 110| 171k| } _ZN3uWS10HttpRouterINS_15HttpContextDataILb0EE10RouterDataEE15executeHandlersEPNS4_4NodeEiRS3_: 168| 307k| bool executeHandlers(Node *parent, int urlSegment, USERDATA &userData) { 169| | 170| 307k| auto [segment, isStop] = getUrlSegment(urlSegment); 171| | 172| | /* If we are on STOP, return where we may stand */ 173| 307k| if (isStop) { ------------------ | Branch (173:13): [True: 132k, False: 175k] ------------------ 174| | /* We have reached accross the entire URL with no stoppage, execute */ 175| 132k| for (uint32_t handler : parent->handlers) { ------------------ | Branch (175:35): [True: 132k, False: 1.83k] ------------------ 176| 132k| if (handlers[handler & HANDLER_MASK](this)) { ------------------ | Branch (176:21): [True: 130k, False: 1.83k] ------------------ 177| 130k| return true; 178| 130k| } 179| 132k| } 180| | /* We reached the end, so go back */ 181| 1.83k| return false; 182| 132k| } 183| | 184| 211k| for (auto &p : parent->children) { ------------------ | Branch (184:22): [True: 211k, False: 3.38k] ------------------ 185| 211k| if (p->name.length() && p->name[0] == '*') { ------------------ | Branch (185:17): [True: 211k, False: 0] | Branch (185:37): [True: 44.3k, False: 167k] ------------------ 186| | /* Wildcard match (can be seen as a shortcut) */ 187| 44.3k| for (uint32_t handler : p->handlers) { ------------------ | Branch (187:39): [True: 44.3k, False: 2.95k] ------------------ 188| 44.3k| if (handlers[handler & HANDLER_MASK](this)) { ------------------ | Branch (188:25): [True: 41.3k, False: 2.95k] ------------------ 189| 41.3k| return true; 190| 41.3k| } 191| 44.3k| } 192| 167k| } else if (p->name.length() && p->name[0] == ':' && segment.length()) { ------------------ | Branch (192:24): [True: 167k, False: 0] | Branch (192:44): [True: 0, False: 167k] | Branch (192:65): [True: 0, False: 0] ------------------ 193| | /* Parameter match */ 194| 0| routeParameters.push(segment); 195| 0| if (executeHandlers(p.get(), urlSegment + 1, userData)) { ------------------ | Branch (195:21): [True: 0, False: 0] ------------------ 196| 0| return true; 197| 0| } 198| 0| routeParameters.pop(); 199| 167k| } else if (p->name == segment) { ------------------ | Branch (199:24): [True: 132k, False: 34.5k] ------------------ 200| | /* Static match */ 201| 132k| if (executeHandlers(p.get(), urlSegment + 1, userData)) { ------------------ | Branch (201:21): [True: 130k, False: 2.25k] ------------------ 202| 130k| return true; 203| 130k| } 204| 132k| } 205| 211k| } 206| 3.38k| return false; 207| 175k| } _ZN3uWS10HttpRouterINS_15HttpContextDataILb0EE10RouterDataEE13getUrlSegmentEi: 134| 383k| inline std::pair getUrlSegment(int urlSegment) { 135| 383k| if (urlSegment > urlSegmentTop) { ------------------ | Branch (135:13): [True: 351k, False: 32.1k] ------------------ 136| | /* Signal as STOP when we have no more URL or stack space */ 137| 351k| if (!currentUrl.length() || urlSegment > int(MAX_URL_SEGMENTS - 1)) { ------------------ | Branch (137:17): [True: 149k, False: 201k] | Branch (137:41): [True: 0, False: 201k] ------------------ 138| 149k| return {{}, true}; 139| 149k| } 140| | 141| | /* We always stand on a slash here, so step over it */ 142| 201k| currentUrl.remove_prefix(1); 143| | 144| 201k| auto segmentLength = currentUrl.find('/'); 145| 201k| if (segmentLength == std::string::npos) { ------------------ | Branch (145:17): [True: 200k, False: 1.46k] ------------------ 146| 200k| segmentLength = currentUrl.length(); 147| | 148| | /* Push to url segment vector */ 149| 200k| urlSegmentVector[urlSegment] = currentUrl.substr(0, segmentLength); 150| 200k| urlSegmentTop++; 151| | 152| | /* Update currentUrl */ 153| 200k| currentUrl = currentUrl.substr(segmentLength); 154| 200k| } else { 155| | /* Push to url segment vector */ 156| 1.46k| urlSegmentVector[urlSegment] = currentUrl.substr(0, segmentLength); 157| 1.46k| urlSegmentTop++; 158| | 159| | /* Update currentUrl */ 160| 1.46k| currentUrl = currentUrl.substr(segmentLength); 161| 1.46k| } 162| 201k| } 163| | /* In any case we return it */ 164| 233k| return {urlSegmentVector[urlSegment], false}; 165| 383k| } _ZN3uWS10HttpRouterINS_15HttpContextDataILb0EE10RouterDataEE6removeENSt3__112basic_stringIcNS5_11char_traitsIcEENS5_9allocatorIcEEEESB_j: 360| 17.5k| void remove(std::string method, std::string pattern, uint32_t priority) { 361| 17.5k| uint32_t handler = findHandler(method, pattern, priority); 362| 17.5k| if (handler == UINT32_MAX) { ------------------ | Branch (362:13): [True: 17.5k, False: 0] ------------------ 363| | /* Not found or already removed, do nothing */ 364| 17.5k| return; 365| 17.5k| } 366| | 367| | /* Cull the entire tree */ 368| | /* For all nodes in depth first tree traveral; 369| | * if node contains handler - remove the handler - 370| | * if node holds no handlers after removal, remove the node and return */ 371| 0| cullNode(nullptr, &root, handler); 372| | 373| | /* Now remove the actual handler */ 374| 0| handlers.erase(handlers.begin() + (handler & HANDLER_MASK)); 375| 0| } _ZN3uWS10HttpRouterINS_15HttpContextDataILb0EE10RouterDataEE11findHandlerENSt3__112basic_stringIcNS5_11char_traitsIcEENS5_9allocatorIcEEEESB_j: 210| 17.5k| uint32_t findHandler(std::string method, std::string pattern, uint32_t priority) { 211| 17.5k| for (std::unique_ptr &node : root.children) { ------------------ | Branch (211:42): [True: 17.5k, False: 5.84k] ------------------ 212| 17.5k| if (method == node->name) { ------------------ | Branch (212:17): [True: 11.6k, False: 5.84k] ------------------ 213| 11.6k| setUrl(pattern); 214| 11.6k| Node *n = node.get(); 215| 11.6k| for (int i = 0; !getUrlSegment(i).second; i++) { ------------------ | Branch (215:33): [True: 11.6k, False: 0] ------------------ 216| | /* Go to next segment or quit */ 217| 11.6k| std::string segment = std::string(getUrlSegment(i).first); 218| 11.6k| Node *next = nullptr; 219| 11.6k| for (std::unique_ptr &child : n->children) { ------------------ | Branch (219:55): [True: 5.84k, False: 11.6k] ------------------ 220| 5.84k| if (child->name == segment && child->isHighPriority == (priority == HIGH_PRIORITY)) { ------------------ | Branch (220:29): [True: 0, False: 5.84k] | Branch (220:55): [True: 0, False: 0] ------------------ 221| 0| next = child.get(); 222| 0| break; 223| 0| } 224| 5.84k| } 225| 11.6k| if (!next) { ------------------ | Branch (225:25): [True: 11.6k, False: 0] ------------------ 226| 11.6k| return UINT32_MAX; 227| 11.6k| } 228| 0| n = next; 229| 0| } 230| | /* Seek for a priority match in the found node */ 231| 0| for (unsigned int i = 0; i < n->handlers.size(); i++) { ------------------ | Branch (231:42): [True: 0, False: 0] ------------------ 232| 0| if ((n->handlers[i] & ~HANDLER_MASK) == priority) { ------------------ | Branch (232:25): [True: 0, False: 0] ------------------ 233| 0| return n->handlers[i]; 234| 0| } 235| 0| } 236| 0| return UINT32_MAX; 237| 0| } 238| 17.5k| } 239| 5.84k| return UINT32_MAX; 240| 17.5k| } _ZN3uWS10HttpRouterINS_15HttpContextDataILb0EE10RouterDataEE3addENSt3__16vectorINS5_12basic_stringIcNS5_11char_traitsIcEENS5_9allocatorIcEEEENSA_ISC_EEEESC_ON5ofats13any_invocableIFbPS4_EEEj: 279| 17.5k| void add(std::vector methods, std::string pattern, MoveOnlyFunction &&handler, uint32_t priority = MEDIUM_PRIORITY) { 280| | /* First remove existing handler */ 281| 17.5k| remove(methods[0], pattern, priority); 282| | 283| 17.5k| for (std::string method : methods) { ------------------ | Branch (283:33): [True: 17.5k, False: 17.5k] ------------------ 284| | /* Lookup method */ 285| 17.5k| Node *node = getNode(&root, method, false); 286| | /* Iterate over all segments */ 287| 17.5k| setUrl(pattern); 288| 35.0k| for (int i = 0; !getUrlSegment(i).second; i++) { ------------------ | Branch (288:29): [True: 17.5k, False: 17.5k] ------------------ 289| 17.5k| std::string strippedSegment(getUrlSegment(i).first); 290| 17.5k| if (strippedSegment.length() && strippedSegment[0] == ':') { ------------------ | Branch (290:21): [True: 17.5k, False: 0] | Branch (290:49): [True: 0, False: 17.5k] ------------------ 291| | /* Parameter routes must be named only : */ 292| 0| strippedSegment = ":"; 293| 0| } 294| 17.5k| node = getNode(node, strippedSegment, priority == HIGH_PRIORITY); 295| 17.5k| } 296| | /* Insert handler in order sorted by priority (most significant 1 byte) */ 297| 17.5k| node->handlers.insert(std::upper_bound(node->handlers.begin(), node->handlers.end(), (uint32_t) (priority | handlers.size())), (uint32_t) (priority | handlers.size())); 298| 17.5k| } 299| | 300| | /* Alloate this handler */ 301| 17.5k| handlers.emplace_back(std::move(handler)); 302| | 303| | /* ANY method must be last, GET must be first */ 304| 17.5k| std::sort(root.children.begin(), root.children.end(), [](const auto &a, const auto &b) { 305| | /* Assuming the list of methods is unique, non-repeating */ 306| 17.5k| if (a->name == "GET") { 307| 17.5k| return true; 308| 17.5k| } else if (b->name == "GET") { 309| 17.5k| return false; 310| 17.5k| } else if (a->name == ANY_METHOD_TOKEN) { 311| 17.5k| return false; 312| 17.5k| } else if (b->name == ANY_METHOD_TOKEN) { 313| 17.5k| return true; 314| 17.5k| } else { 315| 17.5k| return a->name < b->name; 316| 17.5k| } 317| 17.5k| }); 318| 17.5k| } _ZZN3uWS10HttpRouterINS_15HttpContextDataILb0EE10RouterDataEE3addENSt3__16vectorINS5_12basic_stringIcNS5_11char_traitsIcEENS5_9allocatorIcEEEENSA_ISC_EEEESC_ON5ofats13any_invocableIFbPS4_EEEjENKUlRKT_RKT0_E_clINS5_10unique_ptrINS4_4NodeENS5_14default_deleteISU_EEEESX_EEDaSN_SQ_: 304| 11.6k| std::sort(root.children.begin(), root.children.end(), [](const auto &a, const auto &b) { 305| | /* Assuming the list of methods is unique, non-repeating */ 306| 11.6k| if (a->name == "GET") { ------------------ | Branch (306:17): [True: 5.84k, False: 5.84k] ------------------ 307| 5.84k| return true; 308| 5.84k| } else if (b->name == "GET") { ------------------ | Branch (308:24): [True: 5.84k, False: 0] ------------------ 309| 5.84k| return false; 310| 5.84k| } else if (a->name == ANY_METHOD_TOKEN) { ------------------ | Branch (310:24): [True: 0, False: 0] ------------------ 311| 0| return false; 312| 0| } else if (b->name == ANY_METHOD_TOKEN) { ------------------ | Branch (312:24): [True: 0, False: 0] ------------------ 313| 0| return true; 314| 0| } else { 315| 0| return a->name < b->name; 316| 0| } 317| 11.6k| }); _ZN3uWS10HttpRouterINS_15HttpContextDataILb0EE10RouterDataEE13getParametersEv: 248| 176k| std::pair getParameters() { 249| 176k| return {routeParameters.paramsTop, routeParameters.params}; 250| 176k| } _ZN3uWS4Loop3getEPv: 111| 60.0k| static Loop *get(void *existingNativeLoop = nullptr) { 112| 60.0k| if (!getLazyLoop().loop) { ------------------ | Branch (112:13): [True: 5.84k, False: 54.2k] ------------------ 113| | /* If we are given a native loop pointer we pass that to uSockets and let it deal with it */ 114| 5.84k| if (existingNativeLoop) { ------------------ | Branch (114:17): [True: 0, False: 5.84k] ------------------ 115| | /* Todo: here we want to pass the pointer, not a boolean */ 116| 0| getLazyLoop().loop = create(existingNativeLoop); 117| | /* We cannot register automatic free here, must be manually done */ 118| 5.84k| } else { 119| 5.84k| getLazyLoop().loop = create(nullptr); 120| 5.84k| getLazyLoop().cleanMe = true; 121| 5.84k| } 122| 5.84k| } 123| | 124| 60.0k| return getLazyLoop().loop; 125| 60.0k| } _ZN3uWS4Loop11getLazyLoopEv: 103| 137k| static LoopCleaner &getLazyLoop() { 104| 137k| static thread_local LoopCleaner lazyLoop; 105| 137k| return lazyLoop; 106| 137k| } _ZN3uWS4Loop11LoopCleanerD2Ev: 94| 1| ~LoopCleaner() { 95| 1| if(loop && cleanMe) { ------------------ | Branch (95:16): [True: 0, False: 1] | Branch (95:24): [True: 0, False: 0] ------------------ 96| 0| loop->free(); 97| 0| } 98| 1| } _ZN3uWS4Loop6createEPv: 76| 5.84k| static Loop *create(void *hint) { 77| 5.84k| Loop *loop = ((Loop *) us_create_loop(hint, wakeupCb, preCb, postCb, sizeof(LoopData)))->init(); 78| | 79| | /* We also need some timers (should live off the one 4 second timer rather) */ 80| 5.84k| LoopData *loopData = (LoopData *) us_loop_ext((struct us_loop_t *) loop); 81| 5.84k| loopData->dateTimer = us_create_timer((struct us_loop_t *) loop, 1, sizeof(LoopData *)); 82| 5.84k| memcpy(us_timer_ext(loopData->dateTimer), &loopData, sizeof(LoopData *)); 83| 5.84k| us_timer_set(loopData->dateTimer, [](struct us_timer_t *t) { 84| 5.84k| LoopData *loopData; 85| 5.84k| memcpy(&loopData, us_timer_ext(t), sizeof(LoopData *)); 86| 5.84k| loopData->updateDate(); 87| 5.84k| }, 1000, 1000); 88| | 89| 5.84k| return loop; 90| 5.84k| } _ZN3uWS4Loop8wakeupCbEP9us_loop_t: 30| 1.63M| static void wakeupCb(us_loop_t *loop) { 31| 1.63M| LoopData *loopData = (LoopData *) us_loop_ext(loop); 32| | 33| | /* Swap current deferQueue */ 34| 1.63M| loopData->deferMutex.lock(); 35| 1.63M| int oldDeferQueue = loopData->currentDeferQueue; 36| 1.63M| loopData->currentDeferQueue = (loopData->currentDeferQueue + 1) % 2; 37| 1.63M| loopData->deferMutex.unlock(); 38| | 39| | /* Drain the queue */ 40| 1.63M| for (auto &x : loopData->deferQueues[oldDeferQueue]) { ------------------ | Branch (40:22): [True: 3.78k, False: 1.63M] ------------------ 41| 3.78k| x(); 42| 3.78k| } 43| 1.63M| loopData->deferQueues[oldDeferQueue].clear(); 44| 1.63M| } _ZN3uWS4Loop5preCbEP9us_loop_t: 46| 2.18M| static void preCb(us_loop_t *loop) { 47| 2.18M| LoopData *loopData = (LoopData *) us_loop_ext(loop); 48| | 49| 2.18M| for (auto &p : loopData->preHandlers) { ------------------ | Branch (49:22): [True: 2.18M, False: 2.18M] ------------------ 50| 2.18M| p.second((Loop *) loop); 51| 2.18M| } 52| 2.18M| } _ZN3uWS4Loop6postCbEP9us_loop_t: 54| 2.18M| static void postCb(us_loop_t *loop) { 55| 2.18M| LoopData *loopData = (LoopData *) us_loop_ext(loop); 56| | 57| 2.18M| for (auto &p : loopData->postHandlers) { ------------------ | Branch (57:22): [True: 2.18M, False: 2.18M] ------------------ 58| 2.18M| p.second((Loop *) loop); 59| 2.18M| } 60| | 61| | /* After every event loop iteration, we must not hold the cork buffer */ 62| 2.18M| if (loopData->corkedSocket) { ------------------ | Branch (62:13): [True: 0, False: 2.18M] ------------------ 63| 0| std::cerr << "Error: Cork buffer must not be held across event loop iterations!" << std::endl; 64| 0| std::terminate(); 65| 0| } 66| 2.18M| } _ZN3uWS4Loop4initEv: 71| 5.84k| Loop *init() { 72| 5.84k| new (us_loop_ext((us_loop_t *) this)) LoopData; 73| 5.84k| return this; 74| 5.84k| } _ZZN3uWS4Loop6createEPvENKUlP10us_timer_tE_clES3_: 83| 1.62M| us_timer_set(loopData->dateTimer, [](struct us_timer_t *t) { 84| 1.62M| LoopData *loopData; 85| 1.62M| memcpy(&loopData, us_timer_ext(t), sizeof(LoopData *)); 86| 1.62M| loopData->updateDate(); 87| 1.62M| }, 1000, 1000); _ZN3uWS4Loop4freeEv: 128| 5.84k| void free() { 129| 5.84k| LoopData *loopData = (LoopData *) us_loop_ext((us_loop_t *) this); 130| | 131| | /* Stop and free dateTimer first */ 132| 5.84k| us_timer_close(loopData->dateTimer); 133| | 134| 5.84k| loopData->~LoopData(); 135| | /* uSockets will track whether this loop is owned by us or a borrowed alien loop */ 136| 5.84k| us_loop_free((us_loop_t *) this); 137| | 138| | /* Reset lazyLoop */ 139| 5.84k| getLazyLoop().loop = nullptr; 140| 5.84k| } _ZN3uWS4Loop17removePostHandlerEPv: 149| 5.84k| void removePostHandler(void *key) { 150| 5.84k| LoopData *loopData = (LoopData *) us_loop_ext((us_loop_t *) this); 151| | 152| 5.84k| loopData->postHandlers.erase(key); 153| 5.84k| } _ZN3uWS4Loop16removePreHandlerEPv: 162| 5.84k| void removePreHandler(void *key) { 163| 5.84k| LoopData *loopData = (LoopData *) us_loop_ext((us_loop_t *) this); 164| | 165| 5.84k| loopData->preHandlers.erase(key); 166| 5.84k| } _ZN3uWS4Loop14addPostHandlerEPvON5ofats13any_invocableIFvPS0_EEE: 142| 5.84k| void addPostHandler(void *key, MoveOnlyFunction &&handler) { 143| 5.84k| LoopData *loopData = (LoopData *) us_loop_ext((us_loop_t *) this); 144| | 145| 5.84k| loopData->postHandlers.emplace(key, std::move(handler)); 146| 5.84k| } _ZN3uWS4Loop13addPreHandlerEPvON5ofats13any_invocableIFvPS0_EEE: 155| 5.84k| void addPreHandler(void *key, MoveOnlyFunction &&handler) { 156| 5.84k| LoopData *loopData = (LoopData *) us_loop_ext((us_loop_t *) this); 157| | 158| 5.84k| loopData->preHandlers.emplace(key, std::move(handler)); 159| 5.84k| } _ZN3uWS4Loop5deferEON5ofats13any_invocableIFvvEEE: 169| 7.41k| void defer(MoveOnlyFunction &&cb) { 170| 7.41k| LoopData *loopData = (LoopData *) us_loop_ext((us_loop_t *) this); 171| | 172| | //if (std::thread::get_id() == ) // todo: add fast path for same thread id 173| 7.41k| loopData->deferMutex.lock(); 174| 7.41k| loopData->deferQueues[loopData->currentDeferQueue].emplace_back(std::move(cb)); 175| 7.41k| loopData->deferMutex.unlock(); 176| | 177| 7.41k| us_wakeup_loop((us_loop_t *) this); 178| 7.41k| } _ZN3uWS3runEv: 198| 5.84k|inline void run() { 199| 5.84k| Loop::get()->run(); 200| 5.84k|} _ZN3uWS4Loop3runEv: 181| 5.84k| void run() { 182| 5.84k| us_loop_run((us_loop_t *) this); 183| 5.84k| } _ZN3uWS8LoopDataC2Ev: 49| 5.84k| LoopData() { 50| 5.84k| updateDate(); 51| 5.84k| } _ZN3uWS8LoopData10updateDateEv: 63| 1.63M| void updateDate() { 64| 1.63M| time_t now = time(0); 65| 1.63M| struct tm tstruct = {}; 66| |#ifdef _WIN32 67| | /* Micro, fucking soft never follows spec. */ 68| | gmtime_s(&tstruct, &now); 69| |#else 70| 1.63M| gmtime_r(&now, &tstruct); 71| 1.63M|#endif 72| 1.63M| static const char wday_name[][4] = { 73| 1.63M| "Sun", "Mon", "Tue", "Wed", "Thu", "Fri", "Sat" 74| 1.63M| }; 75| 1.63M| static const char mon_name[][4] = { 76| 1.63M| "Jan", "Feb", "Mar", "Apr", "May", "Jun", 77| 1.63M| "Jul", "Aug", "Sep", "Oct", "Nov", "Dec" 78| 1.63M| }; 79| 1.63M| snprintf(date, 32, "%.3s, %.2u %.3s %.4u %.2u:%.2u:%.2u GMT", 80| 1.63M| wday_name[tstruct.tm_wday], 81| 1.63M| tstruct.tm_mday % 99, 82| 1.63M| mon_name[tstruct.tm_mon], 83| 1.63M| (1900 + tstruct.tm_year) % 9999, 84| 1.63M| tstruct.tm_hour % 99, 85| 1.63M| tstruct.tm_min % 99, 86| 1.63M| tstruct.tm_sec % 99); 87| 1.63M| } _ZN3uWS8LoopDataD2Ev: 53| 5.84k| ~LoopData() { 54| | /* If we have had App.ws called with compression we need to clear this */ 55| 5.84k| if (zlibContext) { ------------------ | Branch (55:13): [True: 5.56k, False: 287] ------------------ 56| 5.56k| delete zlibContext; 57| 5.56k| delete inflationStream; 58| 5.56k| delete deflationStream; 59| 5.56k| } 60| 5.84k| delete [] corkBuffer; 61| 5.84k| } _ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS12HttpResponseILb0EEEPNS2_11HttpRequestEP19us_socket_context_tEEC2EDn: 187| 11.6k| any_invocable_impl(std::nullptr_t) noexcept {} EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEENS2_6OpCodeEEEC2EDn: 187| 35.0k| any_invocable_impl(std::nullptr_t) noexcept {} EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEiiEEC2EDn: 187| 23.3k| any_invocable_impl(std::nullptr_t) noexcept {} _ZN5ofats10any_detail18any_invocable_implIvLb0EJP18us_listen_socket_tEED2Ev: 206| 5.84k| ~any_invocable_impl() { destroy(); } _ZN5ofats10any_detail18any_invocable_implIvLb0EJP18us_listen_socket_tEE7destroyEv: 239| 5.84k| void destroy() noexcept { 240| 5.84k| if (handle_) { ------------------ | Branch (240:9): [True: 5.84k, False: 0] ------------------ 241| 5.84k| handle_(action::destroy, &storage_, nullptr); 242| 5.84k| handle_ = nullptr; 243| 5.84k| } 244| 5.84k| } EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEiNSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEED2Ev: 206| 81.8k| ~any_invocable_impl() { destroy(); } EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEiNSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEE7destroyEv: 239| 81.8k| void destroy() noexcept { 240| 81.8k| if (handle_) { ------------------ | Branch (240:9): [True: 23.3k, False: 58.4k] ------------------ 241| 23.3k| handle_(action::destroy, &storage_, nullptr); 242| 23.3k| handle_ = nullptr; 243| 23.3k| } 244| 81.8k| } EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEiiEED2Ev: 206| 58.4k| ~any_invocable_impl() { destroy(); } EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEiiEE7destroyEv: 239| 58.4k| void destroy() noexcept { 240| 58.4k| if (handle_) { ------------------ | Branch (240:9): [True: 0, False: 58.4k] ------------------ 241| 0| handle_(action::destroy, &storage_, nullptr); 242| 0| handle_ = nullptr; 243| 0| } 244| 58.4k| } EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEED2Ev: 206| 116k| ~any_invocable_impl() { destroy(); } EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEE7destroyEv: 239| 116k| void destroy() noexcept { 240| 116k| if (handle_) { ------------------ | Branch (240:9): [True: 23.3k, False: 93.5k] ------------------ 241| 23.3k| handle_(action::destroy, &storage_, nullptr); 242| 23.3k| handle_ = nullptr; 243| 23.3k| } 244| 116k| } EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEEED2Ev: 206| 116k| ~any_invocable_impl() { destroy(); } EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEEE7destroyEv: 239| 116k| void destroy() noexcept { 240| 116k| if (handle_) { ------------------ | Branch (240:9): [True: 23.3k, False: 93.5k] ------------------ 241| 23.3k| handle_(action::destroy, &storage_, nullptr); 242| 23.3k| handle_ = nullptr; 243| 23.3k| } 244| 116k| } EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEENS2_6OpCodeEEED2Ev: 206| 116k| ~any_invocable_impl() { destroy(); } EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEENS2_6OpCodeEEE7destroyEv: 239| 116k| void destroy() noexcept { 240| 116k| if (handle_) { ------------------ | Branch (240:9): [True: 11.6k, False: 105k] ------------------ 241| 11.6k| handle_(action::destroy, &storage_, nullptr); 242| 11.6k| handle_ = nullptr; 243| 11.6k| } 244| 116k| } _ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS12HttpResponseILb0EEEPNS2_11HttpRequestEP19us_socket_context_tEED2Ev: 206| 35.0k| ~any_invocable_impl() { destroy(); } _ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS12HttpResponseILb0EEEPNS2_11HttpRequestEP19us_socket_context_tEE7destroyEv: 239| 35.0k| void destroy() noexcept { 240| 35.0k| if (handle_) { ------------------ | Branch (240:9): [True: 0, False: 35.0k] ------------------ 241| 0| handle_(action::destroy, &storage_, nullptr); 242| 0| handle_ = nullptr; 243| 0| } 244| 35.0k| } _ZN5ofats13any_invocableIFvvEEclEv: 345| 15.4k| R operator()(ArgTypes... args) cv ref noexcept(noex) { \ 346| 15.4k| return base_type::call(std::forward(args)...); \ 347| 15.4k| } \ _ZN5ofats10any_detail18any_invocable_implIvLb0EJEE4callEv: 246| 15.4k| R call(ArgTypes... args) noexcept(is_noexcept) { 247| 15.4k| return call_(storage_, std::forward(args)...); 248| 15.4k| } _ZN5ofats10any_detail18any_invocable_implIvLb0EJEED2Ev: 206| 1.85M| ~any_invocable_impl() { destroy(); } _ZN5ofats10any_detail18any_invocable_implIvLb0EJEE7destroyEv: 239| 1.85M| void destroy() noexcept { 240| 1.85M| if (handle_) { ------------------ | Branch (240:9): [True: 19.1k, False: 1.83M] ------------------ 241| 19.1k| handle_(action::destroy, &storage_, nullptr); 242| 19.1k| handle_ = nullptr; 243| 19.1k| } 244| 1.85M| } _ZN5ofats13any_invocableIFvPN3uWS4LoopEEEclES3_: 345| 4.36M| R operator()(ArgTypes... args) cv ref noexcept(noex) { \ 346| 4.36M| return base_type::call(std::forward(args)...); \ 347| 4.36M| } \ _ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS4LoopEEE4callES4_: 246| 4.36M| R call(ArgTypes... args) noexcept(is_noexcept) { 247| 4.36M| return call_(storage_, std::forward(args)...); 248| 4.36M| } _ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS4LoopEEED2Ev: 206| 23.3k| ~any_invocable_impl() { destroy(); } _ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS4LoopEEE7destroyEv: 239| 23.3k| void destroy() noexcept { 240| 23.3k| if (handle_) { ------------------ | Branch (240:9): [True: 11.6k, False: 11.6k] ------------------ 241| 11.6k| handle_(action::destroy, &storage_, nullptr); 242| 11.6k| handle_ = nullptr; 243| 11.6k| } 244| 23.3k| } _ZN5ofats10any_detail18any_invocable_implIvLb0EJPKcEEC2Ev: 186| 5.84k| any_invocable_impl() noexcept = default; _ZN5ofats10any_detail18any_invocable_implIbLb0EJPN3uWS10HttpRouterINS2_15HttpContextDataILb0EE10RouterDataEEEEED2Ev: 206| 52.6k| ~any_invocable_impl() { destroy(); } _ZN5ofats10any_detail18any_invocable_implIbLb0EJPN3uWS10HttpRouterINS2_15HttpContextDataILb0EE10RouterDataEEEEE7destroyEv: 239| 52.6k| void destroy() noexcept { 240| 52.6k| if (handle_) { ------------------ | Branch (240:9): [True: 17.5k, False: 35.0k] ------------------ 241| 17.5k| handle_(action::destroy, &storage_, nullptr); 242| 17.5k| handle_ = nullptr; 243| 17.5k| } 244| 52.6k| } _ZN5ofats10any_detail18any_invocable_implIvLb0EJPKcEED2Ev: 206| 5.84k| ~any_invocable_impl() { destroy(); } _ZN5ofats10any_detail18any_invocable_implIvLb0EJPKcEE7destroyEv: 239| 5.84k| void destroy() noexcept { 240| 5.84k| if (handle_) { ------------------ | Branch (240:9): [True: 0, False: 5.84k] ------------------ 241| 0| handle_(action::destroy, &storage_, nullptr); 242| 0| handle_ = nullptr; 243| 0| } 244| 5.84k| } _ZN5ofats10any_detail18any_invocable_implIbLb0EJmEEC2Ev: 186| 1.63M| any_invocable_impl() noexcept = default; _ZN5ofats10any_detail18any_invocable_implIvLb0EJEEC2Ev: 186| 1.65M| any_invocable_impl() noexcept = default; _ZN5ofats10any_detail18any_invocable_implIvLb0EJNSt3__117basic_string_viewIcNS2_11char_traitsIcEEEEbEEC2Ev: 186| 1.63M| any_invocable_impl() noexcept = default; _ZNK5ofats10any_detail18any_invocable_implIvLb0EJEEcvbEv: 228| 1.46M| explicit operator bool() const noexcept { return handle_ != nullptr; } _ZN5ofats10any_detail18any_invocable_implIvLb0EJNSt3__117basic_string_viewIcNS2_11char_traitsIcEEEEbEED2Ev: 206| 1.63M| ~any_invocable_impl() { destroy(); } _ZN5ofats10any_detail18any_invocable_implIvLb0EJNSt3__117basic_string_viewIcNS2_11char_traitsIcEEEEbEE7destroyEv: 239| 1.63M| void destroy() noexcept { 240| 1.63M| if (handle_) { ------------------ | Branch (240:9): [True: 0, False: 1.63M] ------------------ 241| 0| handle_(action::destroy, &storage_, nullptr); 242| 0| handle_ = nullptr; 243| 0| } 244| 1.63M| } _ZN5ofats10any_detail18any_invocable_implIbLb0EJmEED2Ev: 206| 1.80M| ~any_invocable_impl() { destroy(); } _ZN5ofats10any_detail18any_invocable_implIbLb0EJmEE7destroyEv: 239| 1.80M| void destroy() noexcept { 240| 1.80M| if (handle_) { ------------------ | Branch (240:9): [True: 0, False: 1.80M] ------------------ 241| 0| handle_(action::destroy, &storage_, nullptr); 242| 0| handle_ = nullptr; 243| 0| } 244| 1.80M| } _ZN5ofats13any_invocableIFPvS1_NSt3__117basic_string_viewIcNS2_11char_traitsIcEEEEbEEclES1_S6_b: 345| 7.55k| R operator()(ArgTypes... args) cv ref noexcept(noex) { \ 346| 7.55k| return base_type::call(std::forward(args)...); \ 347| 7.55k| } \ _ZN5ofats10any_detail18any_invocable_implIPvLb0EJS2_NSt3__117basic_string_viewIcNS3_11char_traitsIcEEEEbEE4callES2_S7_b: 246| 7.55k| R call(ArgTypes... args) noexcept(is_noexcept) { 247| 7.55k| return call_(storage_, std::forward(args)...); 248| 7.55k| } _ZN5ofats13any_invocableIFPvS1_PN3uWS11HttpRequestEEEclES1_S4_: 345| 171k| R operator()(ArgTypes... args) cv ref noexcept(noex) { \ 346| 171k| return base_type::call(std::forward(args)...); \ 347| 171k| } \ _ZN5ofats10any_detail18any_invocable_implIPvLb0EJS2_PN3uWS11HttpRequestEEE4callES2_S5_: 246| 171k| R call(ArgTypes... args) noexcept(is_noexcept) { 247| 171k| return call_(storage_, std::forward(args)...); 248| 171k| } _ZN5ofats13any_invocableIFPvS1_PN3uWS11HttpRequestEEEC2IZZNS2_11HttpContextILb0EE4initEvENKUlP11us_socket_tPciE_clESB_SC_iEUlS1_S4_E_vEEOT_: 303| 592k| any_invocable(F&& f) { \ 304| 592k| base_type::template create>(std::forward(f)); \ 305| 592k| } \ _ZN5ofats10any_detail18any_invocable_implIPvLb0EJS2_PN3uWS11HttpRequestEEEC2Ev: 186| 592k| any_invocable_impl() noexcept = default; _ZN5ofats10any_detail18any_invocable_implIPvLb0EJS2_PN3uWS11HttpRequestEEE6createIZZNS3_11HttpContextILb0EE4initEvENKUlP11us_socket_tPciE_clESB_SC_iEUlS2_S5_E_JSE_EEEvDpOT0_: 232| 592k| void create(Args&&... args) { 233| 592k| using hdl = handler; 234| 592k| hdl::create(storage_, std::forward(args)...); 235| 592k| handle_ = &hdl::handle; 236| 592k| call_ = &hdl::call; 237| 592k| } _ZN5ofats10any_detail14handler_traitsIPvJS2_PN3uWS11HttpRequestEEE13small_handlerIZZNS3_11HttpContextILb0EE4initEvENKUlP11us_socket_tPciE_clESB_SC_iEUlS2_S5_E_E6createIJSE_EEEvRNS0_7storageEDpOT_: 118| 592k| static void create(storage& s, Args&&... args) { 119| 592k| new (static_cast(&s.buf_)) T(std::forward(args)...); 120| 592k| } _ZN5ofats10any_detail14handler_traitsIPvJS2_PN3uWS11HttpRequestEEE12handler_baseINS6_13small_handlerIZZNS3_11HttpContextILb0EE4initEvENKUlP11us_socket_tPciE_clESC_SD_iEUlS2_S5_E_EEE6handleENS0_6actionEPNS0_7storageESK_: 103| 592k| static void handle(action act, storage* current, storage* other = nullptr) { 104| 592k| switch (act) { ------------------ | Branch (104:15): [True: 0, False: 592k] ------------------ 105| 592k| case (action::destroy): ------------------ | Branch (105:9): [True: 592k, False: 0] ------------------ 106| 592k| Derived::destroy(*current); 107| 592k| break; 108| 0| case (action::move): ------------------ | Branch (108:9): [True: 0, False: 592k] ------------------ 109| 0| Derived::move(*current, *other); 110| 0| break; 111| 592k| } 112| 592k| } _ZN5ofats10any_detail14handler_traitsIPvJS2_PN3uWS11HttpRequestEEE13small_handlerIZZNS3_11HttpContextILb0EE4initEvENKUlP11us_socket_tPciE_clESB_SC_iEUlS2_S5_E_E7destroyERNS0_7storageE: 122| 592k| static void destroy(storage& s) noexcept { 123| 592k| T& value = *static_cast(static_cast(&s.buf_)); 124| 592k| value.~T(); 125| 592k| } _ZN5ofats10any_detail14handler_traitsIPvJS2_PN3uWS11HttpRequestEEE13small_handlerIZZNS3_11HttpContextILb0EE4initEvENKUlP11us_socket_tPciE_clESB_SC_iEUlS2_S5_E_E4callERNS0_7storageES2_S5_: 132| 171k| static R call(storage& s, ArgTypes... args) { 133| 171k| return std::invoke(*static_cast(static_cast(&s.buf_)), 134| 171k| std::forward(args)...); 135| 171k| } _ZN5ofats13any_invocableIFbPN3uWS10HttpRouterINS1_15HttpContextDataILb0EE10RouterDataEEEEEclES7_: 345| 176k| R operator()(ArgTypes... args) cv ref noexcept(noex) { \ 346| 176k| return base_type::call(std::forward(args)...); \ 347| 176k| } \ _ZN5ofats10any_detail18any_invocable_implIbLb0EJPN3uWS10HttpRouterINS2_15HttpContextDataILb0EE10RouterDataEEEEE4callES8_: 246| 176k| R call(ArgTypes... args) noexcept(is_noexcept) { 247| 176k| return call_(storage_, std::forward(args)...); 248| 176k| } _ZNK5ofats10any_detail18any_invocable_implIvLb0EJNSt3__117basic_string_viewIcNS2_11char_traitsIcEEEEbEEcvbEv: 228| 7.55k| explicit operator bool() const noexcept { return handle_ != nullptr; } _ZN5ofats10any_detail18any_invocable_implIPvLb0EJS2_PN3uWS11HttpRequestEEED2Ev: 206| 592k| ~any_invocable_impl() { destroy(); } _ZN5ofats10any_detail18any_invocable_implIPvLb0EJS2_PN3uWS11HttpRequestEEE7destroyEv: 239| 592k| void destroy() noexcept { 240| 592k| if (handle_) { ------------------ | Branch (240:9): [True: 592k, False: 0] ------------------ 241| 592k| handle_(action::destroy, &storage_, nullptr); 242| 592k| handle_ = nullptr; 243| 592k| } 244| 592k| } _ZN5ofats13any_invocableIFPvS1_NSt3__117basic_string_viewIcNS2_11char_traitsIcEEEEbEEC2IZZN3uWS11HttpContextILb0EE4initEvENKUlP11us_socket_tPciE_clESE_SF_iEUlS1_S6_bE_vEEOT_: 303| 592k| any_invocable(F&& f) { \ 304| 592k| base_type::template create>(std::forward(f)); \ 305| 592k| } \ _ZN5ofats10any_detail18any_invocable_implIPvLb0EJS2_NSt3__117basic_string_viewIcNS3_11char_traitsIcEEEEbEEC2Ev: 186| 592k| any_invocable_impl() noexcept = default; _ZN5ofats10any_detail18any_invocable_implIPvLb0EJS2_NSt3__117basic_string_viewIcNS3_11char_traitsIcEEEEbEE6createIZZN3uWS11HttpContextILb0EE4initEvENKUlP11us_socket_tPciE_clESE_SF_iEUlS2_S7_bE_JSH_EEEvDpOT0_: 232| 592k| void create(Args&&... args) { 233| 592k| using hdl = handler; 234| 592k| hdl::create(storage_, std::forward(args)...); 235| 592k| handle_ = &hdl::handle; 236| 592k| call_ = &hdl::call; 237| 592k| } _ZN5ofats10any_detail14handler_traitsIPvJS2_NSt3__117basic_string_viewIcNS3_11char_traitsIcEEEEbEE13small_handlerIZZN3uWS11HttpContextILb0EE4initEvENKUlP11us_socket_tPciE_clESE_SF_iEUlS2_S7_bE_E6createIJSH_EEEvRNS0_7storageEDpOT_: 118| 592k| static void create(storage& s, Args&&... args) { 119| 592k| new (static_cast(&s.buf_)) T(std::forward(args)...); 120| 592k| } _ZN5ofats10any_detail14handler_traitsIPvJS2_NSt3__117basic_string_viewIcNS3_11char_traitsIcEEEEbEE12handler_baseINS8_13small_handlerIZZN3uWS11HttpContextILb0EE4initEvENKUlP11us_socket_tPciE_clESF_SG_iEUlS2_S7_bE_EEE6handleENS0_6actionEPNS0_7storageESN_: 103| 592k| static void handle(action act, storage* current, storage* other = nullptr) { 104| 592k| switch (act) { ------------------ | Branch (104:15): [True: 0, False: 592k] ------------------ 105| 592k| case (action::destroy): ------------------ | Branch (105:9): [True: 592k, False: 0] ------------------ 106| 592k| Derived::destroy(*current); 107| 592k| break; 108| 0| case (action::move): ------------------ | Branch (108:9): [True: 0, False: 592k] ------------------ 109| 0| Derived::move(*current, *other); 110| 0| break; 111| 592k| } 112| 592k| } _ZN5ofats10any_detail14handler_traitsIPvJS2_NSt3__117basic_string_viewIcNS3_11char_traitsIcEEEEbEE13small_handlerIZZN3uWS11HttpContextILb0EE4initEvENKUlP11us_socket_tPciE_clESE_SF_iEUlS2_S7_bE_E7destroyERNS0_7storageE: 122| 592k| static void destroy(storage& s) noexcept { 123| 592k| T& value = *static_cast(static_cast(&s.buf_)); 124| 592k| value.~T(); 125| 592k| } _ZN5ofats10any_detail14handler_traitsIPvJS2_NSt3__117basic_string_viewIcNS3_11char_traitsIcEEEEbEE13small_handlerIZZN3uWS11HttpContextILb0EE4initEvENKUlP11us_socket_tPciE_clESE_SF_iEUlS2_S7_bE_E4callERNS0_7storageES2_S7_b: 132| 7.55k| static R call(storage& s, ArgTypes... args) { 133| 7.55k| return std::invoke(*static_cast(static_cast(&s.buf_)), 134| 7.55k| std::forward(args)...); 135| 7.55k| } _ZN5ofats10any_detail18any_invocable_implIPvLb0EJS2_NSt3__117basic_string_viewIcNS3_11char_traitsIcEEEEbEED2Ev: 206| 592k| ~any_invocable_impl() { destroy(); } _ZN5ofats10any_detail18any_invocable_implIPvLb0EJS2_NSt3__117basic_string_viewIcNS3_11char_traitsIcEEEEbEE7destroyEv: 239| 592k| void destroy() noexcept { 240| 592k| if (handle_) { ------------------ | Branch (240:9): [True: 592k, False: 0] ------------------ 241| 592k| handle_(action::destroy, &storage_, nullptr); 242| 592k| handle_ = nullptr; 243| 592k| } 244| 592k| } _ZNK5ofats10any_detail18any_invocable_implIbLb0EJmEEcvbEv: 228| 1.33k| explicit operator bool() const noexcept { return handle_ != nullptr; } _ZN5ofats10any_detail18any_invocable_implIbLb0EJmEE4swapERS2_: 208| 171k| void swap(any_invocable_impl& rhs) noexcept { 209| 171k| if (handle_) { ------------------ | Branch (209:9): [True: 0, False: 171k] ------------------ 210| 0| if (rhs.handle_) { ------------------ | Branch (210:11): [True: 0, False: 0] ------------------ 211| 0| storage tmp; 212| 0| handle_(action::move, &tmp, &storage_); 213| 0| rhs.handle_(action::move, &storage_, &rhs.storage_); 214| 0| handle_(action::move, &rhs.storage_, &tmp); 215| 0| std::swap(handle_, rhs.handle_); 216| 0| std::swap(call_, rhs.call_); 217| 0| } else { 218| 0| rhs.swap(*this); 219| 0| } 220| 171k| } else if (rhs.handle_) { ------------------ | Branch (220:16): [True: 0, False: 171k] ------------------ 221| 0| rhs.handle_(action::move, &storage_, &rhs.storage_); 222| 0| handle_ = rhs.handle_; 223| 0| call_ = rhs.call_; 224| 0| rhs.handle_ = nullptr; 225| 0| } 226| 171k| } _ZNK5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS12HttpResponseILb0EEEPNS2_11HttpRequestEEEcvbEv: 228| 17.5k| explicit operator bool() const noexcept { return handle_ != nullptr; } _ZN5ofats10any_detail18any_invocable_implIbLb0EJPN3uWS10HttpRouterINS2_15HttpContextDataILb0EE10RouterDataEEEEEC2EOS9_: 188| 35.0k| any_invocable_impl(any_invocable_impl&& rhs) noexcept { 189| 35.0k| if (rhs.handle_) { ------------------ | Branch (189:9): [True: 35.0k, False: 0] ------------------ 190| 35.0k| handle_ = rhs.handle_; 191| 35.0k| handle_(action::move, &storage_, &rhs.storage_); 192| 35.0k| call_ = rhs.call_; 193| 35.0k| rhs.handle_ = nullptr; 194| 35.0k| } 195| 35.0k| } _ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS12HttpResponseILb0EEEPNS2_11HttpRequestEEEC2EOS8_: 188| 35.0k| any_invocable_impl(any_invocable_impl&& rhs) noexcept { 189| 35.0k| if (rhs.handle_) { ------------------ | Branch (189:9): [True: 35.0k, False: 0] ------------------ 190| 35.0k| handle_ = rhs.handle_; 191| 35.0k| handle_(action::move, &storage_, &rhs.storage_); 192| 35.0k| call_ = rhs.call_; 193| 35.0k| rhs.handle_ = nullptr; 194| 35.0k| } 195| 35.0k| } _ZN5ofats13any_invocableIFbPN3uWS10HttpRouterINS1_15HttpContextDataILb0EE10RouterDataEEEEEC2IZNS1_11HttpContextILb0EE6onHttpENSt3__112basic_stringIcNSD_11char_traitsIcEENSD_9allocatorIcEEEESJ_ONS0_IFvPNS1_12HttpResponseILb0EEEPNS1_11HttpRequestEEEEbEUlPT_E_vEEOSS_: 303| 17.5k| any_invocable(F&& f) { \ 304| 17.5k| base_type::template create>(std::forward(f)); \ 305| 17.5k| } \ _ZN5ofats10any_detail18any_invocable_implIbLb0EJPN3uWS10HttpRouterINS2_15HttpContextDataILb0EE10RouterDataEEEEEC2Ev: 186| 17.5k| any_invocable_impl() noexcept = default; _ZN5ofats10any_detail18any_invocable_implIbLb0EJPN3uWS10HttpRouterINS2_15HttpContextDataILb0EE10RouterDataEEEEE6createIZNS2_11HttpContextILb0EE6onHttpENSt3__112basic_stringIcNSD_11char_traitsIcEENSD_9allocatorIcEEEESJ_ONS_13any_invocableIFvPNS2_12HttpResponseILb0EEEPNS2_11HttpRequestEEEEbEUlPT_E_JSV_EEEvDpOT0_: 232| 17.5k| void create(Args&&... args) { 233| 17.5k| using hdl = handler; 234| 17.5k| hdl::create(storage_, std::forward(args)...); 235| 17.5k| handle_ = &hdl::handle; 236| 17.5k| call_ = &hdl::call; 237| 17.5k| } _ZN5ofats10any_detail14handler_traitsIbJPN3uWS10HttpRouterINS2_15HttpContextDataILb0EE10RouterDataEEEEE13large_handlerIZNS2_11HttpContextILb0EE6onHttpENSt3__112basic_stringIcNSD_11char_traitsIcEENSD_9allocatorIcEEEESJ_ONS_13any_invocableIFvPNS2_12HttpResponseILb0EEEPNS2_11HttpRequestEEEEbEUlPT_E_E6createIJSV_EEEvRNS0_7storageEDpOT_: 141| 17.5k| static void create(storage& s, Args&&... args) { 142| 17.5k| s.ptr_ = new T(std::forward(args)...); 143| 17.5k| } _ZN5ofats10any_detail14handler_traitsIbJPN3uWS10HttpRouterINS2_15HttpContextDataILb0EE10RouterDataEEEEE12handler_baseINS9_13large_handlerIZNS2_11HttpContextILb0EE6onHttpENSt3__112basic_stringIcNSE_11char_traitsIcEENSE_9allocatorIcEEEESK_ONS_13any_invocableIFvPNS2_12HttpResponseILb0EEEPNS2_11HttpRequestEEEEbEUlPT_E_EEE6handleENS0_6actionEPNS0_7storageES11_: 103| 52.6k| static void handle(action act, storage* current, storage* other = nullptr) { 104| 52.6k| switch (act) { ------------------ | Branch (104:15): [True: 0, False: 52.6k] ------------------ 105| 17.5k| case (action::destroy): ------------------ | Branch (105:9): [True: 17.5k, False: 35.0k] ------------------ 106| 17.5k| Derived::destroy(*current); 107| 17.5k| break; 108| 35.0k| case (action::move): ------------------ | Branch (108:9): [True: 35.0k, False: 17.5k] ------------------ 109| 35.0k| Derived::move(*current, *other); 110| 35.0k| break; 111| 52.6k| } 112| 52.6k| } _ZN5ofats10any_detail14handler_traitsIbJPN3uWS10HttpRouterINS2_15HttpContextDataILb0EE10RouterDataEEEEE13large_handlerIZNS2_11HttpContextILb0EE6onHttpENSt3__112basic_stringIcNSD_11char_traitsIcEENSD_9allocatorIcEEEESJ_ONS_13any_invocableIFvPNS2_12HttpResponseILb0EEEPNS2_11HttpRequestEEEEbEUlPT_E_E7destroyERNS0_7storageE: 145| 17.5k| static void destroy(storage& s) noexcept { delete static_cast(s.ptr_); } _ZN5ofats10any_detail14handler_traitsIbJPN3uWS10HttpRouterINS2_15HttpContextDataILb0EE10RouterDataEEEEE13large_handlerIZNS2_11HttpContextILb0EE6onHttpENSt3__112basic_stringIcNSD_11char_traitsIcEENSD_9allocatorIcEEEESJ_ONS_13any_invocableIFvPNS2_12HttpResponseILb0EEEPNS2_11HttpRequestEEEEbEUlPT_E_E4moveERNS0_7storageESY_: 147| 35.0k| static void move(storage& dst, storage& src) noexcept { 148| 35.0k| dst.ptr_ = src.ptr_; 149| 35.0k| } _ZN5ofats10any_detail14handler_traitsIbJPN3uWS10HttpRouterINS2_15HttpContextDataILb0EE10RouterDataEEEEE13large_handlerIZNS2_11HttpContextILb0EE6onHttpENSt3__112basic_stringIcNSD_11char_traitsIcEENSD_9allocatorIcEEEESJ_ONS_13any_invocableIFvPNS2_12HttpResponseILb0EEEPNS2_11HttpRequestEEEEbEUlPT_E_E4callERNS0_7storageES8_: 151| 176k| static R call(storage& s, ArgTypes... args) { 152| 176k| return std::invoke(*static_cast(s.ptr_), 153| 176k| std::forward(args)...); 154| 176k| } _ZN5ofats13any_invocableIFvPN3uWS12HttpResponseILb0EEEPNS1_11HttpRequestEEEclES4_S6_: 345| 176k| R operator()(ArgTypes... args) cv ref noexcept(noex) { \ 346| 176k| return base_type::call(std::forward(args)...); \ 347| 176k| } \ _ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS12HttpResponseILb0EEEPNS2_11HttpRequestEEE4callES5_S7_: 246| 176k| R call(ArgTypes... args) noexcept(is_noexcept) { 247| 176k| return call_(storage_, std::forward(args)...); 248| 176k| } _ZN5ofats13any_invocableIFvPN3uWS12HttpResponseILb0EEEPNS1_11HttpRequestEEEC2IZNS1_12TemplatedAppILb0EEC1ENS1_20SocketContextOptionsEEUlPT_PT0_E_vEEOSD_: 303| 5.84k| any_invocable(F&& f) { \ 304| 5.84k| base_type::template create>(std::forward(f)); \ 305| 5.84k| } \ _ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS12HttpResponseILb0EEEPNS2_11HttpRequestEEEC2Ev: 186| 17.5k| any_invocable_impl() noexcept = default; _ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS12HttpResponseILb0EEEPNS2_11HttpRequestEEE6createIZNS2_12TemplatedAppILb0EEC1ENS2_20SocketContextOptionsEEUlPT_PT0_E_JSH_EEEvDpOT0_: 232| 5.84k| void create(Args&&... args) { 233| 5.84k| using hdl = handler; 234| 5.84k| hdl::create(storage_, std::forward(args)...); 235| 5.84k| handle_ = &hdl::handle; 236| 5.84k| call_ = &hdl::call; 237| 5.84k| } _ZN5ofats10any_detail14handler_traitsIvJPN3uWS12HttpResponseILb0EEEPNS2_11HttpRequestEEE13small_handlerIZNS2_12TemplatedAppILb0EEC1ENS2_20SocketContextOptionsEEUlPT_PT0_E_E6createIJSH_EEEvRNS0_7storageEDpOT_: 118| 17.5k| static void create(storage& s, Args&&... args) { 119| 17.5k| new (static_cast(&s.buf_)) T(std::forward(args)...); 120| 17.5k| } _ZN5ofats10any_detail14handler_traitsIvJPN3uWS12HttpResponseILb0EEEPNS2_11HttpRequestEEE12handler_baseINS8_13small_handlerIZNS2_12TemplatedAppILb0EEC1ENS2_20SocketContextOptionsEEUlPT_PT0_E_EEE6handleENS0_6actionEPNS0_7storageESN_: 103| 17.5k| static void handle(action act, storage* current, storage* other = nullptr) { 104| 17.5k| switch (act) { ------------------ | Branch (104:15): [True: 0, False: 17.5k] ------------------ 105| 5.84k| case (action::destroy): ------------------ | Branch (105:9): [True: 5.84k, False: 11.6k] ------------------ 106| 5.84k| Derived::destroy(*current); 107| 5.84k| break; 108| 11.6k| case (action::move): ------------------ | Branch (108:9): [True: 11.6k, False: 5.84k] ------------------ 109| 11.6k| Derived::move(*current, *other); 110| 11.6k| break; 111| 17.5k| } 112| 17.5k| } _ZN5ofats10any_detail14handler_traitsIvJPN3uWS12HttpResponseILb0EEEPNS2_11HttpRequestEEE13small_handlerIZNS2_12TemplatedAppILb0EEC1ENS2_20SocketContextOptionsEEUlPT_PT0_E_E7destroyERNS0_7storageE: 122| 17.5k| static void destroy(storage& s) noexcept { 123| 17.5k| T& value = *static_cast(static_cast(&s.buf_)); 124| 17.5k| value.~T(); 125| 17.5k| } _ZN5ofats10any_detail14handler_traitsIvJPN3uWS12HttpResponseILb0EEEPNS2_11HttpRequestEEE13small_handlerIZNS2_12TemplatedAppILb0EEC1ENS2_20SocketContextOptionsEEUlPT_PT0_E_E4moveERNS0_7storageESK_: 127| 11.6k| static void move(storage& dst, storage& src) noexcept { 128| 11.6k| create(dst, std::move(*static_cast(static_cast(&src.buf_)))); 129| 11.6k| destroy(src); 130| 11.6k| } _ZN5ofats10any_detail14handler_traitsIvJPN3uWS12HttpResponseILb0EEEPNS2_11HttpRequestEEE13small_handlerIZNS2_12TemplatedAppILb0EEC1ENS2_20SocketContextOptionsEEUlPT_PT0_E_E4callERNS0_7storageES5_S7_: 132| 7.55k| static R call(storage& s, ArgTypes... args) { 133| 7.55k| return std::invoke(*static_cast(static_cast(&s.buf_)), 134| 7.55k| std::forward(args)...); 135| 7.55k| } _ZN5ofats13any_invocableIFvvEEaSIDnDnEENSt3__19enable_ifIXaantsr3stdE9is_same_vIT0_S2_Esr3stdE23is_move_constructible_vIS6_EERS2_E4typeEOT_: 335| 171k| operator=(F&& f) { \ 336| 171k| any_invocable{std::forward(f)}.swap(*this); \ 337| 171k| return *this; \ 338| 171k| } \ _ZN5ofats10any_detail18any_invocable_implIvLb0EJEEC2EDn: 187| 171k| any_invocable_impl(std::nullptr_t) noexcept {} _ZN5ofats10any_detail18any_invocable_implIvLb0EJEE4swapERS2_: 208| 171k| void swap(any_invocable_impl& rhs) noexcept { 209| 171k| if (handle_) { ------------------ | Branch (209:9): [True: 0, False: 171k] ------------------ 210| 0| if (rhs.handle_) { ------------------ | Branch (210:11): [True: 0, False: 0] ------------------ 211| 0| storage tmp; 212| 0| handle_(action::move, &tmp, &storage_); 213| 0| rhs.handle_(action::move, &storage_, &rhs.storage_); 214| 0| handle_(action::move, &rhs.storage_, &tmp); 215| 0| std::swap(handle_, rhs.handle_); 216| 0| std::swap(call_, rhs.call_); 217| 0| } else { 218| 0| rhs.swap(*this); 219| 0| } 220| 171k| } else if (rhs.handle_) { ------------------ | Branch (220:16): [True: 0, False: 171k] ------------------ 221| 0| rhs.handle_(action::move, &storage_, &rhs.storage_); 222| 0| handle_ = rhs.handle_; 223| 0| call_ = rhs.call_; 224| 0| rhs.handle_ = nullptr; 225| 0| } 226| 171k| } _ZN5ofats13any_invocableIFbmEEaSIDnDnEENSt3__19enable_ifIXaantsr3stdE9is_same_vIT0_S2_Esr3stdE23is_move_constructible_vIS6_EERS2_E4typeEOT_: 335| 171k| operator=(F&& f) { \ 336| 171k| any_invocable{std::forward(f)}.swap(*this); \ 337| 171k| return *this; \ 338| 171k| } \ _ZN5ofats10any_detail18any_invocable_implIbLb0EJmEEC2EDn: 187| 171k| any_invocable_impl(std::nullptr_t) noexcept {} _ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS12HttpResponseILb0EEEPNS2_11HttpRequestEEED2Ev: 206| 52.6k| ~any_invocable_impl() { destroy(); } _ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS12HttpResponseILb0EEEPNS2_11HttpRequestEEE7destroyEv: 239| 52.6k| void destroy() noexcept { 240| 52.6k| if (handle_) { ------------------ | Branch (240:9): [True: 17.5k, False: 35.0k] ------------------ 241| 17.5k| handle_(action::destroy, &storage_, nullptr); 242| 17.5k| handle_ = nullptr; 243| 17.5k| } 244| 52.6k| } _ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS4LoopEEEC2EOS5_: 188| 11.6k| any_invocable_impl(any_invocable_impl&& rhs) noexcept { 189| 11.6k| if (rhs.handle_) { ------------------ | Branch (189:9): [True: 11.6k, False: 0] ------------------ 190| 11.6k| handle_ = rhs.handle_; 191| 11.6k| handle_(action::move, &storage_, &rhs.storage_); 192| 11.6k| call_ = rhs.call_; 193| 11.6k| rhs.handle_ = nullptr; 194| 11.6k| } 195| 11.6k| } EpollEchoServer.cpp:_ZN5ofats13any_invocableIFvPN3uWS4LoopEEEC2IZNS1_12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOS8_NSt3__112basic_stringIcNSC_11char_traitsIcEENSC_9allocatorIcEEEEONS8_17WebSocketBehaviorIT_EEEUlS3_E_vEEOSK_: 303| 5.84k| any_invocable(F&& f) { \ 304| 5.84k| base_type::template create>(std::forward(f)); \ 305| 5.84k| } \ _ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS4LoopEEEC2Ev: 186| 11.6k| any_invocable_impl() noexcept = default; EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS4LoopEEE6createIZNS2_12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOS8_NSt3__112basic_stringIcNSC_11char_traitsIcEENSC_9allocatorIcEEEEONS8_17WebSocketBehaviorIT_EEEUlS4_E_JSN_EEEvDpOT0_: 232| 5.84k| void create(Args&&... args) { 233| 5.84k| using hdl = handler; 234| 5.84k| hdl::create(storage_, std::forward(args)...); 235| 5.84k| handle_ = &hdl::handle; 236| 5.84k| call_ = &hdl::call; 237| 5.84k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS4LoopEEE13small_handlerIZNS2_12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOS8_NSt3__112basic_stringIcNSC_11char_traitsIcEENSC_9allocatorIcEEEEONS8_17WebSocketBehaviorIT_EEEUlS4_E_E6createIJSN_EEEvRNS0_7storageEDpOT_: 118| 11.6k| static void create(storage& s, Args&&... args) { 119| 11.6k| new (static_cast(&s.buf_)) T(std::forward(args)...); 120| 11.6k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS4LoopEEE12handler_baseINS5_13small_handlerIZNS2_12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOS9_NSt3__112basic_stringIcNSD_11char_traitsIcEENSD_9allocatorIcEEEEONS9_17WebSocketBehaviorIT_EEEUlS4_E_EEE6handleENS0_6actionEPNS0_7storageEST_: 103| 11.6k| static void handle(action act, storage* current, storage* other = nullptr) { 104| 11.6k| switch (act) { ------------------ | Branch (104:15): [True: 0, False: 11.6k] ------------------ 105| 5.84k| case (action::destroy): ------------------ | Branch (105:9): [True: 5.84k, False: 5.84k] ------------------ 106| 5.84k| Derived::destroy(*current); 107| 5.84k| break; 108| 5.84k| case (action::move): ------------------ | Branch (108:9): [True: 5.84k, False: 5.84k] ------------------ 109| 5.84k| Derived::move(*current, *other); 110| 5.84k| break; 111| 11.6k| } 112| 11.6k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS4LoopEEE13small_handlerIZNS2_12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOS8_NSt3__112basic_stringIcNSC_11char_traitsIcEENSC_9allocatorIcEEEEONS8_17WebSocketBehaviorIT_EEEUlS4_E_E7destroyERNS0_7storageE: 122| 11.6k| static void destroy(storage& s) noexcept { 123| 11.6k| T& value = *static_cast(static_cast(&s.buf_)); 124| 11.6k| value.~T(); 125| 11.6k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS4LoopEEE13small_handlerIZNS2_12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOS8_NSt3__112basic_stringIcNSC_11char_traitsIcEENSC_9allocatorIcEEEEONS8_17WebSocketBehaviorIT_EEEUlS4_E_E4moveERNS0_7storageESQ_: 127| 5.84k| static void move(storage& dst, storage& src) noexcept { 128| 5.84k| create(dst, std::move(*static_cast(static_cast(&src.buf_)))); 129| 5.84k| destroy(src); 130| 5.84k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS4LoopEEE13small_handlerIZNS2_12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOS8_NSt3__112basic_stringIcNSC_11char_traitsIcEENSC_9allocatorIcEEEEONS8_17WebSocketBehaviorIT_EEEUlS4_E_E4callERNS0_7storageES4_: 132| 2.18M| static R call(storage& s, ArgTypes... args) { 133| 2.18M| return std::invoke(*static_cast(static_cast(&s.buf_)), 134| 2.18M| std::forward(args)...); 135| 2.18M| } EpollEchoServer.cpp:_ZN5ofats13any_invocableIFvPN3uWS4LoopEEEC2IZNS1_12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOS8_NSt3__112basic_stringIcNSC_11char_traitsIcEENSC_9allocatorIcEEEEONS8_17WebSocketBehaviorIT_EEEUlS3_E0_vEEOSK_: 303| 5.84k| any_invocable(F&& f) { \ 304| 5.84k| base_type::template create>(std::forward(f)); \ 305| 5.84k| } \ EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS4LoopEEE6createIZNS2_12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOS8_NSt3__112basic_stringIcNSC_11char_traitsIcEENSC_9allocatorIcEEEEONS8_17WebSocketBehaviorIT_EEEUlS4_E0_JSN_EEEvDpOT0_: 232| 5.84k| void create(Args&&... args) { 233| 5.84k| using hdl = handler; 234| 5.84k| hdl::create(storage_, std::forward(args)...); 235| 5.84k| handle_ = &hdl::handle; 236| 5.84k| call_ = &hdl::call; 237| 5.84k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS4LoopEEE13small_handlerIZNS2_12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOS8_NSt3__112basic_stringIcNSC_11char_traitsIcEENSC_9allocatorIcEEEEONS8_17WebSocketBehaviorIT_EEEUlS4_E0_E6createIJSN_EEEvRNS0_7storageEDpOT_: 118| 11.6k| static void create(storage& s, Args&&... args) { 119| 11.6k| new (static_cast(&s.buf_)) T(std::forward(args)...); 120| 11.6k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS4LoopEEE12handler_baseINS5_13small_handlerIZNS2_12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOS9_NSt3__112basic_stringIcNSD_11char_traitsIcEENSD_9allocatorIcEEEEONS9_17WebSocketBehaviorIT_EEEUlS4_E0_EEE6handleENS0_6actionEPNS0_7storageEST_: 103| 11.6k| static void handle(action act, storage* current, storage* other = nullptr) { 104| 11.6k| switch (act) { ------------------ | Branch (104:15): [True: 0, False: 11.6k] ------------------ 105| 5.84k| case (action::destroy): ------------------ | Branch (105:9): [True: 5.84k, False: 5.84k] ------------------ 106| 5.84k| Derived::destroy(*current); 107| 5.84k| break; 108| 5.84k| case (action::move): ------------------ | Branch (108:9): [True: 5.84k, False: 5.84k] ------------------ 109| 5.84k| Derived::move(*current, *other); 110| 5.84k| break; 111| 11.6k| } 112| 11.6k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS4LoopEEE13small_handlerIZNS2_12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOS8_NSt3__112basic_stringIcNSC_11char_traitsIcEENSC_9allocatorIcEEEEONS8_17WebSocketBehaviorIT_EEEUlS4_E0_E7destroyERNS0_7storageE: 122| 11.6k| static void destroy(storage& s) noexcept { 123| 11.6k| T& value = *static_cast(static_cast(&s.buf_)); 124| 11.6k| value.~T(); 125| 11.6k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS4LoopEEE13small_handlerIZNS2_12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOS8_NSt3__112basic_stringIcNSC_11char_traitsIcEENSC_9allocatorIcEEEEONS8_17WebSocketBehaviorIT_EEEUlS4_E0_E4moveERNS0_7storageESQ_: 127| 5.84k| static void move(storage& dst, storage& src) noexcept { 128| 5.84k| create(dst, std::move(*static_cast(static_cast(&src.buf_)))); 129| 5.84k| destroy(src); 130| 5.84k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS4LoopEEE13small_handlerIZNS2_12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOS8_NSt3__112basic_stringIcNSC_11char_traitsIcEENSC_9allocatorIcEEEEONS8_17WebSocketBehaviorIT_EEEUlS4_E0_E4callERNS0_7storageES4_: 132| 2.18M| static R call(storage& s, ArgTypes... args) { 133| 2.18M| return std::invoke(*static_cast(static_cast(&s.buf_)), 134| 2.18M| std::forward(args)...); 135| 2.18M| } EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEEEC2EDn: 187| 23.3k| any_invocable_impl(std::nullptr_t) noexcept {} EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEiNSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEEC2EDn: 187| 11.6k| any_invocable_impl(std::nullptr_t) noexcept {} EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEEC2EDn: 187| 23.3k| any_invocable_impl(std::nullptr_t) noexcept {} EpollEchoServer.cpp:_ZNK5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEiiEEcvbEv: 228| 260k| explicit operator bool() const noexcept { return handle_ != nullptr; } EpollEchoServer.cpp:_ZNK5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEiNSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEEcvbEv: 228| 328k| explicit operator bool() const noexcept { return handle_ != nullptr; } EpollEchoServer.cpp:_ZN5ofats13any_invocableIFvPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEiNSt3__117basic_string_viewIcNS6_11char_traitsIcEEEEEEclES5_iSA_: 345| 328k| R operator()(ArgTypes... args) cv ref noexcept(noex) { \ 346| 328k| return base_type::call(std::forward(args)...); \ 347| 328k| } \ EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEiNSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEE4callES6_iSB_: 246| 328k| R call(ArgTypes... args) noexcept(is_noexcept) { 247| 328k| return call_(storage_, std::forward(args)...); 248| 328k| } EpollEchoServer.cpp:_ZNK5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEENS2_6OpCodeEEEcvbEv: 228| 38.6k| explicit operator bool() const noexcept { return handle_ != nullptr; } EpollEchoServer.cpp:_ZN5ofats13any_invocableIFvPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS6_11char_traitsIcEEEENS1_6OpCodeEEEclES5_SA_SB_: 345| 38.6k| R operator()(ArgTypes... args) cv ref noexcept(noex) { \ 346| 38.6k| return base_type::call(std::forward(args)...); \ 347| 38.6k| } \ EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEENS2_6OpCodeEEE4callES6_SB_SC_: 246| 38.6k| R call(ArgTypes... args) noexcept(is_noexcept) { 247| 38.6k| return call_(storage_, std::forward(args)...); 248| 38.6k| } EpollEchoServer.cpp:_ZNK5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEEcvbEv: 228| 14.9k| explicit operator bool() const noexcept { return handle_ != nullptr; } EpollEchoServer.cpp:_ZN5ofats13any_invocableIFvPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS6_11char_traitsIcEEEEEEclES5_SA_: 345| 14.9k| R operator()(ArgTypes... args) cv ref noexcept(noex) { \ 346| 14.9k| return base_type::call(std::forward(args)...); \ 347| 14.9k| } \ EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEE4callES6_SB_: 246| 14.9k| R call(ArgTypes... args) noexcept(is_noexcept) { 247| 14.9k| return call_(storage_, std::forward(args)...); 248| 14.9k| } EpollEchoServer.cpp:_ZNK5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEEEcvbEv: 228| 189k| explicit operator bool() const noexcept { return handle_ != nullptr; } EpollEchoServer.cpp:_ZN5ofats13any_invocableIFvPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEEEclES5_: 345| 189k| R operator()(ArgTypes... args) cv ref noexcept(noex) { \ 346| 189k| return base_type::call(std::forward(args)...); \ 347| 189k| } \ EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEEE4callES6_: 246| 189k| R call(ArgTypes... args) noexcept(is_noexcept) { 247| 189k| return call_(storage_, std::forward(args)...); 248| 189k| } _ZN5ofats10any_detail18any_invocable_implIvLb0EJEEC2EOS2_: 188| 32.7k| any_invocable_impl(any_invocable_impl&& rhs) noexcept { 189| 32.7k| if (rhs.handle_) { ------------------ | Branch (189:9): [True: 32.7k, False: 0] ------------------ 190| 32.7k| handle_ = rhs.handle_; 191| 32.7k| handle_(action::move, &storage_, &rhs.storage_); 192| 32.7k| call_ = rhs.call_; 193| 32.7k| rhs.handle_ = nullptr; 194| 32.7k| } 195| 32.7k| } EpollEchoServer.cpp:_ZN5ofats13any_invocableIFvvEEC2IZN3uWS12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOS6_NSt3__112basic_stringIcNSA_11char_traitsIcEENSA_9allocatorIcEEEEONS6_17WebSocketBehaviorIT_EEEUlvE_vEEOSI_: 303| 11.6k| any_invocable(F&& f) { \ 304| 11.6k| base_type::template create>(std::forward(f)); \ 305| 11.6k| } \ EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJEE6createIZN3uWS12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOS6_NSt3__112basic_stringIcNSA_11char_traitsIcEENSA_9allocatorIcEEEEONS6_17WebSocketBehaviorIT_EEEUlvE_JSL_EEEvDpOT0_: 232| 11.6k| void create(Args&&... args) { 233| 11.6k| using hdl = handler; 234| 11.6k| hdl::create(storage_, std::forward(args)...); 235| 11.6k| handle_ = &hdl::handle; 236| 11.6k| call_ = &hdl::call; 237| 11.6k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJEE13small_handlerIZN3uWS12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOS6_NSt3__112basic_stringIcNSA_11char_traitsIcEENSA_9allocatorIcEEEEONS6_17WebSocketBehaviorIT_EEEUlvE_E6createIJSL_EEEvRNS0_7storageEDpOT_: 118| 29.2k| static void create(storage& s, Args&&... args) { 119| 29.2k| new (static_cast(&s.buf_)) T(std::forward(args)...); 120| 29.2k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJEE12handler_baseINS2_13small_handlerIZN3uWS12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOS7_NSt3__112basic_stringIcNSB_11char_traitsIcEENSB_9allocatorIcEEEEONS7_17WebSocketBehaviorIT_EEEUlvE_EEE6handleENS0_6actionEPNS0_7storageESR_: 103| 29.2k| static void handle(action act, storage* current, storage* other = nullptr) { 104| 29.2k| switch (act) { ------------------ | Branch (104:15): [True: 0, False: 29.2k] ------------------ 105| 11.6k| case (action::destroy): ------------------ | Branch (105:9): [True: 11.6k, False: 17.5k] ------------------ 106| 11.6k| Derived::destroy(*current); 107| 11.6k| break; 108| 17.5k| case (action::move): ------------------ | Branch (108:9): [True: 17.5k, False: 11.6k] ------------------ 109| 17.5k| Derived::move(*current, *other); 110| 17.5k| break; 111| 29.2k| } 112| 29.2k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJEE13small_handlerIZN3uWS12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOS6_NSt3__112basic_stringIcNSA_11char_traitsIcEENSA_9allocatorIcEEEEONS6_17WebSocketBehaviorIT_EEEUlvE_E7destroyERNS0_7storageE: 122| 29.2k| static void destroy(storage& s) noexcept { 123| 29.2k| T& value = *static_cast(static_cast(&s.buf_)); 124| 29.2k| value.~T(); 125| 29.2k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJEE13small_handlerIZN3uWS12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOS6_NSt3__112basic_stringIcNSA_11char_traitsIcEENSA_9allocatorIcEEEEONS6_17WebSocketBehaviorIT_EEEUlvE_E4moveERNS0_7storageESO_: 127| 17.5k| static void move(storage& dst, storage& src) noexcept { 128| 17.5k| create(dst, std::move(*static_cast(static_cast(&src.buf_)))); 129| 17.5k| destroy(src); 130| 17.5k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJEE13small_handlerIZN3uWS12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOS6_NSt3__112basic_stringIcNSA_11char_traitsIcEENSA_9allocatorIcEEEEONS6_17WebSocketBehaviorIT_EEEUlvE_E4callERNS0_7storageE: 132| 11.6k| static R call(storage& s, ArgTypes... args) { 133| 11.6k| return std::invoke(*static_cast(static_cast(&s.buf_)), 134| 11.6k| std::forward(args)...); 135| 11.6k| } EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEEEaSEOS7_: 197| 23.3k| any_invocable_impl& operator=(any_invocable_impl&& rhs) noexcept { 198| 23.3k| any_invocable_impl{std::move(rhs)}.swap(*this); 199| 23.3k| return *this; 200| 23.3k| } EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEEEC2EOS7_: 188| 70.1k| any_invocable_impl(any_invocable_impl&& rhs) noexcept { 189| 70.1k| if (rhs.handle_) { ------------------ | Branch (189:9): [True: 23.3k, False: 46.7k] ------------------ 190| 23.3k| handle_ = rhs.handle_; 191| 23.3k| handle_(action::move, &storage_, &rhs.storage_); 192| 23.3k| call_ = rhs.call_; 193| 23.3k| rhs.handle_ = nullptr; 194| 23.3k| } 195| 70.1k| } EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEEE4swapERS7_: 208| 46.7k| void swap(any_invocable_impl& rhs) noexcept { 209| 46.7k| if (handle_) { ------------------ | Branch (209:9): [True: 23.3k, False: 23.3k] ------------------ 210| 23.3k| if (rhs.handle_) { ------------------ | Branch (210:11): [True: 0, False: 23.3k] ------------------ 211| 0| storage tmp; 212| 0| handle_(action::move, &tmp, &storage_); 213| 0| rhs.handle_(action::move, &storage_, &rhs.storage_); 214| 0| handle_(action::move, &rhs.storage_, &tmp); 215| 0| std::swap(handle_, rhs.handle_); 216| 0| std::swap(call_, rhs.call_); 217| 23.3k| } else { 218| 23.3k| rhs.swap(*this); 219| 23.3k| } 220| 23.3k| } else if (rhs.handle_) { ------------------ | Branch (220:16): [True: 23.3k, False: 0] ------------------ 221| 23.3k| rhs.handle_(action::move, &storage_, &rhs.storage_); 222| 23.3k| handle_ = rhs.handle_; 223| 23.3k| call_ = rhs.call_; 224| 23.3k| rhs.handle_ = nullptr; 225| 23.3k| } 226| 46.7k| } EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEENS2_6OpCodeEEEaSEOSD_: 197| 23.3k| any_invocable_impl& operator=(any_invocable_impl&& rhs) noexcept { 198| 23.3k| any_invocable_impl{std::move(rhs)}.swap(*this); 199| 23.3k| return *this; 200| 23.3k| } EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEENS2_6OpCodeEEEC2EOSD_: 188| 70.1k| any_invocable_impl(any_invocable_impl&& rhs) noexcept { 189| 70.1k| if (rhs.handle_) { ------------------ | Branch (189:9): [True: 11.6k, False: 58.4k] ------------------ 190| 11.6k| handle_ = rhs.handle_; 191| 11.6k| handle_(action::move, &storage_, &rhs.storage_); 192| 11.6k| call_ = rhs.call_; 193| 11.6k| rhs.handle_ = nullptr; 194| 11.6k| } 195| 70.1k| } EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEENS2_6OpCodeEEE4swapERSD_: 208| 35.0k| void swap(any_invocable_impl& rhs) noexcept { 209| 35.0k| if (handle_) { ------------------ | Branch (209:9): [True: 11.6k, False: 23.3k] ------------------ 210| 11.6k| if (rhs.handle_) { ------------------ | Branch (210:11): [True: 0, False: 11.6k] ------------------ 211| 0| storage tmp; 212| 0| handle_(action::move, &tmp, &storage_); 213| 0| rhs.handle_(action::move, &storage_, &rhs.storage_); 214| 0| handle_(action::move, &rhs.storage_, &tmp); 215| 0| std::swap(handle_, rhs.handle_); 216| 0| std::swap(call_, rhs.call_); 217| 11.6k| } else { 218| 11.6k| rhs.swap(*this); 219| 11.6k| } 220| 23.3k| } else if (rhs.handle_) { ------------------ | Branch (220:16): [True: 11.6k, False: 11.6k] ------------------ 221| 11.6k| rhs.handle_(action::move, &storage_, &rhs.storage_); 222| 11.6k| handle_ = rhs.handle_; 223| 11.6k| call_ = rhs.call_; 224| 11.6k| rhs.handle_ = nullptr; 225| 11.6k| } 226| 35.0k| } EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEiiEEaSEOSC_: 197| 11.6k| any_invocable_impl& operator=(any_invocable_impl&& rhs) noexcept { 198| 11.6k| any_invocable_impl{std::move(rhs)}.swap(*this); 199| 11.6k| return *this; 200| 11.6k| } EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEiiEEC2EOSC_: 188| 35.0k| any_invocable_impl(any_invocable_impl&& rhs) noexcept { 189| 35.0k| if (rhs.handle_) { ------------------ | Branch (189:9): [True: 0, False: 35.0k] ------------------ 190| 0| handle_ = rhs.handle_; 191| 0| handle_(action::move, &storage_, &rhs.storage_); 192| 0| call_ = rhs.call_; 193| 0| rhs.handle_ = nullptr; 194| 0| } 195| 35.0k| } EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEiiEE4swapERSC_: 208| 11.6k| void swap(any_invocable_impl& rhs) noexcept { 209| 11.6k| if (handle_) { ------------------ | Branch (209:9): [True: 0, False: 11.6k] ------------------ 210| 0| if (rhs.handle_) { ------------------ | Branch (210:11): [True: 0, False: 0] ------------------ 211| 0| storage tmp; 212| 0| handle_(action::move, &tmp, &storage_); 213| 0| rhs.handle_(action::move, &storage_, &rhs.storage_); 214| 0| handle_(action::move, &rhs.storage_, &tmp); 215| 0| std::swap(handle_, rhs.handle_); 216| 0| std::swap(call_, rhs.call_); 217| 0| } else { 218| 0| rhs.swap(*this); 219| 0| } 220| 11.6k| } else if (rhs.handle_) { ------------------ | Branch (220:16): [True: 0, False: 11.6k] ------------------ 221| 0| rhs.handle_(action::move, &storage_, &rhs.storage_); 222| 0| handle_ = rhs.handle_; 223| 0| call_ = rhs.call_; 224| 0| rhs.handle_ = nullptr; 225| 0| } 226| 11.6k| } EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEiNSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEEC2EOSC_: 188| 46.7k| any_invocable_impl(any_invocable_impl&& rhs) noexcept { 189| 46.7k| if (rhs.handle_) { ------------------ | Branch (189:9): [True: 23.3k, False: 23.3k] ------------------ 190| 23.3k| handle_ = rhs.handle_; 191| 23.3k| handle_(action::move, &storage_, &rhs.storage_); 192| 23.3k| call_ = rhs.call_; 193| 23.3k| rhs.handle_ = nullptr; 194| 23.3k| } 195| 46.7k| } EpollEchoServer.cpp:_ZN5ofats13any_invocableIFvPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEiNSt3__117basic_string_viewIcNS6_11char_traitsIcEEEEEEaSIZNS1_12TemplatedAppILb0EE2wsIS3_EEOSF_NS6_12basic_stringIcS9_NS6_9allocatorIcEEEEONSF_17WebSocketBehaviorIT_EEEUlS5_iSA_E_SQ_EENS6_9enable_ifIXaantsr3stdE9is_same_vIT0_SC_Esr3stdE23is_move_constructible_vISS_EERSC_E4typeEOSN_: 335| 11.6k| operator=(F&& f) { \ 336| 11.6k| any_invocable{std::forward(f)}.swap(*this); \ 337| 11.6k| return *this; \ 338| 11.6k| } \ EpollEchoServer.cpp:_ZN5ofats13any_invocableIFvPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEiNSt3__117basic_string_viewIcNS6_11char_traitsIcEEEEEEC2IZNS1_12TemplatedAppILb0EE2wsIS3_EEOSF_NS6_12basic_stringIcS9_NS6_9allocatorIcEEEEONSF_17WebSocketBehaviorIT_EEEUlS5_iSA_E_vEEOSN_: 303| 11.6k| any_invocable(F&& f) { \ 304| 11.6k| base_type::template create>(std::forward(f)); \ 305| 11.6k| } \ EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEiNSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEEC2Ev: 186| 23.3k| any_invocable_impl() noexcept = default; EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEiNSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEE6createIZNS2_12TemplatedAppILb0EE2wsIS4_EEOSF_NS7_12basic_stringIcSA_NS7_9allocatorIcEEEEONSF_17WebSocketBehaviorIT_EEEUlS6_iSB_E_JSQ_EEEvDpOT0_: 232| 11.6k| void create(Args&&... args) { 233| 11.6k| using hdl = handler; 234| 11.6k| hdl::create(storage_, std::forward(args)...); 235| 11.6k| handle_ = &hdl::handle; 236| 11.6k| call_ = &hdl::call; 237| 11.6k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEiNSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEE13large_handlerIZNS2_12TemplatedAppILb0EE2wsIS4_EEOSF_NS7_12basic_stringIcSA_NS7_9allocatorIcEEEEONSF_17WebSocketBehaviorIT_EEEUlS6_iSB_E_E6createIJSQ_EEEvRNS0_7storageEDpOT_: 141| 11.6k| static void create(storage& s, Args&&... args) { 142| 11.6k| s.ptr_ = new T(std::forward(args)...); 143| 11.6k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEiNSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEE12handler_baseINSC_13large_handlerIZNS2_12TemplatedAppILb0EE2wsIS4_EEOSG_NS7_12basic_stringIcSA_NS7_9allocatorIcEEEEONSG_17WebSocketBehaviorIT_EEEUlS6_iSB_E_EEE6handleENS0_6actionEPNS0_7storageESW_: 103| 23.3k| static void handle(action act, storage* current, storage* other = nullptr) { 104| 23.3k| switch (act) { ------------------ | Branch (104:15): [True: 0, False: 23.3k] ------------------ 105| 11.6k| case (action::destroy): ------------------ | Branch (105:9): [True: 11.6k, False: 11.6k] ------------------ 106| 11.6k| Derived::destroy(*current); 107| 11.6k| break; 108| 11.6k| case (action::move): ------------------ | Branch (108:9): [True: 11.6k, False: 11.6k] ------------------ 109| 11.6k| Derived::move(*current, *other); 110| 11.6k| break; 111| 23.3k| } 112| 23.3k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEiNSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEE13large_handlerIZNS2_12TemplatedAppILb0EE2wsIS4_EEOSF_NS7_12basic_stringIcSA_NS7_9allocatorIcEEEEONSF_17WebSocketBehaviorIT_EEEUlS6_iSB_E_E7destroyERNS0_7storageE: 145| 11.6k| static void destroy(storage& s) noexcept { delete static_cast(s.ptr_); } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEiNSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEE13large_handlerIZNS2_12TemplatedAppILb0EE2wsIS4_EEOSF_NS7_12basic_stringIcSA_NS7_9allocatorIcEEEEONSF_17WebSocketBehaviorIT_EEEUlS6_iSB_E_E4moveERNS0_7storageEST_: 147| 11.6k| static void move(storage& dst, storage& src) noexcept { 148| 11.6k| dst.ptr_ = src.ptr_; 149| 11.6k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEiNSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEE13large_handlerIZNS2_12TemplatedAppILb0EE2wsIS4_EEOSF_NS7_12basic_stringIcSA_NS7_9allocatorIcEEEEONSF_17WebSocketBehaviorIT_EEEUlS6_iSB_E_E4callERNS0_7storageES6_iSB_: 151| 164k| static R call(storage& s, ArgTypes... args) { 152| 164k| return std::invoke(*static_cast(s.ptr_), 153| 164k| std::forward(args)...); 154| 164k| } EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEiNSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEE4swapERSC_: 208| 23.3k| void swap(any_invocable_impl& rhs) noexcept { 209| 23.3k| if (handle_) { ------------------ | Branch (209:9): [True: 11.6k, False: 11.6k] ------------------ 210| 11.6k| if (rhs.handle_) { ------------------ | Branch (210:11): [True: 0, False: 11.6k] ------------------ 211| 0| storage tmp; 212| 0| handle_(action::move, &tmp, &storage_); 213| 0| rhs.handle_(action::move, &storage_, &rhs.storage_); 214| 0| handle_(action::move, &rhs.storage_, &tmp); 215| 0| std::swap(handle_, rhs.handle_); 216| 0| std::swap(call_, rhs.call_); 217| 11.6k| } else { 218| 11.6k| rhs.swap(*this); 219| 11.6k| } 220| 11.6k| } else if (rhs.handle_) { ------------------ | Branch (220:16): [True: 11.6k, False: 0] ------------------ 221| 11.6k| rhs.handle_(action::move, &storage_, &rhs.storage_); 222| 11.6k| handle_ = rhs.handle_; 223| 11.6k| call_ = rhs.call_; 224| 11.6k| rhs.handle_ = nullptr; 225| 11.6k| } 226| 23.3k| } EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEEaSEOSC_: 197| 23.3k| any_invocable_impl& operator=(any_invocable_impl&& rhs) noexcept { 198| 23.3k| any_invocable_impl{std::move(rhs)}.swap(*this); 199| 23.3k| return *this; 200| 23.3k| } EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEEC2EOSC_: 188| 70.1k| any_invocable_impl(any_invocable_impl&& rhs) noexcept { 189| 70.1k| if (rhs.handle_) { ------------------ | Branch (189:9): [True: 23.3k, False: 46.7k] ------------------ 190| 23.3k| handle_ = rhs.handle_; 191| 23.3k| handle_(action::move, &storage_, &rhs.storage_); 192| 23.3k| call_ = rhs.call_; 193| 23.3k| rhs.handle_ = nullptr; 194| 23.3k| } 195| 70.1k| } EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEE4swapERSC_: 208| 46.7k| void swap(any_invocable_impl& rhs) noexcept { 209| 46.7k| if (handle_) { ------------------ | Branch (209:9): [True: 23.3k, False: 23.3k] ------------------ 210| 23.3k| if (rhs.handle_) { ------------------ | Branch (210:11): [True: 0, False: 23.3k] ------------------ 211| 0| storage tmp; 212| 0| handle_(action::move, &tmp, &storage_); 213| 0| rhs.handle_(action::move, &storage_, &rhs.storage_); 214| 0| handle_(action::move, &rhs.storage_, &tmp); 215| 0| std::swap(handle_, rhs.handle_); 216| 0| std::swap(call_, rhs.call_); 217| 23.3k| } else { 218| 23.3k| rhs.swap(*this); 219| 23.3k| } 220| 23.3k| } else if (rhs.handle_) { ------------------ | Branch (220:16): [True: 23.3k, False: 0] ------------------ 221| 23.3k| rhs.handle_(action::move, &storage_, &rhs.storage_); 222| 23.3k| handle_ = rhs.handle_; 223| 23.3k| call_ = rhs.call_; 224| 23.3k| rhs.handle_ = nullptr; 225| 23.3k| } 226| 46.7k| } _ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS12HttpResponseILb0EEEPNS2_11HttpRequestEP19us_socket_context_tEEC2EOSA_: 188| 23.3k| any_invocable_impl(any_invocable_impl&& rhs) noexcept { 189| 23.3k| if (rhs.handle_) { ------------------ | Branch (189:9): [True: 0, False: 23.3k] ------------------ 190| 0| handle_ = rhs.handle_; 191| 0| handle_(action::move, &storage_, &rhs.storage_); 192| 0| call_ = rhs.call_; 193| 0| rhs.handle_ = nullptr; 194| 0| } 195| 23.3k| } EpollEchoServer.cpp:_ZN5ofats13any_invocableIFvPN3uWS12HttpResponseILb0EEEPNS1_11HttpRequestEEEC2IZNS1_12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOSB_NSt3__112basic_stringIcNSF_11char_traitsIcEENSF_9allocatorIcEEEEONSB_17WebSocketBehaviorIT_EEEUlPSN_PT0_E_vEEOSN_: 303| 11.6k| any_invocable(F&& f) { \ 304| 11.6k| base_type::template create>(std::forward(f)); \ 305| 11.6k| } \ EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS12HttpResponseILb0EEEPNS2_11HttpRequestEEE6createIZNS2_12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOSB_NSt3__112basic_stringIcNSF_11char_traitsIcEENSF_9allocatorIcEEEEONSB_17WebSocketBehaviorIT_EEEUlPSN_PT0_E_JST_EEEvDpOT0_: 232| 11.6k| void create(Args&&... args) { 233| 11.6k| using hdl = handler; 234| 11.6k| hdl::create(storage_, std::forward(args)...); 235| 11.6k| handle_ = &hdl::handle; 236| 11.6k| call_ = &hdl::call; 237| 11.6k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS12HttpResponseILb0EEEPNS2_11HttpRequestEEE13large_handlerIZNS2_12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOSB_NSt3__112basic_stringIcNSF_11char_traitsIcEENSF_9allocatorIcEEEEONSB_17WebSocketBehaviorIT_EEEUlPSN_PT0_E_E6createIJST_EEEvRNS0_7storageEDpOT_: 141| 11.6k| static void create(storage& s, Args&&... args) { 142| 11.6k| s.ptr_ = new T(std::forward(args)...); 143| 11.6k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS12HttpResponseILb0EEEPNS2_11HttpRequestEEE12handler_baseINS8_13large_handlerIZNS2_12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOSC_NSt3__112basic_stringIcNSG_11char_traitsIcEENSG_9allocatorIcEEEEONSC_17WebSocketBehaviorIT_EEEUlPSO_PT0_E_EEE6handleENS0_6actionEPNS0_7storageESZ_: 103| 35.0k| static void handle(action act, storage* current, storage* other = nullptr) { 104| 35.0k| switch (act) { ------------------ | Branch (104:15): [True: 0, False: 35.0k] ------------------ 105| 11.6k| case (action::destroy): ------------------ | Branch (105:9): [True: 11.6k, False: 23.3k] ------------------ 106| 11.6k| Derived::destroy(*current); 107| 11.6k| break; 108| 23.3k| case (action::move): ------------------ | Branch (108:9): [True: 23.3k, False: 11.6k] ------------------ 109| 23.3k| Derived::move(*current, *other); 110| 23.3k| break; 111| 35.0k| } 112| 35.0k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS12HttpResponseILb0EEEPNS2_11HttpRequestEEE13large_handlerIZNS2_12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOSB_NSt3__112basic_stringIcNSF_11char_traitsIcEENSF_9allocatorIcEEEEONSB_17WebSocketBehaviorIT_EEEUlPSN_PT0_E_E7destroyERNS0_7storageE: 145| 11.6k| static void destroy(storage& s) noexcept { delete static_cast(s.ptr_); } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS12HttpResponseILb0EEEPNS2_11HttpRequestEEE13large_handlerIZNS2_12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOSB_NSt3__112basic_stringIcNSF_11char_traitsIcEENSF_9allocatorIcEEEEONSB_17WebSocketBehaviorIT_EEEUlPSN_PT0_E_E4moveERNS0_7storageESW_: 147| 23.3k| static void move(storage& dst, storage& src) noexcept { 148| 23.3k| dst.ptr_ = src.ptr_; 149| 23.3k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS12HttpResponseILb0EEEPNS2_11HttpRequestEEE13large_handlerIZNS2_12TemplatedAppILb0EE2wsIZ4testvE13PerSocketDataEEOSB_NSt3__112basic_stringIcNSF_11char_traitsIcEENSF_9allocatorIcEEEEONSB_17WebSocketBehaviorIT_EEEUlPSN_PT0_E_E4callERNS0_7storageES5_S7_: 151| 169k| static R call(storage& s, ArgTypes... args) { 152| 169k| return std::invoke(*static_cast(s.ptr_), 153| 169k| std::forward(args)...); 154| 169k| } _ZNK5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS12HttpResponseILb0EEEPNS2_11HttpRequestEP19us_socket_context_tEEcvbEv: 228| 164k| explicit operator bool() const noexcept { return handle_ != nullptr; } EpollEchoServer.cpp:_ZN5ofats13any_invocableIFvPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEEEC2IZ4testvE3$_0vEEOT_: 303| 5.84k| any_invocable(F&& f) { \ 304| 5.84k| base_type::template create>(std::forward(f)); \ 305| 5.84k| } \ EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEEEC2Ev: 186| 23.3k| any_invocable_impl() noexcept = default; EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEEE6createIZ4testvE3$_0JS9_EEEvDpOT0_: 232| 5.84k| void create(Args&&... args) { 233| 5.84k| using hdl = handler; 234| 5.84k| hdl::create(storage_, std::forward(args)...); 235| 5.84k| handle_ = &hdl::handle; 236| 5.84k| call_ = &hdl::call; 237| 5.84k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEEE13small_handlerIZ4testvE3$_0E6createIJS9_EEEvRNS0_7storageEDpOT_: 118| 17.5k| static void create(storage& s, Args&&... args) { 119| 17.5k| new (static_cast(&s.buf_)) T(std::forward(args)...); 120| 17.5k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEEE12handler_baseINS7_13small_handlerIZ4testvE3$_0EEE6handleENS0_6actionEPNS0_7storageESF_: 103| 17.5k| static void handle(action act, storage* current, storage* other = nullptr) { 104| 17.5k| switch (act) { ------------------ | Branch (104:15): [True: 0, False: 17.5k] ------------------ 105| 5.84k| case (action::destroy): ------------------ | Branch (105:9): [True: 5.84k, False: 11.6k] ------------------ 106| 5.84k| Derived::destroy(*current); 107| 5.84k| break; 108| 11.6k| case (action::move): ------------------ | Branch (108:9): [True: 11.6k, False: 5.84k] ------------------ 109| 11.6k| Derived::move(*current, *other); 110| 11.6k| break; 111| 17.5k| } 112| 17.5k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEEE13small_handlerIZ4testvE3$_0E7destroyERNS0_7storageE: 122| 17.5k| static void destroy(storage& s) noexcept { 123| 17.5k| T& value = *static_cast(static_cast(&s.buf_)); 124| 17.5k| value.~T(); 125| 17.5k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEEE13small_handlerIZ4testvE3$_0E4moveERNS0_7storageESC_: 127| 11.6k| static void move(storage& dst, storage& src) noexcept { 128| 11.6k| create(dst, std::move(*static_cast(static_cast(&src.buf_)))); 129| 11.6k| destroy(src); 130| 11.6k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEEE13small_handlerIZ4testvE3$_0E4callERNS0_7storageES6_: 132| 130k| static R call(storage& s, ArgTypes... args) { 133| 130k| return std::invoke(*static_cast(static_cast(&s.buf_)), 134| 130k| std::forward(args)...); 135| 130k| } EpollEchoServer.cpp:_ZN5ofats13any_invocableIFvPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS6_11char_traitsIcEEEENS1_6OpCodeEEEC2IZ4testvE3$_1vEEOT_: 303| 5.84k| any_invocable(F&& f) { \ 304| 5.84k| base_type::template create>(std::forward(f)); \ 305| 5.84k| } \ EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEENS2_6OpCodeEEEC2Ev: 186| 11.6k| any_invocable_impl() noexcept = default; EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEENS2_6OpCodeEEE6createIZ4testvE3$_1JSF_EEEvDpOT0_: 232| 5.84k| void create(Args&&... args) { 233| 5.84k| using hdl = handler; 234| 5.84k| hdl::create(storage_, std::forward(args)...); 235| 5.84k| handle_ = &hdl::handle; 236| 5.84k| call_ = &hdl::call; 237| 5.84k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEENS2_6OpCodeEEE13small_handlerIZ4testvE3$_1E6createIJSF_EEEvRNS0_7storageEDpOT_: 118| 17.5k| static void create(storage& s, Args&&... args) { 119| 17.5k| new (static_cast(&s.buf_)) T(std::forward(args)...); 120| 17.5k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEENS2_6OpCodeEEE12handler_baseINSD_13small_handlerIZ4testvE3$_1EEE6handleENS0_6actionEPNS0_7storageESL_: 103| 17.5k| static void handle(action act, storage* current, storage* other = nullptr) { 104| 17.5k| switch (act) { ------------------ | Branch (104:15): [True: 0, False: 17.5k] ------------------ 105| 5.84k| case (action::destroy): ------------------ | Branch (105:9): [True: 5.84k, False: 11.6k] ------------------ 106| 5.84k| Derived::destroy(*current); 107| 5.84k| break; 108| 11.6k| case (action::move): ------------------ | Branch (108:9): [True: 11.6k, False: 5.84k] ------------------ 109| 11.6k| Derived::move(*current, *other); 110| 11.6k| break; 111| 17.5k| } 112| 17.5k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEENS2_6OpCodeEEE13small_handlerIZ4testvE3$_1E7destroyERNS0_7storageE: 122| 17.5k| static void destroy(storage& s) noexcept { 123| 17.5k| T& value = *static_cast(static_cast(&s.buf_)); 124| 17.5k| value.~T(); 125| 17.5k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEENS2_6OpCodeEEE13small_handlerIZ4testvE3$_1E4moveERNS0_7storageESI_: 127| 11.6k| static void move(storage& dst, storage& src) noexcept { 128| 11.6k| create(dst, std::move(*static_cast(static_cast(&src.buf_)))); 129| 11.6k| destroy(src); 130| 11.6k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEENS2_6OpCodeEEE13small_handlerIZ4testvE3$_1E4callERNS0_7storageES6_SB_SC_: 132| 29.1k| static R call(storage& s, ArgTypes... args) { 133| 29.1k| return std::invoke(*static_cast(static_cast(&s.buf_)), 134| 29.1k| std::forward(args)...); 135| 29.1k| } EpollEchoServer.cpp:_ZN5ofats13any_invocableIFvPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEEEC2IZ4testvE3$_2vEEOT_: 303| 5.84k| any_invocable(F&& f) { \ 304| 5.84k| base_type::template create>(std::forward(f)); \ 305| 5.84k| } \ EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEEE6createIZ4testvE3$_2JS9_EEEvDpOT0_: 232| 5.84k| void create(Args&&... args) { 233| 5.84k| using hdl = handler; 234| 5.84k| hdl::create(storage_, std::forward(args)...); 235| 5.84k| handle_ = &hdl::handle; 236| 5.84k| call_ = &hdl::call; 237| 5.84k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEEE13small_handlerIZ4testvE3$_2E6createIJS9_EEEvRNS0_7storageEDpOT_: 118| 17.5k| static void create(storage& s, Args&&... args) { 119| 17.5k| new (static_cast(&s.buf_)) T(std::forward(args)...); 120| 17.5k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEEE12handler_baseINS7_13small_handlerIZ4testvE3$_2EEE6handleENS0_6actionEPNS0_7storageESF_: 103| 17.5k| static void handle(action act, storage* current, storage* other = nullptr) { 104| 17.5k| switch (act) { ------------------ | Branch (104:15): [True: 0, False: 17.5k] ------------------ 105| 5.84k| case (action::destroy): ------------------ | Branch (105:9): [True: 5.84k, False: 11.6k] ------------------ 106| 5.84k| Derived::destroy(*current); 107| 5.84k| break; 108| 11.6k| case (action::move): ------------------ | Branch (108:9): [True: 11.6k, False: 5.84k] ------------------ 109| 11.6k| Derived::move(*current, *other); 110| 11.6k| break; 111| 17.5k| } 112| 17.5k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEEE13small_handlerIZ4testvE3$_2E7destroyERNS0_7storageE: 122| 17.5k| static void destroy(storage& s) noexcept { 123| 17.5k| T& value = *static_cast(static_cast(&s.buf_)); 124| 17.5k| value.~T(); 125| 17.5k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEEE13small_handlerIZ4testvE3$_2E4moveERNS0_7storageESC_: 127| 11.6k| static void move(storage& dst, storage& src) noexcept { 128| 11.6k| create(dst, std::move(*static_cast(static_cast(&src.buf_)))); 129| 11.6k| destroy(src); 130| 11.6k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEEE13small_handlerIZ4testvE3$_2E4callERNS0_7storageES6_: 132| 19.4k| static R call(storage& s, ArgTypes... args) { 133| 19.4k| return std::invoke(*static_cast(static_cast(&s.buf_)), 134| 19.4k| std::forward(args)...); 135| 19.4k| } EpollEchoServer.cpp:_ZN5ofats13any_invocableIFvPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS6_11char_traitsIcEEEEEEC2IZ4testvE3$_3vEEOT_: 303| 5.84k| any_invocable(F&& f) { \ 304| 5.84k| base_type::template create>(std::forward(f)); \ 305| 5.84k| } \ EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEEC2Ev: 186| 23.3k| any_invocable_impl() noexcept = default; EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEE6createIZ4testvE3$_3JSE_EEEvDpOT0_: 232| 5.84k| void create(Args&&... args) { 233| 5.84k| using hdl = handler; 234| 5.84k| hdl::create(storage_, std::forward(args)...); 235| 5.84k| handle_ = &hdl::handle; 236| 5.84k| call_ = &hdl::call; 237| 5.84k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEE13small_handlerIZ4testvE3$_3E6createIJSE_EEEvRNS0_7storageEDpOT_: 118| 17.5k| static void create(storage& s, Args&&... args) { 119| 17.5k| new (static_cast(&s.buf_)) T(std::forward(args)...); 120| 17.5k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEE12handler_baseINSC_13small_handlerIZ4testvE3$_3EEE6handleENS0_6actionEPNS0_7storageESK_: 103| 17.5k| static void handle(action act, storage* current, storage* other = nullptr) { 104| 17.5k| switch (act) { ------------------ | Branch (104:15): [True: 0, False: 17.5k] ------------------ 105| 5.84k| case (action::destroy): ------------------ | Branch (105:9): [True: 5.84k, False: 11.6k] ------------------ 106| 5.84k| Derived::destroy(*current); 107| 5.84k| break; 108| 11.6k| case (action::move): ------------------ | Branch (108:9): [True: 11.6k, False: 5.84k] ------------------ 109| 11.6k| Derived::move(*current, *other); 110| 11.6k| break; 111| 17.5k| } 112| 17.5k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEE13small_handlerIZ4testvE3$_3E7destroyERNS0_7storageE: 122| 17.5k| static void destroy(storage& s) noexcept { 123| 17.5k| T& value = *static_cast(static_cast(&s.buf_)); 124| 17.5k| value.~T(); 125| 17.5k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEE13small_handlerIZ4testvE3$_3E4moveERNS0_7storageESH_: 127| 11.6k| static void move(storage& dst, storage& src) noexcept { 128| 11.6k| create(dst, std::move(*static_cast(static_cast(&src.buf_)))); 129| 11.6k| destroy(src); 130| 11.6k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEE13small_handlerIZ4testvE3$_3E4callERNS0_7storageES6_SB_: 132| 3.94k| static R call(storage& s, ArgTypes... args) { 133| 3.94k| return std::invoke(*static_cast(static_cast(&s.buf_)), 134| 3.94k| std::forward(args)...); 135| 3.94k| } EpollEchoServer.cpp:_ZN5ofats13any_invocableIFvPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS6_11char_traitsIcEEEEEEC2IZ4testvE3$_4vEEOT_: 303| 5.84k| any_invocable(F&& f) { \ 304| 5.84k| base_type::template create>(std::forward(f)); \ 305| 5.84k| } \ EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEE6createIZ4testvE3$_4JSE_EEEvDpOT0_: 232| 5.84k| void create(Args&&... args) { 233| 5.84k| using hdl = handler; 234| 5.84k| hdl::create(storage_, std::forward(args)...); 235| 5.84k| handle_ = &hdl::handle; 236| 5.84k| call_ = &hdl::call; 237| 5.84k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEE13small_handlerIZ4testvE3$_4E6createIJSE_EEEvRNS0_7storageEDpOT_: 118| 17.5k| static void create(storage& s, Args&&... args) { 119| 17.5k| new (static_cast(&s.buf_)) T(std::forward(args)...); 120| 17.5k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEE12handler_baseINSC_13small_handlerIZ4testvE3$_4EEE6handleENS0_6actionEPNS0_7storageESK_: 103| 17.5k| static void handle(action act, storage* current, storage* other = nullptr) { 104| 17.5k| switch (act) { ------------------ | Branch (104:15): [True: 0, False: 17.5k] ------------------ 105| 5.84k| case (action::destroy): ------------------ | Branch (105:9): [True: 5.84k, False: 11.6k] ------------------ 106| 5.84k| Derived::destroy(*current); 107| 5.84k| break; 108| 11.6k| case (action::move): ------------------ | Branch (108:9): [True: 11.6k, False: 5.84k] ------------------ 109| 11.6k| Derived::move(*current, *other); 110| 11.6k| break; 111| 17.5k| } 112| 17.5k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEE13small_handlerIZ4testvE3$_4E7destroyERNS0_7storageE: 122| 17.5k| static void destroy(storage& s) noexcept { 123| 17.5k| T& value = *static_cast(static_cast(&s.buf_)); 124| 17.5k| value.~T(); 125| 17.5k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEE13small_handlerIZ4testvE3$_4E4moveERNS0_7storageESH_: 127| 11.6k| static void move(storage& dst, storage& src) noexcept { 128| 11.6k| create(dst, std::move(*static_cast(static_cast(&src.buf_)))); 129| 11.6k| destroy(src); 130| 11.6k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEENSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEE13small_handlerIZ4testvE3$_4E4callERNS0_7storageES6_SB_: 132| 1.49k| static R call(storage& s, ArgTypes... args) { 133| 1.49k| return std::invoke(*static_cast(static_cast(&s.buf_)), 134| 1.49k| std::forward(args)...); 135| 1.49k| } EpollEchoServer.cpp:_ZN5ofats13any_invocableIFvPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEiNSt3__117basic_string_viewIcNS6_11char_traitsIcEEEEEEC2IZ4testvE3$_5vEEOT_: 303| 5.84k| any_invocable(F&& f) { \ 304| 5.84k| base_type::template create>(std::forward(f)); \ 305| 5.84k| } \ EpollEchoServer.cpp:_ZN5ofats10any_detail18any_invocable_implIvLb0EJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEiNSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEE6createIZ4testvE3$_5JSE_EEEvDpOT0_: 232| 5.84k| void create(Args&&... args) { 233| 5.84k| using hdl = handler; 234| 5.84k| hdl::create(storage_, std::forward(args)...); 235| 5.84k| handle_ = &hdl::handle; 236| 5.84k| call_ = &hdl::call; 237| 5.84k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEiNSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEE13small_handlerIZ4testvE3$_5E6createIJSE_EEEvRNS0_7storageEDpOT_: 118| 17.5k| static void create(storage& s, Args&&... args) { 119| 17.5k| new (static_cast(&s.buf_)) T(std::forward(args)...); 120| 17.5k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEiNSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEE12handler_baseINSC_13small_handlerIZ4testvE3$_5EEE6handleENS0_6actionEPNS0_7storageESK_: 103| 17.5k| static void handle(action act, storage* current, storage* other = nullptr) { 104| 17.5k| switch (act) { ------------------ | Branch (104:15): [True: 0, False: 17.5k] ------------------ 105| 5.84k| case (action::destroy): ------------------ | Branch (105:9): [True: 5.84k, False: 11.6k] ------------------ 106| 5.84k| Derived::destroy(*current); 107| 5.84k| break; 108| 11.6k| case (action::move): ------------------ | Branch (108:9): [True: 11.6k, False: 5.84k] ------------------ 109| 11.6k| Derived::move(*current, *other); 110| 11.6k| break; 111| 17.5k| } 112| 17.5k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEiNSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEE13small_handlerIZ4testvE3$_5E7destroyERNS0_7storageE: 122| 17.5k| static void destroy(storage& s) noexcept { 123| 17.5k| T& value = *static_cast(static_cast(&s.buf_)); 124| 17.5k| value.~T(); 125| 17.5k| } EpollEchoServer.cpp:_ZN5ofats10any_detail14handler_traitsIvJPN3uWS9WebSocketILb0ELb1EZ4testvE13PerSocketDataEEiNSt3__117basic_string_viewIcNS7_11char_traitsIcEEEEEE13small_handlerIZ4testvE3$_5E4moveERNS0_7storageESH_: 127| 11.6k| static void move(storage& dst, storage& src) noexcept { 128| 11.6k| create(dst, std::move(*static_cast