Joined: 08 Oct 2007 Posts: 36 Location: Columbia, SC
I've written an application in REXX that does a little bit of everything as far as DB2, VSAM, file I/O, ISPF tables, and TCP/IP socket request. For the most part everything is quick enough except for the TCP/IP requests. I did some test and pulled out the socket code and ran it just by itself and I can get an end to end response of < 1 second. But when that same request is run from in my application, it takes about 6 seconds to get the socket response.
This application is about 20,000 lines of code, so its large in my opinion. I ran a test without the DB2 connection, reduced the stems allocated, and cut out a good portion of my init routine, but that doesn't seem to help. I've also tried to replicate the slow response on my socket test rexx by creating large stems, or large variables, but it seems unaffected. However if I bring up my application in one screen, then try to run the socket test in another, the response time jumps up to 5+ seconds for the test.
So obviously something I'm doing is affecting the response across my whole ISPF session. Has anyone experienced anything like this, or are you aware of what could affect the socket call so adversely? Thanks in advance.
parse arg env1, arg1, arg2, req2
env1 = strip(env1)
upper env1
URLLine = ""
if env1 = 'LCAS' then
URLLine = 'http://xxxserver/services/rexx?wsdl'
if env1 = 'GA' then
URLLine = 'http://xxxserver/services/rexx?wsdl'
if env1 = 'HR' then
URLLine = 'http://xxxserver/services/rexx?wsdl'
if env1 = 'TRIC' then
URLLine = 'http://xxxserver/services/rexx?wsdl'
if env1 = 'CORP1' then
URLLine = 'http://xxxserver/services/rexx?wsdl'
if env1 = 'TEST' then
URLLine = 'http://xxxserver/services/rexx?wsdl'
signal on halt
signal on syntax
call Program_Initiation
select
WHEN ARG1 = 'INITIALIZE_TCPIP_SERVICES' THEN
CALL INITIALIZE_TCPIP_SERVICES
WHEN ARG1 = 'ESTABLISH_A_SOCKET' THEN
CALL ESTABLISH_A_SOCKET
WHEN ARG1 = 'CLOSE_SOCKET' THEN
CALL CLOSE_SOCKET
WHEN ARG1 = 'TERMINATE_TCPIP_SERVICES' THEN
CALL TERMINATE_TCPIP_SERVICES
WHEN ARG1 = 'POST_COMMAND' THEN
CALL POST_COMMAND
WHEN ARG1 = 'READ_FROM_SOCKET' THEN
CALL READ_FROM_SOCKET
OTHERWISE NOP
end
return r_c
/*------------------------------------------------------*/
/* append two pairs of CRLF to end the command string */
/*------------------------------------------------------*/
Command = Command || crlf
so_txt = Socket('write', sk_desc, Command)
parse var so_txt s_rc s_results
if s_rc <> 0 then,
do
call error 'E', 230, 'SOCKET(WRITE) rc='s_rc
end
else,
Do
s_data_len = s_results
End
r_c = '00'
return so_txt
/*----------------------------------------------------------------*/
/* Hear what the server has to say */
/*----------------------------------------------------------------*/
Peek_at_socket:
Returned_data = Socket('Recv', s_d, 8192, 'PEEK')
parse var Returned_data s_rc s_type s_port s_ip s_results
parse var Returned_data s_rc s_data_len s_data_text
If s_rc <> 0 then,
Do
call error 'W', 250, 'SOCKET(Peek) rc='s_rc
End
Return Returned_data
/*----------------------------------------------------------------*/
Read_from_socket:
/*----------------------------------------------------------------*/
parse var arg2 socket '~' sk_desc
s_d = sk_desc
Response = ''
Inbuffer = 0
Do Forever
Returned_data = peek_at_socket()
If s_rc <> 0 then,
Do
say 'I tried to peek but had a problem:'s_rc
say '::'Returned_data'::'
Leave
End
If s_data_len = 0 then,
Do
Leave
End
BytesRcvd = Socket('Recvfrom', s_d, s_data_len)
Parse var bytesrcvd s_rc s_type s_port s_ipaddr s_real_len rcvdata
If s_rc < 0 Then
Do
say s_rc '<= 0 so I am leaving read_from_socket' rcvdata
Leave
End
If s_rc <> 0 then,
Do
call error 'I', 242, 'SOCKET(RecvFrom) rc='s_rc
End
Inbuffer = inbuffer + s_real_len
Response = Response || rcvdata
End
/*------------------------------------------------------*/
/* Common error routine */
/*------------------------------------------------------*/
error:
type = arg(1)
retc = arg(2)
text = arg(3)
ecretc = right(retc,3,'0')
ectype = translate(type)
ecfull = 'URLCheck' || ecretc || ectype
say '===> 'type":" ecfull text
if type <> 'E' then return
if (initialized = 0) then,
do
so_txt = Socket('SocketSetStatus')
parse var so_txt s_rc s_severreason
if (s_rc <> 'Connected') then,
say 'The status of the socket set is' s_rc s_severreason
end
else,
do
so_txt = Socket('SocketSetStatus')
parse var so_txt s_rc s_severreason
if (s_rc <> 'Connected') then,
say 'The status of the socket set is' s_rc s_severreason
end
so_txt = Socket('Terminate')
r_c = '99'||'Sever error'
say 'leaving lchmp901 severe error' r_c
exit r_c
Terminate_TCPIP_Services:
/*-------------------------------------------------------*/
/* Terminate the socket and exit */
/*-------------------------------------------------------*/
so_txt = Socket('Terminate')
Return
Connect:
Parse Arg Server
/* if the servername has a port address specified */
/* then use this one, otherwise use the default http */
/* port 80 */
Parse Var Server Server ':' Port
If Port = '' Then
Port = 80
if this_is_real = 1 then,
do
/* resolve server name alias to dotted IP address */
so_txt = Socket('Gethostbyname', server)
parse var so_txt s_rc s_results
if s_rc <> 0 then,
do
call error 'I', 80, 'GetHostByName for',
server 'failed' s_rc
Return -1
end
end
/*----------------------------------------------------------------*/
/* Connect the socket */
/*----------------------------------------------------------------*/
so_txt = Socket('Connect', s_d, 'AF_INET' port server)
parse var so_txt s_rc s_results
if s_rc <> 0 then,
do
call error 'W', 120, 'SOCKET(CONNECT) rc='s_rc
end
Return 0
/*------------------------------------------------------*/
/* Procedure: Close_Socket */
/*------------------------------------------------------*/
Close_socket:
parse var arg2 socket '~' s_d
so_txt = Socket('Close', s_d)
parse var so_txt s_rc s_results
if s_rc <> 0 then,
do
call error 'W', 234, 'Close rc='s_rc
end
r_c = '00'
Return
/*------------------------------------------------------*/
/* Procedure: Program initiation */
/*------------------------------------------------------*/
Program_Initiation:
CRLF = x2c('0D25')
LF = x2c('25')
rcvdata = ""
Return
Initialize_TCPIP_Services:
/*----------------------------------------------------------------*/
/* Initialize the Socket */
/*----------------------------------------------------------------*/
so_txt = Socket('Initialize', 'LCPKSP01', 2)
parse var so_txt s_rc s_subtask s_maxdesc s_servicename
socket_rc = s_rc
if s_rc = 0 then,
Do
initialized = 1
r_c = '00'||s_servicename
End
else,
Do
call error 'E', 40, 'Unable to initialize SOCKET URLCheck' s_rc
r_c = '99'||'Unable to initialize SOCKET URLCheck'
End
Return
/*------------------------------------------------------*/
/* Procedure: Establish_A_Socket */
/*------------------------------------------------------*/
Establish_A_Socket:
URLLine = ""
if env1 = 'LCAS' then
URLLine = 'http://xxxserver/services/rexx?wsdl'
if env1 = 'GA' then
URLLine = 'http://xxxserver/services/rexx?wsdl'
if env1 = 'HR' then
URLLine = 'http://xxxserver/services/rexx?wsdl'
if env1 = 'TRIC' then
URLLine = 'http://xxxserver/services/rexx?wsdl'
if env1 = 'CORP1' then
URLLine = 'http://xxxserver/services/rexx?wsdl'
if env1 = 'TEST' then
URLLine = 'http://xxxserver/services/rexx?wsdl'
if pos('SPECIALMOVE',env1) > 0 then
Do
parse var env1 . '~' movenumber
movenumber=strip(movenumber)
URLLine = ,
' http://xxxxx/xxxxxx/'||,
'allApprovalsReceived.jsp?movenumber='||movenumber
End
Parse Var URLLine 'http://' Server '/' Document
Document = '/' || Document
socket_rc = -1
so_txt = Socket('Socket', 'AF_INET', 'STREAM', 'TCP')
parse var so_txt s_rc s_results
if s_rc <> 0 then,
do
call error 'E', 60, 'SOCKET(SOCKET) rc='s_rc
end
else,
Do
s_d = s_results
sk_desc = s_d
socket_rc = 0
End
/*----------------------------------------------------------------*/
/* Turn on EBCDIC-Ascii conversion */
/*----------------------------------------------------------------*/
so_txt = Socket('SetSockOpt',s_d,'SOL_SOCKET','SO_ASCII','On')
parse var so_txt s_rc s_results
if s_rc = 0 then nop
else,
call error 'W', 70, 'Unable to set SOCKET So_ASCii' s_rc
so_txt = Socket('SetSockOpt',s_d,'SOL_SOCKET','SO_RCVTIMEO','30 0')
parse var so_txt s_rc s_results
if s_rc = 0 then nop
else,
call error 'W', 70, 'Unable to set SOCKET rcvtimeo' s_rc
so_txt = Socket('SetSockOpt',s_d,'SOL_SOCKET','SO_SNDTIMEO','30 0')
parse var so_txt s_rc s_results
if s_rc = 0 then nop
else,
call error 'W', 70, 'Unable to set SOCKET sndtimeo' s_rc
/*
so_txt = Socket('GetSockOpt',s_d,'SOL_SOCKET','SO_ASCII')
say so_txt
so_txt = Socket('GetSockOpt',s_d,'SOL_SOCKET','SO_RCVTIMEO')
say so_txt
so_txt = Socket('GetSockOpt',s_d,'SOL_SOCKET','SO_SNDTIMEO')
say so_txt
*/
Socket = Connect(Server)
If Socket = -1 Then
r_c = '99'||socket||'~'||'bad socket connect'
else
r_c = '00'||socket||'~'||sk_desc
RETURN 0
Joined: 08 Oct 2007 Posts: 36 Location: Columbia, SC
I thought I'd share my results.
I use a driver REXX to allocate the panel,skeleton,execlibs ect needed for my application. The REXX application is compiled, so I'm calling it from our production EXECLIB. When testing with the above SOCKTEST, if I allocate the prod execlib, then the response time for the socket calls increases. When I remove the allocation, the response is normal. The execlib is the only library that affects the socket call as far as my issue is concerned. I assume it's taking longer to traverse the concatenated datasets to locate the SOCKET exec. ?
My fix was to drop/dealloc the production execlib once my application starts up. Then I allocated it as needed when I'm doing an external call. This one fix seemed to improve overall performance including VSAM reads.
