Hi,
I have written and application that sends out multiple URL reqests using asynchronous httpwebrequests.
These requests include a phone number, a number is then returned indicating which network it belongs too which is stored in our database.
however it is essential that the correct URL is recieved with the correct content from that request but currently it seems as though they are getting mixed up and i cannot see for the life of me how, could someone please look over the code and see if they can find what could be causing this? I think i have ruled out threading conflicts as can be seen from the debug report at the bottom of this post.
any help would be greatly appreciated ......
Here are results from a batch of numbers processed, most of which returned different to what they should have:
I have written and application that sends out multiple URL reqests using asynchronous httpwebrequests.
These requests include a phone number, a number is then returned indicating which network it belongs too which is stored in our database.
however it is essential that the correct URL is recieved with the correct content from that request but currently it seems as though they are getting mixed up and i cannot see for the life of me how, could someone please look over the code and see if they can find what could be causing this? I think i have ruled out threading conflicts as can be seen from the debug report at the bottom of this post.
any help would be greatly appreciated ......
VB.NET:
Private Sub readcallback(ByVal ar As IAsyncResult)
SyncLock Me
Debug.WriteLine("THREAD START")
''''''''''''DECLERATIONS''''''''''''''''''''
Dim state As request_state = CType(ar.AsyncState, request_state)
Dim returned_code As String, SQL As String
Dim tmp_status As String, rID As Integer
Dim rdata As New ADODB.Recordset, finished = False
Dim thread_id As Integer
Dim request_url As String
Dim vMOBILE As String
Dim key As String
Dim URL As String
Dim succesful = False
Dim count = 0
Dim i As Integer
Dim stringContent As String
Dim number As String
''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Debug.WriteLine(returned_code & " , " & SQL & " , " & tmp_status & " , " & thread_id & request_url & " , " & URL & " , " & key & " , " & stringContent)
'''''''''''''''GET RETURNED DATA''''''''''''''''''''
Dim responseStream As Stream = state.streamResponse
Dim read As Integer = responseStream.EndRead(ar)
Debug.WriteLine(state.requestData.ToString & " - " & state.request.Address.AbsoluteUri)
state.requestData.Append(Encoding.ASCII.GetString(state.BufferRead, 0, read))
Debug.WriteLine(state.requestData.ToString & " - " & state.request.Address.AbsoluteUri)
' Debug.WriteLine(state.requestData.ToString() & " - " & state.request.Address.AbsoluteUri)
If state.requestData.Length > 0 Then
'''''get returned network code''''''
returned_code = state.requestData.ToString()
SyncLock Me
running = running + 1
waiting = waiting - 1 : update_stats()
End SyncLock
'''''get rID''''''
URL = state.request.Address.AbsoluteUri
i = URL.IndexOf("rID=")
rID = Val(Mid(URL, i + 5))
'''''''get key'''''''
i = URL.IndexOf("key=")
key = Val(Mid(URL, i + 5))
'''''get number'''''''
i = URL.IndexOf("msisdn=")
number = URL.Substring(i + 7, 12)
Debug.WriteLine(state.requestData.ToString & " - " & state.request.Address.AbsoluteUri)
''''Write to monthly ping record'''''
SyncLock Me
Dim fs As New FileStream(System.Windows.Forms.Application.StartupPath & " / " & Format(Now, "MM yyyy") & ".txt", FileMode.Append)
Dim s As New StreamWriter(fs)
s.WriteLine(cmbCLIENT.Text & vbTab & cmbBATCH.Text & vbTab & number & vbTab & Format(Now, "dd/MM/yy hh:mm:ss") & vbTab & returned_code)
s.Close()
End SyncLock
'''''''''''''''''''''''''''''''''''
Debug.WriteLine(state.requestData.ToString & " - " & state.request.Address.AbsoluteUri)
'''''''''''UPDATE RECORD ON SERVER'''''''''''''''
If rID > 0 Then
If returned_code.Chars(0) <> "E" Then
If Val(returned_code) <> 0 Then
SQL = "Update pinglink set Status='A', lastping='" & Format(Now, "dd MMM yyyy hh:mm:ss") & "', rcode=" & CInt(returned_code) & " where rID=" & rID
Else
SQL = "Update pinglink set status='E', lastping='" & Format(Now, "dd MMM yyyy hh:mm:ss") & "', rcode=-1 where rID=" & rID
End If
Else
Select Case returned_code
Case "E_NO_DATA" : tmp_status = "U"
Case "E_AUTHENTICATION" : tmp_status = "?"
Case "E_INVALID_MSISDN" : tmp_status = "N"
Case "E_SERVER" : tmp_status = "?"
End Select
SQL = "Update pinglink set Status='" & tmp_status & "', lastping='" & Format(Now, "dd MMM yyyy hh:mm:ss") & "', rcode=-1 where rID=" & rID
End If
succesful = False
While succesful = False
Try
CNN.Execute(SQL)
succesful = True
Debug.WriteLine(state.requestData.ToString & " - " & state.request.Address.AbsoluteUri)
Debug.WriteLine(SQL)
Debug.WriteLine(state.requestData.ToString & " - " & state.request.Address.AbsoluteUri)
logging(key, number, rID, SQL & " returned: " & tmp_status & " - " & returned_code)
Catch a As Exception
MsgBox(a.Message)
succesful = False
count = count + 1
If (count > 10) Then
If MsgBox("There have been 10 consecutive failed attempts to contact server (record update)" & vbNewLine & " do you wish to skip this record and continue with clean?", vbYesNo, "Recycle timeouts") = vbYes Then
succesful = True
count = 0
Else
count = 0
gRUN = False
succesful = True
End If
End If
End Try
End While
Else 'rID not found in URL
Debug.WriteLine("rID lost from URL")
End If
Debug.WriteLine(state.requestData.ToString & " - " & state.request.Address.AbsoluteUri)
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''
If Not gRUN = False Then
'''''''''''''GET NEXT RECORD TO PING''''''''''''''
SQL = "sp_ping_next " & pID & "," & key
rdata.MaxRecords = 1
rdata.Open(SQL, server, ADODB.CursorTypeEnum.adOpenForwardOnly, ADODB.LockTypeEnum.adLockReadOnly)
'''''''''''''''if there are more records to ping''''''''''''''''''
If rdata(0).Value > 0 Then
''''''trim dats, store url and record ID''''''''''''''
vMOBILE = RTrim(rdata("Mobile").Value)
rID = (rdata("rID").Value)
rdata.Close()
''''''''''''''''''''''''''''''''''''''''''''''''''''''
Debug.WriteLine(state.requestData.ToString & " - " & state.request.Address.AbsoluteUri)
''''''''''''''''''''Ping next record'''''''''''''''''''
If vMOBILE.Substring(0, 5) = "00447" Then ' if number starts 00447 remove first two numbers
vMOBILE = vMOBILE.Remove(0, 2)
End If
txtMOBILE.Text = vMOBILE : txtMOBILE.Refresh()
Debug.WriteLine(state.requestData.ToString & " - " & state.request.Address.AbsoluteUri)
'''''''''''''''BUILD AND MAKE URL REQUEST'''''''''''''''''
' Create a HttpWebrequest object to the desired URL.
Dim myHttpWebRequest As HttpWebRequest = WebRequest.Create(murl & vMOBILE & "&rID=" & rID & "&key=" & key)
logging(key, vMOBILE, rID, murl & vMOBILE & "&rID=" & rID & "&key=" & key & "SENDING")
Debug.WriteLine(state.requestData.ToString & " - " & state.request.Address.AbsoluteUri)
' Create an instance of the RequestState and assign the previous myHttpWebRequest
' object to its request field.
Dim myRequestState = New request_state
myRequestState.request = myHttpWebRequest
' Start the asynchronous request.
Dim result As IAsyncResult = CType(myHttpWebRequest.BeginGetResponse(New AsyncCallback(AddressOf UpdateItem), myRequestState), IAsyncResult)
' this line implements the timeout, if there is a timeout, the callback fires and the request aborts.
ThreadPool.RegisterWaitForSingleObject(result.AsyncWaitHandle, New WaitOrTimerCallback(AddressOf TimeoutCallback), myHttpWebRequest, 60000, True)
SyncLock Me
running = running - 1
waiting = waiting + 1 : update_stats()
End SyncLock
Else 'no more data
SyncLock Me
running = running - 1
stopped = stopped + 1 : update_stats()
End SyncLock
If Not stopped = TrackBar1.Value Then
finished = True
rdata.Close()
Else
txtMOBILE.Text = ""
cmdRUN.Text = "&Run"
gRUN = False
txtPACE.Text = ""
pBAR.Value = 0
txtSTART.Text = ""
txtEND.Text = ""
cmbBATCH_SelectedIndexChanged(Nothing, Nothing)
Debug.WriteLine(state.requestData.ToString & " - " & state.request.Address.AbsoluteUri)
''''''''enable all controls'''''''''''
TrackBar1.Enabled = True
TrackBar2.Enabled = True
cmdExport.Enabled = True
cmdREPORT.Enabled = True
cmbCLIENT.Enabled = True
cmbBATCH.Enabled = True
add_batch.Enabled = True
Debug.WriteLine(state.requestData.ToString & " - " & state.request.Address.AbsoluteUri)
''''''''''''''''''''''''''''''''''''''''''''''''''''
'''''''''count records in selected batch with '?' status'''''
rdata.Open("select count(*) from sms.dbo.pinglink where pid=" & pID & " and status='T'", CNN, ADODB.CursorTypeEnum.adOpenForwardOnly, ADODB.LockTypeEnum.adLockReadOnly)
Dim timeouts = rdata(0).Value
rdata.Close()
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
MsgBox("Cleaning has finished, there were " & timeouts & " timeouts", MsgBoxStyle.OKOnly, "Clean complete")
txtPACE.Text = ""
End If
End If
Else
SyncLock Me
running = running - 1
stopped = stopped + 1 : update_stats()
End SyncLock
If Not stopped = TrackBar1.Value Then
finished = True
rdata.Close()
Else
txtMOBILE.Text = ""
cmdRUN.Text = "&Run"
gRUN = False
txtPACE.Text = ""
pBAR.Value = 0
txtSTART.Text = ""
txtEND.Text = ""
cmbBATCH_SelectedIndexChanged(Nothing, Nothing)
Debug.WriteLine(state.requestData.ToString & " - " & state.request.Address.AbsoluteUri)
''''''''enable all controls'''''''''''
TrackBar1.Enabled = True
TrackBar2.Enabled = True
cmdExport.Enabled = True
cmdREPORT.Enabled = True
cmbCLIENT.Enabled = True
cmbBATCH.Enabled = True
add_batch.Enabled = True
Debug.WriteLine(state.requestData.ToString & " - " & state.request.Address.AbsoluteUri)
''''''''''''''''''''''''''''''''''''''''''''''''''''
'''''''''count records in selected batch with '?' status'''''
rdata.Open("select count(*) from sms.dbo.pinglink where pid=" & pID & " and status='T'", CNN, ADODB.CursorTypeEnum.adOpenForwardOnly, ADODB.LockTypeEnum.adLockReadOnly)
Dim timeouts = rdata(0).Value
rdata.Close()
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
MsgBox("Cleaning has finished, there were " & timeouts & " timeouts", MsgBoxStyle.OKOnly, "Clean complete")
txtPACE.Text = ""
End If
End If
''''''''''''''''''''''''''''''''''''''''''''''''''
Debug.WriteLine(state.requestData.ToString & " - " & state.request.Address.AbsoluteUri)
End If
Debug.WriteLine(state.requestData.ToString & " - " & state.request.Address.AbsoluteUri)
End SyncLock
Debug.WriteLine("THREAD END")
End SubHere are results from a batch of numbers processed, most of which returned different to what they should have:
