summaryrefslogtreecommitdiff
path: root/modules/database/db_redis.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'modules/database/db_redis.cpp')
-rw-r--r--modules/database/db_redis.cpp12
1 files changed, 6 insertions, 6 deletions
diff --git a/modules/database/db_redis.cpp b/modules/database/db_redis.cpp
index c7e2bc9e7..b4abcab7f 100644
--- a/modules/database/db_redis.cpp
+++ b/modules/database/db_redis.cpp
@@ -26,9 +26,9 @@ public:
delete stream;
}
- std::iostream& operator[](const Anope::string &key) override
+ std::iostream &operator[](const Anope::string &key) override
{
- std::stringstream* &stream = data[key];
+ std::stringstream *&stream = data[key];
if (!stream)
stream = new std::stringstream();
return *stream;
@@ -318,7 +318,7 @@ void ObjectLoader::OnResult(const Reply &r)
data[key->bulk] << value->bulk;
}
- Serializable* &obj = st->objects[this->id];
+ Serializable *&obj = st->objects[this->id];
obj = st->Unserialize(obj, data);
if (obj)
{
@@ -337,7 +337,7 @@ void IDInterface::OnResult(const Reply &r)
return;
}
- Serializable* &obj = o->GetSerializableType()->objects[r.i];
+ Serializable *&obj = o->GetSerializableType()->objects[r.i];
if (obj)
/* This shouldn't be possible */
obj->id = 0;
@@ -537,7 +537,7 @@ void SubscriptionListener::OnResult(const Reply &r)
}
else if (op == "del")
{
- Serializable* &s = s_type->objects[obj_id];
+ Serializable *&s = s_type->objects[obj_id];
if (s == NULL)
return;
@@ -587,7 +587,7 @@ void ModifiedObject::OnResult(const Reply &r)
return;
}
- Serializable* &obj = st->objects[this->id];
+ Serializable *&obj = st->objects[this->id];
/* Transaction start */
me->redis->StartTransaction();