277
278
279
280
281
282
283
284
285
286
287
288
289
290
|
mpidata.next_client = (mpidata.next_client % n) + 1;
r
}) as usize;
mpidata.client_txs[rank - 1]
.send((WorkerMsg::Evaluate { i, y }, Some(Box::new(tx))))
.unwrap();
Ok(())
}
fn update<U, S>(&mut self, state: U, tx: S) -> Result<(), Self::Err>
where
U: UpdateState<<Self::Minorant as Minorant>::Primal>,
|
>
>
>
>
>
|
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
|
mpidata.next_client = (mpidata.next_client % n) + 1;
r
}) as usize;
mpidata.client_txs[rank - 1]
.send((WorkerMsg::Evaluate { i, y }, Some(Box::new(tx))))
.unwrap();
// memory output, only if subproblem 0 is used (so we get memory info regularly but not too often)
if i == 0 {
super::show_mem_info(0);
}
Ok(())
}
fn update<U, S>(&mut self, state: U, tx: S) -> Result<(), Self::Err>
where
U: UpdateState<<Self::Minorant as Minorant>::Primal>,
|