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/mini_mpi.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 <mini_mpi.h> #include "mini_mpi-internal.h" int my_numprocs = 0; int my_taskid = 0; unsigned short my_init = 0; struct sockaddr_in head_addr; int my_socket; task_t *task_array; void string_to_tasks(int count, char *str, task_t *head) { int i; char *substring, *string = str; head = (task_t*)malloc(sizeof(task_t) * count); for (i = 0; i < count; i++) { int id; char addr[16]; substring = strstr(string, "::"); if (substring == NULL) break; sscanf(substring, "::%d:%s", &id, addr); inet_aton(addr, &(head[id].ip_addr.sin_addr)); string = substring + 2; } } int type_size(MPI_Datatype type) { int size = 0; switch (type) { case MPI_CHAR: case MPI_BYTE: size = 1; break; case MPI_UNSIGNED_SHORT: size = sizeof(unsigned short) / sizeof(char); break; case MPI_SHORT: size = sizeof(short) / sizeof(char); break; case MPI_UNSIGNED_INT: size = sizeof(unsigned int) / sizeof(char); break; case MPI_INT: size = sizeof(int) / sizeof(char); break; case MPI_UNSIGNED_LONG: size = sizeof(unsigned long) / sizeof(char); break; case MPI_LONG: size = sizeof(long) / sizeof(char); break; case MPI_FLOAT: size = sizeof(float) / sizeof(char); break; case MPI_DOUBLE: size = sizeof(double) / sizeof(char); break; case MPI_LONG_DOUBLE: size = sizeof(long double) / sizeof(char); break; case MPI_PACKED: default: size = -1; } return size; } int buffer_to_char(char *string, int len, void *buf, int count, MPI_Datatype type) { int i, size = 0; char tmp[64]; switch (type) { case MPI_CHAR: strncpy(string, (char*)buf, count > len ? len : count); size = strlen(string); break; case MPI_BYTE: size = snprintf(string, len, "%hhu", *((unsigned char*)buf)); for (i = 1; i < count; i++) { int length = sprintf(tmp, ":%hhu", *((unsigned char*)buf)); strncat(string, tmp, len - size); size += length; } break; case MPI_UNSIGNED_SHORT: size = snprintf(string, len, "%hu", *((unsigned short*)buf)); for (i = 1; i < count; i++) { int length = sprintf(tmp, ":%hu", *((unsigned short*)buf)); strncat(string, tmp, len - size); size += length; } break; case MPI_SHORT: size = snprintf(string, len, "%hd", *((short*)buf)); for (i = 1; i < count; i++) { int length = sprintf(tmp, ":%hd", *((short*)buf)); strncat(string, tmp, len - size); size += length; } break; case MPI_UNSIGNED_INT: size = snprintf(string, len, "%u", *((unsigned int*)buf)); for (i = 1; i < count; i++) { int length = sprintf(tmp, ":%u", *((unsigned int*)buf)); strncat(string, tmp, len - size); size += length; } break; case MPI_INT: size = snprintf(string, len, "%d", *((int*)buf)); for (i = 1; i < count; i++) { int length = sprintf(tmp, ":%d", *((int*)buf)); strncat(string, tmp, len - size); size += length; } break; case MPI_UNSIGNED_LONG: size = snprintf(string, len, "%lu", *((unsigned long*)buf)); for (i = 1; i < count; i++) { int length = sprintf(tmp, ":%lu", *((unsigned long*)buf)); strncat(string, tmp, len - size); size += length; } break; case MPI_LONG: size = snprintf(string, len, "%ld", *((long*)buf)); for (i = 1; i < count; i++) { int length = sprintf(tmp, ":%ld", *((long*)buf)); strncat(string, tmp, len - size); size += length; } break; case MPI_FLOAT: size = snprintf(string, len, "%f", *((float*)buf)); for (i = 1; i < count; i++) { int length = sprintf(tmp, ":%f", *((float*)buf)); strncat(string, tmp, len - size); size += length; } break; case MPI_DOUBLE: size = snprintf(string, len, "%lf", *((double*)buf)); for (i = 1; i < count; i++) { int length = sprintf(tmp, ":%lf", *((double*)buf)); strncat(string, tmp, len - size); size += length; } break; case MPI_LONG_DOUBLE: size = snprintf(string, len, "%Lf", *((long double*)buf)); for (i = 1; i < count; i++) { int length = sprintf(tmp, ":%Lf", *((long double*)buf)); strncat(string, tmp, len - size); size += length; } break; case MPI_PACKED: default: size = -1; } return size; } int char_to_buffer(void *buf, int count, MPI_Datatype type, char *string) { int size = 0; return size; } int MPI_Initialized(int *flag) { *flag = my_init; return MPI_SUCCESS; } int MPI_Comm_size(MPI_Comm comm, int *size) { if (comm != MPI_COMM_WORLD || my_init == 0) return -1; *size = my_numprocs; return MPI_SUCCESS; } int MPI_Comm_rank(MPI_Comm comm, int *rank) { if (comm != MPI_COMM_WORLD || my_init == 0) return -1; *rank = my_taskid; return MPI_SUCCESS; }

© 2007, Los Alamos National Security, LLC.