130 lines
2.8 KiB
C++
130 lines
2.8 KiB
C++
/*++
|
|
|
|
Copyright (c) 1996 Microsoft Corporation
|
|
|
|
Module Name :
|
|
atqcport.hxx
|
|
|
|
Abstract:
|
|
Declares constants, types and functions for fake completion port
|
|
|
|
Author:
|
|
|
|
VladS 05-Jan-1996 Created.
|
|
--*/
|
|
|
|
#ifndef _ATQCPORT_H_
|
|
#define _ATQCPORT_H_
|
|
|
|
/************************************************************
|
|
* Constants
|
|
************************************************************/
|
|
|
|
//
|
|
// The maximum number of threads we will allow to be created
|
|
//
|
|
|
|
#define SIO_MAX_THREADS 1
|
|
|
|
//
|
|
// The amount of time (in ms) a socket i/o thread will be idle before
|
|
// terminating itself. Timeout is combined from 1 sec syncronization timeout
|
|
// and maximum number of timeouts before shutting down the thread
|
|
//
|
|
|
|
#define SIO_THREAD_TIMEOUT (1000) // 1 sec
|
|
#define SIO_THREAD_TIMEOUT_COUNTER (4*60) // 4 minutes
|
|
|
|
//
|
|
// flags
|
|
//
|
|
|
|
//
|
|
// W95 Completion port replacement support fields
|
|
//
|
|
|
|
#define ATQ_SIO_FLAG_STATE_MASK 0x000f
|
|
#define ATQ_SIO_FLAG_STATE_INCOMING 0x0001
|
|
#define ATQ_SIO_FLAG_STATE_COMPLETED 0x0002
|
|
#define ATQ_SIO_FLAG_STATE_WAITING 0x0003
|
|
|
|
//
|
|
// wakeup port
|
|
//
|
|
|
|
#define CPORT_WAKEUP_PORT 6543
|
|
|
|
//
|
|
// signature
|
|
//
|
|
|
|
#define ATQ_SIO_CPORT_SIGNATURE (DWORD)'C59W'
|
|
#define ATQ_WAKEUP_SIGNATURE 0x11111111
|
|
|
|
|
|
/*************************************************************************
|
|
|
|
NAME: W95CPORT
|
|
|
|
SYNOPSIS:
|
|
|
|
INTERFACE:
|
|
|
|
PARENT:
|
|
|
|
HISTORY:
|
|
|
|
**************************************************************************/
|
|
class W95CPORT {
|
|
|
|
private:
|
|
|
|
DWORD m_Signature;
|
|
LONG m_IsThreadRunning;
|
|
|
|
BOOL m_IsDestroying;
|
|
BOOL m_fWakeupSignalled;
|
|
|
|
HANDLE m_hThread;
|
|
SOCKET m_scWakeup;
|
|
|
|
//
|
|
//
|
|
//
|
|
|
|
FD_SET m_ReadfdsStore;
|
|
FD_SET m_WritefdsStore;
|
|
|
|
CRITICAL_SECTION m_csLock;
|
|
|
|
VOID Lock(VOID) {EnterCriticalSection( &m_csLock );}
|
|
VOID Unlock(VOID) {LeaveCriticalSection( &m_csLock );}
|
|
|
|
BOOL PrepareDescriptorArrays(IN PFD_SET ReadFds,
|
|
IN PFD_SET WriteFds);
|
|
|
|
BOOL ProcessSocketCompletion(IN DWORD dwCompletedCount,
|
|
IN PFD_SET ReadFds,
|
|
IN PFD_SET WriteFds);
|
|
|
|
VOID CleanupDescriptorList(VOID);
|
|
|
|
public:
|
|
|
|
W95CPORT(DWORD dwConcurrentThreads);
|
|
~W95CPORT();
|
|
|
|
inline SOCKET
|
|
QueryWakeupSocket( VOID ) { return m_scWakeup; }
|
|
|
|
BOOL Shutdown(VOID);
|
|
VOID Wakeup(VOID);
|
|
DWORD PoolThreadCallBack(VOID);
|
|
BOOL SIOCheckCompletionThreadStatus(VOID);
|
|
};
|
|
|
|
|
|
#endif // _ATQCPORT_H_
|
|
|
|
|