commit
f0ff7e7dda
@ -1,2 +1,2 @@
|
|||||||
/ip4/147.75.80.29/tcp/1347/p2p/12D3KooWQYHfhaqRCEAcZKFEVZnK7kgPh1FHwYNwLgCZkoxmmARu
|
/ip4/147.75.80.29/tcp/1347/p2p/12D3KooWDzb12XyoKT4uJAqmRVsSYqY9EZczXeWJ7WqehugBTVAT
|
||||||
/ip4/147.75.80.17/tcp/1347/p2p/12D3KooWQg7XTDcU7ySChvLSMZ3L4cywXPsAcv1uyMNw8n5hv9KS
|
/ip4/147.75.80.17/tcp/1347/p2p/12D3KooWDsfpmaYPouFT2RxvSf8eCuUS63T4dAKvDPqzWKdv7Qc7
|
||||||
|
Binary file not shown.
@ -6,6 +6,7 @@ var SectorSizes = []uint64{
|
|||||||
16 << 20,
|
16 << 20,
|
||||||
256 << 20,
|
256 << 20,
|
||||||
1 << 30,
|
1 << 30,
|
||||||
|
32 << 30,
|
||||||
}
|
}
|
||||||
|
|
||||||
// Seconds
|
// Seconds
|
||||||
|
@ -1,7 +1,7 @@
|
|||||||
package build
|
package build
|
||||||
|
|
||||||
// Version is the local build version, set by build system
|
// Version is the local build version, set by build system
|
||||||
const Version = "0.10.0"
|
const Version = "0.11.0"
|
||||||
|
|
||||||
// APIVersion is a hex semver version of the rpc api exposed
|
// APIVersion is a hex semver version of the rpc api exposed
|
||||||
//
|
//
|
||||||
@ -12,7 +12,7 @@ const Version = "0.10.0"
|
|||||||
// R R H
|
// R R H
|
||||||
// |\vv/|
|
// |\vv/|
|
||||||
// vv vv
|
// vv vv
|
||||||
const APIVersion = 0x000a01
|
const APIVersion = 0x000b01
|
||||||
|
|
||||||
const (
|
const (
|
||||||
MajorMask = 0xff0000
|
MajorMask = 0xff0000
|
||||||
|
@ -418,10 +418,15 @@ func (sb *SectorBuilder) SealPreCommit(sectorID uint64, ticket SealTicket, piece
|
|||||||
|
|
||||||
sb.checkRateLimit()
|
sb.checkRateLimit()
|
||||||
|
|
||||||
|
rl := sb.rateLimit
|
||||||
|
if !sb.sealLocal {
|
||||||
|
rl = make(chan struct{})
|
||||||
|
}
|
||||||
|
|
||||||
select { // use whichever is available
|
select { // use whichever is available
|
||||||
case sb.sealTasks <- call:
|
case sb.sealTasks <- call:
|
||||||
return sb.sealPreCommitRemote(call)
|
return sb.sealPreCommitRemote(call)
|
||||||
case sb.rateLimit <- struct{}{}:
|
case rl <- struct{}{}:
|
||||||
}
|
}
|
||||||
|
|
||||||
// local
|
// local
|
||||||
@ -533,10 +538,15 @@ func (sb *SectorBuilder) SealCommit(sectorID uint64, ticket SealTicket, seed Sea
|
|||||||
default:
|
default:
|
||||||
sb.checkRateLimit()
|
sb.checkRateLimit()
|
||||||
|
|
||||||
|
rl := sb.rateLimit
|
||||||
|
if !sb.sealLocal {
|
||||||
|
rl = make(chan struct{})
|
||||||
|
}
|
||||||
|
|
||||||
select { // use whichever is available
|
select { // use whichever is available
|
||||||
case sb.sealTasks <- call:
|
case sb.sealTasks <- call:
|
||||||
proof, err = sb.sealCommitRemote(call)
|
proof, err = sb.sealCommitRemote(call)
|
||||||
case sb.rateLimit <- struct{}{}:
|
case rl <- struct{}{}:
|
||||||
proof, err = sb.sealCommitLocal(sectorID, ticket, seed, pieces, rspco)
|
proof, err = sb.sealCommitLocal(sectorID, ticket, seed, pieces, rspco)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user