generic-library/poco
1
0
Fork 0
mirror of https://github.com/pocoproject/poco.git synced 2025-10-24 17:30:44 +02:00
Code Issues Projects Releases Wiki Activity

Use Array to return all replies

Browse Source
This commit is contained in:
fbraem
2015-10-26 20:27:53 +01:00
parent 76905b426a
commit 2017e937a6
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
Redis/include/Poco/Redis/Client.h
View File

@@ -122,14 +122,15 @@ public:
else throw BadCastException(); else throw BadCastException();
} }
void sendCommands(const std::vector<Array>& commands, void sendCommands(const std::vector<Array>& commands, Array& results);
std::vector<RedisType::Ptr>& results);
/// Sends all commands (pipelining) to the Redis server before /// Sends all commands (pipelining) to the Redis server before
/// getting all replies. /// getting all replies.
void writeCommand(const Array& command); void writeCommand(const Array& command);
/// Sends a request to the Redis server. Use readReply to get the /// Sends a request to the Redis server. Use readReply to get the
/// answer. /// answer. Can also be used for pipelining commands. Make sure you
/// call readReply as many times as you called writeCommand, even when
/// an error occurred on a command.
private: private:

5
Redis/src/Client.cpp
View File

@@ -107,7 +107,7 @@ RedisType::Ptr Client::sendCommand(const Array& command)
return readReply(); return readReply();
} }
void Client::sendCommands(const std::vector<Array>& commands, std::vector<RedisType::Ptr>& results) void Client::sendCommands(const std::vector<Array>& commands, Array& results)
{ {
for(std::vector<Array>::const_iterator it = commands.begin(); it != commands.end(); ++it) for(std::vector<Array>::const_iterator it = commands.begin(); it != commands.end(); ++it)
{ {
@@ -116,8 +116,7 @@ void Client::sendCommands(const std::vector<Array>& commands, std::vector<RedisT
for(int i = 0; i < commands.size(); ++i) for(int i = 0; i < commands.size(); ++i)
{ {
RedisType::Ptr result = readReply(); results.add(readReply());
results.push_back(result);
} }
} }