View Javadoc

1   /*
2    * Copyright 2007-2008 the original author or authors.
3    * 
4    * Licensed under the Apache License, Version 2.0 (the "License");
5    * you may not use this file except in compliance with the License.
6    * You may obtain a copy of the License at
7    * 
8    *      http://www.apache.org/licenses/LICENSE-2.0
9    * 
10   * Unless required by applicable law or agreed to in writing, software
11   * distributed under the License is distributed on an "AS IS" BASIS,
12   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13   * See the License for the specific language governing permissions and
14   * limitations under the License.
15   */
16  
17  package org.gwe.api.impl;
18  
19  import java.rmi.RemoteException;
20  import java.util.List;
21  
22  import org.apache.commons.logging.Log;
23  import org.apache.commons.logging.LogFactory;
24  import org.gwe.api.ServerAPI4User;
25  import org.gwe.api.exceptions.PasswordMismatchException;
26  import org.gwe.app.daemon.domain.UserDomain;
27  import org.gwe.persistence.model.DaemonConfigDesc;
28  import org.gwe.persistence.model.HeadResourceInfo;
29  import org.gwe.persistence.model.JobInfo;
30  import org.gwe.persistence.model.OrderInfo;
31  import org.gwe.utils.security.AccountInfo;
32  
33  /**
34   * @author Marco Ruiz
35   * @since Aug 15, 2007
36   */
37  public class ServerAPI4UserImpl extends SecuredServerAPIImpl<ServerAPI4User, UserDomain> implements ServerAPI4User {
38  
39  	private static Log log = LogFactory.getLog(ServerAPI4UserImpl.class);
40  	
41  	public void configureDaemon(AccountInfo auth, HeadResourceInfo daemonInfo) throws RemoteException, PasswordMismatchException {
42  //		domain.configureDaemon(daemonInfo);
43  	}
44  
45  	public void shutdownDaemon(AccountInfo auth) throws RemoteException, PasswordMismatchException {}
46  	
47  
48  	//==============
49  	// User Profile
50  	//==============
51  	public long getDaemonTime(AccountInfo auth) throws RemoteException, PasswordMismatchException {
52  		return System.currentTimeMillis();
53  	}
54  	
55  	public void updateConfig(AccountInfo sessionId, DaemonConfigDesc config) throws RemoteException, PasswordMismatchException {
56  		try {
57  	        domain.updateConfig(config);
58          } catch (Exception e) {
59  	        // TODO Auto-generated catch block
60  	        log.warn(e);
61          }
62      }
63  
64  	//================
65  	// Orders Control
66  	//================
67  	public List<OrderInfo> getOrdersDefined(AccountInfo auth) throws RemoteException, PasswordMismatchException {
68  		return domain.getOrdersDefined();
69  	}
70  
71  	public OrderInfo queueOrder(AccountInfo auth, OrderInfo order) throws RemoteException, PasswordMismatchException {
72  		order = domain.persistOrder(order);
73  		domain.queueOrder(order);
74          log.info("Request to queue an order received: " + order);
75          return order;
76  	}
77  
78  	public List<String> previewOrder(AccountInfo auth, OrderInfo order) throws RemoteException, PasswordMismatchException, Exception {
79  		return domain.previewOrder(order);
80  	}
81  
82  	public void pauseOrder(AccountInfo auth, int orderId) throws RemoteException, PasswordMismatchException {
83  		setPause(orderId, true);
84  	}
85  
86  	public void resumeOrder(AccountInfo auth, int orderId) throws RemoteException, PasswordMismatchException {
87  		setPause(orderId, false);
88  	}
89  	
90  	private void setPause(int orderId, boolean pause) throws PasswordMismatchException {
91  		domain.pauseOrder(orderId, pause);
92  	}
93  
94  	public void abortOrder(AccountInfo auth, int orderId) throws RemoteException, PasswordMismatchException {
95  		domain.abortOrder(orderId);
96  	}
97  
98  	public void deleteOrder(AccountInfo auth, int orderId) throws RemoteException, PasswordMismatchException {
99  		domain.deleteOrder(orderId);
100     }
101 
102 	public void updateOrder(AccountInfo auth, int orderId, OrderInfo order) throws RemoteException {
103 		// Change priority, scheduling parameters, allocation percentages, etc
104 		log.info("Request to update an order received: " + order);
105 		if (true) return;
106 	}
107 
108 	//==================
109 	// Order Monitoring
110 	//==================
111 	public List<OrderInfo> getOrdersByDescription(AccountInfo auth, String description) throws RemoteException, PasswordMismatchException {
112 		return domain.getOrdersByDescription(description);
113 	}
114 
115 	public OrderInfo getOrderDetails(AccountInfo auth, int orderId, boolean includeJobs) throws RemoteException, PasswordMismatchException {
116 		return domain.getOrder(orderId, includeJobs);
117 	}
118 
119 	public List<OrderInfo> getOrdersList(AccountInfo auth, boolean includeJobs) throws RemoteException, PasswordMismatchException {
120 		return domain.getOrdersList(includeJobs);
121 	}
122 
123 	public JobInfo getJobDetails(AccountInfo auth, int orderId, int jobNum) throws RemoteException, PasswordMismatchException {
124 		JobInfo result = domain.getJobDetails(orderId, jobNum);
125 		result.setExecutions(domain.getExecutionDetails(orderId, jobNum));
126 		return result;
127 	}
128 
129 	public void swapPriorities(AccountInfo auth, int orderId, int orderId2) throws RemoteException, PasswordMismatchException {
130 		domain.swapPriorities(orderId, orderId2);
131     }
132 
133 	public void cleanupDisposedAllocations(AccountInfo sessionId) throws RemoteException, PasswordMismatchException {
134 		domain.cleanupDisposedAllocations();
135     }
136 
137 	// Inspector
138 	/*
139 	 * public WorkOrderStatus getWorkOrderStatus() { // Where each task/job have been allocated and the status
140 	 * of them (scheduled in job manager, agent working on it, completed, etc) }
141 	 * 
142 	 * public WorkOrderStatus getAgents() { // Where each task/job have been allocated and the status of them
143 	 * (scheduled in job manager, agent working on it, completed, etc) }
144 	 */
145 }