meteredsection.h

概述：数据的纵向收集

//[e-mail]

/************************************************************
	Module Name: MeteredSection.h
	Author: Dan Chou
	Description: Defines the metered section synchronization object
************************************************************/

#ifndef _METERED_SECTION_H_
#define _METERED_SECTION_H_

#ifdef USE_METERED_SECTION

#define MAX_METSECT_NAMELEN 128

#ifdef __cplusplus
extern "C"
{
#endif // __cplusplus

// Shared info needed for metered section
typedef struct _METSECT_SHARED_INFO {
	BOOL   fInitialized;     // Is the metered section initialized?
	LONG   lSpinLock;        // Used to gain access to this structure
	LONG   lThreadsWaiting;  // Count of threads waiting
	LONG   lAvailableCount;  // Available resource count
	LONG   lMaximumCount;    // Maximum resource count
} METSECT_SHARED_INFO, *LPMETSECT_SHARED_INFO;

// The opaque Metered Section data structure
typedef struct _METERED_SECTION {
	HANDLE hEvent;           // Handle to a kernel event object
	HANDLE hFileMap;         // Handle to memory mapped file
	LPMETSECT_SHARED_INFO lpSharedInfo;
} METERED_SECTION, *LPMETERED_SECTION;

// Interface functions
LPMETERED_SECTION
CreateMeteredSection(LONG lInitialCount, LONG lMaximumCount, LPCTSTR lpName);

#ifndef _WIN32_WCE
LPMETERED_SECTION OpenMeteredSection(LPCTSTR lpName);
#endif

DWORD EnterMeteredSection(LPMETERED_SECTION lpMetSect, DWORD dwMilliseconds);
BOOL LeaveMeteredSection(LPMETERED_SECTION lpMetSect, LONG lReleaseCount, LPLONG lpPreviousCount);
void CloseMeteredSection(LPMETERED_SECTION lpMetSect);

#ifdef __cplusplus
}
#endif // __cplusplus

#else

#define LPMETERED_SECTION HANDLE
#define CreateMeteredSection(a, b, c) CreateSemaphore(NULL, a, b, c);
#define EnterMeteredSection(a, b) WaitForSingleObject(a, b)
#define LeaveMeteredSection(a, b, c) ReleaseSemaphore(a, b, c)
#define CloseMeteredSection(a) CloseHandle(a)

#endif

#endif // _METERED_SECTION_H_