moving export methods to a standalone file (#211)
This commit is contained in:
pan-wang
GitHub
parent
c845a331bb
commit
bfb2c86cda
|
|
@ -182,6 +182,7 @@
|
|||
<ItemGroup>
|
||||
<ClCompile Include="Src\inprocessstoredcontext.cxx" />
|
||||
<ClCompile Include="Src\inprocessapplication.cxx" />
|
||||
<ClCompile Include="Src\managedexports.cxx" />
|
||||
<ClCompile Include="Src\outprocessapplication.cxx" />
|
||||
<ClCompile Include="Src\application.cxx" />
|
||||
<ClCompile Include="Src\applicationmanager.cxx" />
|
||||
|
|
|
|||
|
|
@ -6,330 +6,6 @@
|
|||
|
||||
typedef DWORD(*hostfxr_main_fn) (CONST DWORD argc, CONST WCHAR* argv[]);
|
||||
|
||||
//
|
||||
// Initialization export
|
||||
//
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
VOID
|
||||
register_callbacks(
|
||||
_In_ PFN_REQUEST_HANDLER request_handler,
|
||||
_In_ PFN_SHUTDOWN_HANDLER shutdown_handler,
|
||||
_In_ PFN_MANAGED_CONTEXT_HANDLER async_completion_handler,
|
||||
_In_ VOID* pvRequstHandlerContext,
|
||||
_In_ VOID* pvShutdownHandlerContext
|
||||
)
|
||||
{
|
||||
IN_PROCESS_APPLICATION::GetInstance()->SetCallbackHandles(
|
||||
request_handler,
|
||||
shutdown_handler,
|
||||
async_completion_handler,
|
||||
pvRequstHandlerContext,
|
||||
pvShutdownHandlerContext
|
||||
);
|
||||
}
|
||||
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
HTTP_REQUEST*
|
||||
http_get_raw_request(
|
||||
_In_ IHttpContext* pHttpContext
|
||||
)
|
||||
{
|
||||
return pHttpContext->GetRequest()->GetRawHttpRequest();
|
||||
}
|
||||
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
HTTP_RESPONSE*
|
||||
http_get_raw_response(
|
||||
_In_ IHttpContext* pHttpContext
|
||||
)
|
||||
{
|
||||
return pHttpContext->GetResponse()->GetRawHttpResponse();
|
||||
}
|
||||
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT VOID http_set_response_status_code(
|
||||
_In_ IHttpContext* pHttpContext,
|
||||
_In_ USHORT statusCode,
|
||||
_In_ PCSTR pszReason
|
||||
)
|
||||
{
|
||||
pHttpContext->GetResponse()->SetStatus(statusCode, pszReason);
|
||||
}
|
||||
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
HRESULT
|
||||
http_post_completion(
|
||||
_In_ IHttpContext* pHttpContext,
|
||||
DWORD cbBytes
|
||||
)
|
||||
{
|
||||
return pHttpContext->PostCompletion(cbBytes);
|
||||
}
|
||||
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
HRESULT
|
||||
http_set_managed_context(
|
||||
_In_ IHttpContext* pHttpContext,
|
||||
_In_ PVOID pvManagedContext
|
||||
)
|
||||
{
|
||||
HRESULT hr;
|
||||
IN_PROCESS_STORED_CONTEXT* pInProcessStoredContext = new IN_PROCESS_STORED_CONTEXT(pHttpContext, pvManagedContext);
|
||||
if (pInProcessStoredContext == NULL)
|
||||
{
|
||||
return E_OUTOFMEMORY;
|
||||
}
|
||||
|
||||
hr = IN_PROCESS_STORED_CONTEXT::SetInProcessStoredContext(pHttpContext, pInProcessStoredContext);
|
||||
if (hr == HRESULT_FROM_WIN32(ERROR_ALREADY_ASSIGNED))
|
||||
{
|
||||
hr = S_OK;
|
||||
}
|
||||
|
||||
return hr;
|
||||
}
|
||||
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
VOID
|
||||
http_indicate_completion(
|
||||
_In_ IHttpContext* pHttpContext,
|
||||
_In_ REQUEST_NOTIFICATION_STATUS notificationStatus
|
||||
)
|
||||
{
|
||||
pHttpContext->IndicateCompletion(notificationStatus);
|
||||
}
|
||||
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
VOID
|
||||
http_get_completion_info(
|
||||
_In_ IHttpCompletionInfo2* info,
|
||||
_Out_ DWORD* cbBytes,
|
||||
_Out_ HRESULT* hr
|
||||
)
|
||||
{
|
||||
*cbBytes = info->GetCompletionBytes();
|
||||
*hr = info->GetCompletionStatus();
|
||||
}
|
||||
|
||||
//
|
||||
// todo: we should not rely on IN_PROCESS_APPLICATION::GetInstance()
|
||||
// the signature should be changed. application's based address should be passed in
|
||||
//
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
BSTR // TODO probably should make this a wide string
|
||||
http_get_application_full_path()
|
||||
{
|
||||
LPWSTR pwzPath = NULL;
|
||||
IN_PROCESS_APPLICATION* pApplication = IN_PROCESS_APPLICATION::GetInstance();
|
||||
if(pApplication != NULL)
|
||||
{
|
||||
pwzPath = pApplication->QueryConfig()->QueryApplicationFullPath()->QueryStr();
|
||||
}
|
||||
return SysAllocString(pwzPath);
|
||||
}
|
||||
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
HRESULT
|
||||
http_read_request_bytes(
|
||||
_In_ IHttpContext* pHttpContext,
|
||||
_Out_ CHAR* pvBuffer,
|
||||
_In_ DWORD dwCbBuffer,
|
||||
_Out_ DWORD* pdwBytesReceived,
|
||||
_Out_ BOOL* pfCompletionPending
|
||||
)
|
||||
{
|
||||
HRESULT hr;
|
||||
|
||||
if (pHttpContext == NULL)
|
||||
{
|
||||
return E_FAIL;
|
||||
}
|
||||
if (dwCbBuffer == 0)
|
||||
{
|
||||
return E_FAIL;
|
||||
}
|
||||
IHttpRequest *pHttpRequest = (IHttpRequest*)pHttpContext->GetRequest();
|
||||
|
||||
BOOL fAsync = TRUE;
|
||||
|
||||
hr = pHttpRequest->ReadEntityBody(
|
||||
pvBuffer,
|
||||
dwCbBuffer,
|
||||
fAsync,
|
||||
pdwBytesReceived,
|
||||
pfCompletionPending);
|
||||
|
||||
if (hr == HRESULT_FROM_WIN32(ERROR_HANDLE_EOF))
|
||||
{
|
||||
// We reached the end of the data
|
||||
hr = S_OK;
|
||||
}
|
||||
|
||||
return hr;
|
||||
}
|
||||
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
HRESULT
|
||||
http_write_response_bytes(
|
||||
_In_ IHttpContext* pHttpContext,
|
||||
_In_ HTTP_DATA_CHUNK* pDataChunks,
|
||||
_In_ DWORD dwChunks,
|
||||
_In_ BOOL* pfCompletionExpected
|
||||
)
|
||||
{
|
||||
IHttpResponse *pHttpResponse = (IHttpResponse*)pHttpContext->GetResponse();
|
||||
BOOL fAsync = TRUE;
|
||||
BOOL fMoreData = TRUE;
|
||||
DWORD dwBytesSent = 0;
|
||||
|
||||
HRESULT hr = pHttpResponse->WriteEntityChunks(
|
||||
pDataChunks,
|
||||
dwChunks,
|
||||
fAsync,
|
||||
fMoreData,
|
||||
&dwBytesSent,
|
||||
pfCompletionExpected);
|
||||
|
||||
return hr;
|
||||
}
|
||||
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
HRESULT
|
||||
http_flush_response_bytes(
|
||||
_In_ IHttpContext* pHttpContext,
|
||||
_Out_ BOOL* pfCompletionExpected
|
||||
)
|
||||
{
|
||||
IHttpResponse *pHttpResponse = (IHttpResponse*)pHttpContext->GetResponse();
|
||||
|
||||
BOOL fAsync = TRUE;
|
||||
BOOL fMoreData = TRUE;
|
||||
DWORD dwBytesSent = 0;
|
||||
|
||||
HRESULT hr = pHttpResponse->Flush(
|
||||
fAsync,
|
||||
fMoreData,
|
||||
&dwBytesSent,
|
||||
pfCompletionExpected);
|
||||
return hr;
|
||||
}
|
||||
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
HRESULT
|
||||
http_websockets_read_bytes(
|
||||
_In_ IHttpContext* pHttpContext,
|
||||
_In_ CHAR* pvBuffer,
|
||||
_In_ DWORD cbBuffer,
|
||||
_In_ PFN_ASYNC_COMPLETION pfnCompletionCallback,
|
||||
_In_ VOID* pvCompletionContext,
|
||||
_In_ DWORD* pDwBytesReceived,
|
||||
_In_ BOOL* pfCompletionPending
|
||||
)
|
||||
{
|
||||
IHttpRequest3 *pHttpRequest = (IHttpRequest3*)pHttpContext->GetRequest();
|
||||
|
||||
BOOL fAsync = TRUE;
|
||||
|
||||
HRESULT hr = pHttpRequest->ReadEntityBody(
|
||||
pvBuffer,
|
||||
cbBuffer,
|
||||
fAsync,
|
||||
pfnCompletionCallback,
|
||||
pvCompletionContext,
|
||||
pDwBytesReceived,
|
||||
pfCompletionPending);
|
||||
|
||||
if (hr == HRESULT_FROM_WIN32(ERROR_HANDLE_EOF))
|
||||
{
|
||||
// We reached the end of the data
|
||||
hr = S_OK;
|
||||
}
|
||||
|
||||
return hr;
|
||||
}
|
||||
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
HRESULT
|
||||
http_websockets_write_bytes(
|
||||
_In_ IHttpContext* pHttpContext,
|
||||
_In_ HTTP_DATA_CHUNK* pDataChunks,
|
||||
_In_ DWORD dwChunks,
|
||||
_In_ PFN_ASYNC_COMPLETION pfnCompletionCallback,
|
||||
_In_ VOID* pvCompletionContext,
|
||||
_In_ BOOL* pfCompletionExpected
|
||||
)
|
||||
{
|
||||
IHttpResponse2 *pHttpResponse = (IHttpResponse2*)pHttpContext->GetResponse();
|
||||
|
||||
BOOL fAsync = TRUE;
|
||||
BOOL fMoreData = TRUE;
|
||||
DWORD dwBytesSent;
|
||||
|
||||
HRESULT hr = pHttpResponse->WriteEntityChunks(
|
||||
pDataChunks,
|
||||
dwChunks,
|
||||
fAsync,
|
||||
fMoreData,
|
||||
pfnCompletionCallback,
|
||||
pvCompletionContext,
|
||||
&dwBytesSent,
|
||||
pfCompletionExpected);
|
||||
|
||||
return hr;
|
||||
}
|
||||
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
HRESULT
|
||||
http_websockets_flush_bytes(
|
||||
_In_ IHttpContext* pHttpContext,
|
||||
_In_ PFN_ASYNC_COMPLETION pfnCompletionCallback,
|
||||
_In_ VOID* pvCompletionContext,
|
||||
_In_ BOOL* pfCompletionExpected
|
||||
)
|
||||
{
|
||||
IHttpResponse2 *pHttpResponse = (IHttpResponse2*)pHttpContext->GetResponse();
|
||||
|
||||
BOOL fAsync = TRUE;
|
||||
BOOL fMoreData = TRUE;
|
||||
DWORD dwBytesSent;
|
||||
|
||||
HRESULT hr = pHttpResponse->Flush(
|
||||
fAsync,
|
||||
fMoreData,
|
||||
pfnCompletionCallback,
|
||||
pvCompletionContext,
|
||||
&dwBytesSent,
|
||||
pfCompletionExpected);
|
||||
return hr;
|
||||
}
|
||||
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
HRESULT
|
||||
http_enable_websockets(
|
||||
_In_ IHttpContext* pHttpContext
|
||||
)
|
||||
{
|
||||
if (!g_fWebSocketSupported)
|
||||
{
|
||||
return E_FAIL;
|
||||
}
|
||||
|
||||
((IHttpContext3*)pHttpContext)->EnableFullDuplex();
|
||||
((IHttpResponse2*)pHttpContext->GetResponse())->DisableBuffering();
|
||||
|
||||
return S_OK;
|
||||
}
|
||||
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
HRESULT
|
||||
http_cancel_io(
|
||||
_In_ IHttpContext* pHttpContext
|
||||
)
|
||||
{
|
||||
return pHttpContext->CancelIo();
|
||||
}
|
||||
|
||||
// End of export
|
||||
|
||||
IN_PROCESS_APPLICATION* IN_PROCESS_APPLICATION::s_Application = NULL;
|
||||
|
||||
IN_PROCESS_APPLICATION::IN_PROCESS_APPLICATION() :
|
||||
|
|
|
|||
|
|
@ -0,0 +1,328 @@
|
|||
// Copyright (c) .NET Foundation and contributors. All rights reserved.
|
||||
// Licensed under the MIT license. See LICENSE file in the project root for full license information.
|
||||
|
||||
#include "precomp.hxx"
|
||||
|
||||
//
|
||||
// Initialization export
|
||||
//
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
VOID
|
||||
register_callbacks(
|
||||
_In_ PFN_REQUEST_HANDLER request_handler,
|
||||
_In_ PFN_SHUTDOWN_HANDLER shutdown_handler,
|
||||
_In_ PFN_MANAGED_CONTEXT_HANDLER async_completion_handler,
|
||||
_In_ VOID* pvRequstHandlerContext,
|
||||
_In_ VOID* pvShutdownHandlerContext
|
||||
)
|
||||
{
|
||||
IN_PROCESS_APPLICATION::GetInstance()->SetCallbackHandles(
|
||||
request_handler,
|
||||
shutdown_handler,
|
||||
async_completion_handler,
|
||||
pvRequstHandlerContext,
|
||||
pvShutdownHandlerContext
|
||||
);
|
||||
}
|
||||
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
HTTP_REQUEST*
|
||||
http_get_raw_request(
|
||||
_In_ IHttpContext* pHttpContext
|
||||
)
|
||||
{
|
||||
return pHttpContext->GetRequest()->GetRawHttpRequest();
|
||||
}
|
||||
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
HTTP_RESPONSE*
|
||||
http_get_raw_response(
|
||||
_In_ IHttpContext* pHttpContext
|
||||
)
|
||||
{
|
||||
return pHttpContext->GetResponse()->GetRawHttpResponse();
|
||||
}
|
||||
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT VOID http_set_response_status_code(
|
||||
_In_ IHttpContext* pHttpContext,
|
||||
_In_ USHORT statusCode,
|
||||
_In_ PCSTR pszReason
|
||||
)
|
||||
{
|
||||
pHttpContext->GetResponse()->SetStatus(statusCode, pszReason);
|
||||
}
|
||||
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
HRESULT
|
||||
http_post_completion(
|
||||
_In_ IHttpContext* pHttpContext,
|
||||
DWORD cbBytes
|
||||
)
|
||||
{
|
||||
return pHttpContext->PostCompletion(cbBytes);
|
||||
}
|
||||
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
HRESULT
|
||||
http_set_managed_context(
|
||||
_In_ IHttpContext* pHttpContext,
|
||||
_In_ PVOID pvManagedContext
|
||||
)
|
||||
{
|
||||
HRESULT hr;
|
||||
IN_PROCESS_STORED_CONTEXT* pInProcessStoredContext = new IN_PROCESS_STORED_CONTEXT(pHttpContext, pvManagedContext);
|
||||
if (pInProcessStoredContext == NULL)
|
||||
{
|
||||
return E_OUTOFMEMORY;
|
||||
}
|
||||
|
||||
hr = IN_PROCESS_STORED_CONTEXT::SetInProcessStoredContext(pHttpContext, pInProcessStoredContext);
|
||||
if (hr == HRESULT_FROM_WIN32(ERROR_ALREADY_ASSIGNED))
|
||||
{
|
||||
hr = S_OK;
|
||||
}
|
||||
|
||||
return hr;
|
||||
}
|
||||
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
VOID
|
||||
http_indicate_completion(
|
||||
_In_ IHttpContext* pHttpContext,
|
||||
_In_ REQUEST_NOTIFICATION_STATUS notificationStatus
|
||||
)
|
||||
{
|
||||
pHttpContext->IndicateCompletion(notificationStatus);
|
||||
}
|
||||
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
VOID
|
||||
http_get_completion_info(
|
||||
_In_ IHttpCompletionInfo2* info,
|
||||
_Out_ DWORD* cbBytes,
|
||||
_Out_ HRESULT* hr
|
||||
)
|
||||
{
|
||||
*cbBytes = info->GetCompletionBytes();
|
||||
*hr = info->GetCompletionStatus();
|
||||
}
|
||||
|
||||
//
|
||||
// todo: we should not rely on IN_PROCESS_APPLICATION::GetInstance()
|
||||
// the signature should be changed. application's based address should be passed in
|
||||
//
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
BSTR // TODO probably should make this a wide string
|
||||
http_get_application_full_path()
|
||||
{
|
||||
LPWSTR pwzPath = NULL;
|
||||
IN_PROCESS_APPLICATION* pApplication = IN_PROCESS_APPLICATION::GetInstance();
|
||||
if (pApplication != NULL)
|
||||
{
|
||||
pwzPath = pApplication->QueryConfig()->QueryApplicationFullPath()->QueryStr();
|
||||
}
|
||||
return SysAllocString(pwzPath);
|
||||
}
|
||||
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
HRESULT
|
||||
http_read_request_bytes(
|
||||
_In_ IHttpContext* pHttpContext,
|
||||
_Out_ CHAR* pvBuffer,
|
||||
_In_ DWORD dwCbBuffer,
|
||||
_Out_ DWORD* pdwBytesReceived,
|
||||
_Out_ BOOL* pfCompletionPending
|
||||
)
|
||||
{
|
||||
HRESULT hr;
|
||||
|
||||
if (pHttpContext == NULL)
|
||||
{
|
||||
return E_FAIL;
|
||||
}
|
||||
if (dwCbBuffer == 0)
|
||||
{
|
||||
return E_FAIL;
|
||||
}
|
||||
IHttpRequest *pHttpRequest = (IHttpRequest*)pHttpContext->GetRequest();
|
||||
|
||||
BOOL fAsync = TRUE;
|
||||
|
||||
hr = pHttpRequest->ReadEntityBody(
|
||||
pvBuffer,
|
||||
dwCbBuffer,
|
||||
fAsync,
|
||||
pdwBytesReceived,
|
||||
pfCompletionPending);
|
||||
|
||||
if (hr == HRESULT_FROM_WIN32(ERROR_HANDLE_EOF))
|
||||
{
|
||||
// We reached the end of the data
|
||||
hr = S_OK;
|
||||
}
|
||||
|
||||
return hr;
|
||||
}
|
||||
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
HRESULT
|
||||
http_write_response_bytes(
|
||||
_In_ IHttpContext* pHttpContext,
|
||||
_In_ HTTP_DATA_CHUNK* pDataChunks,
|
||||
_In_ DWORD dwChunks,
|
||||
_In_ BOOL* pfCompletionExpected
|
||||
)
|
||||
{
|
||||
IHttpResponse *pHttpResponse = (IHttpResponse*)pHttpContext->GetResponse();
|
||||
BOOL fAsync = TRUE;
|
||||
BOOL fMoreData = TRUE;
|
||||
DWORD dwBytesSent = 0;
|
||||
|
||||
HRESULT hr = pHttpResponse->WriteEntityChunks(
|
||||
pDataChunks,
|
||||
dwChunks,
|
||||
fAsync,
|
||||
fMoreData,
|
||||
&dwBytesSent,
|
||||
pfCompletionExpected);
|
||||
|
||||
return hr;
|
||||
}
|
||||
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
HRESULT
|
||||
http_flush_response_bytes(
|
||||
_In_ IHttpContext* pHttpContext,
|
||||
_Out_ BOOL* pfCompletionExpected
|
||||
)
|
||||
{
|
||||
IHttpResponse *pHttpResponse = (IHttpResponse*)pHttpContext->GetResponse();
|
||||
|
||||
BOOL fAsync = TRUE;
|
||||
BOOL fMoreData = TRUE;
|
||||
DWORD dwBytesSent = 0;
|
||||
|
||||
HRESULT hr = pHttpResponse->Flush(
|
||||
fAsync,
|
||||
fMoreData,
|
||||
&dwBytesSent,
|
||||
pfCompletionExpected);
|
||||
return hr;
|
||||
}
|
||||
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
HRESULT
|
||||
http_websockets_read_bytes(
|
||||
_In_ IHttpContext* pHttpContext,
|
||||
_In_ CHAR* pvBuffer,
|
||||
_In_ DWORD cbBuffer,
|
||||
_In_ PFN_ASYNC_COMPLETION pfnCompletionCallback,
|
||||
_In_ VOID* pvCompletionContext,
|
||||
_In_ DWORD* pDwBytesReceived,
|
||||
_In_ BOOL* pfCompletionPending
|
||||
)
|
||||
{
|
||||
IHttpRequest3 *pHttpRequest = (IHttpRequest3*)pHttpContext->GetRequest();
|
||||
|
||||
BOOL fAsync = TRUE;
|
||||
|
||||
HRESULT hr = pHttpRequest->ReadEntityBody(
|
||||
pvBuffer,
|
||||
cbBuffer,
|
||||
fAsync,
|
||||
pfnCompletionCallback,
|
||||
pvCompletionContext,
|
||||
pDwBytesReceived,
|
||||
pfCompletionPending);
|
||||
|
||||
if (hr == HRESULT_FROM_WIN32(ERROR_HANDLE_EOF))
|
||||
{
|
||||
// We reached the end of the data
|
||||
hr = S_OK;
|
||||
}
|
||||
|
||||
return hr;
|
||||
}
|
||||
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
HRESULT
|
||||
http_websockets_write_bytes(
|
||||
_In_ IHttpContext* pHttpContext,
|
||||
_In_ HTTP_DATA_CHUNK* pDataChunks,
|
||||
_In_ DWORD dwChunks,
|
||||
_In_ PFN_ASYNC_COMPLETION pfnCompletionCallback,
|
||||
_In_ VOID* pvCompletionContext,
|
||||
_In_ BOOL* pfCompletionExpected
|
||||
)
|
||||
{
|
||||
IHttpResponse2 *pHttpResponse = (IHttpResponse2*)pHttpContext->GetResponse();
|
||||
|
||||
BOOL fAsync = TRUE;
|
||||
BOOL fMoreData = TRUE;
|
||||
DWORD dwBytesSent;
|
||||
|
||||
HRESULT hr = pHttpResponse->WriteEntityChunks(
|
||||
pDataChunks,
|
||||
dwChunks,
|
||||
fAsync,
|
||||
fMoreData,
|
||||
pfnCompletionCallback,
|
||||
pvCompletionContext,
|
||||
&dwBytesSent,
|
||||
pfCompletionExpected);
|
||||
|
||||
return hr;
|
||||
}
|
||||
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
HRESULT
|
||||
http_websockets_flush_bytes(
|
||||
_In_ IHttpContext* pHttpContext,
|
||||
_In_ PFN_ASYNC_COMPLETION pfnCompletionCallback,
|
||||
_In_ VOID* pvCompletionContext,
|
||||
_In_ BOOL* pfCompletionExpected
|
||||
)
|
||||
{
|
||||
IHttpResponse2 *pHttpResponse = (IHttpResponse2*)pHttpContext->GetResponse();
|
||||
|
||||
BOOL fAsync = TRUE;
|
||||
BOOL fMoreData = TRUE;
|
||||
DWORD dwBytesSent;
|
||||
|
||||
HRESULT hr = pHttpResponse->Flush(
|
||||
fAsync,
|
||||
fMoreData,
|
||||
pfnCompletionCallback,
|
||||
pvCompletionContext,
|
||||
&dwBytesSent,
|
||||
pfCompletionExpected);
|
||||
return hr;
|
||||
}
|
||||
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
HRESULT
|
||||
http_enable_websockets(
|
||||
_In_ IHttpContext* pHttpContext
|
||||
)
|
||||
{
|
||||
if (!g_fWebSocketSupported)
|
||||
{
|
||||
return E_FAIL;
|
||||
}
|
||||
|
||||
((IHttpContext3*)pHttpContext)->EnableFullDuplex();
|
||||
((IHttpResponse2*)pHttpContext->GetResponse())->DisableBuffering();
|
||||
|
||||
return S_OK;
|
||||
}
|
||||
|
||||
EXTERN_C __MIDL_DECLSPEC_DLLEXPORT
|
||||
HRESULT
|
||||
http_cancel_io(
|
||||
_In_ IHttpContext* pHttpContext
|
||||
)
|
||||
{
|
||||
return pHttpContext->CancelIo();
|
||||
}
|
||||
|
||||
// End of export
|
||||
Loading…
Reference in New Issue