From 602559fd9fa39015043ec6fa2a1f8d2c8e36d062 Mon Sep 17 00:00:00 2001
From: Holger Hans Peter Freyther <zecke@selfish.org>
Date: Sun, 5 Aug 2012 09:27:20 +0200
Subject: contrib: Move the shared code into a new file

---
 openbsc/contrib/rtp/rtp_replay.st | 64 ++-------------------------------------
 1 file changed, 2 insertions(+), 62 deletions(-)

(limited to 'openbsc/contrib/rtp/rtp_replay.st')

diff --git a/openbsc/contrib/rtp/rtp_replay.st b/openbsc/contrib/rtp/rtp_replay.st
index 7e73e93a3..a281570cf 100644
--- a/openbsc/contrib/rtp/rtp_replay.st
+++ b/openbsc/contrib/rtp/rtp_replay.st
@@ -3,73 +3,13 @@ Simple UDP replay from the state files
 "
 
 PackageLoader fileInPackage: #Sockets.
+FileStream fileIn: 'rtp_replay_shared.st'.
 
-Object subclass: RTPReplay [
-    | filename |
-    RTPReplay class >> on: aFile [
-        ^ self new
-            file: aFile; yourself
-    ]
-
-    file: aFile [ 
-        filename := aFile
-    ]
-
-    streamAudio: aHost port: aPort [
-        | file last_time last_image udp_send socket dest |
-
-        last_time := nil.
-        last_image := nil.
-        file := FileStream open: filename.
-
-        "Send the payload"
-        dest := Sockets.SocketAddress byName: aHost.
-        socket := Sockets.DatagramSocket new.
-        udp_send := [:payload | | datagram |
-            datagram := Sockets.Datagram data: payload contents address: dest port: aPort.
-            socket nextPut: datagram
-        ].
-
-        [file atEnd] whileFalse: [
-            | lineStream time data now_image |
-            lineStream := file nextLine readStream.
-
-            "Read the time, skip the blank, parse the data"
-            time := Number readFrom: lineStream.
-            lineStream skip: 1.
-
-            data := WriteStream on: (ByteArray new: 30).
-            [lineStream atEnd] whileFalse: [
-                | hex |
-                hex := lineStream next: 2.
-                data nextPut: (Number readFrom: hex readStream radix: 16).
-            ].
-
-            last_time isNil
-                ifTrue: [
-                    "First time, send it right now"
-                    last_time := time.
-                    last_image := Time millisecondClockValue.
-                    udp_send value: data.
-                ]
-                ifFalse: [
-                    | wait_image new_image_time |
-
-                    "How long to wait?"
-                    wait_image := last_image + ((time - last_time) * 1000).
-                    [ wait_image > Time millisecondClockValue ] whileTrue: [].
-
-                    udp_send value: data.
-                    last_time := time.
-                    last_image := wait_image.
-                ]
-        ]
-    ]
-]
 
 Eval [
     | replay |
 
+
     replay := RTPReplay on: 'rtp_ssrc6976010.240.240.1_to_10.240.240.50.state'.
 
     Transcript nextPutAll: 'Going to stream now'; nl.
-- 
cgit v1.2.3