summaryrefslogtreecommitdiff
path: root/benchmarks/CUDA/DG/3rdParty/ParMetis-3.1/ParMETISLib/kwayrefine.c
diff options
context:
space:
mode:
authorTor Aamodt <[email protected]>2010-07-15 18:09:46 -0800
committerTor Aamodt <[email protected]>2010-07-15 18:09:46 -0800
commit69f2911e04ffb1b19eef1fafb8c040af271f656e (patch)
tree231d3b6bdc3a202f7c255bfcf7bf2c36e32cee9e /benchmarks/CUDA/DG/3rdParty/ParMetis-3.1/ParMETISLib/kwayrefine.c
creating branch for adding support for CUDA 3.x and Fermi
[git-p4: depot-paths = "//depot/gpgpu_sim_research/fermi/distribution/": change = 6829]
Diffstat (limited to 'benchmarks/CUDA/DG/3rdParty/ParMetis-3.1/ParMETISLib/kwayrefine.c')
-rw-r--r--benchmarks/CUDA/DG/3rdParty/ParMetis-3.1/ParMETISLib/kwayrefine.c239
1 files changed, 239 insertions, 0 deletions
diff --git a/benchmarks/CUDA/DG/3rdParty/ParMetis-3.1/ParMETISLib/kwayrefine.c b/benchmarks/CUDA/DG/3rdParty/ParMetis-3.1/ParMETISLib/kwayrefine.c
new file mode 100644
index 0000000..e4b776e
--- /dev/null
+++ b/benchmarks/CUDA/DG/3rdParty/ParMetis-3.1/ParMETISLib/kwayrefine.c
@@ -0,0 +1,239 @@
+/*
+ * Copyright 1997, Regents of the University of Minnesota
+ *
+ * medge_refine.c
+ *
+ * This file contains code that performs the k-way refinement
+ *
+ * Started 3/1/96
+ * George
+ *
+ * $Id: kwayrefine.c,v 1.2 2003/07/21 17:18:49 karypis Exp $
+ */
+
+#include <parmetislib.h>
+
+#define ProperSide(c, from, other) \
+ (((c) == 0 && (from)-(other) < 0) || ((c) == 1 && (from)-(other) > 0))
+
+/*************************************************************************
+* This function projects a partition.
+**************************************************************************/
+void Moc_ProjectPartition(CtrlType *ctrl, GraphType *graph, WorkSpaceType *wspace)
+{
+ int i, nvtxs, nnbrs = -1, firstvtx, cfirstvtx;
+ idxtype *match, *cmap, *where, *cwhere;
+ idxtype *peind, *slens = NULL, *rlens = NULL;
+ KeyValueType *rcand, *scand = NULL;
+ GraphType *cgraph;
+
+
+ IFSET(ctrl->dbglvl, DBG_TIME, starttimer(ctrl->ProjectTmr));
+
+ cgraph = graph->coarser;
+ cwhere = cgraph->where;
+ cfirstvtx = cgraph->vtxdist[ctrl->mype];
+
+ nvtxs = graph->nvtxs;
+ match = graph->match;
+ cmap = graph->cmap;
+ where = graph->where = idxmalloc(nvtxs+graph->nrecv, "ProjectPartition: graph->where");
+ firstvtx = graph->vtxdist[ctrl->mype];
+
+
+ if (graph->match_type == MATCH_GLOBAL) { /* Only if global matching is on */
+ /*------------------------------------------------------------
+ / Start the transmission of the remote where information
+ /------------------------------------------------------------*/
+ scand = wspace->pairs;
+ nnbrs = graph->nnbrs;
+ peind = graph->peind;
+ slens = graph->slens;
+ rlens = graph->rlens;
+ rcand = graph->rcand;
+
+ /* Issue the receives first */
+ for (i=0; i<nnbrs; i++) {
+ if (slens[i+1]-slens[i] > 0) /* Issue a receive only if you are getting something */
+ MPI_Irecv((void *)(scand+slens[i]), 2*(slens[i+1]-slens[i]), IDX_DATATYPE, peind[i], 1, ctrl->comm, ctrl->rreq+i);
+ }
+
+#ifdef DEBUG_PROJECT
+ PrintPairs(ctrl, rlens[nnbrs], rcand, "rcand");
+#endif
+
+ /* Put the where[rcand[].key] into the val field */
+ for (i=0; i<rlens[nnbrs]; i++) {
+ ASSERT(ctrl, rcand[i].val >= 0 && rcand[i].val < cgraph->nvtxs);
+ rcand[i].val = cwhere[rcand[i].val];
+ }
+
+#ifdef DEBUG_PROJECT
+ PrintPairs(ctrl, rlens[nnbrs], rcand, "rcand");
+ PrintVector(ctrl, nvtxs, firstvtx, cmap, "cmap");
+#endif
+
+ /* Issue the sends next */
+ for (i=0; i<nnbrs; i++) {
+ if (rlens[i+1]-rlens[i] > 0) /* Issue a send only if you are sending something */
+ MPI_Isend((void *)(rcand+rlens[i]), 2*(rlens[i+1]-rlens[i]), IDX_DATATYPE, peind[i], 1, ctrl->comm, ctrl->sreq+i);
+ }
+ }
+
+ /*------------------------------------------------------------
+ / Project local vertices first
+ /------------------------------------------------------------*/
+ for (i=0; i<nvtxs; i++) {
+ if (match[i] >= KEEP_BIT) {
+ ASSERT(ctrl, cmap[i]-cfirstvtx>=0 && cmap[i]-cfirstvtx<cgraph->nvtxs);
+ where[i] = cwhere[cmap[i]-cfirstvtx];
+ }
+ }
+
+ if (graph->match_type == MATCH_GLOBAL) { /* Only if global matching is on */
+ /*------------------------------------------------------------
+ / Wait for the nonblocking operations to finish
+ /------------------------------------------------------------*/
+ for (i=0; i<nnbrs; i++) {
+ if (rlens[i+1]-rlens[i] > 0)
+ MPI_Wait(ctrl->sreq+i, &ctrl->status);
+ }
+ for (i=0; i<nnbrs; i++) {
+ if (slens[i+1]-slens[i] > 0)
+ MPI_Wait(ctrl->rreq+i, &ctrl->status);
+ }
+
+#ifdef DEBUG_PROJECT
+ PrintPairs(ctrl, slens[nnbrs], scand, "scand");
+#endif
+
+ /*------------------------------------------------------------
+ / Project received vertices now
+ /------------------------------------------------------------*/
+ for (i=0; i<slens[nnbrs]; i++) {
+ ASSERTP(ctrl, scand[i].key-firstvtx>=0 && scand[i].key-firstvtx<graph->nvtxs, (ctrl, "%d %d %d\n", scand[i].key, firstvtx, graph->nvtxs));
+ where[scand[i].key-firstvtx] = scand[i].val;
+ }
+ }
+
+
+ FreeGraph(graph->coarser);
+ graph->coarser = NULL;
+
+ IFSET(ctrl->dbglvl, DBG_TIME, stoptimer(ctrl->ProjectTmr));
+}
+
+
+
+/*************************************************************************
+* This function computes the initial id/ed
+**************************************************************************/
+void Moc_ComputePartitionParams(CtrlType *ctrl, GraphType *graph, WorkSpaceType *wspace)
+{
+ int h, i, j, k;
+ int nvtxs, ncon;
+ int firstvtx, lastvtx;
+ idxtype *xadj, *ladjncy, *adjwgt, *vtxdist;
+ float *lnpwgts, *gnpwgts;
+ idxtype *where, *swhere, *rwhere;
+ RInfoType *rinfo, *myrinfo;
+ EdgeType *edegrees;
+ int me, other;
+
+ IFSET(ctrl->dbglvl, DBG_TIME, starttimer(ctrl->KWayInitTmr));
+
+
+ nvtxs = graph->nvtxs;
+ ncon = graph->ncon;
+
+ vtxdist = graph->vtxdist;
+ xadj = graph->xadj;
+ ladjncy = graph->adjncy;
+ adjwgt = graph->adjwgt;
+
+ where = graph->where;
+ rinfo = graph->rinfo = (RInfoType *)GKmalloc(sizeof(RInfoType)*nvtxs, "CPP: rinfo");
+ lnpwgts = graph->lnpwgts = fmalloc(ctrl->nparts*ncon, "CPP: lnpwgts");
+ gnpwgts = graph->gnpwgts = fmalloc(ctrl->nparts*ncon, "CPP: gnpwgts");
+
+ sset(ctrl->nparts*ncon, 0, lnpwgts);
+
+ firstvtx = vtxdist[ctrl->mype];
+ lastvtx = vtxdist[ctrl->mype+1];
+
+ /*------------------------------------------------------------
+ / Send/Receive the where information of interface vertices
+ /------------------------------------------------------------*/
+ swhere = wspace->indices;
+ rwhere = where + nvtxs;
+
+ CommInterfaceData(ctrl, graph, where, swhere, rwhere);
+
+#ifdef DEBUG_COMPUTEPPARAM
+ PrintVector(ctrl, nvtxs, firstvtx, where, "where");
+#endif
+
+ ASSERT(ctrl, wspace->nlarge >= xadj[nvtxs]);
+
+ /*------------------------------------------------------------
+ / Compute now the id/ed degrees
+ /------------------------------------------------------------*/
+ graph->lmincut = 0;
+ for (i=0; i<nvtxs; i++) {
+ me = where[i];
+ myrinfo = rinfo+i;
+
+ for (h=0; h<ncon; h++)
+ lnpwgts[me*ncon+h] += graph->nvwgt[i*ncon+h];
+
+ myrinfo->degrees = wspace->degrees + xadj[i];
+ myrinfo->ndegrees = myrinfo->id = myrinfo->ed = 0;
+
+ for (j=xadj[i]; j<xadj[i+1]; j++) {
+ if (me == where[ladjncy[j]])
+ myrinfo->id += adjwgt[j];
+ else
+ myrinfo->ed += adjwgt[j];
+ }
+
+
+ if (myrinfo->ed > 0) { /* Time to do some serious work */
+ graph->lmincut += myrinfo->ed;
+ edegrees = myrinfo->degrees;
+
+ for (j=xadj[i]; j<xadj[i+1]; j++) {
+ other = where[ladjncy[j]];
+ if (me != other) {
+ for (k=0; k<myrinfo->ndegrees; k++) {
+ if (edegrees[k].edge == other) {
+ edegrees[k].ewgt += adjwgt[j];
+ break;
+ }
+ }
+ if (k == myrinfo->ndegrees) {
+ edegrees[k].edge = other;
+ edegrees[k].ewgt = adjwgt[j];
+ myrinfo->ndegrees++;
+ }
+ ASSERT(ctrl, myrinfo->ndegrees <= xadj[i+1]-xadj[i]);
+ }
+ }
+ }
+ }
+
+#ifdef DEBUG_COMPUTEPPARAM
+ PrintVector(ctrl, ctrl->nparts*ncon, 0, lnpwgts, "lnpwgts");
+#endif
+
+ /* Finally, sum-up the partition weights */
+ MPI_Allreduce((void *)lnpwgts, (void *)gnpwgts, ctrl->nparts*ncon, MPI_FLOAT, MPI_SUM, ctrl->comm);
+
+ graph->mincut = GlobalSESum(ctrl, graph->lmincut)/2;
+
+#ifdef DEBUG_COMPUTEPPARAM
+ PrintVector(ctrl, ctrl->nparts*ncon, 0, gnpwgts, "gnpwgts");
+#endif
+
+ IFSET(ctrl->dbglvl, DBG_TIME, stoptimer(ctrl->KWayInitTmr));
+}
+