1.1 --- /dev/null	Thu Jan 01 00:00:00 1970 +0000
     1.2 +++ b/DKU_Fns.c	Tue Sep 24 08:08:18 2013 -0700
     1.3 @@ -0,0 +1,122 @@
     1.4 +/*
     1.5 + *  Copyright 2009 OpenSourceResearchInstitute.org
     1.6 + *  Licensed under GNU General Public License version 2
     1.7 + *
     1.8 + * Author: seanhalle@yahoo.com
     1.9 + *
    1.10 + */
    1.11 +
    1.12 +
    1.13 +#include <math.h>
    1.14 +#include <string.h>
    1.15 +#include "DKU__Test_App.h"
    1.16 +
    1.17 +/*Bare smoke test of DKU wrapper library functions.
    1.18 + * Create one DKU instance, with a dummy kernel
    1.19 + * Bare bones divider and undivider
    1.20 + * simple root piece maker
    1.21 + * dummy serial kernel
    1.22 + */
    1.23 +
    1.24 +int 
    1.25 +square( int x ) 
    1.26 + { return x*x; 
    1.27 + }
    1.28 +
    1.29 +
    1.30 +DKUPiece *
    1.31 +rootPieceMakerFn( void *params, DKUInstance *dkuInstance )
    1.32 + { DKUPiece      *rootPiece;
    1.33 + 
    1.34 +   rootPiece          = PRServ__DKU_make_empty_DKU_piece();
    1.35 +   rootPiece->parent  = NULL;
    1.36 +   rootPiece->payload = params;
    1.37 +   rootPiece->dkuInstance = dkuInstance;
    1.38 +   
    1.39 +   return rootPiece;
    1.40 + }
    1.41 +
    1.42 +DKUPiece *
    1.43 +make_root_dku_piece_for_test_inst( int32 *data, int32 size, 
    1.44 +                                   DKUInstance *dkuInstance )
    1.45 + { DKUPiece      *rootPiece;
    1.46 +   TestAppStruct *params;
    1.47 +   
    1.48 +   params = PR__malloc( sizeof(TestAppStruct) );
    1.49 +   params->startIter  = 0;
    1.50 +   params->endIter    = size-1;
    1.51 +   params->data       = data;
    1.52 +   params->size       = size;
    1.53 +   rootPiece = (*(dkuInstance->rootPieceMaker))( params, dkuInstance );
    1.54 +   return rootPiece;
    1.55 + } 
    1.56 +
    1.57 +
    1.58 +void 
    1.59 +kernelFn( void  *_params, SlaveVP *animVP )
    1.60 + { int32 i;
    1.61 +   DKUPiece *piece = (DKUPiece *)_params;
    1.62 +   TestAppStruct *params = (TestAppStruct *)piece->payload;
    1.63 +   int32 *data           = params->data;
    1.64 +   
    1.65 +         DEBUG__printf(dbgAppFlow, "Kernel %d", params->startIter);
    1.66 +   
    1.67 +   for( i=params->startIter; i <= params->endIter; ++i ) 
    1.68 +    { data[i] = square(i);
    1.69 +    }
    1.70 +   PRServ__DKU_end_kernel( piece, animVP );
    1.71 + }
    1.72 +
    1.73 +
    1.74 +/*Serial kernel is called with bare app-defined struct, not DKUPiece
    1.75 + */
    1.76 +void 
    1.77 +serialKernelFn( void *_params, SlaveVP *animVP )
    1.78 + { int32 i;
    1.79 +   TestAppStruct *params = (TestAppStruct *)_params;
    1.80 +   int32 *data = params->data;
    1.81 +   
    1.82 +         DEBUG__printf(dbgAppFlow, "SerialKernel %d", params->startIter);
    1.83 +   
    1.84 +   for( i=params->startIter; i < params->endIter; ++i ) 
    1.85 +    { data[i] = square(i);
    1.86 +    }
    1.87 +   PRServ__DKU_end_serial_kernel( animVP );
    1.88 + }
    1.89 +
    1.90 +void
    1.91 +dividerFn( DKUPiece *pieceToDivide )
    1.92 + {
    1.93 +   int32 idx, childIdx, numChildren, size, *data;
    1.94 +   DKUPiece *childPiece, **childrenArray;
    1.95 +   TestAppStruct *params;
    1.96 +         DEBUG__printf(dbgAppFlow, "divider %p", pieceToDivide)
    1.97 +   
    1.98 +   numChildren = pieceToDivide->numChildren;
    1.99 +   childrenArray = PR__malloc( numChildren * sizeof(DKUPiece *) );
   1.100 +   size = ((TestAppStruct*)pieceToDivide->payload)->size;
   1.101 +   data = ((TestAppStruct*)pieceToDivide->payload)->data;
   1.102 +   int chunkSize = size/numChildren; //for portability, lang would choose this dynamically at run time
   1.103 +   //note: should do processing to catch too small a chunksize and deal w/it
   1.104 +   for( childIdx = 0; childIdx < numChildren; childIdx++ ) 
   1.105 +    { params = PR__malloc(sizeof(TestAppStruct)); //these define work the task performs
   1.106 +      idx = childIdx * chunkSize;
   1.107 +      params->startIter = idx;
   1.108 +      params->endIter   = idx + chunkSize -1;
   1.109 +      params->data      = data;
   1.110 +      params->size      = size;
   1.111 +      childPiece = PRServ__DKU_make_child_piece_from( pieceToDivide );
   1.112 +      childPiece->payload = params;
   1.113 +      childrenArray[childIdx] = childPiece;
   1.114 +    }
   1.115 +   params->endIter = size -1; //catch truncation error from chunkSize calc
   1.116 +   
   1.117 +   pieceToDivide->children = childrenArray;
   1.118 + }
   1.119 +
   1.120 +void undividerFn( DKUPiece *piece )
   1.121 + {
   1.122 +         //DEBUG__printf(dbgAppFlow, "Undivider %p", piece)
   1.123 +   //nothing to do -- request handler does counting of completions 
   1.124 + }
   1.125 +

     2.1 --- /dev/null	Thu Jan 01 00:00:00 1970 +0000
     2.2 +++ b/DKU__Test_App.h	Tue Sep 24 08:08:18 2013 -0700
     2.3 @@ -0,0 +1,53 @@
     2.4 +/*
     2.5 + *  Copyright 2013 OpenSourceResearchInstitute.org
     2.6 + *  Licensed under GNU General Public License version 2
     2.7 + */
     2.8 +
     2.9 +#ifndef _DKU_TEST_APP_H_
    2.10 +#define _DKU_TEST_APP_H_
    2.11 +
    2.12 +#include <stdio.h>
    2.13 +
    2.14 +#include "../PR_defs__turn_on_and_off.h"
    2.15 +#include <PR__include/langlets/PRServ__wrapper_library.h>
    2.16 +
    2.17 +/*Bare smoke test of DKU wrapper library functions.
    2.18 + * Create one DKU instance, with a dummy kernel
    2.19 + * Bare bones divider and undivider
    2.20 + * simple root piece maker
    2.21 + * dummy serial kernel
    2.22 + */
    2.23 +
    2.24 +//===============================  Defines  ==============================
    2.25 +
    2.26 +//==============================  Structures  ==============================
    2.27 +typedef struct
    2.28 + { int32 *data;
    2.29 + } 
    2.30 +SeedParams;
    2.31 +
    2.32 +typedef struct
    2.33 + {
    2.34 +   int32 *data;
    2.35 +   int32  size;
    2.36 +   int32  startIter;
    2.37 +   int32  endIter;
    2.38 + }
    2.39 +TestAppStruct;
    2.40 +
    2.41 +//============================= Processor Functions =========================
    2.42 +void test_app_seed_Fn(      void *data, SlaveVP *animatingVP ); //seed VP function
    2.43 +
    2.44 +DKUPiece *rootPieceMakerFn( void *data, DKUInstance *dkuInstance );
    2.45 +void kernelFn( void *_params, SlaveVP *animVP );       //used as task birth Fn
    2.46 +void serialKernelFn( void *_params, SlaveVP *animVP ); //used as task birth Fn
    2.47 +void dividerFn( DKUPiece *piece );
    2.48 +void undividerFn( DKUPiece *piece );
    2.49 +
    2.50 +DKUPiece *
    2.51 +make_root_dku_piece_for_test_inst( int32 *data, int32 size, 
    2.52 +                                   DKUInstance *dkuInstance );
    2.53 +
    2.54 +//================================ Global Vars ==============================
    2.55 +
    2.56 +#endif /*_SSR_MATRIX_MULT_H_*/

     3.1 --- /dev/null	Thu Jan 01 00:00:00 1970 +0000
     3.2 +++ b/SeedVP.c	Tue Sep 24 08:08:18 2013 -0700
     3.3 @@ -0,0 +1,63 @@
     3.4 +/*
     3.5 + *  Copyright 2009 OpenSourceResearchInstitute.org
     3.6 + *  Licensed under GNU General Public License version 2
     3.7 + *
     3.8 + * Author: seanhalle@yahoo.com
     3.9 + *
    3.10 + */
    3.11 +
    3.12 +
    3.13 +#include <math.h>
    3.14 +#include <string.h>
    3.15 +#include "DKU__Test_App.h"
    3.16 +
    3.17 +/*Bare smoke test of DKU wrapper library functions.
    3.18 + * Create one DKU instance, with a dummy kernel
    3.19 + * Bare bones divider and undivider
    3.20 + * simple root piece maker
    3.21 + * dummy serial kernel
    3.22 + */
    3.23 +
    3.24 +//====================================================================
    3.25 +#define NO_INPUT NULL
    3.26 + /*Just to get proto-runtime built and run, to test it..
    3.27 +  */
    3.28 +void test_app_seed_Fn( void *_params, SlaveVP *seedVP )
    3.29 + { DKUInstance *dkuInstance;
    3.30 +   DKUPiece    *rootPiece;
    3.31 +   int32  size = 1000;
    3.32 +   int32 *data = (int32 *) PR__malloc (size * sizeof(int32)) ;
    3.33 +   
    3.34 +         DEBUG__printf(dbgAppFlow, "In seed Fn")
    3.35 +       
    3.36 +   SeedParams *seedParams = (SeedParams *)_params; //used to comm with main()
    3.37 +   
    3.38 +   dkuInstance = PRServ__DKU_make_empty_DKU_instance( seedVP );
    3.39 +   PRServ__DKU_set_root_piece_maker( dkuInstance, &rootPieceMakerFn, seedVP );
    3.40 +   PRServ__DKU_set_kernel( dkuInstance, &kernelFn, seedVP );
    3.41 +   PRServ__DKU_set_serial_kernel( dkuInstance, &serialKernelFn, seedVP );
    3.42 +   PRServ__DKU_set_divider( dkuInstance, &dividerFn, seedVP );
    3.43 +   PRServ__DKU_set_undivider( dkuInstance, &undividerFn, seedVP );
    3.44 +   
    3.45 +   rootPiece = 
    3.46 +       make_root_dku_piece_for_test_inst( data, size, dkuInstance );
    3.47 +//   rootPiece = PRServ__DKU_make_root_piece( dkuInstance, data, seedVP );
    3.48 +   
    3.49 +   PRServ__DKU_perform_work_on( rootPiece, seedVP );
    3.50 +   
    3.51 +   PRServ__DKU_wait_for_result_to_be_complete( rootPiece, seedVP );
    3.52 +
    3.53 +   seedParams->data = data; //sends results back to main()
    3.54 +   
    3.55 +      //Tells PR to end the process, which it will do even
    3.56 +      // if work is active, or suspended work entities are still live, or the
    3.57 +      // process has input ports that could trigger future work.
    3.58 +   PR__end_process_from_inside( seedVP );
    3.59 +
    3.60 +      //This ends the last live entity capable of work, in a process
    3.61 +      // that has no external input ports.. hence, no activity can take place
    3.62 +      // past that point..  PR detects that, and then automatically ends the
    3.63 +      // process.
    3.64 +   PR__end_seedVP( seedVP );
    3.65 + }
    3.66 +