5188263429
Refactor first-hop handling types a bit
...
This lets us have the notion of "get the first hop of a path as some
kind of a chantarget", which will make it easier to write other path
types.
2020-11-17 16:46:23 -05:00
cb59ae3933
Move closed-check for circuits into an atomicbool.
2020-11-13 09:08:15 -05:00
4a83f21ae9
Light refactoring on remaining ChannelImpl functions
2020-11-13 08:39:01 -05:00
4b1ed6c39c
Turn the channel "closed" method into an AtomicBool
...
This lets us make the test for closed channels non-async.
2020-11-13 08:34:30 -05:00
11b257e1ae
Move a few immutable fields from ChannelImpl outside the lock.
...
Since these don't change while the channel is alive, we don't need
the lock to protect them.
2020-11-13 08:17:36 -05:00
6e5db3a0e7
Make Arc<>-ness of ClientCirc explicit.
2020-11-12 12:58:33 -05:00
ac174c7666
Make the Arc-ness of channels more explicit.
...
Previously every channel was a secret Arc<>, which I think is bad
style, and which stopped us from using weak references in other
places.
2020-11-12 12:34:50 -05:00
af16ec18a3
update some dependencies
2020-11-11 09:14:26 -05:00
4d24fff9c0
Upgrade dependencies
2020-11-10 12:27:10 -05:00
9c7ed1fdde
upgrade a few packages.
2020-11-05 16:56:29 -05:00
c0f9d94b34
Refactor DataStream to be splittable, and have internal locking.
...
This lets me fix the deadlock in the proxy code.
2020-11-04 12:10:09 -05:00
954108e0ee
stream: Update to enable more fine-grained locking
...
Not sure this is quite right, or quite deadlock free, but it lets
us read/write cells on a stream we haven't locked.
2020-11-04 11:50:23 -05:00
80b70881af
Add a tiny bit of cleanup logic to tor-circmgr
2020-11-02 14:21:14 -05:00
fbbc14d4fb
Tests for tor-chanmgr.
2020-10-30 15:45:53 -04:00
8d8ce482c9
chanmgr: don't return closing channels.
2020-10-30 09:51:52 -04:00
f399851bcf
Implement a channel-manager type to get or launch channels on request.
2020-10-30 09:51:31 -04:00
67e39450fb
Remove duplication of ipaddr argument in handshake.
2020-10-29 17:03:12 -04:00
f8d526a85a
Function to check whether a channel matches a target.
2020-10-29 17:03:12 -04:00
4cf972d69b
tor-proto API: Use new_ref, not clone.
...
Semantically, cloning a Channel or Circuit is actually increasing an
internal reference count. We should name the functions to reflect
that, to be more explicit about what we're doing.
2020-10-29 12:11:36 -04:00
5989b843cc
Add a simple test for stream creation.
2020-10-27 14:40:23 -04:00
705d9c061f
Add a test for extending a circuit with ntor.
2020-10-27 14:26:22 -04:00
911185ec38
circuit: test meta-cell receiving
2020-10-27 13:41:31 -04:00
b90ca2acd7
Downgrade an XXXXM3 message.
2020-10-27 13:11:57 -04:00
f8e1e6976f
Unify interface for detecting stream close.
2020-10-27 13:09:17 -04:00
4cded7a05a
Add a test for sending a cell.
2020-10-27 13:03:39 -04:00
8f5d239c21
Expand test to handle building circuit with ntor.
2020-10-27 12:23:18 -04:00
483425ba4b
Make a test for create_firsthop_fast. WOW that was hard.
2020-10-27 11:55:24 -04:00
dcf0936396
Make circuit reactors also have a run_once() method for testing.
2020-10-27 11:54:11 -04:00
5bd85e57ec
Add a fake, reactorless channel, for use in testing circuits
2020-10-27 10:16:05 -04:00
e2f7fe3827
Remove use of Cell<> in tor_proto.
...
I was confused about what this was for, I guess.
2020-10-27 10:14:28 -04:00
94042b60b8
Rename CircIDRange to CircIdRange
2020-10-27 09:51:28 -04:00
ee9ad7f59d
Run "cargo upgrade".
2020-10-26 14:56:06 -04:00
b93e4b76c8
Remove a bunch of dbg! calls.
2020-10-26 14:33:14 -04:00
a796f7bf6a
Use event_listener to find out about sendme replenishment.
...
Previously we would fail if a sendme window was exhausted and two
tasks were waiting for it to be replenished at the same time.
2020-10-26 14:25:46 -04:00
4348faff3c
Resolve a bunch of XXXM3 comments in tor-proto.
2020-10-26 14:03:25 -04:00
4d9c08669e
Improve documentation in tor-proto
2020-10-26 13:08:46 -04:00
db94abadcc
rudimentary test for channelbuilder.
2020-10-26 09:29:59 -04:00
1b86818085
Tests for sending bad/good cell types on a channel
2020-10-26 09:23:42 -04:00
498bc3633d
Clean up some XXXXs in channel::reactor.rs
2020-10-26 09:23:10 -04:00
6d6cff5176
Tests for receving incoming DESTROY cell.
2020-10-26 09:06:52 -04:00
937d924b0a
channel::reactor: Tests for handling incoming RELAY cells
2020-10-26 09:06:52 -04:00
46c991a087
Test for rejecting CREATED cells
2020-10-26 09:06:52 -04:00
494c4679b5
Add a CircEnt::DestroySent circuit state.
...
A circuit enters DestroySent after it's sent a DESTROY cell. We use
this state to make sure that we don't receive too many cells on a
destroyed circuit, _and_ so that we don't block such cells
completely.
2020-10-26 09:06:52 -04:00
32b025de1d
Use better return type in advance_from_opening
2020-10-25 23:37:25 -04:00
8c09981427
Use from_bytes name for Ed25519Identity
2020-10-25 20:32:47 -04:00
fa01a50f32
Rename CircID and StreamID to end with Id instead, for consistency
2020-10-25 20:29:01 -04:00
fbf200ae6f
Add some tests for channel reactor and related code.
2020-10-25 15:09:06 -04:00
0e91d97f76
Add a test for running and shutting down reactors.
...
This took a long time since I needed to learn about futures and
executors, but I think it'll work out okay.
2020-10-25 14:12:51 -04:00
e20bfaab0f
channel: Refactor the point when we split the framed codec.
...
We used to do this during creating the channel in Channel::new, but
now we do it one step before, so that it's easier to construct
channels for testing.
2020-10-25 12:42:53 -04:00
510a27f2d3
channel: Move looping part of run_impl() into run().
...
This lets us turn run-impl() into a run_once() function for easier
testing.
2020-10-25 12:06:36 -04:00
Nick Mathewson