mirror of
https://github.com/DarkflameUniverse/DarkflameServer.git
synced 2024-11-22 21:47:24 +00:00
91 lines
2.5 KiB
C
91 lines
2.5 KiB
C
|
/// \file
|
||
|
|
/// \brief \b [Internal] Depreciated, used for windows back when I supported IO completion ports.
|
||
|
|
///
|
||
|
|
/// This file is part of RakNet Copyright 2003 Kevin Jenkins.
|
||
|
|
///
|
||
|
|
/// Usage of RakNet is subject to the appropriate license agreement.
|
||
|
|
/// Creative Commons Licensees are subject to the
|
||
|
|
/// license found at
|
||
|
|
/// http://creativecommons.org/licenses/by-nc/2.5/
|
||
|
|
/// Single application licensees are subject to the license found at
|
||
|
|
/// http://www.jenkinssoftware.com/SingleApplicationLicense.html
|
||
|
|
/// Custom license users are subject to the terms therein.
|
||
|
|
/// GPL license users are subject to the GNU General Public
|
||
|
|
/// License as published by the Free
|
||
|
|
/// Software Foundation; either version 2 of the License, or (at your
|
||
|
|
/// option) any later version.
|
||
|
|
|
||
|
|
// No longer used as I no longer support IO Completion ports
|
||
|
|
/*
|
||
|
|
#ifdef __USE_IO_COMPLETION_PORTS
|
||
|
|
|
||
|
|
#ifndef __ASYNCHRONOUS_FILE_IO_H
|
||
|
|
#define __ASYNCHRONOUS_FILE_IO_H
|
||
|
|
|
||
|
|
#ifdef _XBOX360
|
||
|
|
#elif defined(_WIN32)
|
||
|
|
// IP_DONTFRAGMENT is different between winsock 1 and winsock 2. Therefore, Winsock2.h must be linked againt Ws2_32.lib
|
||
|
|
// winsock.h must be linked against WSock32.lib. If these two are mixed up the flag won't work correctly
|
||
|
|
//#include <winsock2.h>
|
||
|
|
//#include <windows.h>
|
||
|
|
#endif
|
||
|
|
#include "SimpleMutex.h"
|
||
|
|
|
||
|
|
struct ExtendedOverlappedStruct;
|
||
|
|
|
||
|
|
/// Provides asynch file input and ouput, either for sockets or files
|
||
|
|
class AsynchronousFileIO
|
||
|
|
{
|
||
|
|
|
||
|
|
public:
|
||
|
|
|
||
|
|
/// Default Constructor
|
||
|
|
AsynchronousFileIO();
|
||
|
|
|
||
|
|
/// Destructor
|
||
|
|
~AsynchronousFileIO();
|
||
|
|
|
||
|
|
|
||
|
|
/// Associate a socket with a completion port
|
||
|
|
/// \param[in] socket the socket used for communication
|
||
|
|
/// \param[in] dwCompletionKey the completion port key
|
||
|
|
bool AssociateSocketWithCompletionPort( SOCKET socket, DWORD dwCompletionKey );if
|
||
|
|
|
||
|
|
/// Singleton instance
|
||
|
|
static inline AsynchronousFileIO* Instance()
|
||
|
|
{
|
||
|
|
return & I;
|
||
|
|
}
|
||
|
|
|
||
|
|
/// Increase the number of users of this instance
|
||
|
|
void IncreaseUserCount( void );
|
||
|
|
|
||
|
|
/// Decrease the number of users of this instance
|
||
|
|
void DecreaseUserCount( void );
|
||
|
|
|
||
|
|
/// Stop using asynchronous IO
|
||
|
|
void Shutdown( void );
|
||
|
|
|
||
|
|
/// Get the number of user of the instance
|
||
|
|
int GetUserCount( void );
|
||
|
|
|
||
|
|
unsigned threadCount;
|
||
|
|
bool killThreads;
|
||
|
|
|
||
|
|
private:
|
||
|
|
HANDLE completionPort;
|
||
|
|
SimpleMutex userCountMutex;
|
||
|
|
SYSTEM_INFO systemInfo;
|
||
|
|
int userCount;
|
||
|
|
|
||
|
|
static AsynchronousFileIO I;
|
||
|
|
};
|
||
|
|
|
||
|
|
unsigned __stdcall ThreadPoolFunc( LPVOID arguments );
|
||
|
|
|
||
|
|
void WriteAsynch( HANDLE handle, ExtendedOverlappedStruct *extended );
|
||
|
|
|
||
|
|
BOOL ReadAsynch( HANDLE handle, ExtendedOverlappedStruct *extended );
|
||
|
|
|
||
|
|
#endif
|
||
|
|
*/
|