jprdonnelly/impala
1
0
Fork 0
mirror of https://github.com/apache/impala.git synced 2026-01-08 12:02:54 -05:00
Code Issues Projects Releases Wiki Activity

Add io mgr warning for machines without sse4_2.

Browse Source
This commit is contained in:
Nong Li
2013-04-18 15:29:32 -07:00
committed by Henry Robinson
parent 329edcef64
commit dcbd408fa8
1 changed files with 11 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
be/src/runtime/disk-io-mgr.cc
View File

@@ -506,6 +506,15 @@ void DiskIoMgr::BufferDescriptor::Return() {
io_mgr_->ReturnBuffer(this);
}
static void CheckSseSupport() {
if (!CpuInfo::IsSupported(CpuInfo::SSE4_2)) {
LOG(WARNING) << "This machine does not support sse4_2. The default IO system "
"configurations are suboptimal for this hardware. Consider "
"increasing the number of threads per disk by restarting impalad "
"using the --num_threads_per_disk flag with a higher value";
}
}
DiskIoMgr::DiskIoMgr() :
num_threads_per_disk_(FLAGS_num_threads_per_disk),
max_read_size_(FLAGS_read_size),
@@ -517,6 +526,7 @@ DiskIoMgr::DiskIoMgr() :
int num_disks = FLAGS_num_disks;
if (num_disks == 0) num_disks = DiskInfo::num_disks();
disk_queues_.resize(num_disks);
CheckSseSupport();
}
DiskIoMgr::DiskIoMgr(int num_disks, int threads_per_disk, int max_read_size) :
@@ -529,6 +539,7 @@ DiskIoMgr::DiskIoMgr(int num_disks, int threads_per_disk, int max_read_size) :
num_buffers_in_readers_(0) {
if (num_disks == 0) num_disks = DiskInfo::num_disks();
disk_queues_.resize(num_disks);
CheckSseSupport();
}
DiskIoMgr::~DiskIoMgr() {