You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cloudstack.apache.org by ke...@apache.org on 2012/08/23 23:30:54 UTC
[21/40] m2e doesn't like it when the project root is the source folder
http://git-wip-us.apache.org/repos/asf/incubator-cloudstack/blob/3976c747/deps/XenServerJava/src/com/xensource/xenapi/DataSource.java
----------------------------------------------------------------------
diff --git a/deps/XenServerJava/src/com/xensource/xenapi/DataSource.java b/deps/XenServerJava/src/com/xensource/xenapi/DataSource.java
new file mode 100644
index 0000000..e623c10
--- /dev/null
+++ b/deps/XenServerJava/src/com/xensource/xenapi/DataSource.java
@@ -0,0 +1,142 @@
+// Copyright 2012 Citrix Systems, Inc. Licensed under the
+// Apache License, Version 2.0 (the "License"); you may not use this
+// file except in compliance with the License. Citrix Systems, Inc.
+// reserves all rights not expressly granted by the License.
+// You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+// Automatically generated by addcopyright.py at 04/03/2012
+package com.xensource.xenapi;
+
+import com.xensource.xenapi.Types.BadServerResponse;
+import com.xensource.xenapi.Types.VersionException;
+import com.xensource.xenapi.Types.XenAPIException;
+
+import java.io.PrintWriter;
+import java.io.StringWriter;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.LinkedHashSet;
+import java.util.Map;
+import java.util.Set;
+
+import org.apache.xmlrpc.XmlRpcException;
+
+/**
+ * Data sources for logging in RRDs
+ *
+ * @author Citrix Systems, Inc.
+ */
+public class DataSource extends XenAPIObject {
+
+ /**
+ * The XenAPI reference to this object.
+ */
+ protected final String ref;
+
+ /**
+ * For internal use only.
+ */
+ DataSource(String ref) {
+ this.ref = ref;
+ }
+
+ public String toWireString() {
+ return this.ref;
+ }
+
+ /**
+ * If obj is a DataSource, compares XenAPI references for equality.
+ */
+ @Override
+ public boolean equals(Object obj)
+ {
+ if (obj != null && obj instanceof DataSource)
+ {
+ DataSource other = (DataSource) obj;
+ return other.ref.equals(this.ref);
+ } else
+ {
+ return false;
+ }
+ }
+
+ @Override
+ public int hashCode()
+ {
+ return ref.hashCode();
+ }
+
+ /**
+ * Represents all the fields in a DataSource
+ */
+ public static class Record implements Types.Record {
+ public String toString() {
+ StringWriter writer = new StringWriter();
+ PrintWriter print = new PrintWriter(writer);
+ print.printf("%1$20s: %2$s\n", "nameLabel", this.nameLabel);
+ print.printf("%1$20s: %2$s\n", "nameDescription", this.nameDescription);
+ print.printf("%1$20s: %2$s\n", "enabled", this.enabled);
+ print.printf("%1$20s: %2$s\n", "standard", this.standard);
+ print.printf("%1$20s: %2$s\n", "units", this.units);
+ print.printf("%1$20s: %2$s\n", "min", this.min);
+ print.printf("%1$20s: %2$s\n", "max", this.max);
+ print.printf("%1$20s: %2$s\n", "value", this.value);
+ return writer.toString();
+ }
+
+ /**
+ * Convert a data_source.Record to a Map
+ */
+ public Map<String,Object> toMap() {
+ Map<String,Object> map = new HashMap<String,Object>();
+ map.put("name_label", this.nameLabel == null ? "" : this.nameLabel);
+ map.put("name_description", this.nameDescription == null ? "" : this.nameDescription);
+ map.put("enabled", this.enabled == null ? false : this.enabled);
+ map.put("standard", this.standard == null ? false : this.standard);
+ map.put("units", this.units == null ? "" : this.units);
+ map.put("min", this.min == null ? 0.0 : this.min);
+ map.put("max", this.max == null ? 0.0 : this.max);
+ map.put("value", this.value == null ? 0.0 : this.value);
+ return map;
+ }
+
+ /**
+ * a human-readable name
+ */
+ public String nameLabel;
+ /**
+ * a notes field containg human-readable description
+ */
+ public String nameDescription;
+ /**
+ * true if the data source is being logged
+ */
+ public Boolean enabled;
+ /**
+ * true if the data source is enabled by default. Non-default data sources cannot be disabled
+ */
+ public Boolean standard;
+ /**
+ * the units of the value
+ */
+ public String units;
+ /**
+ * the minimum value of the data source
+ */
+ public Double min;
+ /**
+ * the maximum value of the data source
+ */
+ public Double max;
+ /**
+ * current value of the data source
+ */
+ public Double value;
+ }
+
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-cloudstack/blob/3976c747/deps/XenServerJava/src/com/xensource/xenapi/Event.java
----------------------------------------------------------------------
diff --git a/deps/XenServerJava/src/com/xensource/xenapi/Event.java b/deps/XenServerJava/src/com/xensource/xenapi/Event.java
new file mode 100644
index 0000000..46e2d6c
--- /dev/null
+++ b/deps/XenServerJava/src/com/xensource/xenapi/Event.java
@@ -0,0 +1,242 @@
+// Copyright 2012 Citrix Systems, Inc. Licensed under the
+// Apache License, Version 2.0 (the "License"); you may not use this
+// file except in compliance with the License. Citrix Systems, Inc.
+// reserves all rights not expressly granted by the License.
+// You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+// Automatically generated by addcopyright.py at 04/03/2012
+package com.xensource.xenapi;
+
+import java.io.PrintWriter;
+import java.io.StringWriter;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Set;
+
+import org.apache.xmlrpc.XmlRpcException;
+
+import com.xensource.xenapi.Types.BadServerResponse;
+import com.xensource.xenapi.Types.XenAPIException;
+
+/**
+ * Asynchronous event registration and handling
+ *
+ * @author Citrix Systems, Inc.
+ */
+public class Event extends XenAPIObject {
+
+ /**
+ * The XenAPI reference to this object.
+ */
+ protected final String ref;
+
+ /**
+ * For internal use only.
+ */
+ Event(String ref) {
+ this.ref = ref;
+ }
+
+ @Override
+ public String toWireString() {
+ return this.ref;
+ }
+
+ /**
+ * If obj is a Event, compares XenAPI references for equality.
+ */
+ @Override
+ public boolean equals(Object obj)
+ {
+ if (obj != null && obj instanceof Event)
+ {
+ Event other = (Event) obj;
+ return other.ref.equals(this.ref);
+ } else
+ {
+ return false;
+ }
+ }
+
+ @Override
+ public int hashCode()
+ {
+ return ref.hashCode();
+ }
+
+ /**
+ * Represents all the fields in a Event
+ */
+ public static class Record implements Types.Record {
+ @Override
+ public String toString() {
+ StringWriter writer = new StringWriter();
+ PrintWriter print = new PrintWriter(writer);
+ print.printf("%1$20s: %2$s\n", "id", this.id);
+ print.printf("%1$20s: %2$s\n", "timestamp", this.timestamp);
+ print.printf("%1$20s: %2$s\n", "clazz", this.clazz);
+ print.printf("%1$20s: %2$s\n", "operation", this.operation);
+ print.printf("%1$20s: %2$s\n", "ref", this.ref);
+ print.printf("%1$20s: %2$s\n", "objUuid", this.objUuid);
+ print.printf("%1$20s: %2$s\n", "snapshot", this.snapshot);
+ return writer.toString();
+ }
+
+ /**
+ * Convert a event.Record to a Map
+ */
+ @Override
+ public Map<String,Object> toMap() {
+ Map<String,Object> map = new HashMap<String,Object>();
+ map.put("id", this.id == null ? 0 : this.id);
+ map.put("timestamp", this.timestamp == null ? new Date(0) : this.timestamp);
+ map.put("class", this.clazz == null ? "" : this.clazz);
+ map.put("operation", this.operation == null ? Types.EventOperation.UNRECOGNIZED : this.operation);
+ map.put("ref", this.ref == null ? "" : this.ref);
+ map.put("obj_uuid", this.objUuid == null ? "" : this.objUuid);
+ map.put("snapshot", this.snapshot);
+ return map;
+ }
+
+ /**
+ * An ID, monotonically increasing, and local to the current session
+ */
+ public Long id;
+ /**
+ * The time at which the event occurred
+ */
+ public Date timestamp;
+ /**
+ * The name of the class of the object that changed
+ */
+ public String clazz;
+ /**
+ * The operation that was performed
+ */
+ public Types.EventOperation operation;
+ /**
+ * A reference to the object that changed
+ */
+ public String ref;
+ /**
+ * The uuid of the object that changed
+ */
+ public String objUuid;
+ /**
+ * The record of the database object that was added, changed or deleted
+ * (the actual type will be VM.Record, VBD.Record or similar)
+ */
+ public Object snapshot;
+ }
+
+ /**
+ * Registers this session with the event system. Specifying the empty list will register for all classes.
+ *
+ * @param classes register for events for the indicated classes
+ * @return Task
+ */
+ public static Task registerAsync(Connection c, Set<String> classes) throws
+ BadServerResponse,
+ XenAPIException,
+ XmlRpcException {
+ String method_call = "Async.event.register";
+ String session = c.getSessionReference();
+ Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(classes)};
+ Map response = c.dispatch(method_call, method_params);
+ Object result = response.get("Value");
+ return Types.toTask(result);
+ }
+
+ /**
+ * Registers this session with the event system. Specifying the empty list will register for all classes.
+ *
+ * @param classes register for events for the indicated classes
+ */
+ public static void register(Connection c, Set<String> classes) throws
+ BadServerResponse,
+ XenAPIException,
+ XmlRpcException {
+ String method_call = "event.register";
+ String session = c.getSessionReference();
+ Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(classes)};
+ Map response = c.dispatch(method_call, method_params);
+ return;
+ }
+
+ /**
+ * Unregisters this session with the event system
+ *
+ * @param classes remove this session's registration for the indicated classes
+ * @return Task
+ */
+ public static Task unregisterAsync(Connection c, Set<String> classes) throws
+ BadServerResponse,
+ XenAPIException,
+ XmlRpcException {
+ String method_call = "Async.event.unregister";
+ String session = c.getSessionReference();
+ Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(classes)};
+ Map response = c.dispatch(method_call, method_params);
+ Object result = response.get("Value");
+ return Types.toTask(result);
+ }
+
+ /**
+ * Unregisters this session with the event system
+ *
+ * @param classes remove this session's registration for the indicated classes
+ */
+ public static void unregister(Connection c, Set<String> classes) throws
+ BadServerResponse,
+ XenAPIException,
+ XmlRpcException {
+ String method_call = "event.unregister";
+ String session = c.getSessionReference();
+ Object[] method_params = {Marshalling.toXMLRPC(session), Marshalling.toXMLRPC(classes)};
+ Map response = c.dispatch(method_call, method_params);
+ return;
+ }
+
+ /**
+ * Blocking call which returns a (possibly empty) batch of events
+ *
+ * @return the batch of events
+ */
+ public static Set<Event.Record> next(Connection c) throws
+ BadServerResponse,
+ XenAPIException,
+ XmlRpcException,
+ Types.SessionNotRegistered,
+ Types.EventsLost {
+ String method_call = "event.next";
+ String session = c.getSessionReference();
+ Object[] method_params = {Marshalling.toXMLRPC(session)};
+ Map response = c.dispatch(method_call, method_params);
+ Object result = response.get("Value");
+ return Types.toSetOfEventRecord(result);
+ }
+
+ /**
+ * Return the ID of the next event to be generated by the system
+ *
+ * @return the event ID
+ */
+ public static Long getCurrentId(Connection c) throws
+ BadServerResponse,
+ XenAPIException,
+ XmlRpcException {
+ String method_call = "event.get_current_id";
+ String session = c.getSessionReference();
+ Object[] method_params = {Marshalling.toXMLRPC(session)};
+ Map response = c.dispatch(method_call, method_params);
+ Object result = response.get("Value");
+ return Types.toLong(result);
+ }
+
+}
\ No newline at end of file