Changing SeqNums to uint64

Author: SNORRIS721

in_session.go

@@ -165,7 +165,7 @@ func (state inSession) handleSequenceReset(session *session, msg *Message) (next
 
 		switch {
 		case newSeqNo > expectedSeqNum:
-			if err := session.store.SetNextTargetMsgSeqNum(int(newSeqNo)); err != nil {
+			if err := session.store.SetNextTargetMsgSeqNum(uint64(newSeqNo)); err != nil {
 				return handleStateError(session, err)
 			}
 		case newSeqNo < expectedSeqNum:
@@ -196,7 +196,7 @@ func (state inSession) handleResendRequest(session *session, msg *Message) (next
 		return state.processReject(session, msg, RequiredTagMissing(tagEndSeqNo))
 	}
 
-	endSeqNo := int(endSeqNoField)
+	endSeqNo := uint64(endSeqNoField)
 
 	session.log.OnEventf("Received ResendRequest FROM: %d TO: %d", beginSeqNo, endSeqNo)
 	expectedSeqNum := session.store.NextSenderMsgSeqNum()
@@ -207,7 +207,7 @@ func (state inSession) handleResendRequest(session *session, msg *Message) (next
 		endSeqNo = expectedSeqNum - 1
 	}
 
-	if err := state.resendMessages(session, int(beginSeqNo), endSeqNo, *msg); err != nil {
+	if err := state.resendMessages(session, uint64(beginSeqNo), endSeqNo, *msg); err != nil {
 		return handleStateError(session, err)
 	}
 
@@ -225,7 +225,7 @@ func (state inSession) handleResendRequest(session *session, msg *Message) (next
 	return state
 }
 
-func (state inSession) resendMessages(session *session, beginSeqNo, endSeqNo int, inReplyTo Message) error {
+func (state inSession) resendMessages(session *session, beginSeqNo, endSeqNo uint64, inReplyTo Message) error {
 	if session.DisableMessagePersist {
 		return state.generateSequenceReset(session, beginSeqNo, endSeqNo+1, inReplyTo)
 	}
@@ -387,7 +387,7 @@ func (state inSession) doTargetTooLow(session *session, msg *Message, rej target
 	return state
 }
 
-func (state *inSession) generateSequenceReset(session *session, beginSeqNo int, endSeqNo int, inReplyTo Message) (err error) {
+func (state *inSession) generateSequenceReset(session *session, beginSeqNo uint64, endSeqNo int, inReplyTo Message) (err error) {
 	sequenceReset := NewMessage()
 	session.fillDefaultHeader(sequenceReset, &inReplyTo)
 

store.go

@@ -21,22 +21,22 @@ import (
 
 // The MessageStore interface provides methods to record and retrieve messages for resend purposes.
 type MessageStore interface {
-	NextSenderMsgSeqNum() int
-	NextTargetMsgSeqNum() int
+	NextSenderMsgSeqNum() uint64
+	NextTargetMsgSeqNum() uint64
 
 	IncrNextSenderMsgSeqNum() error
 	IncrNextTargetMsgSeqNum() error
 
-	SetNextSenderMsgSeqNum(next int) error
-	SetNextTargetMsgSeqNum(next int) error
+	SetNextSenderMsgSeqNum(next uint64) error
+	SetNextTargetMsgSeqNum(next uint64) error
 
 	CreationTime() time.Time
 	SetCreationTime(time.Time)
 
-	SaveMessage(seqNum int, msg []byte) error
-	SaveMessageAndIncrNextSenderMsgSeqNum(seqNum int, msg []byte) error
-	GetMessages(beginSeqNum, endSeqNum int) ([][]byte, error)
-	IterateMessages(beginSeqNum, endSeqNum int, cb func([]byte) error) error
+	SaveMessage(seqNum uint64, msg []byte) error
+	SaveMessageAndIncrNextSenderMsgSeqNum(seqNum uint64, msg []byte) error
+	GetMessages(beginSeqNum, endSeqNum uint64) ([][]byte, error)
+	IterateMessages(beginSeqNum, endSeqNum uint64, cb func([]byte) error) error
 
 	Refresh() error
 	Reset() error