- Adding coverity badge

- Small fixes in tcp stack management
- Fixed mtcp's issue# 67 pertaining to epwget*.

README.md

@@ -1,4 +1,5 @@
 [![Build Status](https://travis-ci.org/ndsl-kaist/mOS-networking-stack.svg?branch=master)](https://travis-ci.org/ndsl-kaist/mOS-networking-stack)
+[![Build Status](https://scan.coverity.com/projects/11918/badge.svg)](https://scan.coverity.com/projects/mos-networking-stack)
 
 # mOS-networking-stack
 

core/src/tcp_in.c

@@ -1305,8 +1305,11 @@ UpdateRecvTCPContext(mtcp_manager_t mtcp, struct tcp_stream *cur_stream,
 		/* SYN retransmit implies our SYN/ACK was lost. Resend */
 		if (tcph->syn && pctx->p.seq == cur_stream->rcvvar->irs)
 			Handle_TCP_ST_LISTEN(mtcp, cur_stream, pctx);
-		else
+		else {
 			Handle_TCP_ST_SYN_RCVD(mtcp, cur_stream, pctx);
+			if (pctx->p.payloadlen > 0 && cur_stream->state == TCP_ST_ESTABLISHED)
+				Handle_TCP_ST_ESTABLISHED(mtcp, cur_stream, pctx);
+		}
 		break;
 
 	case TCP_ST_ESTABLISHED:

core/src/tcp_out.c

@@ -377,11 +377,13 @@ SendTCPPacket(struct mtcp_manager *mtcp, tcp_stream *cur_stream,
 		struct tcp_stream *recvside_stream = cur_stream->pair_stream;
 		struct tcp_stream *sendside_stream = cur_stream;
 
-		if (recvside_stream->rcvvar && recvside_stream->rcvvar->rcvbuf)
-			pctx.p.offset = (uint64_t)seq2loff(recvside_stream->rcvvar->rcvbuf,
-					pctx.p.seq, recvside_stream->rcvvar->irs + 1);
-
-		UpdateMonitor(mtcp, sendside_stream, recvside_stream, &pctx, false);
+		if (recvside_stream) {
+			if (recvside_stream->rcvvar && recvside_stream->rcvvar->rcvbuf)
+				pctx.p.offset = (uint64_t)seq2loff(recvside_stream->rcvvar->rcvbuf,
+								   pctx.p.seq, recvside_stream->rcvvar->irs + 1);
+
+			UpdateMonitor(mtcp, sendside_stream, recvside_stream, &pctx, false);
+		}
 	}
 
 #ifdef PKTDUMP

samples/epwget/epwget-mp.c

@@ -345,9 +345,9 @@ HandleReadEvent(thread_context_t ctx, int sockid, struct wget_vars *wv)
 						wv->file_len, wv->file_len / 1024 / 1024);
 				wv->headerset = TRUE;
 				wv->recv += (rd - (wv->resp_len - wv->header_len));
-				rd = (wv->resp_len - wv->header_len);
 
 				pbuf += (rd - (wv->resp_len - wv->header_len));
+				rd = (wv->resp_len - wv->header_len);
 
 			} else {
 				/* failed to parse response header */

samples/epwget/epwget.c

@@ -346,9 +346,9 @@ HandleReadEvent(thread_context_t ctx, int sockid, struct wget_vars *wv)
 						wv->file_len, wv->file_len / 1024 / 1024);
 				wv->headerset = TRUE;
 				wv->recv += (rd - (wv->resp_len - wv->header_len));
-				rd = (wv->resp_len - wv->header_len);
 
 				pbuf += (rd - (wv->resp_len - wv->header_len));
+				rd = (wv->resp_len - wv->header_len);
 
 			} else {
 				/* failed to parse response header */