From a760ce05b948e89bc564af20599dcf95698ac0eb Mon Sep 17 00:00:00 2001
From: obscuren <geffobscura@gmail.com>
Date: Mon, 11 Aug 2014 16:23:38 +0200
Subject: Updated chain for filtering

---
 ethwire/messaging.go | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

(limited to 'ethwire')

diff --git a/ethwire/messaging.go b/ethwire/messaging.go
index f13b72353..d114a1c9d 100644
--- a/ethwire/messaging.go
+++ b/ethwire/messaging.go
@@ -6,9 +6,10 @@ import (
 	"bytes"
 	"errors"
 	"fmt"
-	"github.com/ethereum/eth-go/ethutil"
 	"net"
 	"time"
+
+	"github.com/ethereum/eth-go/ethutil"
 )
 
 // Connection interface describing the methods required to implement the wire protocol.
@@ -109,7 +110,7 @@ func (self *Connection) Write(typ MsgType, v ...interface{}) error {
 
 	slice := [][]interface{}{[]interface{}{byte(typ)}}
 	for _, value := range v {
-		if encodable, ok := value.(ethutil.RlpEncodable); ok {
+		if encodable, ok := value.(ethutil.RlpEncodeDecode); ok {
 			slice = append(slice, encodable.RlpValue())
 		} else if raw, ok := value.([]interface{}); ok {
 			slice = append(slice, raw)
-- 
cgit v1.2.3


From eaa2e8900d1036e09b002c4e20fc6e4f9cd031bb Mon Sep 17 00:00:00 2001
From: obscuren <geffobscura@gmail.com>
Date: Thu, 21 Aug 2014 14:47:58 +0200
Subject: PoC 6 networking code.

* Added block pool for gathering blocks from the network (chunks)
* Re wrote syncing
---
 ethwire/messaging.go | 52 ++++++++++++++++++++++++++++++----------------------
 1 file changed, 30 insertions(+), 22 deletions(-)

(limited to 'ethwire')

diff --git a/ethwire/messaging.go b/ethwire/messaging.go
index d114a1c9d..7ac0188a1 100644
--- a/ethwire/messaging.go
+++ b/ethwire/messaging.go
@@ -27,33 +27,41 @@ const (
 	// Values are given explicitly instead of by iota because these values are
 	// defined by the wire protocol spec; it is easier for humans to ensure
 	// correctness when values are explicit.
-	MsgHandshakeTy  = 0x00
-	MsgDiscTy       = 0x01
-	MsgPingTy       = 0x02
-	MsgPongTy       = 0x03
-	MsgGetPeersTy   = 0x10
-	MsgPeersTy      = 0x11
-	MsgTxTy         = 0x12
-	MsgBlockTy      = 0x13
-	MsgGetChainTy   = 0x14
-	MsgNotInChainTy = 0x15
-	MsgGetTxsTy     = 0x16
+	MsgHandshakeTy      = 0x00
+	MsgDiscTy           = 0x01
+	MsgPingTy           = 0x02
+	MsgPongTy           = 0x03
+	MsgGetPeersTy       = 0x10
+	MsgPeersTy          = 0x11
+	MsgTxTy             = 0x12
+	MsgGetChainTy       = 0x14
+	MsgNotInChainTy     = 0x15
+	MsgGetTxsTy         = 0x16
+	MsgGetBlockHashesTy = 0x17
+	MsgBlockHashesTy    = 0x18
+	MsgGetBlocksTy      = 0x19
+	MsgBlockTy          = 0x13
+
+	MsgOldBlockTy = 0xbb
 
 	MsgTalkTy = 0xff
 )
 
 var msgTypeToString = map[MsgType]string{
-	MsgHandshakeTy:  "Handshake",
-	MsgDiscTy:       "Disconnect",
-	MsgPingTy:       "Ping",
-	MsgPongTy:       "Pong",
-	MsgGetPeersTy:   "Get peers",
-	MsgPeersTy:      "Peers",
-	MsgTxTy:         "Transactions",
-	MsgBlockTy:      "Blocks",
-	MsgGetChainTy:   "Get chain",
-	MsgGetTxsTy:     "Get Txs",
-	MsgNotInChainTy: "Not in chain",
+	MsgHandshakeTy:      "Handshake",
+	MsgDiscTy:           "Disconnect",
+	MsgPingTy:           "Ping",
+	MsgPongTy:           "Pong",
+	MsgGetPeersTy:       "Get peers",
+	MsgPeersTy:          "Peers",
+	MsgTxTy:             "Transactions",
+	MsgBlockTy:          "Blocks",
+	MsgGetChainTy:       "Get chain",
+	MsgGetTxsTy:         "Get Txs",
+	MsgNotInChainTy:     "Not in chain",
+	MsgGetBlockHashesTy: "Get block hashes",
+	MsgBlockHashesTy:    "Block hashes",
+	MsgGetBlocksTy:      "Get blocks",
 }
 
 func (mt MsgType) String() string {
-- 
cgit v1.2.3