Commit Graph

1630 Commits

Author SHA1 Message Date
saxon 1cdbfa2c66 cmd/revid-cli: setting mode to paused if ns is in burst mode. 2019-02-04 17:14:19 +10:30
saxon 8978f9edc5 cmd/revid-cli & revid: using goto to sleep for monitor period, and using wg.Done() at the end of output routine. 2019-02-04 17:12:30 +10:30
saxon 93e3899725 cmd/revid-cli: using ns.Send() rather than ns.Run() to poll 2019-02-04 17:04:49 +10:30
saxon ee7eb84d26 revid-cli: correctly using ns.Mode() and ns.SetMode() 2019-02-04 13:25:37 +10:30
saxon 6171c4e999 revid: added handling of burstPeriod to config 2019-02-03 23:43:51 +10:30
saxon 1010721dd0 cmd/revid-cli & revid: Checking revid mode differently - now using ns.Mode(), which should soon be an available feature. Also now using ns.SetMode() - which tells netreceiver that we've changed mode. 2019-02-03 23:37:38 +10:30
saxon 9095044e23 revid: using waitgroups so that revid.Stop() is safer - we can wait until the input and output routines are done before we do anything, like touch the revid config. Also started modifying revid.Update() to remove errors introduced after the copy of updateRevid from revid-cli to revid.go in the previous commit. 2019-02-03 21:55:40 +10:30
saxon 1af4b25030 cmd/revid-cli & revid: removed startRevid and stopRevid as shouldn't be required when we have revid.Start() and revid.Stop(). Created revid.Config() which returns copy of config safely using mutex. removed updateRevid in revid-cli and move to fun revid.Update() - as there's no reason why it can't just be a receiver func - even better considering we want to start moving alot of stuff from revid-cli to the revid-api anyways. 2019-02-03 21:17:44 +10:30
Saxon Milton ea89e7a5af Merged in revid-api-redesign-phase1 (pull request #130)
stream/mts: patch for revid.Start() no exit bug

Approved-by: Alan Noble <anoble@gmail.com>
2019-01-31 23:55:14 +00:00
saxon c44d6bbfd3 revid/revid.go: not during time.Duration conversion 2019-02-01 10:08:49 +10:30
saxon 9bddf343f5 revid/revid.go: moved revid.mu declaration
. Updated todo owner
2019-02-01 10:07:00 +10:30
saxon d26aa8643a revid: renamed transcode to processFrom. Using mutex for isRunning flag. Created setIsRunning func to set state of isRunning. 2019-02-01 09:47:31 +10:30
Alan Noble 0f346ea523 Merged in rtmp-refactoring-4 (pull request #121)
Rtmp refactoring 4

Approved-by: Saxon Milton <saxon.milton@gmail.com>
Approved-by: Alan Noble <anoble@gmail.com>
2019-01-31 21:26:22 +00:00
saxon 051263c144 revid/revid.go: revid.lex to revid.transcode 2019-01-31 19:58:25 +10:30
saxon 1e307fc37b revid/revid.go: made routines named rather than anonymous 2019-01-31 19:42:20 +10:30
saxon e18b1f51f0 revid/revid.go: capture error from r.Start() in error handling routine 2019-01-31 15:49:44 +10:30
saxon d53eafe215 revid/revid.go: not running r.setupInput() as routine - now getting error an returning 2019-01-31 15:15:38 +10:30
saxon ed4d97f893 stream/mts: patch for revid.Start() no exit bug 2019-01-31 15:03:50 +10:30
kortschak 197ca684a6 Merged in sliceoutputs (pull request #120)
cmd/revid-cli,revid: use a slice for output destination flags

Approved-by: Saxon Milton <saxon.milton@gmail.com>
2019-01-30 03:07:30 +00:00
Dan Kortschak 58102e5587 revid: fix http destination assignment 2019-01-30 13:19:00 +10:30
Dan Kortschak 071e6fd0f7 revid: honour difference between rtmp dst and others 2019-01-29 19:56:02 +10:30
Saxon Milton 286ae4334b Merged in psi-at-start (pull request #127)
stream/mts/encoder.go: writing psi at start of stream

Approved-by: Alan Noble <anoble@gmail.com>
2019-01-24 02:53:53 +00:00
saxon df146cfb17 stream/mts/encoder.go: writing psi at start of stream 2019-01-23 15:50:25 +10:30
saxon 2da8d2af85 av/rtmp/rtmp_test.go: using local rtmpSender io.writer implemntation to handle errors from rtmp 2019-01-22 13:54:56 +10:30
Saxon Milton bea48d8657 Merged in findPMT-improve (pull request #122)
mts/mpegts.go: FindPMT now also returns index

Approved-by: Alan Noble <anoble@gmail.com>
2019-01-22 01:01:18 +00:00
saxon 6b4e0946dd stream/mts/mpegts.go: updated FindPMT comment 2019-01-22 11:27:24 +10:30
saxon ba209a1d7c mts/mpegts.go: FindPMT now also returns index 2019-01-22 11:21:12 +10:30
Saxon Milton 1ec23badcc Merged in remove-LocationStrBytes (pull request #118)
Get rid of LocationStrBytes func

Approved-by: kortschak <dan@kortschak.io>
2019-01-21 11:40:02 +00:00
saxon bc3a73bedc av/stream/psi/psi_test.go: updated comment for buildPmtWithMeta() 2019-01-21 18:25:06 +10:30
scruzin 2697dcf515 More elegant switch in parseURL() for port logic. 2019-01-21 10:57:40 +10:30
scruzin 3a70dc6ddc parseURL() now returns errUnimplemented for SSL. 2019-01-21 10:38:27 +10:30
saxon 67d952c6a7 psi/psi_test.go: made buildPmtWithMeta() safer and readable 2019-01-20 21:58:23 +10:30
saxon a24e4ecb81 psi/psi_test.go: not making it look like I'm appending directly to a global 2019-01-20 21:48:34 +10:30
saxon c4990c946f psi/psi_test.go: not wrapp tstStr in []byte 2019-01-20 21:39:07 +10:30
saxon 239cebe347 psi/psi_test.go: made location tsts const 2019-01-20 21:12:26 +10:30
saxon 3835ff7ce1 psi/psi_test.go: made location tsts strings again and have buildPmtWithMeta take a string instead of []byte 2019-01-20 21:11:09 +10:30
saxon b69c990b21 psi/psi_test.go: got rid of bytes declaration for location strigns 2019-01-20 21:04:27 +10:30
saxon 1a966e8f9b psi/psi_test.go: improved some naming 2019-01-20 20:43:00 +10:30
saxon 5c4795786e psi/helpers.go: modified UpdateLocation() to make updating of location in pmt cleaner, and also removed redundant conversion of string to byte slice 2019-01-20 20:14:27 +10:30
scruzin 0105c76dc5 Move port defaulting logic to parseURL(). 2019-01-20 13:33:44 +10:30
scruzin 89d9bf3eef Return errors from the loop in connect() rather than breaking. 2019-01-20 10:28:05 +10:30
scruzin efe40a6778 Move test for empty RTMP 'app' into parseURL(). 2019-01-20 09:59:28 +10:30
scruzin a362d1d2ab connect() now closes c.link.conn upon an error. 2019-01-20 09:50:51 +10:30
scruzin 04ad1fec25 Log packet size before la and ra. 2019-01-20 09:20:56 +10:30
scruzin fbad21bc76 connect() now constructs its packet with a buf to avoid needless packet resizing later. 2019-01-20 08:52:58 +10:30
scruzin 969e2f4fa9 packet.resize() now only makes a new buf when necessary. 2019-01-20 08:41:32 +10:30
scruzin ddd1e4ab17 readFrom() now logs a warning if it is reading a large packet (which I suspect never happens). 2019-01-20 08:09:49 +10:30
scruzin 828cc3780a Removed superfluous packet.bytesRead. 2019-01-20 07:56:55 +10:30
scruzin 42be87d98a sendConnectPacket() now encodes required link info in one go using amf.Encode(). 2019-01-20 07:33:43 +10:30
scruzin adfb87dcf9 TypeString now exported (was typeString). 2019-01-20 07:30:24 +10:30