1 /* Copyright (c) 2007-2017. The SimGrid Team. All rights reserved. */
3 /* This program is free software; you can redistribute it and/or modify it
4 * under the terms of the license (GNU LGPL) which comes with this package. */
7 #include "smpi_comm.hpp"
8 #include "smpi_coll.hpp"
9 #include "smpi_datatype_derived.hpp"
10 #include "smpi_op.hpp"
11 #include "smpi_process.hpp"
12 #include "smpi_win.hpp"
14 XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(smpi_pmpi);
16 /* PMPI User level calls */
17 extern "C" { // Obviously, the C MPI interface should use the C linkage
19 int PMPI_Win_create( void *base, MPI_Aint size, int disp_unit, MPI_Info info, MPI_Comm comm, MPI_Win *win){
22 if (comm == MPI_COMM_NULL) {
24 }else if ((base == nullptr && size != 0) || disp_unit <= 0 || size < 0 ){
25 retval= MPI_ERR_OTHER;
27 *win = new simgrid::smpi::Win( base, size, disp_unit, info, comm);
34 int PMPI_Win_allocate( MPI_Aint size, int disp_unit, MPI_Info info, MPI_Comm comm, void *base, MPI_Win *win){
37 if (comm == MPI_COMM_NULL) {
39 }else if (disp_unit <= 0 || size < 0 ){
40 retval= MPI_ERR_OTHER;
42 void* ptr = xbt_malloc(size);
44 return MPI_ERR_NO_MEM;
45 *static_cast<void**>(base) = ptr;
46 *win = new simgrid::smpi::Win( ptr, size, disp_unit, info, comm,1);
53 int PMPI_Win_create_dynamic( MPI_Info info, MPI_Comm comm, MPI_Win *win){
56 if (comm == MPI_COMM_NULL) {
59 *win = new simgrid::smpi::Win(info, comm);
66 int PMPI_Win_attach(MPI_Win win, void *base, MPI_Aint size){
69 if(win == MPI_WIN_NULL){
71 } else if ((base == nullptr && size != 0) || size < 0 ){
72 retval= MPI_ERR_OTHER;
74 retval = win->attach(base, size);
80 int PMPI_Win_detach(MPI_Win win, void *base){
83 if(win == MPI_WIN_NULL){
85 } else if (base == nullptr){
86 retval= MPI_ERR_OTHER;
88 retval = win->detach(base);
95 int PMPI_Win_free( MPI_Win* win){
98 if (win == nullptr || *win == MPI_WIN_NULL) {
108 int PMPI_Win_set_name(MPI_Win win, char * name)
110 if (win == MPI_WIN_NULL) {
112 } else if (name == nullptr) {
120 int PMPI_Win_get_name(MPI_Win win, char * name, int* len)
122 if (win == MPI_WIN_NULL) {
124 } else if (name == nullptr) {
127 win->get_name(name, len);
132 int PMPI_Win_get_info(MPI_Win win, MPI_Info* info)
134 if (win == MPI_WIN_NULL) {
142 int PMPI_Win_set_info(MPI_Win win, MPI_Info info)
144 if (win == MPI_WIN_NULL) {
152 int PMPI_Win_get_group(MPI_Win win, MPI_Group * group){
153 if (win == MPI_WIN_NULL) {
156 win->get_group(group);
162 int PMPI_Win_fence( int assert, MPI_Win win){
165 if (win == MPI_WIN_NULL) {
166 retval = MPI_ERR_WIN;
168 int rank = smpi_process()->index();
169 TRACE_smpi_collective_in(rank, __FUNCTION__, nullptr);
170 retval = win->fence(assert);
171 TRACE_smpi_collective_out(rank, __FUNCTION__);
177 int PMPI_Get( void *origin_addr, int origin_count, MPI_Datatype origin_datatype, int target_rank,
178 MPI_Aint target_disp, int target_count, MPI_Datatype target_datatype, MPI_Win win){
181 if (win == MPI_WIN_NULL) {
182 retval = MPI_ERR_WIN;
183 } else if (target_rank == MPI_PROC_NULL) {
184 retval = MPI_SUCCESS;
185 } else if (target_rank <0){
186 retval = MPI_ERR_RANK;
187 } else if (win->dynamic()==0 && target_disp <0){
188 //in case of dynamic window, target_disp can be mistakenly seen as negative, as it is an address
189 retval = MPI_ERR_ARG;
190 } else if ((origin_count < 0 || target_count < 0) ||
191 (origin_addr==nullptr && origin_count > 0)){
192 retval = MPI_ERR_COUNT;
193 } else if (((origin_datatype == MPI_DATATYPE_NULL) || (target_datatype == MPI_DATATYPE_NULL)) ||
194 ((not origin_datatype->is_valid()) || (not target_datatype->is_valid()))) {
195 retval = MPI_ERR_TYPE;
197 int rank = smpi_process()->index();
199 win->get_group(&group);
200 TRACE_smpi_ptp_in(rank, __FUNCTION__, nullptr);
202 retval = win->get( origin_addr, origin_count, origin_datatype, target_rank, target_disp, target_count,
205 TRACE_smpi_ptp_out(rank, rank, __FUNCTION__);
211 int PMPI_Rget( void *origin_addr, int origin_count, MPI_Datatype origin_datatype, int target_rank,
212 MPI_Aint target_disp, int target_count, MPI_Datatype target_datatype, MPI_Win win, MPI_Request* request){
215 if (win == MPI_WIN_NULL) {
216 retval = MPI_ERR_WIN;
217 } else if (target_rank == MPI_PROC_NULL) {
218 *request = MPI_REQUEST_NULL;
219 retval = MPI_SUCCESS;
220 } else if (target_rank <0){
221 retval = MPI_ERR_RANK;
222 } else if (win->dynamic()==0 && target_disp <0){
223 //in case of dynamic window, target_disp can be mistakenly seen as negative, as it is an address
224 retval = MPI_ERR_ARG;
225 } else if ((origin_count < 0 || target_count < 0) ||
226 (origin_addr==nullptr && origin_count > 0)){
227 retval = MPI_ERR_COUNT;
228 } else if (((origin_datatype == MPI_DATATYPE_NULL) || (target_datatype == MPI_DATATYPE_NULL)) ||
229 ((not origin_datatype->is_valid()) || (not target_datatype->is_valid()))) {
230 retval = MPI_ERR_TYPE;
231 } else if(request == nullptr){
232 retval = MPI_ERR_REQUEST;
234 int rank = smpi_process()->index();
236 win->get_group(&group);
237 TRACE_smpi_ptp_in(rank, __FUNCTION__, nullptr);
239 retval = win->get( origin_addr, origin_count, origin_datatype, target_rank, target_disp, target_count,
240 target_datatype, request);
242 TRACE_smpi_ptp_out(rank, rank, __FUNCTION__);
248 int PMPI_Put( void *origin_addr, int origin_count, MPI_Datatype origin_datatype, int target_rank,
249 MPI_Aint target_disp, int target_count, MPI_Datatype target_datatype, MPI_Win win){
252 if (win == MPI_WIN_NULL) {
253 retval = MPI_ERR_WIN;
254 } else if (target_rank == MPI_PROC_NULL) {
255 retval = MPI_SUCCESS;
256 } else if (target_rank <0){
257 retval = MPI_ERR_RANK;
258 } else if (win->dynamic()==0 && target_disp <0){
259 //in case of dynamic window, target_disp can be mistakenly seen as negative, as it is an address
260 retval = MPI_ERR_ARG;
261 } else if ((origin_count < 0 || target_count < 0) ||
262 (origin_addr==nullptr && origin_count > 0)){
263 retval = MPI_ERR_COUNT;
264 } else if (((origin_datatype == MPI_DATATYPE_NULL) || (target_datatype == MPI_DATATYPE_NULL)) ||
265 ((not origin_datatype->is_valid()) || (not target_datatype->is_valid()))) {
266 retval = MPI_ERR_TYPE;
268 int rank = smpi_process()->index();
270 win->get_group(&group);
271 int dst_traced = group->index(target_rank);
272 TRACE_smpi_ptp_in(rank, __FUNCTION__, nullptr);
273 TRACE_smpi_send(rank, rank, dst_traced, SMPI_RMA_TAG, origin_count*origin_datatype->size());
275 retval = win->put( origin_addr, origin_count, origin_datatype, target_rank, target_disp, target_count,
278 TRACE_smpi_ptp_out(rank, dst_traced, __FUNCTION__);
284 int PMPI_Rput( void *origin_addr, int origin_count, MPI_Datatype origin_datatype, int target_rank,
285 MPI_Aint target_disp, int target_count, MPI_Datatype target_datatype, MPI_Win win, MPI_Request* request){
288 if (win == MPI_WIN_NULL) {
289 retval = MPI_ERR_WIN;
290 } else if (target_rank == MPI_PROC_NULL) {
291 *request = MPI_REQUEST_NULL;
292 retval = MPI_SUCCESS;
293 } else if (target_rank <0){
294 retval = MPI_ERR_RANK;
295 } else if (win->dynamic()==0 && target_disp <0){
296 //in case of dynamic window, target_disp can be mistakenly seen as negative, as it is an address
297 retval = MPI_ERR_ARG;
298 } else if ((origin_count < 0 || target_count < 0) ||
299 (origin_addr==nullptr && origin_count > 0)){
300 retval = MPI_ERR_COUNT;
301 } else if (((origin_datatype == MPI_DATATYPE_NULL) || (target_datatype == MPI_DATATYPE_NULL)) ||
302 ((not origin_datatype->is_valid()) || (not target_datatype->is_valid()))) {
303 retval = MPI_ERR_TYPE;
304 } else if(request == nullptr){
305 retval = MPI_ERR_REQUEST;
307 int rank = smpi_process()->index();
309 win->get_group(&group);
310 int dst_traced = group->index(target_rank);
311 TRACE_smpi_ptp_in(rank, __FUNCTION__, nullptr);
312 TRACE_smpi_send(rank, rank, dst_traced, SMPI_RMA_TAG, origin_count*origin_datatype->size());
314 retval = win->put( origin_addr, origin_count, origin_datatype, target_rank, target_disp, target_count,
315 target_datatype, request);
317 TRACE_smpi_ptp_out(rank, dst_traced, __FUNCTION__);
323 int PMPI_Accumulate( void *origin_addr, int origin_count, MPI_Datatype origin_datatype, int target_rank,
324 MPI_Aint target_disp, int target_count, MPI_Datatype target_datatype, MPI_Op op, MPI_Win win){
327 if (win == MPI_WIN_NULL) {
328 retval = MPI_ERR_WIN;
329 } else if (target_rank == MPI_PROC_NULL) {
330 retval = MPI_SUCCESS;
331 } else if (target_rank <0){
332 retval = MPI_ERR_RANK;
333 } else if (win->dynamic()==0 && target_disp <0){
334 //in case of dynamic window, target_disp can be mistakenly seen as negative, as it is an address
335 retval = MPI_ERR_ARG;
336 } else if ((origin_count < 0 || target_count < 0) ||
337 (origin_addr==nullptr && origin_count > 0)){
338 retval = MPI_ERR_COUNT;
339 } else if (((origin_datatype == MPI_DATATYPE_NULL) || (target_datatype == MPI_DATATYPE_NULL)) ||
340 ((not origin_datatype->is_valid()) || (not target_datatype->is_valid()))) {
341 retval = MPI_ERR_TYPE;
342 } else if (op == MPI_OP_NULL) {
345 int rank = smpi_process()->index();
347 win->get_group(&group);
348 TRACE_smpi_ptp_in(rank, __FUNCTION__, nullptr);
349 retval = win->accumulate( origin_addr, origin_count, origin_datatype, target_rank, target_disp, target_count,
350 target_datatype, op);
352 TRACE_smpi_ptp_out(rank, rank, __FUNCTION__);
358 int PMPI_Raccumulate( void *origin_addr, int origin_count, MPI_Datatype origin_datatype, int target_rank,
359 MPI_Aint target_disp, int target_count, MPI_Datatype target_datatype, MPI_Op op, MPI_Win win, MPI_Request* request){
362 if (win == MPI_WIN_NULL) {
363 retval = MPI_ERR_WIN;
364 } else if (target_rank == MPI_PROC_NULL) {
365 *request = MPI_REQUEST_NULL;
366 retval = MPI_SUCCESS;
367 } else if (target_rank <0){
368 retval = MPI_ERR_RANK;
369 } else if (win->dynamic()==0 && target_disp <0){
370 //in case of dynamic window, target_disp can be mistakenly seen as negative, as it is an address
371 retval = MPI_ERR_ARG;
372 } else if ((origin_count < 0 || target_count < 0) ||
373 (origin_addr==nullptr && origin_count > 0)){
374 retval = MPI_ERR_COUNT;
375 } else if (((origin_datatype == MPI_DATATYPE_NULL) || (target_datatype == MPI_DATATYPE_NULL)) ||
376 ((not origin_datatype->is_valid()) || (not target_datatype->is_valid()))) {
377 retval = MPI_ERR_TYPE;
378 } else if (op == MPI_OP_NULL) {
380 } else if(request == nullptr){
381 retval = MPI_ERR_REQUEST;
383 int rank = smpi_process()->index();
385 win->get_group(&group);
386 TRACE_smpi_ptp_in(rank, __FUNCTION__, nullptr);
388 retval = win->accumulate( origin_addr, origin_count, origin_datatype, target_rank, target_disp, target_count,
389 target_datatype, op, request);
391 TRACE_smpi_ptp_out(rank, rank, __FUNCTION__);
397 int PMPI_Get_accumulate(void *origin_addr, int origin_count, MPI_Datatype origin_datatype, void *result_addr,
398 int result_count, MPI_Datatype result_datatype, int target_rank, MPI_Aint target_disp, int target_count,
399 MPI_Datatype target_datatype, MPI_Op op, MPI_Win win){
402 if (win == MPI_WIN_NULL) {
403 retval = MPI_ERR_WIN;
404 } else if (target_rank == MPI_PROC_NULL) {
405 retval = MPI_SUCCESS;
406 } else if (target_rank <0){
407 retval = MPI_ERR_RANK;
408 } else if (win->dynamic()==0 && target_disp <0){
409 //in case of dynamic window, target_disp can be mistakenly seen as negative, as it is an address
410 retval = MPI_ERR_ARG;
411 } else if ((origin_count < 0 || target_count < 0 || result_count <0) ||
412 (origin_addr==nullptr && origin_count > 0 && op != MPI_NO_OP) ||
413 (result_addr==nullptr && result_count > 0)){
414 retval = MPI_ERR_COUNT;
415 } else if (((target_datatype == MPI_DATATYPE_NULL) || (result_datatype == MPI_DATATYPE_NULL)) ||
416 (((origin_datatype != MPI_DATATYPE_NULL) && (not origin_datatype->is_valid())) || (not target_datatype->is_valid()) || (not result_datatype->is_valid()))) {
417 retval = MPI_ERR_TYPE;
418 } else if (op == MPI_OP_NULL) {
421 int rank = smpi_process()->index();
423 win->get_group(&group);
424 TRACE_smpi_ptp_in(rank, __FUNCTION__, nullptr);
426 retval = win->get_accumulate( origin_addr, origin_count, origin_datatype, result_addr,
427 result_count, result_datatype, target_rank, target_disp,
428 target_count, target_datatype, op);
430 TRACE_smpi_ptp_out(rank, rank, __FUNCTION__);
437 int PMPI_Rget_accumulate(void *origin_addr, int origin_count, MPI_Datatype origin_datatype, void *result_addr,
438 int result_count, MPI_Datatype result_datatype, int target_rank, MPI_Aint target_disp, int target_count,
439 MPI_Datatype target_datatype, MPI_Op op, MPI_Win win, MPI_Request* request){
442 if (win == MPI_WIN_NULL) {
443 retval = MPI_ERR_WIN;
444 } else if (target_rank == MPI_PROC_NULL) {
445 *request = MPI_REQUEST_NULL;
446 retval = MPI_SUCCESS;
447 } else if (target_rank <0){
448 retval = MPI_ERR_RANK;
449 } else if (win->dynamic()==0 && target_disp <0){
450 //in case of dynamic window, target_disp can be mistakenly seen as negative, as it is an address
451 retval = MPI_ERR_ARG;
452 } else if ((origin_count < 0 || target_count < 0 || result_count <0) ||
453 (origin_addr==nullptr && origin_count > 0 && op != MPI_NO_OP) ||
454 (result_addr==nullptr && result_count > 0)){
455 retval = MPI_ERR_COUNT;
456 } else if (((target_datatype == MPI_DATATYPE_NULL) || (result_datatype == MPI_DATATYPE_NULL)) ||
457 (((origin_datatype != MPI_DATATYPE_NULL) && (not origin_datatype->is_valid())) || (not target_datatype->is_valid()) || (not result_datatype->is_valid()))) {
458 retval = MPI_ERR_TYPE;
459 } else if (op == MPI_OP_NULL) {
461 } else if(request == nullptr){
462 retval = MPI_ERR_REQUEST;
464 int rank = smpi_process()->index();
466 win->get_group(&group);
467 TRACE_smpi_ptp_in(rank, __FUNCTION__, nullptr);
469 retval = win->get_accumulate( origin_addr, origin_count, origin_datatype, result_addr,
470 result_count, result_datatype, target_rank, target_disp,
471 target_count, target_datatype, op, request);
473 TRACE_smpi_ptp_out(rank, rank, __FUNCTION__);
479 int PMPI_Fetch_and_op(void *origin_addr, void *result_addr, MPI_Datatype dtype, int target_rank, MPI_Aint target_disp, MPI_Op op, MPI_Win win){
480 return PMPI_Get_accumulate(origin_addr, origin_addr==nullptr?0:1, dtype, result_addr, 1, dtype, target_rank, target_disp, 1, dtype, op, win);
483 int PMPI_Compare_and_swap(void *origin_addr, void *compare_addr,
484 void *result_addr, MPI_Datatype datatype, int target_rank,
485 MPI_Aint target_disp, MPI_Win win){
488 if (win == MPI_WIN_NULL) {
489 retval = MPI_ERR_WIN;
490 } else if (target_rank == MPI_PROC_NULL) {
491 retval = MPI_SUCCESS;
492 } else if (target_rank <0){
493 retval = MPI_ERR_RANK;
494 } else if (win->dynamic()==0 && target_disp <0){
495 //in case of dynamic window, target_disp can be mistakenly seen as negative, as it is an address
496 retval = MPI_ERR_ARG;
497 } else if (origin_addr==nullptr || result_addr==nullptr || compare_addr==nullptr){
498 retval = MPI_ERR_COUNT;
499 } else if ((datatype == MPI_DATATYPE_NULL) || (not datatype->is_valid())) {
500 retval = MPI_ERR_TYPE;
502 int rank = smpi_process()->index();
504 win->get_group(&group);
505 TRACE_smpi_ptp_in(rank, __FUNCTION__, nullptr);
507 retval = win->compare_and_swap( origin_addr, compare_addr, result_addr, datatype,
508 target_rank, target_disp);
510 TRACE_smpi_ptp_out(rank, rank, __FUNCTION__);
516 int PMPI_Win_post(MPI_Group group, int assert, MPI_Win win){
519 if (win == MPI_WIN_NULL) {
520 retval = MPI_ERR_WIN;
521 } else if (group==MPI_GROUP_NULL){
522 retval = MPI_ERR_GROUP;
524 int rank = smpi_process()->index();
525 TRACE_smpi_collective_in(rank, __FUNCTION__, nullptr);
526 retval = win->post(group,assert);
527 TRACE_smpi_collective_out(rank, __FUNCTION__);
533 int PMPI_Win_start(MPI_Group group, int assert, MPI_Win win){
536 if (win == MPI_WIN_NULL) {
537 retval = MPI_ERR_WIN;
538 } else if (group==MPI_GROUP_NULL){
539 retval = MPI_ERR_GROUP;
541 int rank = smpi_process()->index();
542 TRACE_smpi_collective_in(rank, __FUNCTION__, nullptr);
543 retval = win->start(group,assert);
544 TRACE_smpi_collective_out(rank, __FUNCTION__);
550 int PMPI_Win_complete(MPI_Win win){
553 if (win == MPI_WIN_NULL) {
554 retval = MPI_ERR_WIN;
556 int rank = smpi_process()->index();
557 TRACE_smpi_collective_in(rank, __FUNCTION__, nullptr);
559 retval = win->complete();
561 TRACE_smpi_collective_out(rank, __FUNCTION__);
567 int PMPI_Win_wait(MPI_Win win){
570 if (win == MPI_WIN_NULL) {
571 retval = MPI_ERR_WIN;
573 int rank = smpi_process()->index();
574 TRACE_smpi_collective_in(rank, __FUNCTION__, nullptr);
576 retval = win->wait();
578 TRACE_smpi_collective_out(rank, __FUNCTION__);
584 int PMPI_Win_lock(int lock_type, int rank, int assert, MPI_Win win){
587 if (win == MPI_WIN_NULL) {
588 retval = MPI_ERR_WIN;
589 } else if (lock_type != MPI_LOCK_EXCLUSIVE &&
590 lock_type != MPI_LOCK_SHARED) {
591 retval = MPI_ERR_LOCKTYPE;
592 } else if (rank == MPI_PROC_NULL){
593 retval = MPI_SUCCESS;
595 int myrank = smpi_process()->index();
596 TRACE_smpi_collective_in(myrank, __FUNCTION__, nullptr);
597 retval = win->lock(lock_type,rank,assert);
598 TRACE_smpi_collective_out(myrank, __FUNCTION__);
604 int PMPI_Win_unlock(int rank, MPI_Win win){
607 if (win == MPI_WIN_NULL) {
608 retval = MPI_ERR_WIN;
609 } else if (rank == MPI_PROC_NULL){
610 retval = MPI_SUCCESS;
612 int myrank = smpi_process()->index();
613 TRACE_smpi_collective_in(myrank, __FUNCTION__, nullptr);
614 retval = win->unlock(rank);
615 TRACE_smpi_collective_out(myrank, __FUNCTION__);
621 int PMPI_Win_lock_all(int assert, MPI_Win win){
624 if (win == MPI_WIN_NULL) {
625 retval = MPI_ERR_WIN;
627 int myrank = smpi_process()->index();
628 TRACE_smpi_collective_in(myrank, __FUNCTION__, nullptr);
629 retval = win->lock_all(assert);
630 TRACE_smpi_collective_out(myrank, __FUNCTION__);
636 int PMPI_Win_unlock_all(MPI_Win win){
639 if (win == MPI_WIN_NULL) {
640 retval = MPI_ERR_WIN;
642 int myrank = smpi_process()->index();
643 TRACE_smpi_collective_in(myrank, __FUNCTION__, nullptr);
644 retval = win->unlock_all();
645 TRACE_smpi_collective_out(myrank, __FUNCTION__);
651 int PMPI_Win_flush(int rank, MPI_Win win){
654 if (win == MPI_WIN_NULL) {
655 retval = MPI_ERR_WIN;
656 } else if (rank == MPI_PROC_NULL){
657 retval = MPI_SUCCESS;
659 int myrank = smpi_process()->index();
660 TRACE_smpi_collective_in(myrank, __FUNCTION__, nullptr);
661 retval = win->flush(rank);
662 TRACE_smpi_collective_out(myrank, __FUNCTION__);
668 int PMPI_Win_flush_local(int rank, MPI_Win win){
671 if (win == MPI_WIN_NULL) {
672 retval = MPI_ERR_WIN;
673 } else if (rank == MPI_PROC_NULL){
674 retval = MPI_SUCCESS;
676 int myrank = smpi_process()->index();
677 TRACE_smpi_collective_in(myrank, __FUNCTION__, nullptr);
678 retval = win->flush_local(rank);
679 TRACE_smpi_collective_out(myrank, __FUNCTION__);
685 int PMPI_Win_flush_all(MPI_Win win){
688 if (win == MPI_WIN_NULL) {
689 retval = MPI_ERR_WIN;
691 int myrank = smpi_process()->index();
692 TRACE_smpi_collective_in(myrank, __FUNCTION__, nullptr);
693 retval = win->flush_all();
694 TRACE_smpi_collective_out(myrank, __FUNCTION__);
700 int PMPI_Win_flush_local_all(MPI_Win win){
703 if (win == MPI_WIN_NULL) {
704 retval = MPI_ERR_WIN;
706 int myrank = smpi_process()->index();
707 TRACE_smpi_collective_in(myrank, __FUNCTION__, nullptr);
708 retval = win->flush_local_all();
709 TRACE_smpi_collective_out(myrank, __FUNCTION__);
716 int PMPI_Win_get_attr (MPI_Win win, int keyval, void *attribute_val, int* flag)
718 static MPI_Aint size;
719 static int disp_unit;
720 if (win==MPI_WIN_NULL)
725 *static_cast<void**>(attribute_val) = win->base();
730 *static_cast<MPI_Aint**>(attribute_val) = &size;
733 case MPI_WIN_DISP_UNIT :
734 disp_unit=win->disp_unit();
735 *static_cast<int**>(attribute_val) = &disp_unit;
739 return win->attr_get<simgrid::smpi::Win>(keyval, attribute_val, flag);
745 int PMPI_Win_set_attr (MPI_Win win, int type_keyval, void *attribute_val)
747 if (win==MPI_WIN_NULL)
750 return win->attr_put<simgrid::smpi::Win>(type_keyval, attribute_val);
753 int PMPI_Win_delete_attr (MPI_Win win, int type_keyval)
755 if (win==MPI_WIN_NULL)
758 return win->attr_delete<simgrid::smpi::Win>(type_keyval);
761 int PMPI_Win_create_keyval(MPI_Win_copy_attr_function* copy_fn, MPI_Win_delete_attr_function* delete_fn, int* keyval,
764 smpi_copy_fn _copy_fn={nullptr, nullptr, copy_fn};
765 smpi_delete_fn _delete_fn={nullptr, nullptr, delete_fn};
766 return simgrid::smpi::Keyval::keyval_create<simgrid::smpi::Win>(_copy_fn, _delete_fn, keyval, extra_state);
769 int PMPI_Win_free_keyval(int* keyval) {
770 return simgrid::smpi::Keyval::keyval_free<simgrid::smpi::Win>(keyval);
773 MPI_Win PMPI_Win_f2c(MPI_Fint win){
774 return static_cast<MPI_Win>(simgrid::smpi::Win::f2c(win));
777 MPI_Fint PMPI_Win_c2f(MPI_Win win){