Changeset 130

Timestamp:

18/11/05 00:14:19 (3 years ago)

Author:

jpsaman

Message:

Added bytes transferred and bitrates between two PCR's to the verbose output.

Files:

• trunk/examples/decode_mpeg.c (modified) (10 diffs)

trunk/examples/decode_mpeg.c

@@ -171 +171 @@
-    memset( p_dst, 0, i_size );
-    i_rc = read( i_socket, p_dst, i_size );
+    if( i_rc < 0 ) printf( "READ INTERRUPTED BY SIGNAL\n" );
+    if( i_rc == 0 ) printf( "READ RETURNS 0\n" );
-    return (i_rc <= i_size ) ? 1 : 0;
-}
@@ -418 +420 @@
-    int i_mtu = 1316; /* (7 * 188) = 1316 < 1500 network MTU */
-#ifdef HAVE_SYS_SOCKET_H
-
-
-
-
-
-
+
+
+
+
+
+
+
-    char *filename = NULL;
-    
@@ -447 +450 @@
-                i_mtu = atoi( optarg );
-                if( i_mtu < 0 ) i_mtu = 1316;
+                else i_mtu = (i_mtu / 188) * 188;
-                break;
-            case 'p':
@@ -466 +470 @@
-    } while( next_option != -1 );
-
+#ifdef HAVE_SYS_SOCKET_H
+    if( b_verbose ) 
+    {
+        printf( "set mtu to %d\n", i_mtu );
+    }
+#endif
-    /* initialize */
-    if( filename )
@@ -490 +500 @@
-    /* Read first packet */
-    if( filename )
+    {
-        b_ok = ReadPacket( i_fd, p_data);
-
-
+
+
+
+
+
-        b_ok = ReadPacketFromSocket( i_fd, p_data, i_mtu );
-
+
+
-    if( b_verbose )
-
+, bytes, bitrate (bytes/delta)
-#endif
-        
-    /* Enter infinite loop */    
-    p_stream->pat.handle = dvbpsi_AttachPAT( DumpPAT, p_stream );    
-b_ok
+ b_ok 
-    {
-        int     i = 0;
@@ -538 +553 @@
-                p_stream->pid[i_pid].i_cc = i_cc;
-            }
-
+
-            /* Other adaptation field */
-            if( b_adaptation )
@@ -555 +570 @@
-                {
-                    mtime_t i_pcr;  /* 33 bits */
-
-
+
-
-                    i_pcr = ( ( (mtime_t)p_tmp[6] << 25 ) |
@@ -572 +586 @@
-                        time_t time_current;
-                        time_t tv_delta;
+                        struct timeval tv;
-
-                        gettimeofday( &tv, NULL );
-                        time_current = (tv.tv_sec*1000) + (tv.tv_usec/1000);
-
-
+
+
+
+
+
+
+
-                        time_prev = time_current;
-                    }
-
-\n
+=
+, bytes %u, 
-                                (long long int)p_stream->pid[i_pid].i_pcr, (long long int)i_prev_pcr,
-
+, i_bytes
-                    else if( b_verbose )
-\n
+, bytes %u, 
-                                (long long int)p_stream->pid[i_pid].i_pcr, (long long int)i_prev_pcr,
-
+
+
+
+
+
+
+
+
+
-                }
-            }
-
+
-            /* Handle discontinuities if they occured,
-             * according to ISO/IEC 13818-1: DIS pages 20-22 */
@@ -600 +628 @@
-                {
-                    if( b_pcr )
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-                    if( b_discontinuity_seen )
-                    {
@@ -622 +667 @@
-        /* Read next packet */
-        if( filename )
+        {
-            b_ok = ReadPacket( i_fd, p_data);
+            i_bytes += 188;
+        }
-#ifdef HAVE_SYS_SOCKET_H
-        else
+        {
-            b_ok = ReadPacketFromSocket( i_fd, p_data, i_mtu );
+            i_bytes += i_mtu;
+        }
-#endif
-    }