xdev_mxdev_mxsendrequest.c

MPI for java for Distributed Programming

/** The MIT License 
	
Copyright (c) 2005 - 2007
   1. Distributed Systems Group, University of Portsmouth (2005)
   2. Aamir Shafi (2005 - 2007)
   3. Bryan Carpenter (2005 - 2007)
   4. Mark Baker (2005 - 2007)
*/	
#include <stdio.h>
#include "jni.h"
#include "myriexpress.h"
#include "xdev_mxdev_MXSendRequest.h"

jfieldID reqhandleID;
jfieldID dbuflenID ;
jfieldID dbufreqhandleID ;
jfieldID m_local_endpoint;
jfieldID bufferhandleID;
jfieldID testcalledID ;
jfieldID isPeekedID ; 
//jfieldID r_endpoint_handleID ; 
//jfieldID d_msg_tag_handleID ;

/*
 * Class:     xdev_mxdev_MXSendRequest
 * Method:    nativeIwait
 * Signature: (Lmpjdev/Status;)V
 */
JNIEXPORT void JNICALL Java_xdev_mxdev_MXSendRequest_nativeIwait
  (JNIEnv *env, jobject jthis, jobject status) {
  //printf("sendRequest wait called \n"); fflush(stdout); 
  mx_return_t rc ; 	  
  int testCalled = ((*env)->GetIntField(env,jthis,testcalledID)) ; 
  int isPeeked = ((*env)->GetIntField(env,jthis,isPeekedID)) ;

  if(testCalled == 1) {
    //((*env)->SetIntField(env,jthis,testcalledID,0)) ;               
    return ; 
  }
  
  //printf("native:recvrequest \n");	  
  uint32_t result;
  mx_status_t send_status;
  mx_request_t reqhandle ;
  mx_status_t send_status1;
  uint32_t result1;
  //mx_request_t reqhandle ;
  mx_request_t dbufreqhandle ;
  mx_endpoint_t mlep ;
  jobject buffer ; 
  int dbuf_length ; 

  jclass req_class = (*env)->GetObjectClass(env, jthis);

  reqhandle = (mx_request_t) ((*env)->GetLongField(env, jthis, reqhandleID )) ;
  dbuf_length = ((*env)->GetIntField(env, jthis, dbuflenID )) ;
  dbufreqhandle = (mx_request_t) 
	  ((*env)->GetLongField(env, jthis, dbufreqhandleID )) ;
  mlep = (mx_endpoint_t) ((*env)->GetLongField(env, jthis, m_local_endpoint )) ;
  buffer = ((*env)->GetObjectField(env, jthis, 
			  bufferhandleID )) ;

  if( dbuf_length > 0) { 
    //printf("sendreq calling mx_wait 1 \n"); fflush(stdout);
    /* this is for dbuf message */
    mx_wait(mlep, &dbufreqhandle, MX_INFINITE,
		    &send_status1, &result1); 
  }
  
  if(!isPeeked) { 
    rc = mx_wait(mlep, &reqhandle, MX_INFINITE,
                    &send_status, &result); 
    if(rc != MX_SUCCESS) { 
      printf("error in isend"); fflush(stdout); 	  
    }
  }
  //printf("sendreq calling mx_wait 2 \n"); fflush(stdout);
  /* this is for static buffer message */
  //printf("sendreq called two mx_waits \n"); fflush(stdout);
  /*
  jclass mpjbuf_class = (*env)->GetObjectClass(env, buffer);
  jmethodID set_size = (*env)->GetMethodID(env, mpjbuf_class,
                       "setSize", "(I)V");
  (*env)->CallVoidMethod(env, buffer, set_size, send_status.msg_length);
  */
  //printf("native:receiver printing the status information \n");
  //printf("native:receiver xfer_length <%d> \n", send_status.xfer_length );
  //printf("native:receiver buffer capacity <%d>", capacity );
  //printf("native:receiver msg_length <%d> \n", send_status.msg_length );
  //printf("native:receiver recv method ends \n");
  (*env)->SetIntField(env,jthis, testcalledID, 1);
}

/*
 * Class:     xdev_mxdev_MXSendRequest
 * Method:    nativeItest
 * Signature: (Lmpjdev/Status;)I
 */
