Skip to content
项目
群组
代码片段
帮助
当前项目
正在载入...
登录 / 注册
切换导航面板
G
go-ipfs
概览
概览
详情
活动
周期分析
版本库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
统计图
问题
0
议题
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
CI / CD
CI / CD
流水线
作业
日程表
图表
维基
Wiki
代码片段
代码片段
成员
成员
折叠边栏
关闭边栏
活动
图像
聊天
创建新问题
作业
提交
问题看板
Open sidebar
jihao
go-ipfs
Commits
4924b80e
提交
4924b80e
authored
5月 10, 2019
作者:
Steven Allen
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
chore: fix linter nits
License: MIT Signed-off-by:
Steven Allen
<
steven@stebalien.com
>
上级
96e6dd29
隐藏空白字符变更
内嵌
并排
正在显示
8 个修改的文件
包含
13 行增加
和
12 行删除
+13
-12
ulimit_test.go
cmd/ipfs/util/ulimit_test.go
+1
-1
builder.go
core/builder.go
+4
-1
block.go
core/commands/block.go
+3
-0
commands.go
core/corehttp/commands.go
+2
-4
add_test.go
core/coreunix/add_test.go
+1
-1
builder.go
core/node/builder.go
+0
-3
storage.go
core/node/storage.go
+1
-1
fsrefstore.go
filestore/fsrefstore.go
+1
-1
没有找到文件。
cmd/ipfs/util/ulimit_test.go
浏览文件 @
4924b80e
...
@@ -42,7 +42,7 @@ func TestManageInvalidNFds(t *testing.T) {
...
@@ -42,7 +42,7 @@ func TestManageInvalidNFds(t *testing.T) {
if
changed
,
new
,
err
:=
ManageFdLimit
();
err
==
nil
{
if
changed
,
new
,
err
:=
ManageFdLimit
();
err
==
nil
{
t
.
Errorf
(
"ManageFdLimit should return an error: changed %t, new: %d"
,
changed
,
new
)
t
.
Errorf
(
"ManageFdLimit should return an error: changed %t, new: %d"
,
changed
,
new
)
}
else
if
err
!=
nil
{
}
else
{
flag
:=
strings
.
Contains
(
err
.
Error
(),
flag
:=
strings
.
Contains
(
err
.
Error
(),
"failed to raise ulimit to IPFS_FD_MAX"
)
"failed to raise ulimit to IPFS_FD_MAX"
)
if
!
flag
{
if
!
flag
{
...
...
core/builder.go
浏览文件 @
4924b80e
...
@@ -31,7 +31,10 @@ func NewNode(ctx context.Context, cfg *BuildCfg) (*IpfsNode, error) {
...
@@ -31,7 +31,10 @@ func NewNode(ctx context.Context, cfg *BuildCfg) (*IpfsNode, error) {
// Note that some services use contexts to signal shutting down, which is
// Note that some services use contexts to signal shutting down, which is
// very suboptimal. This needs to be here until that's addressed somehow
// very suboptimal. This needs to be here until that's addressed somehow
<-
ctx
.
Done
()
<-
ctx
.
Done
()
app
.
Stop
(
context
.
Background
())
err
:=
app
.
Stop
(
context
.
Background
())
if
err
!=
nil
{
log
.
Error
(
"failure on stop: "
,
err
)
}
}()
}()
n
.
IsOnline
=
cfg
.
Online
n
.
IsOnline
=
cfg
.
Online
...
...
core/commands/block.go
浏览文件 @
4924b80e
...
@@ -224,6 +224,9 @@ It takes a list of base58 encoded multihashes to remove.
...
@@ -224,6 +224,9 @@ It takes a list of base58 encoded multihashes to remove.
// TODO: use batching coreapi when done
// TODO: use batching coreapi when done
for
_
,
b
:=
range
req
.
Arguments
{
for
_
,
b
:=
range
req
.
Arguments
{
rp
,
err
:=
api
.
ResolvePath
(
req
.
Context
,
path
.
New
(
b
))
rp
,
err
:=
api
.
ResolvePath
(
req
.
Context
,
path
.
New
(
b
))
if
err
!=
nil
{
return
err
}
err
=
api
.
Block
()
.
Rm
(
req
.
Context
,
rp
,
options
.
Block
.
Force
(
force
))
err
=
api
.
Block
()
.
Rm
(
req
.
Context
,
rp
,
options
.
Block
.
Force
(
force
))
if
err
!=
nil
{
if
err
!=
nil
{
...
...
core/corehttp/commands.go
浏览文件 @
4924b80e
...
@@ -61,10 +61,8 @@ func addHeadersFromConfig(c *cmdsHttp.ServerConfig, nc *config.Config) {
...
@@ -61,10 +61,8 @@ func addHeadersFromConfig(c *cmdsHttp.ServerConfig, nc *config.Config) {
if
acam
:=
nc
.
API
.
HTTPHeaders
[
cmdsHttp
.
ACAMethods
];
acam
!=
nil
{
if
acam
:=
nc
.
API
.
HTTPHeaders
[
cmdsHttp
.
ACAMethods
];
acam
!=
nil
{
c
.
SetAllowedMethods
(
acam
...
)
c
.
SetAllowedMethods
(
acam
...
)
}
}
if
acac
:=
nc
.
API
.
HTTPHeaders
[
cmdsHttp
.
ACACredentials
];
acac
!=
nil
{
for
_
,
v
:=
range
nc
.
API
.
HTTPHeaders
[
cmdsHttp
.
ACACredentials
]
{
for
_
,
v
:=
range
acac
{
c
.
SetAllowCredentials
(
strings
.
ToLower
(
v
)
==
"true"
)
c
.
SetAllowCredentials
(
strings
.
ToLower
(
v
)
==
"true"
)
}
}
}
c
.
Headers
=
make
(
map
[
string
][]
string
,
len
(
nc
.
API
.
HTTPHeaders
)
+
1
)
c
.
Headers
=
make
(
map
[
string
][]
string
,
len
(
nc
.
API
.
HTTPHeaders
)
+
1
)
...
...
core/coreunix/add_test.go
浏览文件 @
4924b80e
...
@@ -68,7 +68,7 @@ func TestAddMultipleGCLive(t *testing.T) {
...
@@ -68,7 +68,7 @@ func TestAddMultipleGCLive(t *testing.T) {
go
func
()
{
go
func
()
{
defer
close
(
out
)
defer
close
(
out
)
adder
.
AddAllAndPin
(
slf
)
_
,
_
=
adder
.
AddAllAndPin
(
slf
)
// Ignore errors for clarity - the real bug would be gc'ing files while adding them, not this resultant error
// Ignore errors for clarity - the real bug would be gc'ing files while adding them, not this resultant error
}()
}()
...
...
core/node/builder.go
浏览文件 @
4924b80e
...
@@ -15,13 +15,10 @@ import (
...
@@ -15,13 +15,10 @@ import (
ds
"github.com/ipfs/go-datastore"
ds
"github.com/ipfs/go-datastore"
dsync
"github.com/ipfs/go-datastore/sync"
dsync
"github.com/ipfs/go-datastore/sync"
cfg
"github.com/ipfs/go-ipfs-config"
cfg
"github.com/ipfs/go-ipfs-config"
logging
"github.com/ipfs/go-log"
ci
"github.com/libp2p/go-libp2p-crypto"
ci
"github.com/libp2p/go-libp2p-crypto"
peer
"github.com/libp2p/go-libp2p-peer"
peer
"github.com/libp2p/go-libp2p-peer"
)
)
var
log
=
logging
.
Logger
(
"node"
)
type
BuildCfg
struct
{
type
BuildCfg
struct
{
// If online is set, the node will have networking enabled
// If online is set, the node will have networking enabled
Online
bool
Online
bool
...
...
core/node/storage.go
浏览文件 @
4924b80e
...
@@ -91,7 +91,7 @@ func GcBlockstoreCtor(bb BaseBlocks) (gclocker blockstore.GCLocker, gcbs blockst
...
@@ -91,7 +91,7 @@ func GcBlockstoreCtor(bb BaseBlocks) (gclocker blockstore.GCLocker, gcbs blockst
// GcBlockstoreCtor wraps GcBlockstore and adds Filestore support
// GcBlockstoreCtor wraps GcBlockstore and adds Filestore support
func
FilestoreBlockstoreCtor
(
repo
repo
.
Repo
,
bb
BaseBlocks
)
(
gclocker
blockstore
.
GCLocker
,
gcbs
blockstore
.
GCBlockstore
,
bs
blockstore
.
Blockstore
,
fstore
*
filestore
.
Filestore
)
{
func
FilestoreBlockstoreCtor
(
repo
repo
.
Repo
,
bb
BaseBlocks
)
(
gclocker
blockstore
.
GCLocker
,
gcbs
blockstore
.
GCBlockstore
,
bs
blockstore
.
Blockstore
,
fstore
*
filestore
.
Filestore
)
{
gclocker
,
gcbs
,
bs
=
GcBlockstoreCtor
(
bb
)
gclocker
=
blockstore
.
NewGCLocker
(
)
// hash security
// hash security
fstore
=
filestore
.
NewFilestore
(
bb
,
repo
.
FileManager
())
fstore
=
filestore
.
NewFilestore
(
bb
,
repo
.
FileManager
())
...
...
filestore/fsrefstore.go
浏览文件 @
4924b80e
...
@@ -281,7 +281,7 @@ func (f *FileManager) putTo(b *posinfo.FilestoreNode, to putter) error {
...
@@ -281,7 +281,7 @@ func (f *FileManager) putTo(b *posinfo.FilestoreNode, to putter) error {
if
!
f
.
AllowFiles
{
if
!
f
.
AllowFiles
{
return
ErrFilestoreNotEnabled
return
ErrFilestoreNotEnabled
}
}
if
!
filepath
.
HasPrefix
(
b
.
PosInfo
.
FullPath
,
f
.
root
)
{
if
!
filepath
.
HasPrefix
(
b
.
PosInfo
.
FullPath
,
f
.
root
)
{
//nolint:staticcheck
return
fmt
.
Errorf
(
"cannot add filestore references outside ipfs root (%s)"
,
f
.
root
)
return
fmt
.
Errorf
(
"cannot add filestore references outside ipfs root (%s)"
,
f
.
root
)
}
}
...
...
编写
预览
Markdown
格式
0%
重试
或
添加新文件
添加附件
取消
您添加了
0
人
到此讨论。请谨慎行事。
请先完成此评论的编辑!
取消
请
注册
或者
登录
后发表评论