| Commit message (Collapse) | Author | Age | Files | Lines |
|\
| |
| |
| | |
irmd: Specify timeout per command
|
| |
| |
| |
| |
| |
| |
| |
| |
| | |
The DHT lookup would stop if a node returned no new useful information
(i.e. the value for the key or unknown nodes closer to the key)
without waiting for other pending requests that could still return
useful information. Now it correctly tracks the number of outstanding
requests or returns if it doesn't get a response for KAD_T_RESP
seconds. This fixes multi-hop flow allocation over the normal.
|
| |
| |
| |
| |
| |
| | |
Upon flow_allocation, the IRMd queries IPCPs for the destination
name. After this commit, when an IPCP allocates a flow, the IRMd won't
query that IPCP.
|
| |
| |
| |
| |
| |
| |
| |
| |
| |
| | |
When a process was killed, ipcp_flow_dealloc was called under a lock,
causing a deadlock in the IRMd because handling the IPCP response also
needs to take the same lock (the IPCP calls flow_dealloc to finalize
this). This deadlock also resulted in the IPCP always reporting that
it failed to send a reply message as the deadlock effectively blocks
the IRMd until its socket timeout expired and thus the IPCP was always
responding to an already closed socket.
|
| |
| |
| |
| |
| |
| |
| | |
The commands towards the IPCPs have different time requirements, but
the irmd had only a single timeout value to wait for a response. This
commit allows setting different timeouts for the IRMd based on the
command, configurable globally.
|
| |\
| |/
|/| |
|
|\ \ |
|
| |\ \
| | | |
| | | |
| | | | |
irmd: Release lock before ipcp_query
|
| | | | |
|
| |/ /
| | |
| | |
| | |
| | |
| | | |
The blocking ipcp_query call was called under reg_lock, causing
flow_allocs over the shim-eth-llc to block the irmd for prolonged
timespans.
|
|\| | |
|
| |\ \
| | | |
| | | |
| | | | |
ipcpd: Fix pthread_cond_timedwait deadlines
|
|\ \ \ \
| | | | |
| | | | |
| | | | | |
build: Add check for robust mutexes
|
|/ / / /
| | | |
| | | |
| | | |
| | | |
| | | | |
This adds a check for robust mutexes. The constant HAVE_ROBUST_MUTEX
is set accordingly in config.h. It also adds some other fixes to make
the prototype compile on the Hurd.
|
| |_|/|
|/| |/ |
|
| |/
| |
| |
| |
| |
| | |
This fixes pthread_condtimedwaits in the flow allocator of all IPCPs
that had bad deadlines set (the interval instead of the actual
absolute time).
|
|\ \
| | |
| | |
| | |
| | |
| | | |
lib: Simplify opening flows
Approved-by: dimitri staessens <[email protected]>
|
|/ /
| |
| |
| |
| | |
This refactors dev.c to have a common function called init_flow that
is called whenever a flow is allocated in dev.c
|
|\ \
| | |
| | |
| | | |
Be fixes
|
| | | |
|
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | | |
The scheduler in the normal IPCP is now multithreaded. While useful in
itself for scalability, it currently solves thread starvation in case
of executing post_sdu operations that may require a response. This
could be further revised in the future to split the SDU handling
threads from the component tasks.
|
| | | |
|
| | | |
|
|/ /
| |
| |
| |
| |
| |
| | |
Fixes a memory leak when the DHT is destroyed during a send_msg. Fixes
a deadlock when destroying the DHT with a pending lookup. Removes some
debug logs that clutter output due to expected redundant FIND_VALUE
responses.
|
|\ \
| | |
| | |
| | | |
lib: Add threadpool manager
|
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | | |
This adds a threadpool manager component in the library that is used
in the IRMd and IPCPs. The threadpool manager now doesn't detach
threads but does a join when they exit. This solves a data race in the
previous implementation where some threads were not completely finished
upon release of some resources.
|
|\| |
| | |
| | |
| | | |
ipcpd: Retry sending DHT response messages
|
|/ /
| |
| |
| |
| |
| |
| | |
This will make the remote retry sending responses when the DT
component can't send the message. This is most useful at enrollment,
when the remote's routing table may need to wait a bit on the routing
component for a path to the new member,
|
|\| |
|
| |\
| | |
| | |
| | | |
lib: Fix destruction of CDAP instances
|
| | |
| | |
| | |
| | |
| | |
| | |
| | | |
The received message list was not correctly freed upon destruction of
the CDAP object. There was also still a rare case in which thread
cancellation would keep a lock, blocking the IPCP shutdown, which is
also fixed.
|
|\| | |
|
| |\|
| | |
| | |
| | | |
lib: Fix processing state in CDAP
|
| |/
| |
| |
| |
| |
| | |
The processing state was not correctly reset at all points in the
loop, causing CDAP to block the IPCP on shutdown in some cases. This
also adds a missing unlock and reorders some other unlocks.
|
|\ \
| | |
| | |
| | | |
ipcpd: Fix DHT lookup processing
|
|/ /
| |
| |
| |
| | |
Not all returned contacts were processed when a FIND_NODE or
FIND_VALUE message was returned.
|
|\ \
| | |
| | |
| | | |
irmd: Fix order of IPCPs
|
|/ /
| |
| |
| |
| | |
This fixes the order of the IPCPs in the IRMd, so that the right type
is queried first on flow allocation.
|
|\ \
| |/
|/|
| | |
ipcpd: Add DHT as directory in normal IPCP
|
| |
| |
| |
| |
| |
| |
| |
| |
| | |
This implements a Distributed Hash Table (DHT) based on the Kademlia
protocol, with default parameters set as used in the BitTorrent
Mainline DHT. This initial implementation is almost feature complete,
except for some things to be done after a testing period: caching and
stale peer bumping, and setting the expiration timeout via the IRM
tool.
|
|\ \
| |/
|/|
| | |
Be fixes
|
| |
| |
| |
| |
| |
| |
| | |
The enrollment calls dealloc immediately after cdap_del_flow(), but
the CDAP instance may still have that fd in its fqueue loop.
cdap_del_flow will now wait for an fqueue loop to end before
returning, to make sure the flow is not needed anymore.
|
|/ |
|
|\
| |
| |
| |
| |
| | |
ipcpd, lib, irmd: Hardcode shim hash algorithms
Approved-by: dimitri staessens <[email protected]>
|
|/
|
|
|
|
|
| |
This will hardcode the shim hash algorithms as they don't have an
enrollment phase.
Fixes #44
|
|\
| |
| |
| | |
irmd: Shutdown sanitizer without cancellation
|
| | |
|
|\|
| |
| |
| | |
Be fixes
|
| | |
|
| | |
|