@@ -209,9 +209,9 @@ func (s *session) sendLogonInReplyTo(setResetSeqNum bool, inReplyTo *Message) er
209
209
return nil
210
210
}
211
211
212
- func (session * session ) generateSequenceReset (beginSeqNo int , endSeqNo int , inReplyTo Message ) (err error ) {
212
+ func (s * session ) generateSequenceReset (beginSeqNo int , endSeqNo int , inReplyTo Message ) (err error ) {
213
213
sequenceReset := NewMessage ()
214
- session .fillDefaultHeader (sequenceReset , & inReplyTo )
214
+ s .fillDefaultHeader (sequenceReset , & inReplyTo )
215
215
216
216
sequenceReset .Header .SetField (tagMsgType , FIXString ("4" ))
217
217
sequenceReset .Header .SetField (tagMsgSeqNum , FIXInt (beginSeqNo ))
@@ -224,12 +224,12 @@ func (session *session) generateSequenceReset(beginSeqNo int, endSeqNo int, inRe
224
224
sequenceReset .Header .SetField (tagOrigSendingTime , origSendingTime )
225
225
}
226
226
227
- session .application .ToAdmin (sequenceReset , session .sessionID )
227
+ s .application .ToAdmin (sequenceReset , s .sessionID )
228
228
229
229
msgBytes := sequenceReset .build ()
230
230
231
- session .EnqueueBytesAndSend (msgBytes )
232
- session .log .OnEventf ("Sent SequenceReset TO: %v" , endSeqNo )
231
+ s .EnqueueBytesAndSend (msgBytes )
232
+ s .log .OnEventf ("Sent SequenceReset TO: %v" , endSeqNo )
233
233
234
234
return
235
235
}
@@ -549,19 +549,19 @@ func (s *session) handleLogon(msg *Message) error {
549
549
550
550
// Evaluate tag 789 to see if we end up with an implied gapfill/resend.
551
551
if s .EnableNextExpectedMsgSeqNum && ! msg .Body .Has (tagResetSeqNumFlag ) {
552
- targetWantsNextSeqNumToBe , getErr := msg .Body .GetInt (tagNextExpectedMsgSeqNum )
553
- if getErr == nil {
554
- if targetWantsNextSeqNumToBe != nextSenderMsgNumAtLogonReceived {
555
- if ! s .DisableMessagePersist {
556
- seqResetErr := s .generateSequenceReset (targetWantsNextSeqNumToBe , nextSenderMsgNumAtLogonReceived + 1 , * msg )
557
- if seqResetErr != nil {
558
- return seqResetErr
559
- }
560
- } else {
561
- return targetTooHigh {ReceivedTarget : targetWantsNextSeqNumToBe , ExpectedTarget : nextSenderMsgNumAtLogonReceived }
562
- }
552
+ targetWantsNextSeqNumToBe , getErr := msg .Body .GetInt (tagNextExpectedMsgSeqNum )
553
+ if getErr == nil {
554
+ if targetWantsNextSeqNumToBe != nextSenderMsgNumAtLogonReceived {
555
+ if ! s .DisableMessagePersist {
556
+ seqResetErr := s .generateSequenceReset (targetWantsNextSeqNumToBe , nextSenderMsgNumAtLogonReceived + 1 , * msg )
557
+ if seqResetErr != nil {
558
+ return seqResetErr
563
559
}
560
+ } else {
561
+ return targetTooHigh {ReceivedTarget : targetWantsNextSeqNumToBe , ExpectedTarget : nextSenderMsgNumAtLogonReceived }
562
+ }
564
563
}
564
+ }
565
565
}
566
566
567
567
if err := s .checkTargetTooHigh (msg ); err != nil {
0 commit comments