1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152

void __fastcall TPSM_OperatorClientForm::csktClientSocketRead
(
      TObject *             Sender          ,
      TCustomWinSocket *    Socket
)
{
    try
    {
        bool done = false;
        int bytes = 0;
        static int bytesLeft = 0;
        int msgBytes = 0;
        int offset = 0;
        struct PSM_Message *msg = 0;
    
        // Allocate memory to receive message
        static char *ptr;
        static char buf[MAX_SIZE];

        ptr = buf;

         // Read the message from the socket
        bytes = Socket->ReceiveBuf((void*)(ptr + bytesLeft), (MAX_SIZE - bytesLeft));

        // Set the bytes left value
        bytesLeft += bytes;
        WriteLog("bytes=%d   bytesLeft=%d", bytes, bytesLeft );    
        
         // Are there messages to be dispatched
        int iTotalLen = 0;

        while(1)
        {
            void *cpyBuff = 0;
        
            // Get the 1st message
            //msg = (struct PSM_Message *)&(ptr[offset]);
            msg = (struct PSM_Message *)(ptr+bytesLeft);
            msgBytes = msg->m_size;
            WriteLog("m_messageID=%d   m_size=%d", 
                        m_messageID, msg->m_size );    

            //badri
            if(bytesLeft < msgBytes)
            {
                // return;
                break;
            }
        
            // Allocate copy buffer for message
            cpyBuff = calloc(msg->m_size, sizeof(char));
            //  cpyBuff = calloc(msgBytes, sizeof(char));
        
            // cpyBuff = malloc(msgBytes);
            if( cpyBuff == NULL)
                return;
    
           // Copy the 1st message to the copy buffer
           ::memmove((void *)cpyBuff, (const void *)&(ptr[offset]), sizeof(char) * msgBytes);
           iTotalLen += sizeof(char) * msgBytes;
    
           // Move the offset
           offset += msg->m_size;
    
           if(msg->m_messageID == MSG_SM_OC_DATABASE_PATH_INFO)
           {
              WriteLog("OperatorCLientForm : Connected to server received - MSG_SM_OC_DATABASE_PATH_INFO");
              LogonRequest(msg);
              free(cpyBuff);
           }
           else
           {
                if (!::PostThreadMessage(pRouterThread->ThreadID, msg->m_messageID, (WPARAM)cpyBuff, 0))
                {
                    //Savita 11/dec/2001
                    AnsiString str = " PostMsgFailed --The Error Code returned " + AnsiString(GetLastError());
                    WriteLog(L_ERROR,str.c_str());
                    free(cpyBuff);
    
                    //If it has not deleted also create this thread inorder to maintain the continuity
                    pRouterThread = NULL;
                    pRouterThread = new PSM_RouterThread(false);

                    //Viswanath   12/dec/2001
                    if(pRouterThread != NULL)
                    {
                        WriteLog("OperatorCLientForm : Creating New Router Thread");
                    }
                    else
                    {
                        //Display a message stating that the resources is low. Shut down OC gracefully
                        //MessageBox(Handle,"System running low on resources.....Shutting down Operator Client","MMPOSEM Error",MB_OK |MB_SYSTEMMODAL );
                        MessageBox(Handle,GetString(IDS_ERR_SYSTEM_LOW_RESOURCES).c_str(),
                                        GetString(IDS_ERR_IPOS_ERROR).c_str(),
                                        MB_OK |MB_SYSTEMMODAL );
                        exit(-1);
                    }
                }
            }
        
            // adjust the bytes left value
            bytesLeft -= msg->m_size;
            if (bytesLeft < 0)   //if bytesLeft is less than zero
            {
                WriteLog("size of m_size is @ line 6833 %d", sizeof(msg->m_size));
                bytesLeft = 0;
                return;
            }
            // Check to see if we have dispatched ALL the messages in the buffer
            if(bytesLeft < 8) //badri     if bytesLeft is Less than 8
            {
                  ::memmove((void *)ptr, (const void *)&(ptr[iTotalLen]), sizeof(char) * bytesLeft);
                  return;
            }
        
            // Reset locals   (NER - no need... they're locals.
            cpyBuff = 0;
            msg = 0;
            
        } // end of while(1)
        
        // Free the Rx buffer
        free(ptr);
        
        #ifdef COMMOUT
             //Process the message
            try
            {
                if ( msg->m_messageID == MSG_SM_OC_DATABASE_PATH_INFO )
                {
                    WriteLog("OperatorCLientForm : Connected to server received - MSG_SM_OC_DATABASE_PATH_INFO");
                    LogonRequest(msg);
                }
                else
                {
                    ::PostThreadMessage(pRouterThread->ThreadID, msg->m_messageID, (WPARAM)msg,0);
                }
            }
            catch(...)
            {
                //ShowMessage("Server not located");
                ShowMessage( GetString(ID_SVR_NOT_LOC) );
                PSM_TransFilterForm->TransGridHeaderDisplay();
            }
        #endif
    }
    catch(...)
    {
        WriteLog(L_ERROR,"TPSM_OperatorClientForm :: csktClientSocketRead Failed ");
    }
}
/*EOS*/