Skip to content
GitLab
Explore
Sign in
Primary navigation
Search or go to…
Project
D
dune-uggrid
Manage
Activity
Members
Labels
Plan
Issues
Issue boards
Milestones
Wiki
Code
Merge requests
Repository
Branches
Commits
Tags
Repository graph
Compare revisions
Build
Pipelines
Jobs
Pipeline schedules
Artifacts
Deploy
Releases
Model registry
Operate
Environments
Monitor
Incidents
Service Desk
Analyze
Value stream analytics
Contributor analytics
CI/CD analytics
Repository analytics
Model experiments
Help
Help
Support
GitLab documentation
Compare GitLab plans
Community forum
Contribute to GitLab
Provide feedback
Keyboard shortcuts
?
Snippets
Groups
Projects
Show more breadcrumbs
staging
dune-uggrid
Commits
b8476ecb
Commit
b8476ecb
authored
6 years ago
by
Ansgar Burchardt
Browse files
Options
Downloads
Patches
Plain Diff
PPIF: remove now unused functions not taking a context object
parent
f6a816e6
No related branches found
Branches containing commit
No related tags found
Tags containing commit
1 merge request
!96
DDD: move global state to a context object
Changes
2
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
parallel/ppif/MPI/ppif.cc
+0
-90
0 additions, 90 deletions
parallel/ppif/MPI/ppif.cc
parallel/ppif/ppif.h
+0
-18
0 additions, 18 deletions
parallel/ppif/ppif.h
with
0 additions
and
108 deletions
parallel/ppif/MPI/ppif.cc
+
0
−
90
View file @
b8476ecb
...
@@ -317,11 +317,6 @@ int PPIF::Broadcast (const PPIFContext& context, void *data, int size)
...
@@ -317,11 +317,6 @@ int PPIF::Broadcast (const PPIFContext& context, void *data, int size)
return
(
PPIF_SUCCESS
);
return
(
PPIF_SUCCESS
);
}
}
int
PPIF
::
Broadcast
(
void
*
data
,
int
size
)
{
return
Broadcast
(
*
ppifContext
(),
data
,
size
);
}
int
PPIF
::
Concentrate
(
const
PPIFContext
&
context
,
void
*
data
,
int
size
)
int
PPIF
::
Concentrate
(
const
PPIFContext
&
context
,
void
*
data
,
int
size
)
{
{
if
(
not
context
.
isMaster
())
if
(
not
context
.
isMaster
())
...
@@ -330,11 +325,6 @@ int PPIF::Concentrate (const PPIFContext& context, void *data, int size)
...
@@ -330,11 +325,6 @@ int PPIF::Concentrate (const PPIFContext& context, void *data, int size)
return
(
PPIF_SUCCESS
);
return
(
PPIF_SUCCESS
);
}
}
int
PPIF
::
Concentrate
(
void
*
data
,
int
size
)
{
return
Concentrate
(
*
ppifContext
(),
data
,
size
);
}
int
PPIF
::
GetConcentrate
(
const
PPIFContext
&
context
,
int
slave
,
void
*
data
,
int
size
)
int
PPIF
::
GetConcentrate
(
const
PPIFContext
&
context
,
int
slave
,
void
*
data
,
int
size
)
{
{
if
(
slave
<
context
.
degree
())
if
(
slave
<
context
.
degree
())
...
@@ -343,11 +333,6 @@ int PPIF::GetConcentrate(const PPIFContext& context, int slave, void *data, int
...
@@ -343,11 +333,6 @@ int PPIF::GetConcentrate(const PPIFContext& context, int slave, void *data, int
return
(
PPIF_SUCCESS
);
return
(
PPIF_SUCCESS
);
}
}
int
PPIF
::
GetConcentrate
(
int
slave
,
void
*
data
,
int
size
)
{
return
GetConcentrate
(
*
ppifContext
(),
slave
,
data
,
size
);
}
int
PPIF
::
Spread
(
const
PPIFContext
&
context
,
int
slave
,
void
*
data
,
int
size
)
int
PPIF
::
Spread
(
const
PPIFContext
&
context
,
int
slave
,
void
*
data
,
int
size
)
{
{
if
(
slave
<
context
.
degree
())
if
(
slave
<
context
.
degree
())
...
@@ -356,11 +341,6 @@ int PPIF::Spread(const PPIFContext& context, int slave, void *data, int size)
...
@@ -356,11 +341,6 @@ int PPIF::Spread(const PPIFContext& context, int slave, void *data, int size)
return
(
PPIF_SUCCESS
);
return
(
PPIF_SUCCESS
);
}
}
int
PPIF
::
Spread
(
int
slave
,
void
*
data
,
int
size
)
{
return
Spread
(
*
ppifContext
(),
slave
,
data
,
size
);
}
int
PPIF
::
GetSpread
(
const
PPIFContext
&
context
,
void
*
data
,
int
size
)
int
PPIF
::
GetSpread
(
const
PPIFContext
&
context
,
void
*
data
,
int
size
)
{
{
if
(
not
context
.
isMaster
())
if
(
not
context
.
isMaster
())
...
@@ -369,11 +349,6 @@ int PPIF::GetSpread(const PPIFContext& context, void *data, int size)
...
@@ -369,11 +349,6 @@ int PPIF::GetSpread(const PPIFContext& context, void *data, int size)
return
(
PPIF_SUCCESS
);
return
(
PPIF_SUCCESS
);
}
}
int
PPIF
::
GetSpread
(
void
*
data
,
int
size
)
{
return
GetSpread
(
*
ppifContext
(),
data
,
size
);
}
int
PPIF
::
Synchronize
(
const
PPIFContext
&
context
)
int
PPIF
::
Synchronize
(
const
PPIFContext
&
context
)
{
{
if
(
MPI_SUCCESS
!=
MPI_Barrier
(
context
.
comm
())
)
return
(
PPIF_FAILURE
);
if
(
MPI_SUCCESS
!=
MPI_Barrier
(
context
.
comm
())
)
return
(
PPIF_FAILURE
);
...
@@ -381,11 +356,6 @@ int PPIF::Synchronize(const PPIFContext& context)
...
@@ -381,11 +356,6 @@ int PPIF::Synchronize(const PPIFContext& context)
return
(
PPIF_SUCCESS
);
return
(
PPIF_SUCCESS
);
}
}
int
PPIF
::
Synchronize
()
{
return
Synchronize
(
*
ppifContext
());
}
/****************************************************************************/
/****************************************************************************/
/* */
/* */
/* Synchronous communication */
/* Synchronous communication */
...
@@ -397,11 +367,6 @@ VChannelPtr PPIF::ConnSync(const PPIFContext&, int p, int id)
...
@@ -397,11 +367,6 @@ VChannelPtr PPIF::ConnSync(const PPIFContext&, int p, int id)
return
NewVChan
(
p
,
id
);
return
NewVChan
(
p
,
id
);
}
}
VChannelPtr
PPIF
::
ConnSync
(
int
p
,
int
id
)
{
return
ConnSync
(
*
ppifContext
(),
p
,
id
);
}
int
PPIF
::
DiscSync
(
const
PPIFContext
&
,
VChannelPtr
v
)
int
PPIF
::
DiscSync
(
const
PPIFContext
&
,
VChannelPtr
v
)
{
{
DeleteVChan
(
v
);
DeleteVChan
(
v
);
...
@@ -409,11 +374,6 @@ int PPIF::DiscSync(const PPIFContext&, VChannelPtr v)
...
@@ -409,11 +374,6 @@ int PPIF::DiscSync(const PPIFContext&, VChannelPtr v)
return
(
0
);
return
(
0
);
}
}
int
PPIF
::
DiscSync
(
VChannelPtr
v
)
{
return
DiscSync
(
*
ppifContext
(),
v
);
}
int
PPIF
::
SendSync
(
const
PPIFContext
&
context
,
VChannelPtr
v
,
void
*
data
,
int
size
)
int
PPIF
::
SendSync
(
const
PPIFContext
&
context
,
VChannelPtr
v
,
void
*
data
,
int
size
)
{
{
if
(
MPI_SUCCESS
==
MPI_Ssend
(
data
,
size
,
MPI_BYTE
,
if
(
MPI_SUCCESS
==
MPI_Ssend
(
data
,
size
,
MPI_BYTE
,
...
@@ -423,11 +383,6 @@ int PPIF::SendSync(const PPIFContext& context, VChannelPtr v, void *data, int si
...
@@ -423,11 +383,6 @@ int PPIF::SendSync(const PPIFContext& context, VChannelPtr v, void *data, int si
return
(
-
1
);
return
(
-
1
);
}
}
int
PPIF
::
SendSync
(
VChannelPtr
v
,
void
*
data
,
int
size
)
{
return
SendSync
(
*
ppifContext
(),
v
,
data
,
size
);
}
int
PPIF
::
RecvSync
(
const
PPIFContext
&
context
,
VChannelPtr
v
,
void
*
data
,
int
size
)
int
PPIF
::
RecvSync
(
const
PPIFContext
&
context
,
VChannelPtr
v
,
void
*
data
,
int
size
)
{
{
int
count
=
-
1
;
int
count
=
-
1
;
...
@@ -440,11 +395,6 @@ int PPIF::RecvSync(const PPIFContext& context, VChannelPtr v, void *data, int si
...
@@ -440,11 +395,6 @@ int PPIF::RecvSync(const PPIFContext& context, VChannelPtr v, void *data, int si
return
(
count
);
return
(
count
);
}
}
int
PPIF
::
RecvSync
(
VChannelPtr
v
,
void
*
data
,
int
size
)
{
return
RecvSync
(
*
ppifContext
(),
v
,
data
,
size
);
}
/****************************************************************************/
/****************************************************************************/
/* */
/* */
/* Asynchronous communication */
/* Asynchronous communication */
...
@@ -456,42 +406,22 @@ VChannelPtr PPIF::ConnASync(const PPIFContext&, int p, int id)
...
@@ -456,42 +406,22 @@ VChannelPtr PPIF::ConnASync(const PPIFContext&, int p, int id)
return
NewVChan
(
p
,
id
);
return
NewVChan
(
p
,
id
);
}
}
VChannelPtr
PPIF
::
ConnASync
(
int
p
,
int
id
)
{
return
ConnASync
(
*
ppifContext
(),
p
,
id
);
}
int
PPIF
::
InfoAConn
(
const
PPIFContext
&
,
VChannelPtr
v
)
int
PPIF
::
InfoAConn
(
const
PPIFContext
&
,
VChannelPtr
v
)
{
{
return
(
v
?
1
:
-
1
);
return
(
v
?
1
:
-
1
);
}
}
int
PPIF
::
InfoAConn
(
VChannelPtr
v
)
{
return
InfoAConn
(
*
ppifContext
(),
v
);
}
int
PPIF
::
DiscASync
(
const
PPIFContext
&
,
VChannelPtr
v
)
int
PPIF
::
DiscASync
(
const
PPIFContext
&
,
VChannelPtr
v
)
{
{
DeleteVChan
(
v
);
DeleteVChan
(
v
);
return
(
PPIF_SUCCESS
);
return
(
PPIF_SUCCESS
);
}
}
int
PPIF
::
DiscASync
(
VChannelPtr
v
)
{
return
DiscASync
(
*
ppifContext
(),
v
);
}
int
PPIF
::
InfoADisc
(
const
PPIFContext
&
,
VChannelPtr
v
)
int
PPIF
::
InfoADisc
(
const
PPIFContext
&
,
VChannelPtr
v
)
{
{
return
(
true
);
return
(
true
);
}
}
int
PPIF
::
InfoADisc
(
VChannelPtr
v
)
{
return
InfoADisc
(
*
ppifContext
(),
v
);
}
msgid
PPIF
::
SendASync
(
const
PPIFContext
&
context
,
VChannelPtr
v
,
void
*
data
,
int
size
,
int
*
error
)
msgid
PPIF
::
SendASync
(
const
PPIFContext
&
context
,
VChannelPtr
v
,
void
*
data
,
int
size
,
int
*
error
)
{
{
msgid
m
=
new
PPIF
::
Msg
;
msgid
m
=
new
PPIF
::
Msg
;
...
@@ -510,11 +440,6 @@ msgid PPIF::SendASync(const PPIFContext& context, VChannelPtr v, void *data, int
...
@@ -510,11 +440,6 @@ msgid PPIF::SendASync(const PPIFContext& context, VChannelPtr v, void *data, int
return
NULL
;
return
NULL
;
}
}
msgid
PPIF
::
SendASync
(
VChannelPtr
v
,
void
*
data
,
int
size
,
int
*
error
)
{
return
SendASync
(
*
ppifContext
(),
v
,
data
,
size
,
error
);
}
msgid
PPIF
::
RecvASync
(
const
PPIFContext
&
context
,
VChannelPtr
v
,
void
*
data
,
int
size
,
int
*
error
)
msgid
PPIF
::
RecvASync
(
const
PPIFContext
&
context
,
VChannelPtr
v
,
void
*
data
,
int
size
,
int
*
error
)
{
{
msgid
m
=
new
PPIF
::
Msg
;
msgid
m
=
new
PPIF
::
Msg
;
...
@@ -533,11 +458,6 @@ msgid PPIF::RecvASync(const PPIFContext& context, VChannelPtr v, void *data, int
...
@@ -533,11 +458,6 @@ msgid PPIF::RecvASync(const PPIFContext& context, VChannelPtr v, void *data, int
return
(
NULL
);
return
(
NULL
);
}
}
msgid
PPIF
::
RecvASync
(
VChannelPtr
v
,
void
*
data
,
int
size
,
int
*
error
)
{
return
RecvASync
(
*
ppifContext
(),
v
,
data
,
size
,
error
);
}
int
PPIF
::
InfoASend
(
const
PPIFContext
&
,
VChannelPtr
v
,
msgid
m
)
int
PPIF
::
InfoASend
(
const
PPIFContext
&
,
VChannelPtr
v
,
msgid
m
)
{
{
int
complete
;
int
complete
;
...
@@ -556,11 +476,6 @@ int PPIF::InfoASend(const PPIFContext&, VChannelPtr v, msgid m)
...
@@ -556,11 +476,6 @@ int PPIF::InfoASend(const PPIFContext&, VChannelPtr v, msgid m)
return
(
-
1
);
/* return -1 for FAILURE */
return
(
-
1
);
/* return -1 for FAILURE */
}
}
int
PPIF
::
InfoASend
(
VChannelPtr
v
,
msgid
m
)
{
return
InfoASend
(
*
ppifContext
(),
v
,
m
);
}
int
PPIF
::
InfoARecv
(
const
PPIFContext
&
,
VChannelPtr
v
,
msgid
m
)
int
PPIF
::
InfoARecv
(
const
PPIFContext
&
,
VChannelPtr
v
,
msgid
m
)
{
{
int
complete
;
int
complete
;
...
@@ -578,8 +493,3 @@ int PPIF::InfoARecv(const PPIFContext&, VChannelPtr v, msgid m)
...
@@ -578,8 +493,3 @@ int PPIF::InfoARecv(const PPIFContext&, VChannelPtr v, msgid m)
return
(
-
1
);
/* return -1 for FAILURE */
return
(
-
1
);
/* return -1 for FAILURE */
}
}
int
PPIF
::
InfoARecv
(
VChannelPtr
v
,
msgid
m
)
{
return
InfoARecv
(
*
ppifContext
(),
v
,
m
);
}
This diff is collapsed.
Click to expand it.
parallel/ppif/ppif.h
+
0
−
18
View file @
b8476ecb
...
@@ -94,45 +94,27 @@ int ExitPPIF (void);
...
@@ -94,45 +94,27 @@ int ExitPPIF (void);
/* tree oriented functions */
/* tree oriented functions */
int
Broadcast
(
const
PPIFContext
&
context
,
void
*
data
,
int
size
);
int
Broadcast
(
const
PPIFContext
&
context
,
void
*
data
,
int
size
);
int
Broadcast
(
void
*
data
,
int
size
);
int
Concentrate
(
const
PPIFContext
&
context
,
void
*
data
,
int
size
);
int
Concentrate
(
const
PPIFContext
&
context
,
void
*
data
,
int
size
);
int
Concentrate
(
void
*
data
,
int
size
);
int
GetConcentrate
(
const
PPIFContext
&
context
,
int
slave
,
void
*
data
,
int
size
);
int
GetConcentrate
(
const
PPIFContext
&
context
,
int
slave
,
void
*
data
,
int
size
);
int
GetConcentrate
(
int
slave
,
void
*
data
,
int
size
);
int
Spread
(
const
PPIFContext
&
context
,
int
slave
,
void
*
data
,
int
size
);
int
Spread
(
const
PPIFContext
&
context
,
int
slave
,
void
*
data
,
int
size
);
int
Spread
(
int
slave
,
void
*
data
,
int
size
);
int
GetSpread
(
const
PPIFContext
&
context
,
void
*
data
,
int
size
);
int
GetSpread
(
const
PPIFContext
&
context
,
void
*
data
,
int
size
);
int
GetSpread
(
void
*
data
,
int
size
);
int
Synchronize
(
const
PPIFContext
&
context
);
int
Synchronize
(
const
PPIFContext
&
context
);
int
Synchronize
(
void
);
/* synchronous communication */
/* synchronous communication */
VChannelPtr
ConnSync
(
const
PPIFContext
&
context
,
int
p
,
int
id
);
VChannelPtr
ConnSync
(
const
PPIFContext
&
context
,
int
p
,
int
id
);
VChannelPtr
ConnSync
(
int
p
,
int
id
);
int
DiscSync
(
const
PPIFContext
&
context
,
VChannelPtr
vc
);
int
DiscSync
(
const
PPIFContext
&
context
,
VChannelPtr
vc
);
int
DiscSync
(
VChannelPtr
vc
);
int
SendSync
(
const
PPIFContext
&
context
,
VChannelPtr
vc
,
void
*
data
,
int
size
);
int
SendSync
(
const
PPIFContext
&
context
,
VChannelPtr
vc
,
void
*
data
,
int
size
);
int
SendSync
(
VChannelPtr
vc
,
void
*
data
,
int
size
);
int
RecvSync
(
const
PPIFContext
&
context
,
VChannelPtr
vc
,
void
*
data
,
int
size
);
int
RecvSync
(
const
PPIFContext
&
context
,
VChannelPtr
vc
,
void
*
data
,
int
size
);
int
RecvSync
(
VChannelPtr
vc
,
void
*
data
,
int
size
);
/* asynchronous communication */
/* asynchronous communication */
VChannelPtr
ConnASync
(
const
PPIFContext
&
context
,
int
p
,
int
id
);
VChannelPtr
ConnASync
(
const
PPIFContext
&
context
,
int
p
,
int
id
);
VChannelPtr
ConnASync
(
int
p
,
int
id
);
int
DiscASync
(
const
PPIFContext
&
context
,
VChannelPtr
vc
);
int
DiscASync
(
const
PPIFContext
&
context
,
VChannelPtr
vc
);
int
DiscASync
(
VChannelPtr
vc
);
msgid
SendASync
(
const
PPIFContext
&
context
,
VChannelPtr
vc
,
void
*
data
,
int
size
,
int
*
error
);
msgid
SendASync
(
const
PPIFContext
&
context
,
VChannelPtr
vc
,
void
*
data
,
int
size
,
int
*
error
);
msgid
SendASync
(
VChannelPtr
vc
,
void
*
data
,
int
size
,
int
*
error
);
msgid
RecvASync
(
const
PPIFContext
&
context
,
VChannelPtr
vc
,
void
*
data
,
int
size
,
int
*
error
);
msgid
RecvASync
(
const
PPIFContext
&
context
,
VChannelPtr
vc
,
void
*
data
,
int
size
,
int
*
error
);
msgid
RecvASync
(
VChannelPtr
vc
,
void
*
data
,
int
size
,
int
*
error
);
int
InfoAConn
(
const
PPIFContext
&
context
,
VChannelPtr
vc
);
int
InfoAConn
(
const
PPIFContext
&
context
,
VChannelPtr
vc
);
int
InfoAConn
(
VChannelPtr
vc
);
int
InfoADisc
(
const
PPIFContext
&
context
,
VChannelPtr
vc
);
int
InfoADisc
(
const
PPIFContext
&
context
,
VChannelPtr
vc
);
int
InfoADisc
(
VChannelPtr
vc
);
int
InfoASend
(
const
PPIFContext
&
context
,
VChannelPtr
vc
,
msgid
m
);
int
InfoASend
(
const
PPIFContext
&
context
,
VChannelPtr
vc
,
msgid
m
);
int
InfoASend
(
VChannelPtr
vc
,
msgid
m
);
int
InfoARecv
(
const
PPIFContext
&
context
,
VChannelPtr
vc
,
msgid
m
);
int
InfoARecv
(
const
PPIFContext
&
context
,
VChannelPtr
vc
,
msgid
m
);
int
InfoARecv
(
VChannelPtr
vc
,
msgid
m
);
}
// end namespace PPIF
}
// end namespace PPIF
...
...
This diff is collapsed.
Click to expand it.
Preview
0%
Loading
Try again
or
attach a new file
.
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Save comment
Cancel
Please
register
or
sign in
to comment