X-Git-Url: https://rtime.felk.cvut.cz/gitweb/orte.git/blobdiff_plain/fb4333963da906f0c4e053cf1d42a0134d67ffe4..3b7435b13a7df0f58e75eeb0fca137ad0fff879c:/orte/java/src/org/ocera/orte/Domain.java diff --git a/orte/java/src/org/ocera/orte/Domain.java b/orte/java/src/org/ocera/orte/Domain.java index 962a0f9..1a1dead 100644 --- a/orte/java/src/org/ocera/orte/Domain.java +++ b/orte/java/src/org/ocera/orte/Domain.java @@ -1,8 +1,4 @@ -/** Domain.java */ -package org.ocera.orte; - -import org.ocera.orte.types.*; -//import org.ocera.orte.tools.CheckType; +/* Domain.java */ /** * Class Domain provides methods for work with the ORTE domain. @@ -25,6 +21,9 @@ import org.ocera.orte.types.*; * */ +package org.ocera.orte; +import org.ocera.orte.types.*; + public class Domain { @@ -33,260 +32,36 @@ public class Domain { System.loadLibrary("jorte"); } - + /* domain fields */ protected int handle; public DomainProp props; public DomainEvents events; - // je to tu spravne???????????????????????????????????????????????? - - - /** - * constructor that creates default domain - * domain = ORTE_DEFAULT_DOMAIN - * suspended thread = false - */ + /* constructor */ public Domain() { // initialization of ORTE layer JOrte.init(); - System.out.println(":j: executed JOrte.init().."); - // this.handle =jORTEDomainDefaultAppCreate(ORTEConstant.ORTE_DEFAULT_DOMAIN,true); - uspane vlakno po startu - this.handle =jORTEDomainDefaultAppCreate(ORTEConstant.ORTE_DEFAULT_DOMAIN,false); - if(this.handle == 0) System.out.println(":j!: zero domain handle! .."); - } - - - /** - * constructor - * - */ - public Domain(int domain, DomainProp ps, DomainEvents ev, boolean suspend) - { - - // initialization of ORTE layer - JOrte.init(); - System.out.println(":j: executed JOrte.init().."); - // set Default Domain Properties - if(ps == null) { - this.props = DomainProp.defaultPropsCreate(); - } - else { - this.props = ps; - } - // init Domain Events - if(ev == null) { - this.events = DomainEvents.init(); - } - else { - this.events = ev; - } - this.handle = jORTEDomainAppCreate(domain,ps.handle,ev.handle,suspend); - if(this.handle == 0) System.out.println(":j!: zero domain handle! .."); + //System.out.println(":j: instance of 'Domain' created .."); } /** - * destructor - * - */ - protected void finalize() - { - if(!destroyAllRegTypes()) System.out.println(":j!: destroyAllRegTypes fault.."); - if(!destroy()) System.out.println(":j!: ORTEDomainADestroy fault.."); - } - - - /** - * getHandle - returns a handle of the domain - * - * @return handler of the domain + * Get handle of the Application Domain. + * @return Handle of the Application Domain. */ public int getHandle() { return this.handle; } - /** - * getDomain - returns a handle of the domain - * - * - * @param d given instance of Domain - * @param jp_ORTEDomainProp address from C pointer - * @return handler of the domain - */ - public boolean destroy() - { - if (jORTEDomainADestroy(this.handle)) return true; - return false; - } - - /** - * regNewDataType - - * - * - * @param - * @param - * @param - * @param - * @return - */ - public - boolean regNewDataType(String name, - // serial, deserial, - long maxlength) - { - int b = jORTETypeRegisterAdd(handle, name, - // serial, deserial, - maxlength); - if (b == ORTEConstant.ORTE_BAD_HANDLE) - { - System.out.println(":!j: regNewDataType() - bad domain handle!"); - return false; - } - if (b == ORTEConstant.ORTE_OK) - { - System.out.println(":j: ORTE_OK - regNewDataType().."); - return true; - } - - return false; - } - - - - /** - * destroyAllRegTypes - destroys all previous registered data types. - * - * - * @return boolean value, False when some error occures, otherwise True - */ - public - boolean destroyAllRegTypes() - { - if (jORTETypeRegisterDestroyAll(this.handle)) return true; - return false; - } - - - /** - * createSubscription - - * - * - * @param - * @param - * @param - * @param - * @return - */ - public - Subscription createSubscription(int subsmode, - int substype, - String topic, - String typeName, - int bufflength, - NtpTime deadline, - NtpTime minSeparation, - SubscriptionCallback cb, - /* recvCallBack */ - /* recvCallBackParam*/ - long multicastIP) - { - Subscription s = new Subscription(this, - subsmode, - substype, - topic, - typeName, - bufflength, - deadline, - minSeparation, - cb, - multicastIP); - return s; - } - - - - - /** - * createPublication - - * - * - * @param - * @param - * @param - * @param - * @return - */ - public - Publication createPublication (String topic, - org.ocera.orte.types.MessageData instance, - NtpTime persistence, - int strength) - { - System.out.println(":j: vytvarim publikaci pro DataType: " + instance.getType()); - Publication p = new Publication(this, - topic, - instance, - persistence, - strength); - return p; - } - - - /* ****************************************************************** * * * * native methods * * * * ****************************************************************** */ - /** - * jORTEDomainAppCreate - creates an default application object within given - * domain, returns handle to created object (from C environment), - * NULL in case of any error. - * - * - * @param domain given domain - * @return addres value (from C environment) of the created domain - */ - private static native - int jORTEDomainDefaultAppCreate(int domain,boolean suspend); - - - /** - * jORTEDomainAppCreate - creates an application object within given - * domain, returns handle to created object (from C environment), - * NULL in case of any error. - * - * - * @param domain given domain - * @param handler for C pointer to ORTEDomainProps - * @param handler for C pointer to ORTEDomainEvents - * @param suspended specifies whether threads of this application should be started as well (False) or stay suspended (True) - * @return addres value (from C environment) of the created domain - */ - - private static native - int jORTEDomainAppCreate(int domain, - int propHandle, - int eventsHandle, - boolean suspend); - - - /** - * jORTEDomainADestroy - destroys all application objects in specified - * domain, returns False if some error occures otherwise returns True. - * - * - * @param jp_domhandle handler to domain - * @return boolean value, False when some error occures, otherwise True - */ - private static native - boolean jORTEDomainADestroy(int dhandle); - - /** * jORTEDomainStart - * @@ -300,42 +75,4 @@ public class Domain { boolean recvMetatrafficThread, boolean recvUserDataThread, boolean sendThread); - - - /** - * jORTETypeRegisterAdd - register new data type. - * - * - * @param dhandle handler to domain - * @param - * @param - * @param - * @return - */ - private static native - int jORTETypeRegisterAdd(int dhandle, - String typeName, - // serial, - // deserial, - long maxlenght); - - - /** - * jORTETypeRegisterDestroyAll - destroys all previous registered data types. - * - * - * @param dhandle handler to domain - * @return boolean value, False when some error occures, otherwise True - */ - private static native - boolean jORTETypeRegisterDestroyAll(int dhandle); - - -/* ****************************************************************** */ - - - - - } -