N-sim Emulation and simulation of Wireless Sensor Networks    Home    Project Page    Download    CVS    Installation    Configuration    Plug-ins  Hosted by

/home/brennan/n-sim/OrbisQuartus/server/xen/mini_mpi-xen.c Go to the documentation of this file. /* * Copyright 2007. Los Alamos National Security, LLC. This material * was produced under U.S. Government contract DE-AC52-06NA25396 for * Los Alamos National Laboratory (LANL), which is operated by Los * Alamos National Security, LLC, for the Department of Energy. The * U.S. Government has rights to use, reproduce, and distribute this * software. NEITHER THE GOVERNMENT NOR LOS ALAMOS NATIONAL SECURITY, * LLC, MAKES ANY WARRANTY, EXPRESS OR IMPLIED, OR ASSUMES ANY LEGAL * LIABILITY FOR THE USE OF THIS SOFTWARE. If software is modified to * produce derivative works, such modified software should be clearly * marked, so as not to confuse it with the version available from LANL. * * Additionally, this program is free software; you can redistribute * it and/or modify it under the terms of the GNU General Public * License as published by the Free Software Foundation; version 2 of * the License. Accordingly, this program is distributed in the hope * it will be useful, but WITHOUT ANY WARRANTY; without even the * implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR * PURPOSE. See the GNU General Public License for more details. */ #include <stdio.h> #include <stdlib.h> #include <string.h> #include <errno.h> #include <sys/types.h> #include <sys/socket.h> #include <arpa/inet.h> #include <netdb.h> #include <mini_mpi.h> #include <mini_mpi-internal.h> extern int my_numprocs = 0; extern int my_taskid = 0; extern unsigned short my_init = 0; extern struct sockaddr_in head_addr; extern socket_ptr_t my_socket; extern task_t *task_array; #define MY_SOCK (my_socket.fd) int MPI_Init(int *argc, char ***argv) { int error, bcast, numbytes, broadcast = 1; struct sockaddr_in their_addr; struct hostent *he; char msg_out[32]; char msg_in[1024]; int header; socklen_t head_size; char *table; sprintf(msg_out, "%d", MINI_MPI_INIT); if ((he = gethostbyname("255.255.255.255")) == NULL) { herror("gethostbyname"); return h_errno; } if ((bcast = socket(AF_INET, SOCK_DGRAM, 0)) < 0) { perror("socket"); return bcast; } if ((error = setsockopt(bcast, SOL_SOCKET, SO_BROADCAST, &broadcast, sizeof(broadcast))) < 0) { perror("setsockopt (SO_BROADCAST)"); return error; } their_addr.sin_family = AF_INET; their_addr.sin_port = htons(MPI_INIT_PORT); their_addr.sin_addr = *((struct in_addr *)he->h_addr); memset(their_addr.sin_zero, '\0', sizeof their_addr.sin_zero); if ((numbytes = sendto(bcast, msg_out, strlen(msg_out), 0, (struct sockaddr *)&their_addr, sizeof(struct sockaddr))) < 0) { perror("sendto"); return numbytes; } await_reply: if ((numbytes = recvfrom(bcast, msg_in, sizeof(msg_in), 0, (struct sockaddr *)&head_addr, &head_size)) < 0) { perror("recvfrom"); return numbytes; } msg_in[num_bytes] = '\0'; error = sscanf(msg_in, "%d::%d:%d::", &header, &my_numprocs, &my_taskid); if (error < 3 || header != MINI_MPI_HEAD) { // log error goto await_reply; } if ((table = strstr(msg_in, "::::")) == NULL) { perror("strstr"); return errno; } table += 2; string_to_tasks(my_numprocs, table, task_array); if ((MY_SOCK = socket(PF_INET, SOCK_STREAM, 0)) < 0) { perror("socket"); return MY_SOCK; } if ((error = connect(MY_SOCK, (struct sockaddr *)&head_addr, sizeof(struct sockaddr))) < 0) { perror("connect"); return error; } my_init = 1; return MPI_SUCCESS; } int MPI_Comm_socket(MPI_Comm comm, int *sock) { if (comm != MPI_COMM_WORLD || my_init == 0) return EINVAL; *sock = MY_SOCK; return MPI_SUCCESS; } int MPI_Abort(MPI_Comm comm, int errorcode) { int error; char msg[32]; sprintf(msg, "%d", MINI_MPI_ABORT); if (comm != MPI_COMM_WORLD || my_init == 0) return EINVAL; if ((error = send(MY_SOCK, msg, strlen(msg), 0)) < 0) return error; return MPI_SUCCESS; } int MPI_Finalize(void) { int error; char msg[32]; sprintf(msg, "%d", MINI_MPI_FINAL); if (my_init == 0) return EINVAL; if ((error = send(MY_SOCK, msg, strlen(msg), 0)) < 0) return error; my_init = 0; free(task_array); return MPI_SUCCESS; } /******************************/ int MPI_Send(void *buf, int count, MPI_Datatype type, int dest, int tag, MPI_Comm comm) { int error, sock = task_array[dest].sock; int msg_len = (type_size(type) * count) + 1; char msg[msg_len], tracker[msg_len + 33]; if (comm != MPI_COMM_WORLD || my_init == 0) return EINVAL; buffer_to_char(msg, msg_len, buf, count, type); if ((error = send(sock, msg, strlen(msg), 0)) < 0) return error; sprintf(tracker, "%d:%s", MINI_MPI_SEND, msg); if ((error = send(MY_SOCK, tracker, strlen(tracker), 0)) < 0) return error; return MPI_SUCCESS; } int MPI_Recv(void *buf, int count, MPI_Datatype type, int source, int tag, MPI_Comm comm, MPI_Status *status) { // int error; if (comm != MPI_COMM_WORLD || my_init == 0) return EINVAL; // recv return MPI_SUCCESS; } /******************************/ int MPI_Isend(void *buf, int count, MPI_Datatype type, int dest, int tag, MPI_Comm comm, MPI_Request *request) { int error, sock = task_array[dest].sock; int msg_len = (type_size(type) * count) + 1; char msg[msg_len], tracker[msg_len + 33]; if (comm != MPI_COMM_WORLD || my_init == 0) return EINVAL; buffer_to_char(msg, msg_len, buf, count, type); if ((error = send(sock, msg, strlen(msg), 0)) < 0) return error; sprintf(tracker, "%d:%s", MINI_MPI_SEND, msg); if ((error = send(MY_SOCK, tracker, strlen(tracker), 0)) < 0) return error; return MPI_SUCCESS; } int MPI_Irecv(void *buf, int count, MPI_Datatype type, int source, int tag, MPI_Comm comm, MPI_Request *request) { // int error; if (comm != MPI_COMM_WORLD || my_init == 0) return EINVAL; // nonblocking recv return MPI_SUCCESS; } int MPI_Wait(MPI_Request *request, MPI_Status *status) { // select? return MPI_SUCCESS; } int MPI_Waitall(int count, MPI_Request *request[], MPI_Status *status[]) { return MPI_SUCCESS; } /******************************/ int MPI_Barrier(MPI_Comm comm) { int error; char msg_out[32], msg_in[64]; sprintf(msg_out, "%d", MINI_MPI_BARRIER); if (comm != MPI_COMM_WORLD || my_init == 0) return EINVAL; if ((error = send(MY_SOCK, msg_out, strlen(msg_out), 0)) < 0) return error; await_resume: if ((error = recv(MY_SOCK, msg_in, 64, 0)) < 0) return error; if (atoi(msg_in) != MINI_MPI_RESUME) { // log error goto await_resume; } return MPI_SUCCESS; } int MPI_Bcast(void *buffer, int count, MPI_Datatype datatype, int root, MPI_Comm comm) { // int error; if (comm != MPI_COMM_WORLD || my_init == 0) return EINVAL; // send MINI_MPI_?? return MPI_SUCCESS; } int MPI_Scatter(void *sendbuffer, int sendcount, MPI_Datatype sendtype, void *recvbuffer, int recvcount, MPI_Datatype recvtype, int root, MPI_Comm comm) { // int error; if (comm != MPI_COMM_WORLD || my_init == 0) return EINVAL; // if ((error = send(MY_SOCK, msg, strlen(msg), 0)) < 0) // return error; // send MINI_MPI_SCATTER return MPI_SUCCESS; } int MPI_Gather(void *sendbuffer, int sendcount, MPI_Datatype sendtype, void *recvbuffer, int recvcount, MPI_Datatype recvtype, int root, MPI_Comm comm) { // int error; if (comm != MPI_COMM_WORLD || my_init == 0) return EINVAL; // recv ?? return MPI_SUCCESS; }

© 2007, Los Alamos National Security, LLC.