Ok, several points.
Bear in mind that I have not used MPICH (I use LAM/MPI)
And I'm not familiar with GTK, but I'm not really going to go through
all the nitty gritty details of your code ;-)
As I understand, you have a GUI up only on the manager node.
After the user enters the path to a file and clicks the execute
button, you want to perform the broadcast..
Assuming gtk_main () is anything like glut_main (), it's going to go
into an infinite loop that handles everything.. user input and all...
This means the manager node will never get to its while (1) infinite
loop until AFTER gtk_main () ends.. ie. the gui terminates..
What you want to do is issue the broadcast from within the callback of
your execute button..
So assuming "button2" is the execute button, you'll want to get rid of
the inifinite while loop in the manager node, and do something like
this instead:
gint button2_click(GtkWidget *widget,gpointer gdata)
{
printf("I am here %d %s %s!\n", sizeof(gdata), gdata, (char
*)gtk_entry_get_text(GTK_ENTRY(QueryWord)));
strcpy(Query_FileName , (char *)gtk_entry_get_text(GTK_ENTRY(QueryWord)));
/* Issue your MPI commands.. */
MPI_Bcast( Query_FileName, strlen(Query_FileName), MPI_CHAR, 0,
MPI_COMM_WORLD );/*processor-0 broadcast*/
return(FALSE);
}
You should probably also check the Query_FileName to make sure the
file exists (I guess you should also to do that on every slave
node...)
Remember to call MPI_Finalize () on every node once you're done with
the program and want to exit...
In summation:
Get rid of the while(1) loop on the manager.
Put the manager's MPI_Bcast () in the execution button's callback.
The slaves keep their infinite loop.
Call MPI_Finalize () on every node before quitting.
Hope that helps.
On 6/13/07, chenyong <cy163_at_[hidden]> wrote:
> Hello all,
> i am programming using MPICH + C++ and Gtk. I using Gtk to create the
> interactive interface (frontend), by which users can specify afile to be
> processed by the parallelized program coded in MPICH and C++ (backend).
> My problem arised with the combination of the three programming languages.
>
> On the GUI, there is a button to bring up a File Open dialog for user
> selecting a file from the file system. The path of the selected filewill be
> displayed in a text box. Once users have selected a file Users can pass the
> file name to the parallelized program by click another button (Execution
> Button).
> In current design, the GUI is only used with one processor 'processor-0'.
> That is, 'processor-0' is responsible to accept users' input of the selected
> fileThen, it MPI_Bcast() the file path to other processors. As soon as ALL
> processors receive the file path, the parallelized process starts.
> I can sucessfully bring up the GUI and select a file, showing the file path
> on the text box. However, when I press the Execution button, the
> parallelized process cannot continue unless I close the GUI. It seems that
> the execution control held by the Gtk program failed to be shifted to the
> parallelized program.
> the code is as follows:
> GtkWidget *QueryWord;char Query_FileName[300] = "";
> // ###### button2_click for assign the content of QueryWord to the global
> variable Query_FileNamegint button2_click(GtkWidget *widget,gpointer gdata){
> printf("I am here %d %s %s!\n", sizeof(gdata), gdata, (char
> *)gtk_entry_get_text(GTK_ENTRY(QueryWord))); strcpy(Query_FileName , (char
> *)gtk_entry_get_text(GTK_ENTRY(QueryWord))); return(FALSE);}//
> button_click for bring up the File Open dialog for selecting a file to be
> processedgint button_click(GtkWidget *widget,gpointer gdata){ GtkWidget
> *dialog; dialog = gtk_file_chooser_dialog_new ("Open File",
> GTK_WINDOW(gdata), GTK_FILE_CHOOSER_ACTION_OPEN, GTK_STOCK_CANCEL,
> GTK_RESPONSE_CANCEL, GTK_STOCK_OPEN, GTK_RESPONSE_ACCEPT, NULL); if
> (gtk_dialog_run (GTK_DIALOG (dialog)) == GTK_RESPONSE_ACCEPT) { char
> *filename; filename = gtk_file_chooser_get_filename (GTK_FILE_CHOOSER
> (dialog)); gtk_entry_set_text(GTK_ENTRY(QueryWord),
> g_locale_to_utf8(filename,-1,NULL,NULL,NULL)); printf("%s\n", filename);
> g_free (filena!
> me); } gtk_widget_destroy (dialog); return(FALSE);}
> int main(int argc, char *argv[]){
>
> int i; int myid, numprocs; char Query_FileName[1000]="";
> double startwtime = 0.0, endwtime; int namelen; char
> processor_name[MPI_MAX_PROCESSOR_NAME]; MPI_Init(&argc,&argv); //MPI
> MPI_Comm_size(MPI_COMM_WORLD,&numprocs); //MPI
> MPI_Comm_rank(MPI_COMM_WORLD,&myid); //MPI
> MPI_Get_processor_name(processor_name,&namelen); //MPI
> if (myid ==0) { GtkWidget *window; GtkWidget *table; /*Table*/
> GtkWidget *button, *button2; /*Button */ GtkWidget *label;
> gtk_init(&argc,
> &argv);//<============================================================
> window = gtk_window_new(GTK_WINDOW_TOPLEVEL);
> gtk_widget_set_size_request(window,1000,800);
> g_signal_connect(GTK_OBJECT(window),"destroy",G_CALLBACK(gtk_main_quit),NULL);
> table=gtk_table_new(8,8,TRUE); /*create a new table*/
> QueryWord=gtk_entry_new();/*create a text box*/
> gtk_table_attach(GTK_TABLE(table),
> QueryWord,1,7,1,2,GTK_FILL,GTK_FILL,0,0);/*add label*/
> gtk_widget_show(QueryWord);; /*show label*/
> button=gtk_button_new_with_label(g_locale_to_utf8("SEAsea",-1,NULL,NULL,NULL));
> gtk_table_attach(GTK_TABLE(table),button,2,4,2,3,GTK_FILL,GTK_FILL,0,0);
> gtk_widget_show(button);
> gtk_signal_connect(GTK_OBJECT(button),"clicked",GTK_SIGNAL_FUNC(button_click),window);
> button2=gtk_button_new_with_label(g_locale_to_utf8("Ocean",-1,N!
> ULL,NULL,NULL));
> gtk_table_attach(GTK_TABLE(table),button2,5,7,2,3,GTK_FILL,GTK_FILL,0,0);
> gtk_widget_show(button2);
> gtk_signal_connect(GTK_OBJECT(button2),"clicked",GTK_SIGNAL_FUNC(button2_click),(void*)gtk_entry_get_text(GTK_ENTRY(QueryWord)));
> gtk_container_add(GTK_CONTAINER(window),table); /*add table to window*/
> gtk_widget_show(table); /*show table*/ gtk_widget_show(window);
> gtk_main();// it seems that the solution to this question is to find a way
> of how to shift between gtk_main() and main(int argc, char *argv[])
> } if(myid == 0) { while(1)// wait Query_FileName is assigned by the
> user on GUI { if(strlen(Query_FileName) > 0) { MPI_Bcast(
> Query_FileName, strlen(Query_FileName), MPI_CHAR, 0, MPI_COMM_WORLD
> );/*processor-0 broadcast*/ break; } } } else {
> while(1) //wait processor-0 broadcast Query_FileName {
> if(strlen(Query_FileName) == 0) { MPI_Bcast( Query_FileName,
> strlen(Query_FileName), MPI_CHAR, 0, MPI_COMM_WORLD );/*processor-xxx
> receive data*/
> } else { break; } } }
> _________________________________________________________________
> ÖйúÊ®´óÈÈÃÅÂÃÓξ°µã
> http://search.msn.com/results.aspx?q=%E4%B8%AD%E5%9B%BD%E5%8D%81%E5%A4%A7%E9%A3%8E%E6%99%AF&mkt=zh-CN&form=QBRE
--
(N)E
|
