http://en.zaoniao.it/index.php?action=history&feed=atom&title=Satoshi_Client_Sockets_and_Messages 2026-05-15T09:26:30Z Revision history for this page on the wiki MediaWiki 1.32.0 http://en.zaoniao.it/index.php?title=Satoshi_Client_Sockets_and_Messages&diff=6746&oldid=prev 2019-07-10T06:12:29Z

<p>Created page with &quot;The original bitcoin client uses a multithreaded approach to socket handling and messages processing. There is one thread that handles socket communication (ThreadSocketHandle...&quot;</p> <p><b>New page</b></p><div>The original bitcoin client uses a multithreaded approach to socket<br /> handling and messages processing. There is one thread that handles<br /> socket communication (ThreadSocketHandler) and one (ThreadMessageHandler)<br /> which handles pulling messages off sockets and calling the<br /> processing routines. Both of these threads are in [https://github.com/bitcoin/bitcoin/blob/master/src/net.cpp net.cpp].<br /> The message processing routines are in [https://github.com/bitcoin/bitcoin/blob/master/src/main.cpp main.cpp], however.<br /> <br /> ==Socket Thread==<br /> The socket thread reads the sockets and places data into a CDataStream<br /> associated with each node called vRecv. The Satoshi client uses C++<br /> serialization operators &amp;gt;&amp;gt; and &amp;lt;&amp;lt; to read and write to a CDataStream<br /> and then it uses generic routines to move the data between the streams<br /> and sockets.<br /> <br /> ==Message Thread==<br /> The message thread reads and processes all messages from each node in<br /> sequence, and then it sends messages to each node that should be sent<br /> messages. That is all it does.<br /> <br /> Specifically, ThreadMessageHandler2 calls ProcessMessages(), which is<br /> located in [https://github.com/bitcoin/bitcoin/blob/master/src/main.cpp main.cpp], to pull messages off each node's socket and<br /> process them. Then it calls SendMessages(), which is also located<br /> in [https://github.com/bitcoin/bitcoin/blob/master/src/main.cpp main.cpp] to create and send any messages appropriate for each node.<br /> <br /> ProcessMessages() attempts to find a message start signature in the<br /> vRecv stream. If it finds a message start, it deletes everything<br /> prior to the start. Then it reads the header, extracts the message<br /> type, and calls ProcessMessage on the message.<br /> <br /> SendMessages() actually creates and sends messages; it does not<br /> just send preexisting queued messages. It goes through various<br /> maps looking for work to do and produces a message and calls<br /> PushMessage method of CNode to send the message. PushMessage<br /> queues outbound data in the vSend data stream. (See PushMessage() in<br /> [https://github.com/bitcoin/bitcoin/blob/master/src/net.cpp net.cpp]). The socket thread handler then pulls data off the<br /> vSend data stream and calls send on the socket to send the data.<br /> <br /> ==Source==<br /> <br /> [http://bitcoin.it/ http://bitcoin.it/]<br /> <br /> [[Category:Technology]]<br /> [[Category:Manuals]]<br /> ==See Also on BitcoinWiki==<br /> * [[ServAdvisor]]<br /> * [[Litebolt]]<br /> * [[Realista]]<br /> * [[ImmVRse]]<br /> * [[AQUA]]</div>

Admin