bahman/protocol
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
511 Commits 77 Branches 300 Tags
datachannel_efficient
Commit Graph

76 Commits

Author SHA1 Message Date
Raja Subramanian
cf9f95141e bit map (#473) 
copying Paul's go playground mostly.
 2023-09-16 01:53:28 +05:30
Paul Wells
079ca0da61 add function to get graph node ids (#462) 2023-09-05 10:09:31 -07:00
Benjamin Pracht
405389fa48 Support URL pull in ingress (#438) 2023-08-03 10:14:19 -07:00
Raja Subramanian
d45d830f69 De-duped slice util (#433) 2023-07-29 18:17:40 +05:30
Paul Wells
e1a077ae92 move timeout queue helper to utils (#431) 2023-07-27 19:40:59 -07:00
David Zhao
c9e9ae555f Add license headers & NOTICE (#429) 
* Add license headers & NOTICE

* generated protobuf

---------

Co-authored-by: github-actions <41898282+github-actions[bot]@users.noreply.github.com>
 2023-07-27 16:43:25 -07:00
David Zhao
1cc5a5d915 Fix rare race condition with missed protoproxy update. (#424) 
Also do not update refreshedAt unless content has changed
 2023-07-19 14:31:52 -07:00
Raja Subramanian
9d0d6c9e94 Do not update if the model does not change. (#423) 
* Do not update if the model does not change.

* No need for equality function

* generated protobuf

---------

Co-authored-by: github-actions <41898282+github-actions[bot]@users.noreply.github.com>
 2023-07-15 13:58:01 +05:30
Benjamin Pracht
b0d723aaa9 Export redactStreamKey as RedactIdentifier (#419) 2023-07-11 15:41:19 +08:00
Benjamin Pracht
193f7bd191 Move redact.go from egress (#417) 2023-07-11 08:39:53 +08:00
renovate[bot]
fefcd74b77 fix(deps): update go deps (#399) 
* fix(deps): update go deps

Generated by renovateBot

* generated protobuf

* improve protoproxy test reliability

---------

Co-authored-by: renovate[bot] <29139614+renovate[bot]@users.noreply.github.com>
Co-authored-by: github-actions <41898282+github-actions[bot]@users.noreply.github.com>
Co-authored-by: David Zhao <dz@livekit.io>
 2023-07-08 22:48:29 -07:00
Paul Wells
99e39d9896 add math utils (#415) 2023-07-05 23:39:19 -07:00
Raja Subramanian
e5323cdb4a Timed aggregator. (#412) 
* Timed aggregator.

Online aggretor over time.

Samples added aggregate (scaled by amount of time a sample
has lived for) at the time of adding sample.

Can get aggregate, aggregate duration and average value later.

First use: in scorer to keep track of aggregate bandwidth, average
distance from desired layer

* Feedback + check for backwards time in getters.
 2023-07-01 09:58:48 +05:30
David Colburn
cda2a8ac91 Use floats for cpu (#410) 
* use floats for cpu

* change CPUStats.NumCPU

* missed a return
 2023-06-29 18:29:18 -07:00
Benjamin Pracht
0644d9a979 Fix NumCPU implementation for cgroup v1 (#409) 2023-06-29 16:07:10 -07:00
Benjamin Pracht
5cff0336ab Add resourceID to IngressState (#408) 2023-06-28 18:50:34 -07:00
Paul Wells
519c96683d add graph node delete method (#407) 2023-06-22 10:20:00 -07:00
David Zhao
7d128913f3 Create missed queueUpdate channel for ProtoProxy (#402) 
This caused immediate updates to not go through right away.
 2023-06-10 20:06:50 -07:00
Paul Wells
6cb3e577e2 make graph accessors consistent (#400) 2023-06-08 05:55:54 -07:00
Paul Wells
d8cc358109 add event observer list util (#394) 
* add event observer list util

* update psrpc

* update codegen

* generated protobuf

---------

Co-authored-by: github-actions <41898282+github-actions[bot]@users.noreply.github.com>
 2023-06-05 18:22:16 -07:00
Mikhail Chekh
89c91393d0 Fix call numCPU in root cgroup (#388) 2023-05-31 10:14:46 -07:00
Paul Wells
08ebbda448 add graph util (#380) 2023-05-14 22:26:51 -07:00
Paul Wells
c3734b9b46 add event emitter (#379) 
* add director node type

* add event emitter

* add tests

* generated protobuf

* feedback

* correct require

---------

Co-authored-by: github-actions <41898282+github-actions[bot]@users.noreply.github.com>
 2023-05-14 20:42:41 -07:00
Paul Wells
26fe70550b add b62 encoding for guids (#376) 
* add b62 encoding for guids

* add test

* cleanup

* cleanup
 2023-05-12 11:59:53 -07:00
Paul Wells
e2f4e65f58 record stack trace in lock tracker (#373) 
* record stack trace in lock tracker

* copy stack
 2023-05-07 02:02:38 -07:00
David Zhao
ac74d1e920 Periodically process webhooks queue, in case an event was not flushed (#372) 
* Periodically process webhooks queue, in case an event was not flushed

* more resilient goroutines check

* added more logging
 2023-05-05 16:35:07 -07:00
Benjamin Pracht
db5afb1c7f Protocol support for WHIP ingress (#366) 
The pion logger package was extracted from livekit-server. The err_array code is from egress.
 2023-04-27 18:13:59 -07:00
Raja Subramanian
c54f5f7f41 Adding a few more bits (#361) 
- getting samples after some time
- getting linear extrapolated value

some day, I will use all of these :-)
 2023-04-24 13:09:01 +05:30
David Zhao
eee263b380 Improve protoproxy test reliability (#359) 2023-04-22 21:09:04 -07:00
David Zhao
a68f38ce7d Added ProtoProxy util, NumPublishers field (#358) 
ProtoProxy achieves two goals:
- avoids needless regeneration of readonly protobufs
- update certain changes periodically
 2023-04-22 20:25:51 -07:00
Paul Wells
eb3ef0f4bf add method to check if timed version is uninitialized (#357) 2023-04-22 06:14:40 -07:00
Raja Subramanian
6707e562d4 Adding a collapse duration for repeated values. (#356) 
* Adding a collapse duration for repeated values.

Hoping to use this struct more widely. Hopefully in stream allocator.
That's what I am looking at now.

* add kendall's tau

* introduce update op latest
 2023-04-22 11:23:06 +05:30
Raja Subramanian
3058e52593 Moving timeseries to own module and adding more stats/tests. (#355) 
* Moving timeseries to own module and adding more stats/tests.

* clean up
 2023-04-22 09:33:22 +05:30
Benjamin Pracht
802309c658 Work around phantom CPU core reporting in group v1 (#337) 2023-04-05 12:46:50 -07:00
Paul Wells
2336d2c655 Revert "add clock offset to timed version generator (#330)" (#332) 
This reverts commit 7488296390.
 2023-03-30 17:30:29 -07:00
Raja Subramanian
f1bba9bc14 Adding a time series utility. (#331) 
* Adding a time series utility.

Also adding a `SWEEPER` node type.

* generated protobuf

* regen with protoco 3.21.12

* generated protobuf

* remove unnecessary prune calls

* slice -> list

* correct comment

---------

Co-authored-by: github-actions <41898282+github-actions[bot]@users.noreply.github.com>
 2023-03-30 21:48:57 +05:30
Mathew Kamkar
7488296390 add clock offset to timed version generator (#330) 
* add clock offset to timed version generator

* fix interface
 2023-03-29 23:27:28 -07:00
Paul Wells
7d4c517bf4 add workergroup util (#329) 2023-03-23 22:01:34 -07:00
Benjamin Pracht
c3e5be2aff Update ingress protocol definition to use the same constants as Egress for audio and video codecs (#319) 
Also Add utils to convert codec enums to mime type, add VP8 constant
 2023-03-10 09:46:19 -08:00
Paul Wells
dac2223d7a nil safe NewTimedVersionFromProto (#312) 2023-03-01 20:10:04 -08:00
Paul Wells
721dbba55d add method to get time.Time from TimedVersion (#311) 
* time.Time from TimedVersion method

* time.Time rundtrip test
 2023-02-28 15:52:27 -08:00
renovate[bot]
073251b64a fix(deps): update go deps (#302) 
* fix(deps): update go deps

Generated by renovateBot

* go-throttle -> core

---------

Co-authored-by: renovate[bot] <29139614+renovate[bot]@users.noreply.github.com>
Co-authored-by: David Colburn <xero73@gmail.com>
 2023-02-27 16:01:08 -08:00
Paul Wells
5fa71af6c3 range check min version (#309) 2023-02-27 15:08:48 -08:00
Paul Wells
43f5fc64e9 return TimedVersion update success/failure (#307) 2023-02-23 19:07:56 -08:00
cnderrauber
e946da680c parallel execute function (#306) 2023-02-22 11:00:27 +08:00
Paul Wells
26f188cb84 move TimedVersion from livekit (#305) 
* move TimedVersion from livekit

* Store/Load

* cleanup

* prevent comparison

* nocmp generator

* comment for unused import

* skip update for equal

* uber atomic

* cleanup

* cleanup

* ensure ts is non-negative

* cleanup

* simplify

* cleanup

* cleanup

* assert -> require
 2023-02-18 11:34:29 -08:00
David Zhao
9a57a8c5b2 Fix support for Redis cluster mode, updated to v9 (#297) 
* Fix support for Redis cluster mode, updated to v9

* update to Go 1.18
 2023-02-12 21:48:01 -08:00
Paul Wells
358df22e41 reduce number of goroutines spawned during testing (#291) 2023-02-01 19:59:12 -08:00
Paul Wells
c71216774a fix lock tracker init for race detector (#290) 
* add room/identity to node rtc messages

* fix lock tracker init for race detector

* generated protobuf

---------

Co-authored-by: github-actions <41898282+github-actions[bot]@users.noreply.github.com>
 2023-02-01 19:46:47 -08:00
Paul Wells
f55bf39335 add norace directive to scanTrackedLocks (#280) 
race detector panics if we access an object that is being gced. it
is safe here because until the finalizer finishes the `trackedLock`
won't be freed and finalizer and scan functions all hold
`weakRefLock`.
 2023-01-27 20:27:00 -08:00