libtransport.git Changeset - 6ec566375c7d

Changeset - 6ec566375c7d

Parent rev.

Child rev.

[Not reviewed]

0 4 0

HanzZ - 14 years ago 2012-03-09 17:13:32
hanzz.k@gmail.com

Send backend id back to main instance

4 files changed with 11 insertions and 0 deletions:

include/transport/networkpluginserver.h

include/transport/protocol.proto

plugin/cpp/networkplugin.cpp

src/networkpluginserver.cpp

0 comments (0 inline, 0 general)

include/transport/networkpluginserver.h

➞

Show inline comments

@@ @@ -53,12 +53,13 @@ class NetworkPluginServer { @@
 			unsigned long res;
 			unsigned long init_res;
 			unsigned long shared;
 			bool acceptUsers;
 			bool longRun;
 			bool willDie;
 			std::string id;
 		};
 		NetworkPluginServer(Component *component, Config *config, UserManager *userManager, FileTransferManager *ftManager);
 		virtual ~NetworkPluginServer();

include/transport/protocol.proto

➞

Show inline comments

@@ @@ -103,12 +103,13 @@ message Status { @@
+}
 message Stats {
 	required int32 res = 1;
 	required int32 init_res = 2;
 	required int32 shared = 3;
 	required string id = 4;
+}
 message File {
 	required string userName = 1;
 	required string buddyName = 2;
 	required string fileName = 3;

plugin/cpp/networkplugin.cpp

➞

Show inline comments

@@ @@ -38,12 +38,18 @@ namespace Transport { @@
 #define WRAP(MESSAGE, TYPE) 	pbnetwork::WrapperMessage wrap; \
 	wrap.set_type(TYPE); \
 	wrap.set_payload(MESSAGE); \
 	wrap.SerializeToString(&MESSAGE);
 template <class T> std::string stringOf(T object) {
 	std::ostringstream os;
 	os << object;
 	return (os.str());
+}
 NetworkPlugin::NetworkPlugin() {
 	m_pingReceived = false;
 	double shared;
 #ifndef WIN32
 	process_mem_usage(shared, m_init_res);
@@ @@ -600,12 +606,14 @@ void NetworkPlugin::sendMemoryUsage() { @@
 	stats.set_res(res + e_res);
 	stats.set_shared(shared + e_shared);
 	std::string message;
 	stats.SerializeToString(&message);
 	stats.set_id(stringOf(getpid()));
 	WRAP(message, pbnetwork::WrapperMessage_Type_TYPE_STATS);
 	send(message);
+}
+}

src/networkpluginserver.cpp

➞

Show inline comments

 		return;
+	}
 	c->res = payload.res();
 	c->init_res = payload.init_res();
 	c->shared = payload.shared();
 	c->id = payload.id();
+}
 void NetworkPluginServer::handleFTStartPayload(const std::string &data) {
 	pbnetwork::File payload;
 	if (payload.ParseFromString(data) == false) {
 		// TODO: ERROR

0 comments (0 inline, 0 general)