63 Commits

Author	SHA1	Message	Date
Marcel Märtens	661060808d	switch from serde to manually for speed, remove async_serde ... - removing async_serde as it seems to be not usefull the idea was because deserialising is slow parallising it could speed up. Whoever we need to keep the order of frames, (at least for controlframes) so serialising in threads would be quite complicated. Also serialisation is quite fast, about 1 Gbit/s such speed is enough for messaging, it's more important to serve parallel streams better. Thats why i am removing async serde coding for now - frames are no longer serialized by serde, by byte by byte manually, increadible speed upgrade - more metrics - switch channel_creator into for_each_concurrent - removing some pool.spwan_ok() as they dont allow me to use self - reduce features needed	2020-06-09 01:23:42 +02:00
Marcel Märtens	2ee18b1fd8	Examples, HUGE fixes, test, make it alot smother ... - switch `listen` to async in oder to verify if the bind was successful - Introduce the following examples - network speed - chat - fileshare - add additional tests - fix dropping stream before last messages can be handled bug, when dropping a stream, BParticipant will wait for prio to be empty before dropping the stream and sending the signal - correct closing of stream and participant - move tcp to protocols and create udp front and backend - tracing and fixing a bug that is caused by not waiting for configuration after receiving a frame - fix a bug in network-speed, but there is still a bug if trace=warn after 2.000.000 messages the server doesnt get that client has shut down and seems to lock somewhere. hard to reproduce open tasks [ ] verify UDP works correctly, especcially the connect! [ ] implements UDP shutdown correctly, the one created in connect! [ ] unify logging [ ] fill metrics [ ] fix dropping stream before last messages can be handled bug [ ] add documentation [ ] add benchmarks [ ] remove async_serde??? [ ] add mpsc	2020-06-09 01:23:37 +02:00
Marcel Märtens	595f1502b3	COMPLETE REWRITE ... - use async_std and implement a async serialisaition - new participant, stream and drop on the participant - sending and receiving on streams	2020-06-09 01:23:30 +02:00
Marcel Märtens	499a895922	shutdown and udp/mpsc ... - theorectically closing of streams and shutdown - mpsc and udp preparations - cleanup and build better tests	2020-06-09 01:23:26 +02:00
Marcel Märtens	9354952a7f	Code/Dependency Cleanup	2020-06-09 01:23:19 +02:00
Marcel Märtens	641df53f4a	Got some async test to work	2020-06-09 01:23:15 +02:00
Marcel Märtens	a6f1e3f176	Add a speedtest program to benchmark networking	2020-06-09 01:23:01 +02:00
Marcel Märtens	88f6b36a4e	Differ Metrics to make it easier to implement your own metric coding! ... Implement my own metric coding in networking	2020-06-09 01:22:48 +02:00
Marcel Märtens	f3251c0879	Converting the API interface to Async and experimenting with a Channel implementation for TCP, UDP, MPSC, which will later be reverted ... It should compile and tests run fine now. If not, the 2nd last squashed commit message said it currently only send frames but not incomming messages, also recv would only handle frames. The last one said i added internal messages and a reverse path (prob for .recv)	2020-06-09 01:22:45 +02:00
Marcel Märtens	5c5b33bd2a	Bring networking tests to green ... - Seperate worker into own directory - implement correct handshakes - implement correct receiving	2020-06-09 01:22:42 +02:00
Marcel Märtens	3d8ddcb4b3	Continue backend for networking and fill gaps, including: ... - introduce tlid to allow - introduce channel trait - remove old experimental handshake - seperate mio_worker into multiple fn - implement stream in backend	2020-06-09 01:22:38 +02:00
Marcel Märtens	52078f2251	first implementation of connect and tcp using a mio worker protocol and: ... - introduce a loadtest, for tcp messages - cleanup api - added a unittest - prepared a handshake message, which will in next commits get removed again - experimental mio worker merges - using uuid for participant id	2020-06-09 01:22:35 +02:00
Marcel Märtens	a01afd0c86	initial implementation of a network api	2020-06-09 01:22:32 +02:00