pyMPI error on mpi.barrier

2009-05-09 Thread Dina Ali
Hello there

I am trying to paralleize GA code using pyMPI. part of the code and and the
error message is as below.
i write the new positions in a file by root (which is mpi.rank = 0) then
other processes are suppose to wait
until the written in the file finishes to start evaluating the objective.
the problem arises in the barrier method...
any ideas on how to do this would be very much appreciated..

for i in xrange(max_iter):
if (mpi.rank == 0):
update_positions()
save_GA_pops_iter()

mpi.barrier()   error is here
evaluate_objective()
mpi.barrier()

error message:
mpi.barrier()
mpi.MPIError: MPI_Error_string: invalid communicator: Input/output error
(pyMPI_comm_io.c:367)


Thanks very much
Dina
--
http://mail.python.org/mailman/listinfo/python-list


pyMPI error on mpi.barrier

2009-05-09 Thread Dina Ali
Hello there

I am trying to paralleize GA code using pyMPI. part of the code and and the
error message is as below.
i write the new positions in a file by root (which is mpi.rank = 0) then
other processes are suppose to wait
until the written in the file finishes to start evaluating the objective.
the problem arises in the barrier method...
any ideas on how to do this would be very much appreciated..

for i in xrange(max_iter):
if (mpi.rank == 0):
update_positions()
save_GA_pops_iter()

mpi.barrier()   error is here
evaluate_objective()
mpi.barrier()

error message:
mpi.barrier()
mpi.MPIError: MPI_Error_string: invalid communicator: Input/output error
(pyMPI_comm_io.c:367)


Thanks very much
Dina
--
http://mail.python.org/mailman/listinfo/python-list


pyMPI error on mpi.barrier

2009-05-09 Thread Dina Ali
Hello there

I am trying to paralleize GA code using pyMPI. part of the code and and the
error message is as below.
i write the new positions in a file by root (which is mpi.rank = 0) then
other processes are suppose to wait
until the written in the file finishes to start evaluating the objective.
the problem arises in the barrier method...
any ideas on how to do this would be very much appreciated..

for i in xrange(max_iter):
if (mpi.rank == 0):
update_positions()
save_GA_pops_iter()

mpi.barrier()   error is here
evaluate_objective()
mpi.barrier()

error message:
mpi.barrier()
mpi.MPIError: MPI_Error_string: invalid communicator: Input/output error
(pyMPI_comm_io.c:367)


Thanks very much
Dina
--
http://mail.python.org/mailman/listinfo/python-list


pyMPI error on mpi.barrier()

2009-05-07 Thread Dina Ali
Hello there

I am trying to paralleize GA code using pyMPI. part of the code and and the
error message is as below.
i write the new positions in a file by root (which is mpi.rank = 0) then
other processes are suppose to wait
until the written in the file finishes to start evaluating the objective.
the problem arises in the barrier method...
any ideas on how to do this would be very much appreciated..

Thanks very much
Dina

for i in xrange(max_iter):
if (mpi.rank == 0):
update_positions()
save_pso_pops_iter()

mpi.barrier()  error is here
evaluate_objective()
mpi.barrier()

error message:
mpi.barrier()
mpi.MPIError: MPI_Error_string: invalid communicator: Input/output error
(pyMPI_comm_io.c:367)
--
http://mail.python.org/mailman/listinfo/python-list


pympi and threading in python

2008-08-11 Thread Dina Ali
Hello there

I am confused in the usage/differences of pympi and threading in python.
What I want to do it to run multiple MCMC simulations by dividing the number
of the chains I want to run on number of the processors available. Some
methods need to be synchronized/locked until some addition operation is
finished.

I will be very grateful if some one could help.

Thanks very much

Dina
--
http://mail.python.org/mailman/listinfo/python-list