Commit 699037a8 authored by Bradley C. Kuszmaul's avatar Bradley C. Kuszmaul Committed by Yoni Fogel

Set the queue to depth=2 for the extractor_thread. Refs #2571. [t:2571]

git-svn-id: file:///svn/toku/tokudb@20032 c7de825b-a66e-492c-adef-691d508d4ae1
parent eda78576
...@@ -330,7 +330,7 @@ int toku_brt_loader_open (/* out */ BRTLOADER *blp, ...@@ -330,7 +330,7 @@ int toku_brt_loader_open (/* out */ BRTLOADER *blp,
brt_loader_init_poll_callback(&bl->poll_callback); brt_loader_init_poll_callback(&bl->poll_callback);
{ int r = init_rowset(&bl->primary_rowset); if (r!=0) return r; } { int r = init_rowset(&bl->primary_rowset); if (r!=0) return r; }
{ int r = queue_create(&bl->primary_rowset_queue, 1); if (r!=0) return r; } { int r = queue_create(&bl->primary_rowset_queue, 2); if (r!=0) return r; }
//printf("%s:%d toku_pthread_create\n", __FILE__, __LINE__); //printf("%s:%d toku_pthread_create\n", __FILE__, __LINE__);
{ int r = toku_pthread_create(&bl->extractor_thread, NULL, extractor_thread, (void*)bl); if (r!=0) return r; } { int r = toku_pthread_create(&bl->extractor_thread, NULL, extractor_thread, (void*)bl); if (r!=0) return r; }
bl->extractor_live = TRUE; bl->extractor_live = TRUE;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment