Miko/libremetaverse
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

* Disable WinGridProxy filters until the proxy is running

Browse Source 
* Rename CapsClient.StartRequest() to CapsClient.BeginGetResponse() to match HttpWebRequest
* Adding the blocking method CapsClient.GetResponse()

git-svn-id: http://libopenmetaverse.googlecode.com/svn/libopenmetaverse/trunk@2611 52acb1d6-8a22-11de-b505-999d5b087335
This commit is contained in:
John Hurliman
2009-04-16 16:25:47 +00:00
parent 686eefa653
commit f918d41133
12 changed files with 109 additions and 68 deletions
Download Patch File Download Diff File Expand all files Collapse all files

53
OpenMetaverse.Http/CapsClient.cs
View File

@@ -27,6 +27,7 @@
using System;
using System.Net;
using System.Security.Cryptography.X509Certificates;
using System.Threading;
using OpenMetaverse.StructuredData;
namespace OpenMetaverse.Http
@@ -66,23 +67,23 @@ namespace OpenMetaverse.Http
_Client.DownloadStringCompleted += new CapsBase.DownloadStringCompletedEventHandler(Client_DownloadStringCompleted);
}
public void StartRequest()
public void BeginGetResponse()
{
StartRequest(null, null);
BeginGetResponse(null, null);
}
public void StartRequest(OSD llsd)
public void BeginGetResponse(OSD data)
{
byte[] postData = OSDParser.SerializeLLSDXmlBytes(llsd);
StartRequest(postData, null);
byte[] postData = OSDParser.SerializeLLSDXmlBytes(data);
BeginGetResponse(postData, null);
}
public void StartRequest(byte[] postData)
public void BeginGetResponse(byte[] postData)
{
StartRequest(postData, null);
BeginGetResponse(postData, null);
}
public void StartRequest(byte[] postData, string contentType)
public void BeginGetResponse(byte[] postData, string contentType)
{
_PostData = postData;
_ContentType = contentType;
@@ -108,6 +109,38 @@ namespace OpenMetaverse.Http
_Client.UploadDataAsync(_Client.Location, postData);
}
public bool GetResponse(int millisecondsTimeout)
{
AutoResetEvent waitEvent = new AutoResetEvent(false);
OnComplete += delegate(CapsClient client, OSD result, Exception error) { waitEvent.Set(); };
BeginGetResponse();
return waitEvent.WaitOne(millisecondsTimeout, false);
}
public bool GetResponse(OSD data, int millisecondsTimeout)
{
AutoResetEvent waitEvent = new AutoResetEvent(false);
OnComplete += delegate(CapsClient client, OSD result, Exception error) { waitEvent.Set(); };
BeginGetResponse(data);
return waitEvent.WaitOne(millisecondsTimeout, false);
}
public bool GetResponse(byte[] postData, int millisecondsTimeout)
{
AutoResetEvent waitEvent = new AutoResetEvent(false);
OnComplete += delegate(CapsClient client, OSD result, Exception error) { waitEvent.Set(); };
BeginGetResponse(postData);
return waitEvent.WaitOne(millisecondsTimeout, false);
}
public bool GetResponse(byte[] postData, string contentType, int millisecondsTimeout)
{
AutoResetEvent waitEvent = new AutoResetEvent(false);
OnComplete += delegate(CapsClient client, OSD result, Exception error) { waitEvent.Set(); };
BeginGetResponse(postData, contentType);
return waitEvent.WaitOne(millisecondsTimeout, false);
}
public void Cancel()
{
if (_Client.IsBusy)
@@ -159,7 +192,7 @@ namespace OpenMetaverse.Http
// cache which will time out periodically. The CAPS server
// interprets this as a generic error and returns a 502 to us
// that we ignore
StartRequest(_PostData, _ContentType);
BeginGetResponse(_PostData, _ContentType);
}
else if (code != HttpStatusCode.OK)
{
@@ -210,7 +243,7 @@ namespace OpenMetaverse.Http
// cache which will time out periodically. The CAPS server
// interprets this as a generic error and returns a 502 to us
// that we ignore
StartRequest(_PostData, _ContentType);
BeginGetResponse(_PostData, _ContentType);
}
else if (code != HttpStatusCode.OK)
{