Skip to content
GitLab
Projects
Groups
Snippets
Help
Loading...
Help
What's new
10
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
Open sidebar
dms3
go-dms3
Commits
1eb0bfe8
Commit
1eb0bfe8
authored
Jan 26, 2015
by
Juan Batiz-Benet
Browse files
Options
Browse Files
Download
Plain Diff
Merge pull request #668 from jbenet/hack
misc user-friendliness fixes
parents
36d03306
2b0c89a5
Changes
10
Hide whitespace changes
Inline
Side-by-side
Showing
10 changed files
with
22 additions
and
22 deletions
+22
-22
cmd/ipfs/daemon.go
cmd/ipfs/daemon.go
+1
-0
cmd/ipfs/init.go
cmd/ipfs/init.go
+0
-1
core/bootstrap.go
core/bootstrap.go
+2
-2
core/commands/diag.go
core/commands/diag.go
+7
-7
core/core.go
core/core.go
+1
-1
p2p/net/swarm/swarm_dial.go
p2p/net/swarm/swarm_dial.go
+2
-2
p2p/protocol/identify/id.go
p2p/protocol/identify/id.go
+3
-3
test/sharness/t0020-init.sh
test/sharness/t0020-init.sh
+1
-1
test/sharness/t0060-daemon.sh
test/sharness/t0060-daemon.sh
+1
-1
test/sharness/t0080-repo.sh
test/sharness/t0080-repo.sh
+4
-4
No files found.
cmd/ipfs/daemon.go
View file @
1eb0bfe8
...
@@ -49,6 +49,7 @@ the daemon.
...
@@ -49,6 +49,7 @@ the daemon.
func
daemonFunc
(
req
cmds
.
Request
,
res
cmds
.
Response
)
{
func
daemonFunc
(
req
cmds
.
Request
,
res
cmds
.
Response
)
{
fmt
.
Println
(
"Initializing daemon..."
)
// first, whether user has provided the initialization flag. we may be
// first, whether user has provided the initialization flag. we may be
// running in an uninitialized state.
// running in an uninitialized state.
initialize
,
_
,
err
:=
req
.
Option
(
initOptionKwd
)
.
Bool
()
initialize
,
_
,
err
:=
req
.
Option
(
initOptionKwd
)
.
Bool
()
...
...
cmd/ipfs/init.go
View file @
1eb0bfe8
...
@@ -80,7 +80,6 @@ var welcomeMsg = `Hello and Welcome to IPFS!
...
@@ -80,7 +80,6 @@ var welcomeMsg = `Hello and Welcome to IPFS!
If you're seeing this, you have successfully installed
If you're seeing this, you have successfully installed
IPFS and are now interfacing with the ipfs merkledag!
IPFS and are now interfacing with the ipfs merkledag!
For a short demo of what you can do, enter 'ipfs tour'
`
`
func
initWithDefaults
(
repoRoot
string
)
error
{
func
initWithDefaults
(
repoRoot
string
)
error
{
...
...
core/bootstrap.go
View file @
1eb0bfe8
...
@@ -92,7 +92,7 @@ func Bootstrap(n *IpfsNode, cfg BootstrapConfig) (io.Closer, error) {
...
@@ -92,7 +92,7 @@ func Bootstrap(n *IpfsNode, cfg BootstrapConfig) (io.Closer, error) {
if
err
:=
bootstrapRound
(
ctx
,
n
.
PeerHost
,
thedht
,
n
.
Peerstore
,
cfg
);
err
!=
nil
{
if
err
:=
bootstrapRound
(
ctx
,
n
.
PeerHost
,
thedht
,
n
.
Peerstore
,
cfg
);
err
!=
nil
{
log
.
Event
(
ctx
,
"bootstrapError"
,
n
.
Identity
,
lgbl
.
Error
(
err
))
log
.
Event
(
ctx
,
"bootstrapError"
,
n
.
Identity
,
lgbl
.
Error
(
err
))
log
.
Error
f
(
"%s bootstrap error: %s"
,
n
.
Identity
,
err
)
log
.
Debug
f
(
"%s bootstrap error: %s"
,
n
.
Identity
,
err
)
}
}
}
}
...
@@ -187,7 +187,7 @@ func bootstrapConnect(ctx context.Context,
...
@@ -187,7 +187,7 @@ func bootstrapConnect(ctx context.Context,
err
:=
route
.
Connect
(
ctx
,
p
.
ID
)
err
:=
route
.
Connect
(
ctx
,
p
.
ID
)
if
err
!=
nil
{
if
err
!=
nil
{
log
.
Event
(
ctx
,
"bootstrapDialFailed"
,
p
.
ID
)
log
.
Event
(
ctx
,
"bootstrapDialFailed"
,
p
.
ID
)
log
.
Error
f
(
"failed to bootstrap with %v: %s"
,
p
.
ID
,
err
)
log
.
Debug
f
(
"failed to bootstrap with %v: %s"
,
p
.
ID
,
err
)
errs
<-
err
errs
<-
err
return
return
}
}
...
...
core/commands/diag.go
View file @
1eb0bfe8
...
@@ -115,14 +115,14 @@ connected peers and latencies between them.
...
@@ -115,14 +115,14 @@ connected peers and latencies between them.
return
return
}
}
res
.
SetOutput
(
io
.
Reader
(
&
buf
))
res
.
SetOutput
(
io
.
Reader
(
&
buf
))
default
:
output
,
err
:=
stdDiagOutputMarshal
(
standardDiagOutput
(
info
))
if
err
!=
nil
{
res
.
SetError
(
err
,
cmds
.
ErrNormal
)
return
}
res
.
SetOutput
(
output
)
}
}
output
,
err
:=
stdDiagOutputMarshal
(
standardDiagOutput
(
info
))
if
err
!=
nil
{
res
.
SetError
(
err
,
cmds
.
ErrNormal
)
return
}
res
.
SetOutput
(
output
)
},
},
}
}
...
...
core/core.go
View file @
1eb0bfe8
...
@@ -308,7 +308,7 @@ func (n *IpfsNode) Bootstrap(cfg BootstrapConfig) error {
...
@@ -308,7 +308,7 @@ func (n *IpfsNode) Bootstrap(cfg BootstrapConfig) error {
bpeers
:=
n
.
Repo
.
Config
()
.
Bootstrap
bpeers
:=
n
.
Repo
.
Config
()
.
Bootstrap
ps
,
err
:=
toPeerInfos
(
bpeers
)
ps
,
err
:=
toPeerInfos
(
bpeers
)
if
err
!=
nil
{
if
err
!=
nil
{
log
.
Error
(
"failed to parse bootstrap peers from config: %s"
,
bpeers
)
log
.
Warningf
(
"failed to parse bootstrap peers from config: %s"
,
bpeers
)
return
nil
return
nil
}
}
return
ps
return
ps
...
...
p2p/net/swarm/swarm_dial.go
View file @
1eb0bfe8
...
@@ -293,7 +293,7 @@ func (s *Swarm) dial(ctx context.Context, p peer.ID) (*Conn, error) {
...
@@ -293,7 +293,7 @@ func (s *Swarm) dial(ctx context.Context, p peer.ID) (*Conn, error) {
// ok try to setup the new connection.
// ok try to setup the new connection.
swarmC
,
err
:=
dialConnSetup
(
ctx
,
s
,
connC
)
swarmC
,
err
:=
dialConnSetup
(
ctx
,
s
,
connC
)
if
err
!=
nil
{
if
err
!=
nil
{
log
.
Error
(
"Dial newConnSetup failed. disconnecting."
)
log
.
Debug
(
"Dial newConnSetup failed. disconnecting."
)
log
.
Event
(
ctx
,
"dialFailureDisconnect"
,
lgbl
.
NetConn
(
connC
),
lgbl
.
Error
(
err
))
log
.
Event
(
ctx
,
"dialFailureDisconnect"
,
lgbl
.
NetConn
(
connC
),
lgbl
.
Error
(
err
))
connC
.
Close
()
// close the connection. didn't work out :(
connC
.
Close
()
// close the connection. didn't work out :(
return
nil
,
err
return
nil
,
err
...
@@ -398,7 +398,7 @@ func dialConnSetup(ctx context.Context, s *Swarm, connC conn.Conn) (*Conn, error
...
@@ -398,7 +398,7 @@ func dialConnSetup(ctx context.Context, s *Swarm, connC conn.Conn) (*Conn, error
// ok try to setup the new connection. (newConnSetup will add to group)
// ok try to setup the new connection. (newConnSetup will add to group)
swarmC
,
err
:=
s
.
newConnSetup
(
ctx
,
psC
)
swarmC
,
err
:=
s
.
newConnSetup
(
ctx
,
psC
)
if
err
!=
nil
{
if
err
!=
nil
{
log
.
Error
(
"Dial newConnSetup failed. disconnecting."
)
log
.
Debug
(
"Dial newConnSetup failed. disconnecting."
)
log
.
Event
(
ctx
,
"dialFailureDisconnect"
,
lgbl
.
NetConn
(
connC
),
lgbl
.
Error
(
err
))
log
.
Event
(
ctx
,
"dialFailureDisconnect"
,
lgbl
.
NetConn
(
connC
),
lgbl
.
Error
(
err
))
psC
.
Close
()
// we need to make sure psC is Closed.
psC
.
Close
()
// we need to make sure psC is Closed.
return
nil
,
err
return
nil
,
err
...
...
p2p/protocol/identify/id.go
View file @
1eb0bfe8
...
@@ -79,7 +79,7 @@ func (ids *IDService) IdentifyConn(c inet.Conn) {
...
@@ -79,7 +79,7 @@ func (ids *IDService) IdentifyConn(c inet.Conn) {
// ok give the response to our handler.
// ok give the response to our handler.
if
err
:=
protocol
.
WriteHeader
(
s
,
ID
);
err
!=
nil
{
if
err
:=
protocol
.
WriteHeader
(
s
,
ID
);
err
!=
nil
{
log
.
Error
(
"error writing stream header for %s"
,
ID
)
log
.
Debugf
(
"error writing stream header for %s"
,
ID
)
log
.
Event
(
context
.
TODO
(),
"IdentifyOpenFailed"
,
c
.
RemotePeer
())
log
.
Event
(
context
.
TODO
(),
"IdentifyOpenFailed"
,
c
.
RemotePeer
())
}
}
ids
.
ResponseHandler
(
s
)
ids
.
ResponseHandler
(
s
)
...
@@ -118,7 +118,7 @@ func (ids *IDService) ResponseHandler(s inet.Stream) {
...
@@ -118,7 +118,7 @@ func (ids *IDService) ResponseHandler(s inet.Stream) {
r
:=
ggio
.
NewDelimitedReader
(
s
,
2048
)
r
:=
ggio
.
NewDelimitedReader
(
s
,
2048
)
mes
:=
pb
.
Identify
{}
mes
:=
pb
.
Identify
{}
if
err
:=
r
.
ReadMsg
(
&
mes
);
err
!=
nil
{
if
err
:=
r
.
ReadMsg
(
&
mes
);
err
!=
nil
{
log
.
Error
f
(
"%s error receiving message from %s %s %s"
,
ID
,
log
.
Debug
f
(
"%s error receiving message from %s %s %s"
,
ID
,
c
.
RemotePeer
(),
c
.
RemoteMultiaddr
(),
err
)
c
.
RemotePeer
(),
c
.
RemoteMultiaddr
(),
err
)
return
return
}
}
...
@@ -169,7 +169,7 @@ func (ids *IDService) consumeMessage(mes *pb.Identify, c inet.Conn) {
...
@@ -169,7 +169,7 @@ func (ids *IDService) consumeMessage(mes *pb.Identify, c inet.Conn) {
for
_
,
addr
:=
range
laddrs
{
for
_
,
addr
:=
range
laddrs
{
maddr
,
err
:=
ma
.
NewMultiaddrBytes
(
addr
)
maddr
,
err
:=
ma
.
NewMultiaddrBytes
(
addr
)
if
err
!=
nil
{
if
err
!=
nil
{
log
.
Error
f
(
"%s failed to parse multiaddr from %s %s"
,
ID
,
log
.
Debug
f
(
"%s failed to parse multiaddr from %s %s"
,
ID
,
p
,
c
.
RemoteMultiaddr
())
p
,
c
.
RemoteMultiaddr
())
continue
continue
}
}
...
...
test/sharness/t0020-init.sh
View file @
1eb0bfe8
...
@@ -34,7 +34,7 @@ test_expect_success "ipfs peer id looks good" '
...
@@ -34,7 +34,7 @@ test_expect_success "ipfs peer id looks good" '
'
'
test_expect_success
"ipfs init output looks good"
'
test_expect_success
"ipfs init output looks good"
'
STARTHASH="Qm
Ypv2VEsxzTTXRYX3PjDg961cnJE3kY1YDXLycHGQ3zZB
" &&
STARTHASH="Qm
TTFXiXoixwT53tcGPu419udsHEHYu6AHrQC8HAKdJYaZ
" &&
echo "initializing ipfs node at $IPFS_PATH" >expected &&
echo "initializing ipfs node at $IPFS_PATH" >expected &&
echo "generating 4096-bit RSA keypair...done" >>expected &&
echo "generating 4096-bit RSA keypair...done" >>expected &&
echo "peer identity: $PEERID" >>expected &&
echo "peer identity: $PEERID" >>expected &&
...
...
test/sharness/t0060-daemon.sh
View file @
1eb0bfe8
...
@@ -34,7 +34,7 @@ test_expect_success "ipfs peer id looks good" '
...
@@ -34,7 +34,7 @@ test_expect_success "ipfs peer id looks good" '
# note this is almost the same as t0020-init.sh "ipfs init output looks good"
# note this is almost the same as t0020-init.sh "ipfs init output looks good"
test_expect_success
"ipfs daemon output looks good"
'
test_expect_success
"ipfs daemon output looks good"
'
STARTHASH="Qm
Ypv2VEsxzTTXRYX3PjDg961cnJE3kY1YDXLycHGQ3zZB
" &&
STARTHASH="Qm
TTFXiXoixwT53tcGPu419udsHEHYu6AHrQC8HAKdJYaZ
" &&
echo "initializing ipfs node at $IPFS_PATH" >expected &&
echo "initializing ipfs node at $IPFS_PATH" >expected &&
echo "generating key pair...done" >>expected &&
echo "generating key pair...done" >>expected &&
echo "peer identity: $PEERID" >>expected &&
echo "peer identity: $PEERID" >>expected &&
...
...
test/sharness/t0080-repo.sh
View file @
1eb0bfe8
...
@@ -43,7 +43,7 @@ test_expect_success "'ipfs pin rm' succeeds" '
...
@@ -43,7 +43,7 @@ test_expect_success "'ipfs pin rm' succeeds" '
test_expect_success
"file no longer pinned"
'
test_expect_success
"file no longer pinned"
'
# we expect the welcome file to show up here
# we expect the welcome file to show up here
echo Qm
Ypv2VEsxzTTXRYX3PjDg961cnJE3kY1YDXLycHGQ3zZB
> expected2
echo Qm
TTFXiXoixwT53tcGPu419udsHEHYu6AHrQC8HAKdJYaZ
> expected2
ipfs pin ls -type=recursive > actual2
ipfs pin ls -type=recursive > actual2
test_cmp expected2 actual2
test_cmp expected2 actual2
'
'
...
@@ -84,8 +84,8 @@ test_expect_success "'ipfs repo gc' removes file" '
...
@@ -84,8 +84,8 @@ test_expect_success "'ipfs repo gc' removes file" '
'
'
test_expect_success
"'ipfs refs local' no longer shows file"
'
test_expect_success
"'ipfs refs local' no longer shows file"
'
echo Qm
UNLLsPACCz1vLxQVkXqqLX5R1X345qqfHbsf67hvA3Nn
> expected8
echo Qm
TTFXiXoixwT53tcGPu419udsHEHYu6AHrQC8HAKdJYaZ
> expected8
echo Qm
Ypv2VEsxzTTXRYX3PjDg961cnJE3kY1YDXLycHGQ3zZB
>> expected8
echo Qm
UNLLsPACCz1vLxQVkXqqLX5R1X345qqfHbsf67hvA3Nn
>> expected8
ipfs refs local > actual8
ipfs refs local > actual8
test_cmp expected8 actual8
test_cmp expected8 actual8
'
'
...
@@ -123,7 +123,7 @@ test_expect_success "'ipfs pin ls -type=direct' is correct" '
...
@@ -123,7 +123,7 @@ test_expect_success "'ipfs pin ls -type=direct' is correct" '
test_expect_success
"'ipfs pin ls -type=recursive' is correct"
'
test_expect_success
"'ipfs pin ls -type=recursive' is correct"
'
echo $MBLOCKHASH > rp_expected
echo $MBLOCKHASH > rp_expected
echo Qm
Ypv2VEsxzTTXRYX3PjDg961cnJE3kY1YDXLycHGQ3zZB
>> rp_expected
echo Qm
TTFXiXoixwT53tcGPu419udsHEHYu6AHrQC8HAKdJYaZ
>> rp_expected
cat rp_expected | sort > rp_exp_sorted
cat rp_expected | sort > rp_exp_sorted
ipfs pin ls -type=recursive | sort > rp_actual
ipfs pin ls -type=recursive | sort > rp_actual
test_cmp rp_exp_sorted rp_actual
test_cmp rp_exp_sorted rp_actual
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
.
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment