remove sets of users
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/7f7c9368 Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/7f7c9368 Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/7f7c9368 Branch: refs/heads/two-dot-o Commit: 7f7c93687e6f705eae9288b444711f9140a2955d Parents: 00d8347 Author: Shawn Feldman <[email protected]> Authored: Thu Nov 6 08:37:42 2014 -0700 Committer: Shawn Feldman <[email protected]> Committed: Thu Nov 6 08:37:42 2014 -0700 ---------------------------------------------------------------------- .../src/main/scala/org/apache/usergrid/helpers/Setup.scala | 6 ++++-- .../scala/org/apache/usergrid/simulations/AppSimulation.scala | 2 ++ 2 files changed, 6 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/7f7c9368/stack/loadtests/src/main/scala/org/apache/usergrid/helpers/Setup.scala ---------------------------------------------------------------------- diff --git a/stack/loadtests/src/main/scala/org/apache/usergrid/helpers/Setup.scala b/stack/loadtests/src/main/scala/org/apache/usergrid/helpers/Setup.scala index bb1ae51..3782726 100644 --- a/stack/loadtests/src/main/scala/org/apache/usergrid/helpers/Setup.scala +++ b/stack/loadtests/src/main/scala/org/apache/usergrid/helpers/Setup.scala @@ -105,7 +105,10 @@ object Setup { } def setupUsers() = { - val userFeeder = FeederGenerator.generateUserWithGeolocationFeeder(Settings.numUsers * Settings.duration, Settings.userLocationRadius, Settings.centerLatitude, Settings.centerLongitude) + val userFeeder = FeederGenerator.generateUserWithGeolocationFeeder(Settings.numUsers , Settings.userLocationRadius, Settings.centerLatitude, Settings.centerLongitude) + val numUsers = userFeeder.length + println(s"Sending requests for $numUsers users") + val list:ArrayBuffer[ListenableFuture[Response]] = new ArrayBuffer[ListenableFuture[Response]] userFeeder.foreach(user => { list += setupUser(user); @@ -138,7 +141,6 @@ object Setup { "displayName":"$displayName","age":"$age","seen":"$seen","weight":"$weight", "height":"$height","aboutMe":"$aboutMe","profileId":"$profileId","headline":"$headline", "showAge":"$showAge","relationshipStatus":"$relationshipStatus","ethnicity":"$ethnicity","password":"$password"}""" - val authToken = getManagementToken() val createUser = client .preparePost(Settings.baseAppUrl + "/users") http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/7f7c9368/stack/loadtests/src/main/scala/org/apache/usergrid/simulations/AppSimulation.scala ---------------------------------------------------------------------- diff --git a/stack/loadtests/src/main/scala/org/apache/usergrid/simulations/AppSimulation.scala b/stack/loadtests/src/main/scala/org/apache/usergrid/simulations/AppSimulation.scala index 6567c91..aa246a4 100644 --- a/stack/loadtests/src/main/scala/org/apache/usergrid/simulations/AppSimulation.scala +++ b/stack/loadtests/src/main/scala/org/apache/usergrid/simulations/AppSimulation.scala @@ -32,10 +32,12 @@ import scala.concurrent.duration._ */ class AppSimulation extends Simulation{ before{ + println("Begin setup") Setup.setupOrg() Setup.setupApplication() Setup.setupNotifier() Setup.setupUsers() + println("End Setup") } setUp( NotificationScenarios.createScenario
