Gary, It might be important to note that the code that you commented out was actually grid computing code rather than threading code. Unfortunately I called my grid computing code 'threading'! Half of it could probably kept as is although relabelled to 'grid'. For example the 'threading' user function class which sets up grid computing. In the future I'll probably want to use my algorithm for handling very slow machines on a grid (which avoids relax having to wait for a slow machine to terminate) and the setting up of slave relax processes (using the 'relax --thread' invocation). Although the grid computing code is currently broken, this is only because there is a problem with the handling of SSH tunnel breakages. I also have in mind some optimisations for minimising data flow through the tunnel and Andrew Perry has had ideas about using heartbeats from the grid machine relax processes to probe for dead tunnels and processes.
The model-free threads, which are true threads, could possibly also be kept and utilised by the MPI implementation. They could be optimised though and any grid computing code separated from it. Cheers, Edward On 3/19/07, [EMAIL PROTECTED] <[EMAIL PROTECTED]> wrote:
Author: varioustoxins Date: Mon Mar 19 11:58:24 2007 New Revision: 3236 URL: http://svn.gna.org/viewcvs/relax?rev=3236&view=rev Log: marked more threading code for reletion Modified: branches/multi_processor/relax Modified: branches/multi_processor/relax URL: http://svn.gna.org/viewcvs/relax/branches/multi_processor/relax?rev=3236&r1=3235&r2=3236&view=diff ============================================================================== --- branches/multi_processor/relax (original) +++ branches/multi_processor/relax Mon Mar 19 11:58:24 2007 @@ -171,23 +171,25 @@ # Run the interpreter. self.interpreter = Interpreter(self) self.interpreter.run() - + print 'exit' + + # FIXME no more threading # Threading mode. - elif mode == 'thread': - # Print the PID prior to IO redirection, and then flush the buffer to send it to the parent. - print self.pid - sys.stdout.flush() - - # Logging (silent IO redirection). - if self.log_file: - self.IO.log(log_file, print_flag=0) - - # Tee (silent IO redirection). - elif self.tee_file: - self.IO.tee(tee_file, print_flag=0) - - # Execute the script. - self.threading.execute() +# elif mode == 'thread': +# # Print the PID prior to IO redirection, and then flush the buffer to send it to the parent. +# print self.pid +# sys.stdout.flush() +# +# # Logging (silent IO redirection). +# if self.log_file: +# self.IO.log(log_file, print_flag=0) +# +# # Tee (silent IO redirection). +# elif self.tee_file: +# self.IO.tee(tee_file, print_flag=0) +# +# # Execute the script. +# self.threading.execute() # Execute the relax test suite elif mode == 'test suite': @@ -553,8 +555,8 @@ module_path = '.'.join(('multi',processor_name)) - modules = import_module(module_path,verbose=True) - print modules + modules = import_module(module_path) + #print modules if hasattr(modules[-1],class_name): clazz = getattr(modules[-1], class_name) else: _______________________________________________ relax (http://nmr-relax.com) This is the relax-commits mailing list [email protected] To unsubscribe from this list, get a password reminder, or change your subscription options, visit the list information page at https://mail.gna.org/listinfo/relax-commits
_______________________________________________ relax (http://nmr-relax.com) This is the relax-devel mailing list [email protected] To unsubscribe from this list, get a password reminder, or change your subscription options, visit the list information page at https://mail.gna.org/listinfo/relax-devel
