2 * Copyright 2011-2012 GRNET S.A. All rights reserved.
4 * Redistribution and use in source and binary forms, with or
5 * without modification, are permitted provided that the following
8 * 1. Redistributions of source code must retain the above
9 * copyright notice, this list of conditions and the following
12 * 2. Redistributions in binary form must reproduce the above
13 * copyright notice, this list of conditions and the following
14 * disclaimer in the documentation and/or other materials
15 * provided with the distribution.
17 * THIS SOFTWARE IS PROVIDED BY GRNET S.A. ``AS IS'' AND ANY EXPRESS
18 * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
19 * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
20 * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL GRNET S.A OR
21 * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
22 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
23 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
24 * USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
25 * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
26 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
27 * ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
28 * POSSIBILITY OF SUCH DAMAGE.
30 * The views and conclusions contained in the software and
31 * documentation are those of the authors and should not be
32 * interpreted as representing official policies, either expressed
33 * or implied, of GRNET S.A.
36 package gr.grnet.aquarium.computation
38 import scala.collection.mutable
39 import gr.grnet.aquarium.logic.accounting.dsl.DSLResourcesMap
40 import gr.grnet.aquarium.computation.data.{LatestResourceEventsWorker, ImplicitlyIssuedResourceEventsWorker, IgnoredFirstResourceEventsWorker}
41 import gr.grnet.aquarium.util.ContextualLogger
42 import gr.grnet.aquarium.event.model.resource.ResourceEventModel
45 * A helper object holding intermediate state/results during resource event processing.
47 * @param previousResourceEvents
48 * This is a collection of all the latest resource events.
49 * We want these in order to correlate incoming resource events with their previous (in `occurredMillis` time)
50 * ones. Will be updated on processing the next resource event.
52 * @param implicitlyIssuedStartEvents
53 * The implicitly issued resource events at the beginning of the billing period.
55 * @param ignoredFirstResourceEvents
56 * The resource events that were first (and unused) of their kind.
58 * @author Christos KK Loverdos <loverdos@gmail.com>
60 case class UserStateWorker(userID: String,
61 previousResourceEvents: LatestResourceEventsWorker,
62 implicitlyIssuedStartEvents: ImplicitlyIssuedResourceEventsWorker,
63 ignoredFirstResourceEvents: IgnoredFirstResourceEventsWorker,
64 resourcesMap: DSLResourcesMap) {
67 * Finds the previous resource event by checking two possible sources: a) The implicitly terminated resource
68 * events and b) the explicit previous resource events. If the event is found, it is removed from the
71 * If the event is not found, then this must be for a new resource instance.
72 * (and probably then some `zero` resource event must be implied as the previous one)
78 def findAndRemovePreviousResourceEvent(resource: String, instanceId: String): Option[ResourceEventModel] = {
79 // implicitly issued events are checked first
80 implicitlyIssuedStartEvents.findAndRemoveResourceEvent(resource, instanceId) match {
84 // explicit previous resource events are checked second
85 previousResourceEvents.findAndRemoveResourceEvent(resource, instanceId) match {
94 def updateIgnored(resourceEvent: ResourceEventModel): Unit = {
95 ignoredFirstResourceEvents.updateResourceEvent(resourceEvent)
98 def updatePrevious(resourceEvent: ResourceEventModel): Unit = {
99 previousResourceEvents.updateResourceEvent(resourceEvent)
102 def debugTheMaps(clog: ContextualLogger)(rcDebugInfo: ResourceEventModel ⇒ String): Unit = {
103 if(previousResourceEvents.size > 0) {
104 val map = previousResourceEvents.latestEventsMap.map {
105 case (k, v) => (k, rcDebugInfo(v))
107 clog.debugMap("previousResourceEvents", map, 0)
109 if(implicitlyIssuedStartEvents.size > 0) {
110 val map = implicitlyIssuedStartEvents.implicitlyIssuedEventsMap.map {
111 case (k, v) => (k, rcDebugInfo(v))
113 clog.debugMap("implicitlyTerminatedResourceEvents", map, 0)
115 if(ignoredFirstResourceEvents.size > 0) {
116 val map = ignoredFirstResourceEvents.ignoredFirstEventsMap.map {
117 case (k, v) => (k, rcDebugInfo(v))
119 clog.debugMap("ignoredFirstResourceEvents", map, 0)
124 // def allPreviousAndAllImplicitlyStarted: List[ResourceEvent] = {
125 // val buffer: FullMutableResourceTypeMap = scala.collection.mutable.Map[FullResourceType, ResourceEvent]()
127 // buffer ++= implicitlyIssuedStartEvents.implicitlyIssuedEventsMap
128 // buffer ++= previousResourceEvents.latestEventsMap
130 // buffer.valuesIterator.toList
134 * Find those events from `implicitlyIssuedStartEvents` and `previousResourceEvents` that will generate implicit
135 * end events along with those implicitly issued events. Before returning, remove the events that generated the
136 * implicit ends from the internal state of this instance.
138 * @see [[gr.grnet.aquarium.logic.accounting.dsl.DSLCostPolicy]]
140 def findAndRemoveGeneratorsOfImplicitEndEvents(
141 newOccuredMillis: Long
142 ): (List[ResourceEventModel], List[ResourceEventModel]) = {
144 val buffer = mutable.ListBuffer[(ResourceEventModel, ResourceEventModel)]()
145 val checkSet = mutable.Set[ResourceEventModel]()
147 def doItFor(map: ResourceEventModel.FullMutableResourceTypeMap): Unit = {
148 val resourceEvents = map.valuesIterator
150 resourceEvent ← resourceEvents
151 dslResource ← resourcesMap.findResource(resourceEvent.safeResource)
152 costPolicy = dslResource.costPolicy
154 if(costPolicy.supportsImplicitEvents) {
155 if(costPolicy.mustConstructImplicitEndEventFor(resourceEvent)) {
156 val implicitEnd = costPolicy.constructImplicitEndEventFor(resourceEvent, newOccuredMillis)
158 if(!checkSet.contains(resourceEvent)) {
159 checkSet.add(resourceEvent)
160 buffer append ((resourceEvent, implicitEnd))
164 map.remove((resourceEvent.safeResource, resourceEvent.safeInstanceId))
170 doItFor(previousResourceEvents.latestEventsMap) // we give priority for previous
171 doItFor(implicitlyIssuedStartEvents.implicitlyIssuedEventsMap) // ... over implicitly issued...
173 (buffer.view.map(_._1).toList, buffer.view.map(_._2).toList)
177 object UserStateWorker {
178 def fromUserState(userState: UserState, resourcesMap: DSLResourcesMap): UserStateWorker = {
181 userState.latestResourceEventsSnapshot.toMutableWorker,
182 userState.implicitlyIssuedSnapshot.toMutableWorker,
183 IgnoredFirstResourceEventsWorker.Empty,