| Commit message (Collapse) | Author | Age | Files | Lines |
... | |
|/
|
|
|
| |
This adds a shim over LLC over Ethernet. It uses the raw socket API to
send messages directly over an interface.
|
| |
|
|
|
|
|
| |
When the ring buffer is empty, a read call will sleep. A write call on
an empty ring buffer will wake up sleeping readers.
|
|
|
|
|
|
|
| |
This stops IPC processes from hanging due to bad locks. It first
informs all threads that the IPCP is shutting down, then cancels all
threads. Cancellation is still required because threads may be in
accept() or receivefrom().
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
This introduces an IPC process that relays data between two local AP's
over the shm_du_map. Only configuration it has is a DIF name.
It required small modification elsewhere:
lib: added support for the IPCP_LOCAL type
irm: added support for the IPCP_LOCAL type
dif_config: added the IPCP_LOCAL type
tools: added support for the IPCP_LOCAL type
|
|
|
|
|
| |
The shim UDP did a non-blocking write call, causing loss of
SDU's. This has been changed to a blocking write call.
|
|
|
|
|
|
|
|
| |
In linux, the select call changes the timeout variable to the time not
spent in sleep, causing the timeout to decrease and that loop to grind
the cpu. The timeval is now reset to the correct value every loop.
Also removed a LOG_ERR message that was hampering performance.
|
|
|
|
|
| |
This adds a cleanup handler for the main message loop, which closes
the socket upon pthread_cancel so that the ipcp can exit cleanly.
|
|
|
|
| |
Conf was not checked on bootstrap.
|
|
|
|
|
| |
This removes an install command from the build, since the protobuf
header file was being installed in the source directory.
|
| |
|
| |
|
|
|
|
|
|
| |
The shim UDP now supports deallocating a flow end-to-end. Contains
some stability fixes for flow allocation and some missing close()
calls in lib/sockets.
|
| |
|
|
|
|
|
| |
There could be a theoretical race condition that the server sends a
message before the FD is set on the client side, which is resolved.
|
|
|
|
|
|
|
|
|
|
|
| |
There were two race conditions. The first was where client received
the response message before the client UDP port was connected to the
server UDP port and the first message of the client was sent to the
LISTEN port instead of the server application port. This was solved by
reordering the operations so the response is sent after the port is
correctly connected. The second race condition is that the FD is not
added to the set in time at the server side before the first SDU
arrives. This was solved by adding a variable proteceted by a mutex.
|
|
|
|
|
| |
some debug code for locking and a sleep check are removed from the
shim-udp.
|
|
|
|
|
|
|
|
|
| |
It uses UDP port 0x0D1F on all hosts to send and receive flow
allocation messages. It supports communication between server and
client AP over a single shim IPCP.
Implementation of full flow deallocation is pending. Both the client
and the server still have to call flow_dealloc();
|
|
|
|
|
|
| |
Adds a missing modulo calculation that would result in index -1 being
returned instead of zero when the ringbuffer skipped back to the
beginning.
|
| |
|
|
|
|
|
|
|
|
|
|
| |
Simplified locking to take only two locks: the first lock guards the
state of the ipcp. This lock must be held for writing on bootstrap and
closing, and held for reading during all other operations. The second
lock guards operations on flows, and must be held for writing during
allocation and deallocation, and held for reading when sending sdu's.
After adding a fd to FD_SET, the shim will wait for 1 ms to ensure
that the FD is added to the select call.
|
|
|
|
|
| |
This takes a lock before notifying the IRMd of a new flow request, to
avoid race conditions when trying to retrieve the fd by port-id.
|
| |
|
|
|
|
|
| |
The fd_to_port_id function has no internal locking and must now be
called under lock.
|
|\
| |
| |
| | |
lib, ipcpd, irmd: Add QoS cube definition
|
| |
| |
| |
| |
| |
| | |
This fixes wrong header inclusion that would make programs which are
not developed within ouroboros fail upon compilation, since they would
not find certain headers on their system.
|
| |
| |
| |
| |
| |
| |
| |
| |
| |
| | |
This adds the QoS cube definition, which is an enum to select which
QoS is needed in the IPCP. An application has to use the qos_spec in
qos.h to define what it needs. The IRMd will map this unto a qos cube
definition.
Some headers are now also no longer installed on the system, since
they are only to be used within the irmd and ipcps.
|
| | |
|
|/
|
|
|
|
|
| |
Added necessary locks for the shim-udp. This PR also improves thread
management, the main thread now starts a mainloop thread, which spawns
sdu handler threads when it the IPCP is enrolled. If the IPCP exits
the enrolled state, the sdu loop is cancelled.
|
|
|
|
|
| |
The shim_udp now correctly destroys its ringbuffer on exit. Now
handles sdu's in a single thread using select() with a 10 us timeout.
|
|
|
|
|
| |
A value that was unitialized was being treated as an error in the
release build with gcc.
|
|
|
|
|
| |
This adds nslookup support to the shim UDP, so that a custom DNS
server can be queried.
|
|
|
|
|
|
| |
This allows someone to disable the use of DNS in the shim UDP. It also
adds a config file specific for the shim UDP (which holds the nsupdate
location). Certain defines were also moved to the global config file.
|
|
|
|
| |
caused the shim to run out of file descriptors fast...
|
|
|
|
|
| |
returning -1 as uint32_t leads to bugs.
also changed types in GPB to sint to use zigzag encoding.
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
This commit has a first implementation of flow allocation (the "slow
path") and read/write (the "fast path") for ouroboros. It provides
basic but unstable communications over the shared memory.
It required a lot of changes all over the stack, and fixes a number of
previously undetected issues.
This PR still need heavy revision regarding data model, locking and
cleanup.
lib/dev: modifications to the API. It now uses an ap_init() call to
set the AP name and sets the Instance ID to the pid of the process. It
also binds the AP to the shared memory and creates tables for mappings
in the fast path. A call to ap_fini() releases the resources.
lib/shm_ap_rbuff: added ring buffer for data exchange between
processes in the fast path. It passes an index in the shm_du_map.
lib/shm_du_map: rewrote API to work with calls from dev.c. Garbage
collector added. Tests updated to new API.
ipcpd/ipcp-data: removed everything related to flows, as these are
universal for all ap's and kept in ap_data (dev.c), or similar structs
for shim ipcps.
shim-udp: added flow allocator and read/write functions and shm
elements.
irmd: revised data model and structures necessary for flow allocation.
tools: echo updated to new dev.h API.
messaging system was updated to comply with new flow allocation
messages. All exchanges use pid and port_id to bootstrap the fast
path.
|
|
|
|
|
| |
This adds support for adding the application name to a BIND DNS server
through the nsupdate utility.
|
|
|
|
|
| |
flow allocation now propagates on the client side up to the IPCP.
added UNKNOWN_AP and UNKNOWN_AE definitions to dev.h
|
|
|
|
|
| |
This abstracts away the IRMd messages by calling the functions from
ipcp.h in the ouroboros library. It also fixes some formatting issues.
|
|
|
|
|
| |
This fixes the shim-udp-test, which was using a non null-terminated
string, which caused it to fail on some systems.
|
|
|
|
|
|
| |
This commits adds the gethostbyname call to resolve the dst_name for a
flow allocation using DNS. The DNS server should be specified using
the method mandated by the system (e.g. added to /etc/resolv.conf).
|
|
|
|
|
|
|
|
| |
All instance-id's in ouroboros will be set by the system to the pid of
the process associated with this application process instance. This
means that the user has no way to choose the instance id's. Function
calls that assumed manually defined instance id's have been replaced
throughout the system.
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
| |
Unregistering ap's now works. An AP now registers/unregisters its AP-I
by sending its AP name and its pid to the IRMd. The IPCPs register
whatevercast names. An AP name is currently mapped on a whatevercast
name represented by the same string literal. The IRMd allows
registration of only one AP-I per AP. A Name Space Management system
is needed in the processing system so we can resolve this completely.
Changing the stack to register whatevercast names required some changes
all over the ipcpd implemented and in the library.
|
| |
|
|
|
|
|
|
| |
Initial code for application registration. Specifying "*" will (for
now) register with the first IPCP available in the system. Modified
the echo server not to barf messages on failed accept()
|
|
|
|
|
|
| |
The shim UDP will listen to incoming SDU's for a flow. If the flow is
FLOW_PENDING, it will set it to FLOW_ALLOCATED on the reception of the
first SDU, and connect() to set the destination server_host:sp.
|
|
|
|
| |
fixes comments on 38c4169 (memleaks)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
This implements the API for flow allocation. The shims currently does
the following.
The shim IPCP binds to an interface (IP address) and listens for flow
allocation requests on UDP port 0x0D1F (3359), referenced as the
listen port (lp). It will treat any datagram received on lp as a flow
allocation request.
Upon receiving an allocation request IRM_MSG_CODE__IPCP_FLOW_ALLOC
from the IRMd, the shim IPCP will bind a UDP socket to a port (cp)
allocated by the host OS. From that port it will send a UDP packet
containing the destination ap_name to server_host:lp and wait for a
response.
Upon reception of a packet on server_host:lp, the shim_IPCP creates a
UDP socket for the flow with a port set by the host os (sp), binds to
it and echoes the received datagram back from server_host:sp to
client_host:cp. It will also notify the IRMd of an incoming flow
allocation request IRM_MSG_CODE__IPCP_FLOW_REQ_ARR, with as
src_ap_name ("John Day"). It will get the port_id as a return value
of that message and create a flow with status FLOW_PENDING with that
port_id. If the server responds negatively to the flow allocation
request (i.e. the shim IPCP on the server side receives a
IRM_MSG_CODE__IPCP_FLOW_ALLOC_RESPONSE with a response != 0, it will
delete the pending flow. If response == 0, it will set the status to
FLOW_ALLOCATED.
On the client machine the IPCP will learn sp upon reception of the
echoed datagram. It will then create a flow with the port_id it
received with the message from the IRMd and set it to ALLOCATED.
Pending implementation:
DNS support, this PR only supports local flows on the loopback adapter
127.0.0.1.
A thread to listen for the echoed message, to avoid the
entire IPCP to block when the echoed message is lost.
This PR compiles but is untested pending necessary implementations
elsewhere in the stack.
|