Merge pull request #1774 from Barenboim/master

Add task 'const' interfaces.

Author: Barenboim

src/client/WFConsulClient.cc

@@ -71,7 +71,7 @@ static bool parse_list_service_result(const json_value_t *root,
 							std::vector<struct ConsulServiceTags>& result);
 
 bool WFConsulTask::get_discover_result(
-	std::vector<struct ConsulServiceInstance>& result)
+	std::vector<struct ConsulServiceInstance>& result) const
 {
 	json_value_t *root;
 	int errno_bak;
@@ -99,7 +99,7 @@ bool WFConsulTask::get_discover_result(
 }
 
 bool WFConsulTask::get_list_service_result(
-	std::vector<struct ConsulServiceTags>& result)
+	std::vector<struct ConsulServiceTags>& result) const
 {
 	json_value_t *root;
 	int errno_bak;

src/client/WFConsulClient.h

@@ -44,10 +44,10 @@ class WFConsulTask : public WFGenericTask
 {
 public:
 	bool get_discover_result(
-			std::vector<struct protocol::ConsulServiceInstance>& result);
+			std::vector<struct protocol::ConsulServiceInstance>& result) const;
 
 	bool get_list_service_result(
-			std::vector<struct protocol::ConsulServiceTags>& result);
+			std::vector<struct protocol::ConsulServiceTags>& result) const;
 
 public:
 	void set_service(const struct protocol::ConsulService *service);
@@ -71,6 +71,7 @@ class WFConsulTask : public WFGenericTask
 	{
 		this->consul_index = consul_index;
 	}
+
 	long long get_consul_index() const { return this->consul_index; }
 
 	const protocol::HttpResponse *get_http_resp() const

src/client/WFHttpChunkedClient.h

@@ -34,6 +34,11 @@ class WFHttpChunkedTask : public WFGenericTask
 		return this->chunk;
 	}
 
+	const protocol::HttpMessageChunk *get_chunk() const
+	{
+		return this->chunk;
+	}
+
 public:
 	protocol::HttpRequest *get_req()
 	{
@@ -45,6 +50,16 @@ class WFHttpChunkedTask : public WFGenericTask
 		return this->task->get_resp();
 	}
 
+	const protocol::HttpRequest *get_req() const
+	{
+		return this->task->get_req();
+	}
+
+	const protocol::HttpResponse *get_resp() const
+	{
+		return this->task->get_resp();
+	}
+
 public:
 	void set_watch_timeout(int timeout)
 	{

src/client/WFKafkaClient.cc

@@ -1692,3 +1692,8 @@ KafkaMetaList *WFKafkaClient::get_meta_list()
 	return &this->member->meta_list;
 }
 
+const KafkaMetaList *WFKafkaClient::get_meta_list() const
+{
+	return &this->member->meta_list;
+}
+

src/client/WFKafkaClient.h

@@ -101,6 +101,11 @@ class WFKafkaTask : public WFGenericTask
 		return &this->result;
 	}
 
+	const protocol::KafkaResult *get_result() const
+	{
+		return &this->result;
+	}
+
 	int get_kafka_error() const
 	{
 		return this->kafka_error;
@@ -183,7 +188,7 @@ class WFKafkaClient
 public:
 	protocol::KafkaMetaList *get_meta_list();
 
-	protocol::KafkaBrokerList *get_broker_list();
+	const protocol::KafkaMetaList *get_meta_list() const;
 
 private:
 	class KafkaMember *member;

src/client/WFRedisSubscriber.h

@@ -41,6 +41,11 @@ class WFRedisSubscribeTask : public WFGenericTask
 		return this->task->get_resp();
 	}
 
+	const protocol::RedisResponse *get_resp() const
+	{
+		return this->task->get_resp();
+	}
+
 public:
 	/* User needs to call 'release()' exactly once, anywhere. */
 	void release()

src/factory/WFTask.h

@@ -68,6 +68,9 @@ class WFThreadTask : public ExecRequest
 	INPUT *get_input() { return &this->input; }
 	OUTPUT *get_output() { return &this->output; }
 
+	const INPUT *get_input() const { return &this->input; }
+	const OUTPUT *get_output() const { return &this->output; }
+
 public:
 	void *user_data;
 
@@ -134,6 +137,9 @@ class WFNetworkTask : public CommRequest
 	REQ *get_req() { return &this->req; }
 	RESP *get_resp() { return &this->resp; }
 
+	const REQ *get_req() const { return &this->req; }
+	const RESP *get_resp() const { return &this->resp; }
+
 public:
 	void *user_data;
 
@@ -332,6 +338,8 @@ class WFFileTask : public IORequest
 public:
 	ARGS *get_args() { return &this->args; }
 
+	const ARGS *get_args() const { return &this->args; }
+
 	long get_retval() const
 	{
 		if (this->state == WFT_STATE_SUCCESS)