mirror of
				https://github.com/matrix-org/synapse.git
				synced 2025-10-31 08:11:24 +01:00 
			
		
		
		
	Always mark remotes as up if we receive a signed request from them
This commit is contained in:
		
							parent
							
								
									60833c8978
								
							
						
					
					
						commit
						db7d0c3127
					
				| @ -79,6 +79,7 @@ class Authenticator(object): | |||||||
|     def __init__(self, hs): |     def __init__(self, hs): | ||||||
|         self.keyring = hs.get_keyring() |         self.keyring = hs.get_keyring() | ||||||
|         self.server_name = hs.hostname |         self.server_name = hs.hostname | ||||||
|  |         self.store = hs.get_datastore() | ||||||
| 
 | 
 | ||||||
|     # A method just so we can pass 'self' as the authenticator to the Servlets |     # A method just so we can pass 'self' as the authenticator to the Servlets | ||||||
|     @defer.inlineCallbacks |     @defer.inlineCallbacks | ||||||
| @ -138,6 +139,12 @@ class Authenticator(object): | |||||||
|         logger.info("Request from %s", origin) |         logger.info("Request from %s", origin) | ||||||
|         request.authenticated_entity = origin |         request.authenticated_entity = origin | ||||||
| 
 | 
 | ||||||
|  |         # If we get a valid signed request from the other side, its probably | ||||||
|  |         # alive | ||||||
|  |         retry_timings = yield self.store.get_destination_retry_timings(origin) | ||||||
|  |         if retry_timings and retry_timings["retry_last_ts"]: | ||||||
|  |             self.store.set_destination_retry_timings(origin, 0, 0) | ||||||
|  | 
 | ||||||
|         defer.returnValue(origin) |         defer.returnValue(origin) | ||||||
| 
 | 
 | ||||||
| 
 | 
 | ||||||
|  | |||||||
		Loading…
	
	
			
			x
			
			
		
	
		Reference in New Issue
	
	Block a user