@@ -338,7 +338,7 @@ class RiskLearningSimulation : public Simulation {
338338 LocationProto proto;
339339 while (reader.ReadRecord (proto)) {
340340 {
341- absl::MutexLock l (& location_mu);
341+ absl::MutexLock l (location_mu);
342342 result->location_types_ [proto.reference ().uuid ()] =
343343 proto.reference ().type ();
344344 }
@@ -350,7 +350,7 @@ class RiskLearningSimulation : public Simulation {
350350 } else if (proto.reference ().type () == LocationReference::RANDOM) {
351351 transmissibility = random_transmissibility;
352352 } else {
353- absl::MutexLock l (& status_mu);
353+ absl::MutexLock l (status_mu);
354354 statuses.push_back (absl::InvalidArgumentError (absl::StrCat (
355355 " Invalid type " , i, " : " , proto.reference ().DebugString ())));
356356 return ;
@@ -369,7 +369,7 @@ class RiskLearningSimulation : public Simulation {
369369 : non_work_drop_prob;
370370 {
371371 const int64 uuid = proto.reference ().uuid ();
372- absl::MutexLock l (& location_mu);
372+ absl::MutexLock l (location_mu);
373373 locations.push_back (NewGraphLocation (
374374 uuid, transmissibility, drop_prob, std::move (edges),
375375 *result->exposure_generators_ [result->get_location_type_ (
@@ -379,27 +379,27 @@ class RiskLearningSimulation : public Simulation {
379379 }
380380 case LocationProto::kRandom : {
381381 const int64 uuid = proto.reference ().uuid ();
382- absl::MutexLock l (& location_mu);
382+ absl::MutexLock l (location_mu);
383383 locations.push_back (NewRandomGraphLocation (
384384 uuid, transmissibility, random_interaction_multiplier,
385385 *result->exposure_generators_ [result->get_location_type_ (
386386 uuid)]));
387387 } break ;
388388 default : {
389- absl::MutexLock l (& status_mu);
389+ absl::MutexLock l (status_mu);
390390 statuses.push_back (absl::InvalidArgumentError (absl::StrCat (
391391 " Invalid location " , i, " : " , proto.DebugString ())));
392392 }
393393 return ;
394394 }
395395 {
396- absl::MutexLock l (& location_mu);
396+ absl::MutexLock l (location_mu);
397397 i++;
398398 }
399399 }
400400 absl::Status status = reader.status ();
401401 if (!status.ok ()) {
402- absl::MutexLock l (& status_mu);
402+ absl::MutexLock l (status_mu);
403403 statuses.push_back (status);
404404 return ;
405405 }
@@ -504,7 +504,7 @@ class RiskLearningSimulation : public Simulation {
504504 while (reader.ReadRecord (proto)) {
505505 auto profile_iter = profile_data.find (proto.population_profile_id ());
506506 if (profile_iter == profile_data.end ()) {
507- absl::MutexLock l (& status_mu);
507+ absl::MutexLock l (status_mu);
508508 statuses.push_back (absl::InvalidArgumentError (
509509 absl::StrCat (" Invalid population profile id for agent: " ,
510510 proto.DebugString ())));
@@ -517,7 +517,7 @@ class RiskLearningSimulation : public Simulation {
517517 config.tracing_policy (), result->risk_score_policy_ ,
518518 result->risk_score_model_ .get (), result->get_location_type_ );
519519 if (!risk_score_or.ok ()) {
520- absl::MutexLock l (& status_mu);
520+ absl::MutexLock l (status_mu);
521521 statuses.push_back (risk_score_or.status ());
522522 return ;
523523 }
@@ -535,7 +535,7 @@ class RiskLearningSimulation : public Simulation {
535535 transmission_model = result->transmission_model_ .get ();
536536 }
537537 {
538- absl::MutexLock l (& agent_mu);
538+ absl::MutexLock l (agent_mu);
539539 if (max_population > 0 && agents.size () == max_population) {
540540 break ;
541541 }
@@ -555,7 +555,7 @@ class RiskLearningSimulation : public Simulation {
555555 }
556556 absl::Status status = reader.status ();
557557 if (!status.ok ()) {
558- absl::MutexLock l (& status_mu);
558+ absl::MutexLock l (status_mu);
559559 statuses.push_back (status);
560560 }
561561 reader.Close ();
0 commit comments