ports/openmpi
ports/openmpi
1
1
Форкнуть 0
Код Релизы Активность

checking in changes that would make this thing work

Просмотр исходного кода 
This commit was SVN r4142.
Этот коммит содержится в:
Prabhanjan Kambadur 2005-01-26 00:20:35 +00:00
родитель 251ff57504
Коммит 34622a5f18
16 изменённых файлов: 51 добавлений и 68 удалений
Показать статистику Скачать Patch файл Скачать Diff файл Показать все файлы Свернуть все файлы

2
src/include/types.h
Просмотреть файл

@ -89,7 +89,7 @@ typedef union {
* handle differences in iovec
*/
#if defined(__APPLE__)
#if defined(__APPLE__) || defined(WIN32)
typedef char* ompi_iov_base_ptr_t;
#else
typedef void* ompi_iov_base_ptr_t;

2
src/mca/gpr/proxy/gpr_proxy.h
Просмотреть файл

@ -51,7 +51,7 @@ struct mca_gpr_proxy_notify_request_tracker_t {
};
typedef struct mca_gpr_proxy_notify_request_tracker_t mca_gpr_proxy_notify_request_tracker_t;
OMPI_DECLSPEC OBJ_CLASS_DECLARATION(mca_gpr_proxy_notify_request_tracker_t);
OMPI_COMP_EXPORT OBJ_CLASS_DECLARATION(mca_gpr_proxy_notify_request_tracker_t);
/*

5
src/mca/gpr/proxy/gpr_proxy_compound_cmd.c
Просмотреть файл

@ -132,7 +132,10 @@ ompi_list_t* mca_gpr_proxy_exec_compound_cmd(bool return_requested)
OMPI_THREAD_UNLOCK(&mca_gpr_proxy_wait_for_compound_mutex);
return OMPI_SUCCESS;
/* TODO: Fix this. The function returns an ompi_list_t * according to definition,
but actually is returning an int. Temporarily casted it to (ompi_list_t *), but
should be fixed in the long run */
return (ompi_list_t *)OMPI_SUCCESS;
}

2
src/mca/gpr/replica/gpr_replica.h
Просмотреть файл

