mirror of
https://github.com/pocoproject/poco.git
synced 2025-04-21 08:18:58 +02:00
Merge remote-tracking branch 'pocoproject/develop' into CygwinOnAppVeyor
Conflicts: Data/src/RecordSet.cpp Signed-off-by: FrancisANDRE <zosrothko@orange.fr>
This commit is contained in:
commit
0062b657c4
@ -52,8 +52,8 @@ public:
|
|||||||
typedef Poco::Any (C::*PropertyGetter)(const std::string&);
|
typedef Poco::Any (C::*PropertyGetter)(const std::string&);
|
||||||
/// The getter method for a property.
|
/// The getter method for a property.
|
||||||
|
|
||||||
AbstractSessionImpl(const std::string& connectionString,
|
AbstractSessionImpl(const std::string& rConnectionString,
|
||||||
std::size_t timeout = LOGIN_TIMEOUT_DEFAULT): SessionImpl(connectionString, timeout),
|
std::size_t timeout = LOGIN_TIMEOUT_DEFAULT): SessionImpl(rConnectionString, timeout),
|
||||||
_storage(std::string("deque")),
|
_storage(std::string("deque")),
|
||||||
_bulk(false),
|
_bulk(false),
|
||||||
_emptyStringIsNull(false),
|
_emptyStringIsNull(false),
|
||||||
|
@ -123,14 +123,14 @@ void Client::disconnect()
|
|||||||
_socket.close();
|
_socket.close();
|
||||||
}
|
}
|
||||||
|
|
||||||
void Client::writeCommand(const Array& command, bool flush)
|
void Client::writeCommand(const Array& command, bool doFlush)
|
||||||
{
|
{
|
||||||
poco_assert(_output);
|
poco_assert(_output);
|
||||||
|
|
||||||
std::string commandStr = command.toString();
|
std::string commandStr = command.toString();
|
||||||
|
|
||||||
_output->write(commandStr.c_str(), commandStr.length());
|
_output->write(commandStr.c_str(), commandStr.length());
|
||||||
if ( flush ) _output->flush();
|
if ( doFlush ) _output->flush();
|
||||||
}
|
}
|
||||||
|
|
||||||
RedisType::Ptr Client::readReply()
|
RedisType::Ptr Client::readReply()
|
||||||
|
@ -20,16 +20,16 @@
|
|||||||
namespace Poco {
|
namespace Poco {
|
||||||
namespace Redis {
|
namespace Redis {
|
||||||
|
|
||||||
RedisEventArgs::RedisEventArgs(RedisType::Ptr message) :
|
RedisEventArgs::RedisEventArgs(RedisType::Ptr pMessage) :
|
||||||
_message(message),
|
_message(pMessage),
|
||||||
_exception(0),
|
_exception(0),
|
||||||
_stop(false)
|
_stop(false)
|
||||||
{
|
{
|
||||||
}
|
}
|
||||||
|
|
||||||
RedisEventArgs::RedisEventArgs(Exception* exception) :
|
RedisEventArgs::RedisEventArgs(Exception* pException) :
|
||||||
_message(),
|
_message(),
|
||||||
_exception(exception ? exception->clone() : 0),
|
_exception(pException ? pException->clone() : 0),
|
||||||
_stop(false)
|
_stop(false)
|
||||||
{
|
{
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user