From e97827d6009d28ec4e08939ec0cf79dba77a68f0 Mon Sep 17 00:00:00 2001 From: Joseph Lawson Date: Tue, 22 Apr 2014 16:05:00 -0400 Subject: [PATCH] capping at 2 second maximum --- raw_socket_listener/tcp_message.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/raw_socket_listener/tcp_message.go b/raw_socket_listener/tcp_message.go index 21b06f6..bbb45e6 100644 --- a/raw_socket_listener/tcp_message.go +++ b/raw_socket_listener/tcp_message.go @@ -6,14 +6,14 @@ import ( "time" ) -const MSG_EXPIRE = 20000 * time.Millisecond +const MSG_EXPIRE = 2000 * time.Millisecond // TCPMessage ensure that all TCP packets for given request is received, and processed in right sequence // Its needed because all TCP message can be fragmented or re-transmitted // // Each TCP Packet have 2 ids: acknowledgment - message_id, and sequence - packet_id // Message can be compiled from unique packets with same message_id which sorted by sequence -// Message is received if we didn't receive any packets for 20000ms +// Message is received if we didn't receive any packets for 2000ms type TCPMessage struct { ID string // Message ID packets []*TCPPacket