@@ -23,6 +23,7 @@ use super::packet::{BIG_PACKET_HOP_DATA_LEN, ForwardControlTlvs, Packet, Payload
23
23
use super :: utils;
24
24
use util:: events:: OnionMessageProvider ;
25
25
use util:: logger:: Logger ;
26
+ use util:: ser:: Writeable ;
26
27
27
28
use core:: ops:: Deref ;
28
29
use sync:: { Arc , Mutex } ;
@@ -122,6 +123,8 @@ pub enum SendError {
122
123
TooFewBlindedHops ,
123
124
/// Our next-hop peer was offline or does not support onion message forwarding.
124
125
InvalidFirstHop ,
126
+ /// Our next-hop peer's buffer was full.
127
+ PeerBufferFull ,
125
128
}
126
129
127
130
impl < Signer : Sign , K : Deref , L : Deref > OnionMessenger < Signer , K , L >
@@ -172,6 +175,7 @@ impl<Signer: Sign, K: Deref, L: Deref> OnionMessenger<Signer, K, L>
172
175
match pending_per_peer_msgs. entry ( introduction_node_id) {
173
176
hash_map:: Entry :: Vacant ( _) => Err ( SendError :: InvalidFirstHop ) ,
174
177
hash_map:: Entry :: Occupied ( mut e) => {
178
+ if peer_buffer_full ( e. get ( ) ) { return Err ( SendError :: PeerBufferFull ) }
175
179
e. get_mut ( ) . push_back ( msgs:: OnionMessage { blinding_point, onion_routing_packet } ) ;
176
180
Ok ( ( ) )
177
181
}
@@ -192,6 +196,18 @@ impl<Signer: Sign, K: Deref, L: Deref> OnionMessenger<Signer, K, L>
192
196
}
193
197
}
194
198
199
+ fn peer_buffer_full ( peer_buf : & VecDeque < msgs:: OnionMessage > ) -> bool {
200
+ const MAX_BUFFER_SIZE : usize = 1024 * 256 ;
201
+ let mut buffered_bytes = 0 ;
202
+ for om in peer_buf {
203
+ buffered_bytes += om. serialized_length ( ) ;
204
+ if buffered_bytes >= MAX_BUFFER_SIZE {
205
+ return true
206
+ }
207
+ }
208
+ false
209
+ }
210
+
195
211
impl < Signer : Sign , K : Deref , L : Deref > OnionMessageHandler for OnionMessenger < Signer , K , L >
196
212
where K :: Target : KeysInterface < Signer = Signer > ,
197
213
L :: Target : Logger ,
0 commit comments