Little fixes

src/client/WFKafkaClient.cc

@@ -1606,3 +1606,4 @@ KafkaBrokerList *WFKafkaClient::get_broker_list()
 {
 	return this->member->broker_list;
 }
+

src/client/WFKafkaClient.h

@@ -153,3 +153,4 @@ private:
 };
 
 #endif
+

src/factory/KafkaTaskImpl.cc

@@ -633,3 +633,4 @@ __WFKafkaTask *__WFKafkaTaskFactory::create_kafka_task(const char *host,
 	task->set_keep_alive(KAFKA_KEEPALIVE_DEFAULT);
 	return task;
 }
+

src/factory/KafkaTaskImpl.inl

@@ -52,3 +52,4 @@ public:
 											const std::string& info,
 											__kafka_callback_t callback);
 };
+

src/nameservice/UpstreamPolicies.cc

@@ -700,3 +700,4 @@ const EndpointAddress *UPSManualPolicy::another_strategy(const ParsedURI& uri,
 																   uri.fragment ? uri.fragment : "");
 	return this->consistent_hash_with_group(hash_value);
 }
+

src/protocol/KafkaMessage.cc

@@ -3834,3 +3834,4 @@ int KafkaResponse::append(const void *buf, size_t *size)
 }
 
 }
+

src/protocol/KafkaMessage.h

@@ -264,3 +264,4 @@ private:
 }
 
 #endif
+

src/protocol/KafkaResult.cc

@@ -118,3 +118,4 @@ void KafkaResult::fetch_records(std::vector<std::vector<KafkaRecord *>>& records
 }
 
 }
+

src/protocol/KafkaResult.h

@@ -62,3 +62,4 @@ private:
 }
 
 #endif
+

src/protocol/RedisMessage.cc

@@ -426,6 +426,11 @@ std::string RedisValue::debug_string() const
 	return ret;
 }
 
+RedisValue::~RedisValue()
+{
+	free_data();
+}
+
 RedisMessage::RedisMessage():
 	parser_(new redis_parser_t),
 	stream_(new EncodeStream),
@@ -445,11 +450,6 @@ RedisMessage::~RedisMessage()
 	}
 }
 
-RedisValue::~RedisValue()
-{
-	free_data();
-}
-
 RedisMessage::RedisMessage(RedisMessage&& move) :
 	ProtocolMessage(std::move(move))
 {
@@ -696,3 +696,4 @@ bool RedisResponse::set_result(const RedisValue& value)
 }
 
 }
+

src/protocol/RedisMessage.h

@@ -321,3 +321,4 @@ inline void RedisResponse::get_result(RedisValue& value) const
 }
 
 #endif
+

src/protocol/kafka_parser.c

@@ -1234,3 +1234,4 @@ int kafka_sasl_set_password(const char *password, kafka_config_t *conf)
 	conf->password = t;
 	return 0;
 }
+

src/protocol/kafka_parser.h

@@ -487,3 +487,4 @@ int kafka_sasl_set_password(const char *passwd, kafka_config_t *conf);
 #endif
 
 #endif
+

tutorial/CMakeLists.txt

@@ -28,9 +28,9 @@ set(TUTORIAL_LIST
 	tutorial-04-http_echo_server
 	tutorial-05-http_proxy
 	tutorial-06-parallel_wget
-	tutorial-09-http_file_server
 	tutorial-07-sort_task
 	tutorial-08-matrix_multiply
+	tutorial-09-http_file_server
 	tutorial-11-graph_task
 )
 

tutorial/GNUmakefile

@@ -9,7 +9,6 @@ CMAKE3 := $(shell if which cmake3>/dev/null ; then echo cmake3; else echo cmake;
 KAFKA 		?= n
 MYSQL 		?= y
 REDIS 		?= y
-UPSTREAM 	?= y
 
 .PHONY: $(ALL_TARGETS)
 
@@ -17,9 +16,9 @@ all:
 	mkdir -p $(BUILD_DIR)
 
 ifeq ($(DEBUG),y)
-	cd $(BUILD_DIR) && $(CMAKE3) -D CMAKE_BUILD_TYPE=Debug -D KAFKA=$(KAFKA) -D MYSQL=$(MYSQL) -D REDIS=$(REDIS) -D UPSTREAM=$(UPSTREAM) $(ROOT_DIR)
+	cd $(BUILD_DIR) && $(CMAKE3) -D CMAKE_BUILD_TYPE=Debug -D KAFKA=$(KAFKA) -D MYSQL=$(MYSQL) -D REDIS=$(REDIS) $(ROOT_DIR)
 else
-	cd $(BUILD_DIR) && $(CMAKE3) -D KAFKA=$(KAFKA) -D MYSQL=$(MYSQL) -D REDIS=$(REDIS) -D UPSTREAM=$(UPSTREAM) $(ROOT_DIR)
+	cd $(BUILD_DIR) && $(CMAKE3) -D KAFKA=$(KAFKA) -D MYSQL=$(MYSQL) -D REDIS=$(REDIS) $(ROOT_DIR)
 endif
 	make -C $(BUILD_DIR) -f Makefile