Represents a thread in the thread pool handling requests to HTTP(S) servers. There are several of these, the total defined by a constant in queues.cpp, and each one will always receive requests for the same rate limit bucket based on its endpoint portion of the url. This makes rate limit handling reliable and easy to manage. Each of these also has its own mutex, so that requests are less likely to block while waiting for internal containers to be usable. More...

Public Member Functions
	in_thread (class cluster owner, class request_queue req_q, uint32_t index)
	Construct a new in thread object. More...

	~in_thread ()
	Destroy the in thread object This will end the thread that is owned by this object by joining it. More...

void	post_request (http_request *req)
	Post a http_request to this thread. More...

Detailed Description

Represents a thread in the thread pool handling requests to HTTP(S) servers. There are several of these, the total defined by a constant in queues.cpp, and each one will always receive requests for the same rate limit bucket based on its endpoint portion of the url. This makes rate limit handling reliable and easy to manage. Each of these also has its own mutex, so that requests are less likely to block while waiting for internal containers to be usable.

Constructor & Destructor Documentation

◆ in_thread()

dpp::in_thread::in_thread	(	class cluster *	owner,
		class request_queue *	req_q,
		uint32_t	index
	)

Construct a new in thread object.

Parameters

owner	Owning cluster
req_q	Owning request queue
index	Thread index number

◆ ~in_thread()

dpp::in_thread::~in_thread ( )

Destroy the in thread object This will end the thread that is owned by this object by joining it.

Member Function Documentation

◆ post_request()

void dpp::in_thread::post_request ( http_request * req )

Post a http_request to this thread.