Package mpi4py :: Module MPI :: Class Win
[hide private]
[frames] | no frames]

Class Win


Window handle
Instance Methods [hide private]
None
Accumulate(self, origin: BufSpec, target_rank: int, target: OptionalTargetSpec=... = None, op: Op= SUM)
Accumulate data into the target process
Win
Allocate(cls, size: int, disp_unit: int= 1, info: Info= INFO_NULL, comm: Intracomm= COMM_SELF)
Create an window object for one-sided communication
Win
Allocate_shared(cls, size: int, disp_unit: int= 1, info: Info= INFO_NULL, comm: Intracomm= COMM_SELF)
Create an window object for one-sided communication
None
Attach(self, memory: Buffer)
Attach a local memory region
None
Call_errhandler(self, errorcode: int)
Call the error handler installed on a window
None
Compare_and_swap(self, origin: BufSpec, compare: BufSpec, result: BufSpec, target_rank: int, target_disp: int= 0)
Perform one-sided atomic compare-and-swap
None
Complete(self)
Completes an RMA operations begun after an Win.Start()
Win
Create(cls, memory: UnionBuffer=..., Bottom=..., None=..., disp_unit: int= 1, info: Info= INFO_NULL, comm: Intracomm= COMM_SELF)
Create an window object for one-sided communication
Win
Create_dynamic(cls, info: Info= INFO_NULL, comm: Intracomm= COMM_SELF)
Create an window object for one-sided communication
int
Create_keyval(cls, copy_fn: OptionalCallableWin=...=..., int=...=..., Any=...=..., Any=... = None, delete_fn: OptionalCallableWin=...=..., int=...=..., Any=...=..., None=... = None, nopython: bool= False)
Create a new attribute key for windows
None
Delete_attr(self, keyval: int)
Delete attribute value associated with a key
None
Detach(self, memory: Buffer)
Detach a local memory region
None
Fence(self, assertion: int= 0)
Perform an MPI fence synchronization on a window
None
Fetch_and_op(self, origin: BufSpec, result: BufSpec, target_rank: int, target_disp: int= 0, op: Op= SUM)
Perform one-sided read-modify-write
None
Flush(self, rank: int)
Complete all outstanding RMA operations at the given target
None
Flush_all(self)
Complete all outstanding RMA operations at all targets
None
Flush_local(self, rank: int)
Complete locally all outstanding RMA operations at the given target
None
Flush_local_all(self)
Complete locally all outstanding RMA opera- tions at all targets
None
Free(self)
Free a window
int
Free_keyval(cls, keyval: int)
Free an attribute key for windows
None
Get(self, origin: BufSpec, target_rank: int, target: OptionalTargetSpec=... = None)
Get data from a memory window on a remote process.
None
Get_accumulate(self, origin: BufSpec, result: BufSpec, target_rank: int, target: OptionalTargetSpec=... = None, op: Op= SUM)
Fetch-and-accumulate data into the target process
Optional[Union[int, Any]]
Get_attr(self, keyval: int)
Retrieve attribute value by key
Errhandler
Get_errhandler(self)
Get the error handler for a window
Group
Get_group(self)
Return a duplicate of the group of the communicator used to create the window
Info
Get_info(self)
Return the hints for a windows that are currently in use
str
Get_name(self)
Get the print name associated with the window
None
Lock(self, rank: int, lock_type: int= LOCK_EXCLUSIVE, assertion: int= 0)
Begin an RMA access epoch at the target process
None
Lock_all(self, assertion: int= 0)
Begin an RMA access epoch at all processes
None
Post(self, group: Group, assertion: int= 0)
Start an RMA exposure epoch
None
Put(self, origin: BufSpec, target_rank: int, target: OptionalTargetSpec=... = None)
Put data into a memory window on a remote process.
Request
Raccumulate(self, origin: BufSpec, target_rank: int, target: OptionalTargetSpec=... = None, op: Op= SUM)
Fetch-and-accumulate data into the target process
Request
Rget(self, origin: BufSpec, target_rank: int, target: OptionalTargetSpec=... = None)
Get data from a memory window on a remote process.
Request
Rget_accumulate(self, origin: BufSpec, result: BufSpec, target_rank: int, target: OptionalTargetSpec=... = None, op: Op= SUM)
Accumulate data into the target process using remote memory access.
Request
Rput(self, origin: BufSpec, target_rank: int, target: OptionalTargetSpec=... = None)
Put data into a memory window on a remote process.
None
Set_attr(self, keyval: int, attrval: Any)
Store attribute value associated with a key
None
Set_errhandler(self, errhandler: Errhandler)
Set the error handler for a window
None
Set_info(self, info: Info)
Set new values for the hints associated with a window
None
Set_name(self, name: str)
Set the print name associated with the window
Tuple[memory, int]
Shared_query(self, rank: int)
Query the process-local address for remote memory segments created with Win.Allocate_shared()
None
Start(self, group: Group, assertion: int= 0)
Start an RMA access epoch for MPI
None
Sync(self)
Synchronize public and private copies of the given window
bool
Test(self)
Test whether an RMA exposure epoch has completed
None
Unlock(self, rank: int)
Complete an RMA access epoch at the target process
None
Unlock_all(self)
Complete an RMA access epoch at all processes
Literal[True]
Wait(self)
Complete an RMA exposure epoch begun with Win.Post()
 
__eq__(y)
x==y
 
__ge__(y)
x>=y
 
__gt__(y)
x>y
 
__le__(y)
x<=y
 
__lt__(y)
x<y
 
__ne__(y)
x!=y
a new object with type S, a subtype of T
__new__(S, ...)
 
__nonzero__()
x != 0
Win
f2py(cls, arg: int)
int
py2f(self)
memory
tomemory(self)
Return window memory buffer

Inherited from object: __delattr__, __format__, __getattribute__, __hash__, __init__, __reduce__, __reduce_ex__, __repr__, __setattr__, __sizeof__, __str__, __subclasshook__

Properties [hide private]
  attrs
Win.attrs: Tuple[int, int, int] window attributes
  flavor
Win.flavor: int window create flavor
  group
Win.group: Group window group
  info
Win.info: Info window info
  model
Win.model: int window memory model
  name
Win.name: str window name

Inherited from object: __class__

Method Details [hide private]

__new__(S, ...)

 
Returns: a new object with type S, a subtype of T
Overrides: object.__new__