#include "EXTERN.h"
#include "perl.h"
#include "XSUB.h"

#include "ppport.h"

#include <pthread.h>
static PerlInterpreter *orig_perl=NULL;

SV* cb_ptr1 = NULL;
SV* cb_ptr2 = NULL;

void InvokeCB ()
{
   static int val = 0;
   SV * sv;

   val++;
   Perl_set_context(orig_perl);
   printf("curr_ctx is %lud\n", Perl_get_context());
   dSP;
   ENTER;
   SAVETMPS;
   PUSHMARK(SP);

   if (val >= 5)
      sv = cb_ptr2;
   else
      sv = cb_ptr1;

   printf("invoking %lud\n", sv);
   XPUSHs(sv_2mortal(newSViv(val)));
                                                                                   PUTBACK;
   call_sv(sv, G_DISCARD);

   FREETMPS;
   LEAVE;
}

void * BGThread(void * dontcare)
{
   while (1)
   {
      sleep(5);
      InvokeCB();
   }
}


MODULE = myModule               PACKAGE = myModule

int
RegisterCB1 (SV *SubRef)
    CODE:
       orig_perl = Perl_get_context();
       printf("orig_ctx is %lud\n", orig_perl);
       pthread_t tid;
       pthread_create(&tid, NULL, BGThread, NULL);
       orig_perl = PERL_GET_CONTEXT;
       cb_ptr1 = SubRef;
       printf("registered %lud\n", cb_ptr1);
       RETVAL = 1;
    OUTPUT:
       RETVAL

int
RegisterCB2 (SV *SubRef)
    CODE:
       cb_ptr2 = SubRef;
       printf("registered %lud\n", cb_ptr1);
       RETVAL = 1;
    OUTPUT:
       RETVAL