SCT DAQ/DCS Software - Java: _ArchivingServiceInterfaceStub.java Source File

00001 package ArchivingServiceI;
00002 
00003 
00011 public class _ArchivingServiceInterfaceStub extends org.omg.CORBA.portable.ObjectImpl implements ArchivingServiceI.ArchivingServiceInterface
00012 {
00013 
00014 
00018   public void archiveISName (String isName)
00019   {
00020             org.omg.CORBA.portable.InputStream $in = null;
00021             try {
00022                 org.omg.CORBA.portable.OutputStream $out = _request ("archiveISName", false);
00023                 $out.write_string (isName);
00024                 $in = _invoke ($out);
00025                 return;
00026             } catch (org.omg.CORBA.portable.ApplicationException $ex) {
00027                 $in = $ex.getInputStream ();
00028                 String _id = $ex.getId ();
00029                 throw new org.omg.CORBA.MARSHAL (_id);
00030             } catch (org.omg.CORBA.portable.RemarshalException $rm) {
00031                 archiveISName (isName        );
00032             } finally {
00033                 _releaseReply ($in);
00034             }
00035   } // archiveISName
00036 
00037 
00039   public void retrieveISName (String isName)
00040   {
00041             org.omg.CORBA.portable.InputStream $in = null;
00042             try {
00043                 org.omg.CORBA.portable.OutputStream $out = _request ("retrieveISName", false);
00044                 $out.write_string (isName);
00045                 $in = _invoke ($out);
00046                 return;
00047             } catch (org.omg.CORBA.portable.ApplicationException $ex) {
00048                 $in = $ex.getInputStream ();
00049                 String _id = $ex.getId ();
00050                 throw new org.omg.CORBA.MARSHAL (_id);
00051             } catch (org.omg.CORBA.portable.RemarshalException $rm) {
00052                 retrieveISName (isName        );
00053             } finally {
00054                 _releaseReply ($in);
00055             }
00056   } // retrieveISName
00057 
00058 
00060   public void retrieveArchName (String archivingName)
00061   {
00062             org.omg.CORBA.portable.InputStream $in = null;
00063             try {
00064                 org.omg.CORBA.portable.OutputStream $out = _request ("retrieveArchName", false);
00065                 $out.write_string (archivingName);
00066                 $in = _invoke ($out);
00067                 return;
00068             } catch (org.omg.CORBA.portable.ApplicationException $ex) {
00069                 $in = $ex.getInputStream ();
00070                 String _id = $ex.getId ();
00071                 throw new org.omg.CORBA.MARSHAL (_id);
00072             } catch (org.omg.CORBA.portable.RemarshalException $rm) {
00073                 retrieveArchName (archivingName        );
00074             } finally {
00075                 _releaseReply ($in);
00076             }
00077   } // retrieveArchName
00078 
00079 
00081   public void retrieve (String runNumber, String scanNumber, String className, String specifier)
00082   {
00083             org.omg.CORBA.portable.InputStream $in = null;
00084             try {
00085                 org.omg.CORBA.portable.OutputStream $out = _request ("retrieve", false);
00086                 $out.write_string (runNumber);
00087                 $out.write_string (scanNumber);
00088                 $out.write_string (className);
00089                 $out.write_string (specifier);
00090                 $in = _invoke ($out);
00091                 return;
00092             } catch (org.omg.CORBA.portable.ApplicationException $ex) {
00093                 $in = $ex.getInputStream ();
00094                 String _id = $ex.getId ();
00095                 throw new org.omg.CORBA.MARSHAL (_id);
00096             } catch (org.omg.CORBA.portable.RemarshalException $rm) {
00097                 retrieve (runNumber, scanNumber, className, specifier        );
00098             } finally {
00099                 _releaseReply ($in);
00100             }
00101   } // retrieve
00102 
00103 
00107   public void setCompressionLevel (short level)
00108   {
00109             org.omg.CORBA.portable.InputStream $in = null;
00110             try {
00111                 org.omg.CORBA.portable.OutputStream $out = _request ("setCompressionLevel", false);
00112                 $out.write_short (level);
00113                 $in = _invoke ($out);
00114                 return;
00115             } catch (org.omg.CORBA.portable.ApplicationException $ex) {
00116                 $in = $ex.getInputStream ();
00117                 String _id = $ex.getId ();
00118                 throw new org.omg.CORBA.MARSHAL (_id);
00119             } catch (org.omg.CORBA.portable.RemarshalException $rm) {
00120                 setCompressionLevel (level        );
00121             } finally {
00122                 _releaseReply ($in);
00123             }
00124   } // setCompressionLevel
00125 
00126   public short getCompressionLevel ()
00127   {
00128             org.omg.CORBA.portable.InputStream $in = null;
00129             try {
00130                 org.omg.CORBA.portable.OutputStream $out = _request ("getCompressionLevel", true);
00131                 $in = _invoke ($out);
00132                 short $result = $in.read_short ();
00133                 return $result;
00134             } catch (org.omg.CORBA.portable.ApplicationException $ex) {
00135                 $in = $ex.getInputStream ();
00136                 String _id = $ex.getId ();
00137                 throw new org.omg.CORBA.MARSHAL (_id);
00138             } catch (org.omg.CORBA.portable.RemarshalException $rm) {
00139                 return getCompressionLevel (        );
00140             } finally {
00141                 _releaseReply ($in);
00142             }
00143   } // getCompressionLevel
00144 
00145 
00146   // IO configuration
00147   public void setRetrieveIsServer (String serverName)
00148   {
00149             org.omg.CORBA.portable.InputStream $in = null;
00150             try {
00151                 org.omg.CORBA.portable.OutputStream $out = _request ("setRetrieveIsServer", false);
00152                 $out.write_string (serverName);
00153                 $in = _invoke ($out);
00154                 return;
00155             } catch (org.omg.CORBA.portable.ApplicationException $ex) {
00156                 $in = $ex.getInputStream ();
00157                 String _id = $ex.getId ();
00158                 throw new org.omg.CORBA.MARSHAL (_id);
00159             } catch (org.omg.CORBA.portable.RemarshalException $rm) {
00160                 setRetrieveIsServer (serverName        );
00161             } finally {
00162                 _releaseReply ($in);
00163             }
00164   } // setRetrieveIsServer
00165 
00166   public String getRetrieveIsServer ()
00167   {
00168             org.omg.CORBA.portable.InputStream $in = null;
00169             try {
00170                 org.omg.CORBA.portable.OutputStream $out = _request ("getRetrieveIsServer", true);
00171                 $in = _invoke ($out);
00172                 String $result = $in.read_string ();
00173                 return $result;
00174             } catch (org.omg.CORBA.portable.ApplicationException $ex) {
00175                 $in = $ex.getInputStream ();
00176                 String _id = $ex.getId ();
00177                 throw new org.omg.CORBA.MARSHAL (_id);
00178             } catch (org.omg.CORBA.portable.RemarshalException $rm) {
00179                 return getRetrieveIsServer (        );
00180             } finally {
00181                 _releaseReply ($in);
00182             }
00183   } // getRetrieveIsServer
00184 
00185 
00187   public void suspendCallbacks (boolean doSuspend)
00188   {
00189             org.omg.CORBA.portable.InputStream $in = null;
00190             try {
00191                 org.omg.CORBA.portable.OutputStream $out = _request ("suspendCallbacks", true);
00192                 $out.write_boolean (doSuspend);
00193                 $in = _invoke ($out);
00194                 return;
00195             } catch (org.omg.CORBA.portable.ApplicationException $ex) {
00196                 $in = $ex.getInputStream ();
00197                 String _id = $ex.getId ();
00198                 throw new org.omg.CORBA.MARSHAL (_id);
00199             } catch (org.omg.CORBA.portable.RemarshalException $rm) {
00200                 suspendCallbacks (doSuspend        );
00201             } finally {
00202                 _releaseReply ($in);
00203             }
00204   } // suspendCallbacks
00205 
00206 
00208   public String status ()
00209   {
00210             org.omg.CORBA.portable.InputStream $in = null;
00211             try {
00212                 org.omg.CORBA.portable.OutputStream $out = _request ("status", true);
00213                 $in = _invoke ($out);
00214                 String $result = $in.read_string ();
00215                 return $result;
00216             } catch (org.omg.CORBA.portable.ApplicationException $ex) {
00217                 $in = $ex.getInputStream ();
00218                 String _id = $ex.getId ();
00219                 throw new org.omg.CORBA.MARSHAL (_id);
00220             } catch (org.omg.CORBA.portable.RemarshalException $rm) {
00221                 return status (        );
00222             } finally {
00223                 _releaseReply ($in);
00224             }
00225   } // status
00226 
00227   public short busy ()
00228   {
00229             org.omg.CORBA.portable.InputStream $in = null;
00230             try {
00231                 org.omg.CORBA.portable.OutputStream $out = _request ("busy", true);
00232                 $in = _invoke ($out);
00233                 short $result = $in.read_short ();
00234                 return $result;
00235             } catch (org.omg.CORBA.portable.ApplicationException $ex) {
00236                 $in = $ex.getInputStream ();
00237                 String _id = $ex.getId ();
00238                 throw new org.omg.CORBA.MARSHAL (_id);
00239             } catch (org.omg.CORBA.portable.RemarshalException $rm) {
00240                 return busy (        );
00241             } finally {
00242                 _releaseReply ($in);
00243             }
00244   } // busy
00245 
00246   public short queueLength ()
00247   {
00248             org.omg.CORBA.portable.InputStream $in = null;
00249             try {
00250                 org.omg.CORBA.portable.OutputStream $out = _request ("queueLength", true);
00251                 $in = _invoke ($out);
00252                 short $result = $in.read_short ();
00253                 return $result;
00254             } catch (org.omg.CORBA.portable.ApplicationException $ex) {
00255                 $in = $ex.getInputStream ();
00256                 String _id = $ex.getId ();
00257                 throw new org.omg.CORBA.MARSHAL (_id);
00258             } catch (org.omg.CORBA.portable.RemarshalException $rm) {
00259                 return queueLength (        );
00260             } finally {
00261                 _releaseReply ($in);
00262             }
00263   } // queueLength
00264 
00265   public void get_info (ipc.InfoHolder inf)
00266   {
00267             org.omg.CORBA.portable.InputStream $in = null;
00268             try {
00269                 org.omg.CORBA.portable.OutputStream $out = _request ("get_info", true);
00270                 $in = _invoke ($out);
00271                 inf.value = ipc.InfoHelper.read ($in);
00272                 return;
00273             } catch (org.omg.CORBA.portable.ApplicationException $ex) {
00274                 $in = $ex.getInputStream ();
00275                 String _id = $ex.getId ();
00276                 throw new org.omg.CORBA.MARSHAL (_id);
00277             } catch (org.omg.CORBA.portable.RemarshalException $rm) {
00278                 get_info (inf        );
00279             } finally {
00280                 _releaseReply ($in);
00281             }
00282   } // get_info
00283 
00284   public void destroy ()
00285   {
00286             org.omg.CORBA.portable.InputStream $in = null;
00287             try {
00288                 org.omg.CORBA.portable.OutputStream $out = _request ("destroy", false);
00289                 $in = _invoke ($out);
00290                 return;
00291             } catch (org.omg.CORBA.portable.ApplicationException $ex) {
00292                 $in = $ex.getInputStream ();
00293                 String _id = $ex.getId ();
00294                 throw new org.omg.CORBA.MARSHAL (_id);
00295             } catch (org.omg.CORBA.portable.RemarshalException $rm) {
00296                 destroy (        );
00297             } finally {
00298                 _releaseReply ($in);
00299             }
00300   } // destroy
00301 
00302   // Type-specific CORBA::Object operations
00303   private static String[] __ids = {
00304     "IDL:ArchivingServiceI/ArchivingServiceInterface:1.0", 
00305     "IDL:ipc/freeable:1.0"};
00306 
00307   public String[] _ids ()
00308   {
00309     return (String[])__ids.clone ();
00310   }
00311 
00312   private void readObject (java.io.ObjectInputStream s) throws java.io.IOException
00313   {
00314      String str = s.readUTF ();
00315      String[] args = null;
00316      java.util.Properties props = null;
00317      org.omg.CORBA.Object obj = org.omg.CORBA.ORB.init (args, props).string_to_object (str);
00318      org.omg.CORBA.portable.Delegate delegate = ((org.omg.CORBA.portable.ObjectImpl) obj)._get_delegate ();
00319      _set_delegate (delegate);
00320   }
00321 
00322   private void writeObject (java.io.ObjectOutputStream s) throws java.io.IOException
00323   {
00324      String[] args = null;
00325      java.util.Properties props = null;
00326      String str = org.omg.CORBA.ORB.init (args, props).object_to_string (this);
00327      s.writeUTF (str);
00328   }
00329 } // class _ArchivingServiceInterfaceStub