Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
whqwjb
go-ethereum
提交
884f7928
G
go-ethereum
项目概览
whqwjb
/
go-ethereum
与 Fork 源项目一致
从无法访问的项目Fork
通知
1
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
G
go-ethereum
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
体验新版 GitCode,发现更多精彩内容 >>
提交
884f7928
编写于
1月 27, 2014
作者:
O
obscuren
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
Removed default connection
上级
7931c662
变更
2
显示空白变更内容
内联
并排
Showing
2 changed file
with
34 addition
and
6 deletion
+34
-6
ethereum.go
ethereum.go
+7
-5
peer.go
peer.go
+27
-1
未找到文件。
ethereum.go
浏览文件 @
884f7928
...
...
@@ -152,12 +152,14 @@ func (s *Ethereum) Start() {
if
ethutil
.
Config
.
Debug
{
log
.
Println
(
"Connection listening disabled. Acting as client"
)
/*
err = s.ConnectToPeer("localhost:12345")
if err != nil {
log.Println("Error starting ethereum", err)
s.Stop()
}
*/
}
else
{
log
.
Fatal
(
err
)
}
...
...
peer.go
浏览文件 @
884f7928
...
...
@@ -68,9 +68,12 @@ func NewOutboundPeer(addr string, ethereum *Ethereum) *Peer {
// Set up the connection in another goroutine so we don't block the main thread
go
func
()
{
conn
,
err
:=
net
.
Dial
(
"tcp"
,
addr
)
conn
,
err
:=
net
.
DialTimeout
(
"tcp"
,
addr
,
30
*
time
.
Second
)
if
err
!=
nil
{
log
.
Println
(
"Connection to peer failed"
,
err
)
p
.
Stop
()
return
}
p
.
conn
=
conn
...
...
@@ -211,7 +214,30 @@ out:
p
.
requestedPeerList
=
false
}
case
ethwire
.
MsgGetChainTy
:
blocksFound
:=
0
l
:=
msg
.
Data
.
Length
()
// Check each SHA block hash from the message and determine whether
// the SHA is in the database
for
i
:=
0
;
i
<
l
;
i
++
{
if
p
.
ethereum
.
BlockManager
.
BlockChain
()
.
HasBlock
(
msg
.
Data
.
Get
(
i
)
.
AsString
())
{
blocksFound
++
// TODO send reply
}
}
// If no blocks are found we send back a reply with msg not in chain
// and the last hash from get chain
if
blocksFound
==
0
{
lastHash
:=
msg
.
Data
.
Get
(
l
-
1
)
p
.
QueueMessage
(
ethwire
.
NewMessage
(
ethwire
.
MsgNotInChainTy
,
lastHash
))
}
case
ethwire
.
MsgNotInChainTy
:
log
.
Println
(
"Not in chain, not yet implemented"
)
// TODO
// Unofficial but fun nonetheless
case
ethwire
.
MsgTalkTy
:
log
.
Printf
(
"%v says: %s
\n
"
,
p
.
conn
.
RemoteAddr
(),
msg
.
Data
.
Get
(
0
)
.
AsString
())
}
}
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录