Changeset 3696

Timestamp:

05/07/07 13:46:17 (6 years ago)

Author:

DrewCormier

Message:

copied over port connection stuff from plot tool since i am receiving data instead of sending data. changed from graph structure class instance to write to file class instance. might not work completely

Files:

• experimental/write_to_file/trunk/write_to_file/write_to_file.py (modified) (4 diffs)

experimental/write_to_file/trunk/write_to_file/write_to_file.py

@@ -15 +15 @@
     #TODO:add comment explainging this class
 
-    def __init__(self, parent):        
-        self.parent = parent
-
-    def write(self, data, file_name):
+    def __init__(self, orb, gui):        
+        self.orb = orb
+        self.gui = gui
+
+    def pushPacket(self, data, file_name):
         #TODO: test this method
         open_file = open(file_name, 'w')   #open the file for writing
@@ -163 +164 @@
              sys.exit(1)
          name = [CosNaming.NameComponent(self.component_name[0],""),
-         CosNaming.NameComponent(self.component_name[1],""),
-         CosNaming.NameComponent(self.component_name[2],"")]
+             CosNaming.NameComponent(self.component_name[1],""),
+             CosNaming.NameComponent(self.component_name[2],"")]
      
          try:
@@ -173 +174 @@
              sys.exit(1)
      
-         #connect to an existing port
          ResourceHandle = ResourceRef._narrow(CF.Resource)
          PortReference = ResourceHandle.getPort(self.port_name)
          if PortReference is None:
              print "Failed to get Port reference"
-         self.PortHandle = PortReference._narrow(standardInterfaces__POA.complexShort)
+         self.PortHandle = PortReference._narrow(CF.Port)
          
+        
+         #create the class instance of the write_to_file class 
+         self.my_file_writer = write_to_file(self.orb, self)
+
+         obj_poa = self.orb.resolve_initial_references("RootPOA")
+         poaManager = obj_poa._get_the_POAManager()
+         poaManager.activate()
+         obj_poa.activate_object(self.my_file_writer)
+         self.PortHandle.connectPort(self.my_file_writer._this(), "thisismyconnectionid_w2file")
+         #orb.run()
+
     def OnCloseWindow(self,event):
         if hasattr(self.parent, 'removeToolFrame'):
@@ -186 +197 @@
         event.Skip()
 
-
-
-
+    def __del__(self):
+        if self.CORBA_being_used:
+            self.PortHandle.disconnectPort("thisismyconnectionid_plot")
+            while (_time.time() - self.my_local_plot.end_time) < 1.5:
+                #print (time.time() - self.my_local_plot.end_time)
+                pass
+                #_time.sleep(1)
+
+
+