.hpp files

core-services/matching-engine/include/book.h → core-services/matching-engine/include/book.hpp

@@ -1,11 +1,11 @@
 #pragma once
 
-#include "constants.h"
-#include "data_types.h"
-#include "engine.h"
-#include "limit_buffer.h"
-#include "limit_entry_buffer.h"
-#include "limit_tree.h"
+#include "constants.hpp"
+#include "data_types.hpp"
+#include "engine.hpp"
+#include "limit_buffer.hpp"
+#include "limit_entry_buffer.hpp"
+#include "limit_tree.hpp"
 
 class Engine;
 
@@ -47,8 +47,7 @@ class Book {
 	Limit* askMin;
 
 	bool match_at_limit(Engine& parentEngine, Order& order, Limit& limit);
-	void update_limit(const bool limitEntryFilled, Limit& limit,
-					  LimitEntry* limitEntry);
+	void update_limit(const bool limitEntryFilled, Limit& limit, LimitEntry* limitEntry);
 	void update_limit_entries(Limit* limit, LimitEntry* newEntry, const Order& order);
 	void refresh_bid_max();
 	void refresh_ask_min();

core-services/matching-engine/include/data_types.h → core-services/matching-engine/include/data_types.hpp

@@ -3,7 +3,7 @@
 #include <cassert>
 #include <string>
 
-#include "constants.h"
+#include "constants.hpp"
 
 /**
  * Order ID assigned by order entry gateway.

core-services/matching-engine/include/engine.h → core-services/matching-engine/include/engine.hpp

@@ -4,9 +4,9 @@
 #include <unordered_map>
 
 #include "SimpleAmqpClient/SimpleAmqpClient.h"
-#include "book.h"
-#include "constants.h"
-#include "data_types.h"
+#include "book.hpp"
+#include "constants.hpp"
+#include "data_types.hpp"
 
 #ifdef _DEBUG
 extern int execNum;
@@ -26,8 +26,7 @@ class Engine {
 		bookMap.emplace("FB", std::make_unique<Book>(*this, "FB"));
 
 		channel = AmqpClient::Channel::CreateFromUri("amqp://guest:guest@rabbitmq:5672/%2F");
-		channel->DeclareExchange("stock_exchange", AmqpClient::Channel::EXCHANGE_TYPE_DIRECT,
-								 true);
+		channel->DeclareExchange("stock_exchange", AmqpClient::Channel::EXCHANGE_TYPE_DIRECT, true);
 	}
 
 	~Engine() {

core-services/matching-engine/include/engine_operator.h → core-services/matching-engine/include/engine_operator.hpp

@@ -3,7 +3,7 @@
 #include <string>
 
 #include "SimpleAmqpClient/SimpleAmqpClient.h"
-#include "engine.h"
+#include "engine.hpp"
 
 class EngineOperator {
    public:

core-services/matching-engine/include/limit_buffer.h → core-services/matching-engine/include/limit_buffer.hpp

@@ -1,6 +1,6 @@
 #pragma once
 
-#include "data_types.h"
+#include "data_types.hpp"
 
 /**
  * A buffer to hold the price limits of an order book.

core-services/matching-engine/include/limit_entry_buffer.h → core-services/matching-engine/include/limit_entry_buffer.hpp

@@ -2,7 +2,7 @@
 
 #include <cassert>
 
-#include "data_types.h"
+#include "data_types.hpp"
 
 /**
  * A buffer to hold the limit entries for a given book.

core-services/matching-engine/include/limit_tree.h → core-services/matching-engine/include/limit_tree.hpp

@@ -3,7 +3,7 @@
 #include <iostream>
 #include <optional>
 
-#include "data_types.h"
+#include "data_types.hpp"
 
 struct Node {
 	Limit* limit;

core-services/matching-engine/src/book.cpp

@@ -1,4 +1,4 @@
-#include "book.h"
+#include "book.hpp"
 
 #include <algorithm>
 #include <cassert>
@@ -153,8 +153,8 @@ bool Book::match_at_limit(Engine& parentEngine, Order& order, Limit& limit) {
 		Order& buyOrder = buySide ? order : currentEntry->order;
 		Order& sellOrder = buySide ? currentEntry->order : order;
 		Quantity execQuantity = std::min(order.quantity, currentEntry->order.quantity);
-		
-		if (execQuantity > 0) { // ignore cancelled orders
+
+		if (execQuantity > 0) {	 // ignore cancelled orders
 			parentEngine.execute(buyOrder, sellOrder, execQuantity);
 			buyOrder.quantity -= execQuantity;
 			sellOrder.quantity -= execQuantity;

core-services/matching-engine/src/engine.cpp

@@ -1,4 +1,4 @@
-#include "engine.h"
+#include "engine.hpp"
 
 #include <stdio.h>
 #include <stdlib.h>
@@ -7,8 +7,8 @@
 
 #include <iostream>
 
-#include "utils/json.h"
-#include "utils/logger.h"
+#include "utils/json.hpp"
+#include "utils/logger.hpp"
 
 #ifdef _DEBUG
 int execNum;

core-services/matching-engine/src/engine_operator.cpp

@@ -1,4 +1,4 @@
-#include "engine_operator.h"
+#include "engine_operator.hpp"
 
 #include <arpa/inet.h>
 #include <netinet/in.h>
@@ -7,7 +7,7 @@
 
 #include <iostream>
 
-#include "utils/json.h"
+#include "utils/json.hpp"
 
 // Helper functions
 

core-services/matching-engine/src/limit_tree.cpp

@@ -1,4 +1,4 @@
-#include "limit_tree.h"
+#include "limit_tree.hpp"
 
 Node* LimitTree::makeEmpty(Node* t) {
 	if (t == nullptr) return nullptr;

core-services/matching-engine/src/main.cpp

@@ -8,9 +8,9 @@
 
 #include "SimpleAmqpClient/Envelope.h"
 #include "SimpleAmqpClient/SimpleAmqpClient.h"
-#include "engine_operator.h"
-#include "utils/json.h"
-#include "utils/logger.h"
+#include "engine_operator.hpp"
+#include "utils/json.hpp"
+#include "utils/logger.hpp"
 
 int init_client(const std::string &host, int port) {
 	int client_sock = socket(AF_INET, SOCK_STREAM, 0);

core-services/matching-engine/src/utils/json.cpp

@@ -1,4 +1,4 @@
-#include "utils/json.h"
+#include "utils/json.hpp"
 
 #include <stdexcept>
 

core-services/matching-engine/src/utils/logger.cpp

@@ -1,4 +1,4 @@
-#include "utils/logger.h"
+#include "utils/logger.hpp"
 
 Logger& Logger::get_instance() {
 	static Logger instance;