|
|
@ -278,7 +278,7 @@ void ParameterClient2::prepareSendData(
|
|
|
|
|
|
|
|
|
|
|
|
if (sendingPara) {
|
|
|
|
if (sendingPara) {
|
|
|
|
sendJob->parallelInputIovs[serverId].push_back(
|
|
|
|
sendJob->parallelInputIovs[serverId].push_back(
|
|
|
|
{sendMat->getLocalRow(row), sizeof(real) * blockSize});
|
|
|
|
{sendMat->getLocalRow(row), sizeof(real) * (size_t) blockSize});
|
|
|
|
/// detect sparse parameter distribution
|
|
|
|
/// detect sparse parameter distribution
|
|
|
|
sparseDistribution_->probeDistribution(serverId,
|
|
|
|
sparseDistribution_->probeDistribution(serverId,
|
|
|
|
sizeof(real) * blockSize);
|
|
|
|
sizeof(real) * blockSize);
|
|
|
@ -302,8 +302,8 @@ void ParameterClient2::prepareSendData(
|
|
|
|
block->set_begin_pos(beginDim);
|
|
|
|
block->set_begin_pos(beginDim);
|
|
|
|
block->set_block_size(endDim - beginDim);
|
|
|
|
block->set_block_size(endDim - beginDim);
|
|
|
|
if (buf) {
|
|
|
|
if (buf) {
|
|
|
|
sendJob->parallelInputIovs[serverId].push_back(
|
|
|
|
sendJob->parallelInputIovs[serverId].push_back({buf + beginDim,
|
|
|
|
{buf + beginDim, sizeof(real) * (endDim - beginDim)});
|
|
|
|
sizeof(real) * ((size_t) (endDim - beginDim))});
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|