Skip to content
This repository has been archived by the owner on Apr 26, 2024. It is now read-only.

remaining isintance fixes #3281

Merged
merged 3 commits into from
May 30, 2018
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 3 additions & 2 deletions synapse/storage/search.py
Original file line number Diff line number Diff line change
Expand Up @@ -18,13 +18,14 @@
import re
import simplejson as json

from six import string_types

from twisted.internet import defer

from .background_updates import BackgroundUpdateStore
from synapse.api.errors import SynapseError
from synapse.storage.engines import PostgresEngine, Sqlite3Engine


logger = logging.getLogger(__name__)

SearchEntry = namedtuple('SearchEntry', [
Expand Down Expand Up @@ -126,7 +127,7 @@ def reindex_search_txn(txn):
# skip over it.
continue

if not isinstance(value, basestring):
if not isinstance(value, string_types):
# If the event body, name or topic isn't a string
# then skip over it
continue
Expand Down
12 changes: 8 additions & 4 deletions synapse/util/caches/descriptors.py
Original file line number Diff line number Diff line change
Expand Up @@ -31,6 +31,9 @@
import inspect
import threading

from six import string_types, itervalues
import six


logger = logging.getLogger(__name__)

Expand Down Expand Up @@ -205,7 +208,7 @@ def invalidate_many(self, key):
def invalidate_all(self):
self.check_thread()
self.cache.clear()
for entry in self._pending_deferred_cache.itervalues():
for entry in itervalues(self._pending_deferred_cache):
entry.invalidate()
self._pending_deferred_cache.clear()

Expand Down Expand Up @@ -392,9 +395,10 @@ def onErr(f):

ret.addErrback(onErr)

# If our cache_key is a string, try to convert to ascii to save
# a bit of space in large caches
if isinstance(cache_key, basestring):
# If our cache_key is a string on py2, try to convert to ascii
# to save a bit of space in large caches. Py3 does this
# internally automatically.
if six.PY2 and isinstance(cache_key, string_types):
cache_key = to_ascii(cache_key)

result_d = ObservableDeferred(ret, consumeErrors=True)
Expand Down
14 changes: 7 additions & 7 deletions synapse/util/frozenutils.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,16 +16,17 @@
from frozendict import frozendict
import simplejson as json

from six import string_types


def freeze(o):
t = type(o)
if t is dict:
if isinstance(o, dict):
return frozendict({k: freeze(v) for k, v in o.items()})

if t is frozendict:
if isinstance(o, frozendict):
return o

if t is str or t is unicode:
if isinstance(o, string_types):
return o

try:
Expand All @@ -37,11 +38,10 @@ def freeze(o):


def unfreeze(o):
t = type(o)
if t is dict or t is frozendict:
if isinstance(o, (dict, frozendict)):
return dict({k: unfreeze(v) for k, v in o.items()})

if t is str or t is unicode:
if isinstance(o, string_types):
return o

try:
Expand Down