@ -238,7 +238,7 @@ struct mca_gpr_replica_notify_request_tracker_t {
};
typedef struct mca_gpr_replica_notify_request_tracker_t mca_gpr_replica_notify_request_tracker_t;
OMPI_DECLSPEC OBJ_CLASS_DECLARATION(mca_gpr_replica_notify_request_tracker_t);
OMPI_COMP_EXPORT OBJ_CLASS_DECLARATION(mca_gpr_replica_notify_request_tracker_t);
/*

46
src/mca/gpr/replica/gpr_replica_internals_dict_ops.c
Просмотреть файл

@ -140,14 +140,14 @@ mca_gpr_replica_key_t
mca_gpr_replica_key_t
mca_gpr_replica_define_key(mca_gpr_replica_segment_t *seg, char *token)
{
mca_gpr_replica_keytable_t *ptr_key, *new;
mca_gpr_replica_keytable_t *ptr_key, *latest;
/* if token is NULL, error */
if (NULL == token) {
return MCA_GPR_REPLICA_KEY_MAX;
}
/* if seg is NULL, use token to define new segment name in global dictionary */
/* if seg is NULL, use token to define latest segment name in global dictionary */
if (NULL == seg) {
for (ptr_key = (mca_gpr_replica_keytable_t*)ompi_list_get_first(&mca_gpr_replica_head.segment_dict);
ptr_key != (mca_gpr_replica_keytable_t*)ompi_list_get_end(&mca_gpr_replica_head.segment_dict);
@ -157,17 +157,17 @@ mca_gpr_replica_define_key(mca_gpr_replica_segment_t *seg, char *token)
}
}
/* okay, token is unique - create dictionary entry */
new = OBJ_NEW(mca_gpr_replica_keytable_t);
new->token = strdup(token);
latest = OBJ_NEW(mca_gpr_replica_keytable_t);
latest->token = strdup(token);
if (0 == ompi_list_get_size(&mca_gpr_replica_head.freekeys)) { /* no keys waiting for reuse */
mca_gpr_replica_head.lastkey++;
new->key = mca_gpr_replica_head.lastkey;
latest->key = mca_gpr_replica_head.lastkey;
} else {
ptr_key = (mca_gpr_replica_keytable_t*)ompi_list_remove_first(&mca_gpr_replica_head.freekeys);
new->key = ptr_key->key;
latest->key = ptr_key->key;
}
ompi_list_append(&mca_gpr_replica_head.segment_dict, &new->item);
return new->key;
ompi_list_append(&mca_gpr_replica_head.segment_dict, &latest->item);
return latest->key;
}
/* check seg's dictionary to ensure uniqueness */
@ -180,24 +180,24 @@ mca_gpr_replica_define_key(mca_gpr_replica_segment_t *seg, char *token)
}
/* okay, token is unique - create dictionary entry */
new = OBJ_NEW(mca_gpr_replica_keytable_t);
new->token = strdup(token);
latest = OBJ_NEW(mca_gpr_replica_keytable_t);
latest->token = strdup(token);
if (0 == ompi_list_get_size(&seg->freekeys)) { /* no keys waiting for reuse */
seg->lastkey++;
new->key = seg->lastkey;
latest->key = seg->lastkey;
} else {
ptr_key = (mca_gpr_replica_keytable_t*)ompi_list_remove_first(&seg->freekeys);
new->key = ptr_key->key;
latest->key = ptr_key->key;
}
ompi_list_append(&seg->keytable, &new->item);
return new->key;
ompi_list_append(&seg->keytable, &latest->item);
return latest->key;
}
int mca_gpr_replica_delete_key(mca_gpr_replica_segment_t *seg, char *token)
{
mca_gpr_replica_core_t *reg;
mca_gpr_replica_keytable_t *ptr_seg, *ptr_key, *new;
mca_gpr_replica_keytable_t *ptr_seg, *ptr_key, *latest;
mca_gpr_replica_key_t *key;
uint i;
@ -209,10 +209,10 @@ int mca_gpr_replica_delete_key(mca_gpr_replica_segment_t *seg, char *token)
}
/* add key to global registry's freekey list */
new = OBJ_NEW(mca_gpr_replica_keytable_t);
new->token = NULL;
new->key = ptr_seg->key;
ompi_list_append(&mca_gpr_replica_head.freekeys, &new->item);
latest = OBJ_NEW(mca_gpr_replica_keytable_t);
latest->token = NULL;
latest->key = ptr_seg->key;
ompi_list_append(&mca_gpr_replica_head.freekeys, &latest->item);
/* remove the dictionary entry */
ompi_list_remove_item(&mca_gpr_replica_head.segment_dict, &ptr_seg->item);
@ -239,10 +239,10 @@ int mca_gpr_replica_delete_key(mca_gpr_replica_segment_t *seg, char *token)
}
/* add key to this segment's freekey list */
new = OBJ_NEW(mca_gpr_replica_keytable_t);
new->token = NULL;
new->key = ptr_key->key;
ompi_list_append(&seg->freekeys, &new->item);
latest = OBJ_NEW(mca_gpr_replica_keytable_t);
latest->token = NULL;
latest->key = ptr_key->key;
ompi_list_append(&seg->freekeys, &latest->item);
/* now remove the dictionary entry from the segment's dictionary */
ompi_list_remove_item(&seg->keytable, &ptr_key->item);

4
src/mca/gpr/replica/gpr_replica_recv_proxy_msgs.c
Просмотреть файл

