From 0f6cc755a22bf51fa5f2afb6bf2a9f85abdd8699 Mon Sep 17 00:00:00 2001
From: xiehan <52160700+Barenboim@users.noreply.github.com>
Date: Tue, 9 Jan 2024 17:48:57 +0800
Subject: [PATCH] Fix some header files. (#1469)

---
 src/client/WFKafkaClient.h   | 3 +--
 src/kernel/CommRequest.h     | 1 +
 src/kernel/IORequest.h       | 1 +
 src/protocol/KafkaMessage.cc | 1 -
 src/protocol/KafkaMessage.h  | 4 ++--
 src/protocol/RedisMessage.cc | 1 -
 src/protocol/RedisMessage.h  | 3 ++-
 7 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/src/client/WFKafkaClient.h b/src/client/WFKafkaClient.h
index 460a95a9..b7777f14 100644
--- a/src/client/WFKafkaClient.h
+++ b/src/client/WFKafkaClient.h
@@ -19,7 +19,6 @@
 #ifndef _WFKAFKACLIENT_H_
 #define _WFKAFKACLIENT_H_
 
-
 #include <string>
 #include <vector>
 #include <functional>
@@ -119,7 +118,7 @@ protected:
 		this->finish = false;
 	}
 
-	virtual ~WFKafkaTask() {}
+	virtual ~WFKafkaTask() { }
 
 	virtual SubTask *done();
 
diff --git a/src/kernel/CommRequest.h b/src/kernel/CommRequest.h
index ce24114f..44132315 100644
--- a/src/kernel/CommRequest.h
+++ b/src/kernel/CommRequest.h
@@ -19,6 +19,7 @@
 #ifndef _COMMREQUEST_H_
 #define _COMMREQUEST_H_
 
+#include <errno.h>
 #include <stddef.h>
 #include "SubTask.h"
 #include "Communicator.h"
diff --git a/src/kernel/IORequest.h b/src/kernel/IORequest.h
index cfc036e6..c17bf2ec 100644
--- a/src/kernel/IORequest.h
+++ b/src/kernel/IORequest.h
@@ -19,6 +19,7 @@
 #ifndef _IOREQUEST_H_
 #define _IOREQUEST_H_
 
+#include <errno.h>
 #include "SubTask.h"
 #include "Communicator.h"
 
diff --git a/src/protocol/KafkaMessage.cc b/src/protocol/KafkaMessage.cc
index af06e7ec..647122b1 100644
--- a/src/protocol/KafkaMessage.cc
+++ b/src/protocol/KafkaMessage.cc
@@ -35,7 +35,6 @@
 #include <snappy.h>
 #include <snappy-sinksource.h>
 #include "crc32c.h"
-#include "EncodeStream.h"
 #include "KafkaMessage.h"
 
 namespace protocol
diff --git a/src/protocol/KafkaMessage.h b/src/protocol/KafkaMessage.h
index 59096d7b..977798da 100644
--- a/src/protocol/KafkaMessage.h
+++ b/src/protocol/KafkaMessage.h
@@ -25,11 +25,11 @@
 #include <vector>
 #include <map>
 #include <functional>
+#include "EncodeStream.h"
 #include "kafka_parser.h"
 #include "ProtocolMessage.h"
 #include "KafkaDataTypes.h"
 
-
 namespace protocol
 {
 
@@ -185,7 +185,7 @@ protected:
 	using parse_func = std::function<int (void **buf, size_t *size)>;
 	std::map<int, parse_func> parse_func_map;
 
-	class EncodeStream *stream;
+	EncodeStream *stream;
 	std::string msgbuf;
 	std::string headbuf;
 
diff --git a/src/protocol/RedisMessage.cc b/src/protocol/RedisMessage.cc
index 842c86f7..ac5d70a2 100644
--- a/src/protocol/RedisMessage.cc
+++ b/src/protocol/RedisMessage.cc
@@ -21,7 +21,6 @@
 #include <string.h>
 #include <sstream>
 #include <utility>
-#include "EncodeStream.h"
 #include "RedisMessage.h"
 
 namespace protocol
diff --git a/src/protocol/RedisMessage.h b/src/protocol/RedisMessage.h
index 043acc0a..82e144b5 100644
--- a/src/protocol/RedisMessage.h
+++ b/src/protocol/RedisMessage.h
@@ -23,6 +23,7 @@
 #include <stdint.h>
 #include <string>
 #include <vector>
+#include "EncodeStream.h"
 #include "ProtocolMessage.h"
 #include "redis_parser.h"
 
@@ -140,7 +141,7 @@ protected:
 	virtual int append(const void *buf, size_t *size);
 	bool encode_reply(redis_reply_t *reply);
 
-	class EncodeStream *stream_;
+	EncodeStream *stream_;
 
 private:
 	size_t cur_size_;