PurpleI2P/i2pd
1
0
Fork 0
mirror of https://github.com/PurpleI2P/i2pd.git synced 2025-01-22 08:14:15 +00:00
Code Issues Releases Activity

BOB: status response now correctly starts with "OK DATA".

Browse Source
This commit is contained in:
rszibele 2019-06-25 17:59:44 +02:00
parent 8e919ddc8e
commit cb8373e487
2 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
libi2pd_client/BOB.cpp
View File

@ -341,10 +341,10 @@ namespace client
SendReplyOK(); SendReplyOK();
} }
void BOBCommandSession::SendData (const char * data) void BOBCommandSession::SendRaw (const char * data)
{ {
std::ostream os(&m_SendBuffer); std::ostream os(&m_SendBuffer);
os << "DATA " << data << std::endl; os << data << std::endl;
} }
void BOBCommandSession::BuildStatusLine(bool currentTunnel, BOBDestination *dest, std::string &out) void BOBCommandSession::BuildStatusLine(bool currentTunnel, BOBDestination *dest, std::string &out)
@ -370,7 +370,8 @@ namespace client
// build line // build line
std::stringstream ss; std::stringstream ss;
ss << "NICKNAME: " << nickname << " " << "STARTING: " << bool_str(starting) << " " ss << "DATA "
<< "NICKNAME: " << nickname << " " << "STARTING: " << bool_str(starting) << " "
<< "RUNNING: " << bool_str(running) << " " << "STOPPING: " << bool_str(stopping) << " " << "RUNNING: " << bool_str(running) << " " << "STOPPING: " << bool_str(stopping) << " "
<< "KEYS: " << bool_str(keys) << " " << "QUIET: " << bool_str(quiet) << " " << "KEYS: " << bool_str(keys) << " " << "QUIET: " << bool_str(quiet) << " "
<< "INPORT: " << inport << " " << "INHOST: " << inhost << " " << "INPORT: " << inport << " " << "INHOST: " << inhost << " "
@ -654,7 +655,7 @@ namespace client
for (const auto& it: destinations) for (const auto& it: destinations)
{ {
BuildStatusLine(false, it.second, statusLine); BuildStatusLine(false, it.second, statusLine);
SendData (statusLine.c_str()); SendRaw(statusLine.c_str());
if(m_Nickname.compare(it.second->GetNickname()) == 0) if(m_Nickname.compare(it.second->GetNickname()) == 0)
sentCurrent = true; sentCurrent = true;
} }
@ -663,7 +664,7 @@ namespace client
// add the current tunnel to the list // add the current tunnel to the list
BuildStatusLine(true, m_CurrentDestination, statusLine); BuildStatusLine(true, m_CurrentDestination, statusLine);
LogPrint(eLogError, statusLine); LogPrint(eLogError, statusLine);
SendData(statusLine.c_str()); SendRaw(statusLine.c_str());
} }
SendReplyOK ("Listing done"); SendReplyOK ("Listing done");
} }

2
libi2pd_client/BOB.h
View File

@ -213,7 +213,7 @@ namespace client
void HandleSent (const boost::system::error_code& ecode, std::size_t bytes_transferred); void HandleSent (const boost::system::error_code& ecode, std::size_t bytes_transferred);
void SendReplyOK (const char * msg = nullptr); void SendReplyOK (const char * msg = nullptr);
void SendReplyError (const char * msg); void SendReplyError (const char * msg);
void SendData (const char * data); void SendRaw (const char * data);
void BuildStatusLine(bool currentTunnel, BOBDestination *destination, std::string &out); void BuildStatusLine(bool currentTunnel, BOBDestination *destination, std::string &out);