17 #define CsrHashThread(t) (HandleToUlong(t) % NUMBER_THREAD_HASH_BUCKETS) 46 ObjectHandleFlagInformation,
55 ObjectHandleFlagInformation,
85 ObjectHandleFlagInformation,
94 ObjectHandleFlagInformation,
125 if (!CsrThread)
return NULL;
157 ++CsrThread->ReferenceCount;
197 NextEntry = ListHead->
Flink;
200 while (NextEntry != ListHead)
206 NextEntry = NextEntry->
Flink;
259 NextEntry = ListHead->
Flink;
262 while (NextEntry != ListHead)
271 NextEntry = NextEntry->
Flink;
381 CsrThread->Process->ThreadCount--;
384 if (CsrThread->HashLinks.Flink)
RemoveEntryList(&CsrThread->HashLinks);
387 if (CsrThread->Process->ThreadCount == 0)
437 if (CsrThread->ThreadHandle)
529 CsrThread->
Flags = ThreadFlags;
539 DPRINT1(
"CsrAddStaticServerThread: alloc failed for thread 0x%x\n",
hThread);
636 CsrThread->
Flags = 0;
693 CurrentCid = CurrentThread->
ClientId;
741 CsrThread->
Flags = 0;
782 ASSERT(CsrThread->ReferenceCount > 0);
783 if ((--CsrThread->ReferenceCount) == 0)
1001 NextEntry = NextEntry->
Flink;
1013 *CsrThread = CurrentThread;
1050 ASSERT(CsrThread->ReferenceCount != 0);
1053 CsrThread->ReferenceCount++;
#define CsrGetClientThread()
BOOLEAN NTAPI CsrNotifyWaitBlock(IN PCSR_WAIT_BLOCK WaitBlock, IN PLIST_ENTRY WaitList, IN PVOID WaitArgument1, IN PVOID WaitArgument2, IN ULONG WaitFlags, IN BOOLEAN DereferenceThread)
VOID NTAPI CsrLockedReferenceThread(IN PCSR_THREAD CsrThread)
FORCEINLINE VOID InsertHeadList(_Inout_ PLIST_ENTRY ListHead, _Inout_ __drv_aliasesMem PLIST_ENTRY Entry)
#define STATUS_THREAD_IS_TERMINATING
NTSTATUS NTAPI CsrLockThreadByClientId(IN HANDLE Tid, OUT PCSR_THREAD *CsrThread)
BOOLEAN NTAPI RtlFreeHeap(IN PVOID HeapHandle, IN ULONG Flags, IN PVOID HeapBase)
PCSR_THREAD NTAPI CsrLocateThreadInProcess(IN PCSR_PROCESS CsrProcess OPTIONAL, IN PCLIENT_ID Cid)
struct _ThreadInfo ThreadInfo
VOID NTAPI CsrDereferenceProcess(IN PCSR_PROCESS CsrProcess)
NTSTATUS NTAPI CsrUnlockThread(IN PCSR_THREAD CsrThread)
#define InsertTailList(ListHead, Entry)
#define CsrReleaseWaitLock()
#define CsrReleaseProcessLock()
static int Link(const char **args)
VOID NTAPI CsrDeallocateThread(IN PCSR_THREAD CsrThread)
NTSTATUS NTAPI CsrExecServerThread(IN PVOID ThreadHandler, IN ULONG Flags)
FORCEINLINE BOOLEAN RemoveEntryList(_In_ PLIST_ENTRY Entry)
PCSR_PROCESS CsrRootProcess
#define ProcessStructureListLocked()
#define DUPLICATE_SAME_ACCESS
NTSTATUS(* NTAPI)(IN PFILE_FULL_EA_INFORMATION EaBuffer, IN ULONG EaLength, OUT PULONG ErrorOffset)
NTSTATUS NTAPI NtSetInformationObject(IN HANDLE ObjectHandle, IN OBJECT_INFORMATION_CLASS ObjectInformationClass, IN PVOID ObjectInformation, IN ULONG Length)
VOID NTAPI CsrLockedDereferenceThread(IN PCSR_THREAD CsrThread)
VOID NTAPI CsrThreadRefcountZero(IN PCSR_THREAD CsrThread)
NTSTATUS NTAPI CsrLockProcessByClientId(IN HANDLE Pid, OUT PCSR_PROCESS *CsrProcess OPTIONAL)
PFLT_MESSAGE_WAITER_QUEUE CONTAINING_RECORD(Csq, DEVICE_EXTENSION, IrpQueue)) -> WaiterQ.mLock) _IRQL_raises_(DISPATCH_LEVEL) VOID NTAPI FltpAcquireMessageWaiterLock(_In_ PIO_CSQ Csq, _Out_ PKIRQL Irql)
#define NtCurrentProcess()
PVOID NTAPI RtlAllocateHeap(IN PVOID HeapHandle, IN ULONG Flags, IN SIZE_T Size)
struct _LIST_ENTRY * Flink
_Must_inspect_result_ _In_ ULONG Flags
_Out_ PCLIENT_ID ClientId
#define NT_SUCCESS(StatCode)
NTSTATUS NtQueryObject(IN HANDLE Handle, IN OBJECT_INFO_CLASS ObjectInformationClass, OUT PVOID ObjectInformation, IN ULONG ObjectInformationLength, OUT PULONG ReturnLength)
VOID NTAPI CsrDereferenceThread(IN PCSR_THREAD CsrThread)
_In_opt_ PFILE_OBJECT _In_opt_ PETHREAD Thread
NTSTATUS NTAPI NtQueryInformationThread(IN HANDLE ThreadHandle, IN THREADINFOCLASS ThreadInformationClass, OUT PVOID ThreadInformation, IN ULONG ThreadInformationLength, OUT PULONG ReturnLength OPTIONAL)
NTSTATUS NTAPI NtClose(IN HANDLE Handle)
#define STATUS_UNSUCCESSFUL
#define CsrAcquireProcessLock()
LIST_ENTRY CsrThreadHashTable[NUMBER_THREAD_HASH_BUCKETS]
NTSYSAPI NTSTATUS NTAPI RtlCreateUserThread(_In_ PVOID ThreadContext, _Out_ HANDLE *OutThreadHandle, _Reserved_ PVOID Reserved1, _Reserved_ PVOID Reserved2, _Reserved_ PVOID Reserved3, _Reserved_ PVOID Reserved4, _Reserved_ PVOID Reserved5, _Reserved_ PVOID Reserved6, _Reserved_ PVOID Reserved7, _Reserved_ PVOID Reserved8)
VOID NTAPI CsrReferenceThread(IN PCSR_THREAD CsrThread)
#define NUMBER_THREAD_HASH_BUCKETS
#define CsrAcquireWaitLock()
GLsizei GLenum const GLvoid GLsizei GLenum GLbyte GLbyte GLbyte GLdouble GLdouble GLdouble GLfloat GLfloat GLfloat GLint GLint GLint GLshort GLshort GLshort GLubyte GLubyte GLubyte GLuint GLuint GLuint GLushort GLushort GLushort GLbyte GLbyte GLbyte GLbyte GLdouble GLdouble GLdouble GLdouble GLfloat GLfloat GLfloat GLfloat GLint GLint GLint GLint GLshort GLshort GLshort GLshort GLubyte GLubyte GLubyte GLubyte GLuint GLuint GLuint GLuint GLushort GLushort GLushort GLushort GLboolean const GLdouble const GLfloat const GLint const GLshort const GLbyte const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLdouble const GLfloat const GLfloat const GLint const GLint const GLshort const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort GLenum GLenum GLenum GLfloat GLenum GLint GLenum GLenum GLenum GLfloat GLenum GLenum GLint GLenum GLfloat GLenum GLint GLint GLushort GLenum GLenum GLfloat GLenum GLenum GLint GLfloat const GLubyte GLenum GLenum GLenum const GLfloat GLenum GLenum const GLint GLenum GLint GLint GLsizei GLsizei GLint GLenum GLenum const GLvoid GLenum GLenum const GLfloat GLenum GLenum const GLint GLenum GLenum const GLdouble GLenum GLenum const GLfloat GLenum GLenum const GLint GLsizei GLuint GLfloat GLuint GLbitfield GLfloat GLint GLuint GLboolean GLenum GLfloat GLenum GLbitfield GLenum GLfloat GLfloat GLint GLint const GLfloat GLenum GLfloat GLfloat GLint GLint GLfloat GLfloat GLint GLint const GLfloat GLint GLfloat GLfloat GLint GLfloat GLfloat GLint GLfloat GLfloat const GLdouble const GLfloat const GLdouble const GLfloat GLint i
struct _CSR_WAIT_BLOCK * WaitBlock
NTSTATUS NTAPI CsrCreateThread(IN PCSR_PROCESS CsrProcess, IN HANDLE hThread, IN PCLIENT_ID ClientId, IN BOOLEAN HaveClient)
PCSR_THREAD NTAPI CsrLocateThreadByClientId(OUT PCSR_PROCESS *Process OPTIONAL, IN PCLIENT_ID ClientId)
NTSTATUS NTAPI CsrDestroyThread(IN PCLIENT_ID Cid)
_Must_inspect_result_ _In_ PLARGE_INTEGER _In_ PLARGE_INTEGER _In_ ULONG _In_ PFILE_OBJECT _In_ PVOID Process
NTSTATUS NTAPI NtDuplicateObject(IN HANDLE SourceProcessHandle, IN HANDLE SourceHandle, IN HANDLE TargetProcessHandle OPTIONAL, OUT PHANDLE TargetHandle OPTIONAL, IN ACCESS_MASK DesiredAccess, IN ULONG HandleAttributes, IN ULONG Options)
NTSTATUS NTAPI CsrCreateRemoteThread(IN HANDLE hThread, IN PCLIENT_ID ClientId)
PCSR_THREAD NTAPI CsrAddStaticServerThread(IN HANDLE hThread, IN PCLIENT_ID ClientId, IN ULONG ThreadFlags)
VOID NTAPI CsrLockedReferenceProcess(IN PCSR_PROCESS CsrProcess)
NTSTATUS NTAPI CsrInsertThread(IN PCSR_PROCESS Process, IN PCSR_THREAD Thread)
BOOLEAN NTAPI UnProtectHandle(IN HANDLE ObjectHandle)
VOID NTAPI CsrLockedDereferenceProcess(PCSR_PROCESS CsrProcess)
NTSTATUS NTAPI CsrUnlockProcess(IN PCSR_PROCESS CsrProcess)
BOOLEAN NTAPI ProtectHandle(IN HANDLE ObjectHandle)
PCSR_THREAD NTAPI CsrAllocateThread(IN PCSR_PROCESS CsrProcess)
VOID NTAPI CsrRemoveThread(IN PCSR_THREAD CsrThread)
PULONG MinorVersion OPTIONAL