Merge "Option to keep FIX sequence numbers" from Denis

penberg · Oct 21, 2015 · edd92d9 · edd92d9
2 parents 8b7e225 + a63e680
commit edd92d9
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/include/libtrading/proto/fix_session.h b/include/libtrading/proto/fix_session.h
@@ -112,6 +112,7 @@ enum fix_send_flag {
 
 enum fix_recv_flag {
 	FIX_RECV_FLAG_MSG_DONTWAIT = 1UL << 16, // upper 16 bits
+	FIX_RECV_KEEP_IN_MSGSEQNUM = 1UL << 17
 };
 
 #ifdef __cplusplus

diff --git a/lib/proto/fix_session.c b/lib/proto/fix_session.c
@@ -207,7 +207,7 @@ int fix_session_recv(struct fix_session *self, struct fix_message **res, unsigne
 
 	if (!fix_message_parse(msg, self->dialect, buffer, flags)) {
 		self->rx_timestamp = self->now;
-		self->in_msg_seq_num++;
+		if (!(flags & FIX_RECV_KEEP_IN_MSGSEQNUM)) self->in_msg_seq_num++;
 		goto parsed;
 	}
 
@@ -230,7 +230,7 @@ int fix_session_recv(struct fix_session *self, struct fix_message **res, unsigne
 
 	if (!fix_message_parse(msg, self->dialect, buffer, flags)) {
 		self->rx_timestamp = self->now;
-		self->in_msg_seq_num++;
+		if (!(flags & FIX_RECV_KEEP_IN_MSGSEQNUM)) self->in_msg_seq_num++;
 		goto parsed;
 	}