1 package org.cloudbus.cloudsim;
2
3 import java.text.DecimalFormat;//十进制
4 import java.util.ArrayList;
5 import java.util.HashMap;//哈希映射
6 import java.util.Iterator;//迭代器
7 import java.util.List;
8 import java.util.Map;
9 import java.util.Set;
10
11 import org.cloudbus.cloudsim.core.CloudSim;//这个类扩展了CloudSimCore使网络模拟在CloudSim中实现
12 import org.cloudbus.cloudsim.core.CloudSimTags;//含有多种静态命令，当CloudSim实体接收或发送事件时，表明被执行的一种行为
13 import org.cloudbus.cloudsim.core.SimEntity;//代表一仿真实体，实体操作事件并可以发送事件到其他实体，要扩展这个类需要加入startEntity(),processEvent()and shutdownEntity()
14 import org.cloudbus.cloudsim.core.SimEvent;//仿真事件 在实体间传递
15
16 /**
17 * Datacenter class is {a CloudResource whose hostList
18 * are virtualized}. It deals with processing of VM queries (i.e., handling
19 * of VMs) instead of processing Cloudlet-related queries. So, even though an
20 * AllocPolicy will be instantiated (in the init() method of the superclass,
21 * it will not be used, as processing of （cloudlets ）are handled by the （CloudletScheduler）
22 * and processing of 【VirtualMachines 】are handled by the【 VmAllocationPolicy】.
23 *
24 * @author Rodrigo N. Calheiros
25 * @author Anton Beloglazov
26 * @since CloudSim Toolkit 1.0
27 */
28 public class Datacenter extends SimEntity {//扩展SimEntity类
29
30 /** The characteristics. *///数据中心特性
31 private DatacenterCharacteristics characteristics;
32
33 /** The regional cis name. *///局部CIS名称
34 private String regionalCisName;
35
36 /** The vm provisioner. *///虚拟机供应
37 private VmAllocationPolicy vmAllocationPolicy;
38
39 /** The last process time. *///上一次处理时间
40 private double lastProcessTime;
41
42 /** The debts. *///费用
43 private Map<Integer, Double> debts;
44
45 /** The storage list. *///存储列表
46 private List<Storage> storageList;
47
48 /** The vm list. *///虚拟机列表
49 private List<? extends Vm> vmList;
50
51 /** The scheduling interval. *///调度间隔
52 private double schedulingInterval;
53
54 /**分配一个功率意识的数据中心对象
55 * Allocates a new PowerDatacenter object.
56 *
57 * @param name the name to be associated with this entity (as
58 * required by Sim_entity class from simjava package)
59 * @param characteristics an object of DatacenterCharacteristics
60 * @param storageList a LinkedList of storage elements, for data simulation
61 * @param vmAllocationPolicy the vmAllocationPolicy
62 *
63 * @throws Exception This happens when one of the following scenarios occur:
64 * <ul>
65 * <li> creating this entity before initializing CloudSim package
66 * <li> this entity name is <tt>null</tt> or empty
67 * <li> this entity has <tt>zero</tt> number of PEs (Processing
68 * Elements). <br>
69 * No PEs mean the Cloudlets can't be processed.
70 * A CloudResource must contain【 one or more Machines】.
71 * A Machine must contain 【one or more PEs】.
72 * </ul>
73 *
74 * @pre name != null
75 * @pre resource != null
76 * @post $none
77 */
78 public Datacenter(String name, DatacenterCharacteristics characteristics, VmAllocationPolicy vmAllocationPolicy, List<Storage> storageList, double schedulingInterval) throws Exception {
79 super(name);
80
81 setCharacteristics(characteristics);
82 setVmAllocationPolicy(vmAllocationPolicy);
83 setLastProcessTime(0.0);
84 setDebts(new HashMap<Integer,Double>());
85 setStorageList(storageList);
86 setVmList(new ArrayList<Vm>());
87 setSchedulingInterval(schedulingInterval);
88
89 // If this resource doesn't have any PEs then no useful at all 资源没有PE 则是没有用（不能处理云任务）
90 if (getCharacteristics().getPesNumber() == 0) {
91 throw new Exception(super.getName() + " : Error - this entity has no PEs. Therefore, can't process any Cloudlets.");
92 }
93
94 // stores id of this class类的存储ID
95 getCharacteristics().setId(super.getId());
96 }
97
98 /**重写此方法 以创建一个新的不同类型的资源
99 * Overrides this method when making a new and different type of resource.
100 * This method is called by {@link #body()} to register other type to
101 * GIS entity. In doing so, you
102 * need to create a new child class extending from
103 * gridsim.CloudInformationService.
104 * <br>
105 * <b>NOTE:</b> 【You do not need to override {@link #body()} method, if
106 * you use this method.】
107 *
108 * @pre $none
109 * @post $none
110 */
111 protected void registerOtherEntity() {
112 // empty. This should be override by a child class 【用一个子类重写】
113 }
114
115 /**处理时间 服务
116 * Processes events or services that are available for this PowerDatacenter.
117 *
118 * @param ev a Sim_event object
119 *
120 * @pre ev != null
121 * @post $none
122 */
123 @Override
124 public void processEvent(SimEvent ev) { //implements org.cloudbus.cloudsim.core.SimEntity.processEvent
125 int srcId = -1;
126 //Log.printLine(CloudSim.clock()+"[PowerDatacenter]: event received:"+ev.getTag());
127
128 switch (ev.getTag()) {
129 // Resource characteristics inquiry 资源特征调查
130 case CloudSimTags.RESOURCE_CHARACTERISTICS:
131 srcId = ((Integer) ev.getData()).intValue();
132 sendNow(srcId, ev.getTag(), getCharacteristics());
133 break;
134
135 // Resource dynamic info inquiry 资源动态信息查询
136 case CloudSimTags.RESOURCE_DYNAMICS:
137 srcId = ((Integer) ev.getData()).intValue();
138 sendNow(srcId, ev.getTag(), 0);
139 break;
140
141 case CloudSimTags.RESOURCE_NUM_PE:
142 srcId = ((Integer) ev.getData()).intValue();
143 int numPE = getCharacteristics().getPesNumber();
144 sendNow(srcId, ev.getTag(), numPE);
145 break;
146
147 case CloudSimTags.RESOURCE_NUM_FREE_PE:
148 srcId = ((Integer) ev.getData()).intValue();
149 int freePesNumber = getCharacteristics().getFreePesNumber();
150 sendNow(srcId, ev.getTag(), freePesNumber);
151 break;
152
153 // New Cloudlet arrives 新的云任务到达
154 case CloudSimTags.CLOUDLET_SUBMIT:
155 processCloudletSubmit(ev, false);
156 break;
157
158 // New Cloudlet arrives, but the sender asks for an ack 确认
159 case CloudSimTags.CLOUDLET_SUBMIT_ACK:
160 processCloudletSubmit(ev, true);
161 break;
162
163 // Cancels a previously submitted Cloudlet取消一个先前提交的云任务
164 case CloudSimTags.CLOUDLET_CANCEL:
165 processCloudlet(ev, CloudSimTags.CLOUDLET_CANCEL);
166 break;
167
168 // Pauses a previously submitted Cloudlet暂停一个先前提交的云任务
169 case CloudSimTags.CLOUDLET_PAUSE:
170 processCloudlet(ev, CloudSimTags.CLOUDLET_PAUSE);
171 break;
172
173 // Pauses a previously submitted Cloudlet, but the sender
174 // asks for an acknowledgement取消一个先前提交的云任务 发送则者要求确认
175 case CloudSimTags.CLOUDLET_PAUSE_ACK:
176 processCloudlet(ev, CloudSimTags.CLOUDLET_PAUSE_ACK);
177 break;
178
179 // Resumes a previously submitted Cloudlet重启一个先前提交的云任务
180 case CloudSimTags.CLOUDLET_RESUME:
181 processCloudlet(ev, CloudSimTags.CLOUDLET_RESUME);
182 break;
183
184 // Resumes a previously submitted Cloudlet, but the sender
185 // asks for an acknowledgement重启一个先前提交的云任务 发送则者要求确认
186 case CloudSimTags.CLOUDLET_RESUME_ACK:
187 processCloudlet(ev, CloudSimTags.CLOUDLET_RESUME_ACK);
188 break;
189
190 // Moves a previously submitted Cloudlet to a different resource移动一个先前提交的云任务
191 case CloudSimTags.CLOUDLET_MOVE:
192 processCloudletMove((int[]) ev.getData(), CloudSimTags.CLOUDLET_MOVE);
193 break;
194
195 // Moves a previously submitted Cloudlet to a different resource
196 case CloudSimTags.CLOUDLET_MOVE_ACK:
197 processCloudletMove((int[]) ev.getData(), CloudSimTags.CLOUDLET_MOVE_ACK);
198 break;
199
200 // Checks the status of a Cloudlet检查云任务状态
201 case CloudSimTags.CLOUDLET_STATUS:
202 processCloudletStatus(ev);
203 break;
204
205 // Ping packet
206 case CloudSimTags.INFOPKT_SUBMIT:
207 processPingRequest(ev);
208 break;
209
210 case CloudSimTags.VM_CREATE:
211 processVmCreate(ev, false);
212 break;
213
214 case CloudSimTags.VM_CREATE_ACK:
215 processVmCreate(ev, true);
216 break;
217
218 case CloudSimTags.VM_DESTROY:
219 processVmDestroy(ev, false);
220 break;
221
222 case CloudSimTags.VM_DESTROY_ACK:
223 processVmDestroy(ev, true);
224 break;
225
226 case CloudSimTags.VM_MIGRATE:
227 processVmMigrate(ev, false);
228 break;
229
230 case CloudSimTags.VM_MIGRATE_ACK:
231 processVmMigrate(ev, true);
232 break;
233
234 case CloudSimTags.VM_DATA_ADD:
235 processDataAdd(ev, false);
236 break;
237
238 case CloudSimTags.VM_DATA_ADD_ACK:
239 processDataAdd(ev, true);
240 break;
241
242 case CloudSimTags.VM_DATA_DEL:
243 processDataDelete(ev, false);
244 break;
245
246 case CloudSimTags.VM_DATA_DEL_ACK:
247 processDataDelete(ev, true);
248 break;
249
250 case CloudSimTags.VM_DATACENTER_EVENT:
251 updateCloudletProcessing();
252 checkCloudletCompletion();
253 break;
254
255 // other unknown tags are processed by this method通过这种方法处理其他不知道的标签
256 default:
257 processOtherEvent(ev);
258 break;
259 }
260 }
261
262 /**处理数据删除文件
263 * Process data del.
264 *
265 * @param ev the ev
266 * @param ack the ack
267 */
268 protected void processDataDelete(SimEvent ev, boolean ack) {
269 if (ev == null) {
270 return;
271 }
272
273 Object[] data = (Object[]) ev.getData();
274 if (data == null) {
275 return;
276 }
277
278 String filename = (String) data[0];
279 int req_source = ((Integer) data[1]).intValue();
280 int tag = -1;
281
282 // check if this file can be deleted (do not delete is right now)检查文件是否可以删除
283 int msg = deleteFileFromStorage(filename);
284 if (msg == DataCloudTags.FILE_DELETE_SUCCESSFUL) {
285 tag = DataCloudTags.CTLG_DELETE_MASTER;
286 } else { // if an error occured, notify user
287 tag = DataCloudTags.FILE_DELETE_MASTER_RESULT;
288 }
289
290 if (ack){
291 // send back to sender
292 Object pack[] = new Object[2];
293 pack[0] = filename;
294 pack[1] = Integer.valueOf(msg);
295
296 sendNow(req_source, tag, pack);
297 }
298 }
299
300 /**数据增加
301 * Process data add.
302 *
303 * @param ev the ev
304 * @param ack the ack
305 */
306 protected void processDataAdd(SimEvent ev, boolean ack) {
307 if (ev == null) {
308 return;
309 }
310
311 Object[] pack = (Object[]) ev.getData();
312 if (pack == null) {
313 return;
314 }
315
316 File file = (File) pack[0]; // get the file
317 file.setMasterCopy(true); // set the file into a master copy
318 int sentFrom = ((Integer) pack[1]).intValue(); // get sender ID
319
320 /****** // DEBUG
321 Log.printLine(super.get_name() + ".addMasterFile(): " +
322 file.getName() + " from " + CloudSim.getEntityName(sentFrom));
323 *******/
324
325 Object[] data = new Object[3];
326 data[0] = file.getName();
327
328 int msg = addFile(file); // add the file
329
330 double debit;
331 if (getDebts().containsKey(sentFrom)) {
332 debit = getDebts().get(sentFrom);
333 } else {
334 debit = 0.0;
335 }
336
337 debit += getCharacteristics().getCostPerBw() * file.getSize();
338
339 getDebts().put(sentFrom, debit);
340
341 if (ack) {
342 data[1] = Integer.valueOf(-1); // no sender id
343 data[2] = Integer.valueOf(msg); // the result of adding a master file
344 sendNow(sentFrom, DataCloudTags.FILE_ADD_MASTER_RESULT, data);
345 }
346 }
347
348 /**
349 * Processes a ping request.
350 *
351 * @param ev a Sim_event object
352 *
353 * @pre ev != null
354 * @post $none
355 */
356 protected void processPingRequest(SimEvent ev) {
357 InfoPacket pkt = (InfoPacket) ev.getData();
358 pkt.setTag(CloudSimTags.INFOPKT_RETURN);
359 pkt.setDestId(pkt.getSrcId());
360
361 // sends back to the sender
362 sendNow(pkt.getSrcId(), CloudSimTags.INFOPKT_RETURN, pkt);
363 }
364
365 /**处理事件：用户/代理想知道云任务状态
366 * Process the event for an User/Broker who wants to know the status of a Cloudlet.
367 * This PowerDatacenter will then send the status back to the User/Broker.
368 *
369 * @param ev a Sim_event object
370 *
371 * @pre ev != null
372 * @post $none
373 */
374 protected void processCloudletStatus(SimEvent ev) {
375 int cloudletId = 0;
376 int userId = 0;
377 int vmId = 0;
378 int status = -1;
379
380 try{
381 // if a sender using 【cloudletXXX() methods】
382 int data[] = (int[]) ev.getData();
383 cloudletId = data[0];
384 userId = data[1];
385 vmId = data[2];
386
387 status = getVmAllocationPolicy().getHost(vmId, userId).getVm(userId, vmId).getCloudletScheduler().getCloudletStatus(cloudletId);
388 }
389
390 // if a sender using normal 【send() methods】
391 catch (ClassCastException c) {
392 try {
393 Cloudlet cl = (Cloudlet) ev.getData();
394 cloudletId = cl.getCloudletId();
395 userId = cl.getUserId();
396
397 status = getVmAllocationPolicy().getHost(vmId, userId).getVm(userId, vmId).getCloudletScheduler().getCloudletStatus(cloudletId);
398 }
399 catch (Exception e) {
400 Log.printLine(getName() +
401 ": Error in processing CloudSimTags.CLOUDLET_STATUS");
402 Log.printLine( e.getMessage() );
403 return;
404 }
405 }
406 catch (Exception e) {
407 Log.printLine(getName() +
408 ": Error in processing CloudSimTags.CLOUDLET_STATUS");
409 Log.printLine( e.getMessage() );
410 return;
411 }
412
413 int[] array = new int[3];
414 array[0] = getId();
415 array[1] = cloudletId;
416 array[2] = status;
417
418 int tag = CloudSimTags.CLOUDLET_STATUS;
419 sendNow(userId, tag, array);
420 }
421
422 /**
423 * Here all the method related to 【VM requests 】will be received and forwarded to the related method.
424 *
425 * @param ev the received event
426 *
427 * @pre $none
428 * @post $none
429 */
430 protected void processOtherEvent(SimEvent ev) {
431 if (ev == null){
432 Log.printLine(getName() + ".processOtherEvent(): Error - an event is null.");
433 }
434 }
435
436 /**处理事件：用户/代理创建一个虚拟机
437 * Process the event for an User/Broker who wants to create a VM
438 * in this PowerDatacenter. This PowerDatacenter will then send the status back to
439 * the User/Broker.
440 *
441 * @param ev a Sim_event object
442 * @param ack the ack
443 *
444 * @pre ev != null
445 * @post $none
446 */
447 protected void processVmCreate(SimEvent ev, boolean ack) {
448 Vm vm = (Vm) ev.getData();
449
450 boolean result = getVmAllocationPolicy().allocateHostForVm(vm);
451
452 if (ack) {
453 int[] data = new int[3];
454 data[0] = getId();
455 data[1] = vm.getId();
456
457 if (result) {
458 data[2] = CloudSimTags.TRUE;
459 } else {
460 data[2] = CloudSimTags.FALSE;
461 }
462 sendNow(vm.getUserId(), CloudSimTags.VM_CREATE_ACK, data);
463 }
464
465 if (result) {
466 double amount = 0.0;
467 if (getDebts().containsKey(vm.getUserId())) {
468 amount = getDebts().get(vm.getUserId());
469 }
470 amount += getCharacteristics().getCostPerMem() * vm.getRam();
471 amount += getCharacteristics().getCostPerStorage() * vm.getSize();
472
473 getDebts().put(vm.getUserId(), amount);
474
475 getVmList().add(vm);
476
477 vm.updateVmProcessing(CloudSim.clock(), getVmAllocationPolicy().getHost(vm).getVmScheduler().getAllocatedMipsForVm(vm));
478 }
479
480 }
481
482 /**处理事件：用户/代理销毁虚拟机
483 * Process the event for an User/Broker who wants to destroy a VM
484 * previously created in this PowerDatacenter. This PowerDatacenter may send,
485 * upon request, the status back to the User/Broker.
486 *
487 * @param ev a Sim_event object
488 * @param ack the ack
489 *
490 * @pre ev != null
491 * @post $none
492 */
493 protected void processVmDestroy(SimEvent ev, boolean ack) {
494 Vm vm = (Vm) ev.getData();
495 getVmAllocationPolicy().deallocateHostForVm(vm);
496
497 if (ack) {
498 int[] data = new int[3];
499 data[0] = getId();
500 data[1] = vm.getId();
501 data[2] = CloudSimTags.TRUE;
502
503 sendNow(vm.getUserId(), CloudSimTags.VM_DESTROY_ACK, data);
504 }
505
506 getVmList().remove(vm);
507 }
508
509 /**处理事件：用户/代理迁移虚拟机
510 * Process the event for an User/Broker who wants to migrate a VM.
511 * This PowerDatacenter will then send the status back to the User/Broker.
512 * @param ev a Sim_event object
513 * @pre ev != null
514 * @post $none
515 */
516 protected void processVmMigrate(SimEvent ev, boolean ack) {
517 Object tmp = ev.getData();
518 if (!(tmp instanceof Map<?, ?>)) {
519 throw new ClassCastException("The data object must be Map<String, Object>");
520 }
521
522 @SuppressWarnings("unchecked")
523 Map<String, Object> migrate = (HashMap<String, Object>) tmp;
524
525 Vm vm = (Vm) migrate.get("vm");
526 Host host = (Host) migrate.get("host");
527
528 getVmAllocationPolicy().deallocateHostForVm(vm);
529 host.removeMigratingInVm(vm);
530 boolean result = getVmAllocationPolicy().allocateHostForVm(vm, host);
531 if (!result) {
532 Log.printLine("Allocation failed");
533 }
534
535 if (ack) {
536 int[] data = new int[3];
537 data[0] = getId();
538 data[1] = vm.getId();
539
540 if (result) {
541 data[2] = CloudSimTags.TRUE;
542 } else {
543 data[2] = CloudSimTags.FALSE;
544 }
545 sendNow(ev.getSource(), CloudSimTags.VM_CREATE_ACK, data);
546 }
547
548 double amount=0.0;
549 if (debts.containsKey(vm.getUserId())) {
550 amount = debts.get(vm.getUserId());
551 }
552
553 amount += getCharacteristics().getCostPerMem() * vm.getRam();
554 amount += getCharacteristics().getCostPerStorage() * vm.getSize();
555
556 debts.put(vm.getUserId(), amount);
557
558 Log.formatLine("%.2f: Migration of VM #%d to Host #%d is completed", CloudSim.clock(), vm.getId(), host.getId());
559 vm.setInMigration(false);
560 }
561
562 /**基于事件类别处理云任务
563 * Processes a Cloudlet based on the event type.
564 *
565 * @param ev a Sim_event object
566 * @param type event type
567 *
568 * @pre ev != null
569 * @pre type > 0
570 * @post $none
571 */
572 protected void processCloudlet(SimEvent ev, int type) {
573 int cloudletId = 0;
574 int userId = 0;
575 int vmId = 0;
576
577 try { // if the sender using 【cloudletXXX() methods】
578 int data[] = (int[]) ev.getData();
579 cloudletId = data[0];
580 userId = data[1];
581 vmId = data[2];
582 }
583
584 // if the sender using 【normal send() methods】
585 catch (ClassCastException c) {
586 try {
587 Cloudlet cl = (Cloudlet) ev.getData();
588 cloudletId = cl.getCloudletId();
589 userId = cl.getUserId();
590 vmId = cl.getVmId();
591 } catch (Exception e) {
592 Log.printLine(super.getName() + ": Error in processing Cloudlet");
593 Log.printLine(e.getMessage());
594 return;
595 }
596 } catch (Exception e) {
597 Log.printLine(super.getName() + ": Error in processing a Cloudlet.");
598 Log.printLine( e.getMessage() );
599 return;
600 }
601
602 // begins executing ....
603 switch (type) {
604 case CloudSimTags.CLOUDLET_CANCEL:
605 processCloudletCancel(cloudletId, userId, vmId);
606 break;
607
608 case CloudSimTags.CLOUDLET_PAUSE:
609 processCloudletPause(cloudletId, userId, vmId, false);
610 break;
611
612 case CloudSimTags.CLOUDLET_PAUSE_ACK:
613 processCloudletPause(cloudletId, userId, vmId, true);
614 break;
615
616 case CloudSimTags.CLOUDLET_RESUME:
617 processCloudletResume(cloudletId, userId, vmId, false);
618 break;
619
620 case CloudSimTags.CLOUDLET_RESUME_ACK:
621 processCloudletResume(cloudletId, userId, vmId, true);
622 break;
623 default:
624 break;
625 }
626
627 }
628
629 /**处理事件：用户/代理移动云任务
630 * Process the event for an User/Broker who wants to move a Cloudlet.
631 *
632 * @param receivedData information about the migration
633 * @param type event tag
634 *
635 * @pre receivedData != null
636 * @pre type > 0
637 * @post $none
638 */
639 protected void processCloudletMove(int[] receivedData, int type) {
640 updateCloudletProcessing();
641
642 int[] array = receivedData;
643 int cloudletId = array[0];
644 int userId = array[1];
645 int vmId = array[2];
646 int vmDestId = array[3];
647 int destId = array[4];
648
649 //get the cloudlet
650 Cloudlet cl = getVmAllocationPolicy().getHost(vmId, userId).getVm(userId, vmId).getCloudletScheduler().cloudletCancel(cloudletId);
651
652 boolean failed=false;
653 if (cl == null) {// cloudlet doesn't exist
654 failed = true;
655 } else {
656 // has the cloudlet already finished?
657 if (cl.getCloudletStatus() == Cloudlet.SUCCESS) {// if yes, send it back to user
658 int[] data = new int[3];
659 data[0] = this.getId();
660 data[1] = cloudletId;
661 data[2] = 0;
662 sendNow(cl.getUserId(), CloudSimTags.CLOUDLET_SUBMIT_ACK, data);
663 sendNow(cl.getUserId(), CloudSimTags.CLOUDLET_RETURN, cl);
664 }
665
666 // prepare cloudlet for migration
667 cl.setVmId(vmDestId);
668
669 // the cloudlet will migrate from one vm to another does the destination VM exist?
670 if (destId == this.getId()) {
671 Vm vm = getVmAllocationPolicy().getHost(vmDestId, userId).getVm(userId, vmDestId);
672 if (vm == null) {
673 failed = true;
674 } else {
675 double fileTransferTime = predictFileTransferTime(cl.getRequiredFiles()); // time to transfer the files
676 vm.getCloudletScheduler().cloudletSubmit(cl, fileTransferTime);
677 }
678 } else {// the cloudlet will migrate from one resource to another
679 int tag = ((type == CloudSimTags.CLOUDLET_MOVE_ACK) ? CloudSimTags.CLOUDLET_SUBMIT_ACK : CloudSimTags.CLOUDLET_SUBMIT);
680 sendNow(destId, tag, cl);
681 }
682 }
683
684 if (type == CloudSimTags.CLOUDLET_MOVE_ACK) {// send ACK if requested
685 int[] data = new int[3];
686 data[0] = this.getId();
687 data[1] = cloudletId;
688 if (failed) {
689 data[2] = 0;
690 } else {
691 data[2] = 1;
692 }
693 sendNow(cl.getUserId(), CloudSimTags.CLOUDLET_SUBMIT_ACK, data);
694 }
695 }
696
697 /**处理事件：云任务提交
698 * Processes a Cloudlet submission.
699 *
700 * @param ev a SimEvent object
701 * @param ack an acknowledgement
702 *
703 * @pre ev != null
704 * @post $none
705 */
706 protected void processCloudletSubmit(SimEvent ev, boolean ack) {
707 updateCloudletProcessing();
708
709 try {
710 // gets the Cloudlet object
711 Cloudlet cl = (Cloudlet) ev.getData();
712
713 // checks whether this Cloudlet has finished or not
714 if (cl.isFinished()){
715 String name = CloudSim.getEntityName(cl.getUserId());
716 Log.printLine(getName()+": Warning - Cloudlet #"+cl.getCloudletId()+" owned by "+name+" is already completed/finished.");
717 Log.printLine("Therefore, it is not being executed again");
718 Log.printLine();
719
720 // NOTE: If a Cloudlet has finished, then it won't be processed.
721 // So, if ack is required, this method sends back a result.
722 // If ack is not required, this method don't send back a result.
723 // Hence, this might cause CloudSim to be hanged since waiting
724 // for this Cloudlet back.
725 if (ack) {
726 int[] data = new int[3];
727 data[0] = getId();
728 data[1] = cl.getCloudletId();
729 data[2] = CloudSimTags.FALSE;
730
731 // unique tag = operation tag
732 int tag = CloudSimTags.CLOUDLET_SUBMIT_ACK;
733 sendNow(cl.getUserId(), tag, data);
734 }
735
736 sendNow(cl.getUserId(), CloudSimTags.CLOUDLET_RETURN, cl);
737
738 return;
739 }
740
741 // process this Cloudlet to this CloudResource
742 cl.setResourceParameter(getId(), getCharacteristics().getCostPerSecond(), getCharacteristics().getCostPerBw());
743
744 int userId = cl.getUserId();
745 int vmId = cl.getVmId();
746
747 double fileTransferTime = predictFileTransferTime(cl.getRequiredFiles()); //time to transfer the files
748
749 Host host = getVmAllocationPolicy().getHost(vmId, userId);
750 Vm vm = host.getVm(vmId, userId);
751 CloudletScheduler scheduler = vm.getCloudletScheduler();
752 double estimatedFinishTime = scheduler.cloudletSubmit(cl,fileTransferTime);
753
754 //if (estimatedFinishTime > 0.0 && estimatedFinishTime < getSchedulingInterval()) { //if this cloudlet is in the exec queue
755 if (estimatedFinishTime > 0.0) { //if this cloudlet is in the exec queue
756 //double estimatedFinishTime = (cl.getCloudletTotalLength()/(capacity*cl.getPesNumber())); //time to process the cloudlet
757 //Log.printLine(estimatedFinishTime+"="+gl.getCloudletLength()+"/("+capacity+"*"+gl.getNumPE()+")");
758 estimatedFinishTime += fileTransferTime;
759 //estimatedFinishTime += CloudSim.clock();
760 //Log.printLine(CloudSim.clock()+": Next event scheduled to +"+estimatedFinishTime);
761 send(getId(), estimatedFinishTime, CloudSimTags.VM_DATACENTER_EVENT);
762 }
763
764 }
765 catch (ClassCastException c) {
766 Log.printLine(getName() + ".processCloudletSubmit(): " + "ClassCastException error.");
767 c.printStackTrace();
768 }
769 catch (Exception e) {
770 Log.printLine(getName() + ".processCloudletSubmit(): " + "Exception error.");
771 e.printStackTrace();
772 }
773
774 checkCloudletCompletion();
775 }
776
777 /**预测文件传输时间
778 * Predict file transfer time.
779 *
780 * @param requiredFiles the required files
781 *
782 * @return the double
783 */
784 protected double predictFileTransferTime(List<String> requiredFiles) {
785 double time = 0.0;
786
787 Iterator<String> iter = requiredFiles.iterator();//【迭代器的使用】
788 while (iter.hasNext()) {
789 String fileName = iter.next();
790 for (int i = 0; i < getStorageList().size(); i++) {
791 Storage tempStorage = getStorageList().get(i);
792 File tempFile = tempStorage.getFile(fileName);
793 if (tempFile != null) {
794 time += tempFile.getSize() / tempStorage.getMaxTransferRate();
795 break;
796 }
797 }
798 }
799 return time;
800 }
801
802 /**处理云任务重启请求
803 * Processes a Cloudlet resume request.
804 *
805 * @param cloudletId resuming cloudlet ID
806 * @param userId ID of the cloudlet's owner
807 * @param ack $true if an ack is requested after operation
808 * @param vmId the vm id
809 *
810 * @pre $none
811 * @post $none
812 */
813 protected void processCloudletResume(int cloudletId, int userId, int vmId, boolean ack) {
814 double eventTime = getVmAllocationPolicy().getHost(vmId,userId).getVm(userId, vmId).getCloudletScheduler().cloudletResume(cloudletId);
815
816 boolean status = false;
817 if (eventTime > 0.0) { //if this cloudlet is in the exec queue
818 status = true;
819 if (eventTime > CloudSim.clock()) {
820 schedule(getId(), eventTime, CloudSimTags.VM_DATACENTER_EVENT);
821 }
822 }
823
824 if (ack) {
825 int[] data = new int[3];
826 data[0] = getId();
827 data[1] = cloudletId;
828 if (status) {
829 data[2] = CloudSimTags.TRUE;
830 } else {
831 data[2] = CloudSimTags.FALSE;
832 }
833 sendNow(userId, CloudSimTags.CLOUDLET_RESUME_ACK, data);
834 }
835 }
836
837 /**处理云任务暂停请求
838 * Processes a Cloudlet pause request.
839 *
840 * @param cloudletId resuming cloudlet ID
841 * @param userId ID of the cloudlet's owner
842 * @param ack $true if an ack is requested after operation
843 * @param vmId the vm id
844 *
845 * @pre $none
846 * @post $none
847 */
848 protected void processCloudletPause(int cloudletId, int userId, int vmId, boolean ack) {
849 boolean status = getVmAllocationPolicy().getHost(vmId,userId).getVm(userId, vmId).getCloudletScheduler().cloudletPause(cloudletId);
850
851 if (ack) {
852 int[] data = new int[3];
853 data[0] = getId();
854 data[1] = cloudletId;
855 if (status) {
856 data[2] = CloudSimTags.TRUE;
857 } else {
858 data[2] = CloudSimTags.FALSE;
859 }
860 sendNow(userId, CloudSimTags.CLOUDLET_PAUSE_ACK, data);
861 }
862 }
863
864 /**处理云任务取消请求
865 * Processes a Cloudlet cancel request.
866 *
867 * @param cloudletId resuming cloudlet ID
868 * @param userId ID of the cloudlet's owner
869 * @param vmId the vm id
870 *
871 * @pre $none
872 * @post $none
873 */
874 protected void processCloudletCancel(int cloudletId, int userId, int vmId) {
875 Cloudlet cl = getVmAllocationPolicy().getHost(vmId,userId).getVm(userId, vmId).getCloudletScheduler().cloudletCancel(cloudletId);
876
877 sendNow(userId, CloudSimTags.CLOUDLET_CANCEL, cl);
878 }
879
880 /**更新处理云任务
881 * Updates processing of each cloudlet running in this PowerDatacenter. It is necessary because
882 * Hosts and VirtualMachines are simple objects, not entities. So, they don't receive events
883 * and updating cloudlets inside them must be called from the outside.
884 *
885 * @pre $none
886 * @post $none
887 */
888 protected void updateCloudletProcessing() {
889 //Log.printLine(CloudSim.clock()+": PowerDatacenter #"+this.get_id()+": updating cloudlet processing.......................................");
890 //if some time passed since last processing
891 if (CloudSim.clock() > this.getLastProcessTime()) {
892 List<? extends Host> list = getVmAllocationPolicy().getHostList();
893 double smallerTime = Double.MAX_VALUE;
894 //for each host...
895 for (int i = 0; i < list.size(); i++) {
896 Host host = list.get(i);
897 double time = host.updateVmsProcessing(CloudSim.clock());//inform VMs to update processing
898 //what time do we expect that the next cloudlet will finish?
899 if (time < smallerTime) {
900 smallerTime = time;
901 }
902 }
903 //schedules an event to the next time, if valid
904 //if (smallerTime > CloudSim.clock() + 0.01 && smallerTime != Double.MAX_VALUE && smallerTime < getSchedulingInterval()) {
905 if (smallerTime > CloudSim.clock() + 0.01 && smallerTime != Double.MAX_VALUE) {
906 schedule(getId(), (smallerTime - CloudSim.clock()), CloudSimTags.VM_DATACENTER_EVENT);
907 }
908 setLastProcessTime(CloudSim.clock());
909 }
910 }
911
912 /**证实 如果一些任务已经完成
913 * Verifies if some cloudlet inside this PowerDatacenter already finished.
914 * If yes, send it to the User/Broker
915 *
916 * @pre $none
917 * @post $none
918 */
919 protected void checkCloudletCompletion() {
920 List<? extends Host> list = getVmAllocationPolicy().getHostList();
921 for (int i = 0; i < list.size(); i++) {
922 Host host = list.get(i);
923 for (Vm vm : host.getVmList()) {
924 while (vm.getCloudletScheduler().isFinishedCloudlets()){
925 Cloudlet cl = vm.getCloudletScheduler().getNextFinishedCloudlet();
926 if (cl != null) {
927 sendNow(cl.getUserId(), CloudSimTags.CLOUDLET_RETURN, cl);
928 }
929 }
930 }
931 }
932 }
933
934 /**实验开始前增加一个文件到资源存储 file ？？？
935 * Adds a file into the resource's storage before the experiment starts.
936 * If the file is a master file, then it will be registered to the RC when
937 * the experiment begins.
938 *
939 * @param file a DataCloud file
940 *
941 * @return a tag number denoting whether this operation is a success or not
942 *
943 * @see CloudSim.datagrid.DataCloudTags#FILE_ADD_SUCCESSFUL
944 * @see CloudSim.datagrid.DataCloudTags#FILE_ADD_ERROR_EMPTY
945 */
946 public int addFile(File file) {
947 if (file == null) {
948 return DataCloudTags.FILE_ADD_ERROR_EMPTY;
949 }
950
951 if (contains(file.getName())) {
952 return DataCloudTags.FILE_ADD_ERROR_EXIST_READ_ONLY;
953 }
954
955 // check storage space first
956 if (getStorageList().size() <= 0) {
957 return DataCloudTags.FILE_ADD_ERROR_STORAGE_FULL;
958 }
959
960 Storage tempStorage = null;
961 int msg = DataCloudTags.FILE_ADD_ERROR_STORAGE_FULL;
962
963 for (int i = 0; i < getStorageList().size(); i++) {
964 tempStorage = getStorageList().get(i);
965 if (tempStorage.getAvailableSpace() >= file.getSize()) {
966 tempStorage.addFile(file);
967 msg = DataCloudTags.FILE_ADD_SUCCESSFUL;
968 break;
969 }
970 }
971
972 return msg;
973 }
974
975 /**核实是否资源拥有给定的文件
976 * Checks whether the resource has the given file.
977 *
978 * @param file a file to be searched
979 *
980 * @return <tt>true</tt> if successful, <tt>false</tt> otherwise
981 */
982 protected boolean contains(File file) {
983 if (file == null) {
984 return false;
985 }
986 return contains( file.getName() );
987 }
988
989 /**
990 * Checks whether the resource has the given file.
991 *
992 * @param fileName a file name to be searched
993 *
994 * @return <tt>true</tt> if successful, <tt>false</tt> otherwise
995 */
996 protected boolean contains(String fileName) {
997 if (fileName == null || fileName.length() == 0) {
998 return false;
999 }
1000
1001 Iterator<Storage> it = getStorageList().iterator();
1002 Storage storage = null;
1003 boolean result = false;
1004
1005 while (it.hasNext()) {
1006 storage = it.next();
1007 if (storage.contains(fileName)) {
1008 result = true;
1009 break;
1010 }
1011 }
1012
1013 return result;
1014 }
1015
1016 /**删除文件
1017 * Deletes the file from the storage. Also, check whether it is
1018 * possible to delete the file from the storage.
1019 *
1020 * @param fileName the name of the file to be deleted
1021 *
1022 * @return the error message as defined in
1023 * {@link CloudSim.datagrid.DataCloudTags}
1024 *
1025 * @see CloudSim.datagrid.DataCloudTags#FILE_DELETE_SUCCESSFUL
1026 * @see CloudSim.datagrid.DataCloudTags#FILE_DELETE_ERROR_ACCESS_DENIED
1027 * @see CloudSim.datagrid.DataCloudTags#FILE_DELETE_ERROR
1028 */
1029 private int deleteFileFromStorage(String fileName) {
1030 Storage tempStorage = null;
1031 File tempFile = null;
1032 int msg = DataCloudTags.FILE_DELETE_ERROR;
1033
1034 for (int i = 0; i < getStorageList().size(); i++) {
1035 tempStorage = getStorageList().get(i);
1036 tempFile = tempStorage.getFile(fileName);
1037 tempStorage.deleteFile(fileName, tempFile);
1038 msg = DataCloudTags.FILE_DELETE_SUCCESSFUL;
1039 } // end for
1040
1041 return msg;
1042 }
1043
1044 /**打印费用
1045 * Prints the debts.
1046 */
1047 public void printDebts() {
1048 Log.printLine("*****PowerDatacenter: "+this.getName()+"*****");
1049 Log.printLine("User id\t\tDebt");
1050
1051 Set<Integer> keys = getDebts().keySet();
1052 Iterator<Integer> iter = keys.iterator();
1053 DecimalFormat df = new DecimalFormat("#.##");
1054 while (iter.hasNext()) {
1055 int key = iter.next();
1056 double value = getDebts().get(key);
1057 Log.printLine(key+"\t\t"+df.format(value));
1058 }
1059 Log.printLine("**********************************");
1060 }
1061
1062 /* (non-Javadoc)
1063 * @see cloudsim.core.SimEntity#shutdownEntity()
1064 */
1065 @Override
1066 public void shutdownEntity() {
1067 Log.printLine(getName() + " is shutting down...");
1068 }
1069
1070 /* (non-Javadoc)
1071 * @see cloudsim.core.SimEntity#startEntity()
1072 */
1073 @Override
1074 public void startEntity() {
1075 Log.printLine(getName() + " is starting...");
1076 // this resource should register to regional GIS.
1077 // However, if not specified, then register to system GIS (the
1078 // default CloudInformationService) entity.
1079 int gisID = CloudSim.getEntityId(regionalCisName);
1080 if (gisID == -1) {
1081 gisID = CloudSim.getCloudInfoServiceEntityId();
1082 }
1083
1084 // send the registration to GIS
1085 sendNow(gisID, CloudSimTags.REGISTER_RESOURCE, getId());
1086 // Below method is for a child class to override
1087 registerOtherEntity();
1088 }
1089
1090 /**获取主机列表
1091 * Gets the host list.
1092 *
1093 * @return the host list
1094 */
1095 @SuppressWarnings("unchecked")
1096 public <T extends Host> List<T> getHostList() {
1097 return (List<T>) getCharacteristics().getHostList();
1098 }
1099
1100 /**获取数据中心特征
1101 * Gets the characteristics.
1102 *
1103 * @return the characteristics
1104 */
1105 protected DatacenterCharacteristics getCharacteristics() {
1106 return characteristics;
1107 }
1108
1109 /**设置数据中心特征
1110 * Sets the characteristics.
1111 *
1112 * @param characteristics the new characteristics
1113 */
1114 protected void setCharacteristics(DatacenterCharacteristics characteristics) {
1115 this.characteristics = characteristics;
1116 }
1117
1118 /**获取局部CIS名
1119 * Gets the regional cis name.
1120 *
1121 * @return the regional cis name
1122 */
1123 protected String getRegionalCisName() {
1124 return regionalCisName;
1125 }
1126
1127 /**
1128 * Sets the regional cis name.
1129 *
1130 * @param regionalCisName the new regional cis name
1131 */
1132 protected void setRegionalCisName(String regionalCisName) {
1133 this.regionalCisName = regionalCisName;
1134 }
1135
1136 /**虚拟机分配协议
1137 * Gets the vm allocation policy.
1138 *
1139 * @return the vm allocation policy
1140 */
1141 public VmAllocationPolicy getVmAllocationPolicy() {
1142 return vmAllocationPolicy;
1143 }
1144
1145 /**
1146 * Sets the vm allocation policy.
1147 *
1148 * @param vmAllocationPolicy the new vm allocation policy
1149 */
1150 protected void setVmAllocationPolicy(VmAllocationPolicy vmAllocationPolicy) {
1151 this.vmAllocationPolicy = vmAllocationPolicy;
1152 }
1153
1154 /**
1155 * Gets the last process time.
1156 *
1157 * @return the last process time
1158 */
1159 protected double getLastProcessTime() {
1160 return lastProcessTime;
1161 }
1162
1163 /**
1164 * Sets the last process time.
1165 *
1166 * @param lastProcessTime the new last process time
1167 */
1168 protected void setLastProcessTime(double lastProcessTime) {
1169 this.lastProcessTime = lastProcessTime;
1170 }
1171
1172 /**费用
1173 * Gets the debts.
1174 *
1175 * @return the debts
1176 */
1177 protected Map<Integer, Double> getDebts() {
1178 return debts;
1179 }
1180
1181 /**
1182 * Sets the debts.
1183 *
1184 * @param debts the debts
1185 */
1186 protected void setDebts(Map<Integer, Double> debts) {
1187 this.debts = debts;
1188 }
1189
1190 /**存储列表
1191 * Gets the storage list.
1192 *
1193 * @return the storage list
1194 */
1195 protected List<Storage> getStorageList() {
1196 return storageList;
1197 }
1198
1199 /**
1200 * Sets the storage list.
1201 *
1202 * @param storageList the new storage list
1203 */
1204 protected void setStorageList(List<Storage> storageList) {
1205 this.storageList = storageList;
1206 }
1207
1208 /**虚拟机列表
1209 * Gets the vm list.
1210 *
1211 * @return the vm list
1212 */
1213 @SuppressWarnings("unchecked")
1214 public <T extends Vm> List<T> getVmList() {
1215 return (List<T>) vmList;
1216 }
1217
1218 /**
1219 * Sets the vm list.
1220 *
1221 * @param vmList the new vm list
1222 */
1223 protected <T extends Vm> void setVmList(List<T> vmList) {
1224 this.vmList = vmList;
1225 }
1226
1227 /**调度间隔
1228 * Gets the scheduling interval.
1229 *
1230 * @return the scheduling interval
1231 */
1232 protected double getSchedulingInterval() {
1233 return schedulingInterval;
1234 }
1235
1236 /**
1237 * Sets the scheduling interval.
1238 *
1239 * @param schedulingInterval the new scheduling interval
1240 */
1241 protected void setSchedulingInterval(double schedulingInterval) {
1242 this.schedulingInterval = schedulingInterval;
1243 }
1244
1245 }
