Revision 1d28971f src/main/scala/gr/grnet/aquarium/util/RandomEventGenerator.scala
| b/src/main/scala/gr/grnet/aquarium/util/RandomEventGenerator.scala | ||
|---|---|---|
| 51 | 51 |
*/ |
| 52 | 52 |
trait RandomEventGenerator extends AkkaAMQP {
|
| 53 | 53 |
|
| 54 |
val userIds = 1 to 100 |
|
| 54 |
val userIds = 1 to 1000
|
|
| 55 | 55 |
val clientIds = 1 to 4 |
| 56 | 56 |
val vmIds = 1 to 4000 |
| 57 | 57 |
val resources = Policy.policy.resources.map{r => r.name}
|
| ... | ... | |
| 94 | 94 |
/** |
| 95 | 95 |
* Generete and publish create events for test users |
| 96 | 96 |
*/ |
| 97 |
def initUsers = {
|
|
| 97 |
def initUsers(num: Int) = {
|
|
| 98 | 98 |
val publisher = producer(MessagingNames.IM_EXCHANGE) |
| 99 | 99 |
|
| 100 |
userIds.foreach {
|
|
| 100 |
userIds.filter(_ < num).foreach {
|
|
| 101 | 101 |
i => |
| 102 | 102 |
val sha1 = CryptoUtils.sha1(genRndAsciiString(35)) |
| 103 | 103 |
val ts = tsFrom + (scala.math.random * ((tsTo - tsFrom) + 1)).asInstanceOf[Long] |
| ... | ... | |
| 186 | 186 |
|
| 187 | 187 |
println("Publishing %d msgs, hit Ctrl+c to stop".format(config.nummsg))
|
| 188 | 188 |
if (config.r) genPublishResEvents(config.nummsg) |
| 189 |
if (config.u) initUsers |
|
| 189 |
if (config.u) initUsers(config.nummsg)
|
|
| 190 | 190 |
if (config.i) genPublishUserEvents(config.nummsg) |
| 191 | 191 |
} |
| 192 | 192 |
|
Also available in: Unified diff