network/libnetservices2/HttpSession.cpp

61 	Request(BHttpRequest&& request, BBorrow<BDataIO> target, BMessenger observer);
130 	BHttpResult Execute(BHttpRequest&& request, BBorrow<BDataIO> target, BMessenger observer);
220 BHttpSession::Impl::Execute(BHttpRequest&& request, BBorrow<BDataIO> target, BMessenger observer)
222 	auto wRequest = Request(std::move(request), std::move(target), observer);
237 	fControlQueue.remove_if([&identifier](auto& request) {
238 		if (request.Id() == identifier) {
242 				request.SetError(std::current_exception());
298 		for (auto& request: requests) {
301 				request.ResolveHostName();
302 				request.OpenConnection();
304 				request.SetError(std::current_exception());
309 				// Do not add the request back to the queue; release the sem to do another round
317 			impl->fDataQueue.push_back(std::move(request));
329 		for (auto& request: impl->fControlQueue) {
333 				request.SetError(std::current_exception());
378 			// be a situation where a request is cancelled and added in the
382 				auto request = std::move(data->fDataQueue.front());
384 				auto socket = request.Socket();
386 				data->connectionMap.insert(std::make_pair(socket, std::move(request)));
421 				auto& request = data->connectionMap.find(item.object)->second;
424 					request.TransferRequest();
426 					request.SetError(std::current_exception());
432 					request.Disconnect();
439 				auto& request = data->connectionMap.find(item.object)->second;
442 					if (request.CanCancel())
445 						finished = request.ReceiveResult();
448 					// Move existing request into a new request and hand over to the control queue
450 					data->fControlQueue.emplace_back(request, r);
455 					request.SetError(std::current_exception());
461 					request.Disconnect();
468 				auto& request = data->connectionMap.find(item.object)->second;
473 					request.SetError(std::current_exception());
478 				auto& request = data->connectionMap.find(item.object)->second;
479 				request.Disconnect();
483 					request.SetError(std::current_exception());
494 				auto& request = data->connectionMap.find(item.object)->second;
495 				request.SendMessage(UrlEvent::DebugMessage, [](BMessage& msg) {
513 				throw BRuntimeError(__PRETTY_FUNCTION__, "Invalid state of request");
563 	fControlQueue.remove_if([this, &requests](auto& request) {
564 		auto host = request.GetHost();
569 				request.SendMessage(UrlEvent::DebugMessage, [](BMessage& msg) {
577 				request.SetCounter(std::addressof(it->second));
581 				request.SendMessage(UrlEvent::DebugMessage, [](BMessage& msg) {
592 			request.SetCounter(std::addressof(newIt->second));
594 		requests.emplace_back(std::move(request));
620 BHttpSession::Execute(BHttpRequest&& request, BBorrow<BDataIO> target, BMessenger observer)
622 	return fImpl->Execute(std::move(request), std::move(target), observer);
634 BHttpSession::Cancel(const BHttpResult& request)
636 	fImpl->Cancel(request.Identity());
655 BHttpSession::Request::Request(BHttpRequest&& request, BBorrow<BDataIO> target, BMessenger observer)
657 	fRequest(std::move(request)),
672 	// inform the parser when we do a HEAD request, so not to expect content
684 	// update the original request with the new location
695 	// inform the parser when we do a HEAD request, so not to expect content
740 	\brief Resolve the hostname for a request
802 	\brief Transfer data from the request to the socket.
804 	\returns \c true if the request is complete, or false if there is more.
812 			__PRETTY_FUNCTION__, "Write request for object that is not in the Connected state");
835 	\returns \c true if the request is complete, or false if there is more.
867 							// These redirects require the request body to be sent again. It this is
934 						// 302 and 303 redirections convert all requests to GET request, except for