Changeset 26516

Timestamp:

02/27/14 14:37:02 (9 years ago)

Author:

gost

Message:

[titan] resync for Data Loss

File:

• titan/titan/record.h (modified) (1 diff)

titan/titan/record.h

@@ -632 +632 @@
                                 }
                                 else
-                                                writeret = dvbwrite(servicenode->recdstfd, buf, readret, writetimeout);
+                                {
+                                        if(buf[0] != 0x47)
+                                        {
+                                                debug(200, "resync");
+                                                i = 1;
+                                                while(i < 188)
+                                                {
+                                                        if(buf[i] == 0x47) break;
+                                                        i++;
+                                                }
+                                                if(i < 188)
+                                                {
+                                                        memcpy(buf, buf + i, recbsize - i);
+                                                        dvbreadfd(servicenode->recsrcfd, buf, recbsize - i, i, readtimeout, 0);
+                                                }
+                                        }
+                                        writeret = dvbwrite(servicenode->recdstfd, buf, readret, writetimeout);
+                                }
 
                                 //inject first pakets slower/smaler, so demux can start and read