Hi Dan, Thank you for sharing this, I was just looking to know a little bit more on this akka.io package and your project might just be the example I needed. I started to read your code but I don't know very well akka. Looking at https://github.com/oxlade39/STorrent/blob/master/src/main/scala/io/github/oxlade39/storrent/peer/PeerConnection.scala and https://github.com/oxlade39/STorrent/blob/master/src/main/scala/io/github/oxlade39/storrent/peer/Handshaker.scala could someone please explain why you can be sure that you won't lose/miss any Tcp.Received message, when the PeerConnection actor is in handshaking state, and the handshaking has just finished. From what I understood, actor messages are put in a queue, so when the Handshaker receives the last Tcp.Received of the handshake, he might have a few more in his queue, right?. How do you make sure you don't lose them? Is there any automatic mechanism that will requeue those messages in the parent (or forwarder) queue when the actor is stopped?
Thanks, -- Quentin Le jeudi 6 février 2014 22:35:05 UTC+1, Dan Oxlade a écrit : > > Hello all, > > After playing with Akka for some time and then learning about it properly > on the Coursera principles of reactive programming course, I decided to try > and write a BitTorrent client. The new reactive IO features seemed like a > perfect abstraction for managing the multiple concurrent connections. > > I got to the point this week where my first download succeeded start to > finish. Over 900mb of Ubuntu 13.10 in around 45 minutes connecting to 50 > concurrent peers downloading up to 30 concurrent pieces at any time. It > will be a lot quicker once I've implemented an 'end game' strategy. > > There is still so much to do for it to be releasable but I'd welcome any > comments/code review/help. > > https://github.com/oxlade39/STorrent > > I has pretty good test coverage so it should be a fairly safe codebase to > clone and play around with. > > Cheers > Dan > -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: http://akka.io/faq/ >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/groups/opt_out.