@ -613,7 +613,7 @@ static int32_t mca_gpr_replica_recv_put_cmd(ompi_buffer_t buffer)
goto RETURN_ERROR;
}
object = (ompi_registry_object_t)malloc(object_size);
object = (ompi_registry_object_t *)malloc(object_size);
if (OMPI_SUCCESS != ompi_unpack(buffer, object, object_size, OMPI_BYTE)) {
goto RETURN_ERROR;
}
@ -1196,7 +1196,7 @@ static void mca_gpr_replica_recv_get_startup_msg_cmd(ompi_buffer_t buffer, ompi_
if (0 < num_objects) {
for (i=0; i < num_objects; i++) {
ompi_unpack(msg, &data_obj_size, 1, MCA_GPR_OOB_PACK_OBJECT_SIZE);
data_object = (ompi_registry_object_t)malloc(data_obj_size);
data_object = (ompi_registry_object_t *)malloc(data_obj_size);
ompi_unpack(msg, data_object, data_obj_size, OMPI_BYTE);
ompi_pack(answer, &data_obj_size, 1, MCA_GPR_OOB_PACK_OBJECT_SIZE);
ompi_pack(answer, data_object, data_obj_size, OMPI_BYTE);

8
src/mca/oob/tcp/oob_tcp_msg.c
Просмотреть файл

@ -189,7 +189,7 @@ bool mca_oob_tcp_msg_send_handler(mca_oob_tcp_msg_t* msg, struct mca_oob_tcp_pee
do {/* while there is still more iovecs to write */
if(rc < (int)msg->msg_rwptr->iov_len) {
msg->msg_rwptr->iov_len -= rc;
msg->msg_rwptr->iov_base = (void *) ((char *) msg->msg_rwptr->iov_base + rc);
msg->msg_rwptr->iov_base = (ompi_iov_base_ptr_t)((char *) msg->msg_rwptr->iov_base + rc);
break;
} else {
rc -= msg->msg_rwptr->iov_len;
@ -229,7 +229,7 @@ bool mca_oob_tcp_msg_recv_handler(mca_oob_tcp_msg_t* msg, struct mca_oob_tcp_pee
mca_oob_tcp_peer_close(peer);
return false;
}
msg->msg_rwiov[1].iov_base = msg->msg_rwbuf;
msg->msg_rwiov[1].iov_base = (ompi_iov_base_ptr_t)msg->msg_rwbuf;
msg->msg_rwiov[1].iov_len = msg->msg_hdr.msg_size;
msg->msg_rwnum = 1;
}
@ -291,7 +291,7 @@ static bool mca_oob_tcp_msg_recv(mca_oob_tcp_msg_t* msg, mca_oob_tcp_peer_t* pee
do {
if(rc < (int)msg->msg_rwptr->iov_len) {
msg->msg_rwptr->iov_len -= rc;
msg->msg_rwptr->iov_base = (void *) ((char *) msg->msg_rwptr->iov_base + rc);
msg->msg_rwptr->iov_base = (ompi_iov_base_ptr_t)((char *) msg->msg_rwptr->iov_base + rc);
break;
} else {
rc -= msg->msg_rwptr->iov_len;
@ -384,7 +384,7 @@ static void mca_oob_tcp_msg_data(mca_oob_tcp_msg_t* msg, mca_oob_tcp_peer_t* pee
/* first iovec of recv message contains the header -
* subsequent contain user data
*/
post->msg_uiov[0].iov_base = msg->msg_rwbuf;
post->msg_uiov[0].iov_base = (ompi_iov_base_ptr_t)msg->msg_rwbuf;
post->msg_uiov[0].iov_len = msg->msg_hdr.msg_size;
post->msg_rc = msg->msg_hdr.msg_size;
msg->msg_rwbuf = NULL;

4
src/mca/oob/tcp/oob_tcp_peer.c
Просмотреть файл

@ -651,11 +651,11 @@ static void mca_oob_tcp_peer_recv_handler(int sd, short flags, void* user)
msg->msg_peer = peer->peer_name;
msg->msg_rwiov = mca_oob_tcp_msg_iov_alloc(msg,2);
msg->msg_rwbuf = NULL;
msg->msg_rwiov->iov_base = msg->msg_rwbuf;
msg->msg_rwiov->iov_base = (ompi_iov_base_ptr_t)msg->msg_rwbuf;
msg->msg_rwiov->iov_len = 1;
msg->msg_rwcnt = msg->msg_rwnum = 1;
msg->msg_rwptr = msg->msg_rwiov;
msg->msg_rwiov[0].iov_base = (void*)&msg->msg_hdr;
msg->msg_rwiov[0].iov_base = (ompi_iov_base_ptr_t)&msg->msg_hdr;
msg->msg_rwiov[0].iov_len = sizeof(msg->msg_hdr);
peer->peer_recv_msg = msg;
}

2
src/mca/oob/tcp/oob_tcp_ping.c
Просмотреть файл

@ -60,7 +60,7 @@ int mca_oob_tcp_ping(
msg->msg_uiov = NULL;
msg->msg_ucnt = 0;
msg->msg_rwiov = mca_oob_tcp_msg_iov_alloc(msg, 1);
msg->msg_rwiov[0].iov_base = (void*)&msg->msg_hdr;
msg->msg_rwiov[0].iov_base = (ompi_iov_base_ptr_t)&msg->msg_hdr;
msg->msg_rwiov[0].iov_len = sizeof(msg->msg_hdr);
msg->msg_rwptr = msg->msg_rwiov;
msg->msg_rwcnt = msg->msg_rwnum = 1;

4
src/mca/oob/tcp/oob_tcp_recv.c
Просмотреть файл

@ -62,7 +62,7 @@ int mca_oob_tcp_recv(
if(NULL == iov || 0 == count) {
return OMPI_ERR_BAD_PARAM;
}
iov[0].iov_base = msg->msg_rwbuf;
iov[0].iov_base = (ompi_iov_base_ptr_t)msg->msg_rwbuf;
iov[0].iov_len = msg->msg_hdr.msg_size;
msg->msg_rwbuf = NULL;
rc = msg->msg_hdr.msg_size;
@ -175,7 +175,7 @@ int mca_oob_tcp_recv_nb(
OMPI_THREAD_UNLOCK(&mca_oob_tcp_component.tcp_match_lock);
return OMPI_ERR_BAD_PARAM;
}
iov[0].iov_base = msg->msg_rwbuf;
iov[0].iov_base = (ompi_iov_base_ptr_t)msg->msg_rwbuf;
iov[0].iov_len = msg->msg_hdr.msg_size;
msg->msg_rwbuf = NULL;
rc = msg->msg_hdr.msg_size;

6
src/mca/oob/tcp/oob_tcp_send.c
Просмотреть файл

@ -32,7 +32,7 @@ static int mca_oob_tcp_send_self(
return OMPI_ERR_OUT_OF_RESOURCE;
}
ptr = msg->msg_rwbuf;
ptr = (unsigned char *)msg->msg_rwbuf;
for(rc = 0; rc < count; rc++) {
memcpy(ptr, iov[rc].iov_base, iov[rc].iov_len);
ptr += iov[rc].iov_len;
@ -98,7 +98,7 @@ int mca_oob_tcp_send(
msg->msg_uiov = iov;
msg->msg_ucnt = count;
msg->msg_rwiov = mca_oob_tcp_msg_iov_alloc(msg, count+1);
msg->msg_rwiov[0].iov_base = (void*)&msg->msg_hdr;
msg->msg_rwiov[0].iov_base = (ompi_iov_base_ptr_t)(&msg->msg_hdr);
msg->msg_rwiov[0].iov_len = sizeof(msg->msg_hdr);
msg->msg_rwptr = msg->msg_rwiov;
msg->msg_rwcnt = msg->msg_rwnum = count + 1;
@ -181,7 +181,7 @@ int mca_oob_tcp_send_nb(
msg->msg_uiov = iov;
msg->msg_ucnt = count;
msg->msg_rwiov = mca_oob_tcp_msg_iov_alloc(msg,count+1);
msg->msg_rwiov[0].iov_base = (void*)&msg->msg_hdr;
msg->msg_rwiov[0].iov_base = (ompi_iov_base_ptr_t)(&msg->msg_hdr);
msg->msg_rwiov[0].iov_len = sizeof(msg->msg_hdr);
msg->msg_rwptr = msg->msg_rwiov;
msg->msg_rwcnt = msg->msg_rwnum = count + 1;

2
src/mca/ptl/tcp/src/ptl_tcp_recvfrag.h
Просмотреть файл

@ -169,7 +169,7 @@ static inline void mca_ptl_tcp_recv_frag_progress(mca_ptl_tcp_recv_frag_t* frag)
offset, /* offset in bytes into packed buffer */
NULL ); /* dont allocate memory */
iov.iov_base = frag->frag_recv.frag_base.frag_addr;
iov.iov_base = (ompi_iov_base_ptr_t)frag->frag_recv.frag_base.frag_addr;
iov.iov_len = frag->frag_recv.frag_base.frag_size;
iov_count = 1;
max_data = iov.iov_len;

4
src/mca/win_makefile
Просмотреть файл

@ -30,7 +30,6 @@ C_SUBDIRS = \
coll/basic \
llm/hostfile/src \
ns/proxy/src \
gpr/proxy/ \
pcmclient/env \
pcmclient/seed \
pcmclient/singleton \
@ -43,6 +42,7 @@ CPP_SUBDIRS = \
oob/tcp/ \
pml/teg/src \
ns/replica/src \
gpr/proxy/ \
gpr/replica/
#list of components that are not working as yet
@ -64,7 +64,6 @@ CFLAGS = \
/DOMPI_BUILDING=0 \
/DHAVE_CONFIG_H \
/DOMPI_SYSCONFDIR="\"${installdir}/share\"" \
/D_WINDLL \
/EHsc \
/MLd \
/W0 \
@ -85,7 +84,6 @@ CPPFLAGS = \
/DOMPI_BUILDING=0 \
/DHAVE_CONFIG_H \
/DOMPI_SYSCONFDIR="\"${installdir}/share\"" \
/D_WINDLL \
/EHsc \
/MLd \
/W0 \

20
vcproj/ompi/ompi.vcproj
Просмотреть файл

@ -18,7 +18,7 @@
CharacterSet="2">
<Tool
Name="VCCLCompilerTool"
AdditionalOptions="/I&quot;../generated_include&quot; /I&quot;../../src/win32/generated_include&quot; /I&quot;../../include&quot; /I&quot;../../src&quot; /I&quot;../../src/event/compat/&quot; /I&quot;../../src/event/WIN32-Code&quot; /D&quot;__i386__&quot; /D&quot;HAVE_CONFIG_H&quot; /DOMPI_PKGDATADIR=&quot;\&quot;C:/cygwin/ompi-new/vcproj/ompi/Debug\&quot;&quot; /DOMPI_PKGLIBDIR=&quot;\&quot;C:/cygwin/ompi-new/vcpro/ompi/Debug\&quot;&quot; /DOMPI_SYSCONFDIR=&quot;\&quot;C:/cygwin/ompi-new/vcproj/ompi/Debug\&quot;&quot; /DOMPI_BUILDING=1"
AdditionalOptions="/I&quot;../generated_include&quot; /I&quot;../../src/win32/generated_include&quot; /I&quot;../../include&quot; /I&quot;../../src&quot; /I&quot;../../src/event/compat/&quot; /I&quot;../../src/event/WIN32-Code&quot; /D&quot;__i386__&quot; /D&quot;HAVE_CONFIG_H&quot; /DOMPI_PKGDATADIR=&quot;\&quot;E:/cygwin/home/pkambadu/ompi-pristine/vcproj/ompi/Debug\&quot;&quot; /DOMPI_PKGLIBDIR=&quot;\&quot;E:/cygwin/home/pkambadu/ompi-pristine/vcproj/ompi/Debug\&quot;&quot; /DOMPI_SYSCONFDIR=&quot;\&quot;E:/cygwin/home/pkambadu/ompi-pristine/vcproj/ompi/Debug\&quot;&quot; /DOMPI_BUILDING=1"
Optimization="0"
PreprocessorDefinitions="WIN32;_DEBUG;_CONSOLE"
GeneratePreprocessedFile="0"
@ -987,6 +987,9 @@
<File
RelativePath="..\..\src\event\evsignal.h">
</File>
<File
RelativePath="..\..\src\event\select.c">
</File>
<Filter
Name="Win32-Code"
Filter="">
@ -2920,21 +2923,6 @@
<File
RelativePath="..\..\src\mca\ptl\tcp\src\ptl_tcp_sendreq.h">
</File>
<File
RelativePath="..\..\src\mca\topo\unity\src\topo_unity.c">
</File>
<File
RelativePath="..\..\src\mca\topo\unity\src\topo_unity.h">
</File>
<File
RelativePath="..\..\src\mca\topo\unity\src\topo_unity_cart_map.c">
</File>
<File
RelativePath="..\..\src\mca\topo\unity\src\topo_unity_component.c">
</File>
<File
RelativePath="..\..\src\mca\topo\unity\src\topo_unity_graph_map.c">
</File>
</Filter>
</Filter>
<File

6
vcproj/openmpi/hello.c
Просмотреть файл

@ -16,13 +16,7 @@
#include <stdio.h>
int main(int argc, char **argv) {
int rank;
int size;
MPI_Init(&argc, &argv);
printf("Hello World!!\n");
MPI_Comm_rank(MPI_COMM_WORLD, &rank);
MPI_Comm_size(MPI_COMM_WORLD, &size);
printf ("I am rank %d of %d\n", rank, size);
MPI_Finalize();
return 0;
}

2
vcproj/openmpi/openmpi.vcproj
Просмотреть файл

@ -117,7 +117,7 @@
Filter="cpp;c;cxx;def;odl;idl;hpj;bat;asm;asmx"
UniqueIdentifier="{4FC737F1-C7A5-4376-A066-2A32D752A2FF}">
<File
RelativePath=".\server.c">
RelativePath=".\hello.c">
</File>
</Filter>
</Files>