299d4a2e05
Teach Router.add_handler() to kill a handler on context disconnect
...
When a context's Stream is disconnected, now any reply_to handlers
waiting for that specific context will be cancelled, rather than hanging
until all pending handelrs are cancelled during Broker is torn down.
This is groundwork for a bunch of things, including moving connect() to
the Broker thread
7 years ago
ffe86a882d
remove redundant conncetion registration
...
It's not needed any more sense Router always routes unknown IDs towards
the parent.
7 years ago
a11003862b
Add warning to docs.
7 years ago
acb6520ea2
Fix feature list link
7 years ago
8e2d691d2d
Move issue lists into GitHub.
7 years ago
e0ecfab5fc
More bold, everyone loves drama
7 years ago
d702a61589
More doc updates.
7 years ago
9ca39dcf72
Add Message Routing section to docs
7 years ago
65d5844d1a
Tidy up docs.
7 years ago
616dc43069
fakessh: Initial working version
7 years ago
fe43180911
Fix crash
7 years ago
379f652641
Update for changed API
7 years ago
7467fc2b0b
Allow CALL_FUNCTION from non-master context.
...
Just ensure CALL_FUNCTION return value is sent back to src_id/reply_to
rather than 0/reply_to.
7 years ago
73c82415aa
Log the FD for I/O to avoid expose swaparoos
...
Wasted some time tracking down swapped stdin/stdout.
7 years ago
6bd8fda1d4
Route unknown context ID messages upstream
...
This propagates messages up the tree until they encounter a node that
knows how to forward them back downstream. As a consequence for invalid
context IDs, a 'no route' message will always be logged by the master.
7 years ago
93abc0aa92
fakessh: Split Channel into Sender and Receiver.
7 years ago
faf50585a4
Add econtext.parent_id constant too
7 years ago
15d3508331
Add examples section to docs.
7 years ago
06d65ac6ac
howitworks additions
7 years ago
fd5e962cb3
Handlers no longer depend on src_id
...
Now there is a single handle namespace in each context, indpendent of
the source of the message. Update module forwarder etc. to cope with
that.
This is to support slave contexts communicating without the master's
intercession.
7 years ago
ad182bc128
Default log level should be INFO
7 years ago
9ed7934994
Shorten slave context logger name.
7 years ago
c37a11fb99
Add Router.local() mostly for testing.
7 years ago
b1d0c569f6
Add TODO
7 years ago
88eea78282
Kindof working graceful shutdown again.
7 years ago
9d356736ca
Reduce os.read/os.write cutpaste.
7 years ago
1f49d24cd6
fakessh: Make ExternalContext.main() more flexible
...
- Allow specifying non-default in/out FDs
- Allow not passing econtext.core source code FD
- Allow starting directly without a first stage
- Allow disabling stdio redirection
7 years ago
69737701f6
Remove debug junk.
7 years ago
174b3242fc
Support building Channels from existing handle, make .get() interruptible.
7 years ago
30d838edf9
Add econtext.master.Context.call_async().
7 years ago
6c33d251df
Reduce src_id/dst_id to 16 bits.
7 years ago
6a164adb22
Preserve sys.executable after first stage.
7 years ago
628a08e339
Update preamble_size.py for recent API changes.
7 years ago
7a50fa724e
Defer stream naming until after connect, so PID can be included.
7 years ago
e2dbd3a44e
Update docstring.
7 years ago
b70803a763
Update numbers.
7 years ago
39e70fe50c
Typo.
7 years ago
37934f8b5a
Document GET_MODULE in a slave context.
7 years ago
4b2170dc81
Wire up ModuleForwarder; closes #3
7 years ago
e8b1ebc434
issue #3 : Teach core.py the difference between its parent context and the master context.
...
Needed to allow GET_MODULE calls to reach the parent rather than the
master, when they are not the same context.
7 years ago
c7b619a50a
It's safe for Waker.on_receive() to drain all bytes.
...
By the the time Waker.wake() writes to the pipe, any shared state that
would trigger action on the Broker thread has already been updated, so
reading subsequent bytes caused by later Waker.wake() can't miss
anything.
This avoids spewing tons of logs messages every time there is a storm of
user-generated log messages.
7 years ago
821c9dfcb6
Generalize ECONNRESET, EIO handling.
7 years ago
0aff1d82c6
Reads more neatly.
7 years ago
17c2fe68f2
Add Router.enable_debug() rather than cutpasting snippets constantly.
7 years ago
a76d871a70
issue #3 : Initial ModuleForwarder implementation.
...
Not wired up yet.
7 years ago
fcd3f42f9e
Quieten noisy logging
7 years ago
a87194a9b8
Uniformly call Context.on_disconnect(), not just for parent.
7 years ago
64f628d590
fix crash during on_shutdown
7 years ago
92a4a61f11
Generate context IDs like handles.
7 years ago
f9df857a57
Tidy up API.
7 years ago
David Wilson