mesos osx build fixes

Author: aleks-f

userspace/libsinsp/mesos.cpp

@@ -27,9 +27,13 @@ mesos::mesos(const std::string& state_uri,
 	const uri_list_t& marathon_uris,
 	const std::string& groups_api,
 	const std::string& apps_api,
-	const std::string& watch_api): m_state_http(*this, state_uri + state_api),
+	const std::string& watch_api)
+#ifdef HAS_CAPTURE
+		: m_state_http(*this, state_uri + state_api),
 		m_collector(false), m_creation_logged(false)
+#endif // HAS_CAPTURE
 {
+#ifdef HAS_CAPTURE
 	for(const auto& uri : marathon_uris)
 	{
 		int port = (uri.substr(0, 5) == "https") ? 443 : 80;
@@ -51,6 +55,7 @@ mesos::mesos(const std::string& state_uri,
 	}
 
 	refresh(marathon_uris.size());
+#endif // HAS_CAPTURE
 }
 
 mesos::~mesos()
@@ -59,6 +64,7 @@ mesos::~mesos()
 
 void mesos::refresh(bool marathon)
 {
+#ifdef HAS_CAPTURE
 	clear(marathon);
 
 	m_state_http.get_all_data(&mesos::parse_state);
@@ -80,12 +86,13 @@ void mesos::refresh(bool marathon)
 			m_collector.add(watch_http.second);
 		}
 	}
+#endif // HAS_CAPTURE
 }
 
 bool mesos::is_alive() const
 {
 	bool connected = true;
-
+#ifdef HAS_CAPTURE
 	connected &= m_state_http.is_connected();
 	for(const auto& group : m_marathon_groups_http)
 	{
@@ -98,12 +105,14 @@ bool mesos::is_alive() const
 	}
 
 	connected &= (m_collector.subscription_count() > 0);
+#endif // HAS_CAPTURE
 
 	return connected;
 }
 
 void mesos::watch()
 {
+#ifdef HAS_CAPTURE
 	if(m_marathon_watch_http.size())
 	{
 		if(!m_collector.subscription_count())
@@ -115,6 +124,7 @@ void mesos::watch()
 		}
 		m_collector.get_data();
 	}
+#endif // HAS_CAPTURE
 }
 
 void mesos::determine_node_type(const Json::Value& root)
@@ -143,6 +153,7 @@ void mesos::determine_node_type(const Json::Value& root)
 
 void mesos::add_task_labels(std::string& json)
 {
+#ifdef HAS_CAPTURE
 	Json::Value root;
 	Json::Reader reader;
 	try
@@ -174,8 +185,10 @@ void mesos::add_task_labels(std::string& json)
 	{
 		g_logger.log(std::string("Error while looking for taks labels:") + ex.what(), sinsp_logger::SEV_ERROR);
 	}
+#endif // HAS_CAPTURE
 }
 
+#ifdef HAS_CAPTURE
 void mesos::get_groups(marathon_http::ptr_t http, std::string& json)
 {
 	std::string group_ev_type = mesos_event_data::m_events[mesos_event_data::MESOS_GROUP_CHANGE_SUCCESS_EVENT];
@@ -242,6 +255,7 @@ void mesos::on_watch_data(const std::string& framework_id, mesos_event_data&& ms
 		}
 	}
 }
+#endif // HAS_CAPTURE
 
 void mesos::parse_state(const std::string& json)
 {

userspace/libsinsp/mesos.h

@@ -55,7 +55,6 @@ class mesos
 	void watch();
 private:
 
-	void on_watch_data(const std::string& framework_id, mesos_event_data&& msg);
 	void parse_state(const std::string& json);
 	void determine_node_type(const Json::Value& root);
 	bool is_master() const;
@@ -70,19 +69,24 @@ class mesos
 	void parse_apps(const std::string& json);
 
 	void add_task_labels(std::string& json);
+
+#ifdef HAS_CAPTURE
+	void on_watch_data(const std::string& framework_id, mesos_event_data&& msg);
 	void get_groups(marathon_http::ptr_t http, std::string& json);
 
 	typedef std::unordered_map<int, marathon_http::ptr_t>       marathon_http_map;
 	typedef std::unordered_map<int, marathon_dispatcher::ptr_t> marathon_disp_map;
 
-	node_t            m_node_type;
 	mesos_http        m_state_http;
 	marathon_http_map m_marathon_groups_http;
 	marathon_http_map m_marathon_apps_http;
 	marathon_http_map m_marathon_watch_http;
-	mesos_state_t     m_state;
-	marathon_disp_map m_dispatch;
 	mesos_collector   m_collector;
+	marathon_disp_map m_dispatch;
+#endif // HAS_CAPTURE
+
+	node_t            m_node_type;
+	mesos_state_t     m_state;
 	bool              m_creation_logged;
 
 	static const mesos_component::component_map m_components;
@@ -106,10 +110,12 @@ inline bool mesos::is_master() const
 	return m_node_type == NODE_MASTER;
 }
 
+#ifdef HAS_CAPTURE
 inline bool mesos::has_marathon() const
 {
 	return m_marathon_watch_http.size() > 0;
 }
+#endif // HAS_CAPTURE
 
 inline void mesos::clear(bool marathon)
 {

userspace/libsinsp/utils.cpp

@@ -1250,7 +1250,7 @@ std::string get_json_string(const Json::Value& root, const std::string& name)
 	return ret;
 }
 
-#ifndef _WIN32
+#if defined(__linux__)
 ///////////////////////////////////////////////////////////////////////////////
 // Curl helpers
 ///////////////////////////////////////////////////////////////////////////////
@@ -1359,4 +1359,4 @@ void sinsp_curl::check_error(unsigned ret)
 		throw sinsp_exception(os.str());
 	}
 }
-#endif // _WIN32
+#endif // __linux__

userspace/libsinsp/utils.h

@@ -189,6 +189,8 @@ std::string get_json_string(const Json::Value& root, const std::string& name);
 // Curl helpers
 ///////////////////////////////////////////////////////////////////////////////
 
+#if defined(__linux__)
+
 class uri;
 
 class sinsp_curl
@@ -215,3 +217,5 @@ class sinsp_curl
 	string m_cert;
 	long m_timeout;
 };
+
+#endif // __linux__