@@ -176,13 +176,13 @@ def on_enter_send(self):
176
176
# TODO: set timeout
177
177
if not self ._send_fragments :
178
178
if not self ._send_messages .empty ():
179
- self .send_fragments = encode_fragment (self ._send_messages .get ().encode ())
179
+ self ._send_fragments = encode_fragment (self ._send_messages .get ().encode ())
180
180
self ._send_fragment_index = - 1
181
181
182
182
self ._send_fragment_index += 1
183
183
self ._send_fragment_try = 1
184
- self ._send_pdu (self .send_fragments [self ._send_fragment_index ])
185
- if len (self .send_fragments ) >= self ._send_fragment_index + 1 :
184
+ self ._send_pdu (self ._send_fragments [self ._send_fragment_index ])
185
+ if len (self ._send_fragments ) >= self ._send_fragment_index + 1 :
186
186
# last message
187
187
self .ev_finished ()
188
188
else :
@@ -192,15 +192,15 @@ def on_enter_send(self):
192
192
def on_timeout_wait_ack (self ):
193
193
# resend
194
194
if self ._send_fragment_try <= 3 :
195
- self ._send_pdu (self .send_fragments [self ._send_fragment_index ])
195
+ self ._send_pdu (self ._send_fragments [self ._send_fragment_index ])
196
196
else :
197
197
self ._error ("Lock is not sending FragmentAcks!" )
198
198
self .ev_error ()
199
199
200
200
def on_timeout_wait_answer (self ):
201
201
""" when waiting for an answer, we might even have to re-send the last fragment """
202
202
if self ._send_fragment_try <= 3 :
203
- self ._send_pdu (self .send_fragments [self ._send_fragment_index ])
203
+ self ._send_pdu (self ._send_fragments [self ._send_fragment_index ])
204
204
205
205
def on_enter_wait_answer (self ):
206
206
self ._recv_fragment_index = 0
0 commit comments