IPv4Sockets_JavaVM.h

//
// Copyright (c) 1999-2020 by Codemesh, Inc.. ALL RIGHTS RESERVED.
//
 
#ifndef IPv4Sockets_JavaVM_inc
#define IPv4Sockets_JavaVM_inc
 
 
#include "xmog.h"
 
 
#if (XMOG_IMPLEMENTS_REMOTE_CLIENT==1)
 
 
#include "ace/Barrier.h"
#include "ace/Synch_Traits.h"
#include "ace/Task_Ex_T.h"
#include "ace/TSS_T.h"
 
class xmog_localenv;
class xmog_i_comm_strategy;
#include "xmog_request.h"
#include "xmog_JavaVM.h"
#include "xmog_java_client.h"
 
 
class IPv4Sockets_JavaVM : public xmog_JavaVM,
                           private ACE_Task_Ex<ACE_MT_SYNCH, xmog_request>
{
public:
 
  IPv4Sockets_JavaVM (xmog_i_comm_strategy *comm_strategy,
                      const ACE_TCHAR *server_addr,
                      unsigned int connect_timeout = 0,
                      unsigned int reply_timeout = 0);
  ~IPv4Sockets_JavaVM ();
 
  int signon ( const char * serverAppNameUTF,
                const char * clientDisplayNameUTF = NULL,
                const char * clientSignOnNameUTF = NULL,
                const char * clientCredentialsUTF = NULL,
                int authenticationType = 0,
                int strCopyLimit = 256,
                int primArrayCopyLimit = 256,
                bool bMaintainObjId = true,
                bool bSendStringOnFirstRef = true,
                bool bAlignData = true );
 
  int   attach (void **penv, JavaVMAttachArgs *args, bool daemon);
 
  int submit (xmog_request *request);
 
    jstring     RemoteNewString( const unsigned short * str, xmog_JNIEnv * env, int len = -1 );
 
    jstring     RemoteNewString( const char * str, xmog_JNIEnv * env, xmog_base * encoding, int len = -1 );
 
    jstring     RemoteNewString( const char * str, xmog_JNIEnv * env, const char * encoding, int len = -1 );
 
    jstring     RemoteNewStringUtf( const char * str, xmog_JNIEnv * env );
 
    jarray      RemoteNewArray( const char * arrType, jsize size, xmog_JNIEnv * env );
 
    jarray      RemoteNewPrimitiveArray( const char * arrType, void * pData, jsize size, xmog_JNIEnv * env );
 
    virtual jarray              RemoteNewPrimitiveArray( const char * arrType, xmog::xmog_data_code elemCode, void * pData, jsize length, jsize size, xmog_JNIEnv * env );
 
    void        RemoteGetArrayRegion( const char * arrType, jarray array, jsize start, jsize len, void * buf, xmog_JNIEnv * env );
 
    void        RemoteSetArrayRegion( const char * arrType, jarray array, jsize start, jsize len, void * buf, xmog_JNIEnv * env );
 
    jclass      RemoteGetSuperClass( jclass sub, xmog_JNIEnv * env );
 
    jboolean    RemoteIsAssignableFrom( jclass sub, jclass sup, xmog_JNIEnv * env );
 
    jboolean    RemoteIsInstanceOf( jobject obj, jclass clazz, xmog_JNIEnv * env );
 
    jclass      RemoteGetClass( jobject obj, xmog_JNIEnv * env );
 
 
private:
 
    void                        inner_init();
 
    static JNIInvokeInterface_   theFunctions;
 
private:
 
  // Inherited from ACE_Task; runs in activated thread.
  virtual int svc (void);
  virtual int close (u_long flags = 0);
 
  // = Inherited from ACE_Event_Handler, called in svc thread context.
 
  virtual int handle_input (ACE_HANDLE fd = ACE_INVALID_HANDLE);
 
  //  virtual int handle_output (ACE_HANDLE fd = ACE_INVALID_HANDLE);
 
  virtual int handle_exception (ACE_HANDLE fd = ACE_INVALID_HANDLE);
 
  virtual int handle_close (ACE_HANDLE handle,
                            ACE_Reactor_Mask close_mask);
 
  ACE_Barrier start_barrier_;     // Cause ctor to wait for svc to begin
  xmog_i_comm_strategy *comm_;
  bool delete_comm_strategy_;     // If we allocate it, we'll delete it
  ACE_TCHAR server_addr_[256];
  int  connect_timeout_;
  int  reply_timeout_;
  ACE_Message_Block *msg_in_;     // Reads message coming in
  typedef enum { LENGTH, BODY } ReadState;
  ReadState state_;
  size_t incoming_msg_len_;
 
    // It would be nice to use a standard container, but this code has to run
    // on a wider range of compilers than STL can be trusted with.
    ACE_DLList<xmog_request> requests_;
 
    // Use this for the Fake Thread ID in attach messages.
    int fake_thread_id_;
 
    // the server-side class ids of various generally useful types
    jint    clsRemoteStringUtils_;
    jint    clsObject_;
    jint    clsClass_;
    jint    clsThrowable_;
    jint    clsException_;
    jint    clsString_;
 
    // 
    xmog_java_class     clsArrayCreator;
    xmog_java_method    mGetArray;
    xmog_java_method    mGetPrimitiveArray;
    xmog_java_method    mFromNative;
    xmog_java_method    mToNative;
    xmog_java_class     clsArrayAccess;
    xmog_java_method    mSetArrayBool;
    xmog_java_method    mSetArrayByte;
    xmog_java_method    mSetArrayChar;
    xmog_java_method    mSetArrayDouble;
    xmog_java_method    mSetArrayFloat;
    xmog_java_method    mSetArrayInt;
    xmog_java_method    mSetArrayLong;
    xmog_java_method    mSetArrayShort;
    xmog_java_method    mSetArrayObject;
    xmog_java_method    mGetArrayBool;
    xmog_java_method    mGetArrayByte;
    xmog_java_method    mGetArrayChar;
    xmog_java_method    mGetArrayDouble;
    xmog_java_method    mGetArrayFloat;
    xmog_java_method    mGetArrayInt;
    xmog_java_method    mGetArrayLong;
    xmog_java_method    mGetArrayShort;
    xmog_java_method    mGetArrayObject;
    xmog_java_method    mCreateArrayLong1;
    xmog_java_method    mCreateArrayLong2;
};
 
 
#endif  /* XMOG_IMPLEMENTS_REMOTE_CLIENT */
 
 
 
#endif /* IPv4Sockets_JavaVM_inc */