Changeset 1082 for BMXNET_RPMS_dotNET_UTILITIES-BMX/trunk/cs/bmx_0200scr/BMX2/BMXNet/BMXNetLib.cs

Timestamp:

Jan 26, 2011, 5:45:02 AM (13 years ago)

Author:

Sam Habiel

Message:

BMX version bumped to 2.3.
New dll
BMXNetConnectInfo: Event polling from RPMS/VISTA is now async. BMX Writer lock removed.
BMXNetLib:

1. Application context changes are now suppressed. Developer must make sure that his/her application has all the needed BMX methods. This was done for performance enhancement as application context changes are very expensive in network time.
2. Locks are implemented at the TransmitRPC with a very simple Lock(this) which works very well.

RPMSDb: See #1 for BMXNetLib. All context changes are now suppressed.

File:

• BMXNET_RPMS_dotNET_UTILITIES-BMX/trunk/cs/bmx_0200scr/BMX2/BMXNet/BMXNetLib.cs (modified) (3 diffs)

BMXNET_RPMS_dotNET_UTILITIES-BMX/trunk/cs/bmx_0200scr/BMX2/BMXNet/BMXNetLib.cs

@@ -1027 +1027 @@
                         try
                         {
-                                string sContext = this.AppContext;
-                                this.AppContext = "BMXRPC";
+                /* 3110109 -- smh Commented out for performance issues.
+                                /*string sContext = this.AppContext;
+                                this.AppContext = "BMXRPC";*/
                                 Variable = Variable.Replace("^","~");
                                 string sRet = "0";
@@ -1035 +1036 @@
                                 sRet = TransmitRPC("BMX LOCK", sParam);
                                 bRet = (sRet == "1")?true:false;
-                                this.AppContext = sContext;
+                /* 3110109 -- smh Commented out for performance issues.
+                                /*this.AppContext = sContext;*/
                                 return bRet;
                         }
@@ -1077 +1079 @@
                 public string TransmitRPC(string sRPC, string sParam, int nLockTimeOut)
                 {
-                        try
-                        {
-                                try
-                                {
-                                        if (m_bConnected == false) 
-                                        {
-                                                throw new BMXNetException("BMXNetLib.TransmitRPC failed because BMXNetLib is not connected to RPMS.");
-                                        }
-                                        Debug.Assert(m_cDUZ != "");
-                                        Debug.Assert(m_pCommSocket != null);
-
-                                        string sOldAppContext = "";
-                                        if (sRPC.StartsWith("BMX")&&(this.m_cAppContext != "BMXRPC"))
-                                        {
-                                                sOldAppContext  = this.m_cAppContext;
-                                                this.AppContext = "BMXRPC";
-                                        }
-                                        string sMult = "";
-                                        string sSend = ADEBLDMsg(m_cHDR, sRPC, sParam, ref sMult);
-                                        SendString(m_pCommSocket, sSend, sMult);
-#if TRACE   
-                    DateTime sendTime = DateTime.Now;
-                    Debug.Write("TransmitRPC Sent: " + sSend.Replace((char) 30, (char) 10) + "\n");
+            lock (this)  // This method CANNOT be executed simultaneously! 
+            {
+                try
+                {
+                    try
+                    {
+                        if (m_bConnected == false)
+                        {
+                            throw new BMXNetException("BMXNetLib.TransmitRPC failed because BMXNetLib is not connected to RPMS.");
+                        }
+                        Debug.Assert(m_cDUZ != "");
+                        Debug.Assert(m_pCommSocket != null);
+
+                        string sOldAppContext = "";
+                        /* 3110109 -- smh Commented out for performance issues.
+                         if (sRPC.StartsWith("BMX")&&(this.m_cAppContext != "BMXRPC"))
+                        {
+                            sOldAppContext  = this.m_cAppContext;
+                            this.AppContext = "BMXRPC";
+                        }
+                         */
+                        string sMult = "";
+                        string sSend = ADEBLDMsg(m_cHDR, sRPC, sParam, ref sMult);
+                        SendString(m_pCommSocket, sSend, sMult);
+#if TRACE
+                        DateTime sendTime = DateTime.Now;
+                        int threadid = Thread.CurrentThread.ManagedThreadId;
+                        Debug.Write("TransmitRPC Sent: (T:" + threadid + ")" + sSend.Replace((char)30, (char)10) + "\n");
 #endif
-                    string strResult = ReceiveString(m_pCommSocket);
+                        string strResult = ReceiveString(m_pCommSocket);
 #if TRACE
-                    DateTime receiveTime = DateTime.Now;
-                    Debug.Write("TransmitRPC Received: " + strResult.Replace((char) 30, (char) 10) + "\n");
-                    TimeSpan executionTime = receiveTime - sendTime;
-                    Debug.Write("Execution Time: " + executionTime.TotalMilliseconds + " ms.\n");
-                    Debug.Write("-------------------------------------------------------\n");
+                        DateTime receiveTime = DateTime.Now;
+                        Debug.Write("TransmitRPC Received: (T:" + threadid + ")" + strResult.Replace((char)30, (char)10) + "\n");
+                        TimeSpan executionTime = receiveTime - sendTime;
+                        Debug.Write("Execution Time: " + executionTime.TotalMilliseconds + " ms.\n");
+                        Debug.Write("-------------------------------------------------------\n");
 #endif
-                                        if (sOldAppContext != "")
+                        /* /* 3110109 -- smh Commented out for performance issues.
+                     * if (sOldAppContext != "")
                                         {
                                                 this.AppContext = sOldAppContext;
                                         }
-                                        return strResult;                               
-                                }
-                                catch (Exception ex)
-                                {
-                                        if (ex.Message == "Unable to write data to the transport connection.")
-                                        {
-                                                m_bConnected = false;
-                                        }
-                                        throw ex;
-                                }
-                                finally
-                                {
-                                }                       
-                        }
-                        catch (ApplicationException aex)
-                        {
-                                // The writer lock request timed out.
-                                Debug.Write("TransmitRPC writer lock request timed out.\n");
-                                throw aex;
-                        }
-                        catch (Exception OuterEx)
-                        {
-                                throw OuterEx;
-                        }
+                     */
+                        return strResult;
+                    }
+                    catch (Exception ex)
+                    {
+                        if (ex.Message == "Unable to write data to the transport connection.")
+                        {
+                            m_bConnected = false;
+                        }
+                        throw ex;
+                    }
+                    finally
+                    {
+                    }
+                }
+                catch (ApplicationException aex)
+                {
+                    // The writer lock request timed out.
+                    Debug.Write("TransmitRPC writer lock request timed out.\n");
+                    throw aex;
+                }
+                catch (Exception OuterEx)
+                {
+                    throw OuterEx;
+                }
+            }
                 }