@@ -1033,7 +1033,7 @@ int th_route_direction(sip_msg_t *msg)
int th_skip_msg(sip_msg_t *msg)
{
- if (!get_cseq(msg)) {
+ if (msg->cseq==NULL || get_cseq(msg)==NULL) {
LM_WARN("Invalid/Unparsed CSeq in message. Skipping.");
return 1;
}
@@ -178,7 +178,10 @@ int th_msg_received(void *data)
msg.buf = obuf->s;
msg.len = obuf->len;
- th_prepare_msg(&msg);
+ if(th_prepare_msg(&msg)!=0)
+ {
+ goto done;
+ }
if(th_skip_msg(&msg))
@@ -260,7 +263,10 @@ int th_msg_sent(void *data)