Compare commits
3 Commits
5936bf96f0
...
c321076f96
Author | SHA1 | Date | |
---|---|---|---|
c321076f96 | |||
ea58c525eb | |||
477cebf235 |
18
.clang-tidy
18
.clang-tidy
@ -37,7 +37,7 @@ CheckOptions:
|
|||||||
- key: readability-identifier-naming.ClassConstantCase
|
- key: readability-identifier-naming.ClassConstantCase
|
||||||
value: CamelCase
|
value: CamelCase
|
||||||
- key: readability-identifier-naming.ClassConstantPrefix
|
- key: readability-identifier-naming.ClassConstantPrefix
|
||||||
value: 'k_'
|
value: 'k'
|
||||||
- key: readability-identifier-naming.ClassConstantSuffix
|
- key: readability-identifier-naming.ClassConstantSuffix
|
||||||
value: ''
|
value: ''
|
||||||
- key: readability-identifier-naming.ClassMemberCase
|
- key: readability-identifier-naming.ClassMemberCase
|
||||||
@ -55,7 +55,7 @@ CheckOptions:
|
|||||||
- key: readability-identifier-naming.ConstantCase
|
- key: readability-identifier-naming.ConstantCase
|
||||||
value: CamelCase
|
value: CamelCase
|
||||||
- key: readability-identifier-naming.ConstantPrefix
|
- key: readability-identifier-naming.ConstantPrefix
|
||||||
value: 'k_'
|
value: 'k'
|
||||||
- key: readability-identifier-naming.ConstantSuffix
|
- key: readability-identifier-naming.ConstantSuffix
|
||||||
value: POST
|
value: POST
|
||||||
- key: readability-identifier-naming.ConstantMemberCase
|
- key: readability-identifier-naming.ConstantMemberCase
|
||||||
@ -91,7 +91,7 @@ CheckOptions:
|
|||||||
- key: readability-identifier-naming.ConstexprVariableCase
|
- key: readability-identifier-naming.ConstexprVariableCase
|
||||||
value: CamelCase
|
value: CamelCase
|
||||||
- key: readability-identifier-naming.ConstexprVariablePrefix
|
- key: readability-identifier-naming.ConstexprVariablePrefix
|
||||||
value: 'k_'
|
value: 'k'
|
||||||
- key: readability-identifier-naming.ConstexprVariableSuffix
|
- key: readability-identifier-naming.ConstexprVariableSuffix
|
||||||
value: ''
|
value: ''
|
||||||
- key: readability-identifier-naming.EnumCase
|
- key: readability-identifier-naming.EnumCase
|
||||||
@ -119,7 +119,7 @@ CheckOptions:
|
|||||||
- key: readability-identifier-naming.GlobalConstantSuffix
|
- key: readability-identifier-naming.GlobalConstantSuffix
|
||||||
value: ''
|
value: ''
|
||||||
- key: readability-identifier-naming.GlobalConstantPointerCase
|
- key: readability-identifier-naming.GlobalConstantPointerCase
|
||||||
value: lower_case
|
value: CamelCase
|
||||||
- key: readability-identifier-naming.GlobalConstantPointerPrefix
|
- key: readability-identifier-naming.GlobalConstantPointerPrefix
|
||||||
value: ''
|
value: ''
|
||||||
- key: readability-identifier-naming.GlobalConstantPointerSuffix
|
- key: readability-identifier-naming.GlobalConstantPointerSuffix
|
||||||
@ -142,6 +142,8 @@ CheckOptions:
|
|||||||
value: ''
|
value: ''
|
||||||
- key: readability-identifier-naming.GlobalVariableSuffix
|
- key: readability-identifier-naming.GlobalVariableSuffix
|
||||||
value: ''
|
value: ''
|
||||||
|
- key: readability-identifier-naming.IgnoreMainLikeFunctions
|
||||||
|
value: 1
|
||||||
- key: readability-identifier-naming.InlineNamespaceCase
|
- key: readability-identifier-naming.InlineNamespaceCase
|
||||||
value: lower_case
|
value: lower_case
|
||||||
- key: readability-identifier-naming.InlineNamespacePrefix
|
- key: readability-identifier-naming.InlineNamespacePrefix
|
||||||
@ -245,15 +247,15 @@ CheckOptions:
|
|||||||
- key: readability-identifier-naming.PublicMethodSuffix
|
- key: readability-identifier-naming.PublicMethodSuffix
|
||||||
value: ''
|
value: ''
|
||||||
- key: readability-identifier-naming.StaticConstantCase
|
- key: readability-identifier-naming.StaticConstantCase
|
||||||
value: camelBack
|
value: CamelCase
|
||||||
- key: readability-identifier-naming.StaticConstantPrefix
|
- key: readability-identifier-naming.StaticConstantPrefix
|
||||||
value: 'k_'
|
value: 'k'
|
||||||
- key: readability-identifier-naming.StaticConstantSuffix
|
- key: readability-identifier-naming.StaticConstantSuffix
|
||||||
value: ''
|
value: ''
|
||||||
- key: readability-identifier-naming.StaticVariableCase
|
- key: readability-identifier-naming.StaticVariableCase
|
||||||
value: camelBack
|
value: CamelCase
|
||||||
- key: readability-identifier-naming.StaticVariablePrefix
|
- key: readability-identifier-naming.StaticVariablePrefix
|
||||||
value: ''
|
value: 's'
|
||||||
- key: readability-identifier-naming.StaticVariableSuffix
|
- key: readability-identifier-naming.StaticVariableSuffix
|
||||||
value: ''
|
value: ''
|
||||||
- key: readability-identifier-naming.StructCase
|
- key: readability-identifier-naming.StructCase
|
||||||
|
@ -1 +1 @@
|
|||||||
Subproject commit 2ea38c32c8d6aa7ccdbdf84cff1d0b0d50cc2fb3
|
Subproject commit 9df188963e5980d305dd50d721978ccdd997a8c3
|
@ -4,10 +4,8 @@ set(AUTHOR_NAME "Андрей Астафьев")
|
|||||||
set(DOXYGEN_PROJECT_TITLE "MyXLib")
|
set(DOXYGEN_PROJECT_TITLE "MyXLib")
|
||||||
set(DOXYGEN_GENERATE_LATEX YES)
|
set(DOXYGEN_GENERATE_LATEX YES)
|
||||||
set(DOXYGEN_GENERATE_HTML YES)
|
set(DOXYGEN_GENERATE_HTML YES)
|
||||||
set(DOXYGEN_GENERATE_SQLITE YES)
|
|
||||||
|
|
||||||
set(CPACK_COMPONENTS_ALL examples)
|
set(CPACK_COMPONENTS_ALL examples)
|
||||||
set(CPACK_GENERATOR "TXZ;DEB")
|
|
||||||
set(CPACK_PACKAGE_CONTACT "Andrei Astafev <dev@246060.ru>")
|
set(CPACK_PACKAGE_CONTACT "Andrei Astafev <dev@246060.ru>")
|
||||||
set(CPACK_PACKAGE_DESCRIPTION_SUMMARY "Mixed functions")
|
set(CPACK_PACKAGE_DESCRIPTION_SUMMARY "Mixed functions")
|
||||||
|
|
||||||
|
@ -15,8 +15,6 @@ namespace myx {
|
|||||||
|
|
||||||
namespace redis {
|
namespace redis {
|
||||||
|
|
||||||
static const QByteArray Separator { "\r\n" }; //!< Строковый разделитель слов во фразе
|
|
||||||
|
|
||||||
/*!
|
/*!
|
||||||
* \brief Создает объект класса
|
* \brief Создает объект класса
|
||||||
* \param host Имя хоста сервера
|
* \param host Имя хоста сервера
|
||||||
@ -49,6 +47,12 @@ inline Base::Base( QObject* parent ) :
|
|||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
inline int Base::rwTimeout() const
|
||||||
|
{
|
||||||
|
return( kRWTimeout );
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
inline QString Base::host() const
|
inline QString Base::host() const
|
||||||
{
|
{
|
||||||
return( m_host );
|
return( m_host );
|
||||||
@ -99,37 +103,6 @@ inline bool Base::isConnected() const
|
|||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/// *!
|
|
||||||
// * \brief Извлекает длину токена из буфера данных
|
|
||||||
// * \param pos Позиция в буфере
|
|
||||||
// * \param buffer Буфер данных
|
|
||||||
// */
|
|
||||||
// inline int Base::fetchLength( QByteArray& buffer, int& pos )
|
|
||||||
// {
|
|
||||||
// if ( ( buffer[pos] != '$' ) && ( buffer[pos] != '*' ) && ( buffer[pos] != ':' ) )
|
|
||||||
// {
|
|
||||||
// buffer.clear();
|
|
||||||
// pos = 0;
|
|
||||||
// return( -1 );
|
|
||||||
// }
|
|
||||||
// pos++;
|
|
||||||
// QByteArray text;
|
|
||||||
// while ( pos < buffer.length() )
|
|
||||||
// {
|
|
||||||
// if ( QChar( buffer[pos] ).isNumber() )
|
|
||||||
// {
|
|
||||||
// text += buffer[pos++];
|
|
||||||
// }
|
|
||||||
// else
|
|
||||||
// {
|
|
||||||
// pos += Separator.length();
|
|
||||||
// return( text.toInt() );
|
|
||||||
// }
|
|
||||||
// }
|
|
||||||
// return( -1 );
|
|
||||||
// } // Base::fetchLength
|
|
||||||
|
|
||||||
|
|
||||||
/*!
|
/*!
|
||||||
* \brief Добавляет к состоянию флаг Read
|
* \brief Добавляет к состоянию флаг Read
|
||||||
*/
|
*/
|
||||||
|
@ -47,7 +47,7 @@ public:
|
|||||||
bool isConnected() const;
|
bool isConnected() const;
|
||||||
|
|
||||||
private:
|
private:
|
||||||
static constexpr int k_RwTimeout { 200 }; //!< Таймаут на операции чтения и записи
|
static constexpr int kRWTimeout { 200 }; //!< Таймаут на операции чтения и записи
|
||||||
int m_connectionFlags { kDisconnected }; //!< Флаги состояния соединения
|
int m_connectionFlags { kDisconnected }; //!< Флаги состояния соединения
|
||||||
quint16 m_port { 6379 }; //!< Номер порта подключения к БД
|
quint16 m_port { 6379 }; //!< Номер порта подключения к БД
|
||||||
QString m_host { QStringLiteral( "127.0.0.1" ) }; //!< Имя хоста подключения к БД
|
QString m_host { QStringLiteral( "127.0.0.1" ) }; //!< Имя хоста подключения к БД
|
||||||
@ -56,7 +56,6 @@ private:
|
|||||||
|
|
||||||
protected:
|
protected:
|
||||||
|
|
||||||
int connectionTimeout() const;
|
|
||||||
int rwTimeout() const;
|
int rwTimeout() const;
|
||||||
|
|
||||||
QString host() const;
|
QString host() const;
|
||||||
@ -68,7 +67,6 @@ protected:
|
|||||||
int connectionFlags() const;
|
int connectionFlags() const;
|
||||||
void setConnectionFlags( int connectionFlags );
|
void setConnectionFlags( int connectionFlags );
|
||||||
|
|
||||||
// int fetchLength( QByteArray& buffer, int& pos );
|
|
||||||
Q_SLOT void onReadyRead();
|
Q_SLOT void onReadyRead();
|
||||||
Q_SLOT void onBytesWritten();
|
Q_SLOT void onBytesWritten();
|
||||||
Q_SLOT void onSocketError();
|
Q_SLOT void onSocketError();
|
||||||
|
@ -14,6 +14,14 @@ namespace myx {
|
|||||||
|
|
||||||
namespace redis {
|
namespace redis {
|
||||||
|
|
||||||
|
namespace constants {
|
||||||
|
|
||||||
|
static const QByteArray Separator { "\r\n" }; //!< Строковый разделитель слов во фразе
|
||||||
|
|
||||||
|
} // namespace constants
|
||||||
|
|
||||||
|
namespace C = constants;
|
||||||
|
|
||||||
/*!
|
/*!
|
||||||
* \brief Создает часть команды
|
* \brief Создает часть команды
|
||||||
* \param value Значение для создани части команды
|
* \param value Значение для создани части команды
|
||||||
@ -22,7 +30,7 @@ namespace redis {
|
|||||||
inline QByteArray part( const QVariant& value )
|
inline QByteArray part( const QVariant& value )
|
||||||
{
|
{
|
||||||
auto bytes = value.toByteArray();
|
auto bytes = value.toByteArray();
|
||||||
return( "$" + QByteArray::number( bytes.length() ) + Separator + bytes );
|
return( "$" + QByteArray::number( bytes.length() ) + C::Separator + bytes );
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@ -37,7 +45,7 @@ inline QByteArray array( const QVariantList& parts )
|
|||||||
std::transform( parts.cbegin(), parts.cend(), std::back_inserter( data ),
|
std::transform( parts.cbegin(), parts.cend(), std::back_inserter( data ),
|
||||||
[]( const QVariant& iter ) { return( part( iter ) ); } );
|
[]( const QVariant& iter ) { return( part( iter ) ); } );
|
||||||
data.prepend( "*" + QByteArray::number( data.size() ) );
|
data.prepend( "*" + QByteArray::number( data.size() ) );
|
||||||
return( data.join( Separator ) + Separator );
|
return( data.join( C::Separator ) + C::Separator );
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@ -76,7 +84,7 @@ inline QByteArrayList split( const QByteArray& buffer, int* splitLength )
|
|||||||
{
|
{
|
||||||
*splitLength = 0;
|
*splitLength = 0;
|
||||||
}
|
}
|
||||||
if ( !buffer.endsWith( Separator ) )
|
if ( !buffer.endsWith( C::Separator ) )
|
||||||
{
|
{
|
||||||
return {};
|
return {};
|
||||||
}
|
}
|
||||||
@ -96,7 +104,7 @@ inline QByteArrayList split( const QByteArray& buffer, int* splitLength )
|
|||||||
return {};
|
return {};
|
||||||
}
|
}
|
||||||
size = text.toInt();
|
size = text.toInt();
|
||||||
pos += Separator.length();
|
pos += C::Separator.length();
|
||||||
}
|
}
|
||||||
QByteArrayList parts;
|
QByteArrayList parts;
|
||||||
Token token { kUndefined };
|
Token token { kUndefined };
|
||||||
@ -131,7 +139,7 @@ inline QByteArrayList split( const QByteArray& buffer, int* splitLength )
|
|||||||
{
|
{
|
||||||
parts.push_back( partLength );
|
parts.push_back( partLength );
|
||||||
token = kUndefined;
|
token = kUndefined;
|
||||||
pos += Separator.length();
|
pos += C::Separator.length();
|
||||||
}
|
}
|
||||||
break;
|
break;
|
||||||
case kFetchPart:
|
case kFetchPart:
|
||||||
@ -147,17 +155,17 @@ inline QByteArrayList split( const QByteArray& buffer, int* splitLength )
|
|||||||
if ( length < 0 )
|
if ( length < 0 )
|
||||||
{
|
{
|
||||||
parts.push_back( "" );
|
parts.push_back( "" );
|
||||||
pos += Separator.length();
|
pos += C::Separator.length();
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
pos += Separator.length();
|
pos += C::Separator.length();
|
||||||
if ( pos + length > buffer.length() )
|
if ( pos + length > buffer.length() )
|
||||||
{
|
{
|
||||||
return {};
|
return {};
|
||||||
}
|
}
|
||||||
parts.push_back( buffer.mid( pos, length ) );
|
parts.push_back( buffer.mid( pos, length ) );
|
||||||
pos += length + Separator.length();
|
pos += length + C::Separator.length();
|
||||||
}
|
}
|
||||||
token = kUndefined;
|
token = kUndefined;
|
||||||
}
|
}
|
||||||
|
@ -12,8 +12,6 @@ namespace myx {
|
|||||||
|
|
||||||
namespace redis {
|
namespace redis {
|
||||||
|
|
||||||
static const QByteArray Separator { "\r\n" }; //!< Строковый разделитель слов во фразе
|
|
||||||
|
|
||||||
QByteArray array( const QVariantList& parts );
|
QByteArray array( const QVariantList& parts );
|
||||||
QByteArrayList split( const QByteArray& buffer, int* splitLength = nullptr );
|
QByteArrayList split( const QByteArray& buffer, int* splitLength = nullptr );
|
||||||
// QByteArray part( const QVariant& value );
|
// QByteArray part( const QVariant& value );
|
||||||
|
@ -19,7 +19,7 @@ namespace myx {
|
|||||||
|
|
||||||
namespace redis {
|
namespace redis {
|
||||||
|
|
||||||
const QString PubSub::k_KeySpacePrefix { QStringLiteral( "__key%1__:" ) };
|
const QString PubSub::kKeySpacePrefix { QStringLiteral( "__key%1__:" ) };
|
||||||
|
|
||||||
/*!
|
/*!
|
||||||
* \brief Конструктор класса
|
* \brief Конструктор класса
|
||||||
@ -49,6 +49,12 @@ inline PubSub::PubSub( QObject* parent ) :
|
|||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
inline int PubSub::connectionTimeout() const
|
||||||
|
{
|
||||||
|
return( kConnectionTimeout );
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
/*!
|
/*!
|
||||||
* \brief Инициирует работу с БД
|
* \brief Инициирует работу с БД
|
||||||
*/
|
*/
|
||||||
@ -94,7 +100,7 @@ inline void PubSub::subscribe( const QString& channel, QObject* subscriber, cons
|
|||||||
{
|
{
|
||||||
if ( m_socket->state() == QAbstractSocket::ConnectedState )
|
if ( m_socket->state() == QAbstractSocket::ConnectedState )
|
||||||
{
|
{
|
||||||
m_socket->write( array( { "SUBSCIBE", channel } ) );
|
m_socket->write( array( { "SUBSCRIBE", channel } ) );
|
||||||
}
|
}
|
||||||
m_subscribers[channel].emplace_back( subscriber, method );
|
m_subscribers[channel].emplace_back( subscriber, method );
|
||||||
}
|
}
|
||||||
@ -108,6 +114,8 @@ inline void PubSub::subscribe( const QString& channel, QObject* subscriber, cons
|
|||||||
if ( it == iter.value().end() )
|
if ( it == iter.value().end() )
|
||||||
{
|
{
|
||||||
iter.value().emplace_back( subscriber, method );
|
iter.value().emplace_back( subscriber, method );
|
||||||
|
connect( subscriber, &QObject::destroyed, this, &PubSub::onSubscriberDestroyed,
|
||||||
|
Qt::UniqueConnection );
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
} // PubSub::subscribe
|
} // PubSub::subscribe
|
||||||
@ -130,7 +138,7 @@ inline void PubSub::subscribe( QString channel, QObject* subscriber, const char*
|
|||||||
auto iter = m_subscribers.find( channel );
|
auto iter = m_subscribers.find( channel );
|
||||||
if ( iter == m_subscribers.end() )
|
if ( iter == m_subscribers.end() )
|
||||||
{
|
{
|
||||||
channel.prepend( k_KeySpacePrefix.arg( "space@" + QString::number( database ) ).toLocal8Bit() );
|
channel.prepend( kKeySpacePrefix.arg( "space@" + QString::number( database ) ).toLocal8Bit() );
|
||||||
if ( m_socket->state() == QAbstractSocket::ConnectedState )
|
if ( m_socket->state() == QAbstractSocket::ConnectedState )
|
||||||
{
|
{
|
||||||
m_socket->write( array( { "SUBSCRIBE", channel } ) );
|
m_socket->write( array( { "SUBSCRIBE", channel } ) );
|
||||||
@ -147,6 +155,8 @@ inline void PubSub::subscribe( QString channel, QObject* subscriber, const char*
|
|||||||
if ( it == iter.value().end() )
|
if ( it == iter.value().end() )
|
||||||
{
|
{
|
||||||
iter.value().emplace_back( subscriber, method );
|
iter.value().emplace_back( subscriber, method );
|
||||||
|
connect( subscriber, &QObject::destroyed, this, &PubSub::onSubscriberDestroyed,
|
||||||
|
Qt::UniqueConnection );
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
} // PubSub::subscribe
|
} // PubSub::subscribe
|
||||||
@ -184,6 +194,8 @@ inline void PubSub::psubscribe( const QString& channel, QObject* subscriber, con
|
|||||||
if ( it == iter.value().end() )
|
if ( it == iter.value().end() )
|
||||||
{
|
{
|
||||||
iter.value().emplace_back( subscriber, method );
|
iter.value().emplace_back( subscriber, method );
|
||||||
|
connect( subscriber, &QObject::destroyed, this, &PubSub::onSubscriberDestroyed,
|
||||||
|
Qt::UniqueConnection );
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
} // PubSub::psubscribe
|
} // PubSub::psubscribe
|
||||||
@ -208,11 +220,11 @@ inline void PubSub::psubscribe( QString channel, QObject* subscriber, const char
|
|||||||
{
|
{
|
||||||
if ( database == -1 )
|
if ( database == -1 )
|
||||||
{
|
{
|
||||||
channel.prepend( k_KeySpacePrefix.arg( QStringLiteral( "*" ) ).toLocal8Bit() );
|
channel.prepend( kKeySpacePrefix.arg( QStringLiteral( "*" ) ).toLocal8Bit() );
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
channel.prepend( k_KeySpacePrefix.arg( "space@" + QString::number( database ) ).toLocal8Bit() );
|
channel.prepend( kKeySpacePrefix.arg( "space@" + QString::number( database ) ).toLocal8Bit() );
|
||||||
}
|
}
|
||||||
if ( m_socket->state() == QAbstractSocket::ConnectedState )
|
if ( m_socket->state() == QAbstractSocket::ConnectedState )
|
||||||
{
|
{
|
||||||
@ -230,6 +242,8 @@ inline void PubSub::psubscribe( QString channel, QObject* subscriber, const char
|
|||||||
if ( it == iter.value().end() )
|
if ( it == iter.value().end() )
|
||||||
{
|
{
|
||||||
iter.value().emplace_back( subscriber, method );
|
iter.value().emplace_back( subscriber, method );
|
||||||
|
connect( subscriber, &QObject::destroyed, this, &PubSub::onSubscriberDestroyed,
|
||||||
|
Qt::UniqueConnection );
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
} // PubSub::psubscribe
|
} // PubSub::psubscribe
|
||||||
@ -288,11 +302,11 @@ inline void PubSub::unsubscribe( QString channel, QObject* subscriber, const cha
|
|||||||
}
|
}
|
||||||
if ( database == -1 )
|
if ( database == -1 )
|
||||||
{
|
{
|
||||||
channel.prepend( k_KeySpacePrefix.arg( QStringLiteral( "*" ) ).toLocal8Bit() );
|
channel.prepend( kKeySpacePrefix.arg( QStringLiteral( "*" ) ).toLocal8Bit() );
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
channel.prepend( k_KeySpacePrefix.arg( "space@" + QString::number( database ) ).toLocal8Bit() );
|
channel.prepend( kKeySpacePrefix.arg( "space@" + QString::number( database ) ).toLocal8Bit() );
|
||||||
}
|
}
|
||||||
auto iter = m_subscribers.find( channel );
|
auto iter = m_subscribers.find( channel );
|
||||||
if ( iter != m_subscribers.end() )
|
if ( iter != m_subscribers.end() )
|
||||||
@ -372,11 +386,11 @@ inline void PubSub::punsubscribe( QString channel, QObject* subscriber,
|
|||||||
}
|
}
|
||||||
if ( database == -1 )
|
if ( database == -1 )
|
||||||
{
|
{
|
||||||
channel.prepend( k_KeySpacePrefix.arg( QStringLiteral( "*" ) ).toLocal8Bit() );
|
channel.prepend( kKeySpacePrefix.arg( QStringLiteral( "*" ) ).toLocal8Bit() );
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
channel.prepend( k_KeySpacePrefix.arg( "space@" + QString::number( database ) ).toLocal8Bit() );
|
channel.prepend( kKeySpacePrefix.arg( "space@" + QString::number( database ) ).toLocal8Bit() );
|
||||||
}
|
}
|
||||||
auto iter = m_psubscribers.find( channel );
|
auto iter = m_psubscribers.find( channel );
|
||||||
if ( iter != m_psubscribers.end() )
|
if ( iter != m_psubscribers.end() )
|
||||||
@ -489,6 +503,68 @@ inline void PubSub::onSocketStateChanged()
|
|||||||
} // PubSub::onSocketStateChanged
|
} // PubSub::onSocketStateChanged
|
||||||
|
|
||||||
|
|
||||||
|
/*!
|
||||||
|
* \brief При удалении подписчика уничтожает все его подписки
|
||||||
|
* \param subscriber Удаленный подписчик
|
||||||
|
*/
|
||||||
|
inline void PubSub::onSubscriberDestroyed( QObject* subscriber )
|
||||||
|
{
|
||||||
|
for ( auto i = m_subscribers.begin(); i != m_subscribers.end(); )
|
||||||
|
{
|
||||||
|
for ( auto j = i.value().begin(); j != i.value().end(); )
|
||||||
|
{
|
||||||
|
if ( j->first == subscriber )
|
||||||
|
{
|
||||||
|
j = i.value().erase( j );
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
j++;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if ( i.value().empty() )
|
||||||
|
{
|
||||||
|
if ( m_socket->state() == QAbstractSocket::ConnectedState )
|
||||||
|
{
|
||||||
|
m_socket->write( array( { "UNSUBSCRIBE", i.key() } ) );
|
||||||
|
}
|
||||||
|
i = m_subscribers.erase( i );
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
i++;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
for ( auto i = m_psubscribers.begin(); i != m_psubscribers.end(); )
|
||||||
|
{
|
||||||
|
for ( auto j = i.value().begin(); j != i.value().end(); )
|
||||||
|
{
|
||||||
|
if ( j->first == subscriber )
|
||||||
|
{
|
||||||
|
j = i.value().erase( j );
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
j++;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if ( i.value().empty() )
|
||||||
|
{
|
||||||
|
if ( m_socket->state() == QAbstractSocket::ConnectedState )
|
||||||
|
{
|
||||||
|
m_socket->write( array( { "PUNSUBSCRIBE", i.key() } ) );
|
||||||
|
}
|
||||||
|
i = m_psubscribers.erase( i );
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
i++;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
} // PubSub::onSubscriberDestroyed
|
||||||
|
|
||||||
|
|
||||||
/*!
|
/*!
|
||||||
* \brief Возвращает сокет
|
* \brief Возвращает сокет
|
||||||
* \return Сокет
|
* \return Сокет
|
||||||
|
@ -14,7 +14,7 @@ namespace myx {
|
|||||||
namespace redis {
|
namespace redis {
|
||||||
|
|
||||||
/*!
|
/*!
|
||||||
* \brief УПравляет подпиской и публикацией сообщений
|
* \brief Управляет подпиской и публикацией сообщений
|
||||||
*/
|
*/
|
||||||
|
|
||||||
class PubSub : public Base
|
class PubSub : public Base
|
||||||
@ -24,6 +24,8 @@ class PubSub : public Base
|
|||||||
public:
|
public:
|
||||||
explicit PubSub( QObject* parent = nullptr );
|
explicit PubSub( QObject* parent = nullptr );
|
||||||
QTcpSocket* socket() const;
|
QTcpSocket* socket() const;
|
||||||
|
int connectionTimeout() const;
|
||||||
|
|
||||||
Q_SLOT void start();
|
Q_SLOT void start();
|
||||||
Q_SLOT void stop();
|
Q_SLOT void stop();
|
||||||
Q_INVOKABLE void subscribe( const QString& channel, QObject* subscriber, const char* method );
|
Q_INVOKABLE void subscribe( const QString& channel, QObject* subscriber, const char* method );
|
||||||
@ -50,19 +52,21 @@ public:
|
|||||||
private:
|
private:
|
||||||
using Sub = QHash< QString, std::vector< std::pair< QObject*, const char* > > >;
|
using Sub = QHash< QString, std::vector< std::pair< QObject*, const char* > > >;
|
||||||
|
|
||||||
static const QString k_KeySpacePrefix; //!< Приставка для наблюдения за данными
|
static const QString kKeySpacePrefix; //!< Приставка для наблюдения за данными
|
||||||
|
static constexpr int kConnectionTimeout { 2000 }; //!< Таймаут на сетевые операции
|
||||||
QTcpSocket* m_socket;
|
QTcpSocket* m_socket;
|
||||||
QTimer* m_connectionTimer; //!< Таймер установления сетевого соединения
|
QTimer* m_connectionTimer; //!< Таймер установления сетевого соединения
|
||||||
static constexpr int k_ConnectionTimeout { 2000 }; //!< Таймаут на сетевые операции
|
|
||||||
/*!
|
/*!
|
||||||
* \brief Таблица подписчиков
|
* \brief Таблица подписчиков
|
||||||
*/
|
*/
|
||||||
QByteArray m_buffer; //!< Буффер прочитанных данных
|
QByteArray m_buffer; //!< Буффер прочитанных данных
|
||||||
Sub m_subscribers; //!< Обработчики сообщений по каналу подписки
|
Sub m_subscribers; //!< Обработчики сообщений по каналу подписки
|
||||||
Sub m_psubscribers; //!< Обработчики сообщений по шаблону канала подписки
|
Sub m_psubscribers; //!< Обработчики сообщений по шаблону канала подписки
|
||||||
|
|
||||||
Q_SLOT void read();
|
Q_SLOT void read();
|
||||||
Q_SLOT void onSocketStateChanged();
|
Q_SLOT void onSocketStateChanged();
|
||||||
|
Q_SLOT void onSubscriberDestroyed( QObject* subscriber );
|
||||||
}; // class PubSub
|
}; // class PubSub
|
||||||
|
|
||||||
} // namespace redis
|
} // namespace redis
|
||||||
|
Loading…
Reference in New Issue
Block a user