diff --git a/synapse/handlers/federation.py b/synapse/handlers/federation.py
index e5deb8a9ef..2201cd977e 100644
--- a/synapse/handlers/federation.py
+++ b/synapse/handlers/federation.py
@@ -346,6 +346,8 @@ class FederationHandler(BaseHandler):
event.get_pdu_json()
)
+ handled_events = set()
+
try:
builder.event_id = self.event_factory.create_event_id()
builder.origin = self.hs.hostname
@@ -371,6 +373,10 @@ class FederationHandler(BaseHandler):
auth_chain = ret["auth_chain"]
auth_chain.sort(key=lambda e: e.depth)
+ handled_events.update([s.event_id for s in state])
+ handled_events.update([a.event_id for a in auth_chain])
+ handled_events.add(new_event.event_id)
+
logger.debug("do_invite_join auth_chain: %s", auth_chain)
logger.debug("do_invite_join state: %s", state)
@@ -426,6 +432,9 @@ class FederationHandler(BaseHandler):
del self.room_queues[room_id]
for p, origin in room_queue:
+ if p.event_id in handled_events:
+ continue
+
try:
self.on_receive_pdu(origin, p, backfilled=False)
except:
diff --git a/synapse/storage/__init__.py b/synapse/storage/__init__.py
index f8d895082d..2db2e9720f 100644
--- a/synapse/storage/__init__.py
+++ b/synapse/storage/__init__.py
@@ -220,7 +220,8 @@ class DataStore(RoomMemberStore, RoomStore,
room_id=event.room_id,
)
- self._store_state_groups_txn(txn, event, context)
+ if not outlier:
+ self._store_state_groups_txn(txn, event, context)
if current_state:
txn.execute(
diff --git a/synapse/storage/schema/state.sql b/synapse/storage/schema/state.sql
index 44f7aafb27..2c48d6daca 100644
--- a/synapse/storage/schema/state.sql
+++ b/synapse/storage/schema/state.sql
@@ -29,7 +29,8 @@ CREATE TABLE IF NOT EXISTS state_groups_state(
CREATE TABLE IF NOT EXISTS event_to_state_groups(
event_id TEXT NOT NULL,
- state_group INTEGER NOT NULL
+ state_group INTEGER NOT NULL,
+ CONSTRAINT event_to_state_groups_uniq UNIQUE (event_id)
);
CREATE INDEX IF NOT EXISTS state_groups_id ON state_groups(id);
|
