124 Commits (tweak-queue-sizes)

Author SHA1 Message Date
  Philipp Oppermann 9bb57ee531
Don't send replies for `SendMessage` requests when using TCP 2 years ago
  Philipp Oppermann 2ccc170649
Send all queued incoming events at once on `NextEvent` request 2 years ago
  Philipp Oppermann 00421e2bcd
Send small messages directly without shared memory 2 years ago
  Philipp Oppermann 019e411eef
Change CLI control request reply type 2 years ago
  Philipp Oppermann 1e07a73a64
Merge branch 'main' into unify-nodes-and-operators 2 years ago
  Philipp Oppermann 1553a198ef
Re-export dora-message from dora-core 2 years ago
  Philipp Oppermann 63dd2ff03d
Fix `_pthread_rwlock_timedrdlock` link error on macOS 2 years ago
  Philipp Oppermann 44d8ee0e6a
Default to safer TCP for daemon control channels for now 2 years ago
  haixuanTao 933dadc68b Expand `env` value when possible 2 years ago
  Philipp Oppermann ff836d200c
Start adding back support for daemon communication over TCP 2 years ago
  Philipp Oppermann 77c4b11c8d
Fix: adjust input mappings that refer to single operator nodes 3 years ago
  dependabot[bot] b74a524031
Bump tokio from 1.23.1 to 1.24.2 3 years ago
  Philipp Oppermann 26def8d26a
Fix parsing of dora timer inputs 3 years ago
  Philipp Oppermann 6aaf4b845c
ShmemServer: Set `disconnect` flag on drop and check it on requests 3 years ago
  Philipp Oppermann cac527a382
Add support for spawning runtime nodes with operators 3 years ago
  Philipp Oppermann 44b1f77035
Remove first-class operator support from input mappings 3 years ago
  Philipp Oppermann 6eb9b46637
Close outputs of operators when they stop 3 years ago
  Philipp Oppermann 492339a687
WIP: Start porting `dora-runtime` to `dora-daemon` 3 years ago
  Philipp Oppermann 6438ef7413
Add special handling for zero-sized messages to avoid one roundtrip 3 years ago
  Philipp Oppermann 8383c99823
Benchmark latency of ShmemServer/ShmemClient 3 years ago
  Philipp Oppermann c1346894b3
Remove logging of elapsed time 3 years ago
  Philipp Oppermann cf95078ca1
Extract shared memory server/client into separate crate 3 years ago
  Philipp Oppermann bf978d9d7d
Always send register message first, also when subscribing 3 years ago
  Philipp Oppermann c6d864b20f
Make shmem server/client typed and report event stream closure 3 years ago
  Philipp Oppermann 5eddf1cae9
Remove uneeded serialization methods 3 years ago
  Philipp Oppermann b7f47c3d99
Log an error instead of panicking when ShmemServer is dropped before client 3 years ago
  Philipp Oppermann 827fb1b241
Fix: Don't use timeout on EventStream client 3 years ago
  Philipp Oppermann 3aa50d2209
Assert that message length is never 0 3 years ago
  Philipp Oppermann 5b12ba8428
Panic when shm server is dropped before client 3 years ago
  Philipp Oppermann 503a9497fd
Use shared memory for event stream too 3 years ago
  dependabot[bot] ae161e644c
Bump tokio from 1.21.2 to 1.23.1 3 years ago
  Philipp Oppermann 670c154e5e
Create a safer server/client API on top of `ShmemChannel` 3 years ago
  Philipp Oppermann 8d1c3742a1
Implement disconnect signal for `ShmemChannel` and set it on drop 3 years ago
  Philipp Oppermann 6ae75c04bd
Remove some log messages 3 years ago
  Philipp Oppermann f04960d680
Fix event + data offsets for Shmem channel client 3 years ago
  Philipp Oppermann 6253d6e5ad
Fix: Initialize events to 'clear' state and length to 0 3 years ago
  Philipp Oppermann 70298d836f
Start migrating the daemon control channel to shared memory 3 years ago
  Philipp Oppermann 218106721d
Add watchdog for checking that coordinator is still reachable 3 years ago
  Philipp Oppermann 2b7d2508f4
Implement watchdog messages for detecting sudden disconnects of daemon 3 years ago
  Philipp Oppermann 35e86684d0
Update `up` and `destroy` commands for dora-daemon and ensure proper coordinator exit 3 years ago
  Philipp Oppermann 7448594622
Update `dora check` to check whether daemon is running 3 years ago
  Philipp Oppermann 778d9d7eb7
Fix: Use correct length for received data 3 years ago
  Philipp Oppermann df5dcfb342
Merge branch 'main' into unify-nodes-and-operators 3 years ago
  Philipp Oppermann 2ed7db1b0e
Make `dora stop` command working with new daemon design 3 years ago
  Philipp Oppermann 377703c325
Report finished dataflows from daemon to coordinator 3 years ago
  Philipp Oppermann 2527ca0e85
Report spawn result from daemon to coordinator 3 years ago
  Philipp Oppermann d3914cca60
Merge pull request #157 from dora-rs/release 3 years ago
  Philipp Oppermann a2cc06ca50
Use drop tokens and reference counting to free shared memory again after usage 3 years ago
  Philipp Oppermann 8225c9f1c5
Make events a borrowed type and report to daemon when they're dropped 3 years ago
  Philipp Oppermann 3cd1b4de65
Notify downstream nodes about closed inputs 3 years ago