Click here to Skip to main content
6,822,123 members and growing! (17,548 online)
Email Password   helpLost your password?
Platforms, Frameworks & Libraries » Windows Communication Foundation » General     Intermediate License: The Code Project Open License (CPOL)

Implementing parallel programming using MPI and C#

By Ali Hamdar

An example of implementing a parallel program using the pure MPI .NET library, C#, and .NET Remoting.
C#, Windows, .NET, WCF, WinForms, Dev
Posted:15 Apr 2008
Views:19,457
Bookmarked:26 times
printPrint   add Share
      Discuss Discuss   Broken Article?Report  
15 votes for this article.
Popularity: 4.56 Rating: 3.88 out of 5

1
2 votes, 13.3%
2
2 votes, 13.3%
3
1 vote, 6.7%
4
10 votes, 66.7%
5

Introduction

Pure .NET MPI is a completely managed implementation of MPI. The object-oriented API is powerful, yet easy to use for parallel programming. It has been developed based on the .NET Framework 3.0, and ported to 3.5 using much of Windows Communication Foundation (WCF).

With the help of WCF, you can use the configuration file to declare the number of process that you are using, which process is the master process, and the locations of the process on your network as IP addresses and ports.

What is most fantastic in Pure MPI .NET is that you can launch all your parallel programs as threads in one single process for debugging and testing issues.

Background

The .NET implementation of the Message Passing Interface (standard 2.0):

  • Built on Windows Communication Foundation (WCF).
  • Single process F5 experience for debugging and development.
  • Multi-threaded, multi-process, or multi-machine execution, and any combination there in.
  • MPI processors can run inside one process, or any number of processes on any number of machines.
  • Type-safe API.
  • x86, x64, and Itanium support.
  • Extensible. Supports existing and custom WCF bindings and channels. Adds higher level and custom synchronization mechanisms to communication objects.
  • Supports communication timeouts for deadlock detection and better error handling.
  • Environment and WCF settings completely configurable.

Using the code

This example draws a MandelBrot set using more than one process.

The attachments constitute of three different projects:

  1. The interface that draws the MandelBrot set.
  2. The MPI program.
  3. The library containing the marshaled objects.

The interface can work in sequential mode and in parallel mode.

When working in parallel mode, the interface will launch the MPI-enabled processes to calculate the MandelBrot set, and will use .NET Remoting to collect the result from the master process, as follows:

TcpChannel channel = new TcpChannel(8090);
ChannelServices.RegisterChannel(channel, false);
RemotingConfiguration.RegisterWellKnownServiceType(typeof(Points), 
                      "MandelBrot", WellKnownObjectMode.SingleCall);
Cache.Attach(observer);

The following is the implementation of the master process:

Console.WriteLine("Master Process: Working...");

int row = 0;
for (int i = 1; i < comm.Size; i++)
{
    comm.Send<int>(i, "ROW_NUMBER", row);
    row += processIncrement;
}

ArrayList list = new ArrayList();
int max = (int)Math.Floor((double)width * height / partition) + 1;
for (int i = 0; i <= max; i++)
{
    ArrayList partList = 
      comm.Receive<ArrayList>(Constants.AnySource, "RESULT");

    if (partList != null)
        list.AddRange(partList);
}

Points points;

TcpChannel chan = new TcpChannel();
ChannelServices.RegisterChannel(chan, false);

points = (Points)Activator.GetObject(typeof(Points), 
          "tcp://localhost:8090/MandelBrot");

points.SetMessage(list);

Console.WriteLine("Finished Calculating: " + list.Count + " points.");

The following is the implementation of the slave process:

Console.WriteLine("Slave Process: " + comm.Rank + ".Working...");

int row = comm.Receive<int>(0, "ROW_NUMBER");

decimal scaleX = (maxNumber.Real - minNumber.Real) / width;
decimal scaleY = (maxNumber.Imaginary - minNumber.Imaginary) / height;

ComplexNumber c = new ComplexNumber();

ArrayList list = new ArrayList();

c.Real = minNumber.Real;
for (int x = 0; x < width; x++)
{
    c.Imaginary = minNumber.Imaginary + row * scaleY;
    for (int y = row; y < (row + processIncrement); y++)
    {
        int count = CalculatePixel(c);

        PointSet set = new PointSet();
        set.W = x;
        set.H = y;
        set.Pixel = count;

        list.Add(set);

        c.Imaginary += scaleY;

        if (list.Count == partition)
        {
            comm.Send<ArrayList>(0, "RESULT", list);
            list.Clear();
        }
    }

    c.Real += scaleX;
}

if (list.Count > 0)
{
    comm.Send<ArrayList>(0, "RESULT", list);
}

Console.WriteLine("Done");

The configuration file should be set as necessary to determine the number of processes and where the processes will launch.

License

This article, along with any associated source code and files, is licensed under The Code Project Open License (CPOL)

About the Author

Ali Hamdar


Member
Been programming since 2001 interested in finance, defense planning, workflows. He is an MCSD, MCDBA, MCAD, MCSD, (again), MCTS, MCPD and MCT.
http://www.ids.com.lb
Occupation: Software Developer (Senior)
Company: Integrated Digital Systems - IDS
Location: Lebanon Lebanon

Other popular Windows Communication Foundation articles:

Article Top
You must Sign In to use this message board.
FAQ FAQ 
 
Noise Tolerance  Layout  Per page   
 Msgs 1 to 6 of 6 (Total in Forum: 6) (Refresh)FirstPrevNext
GeneralCrashes for me Pinmembersam.hill16:21 15 Apr '08  
GeneralRe: Crashes for me Pinmemberlhfiedler0:06 22 Apr '08  
GeneralRe: Crashes for me PinmemberMember 17701853:40 13 Jun '08  
GeneralRe: Crashes for me Pinmemberlhfiedler9:35 7 Jul '08  
GeneralRe: Crashes for me PinmemberDmitri Nesteruk5:10 6 Jul '08  
GeneralRe: Crashes for me [modified] Pinmembertitan688:35 10 Dec '09  

General General    News News    Question Question    Answer Answer    Joke Joke    Rant Rant    Admin Admin   

Use Ctrl+Left/Right to switch messages, Ctrl+Up/Down to switch threads.

PermaLink | Privacy | Terms of Use
Last Updated: 15 Apr 2008
Editor: Smitha Vijayan
Copyright 2008 by Ali Hamdar
Everything else Copyright © CodeProject, 1999-2010
Web17 | Advertise on the Code Project