diff options
Diffstat (limited to 'src/vm/nativeoverlapped.cpp')
| -rw-r--r-- | src/vm/nativeoverlapped.cpp | 24 |
1 files changed, 13 insertions, 11 deletions
diff --git a/src/vm/nativeoverlapped.cpp b/src/vm/nativeoverlapped.cpp index 2e253f3046..d0afbb648a 100644 --- a/src/vm/nativeoverlapped.cpp +++ b/src/vm/nativeoverlapped.cpp @@ -35,14 +35,14 @@ FCIMPL3(void, CheckVMForIOPacket, LPOVERLAPPED* lpOverlapped, DWORD* errorCode, { FCALL_CONTRACT; -#ifndef FEATURE_PAL +#ifndef FEATURE_PAL Thread *pThread = GetThread(); DWORD adid = pThread->GetDomain()->GetId().m_dwId; size_t key=0; - _ASSERTE(pThread); + _ASSERTE(pThread); - //Poll and wait if GC is in progress, to avoid blocking GC for too long. + //Poll and wait if GC is in progress, to avoid blocking GC for too long. FC_GC_POLL(); *lpOverlapped = ThreadpoolMgr::CompletionPortDispatchWorkWithinAppDomain(pThread, errorCode, numBytes, &key, adid); @@ -59,13 +59,15 @@ FCIMPL3(void, CheckVMForIOPacket, LPOVERLAPPED* lpOverlapped, DWORD* errorCode, if(overlapped->m_iocb == NULL) { // no user delegate to callback - _ASSERTE((overlapped->m_iocbHelper == NULL) || !"This is benign, but should be optimized"); + _ASSERTE((overlapped->m_iocbHelper == NULL) || !"This is benign, but should be optimized"); +#ifndef FEATURE_CORECLR if (g_pAsyncFileStream_AsyncResultClass) { SetAsyncResultProperties(overlapped, *errorCode, *numBytes); - } - else + } + else +#endif // !FEATURE_CORECLR { //We're not initialized yet, go back to the Vm, and process the packet there. ThreadpoolMgr::StoreOverlappedInfoInThread(pThread, *errorCode, *numBytes, key, *lpOverlapped); @@ -75,7 +77,7 @@ FCIMPL3(void, CheckVMForIOPacket, LPOVERLAPPED* lpOverlapped, DWORD* errorCode, return; } else - { + { if(!pThread->IsRealThreadPoolResetNeeded()) { pThread->ResetManagedThreadObjectInCoopMode(ThreadNative::PRIORITY_NORMAL); @@ -84,7 +86,7 @@ FCIMPL3(void, CheckVMForIOPacket, LPOVERLAPPED* lpOverlapped, DWORD* errorCode, { //We may have to create a CP thread, go back to the Vm, and process the packet there. ThreadpoolMgr::StoreOverlappedInfoInThread(pThread, *errorCode, *numBytes, key, *lpOverlapped); - *lpOverlapped = NULL; + *lpOverlapped = NULL; } } else @@ -93,7 +95,7 @@ FCIMPL3(void, CheckVMForIOPacket, LPOVERLAPPED* lpOverlapped, DWORD* errorCode, //and process the packet there. ThreadpoolMgr::StoreOverlappedInfoInThread(pThread, *errorCode, *numBytes, key, *lpOverlapped); - *lpOverlapped = NULL; + *lpOverlapped = NULL; } } @@ -105,8 +107,8 @@ FCIMPL3(void, CheckVMForIOPacket, LPOVERLAPPED* lpOverlapped, DWORD* errorCode, *lpOverlapped = NULL; #endif // !FEATURE_PAL - return; -} + return; +} FCIMPLEND FCIMPL1(void*, AllocateNativeOverlapped, OverlappedDataObject* overlappedUNSAFE) |