Reconfigure chunk manager
This commit is contained in:
@@ -46,11 +46,11 @@ func main() {
|
|||||||
|
|
||||||
chunkMgr, err := chunk.NewManager(
|
chunkMgr, err := chunk.NewManager(
|
||||||
"",
|
"",
|
||||||
10485760,
|
524288, // 1MB
|
||||||
4,
|
4, // 4 threads
|
||||||
4,
|
4, // 4 threads
|
||||||
4,
|
4, // 4 threads
|
||||||
32,
|
4, // 4 chunks (4MB)
|
||||||
config)
|
config)
|
||||||
if nil != err {
|
if nil != err {
|
||||||
log.Panicf("Failed to initialize chunk manager: %v", err)
|
log.Panicf("Failed to initialize chunk manager: %v", err)
|
||||||
|
|||||||
@@ -55,8 +55,8 @@ func NewManager(
|
|||||||
chunkFile string,
|
chunkFile string,
|
||||||
chunkSize int64,
|
chunkSize int64,
|
||||||
loadAhead,
|
loadAhead,
|
||||||
checkThreads int,
|
checkThreads,
|
||||||
loadThreads int,
|
loadThreads,
|
||||||
maxChunks int,
|
maxChunks int,
|
||||||
c config.ConfigInterface) (*Manager, error) {
|
c config.ConfigInterface) (*Manager, error) {
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user