JNIEXPORT jint JNICALL Java_xdev_mxdev_MXSendRequest_nativeItest
  (JNIEnv *env, jobject jthis, jobject status) {
  //printf("native itest method \n");	  
  int testCalled = ((*env)->GetIntField(env,jthis,testcalledID)) ; 
  int isPeeked = ((*env)->GetIntField(env,jthis,isPeekedID)) ;
    
  //printf("sendRequest test called \n"); fflush(stdout); 
  if(testCalled == 1) {
    printf(" no need to call test after test (sendRequest) \n");
    fflush(stdout); 
    //((*env)->SetIntField(env,jthis,testcalledID,0)) ;               
    return 1 ; 
  }
  uint32_t result = 0x00000000 ;
  mx_status_t send_status;
  mx_request_t reqhandle ;
  mx_status_t send_status1;
  uint32_t result1 = 0x00000000 ; 
  //mx_request_t reqhandle ;
  mx_request_t dbufreqhandle ;
  mx_endpoint_t mlep ;
  jobject buffer ; 
  int dbuf_length ; 

  jclass req_class = (*env)->GetObjectClass(env, jthis);

  reqhandle = (mx_request_t) ((*env)->GetLongField(env, jthis, reqhandleID )) ;
  dbuf_length = ((*env)->GetIntField(env, jthis, dbuflenID )) ;
  dbufreqhandle = (mx_request_t) 
	  ((*env)->GetLongField(env, jthis, dbufreqhandleID )) ;
  mlep = (mx_endpoint_t) ((*env)->GetLongField(env, jthis, m_local_endpoint )) ;
  buffer = ((*env)->GetObjectField(env, jthis, 
			  bufferhandleID )) ;
  
  if( dbuf_length > 0) { 
    //printf("sendreq calling mx_wait 1 \n"); fflush(stdout);
    /* this is for dbuf message */
    mx_test(mlep, &dbufreqhandle, 
		    &send_status1, &result1);  
    if(!result1) {
      return 0;	    
    }
  }
  
  //printf("sendreq calling mx_wait 2 \n"); fflush(stdout);
  /* this is for static buffer message */
  if(!isPeeked) { 
    mx_test(mlep, &reqhandle, 
                    &send_status, &result);
  }
  
  /* if there is only static section ...then this means stuff is completed */
  if(dbuf_length <= 0 && result) { 
    (*env)->SetIntField(env,jthis, testcalledID, 1);
    return 1; 
  }

  /*  in case we have primary and secondary section */
  if(result && result1) { 
    //printf("test completed the comms (sendRequest) \n"); fflush(stdout);
    //we are not checking if its been completed or not ...
    (*env)->SetIntField(env,jthis, testcalledID, 1);
    return 1; 
  }
  
  if(result && !result1) {
    printf("1. one of the request is tested -- not possible \n ");  	  
    fflush(stdout);
  }
  
  if(!result && result1) {
    printf("2. one of the request is tested -- not possible \n ");  	  
    fflush(stdout);
  }
  
  if(!result && !result1) {
    printf(" (sendRequest) both requests are not completed (unusual) \n"); 
  }

  return 0; 
  
}
  

/*
 * Class:     xdev_mxdev_MXSendRequest
 * Method:    nativeRequestInit
 * Signature: ()V
 */
JNIEXPORT void JNICALL Java_xdev_mxdev_MXSendRequest_nativeRequestInit
  (JNIEnv *env, jclass sendRequest) { 
  reqhandleID    = (*env)->GetFieldID(env, sendRequest , "handle", "J");
  dbuflenID    = (*env)->GetFieldID(env, sendRequest , "dbuflen", "I");
  dbufreqhandleID    = 
	  (*env)->GetFieldID(env, sendRequest , "dbufHandle", "J");
  m_local_endpoint = (*env)->GetFieldID(env, sendRequest,
		  "localEndpointHandle", "J");
  bufferhandleID = (*env)->GetFieldID(env, sendRequest,
		  "bufferHandle", "Lmpjbuf/Buffer;");
  testcalledID    = (*env)->GetFieldID(env, sendRequest, "testCalled", "I");
  isPeekedID = (*env)->GetFieldID(env,
                                  sendRequest, "isPeeked", "I");
  //r_endpoint_handleID = (*env)->GetFieldID(env, sendRequest,
//		  "remoteEndpointHandle", "J");
  //d_msg_tag_handleID = (*env)->GetFieldID(env, sendRequest, 
//		  "dynamicMsgTagHandle", "J");
}