github/reddit
1
1
Fork 0
mirror of https://github.com/reddit-archive/reddit.git synced 2026-01-25 23:08:22 -05:00
Code Issues Packages Projects Releases Wiki Activity

Make CL configurable per CF.

Browse Source
This commit is contained in:
Neil Williams
2011-06-26 13:55:52 -07:00
parent 8758abec07
commit 352d29a32e
1 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
r2/r2/lib/db/tdb_cassandra.py
View File

@@ -120,14 +120,16 @@ class ThingMeta(type):
thing_types[cls._type_prefix] = cls
cls._read_consistency_level = read_consistency_level
cls._write_consistency_level = write_consistency_level
if not getattr(cls, "_read_consistency_level", None):
cls._read_consistency_level = read_consistency_level
if not getattr(cls, "_write_consistency_level", None):
cls._write_consistency_level = write_consistency_level
try:
cls._cf = ColumnFamily(cassandra,
cf_name,
read_consistency_level = read_consistency_level,
write_consistency_level = write_consistency_level)
read_consistency_level = cls._read_consistency_level,
write_consistency_level = cls._write_consistency_level)
except NotFoundException:
if not db_create_tables:
raise
@@ -143,8 +145,8 @@ class ThingMeta(type):
# try again to look it up
cls._cf = ColumnFamily(cassandra,
cf_name,
read_consistency_level = read_consistency_level,
write_consistency_level = write_consistency_level)
read_consistency_level = cls._read_consistency_level,
write_consistency_level = cls._write_consistency_level)
cls._kind = name