Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
dream
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
1
Issues
1
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
Analytics
Analytics
Repository
Value Stream
Wiki
Wiki
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Commits
Issue Boards
Open sidebar
nexedi
dream
Commits
5beb06b5
Commit
5beb06b5
authored
Oct 08, 2014
by
Georgios Dagkakis
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
cleanup in RoutingQueue
parent
0a0e0d1e
Changes
1
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
1 addition
and
32 deletions
+1
-32
dream/simulation/RoutingQueue.py
dream/simulation/RoutingQueue.py
+1
-32
No files found.
dream/simulation/RoutingQueue.py
View file @
5beb06b5
...
...
@@ -67,27 +67,10 @@ class RoutingQueue(Queue):
#===========================================================================
def
sortEntitiesForReceiver
(
self
,
receiver
=
None
):
activeObjectQueue
=
self
.
getActiveObjectQueue
()
# find the entities that have None as receiver and update their receiver to the receiver provided as argument to the method
# the entities that have no receiver can proceed as none of their siblings have gone through the next of the activeObject
# for entity in activeObjectQueue:
# if not entity.receiver:
# entity.receiver=receiver
# print '='*10
# print '----------------- Before'
# print self.env.now, receiver.id
# for entity in activeObjectQueue:
# print entity.id, entity.receiver
# if entity.receiver:
# print entity.receiver.id
activeObjectQueue
.
sort
(
key
=
lambda
x
:
not
(
x
.
receiver
is
receiver
),
reverse
=
False
)
activeObjectQueue
.
sort
(
key
=
lambda
x
:
x
.
receiver
==
None
,
reverse
=
True
)
activeObjectQueue
.
sort
(
key
=
lambda
x
:
(
x
.
receiver
is
receiver
),
reverse
=
True
)
# print '----------------- After'
# print self.env.now, receiver.id
# for entity in activeObjectQueue:
# print entity.id, entity.receiver
# if entity.receiver:
# print entity.receiver.id
# =======================================================================
# gets an entity from the predecessor that
...
...
@@ -99,20 +82,6 @@ class RoutingQueue(Queue):
for
subbatch
in
parentBatch
.
subBatchList
:
subbatch
.
receiver
=
activeEntity
.
currentStation
return
activeEntity
# activeEntity=Queue.getEntity(self) #run the default behavior
# # update the receiver object of the entity just received according to the routing of the parent batch
# route = activeEntity.parentBatch.routing()
# activeEntity.receiver=None
# try:
# for nextObj in self.next:
# if nextObj in activeEntity.parentBatch.routing():
# activeEntity.receiver=nextObj
# break
# # if none of the siblings (same parentBatch) has gone through the buffer then the receiver should remain None
# except:
# pass
# return activeEntity
# =======================================================================
# sorts the Entities of the Queue according to the scheduling rule
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment