The Win32 Foundation Classes (WFC) - Version 45

Sam Blackburn

Rate me:

4.93/5 (40 votes)

16 May 2000

469.5K

12.7K

280

The Win32 Foundation Classes (WFC) are a library of C++ classes that extend Microsoft Foundation Classes (MFC) beyond mere GUI applications, and provide extensive support for system and NT specific applications

wfc.zip
- wfc
  - BACKUP.CMD
  - HTML
    - Document.cmd
    - web
      - CLASSES.HTM
      - Coding.htm
      - gather.cmd
      - HOMEPAGE.HTM
      - pax.HTM
      - Release30.htm
      - Release31.htm
      - Release32.htm
      - Release33.htm
      - release34.htm
      - Release35.htm
      - Release36.htm
      - Release37.htm
      - Release38.htm
      - Release39.htm
      - Release41.htm
      - Release42.htm
      - Release43.htm
      - Release44.htm
      - Samples.htm
      - TechNotes.htm
      - TIMEBEG.HTM
      - TITLE.HTM
      - WFC.HTM
      - WTN001.htm
      - WTN002.htm
      - WTN003.htm
      - WTN004.htm
      - WTN005.htm
      - WTN006.htm
      - WTN007.htm
  - INCLUDE
    - CBase64Coding.hpp
    - CBitArray.hpp
    - CBubble.hpp
    - CConstellation.hpp
    - CCriticalSection.hpp
    - CCrypto.hpp
    - CDataArchive.hpp
    - CDataChunk.hpp
    - CDataFile.hpp
    - CDataLocation.hpp
    - CDataMemory.hpp
    - CDataParser.hpp
    - CDataSocket.hpp
    - CDesktop.hpp
    - CDragQuery.hpp
    - CEventLogRecord.HPP
    - CEVNTLOG.HPP
    - CExtensibleMarkupLanguage.hpp
    - CFile.hpp
    - CFile64.hpp
    - CFileDirectory.hpp
    - CFileTime.hpp
    - CFileTransferProtocol.hpp
    - CGarbageCollector.hpp
    - CJulianDate.hpp
    - CMemoryFile.hpp
    - CMicrosoftTape.hpp
    - CMixer.hpp
    - CNetConn.hpp
    - CNetFile.hpp
    - CNetInfo.hpp
    - CNetMesg.hpp
    - CNetRsrc.hpp
    - CNetSess.hpp
    - CNetShar.hpp
    - CNetUser.hpp
    - CNetWkst.hpp
    - CNetwork.hpp
    - CNetworkScheduleJob.hpp
    - CNMPIPE.HPP
    - CParsePoint.hpp
    - CPasswordChangeFilter.hpp
    - CPhysicalDiskFile.hpp
    - CPing.hpp
    - CQueue.hpp
    - CRandomNumberGenerator.hpp
    - CRandomNumberGenerator2.hpp
    - CRAS.HPP
    - CRASADM.HPP
    - CRASPORT.HPP
    - CReedSolomonErrorCorrectionCode.hpp
    - CREGISTY.HPP
    - CSecureChannel.hpp
    - CServer.hpp
    - CService.hpp
    - CServiceApplication.hpp
    - CSharedMemoryObject.hpp
    - CSMTF.hpp
    - CSquigl.hpp
    - CSuperRandomNumberGenerator.hpp
    - CSvcMgr.hpp
    - CSystemTime.hpp
    - ctape.hpp
    - CTimeEx.hpp
    - CUNC.HPP
    - CURL.HPP
    - CUUCoding.hpp
    - CVolume.hpp
    - CWait.hpp
    - CWeather.hpp
    - CXMLArchive.hpp
    - DCB.HPP
    - DrawGrid.hpp
    - DrawObj.hpp
    - DumyFile.hpp
    - Guards.hpp
    - LSOCKETS.HPP
    - LZFILE.HPP
    - Mfc2Stl.h
    - Modem.hpp
    - mtf.h
    - origianl_CFile.hpp
    - OVRLPD.HPP
    - Pager.hpp
    - PortInformation.hpp
    - RIFF.hpp
    - samtf.h
    - Serial.hpp
    - ServiceConfiguration.hpp
    - SkyWord.hpp
    - SOCKETS.HPP
    - SockFile.hpp
    - SprintSpectrum.hpp
    - stlxml.h
    - Structs.hpp
    - TSOCKETS.HPP
    - WFC.H
    - wfc_coverage.h
    - wfc_crypto.h
    - wfc_linker_setup.h
    - wfc_thread_information_block.h
    - wfc_undocumented.h
    - wfcfloat.h
    - WFCTrace.hpp
    - WindowsSockets.hpp
  - InternalCompilerErrors.txt
  - LIB
    - make.cmd
    - types.xml
    - WFC.dsp
    - WFC.dsw
    - WFC.mak
    - wfcvc42.mak
  - makewebsite.cmd
  - old_paxit.cmd
  - PAXIT.CMD
  - Renames.txt
  - SRC
    - ATCP.cpp
    - CBase64Coding.cpp
    - CBitArray.cpp
    - CBubble.cpp
    - CConstellation.cpp
    - CCriticalSection.cpp
    - CCriticalSectionGuard.cpp
    - CCryptographicAlgorithm.cpp
    - CCryptographicHash.cpp
    - CCryptographicKey.cpp
    - CCryptographicProvider.cpp
    - CCryptography.cpp
    - CDataArchive.cpp
    - CDataChunk.cpp
    - CDataFile.cpp
    - CDataMemory.cpp
    - CDataParser.cpp
    - CDataSocket.cpp
    - CDesktop.cpp
    - CDragQuery.cpp
    - CEventLogRecord.CPP
    - CEVNTLOG.CPP
    - CExtensibleMarkupLanguageAttribute.cpp
    - CExtensibleMarkupLanguageDocument.cpp
    - CExtensibleMarkupLanguageElement.cpp
    - CExtensibleMarkupLanguageEntities.cpp
    - CFile.cpp
    - CFile64.cpp
    - CFileDirectory.cpp
    - CFileTime.cpp
    - CFileTransferProtocol.cpp
    - CGarbageCollector.cpp
    - CJulianDate.cpp
    - CMemoryFile.cpp
    - CMicrosoftTape.cpp
    - CMixer.cpp
    - CMixerCapabilities.cpp
    - CMixerControl.cpp
    - CMixerControlDetails.cpp
    - CMixerControlDetailsData.cpp
    - CMixerControlInstance.cpp
    - CMixerDestination.cpp
    - CMixerLine.cpp
    - CMixerSource.cpp
    - CMixerSourceSelector.cpp
    - CMixerSpeakers.cpp
    - CMixerSwitchControl.cpp
    - CMixerVolumeControl.cpp
    - CMixerWaveIn.cpp
    - CNetConn.cpp
    - CNetFile.cpp
    - CNetInfo.cpp
    - CNetMesg.cpp
    - CNetRsrc.cpp
    - CNetScheduleJob.cpp
    - CNetSess.cpp
    - CNetShar.cpp
    - CNetWkst.cpp
    - CNetwork.cpp
    - CNetworkConnectionInformation.cpp
    - CNetworkFileInformation.cpp
    - CNetworkResourceInformation.cpp
    - CNetworkSessionInformation.cpp
    - CNetworkUser.cpp
    - CNetworkUserInformation.cpp
    - CParsePoint.cpp
    - CPasswordChangeFilter.cpp
    - CPhysicalDiskFile.cpp
    - CPing.cpp
    - CPingRes.cpp
    - CQueue.cpp
    - CRandomNumberGenerator.cpp
    - CRandomNumberGenerator2.cpp
    - CRAS.CPP
    - CRASADM.CPP
    - CReedSolomonErrorCorrectionCode.cpp
    - CRIFFChunk.cpp
    - CSecureChannel.cpp
    - CServer.cpp
    - CService.cpp
    - CServiceApplication.cpp
    - CSharedMemoryObject.cpp
    - CSMTF.cpp
    - CSquigl.cpp
    - CSuperRandomNumberGenerator.cpp
    - CSvcMgr.cpp
    - CSystemTime.cpp
    - CTape.cpp
    - CTapeGetMediaParameters.cpp
    - CTimeEx.cpp
    - CUNC.CPP
    - CURL.CPP
    - CUUCoding.cpp
    - CVolume.cpp
    - CWait.cpp
    - CWeather.cpp
    - CXMLArchive.cpp
    - DCB.CPP
    - doc.cmd
    - DrawGrid.cpp
    - DrawObj.cpp
    - DumyFile.cpp
    - IPCP.cpp
    - IPXCP.cpp
    - LMErr.cpp
    - LSOCKETS.CPP
    - LZFile.cpp
    - Modem.CPP
    - NAMDPIPE.CPP
    - NBFCP.cpp
    - original_CFile.cpp
    - OVRLPD.CPP
    - Pager.cpp
    - PortInformation.CPP
    - RASCP.CPP
    - RASNBPCP.CPP
    - RASPORT.CPP
    - RASPPPCR.cpp
    - RASPSTAT.CPP
    - REGISTRY.CPP
    - RemoteAccessServicePort.CPP
    - RemoteAccessServiceUser.cpp
    - Serial.CPP
    - ServiceConfiguration.cpp
    - SkyWord.cpp
    - SOCKETS.CPP
    - SockFile.cpp
    - SprintSpectrum.cpp
    - STL_CByteArray.cpp
    - STL_CDWordArray.cpp
    - STL_CPtrArray.cpp
    - STL_CString.cpp
    - STL_CStringArray.cpp
    - STL_CUIntArray.cpp
    - STL_CWordArray.cpp
    - Structs.cpp
    - TALKSOCK.CPP
    - U2A_A2U.cpp
    - wfc_am_i_administrator.cpp
    - wfc_append_string_to_CByteArray.cpp
    - wfc_append_text_to_edit_control.cpp
    - wfc_close_handle.cpp
    - wfc_convert_double_null_terminated_string.cpp
    - wfc_convert_double_null_terminated_UNICODE_string.cpp
    - wfc_convert_lpwstr_to_cstring.cpp
    - wfc_create_hard_link.cpp
    - wfc_delete_oldest_file.cpp
    - wfc_enable_all_privileges.cpp
    - wfc_enable_privilege.cpp
    - wfc_get_day_of_week.cpp
    - wfc_get_directory_usage_percentage.cpp
    - wfc_get_error_string.cpp
    - wfc_get_executable_directory.cpp
    - wfc_get_filename_from_handle.cpp
    - wfc_get_list_of_programs_that_run_when_a_user_logs_on.cpp
    - wfc_get_operating_system_version_string.cpp
    - wfc_get_web_page.cpp
    - wfc_move_file_at_reboot.cpp
    - wfc_parse_iso_8601_string.cpp
    - wfc_set_thread_name.cpp
    - wfc_start_screen_saver.cpp
    - wfc_undocumented_get_system_process_list.cpp
    - wfc_UNICODE_floating_point_routines.cpp
    - WfcTrace.cpp
    - xml_character_test_routines.cpp
  - WFC World.txt
  - wfcfaq.htm
sample.zip
- sample
  - Sample
    - ADO2XML
      - ADO2XML.dsp
      - ADO2XML.dsw
      - ado2xml.h
      - ado2xml.xml
      - CDatabaseParameters.cpp
      - CDatabaseParameters.hpp
      - convert_DataTypeEnum_to_string.cpp
      - convert_desired_tables.cpp
      - convert_table.cpp
      - get_blob.cpp
      - get_table_names.cpp
      - main.cpp
      - normalize_string.cpp
      - open_connection_to_database.cpp
      - output_field.cpp
      - output_schema.cpp
      - output_types.cpp
      - print_COM_error.cpp
      - print_provider_error.cpp
      - replace.cpp
    - ChangeServiceConfiguration
      - ChangeServiceConfiguration.cpp
      - ChangeServiceConfiguration.dsp
      - ChangeServiceConfiguration.dsw
      - ChangeServiceConfiguration.mak
    - ClockSync
      - ClockSync.cpp
      - ClockSync.dsp
      - ClockSync.dsw
      - ClockSync.mak
    - Counter
      - Counter.cpp
      - counter.h
      - counter.mak
      - CPCD.cpp
      - CPCD.hpp
      - CPerfDef.cpp
      - CPerfDef.hpp
      - CPerformanceCounterData.hpp
      - CPerformanceCounterDefinition.cpp
      - CPerformanceCounterDefinition.hpp
      - CPerformanceData.cpp
      - CPerformanceData.hpp
      - CPerformanceInstance.cpp
      - CPerformanceInstance.hpp
      - CPerformanceObject.cpp
      - CPerformanceObject.hpp
      - test.cpp
    - Crypto
      - Crypto.cpp
      - Crypto.dsp
      - Crypto.dsw
      - Crypto.mak
    - CScript
      - CScript.dsp
      - CScript.dsw
      - main.cpp
    - Data
      - CSimpleClass.hpp
      - Receiver
        
        Receiver.cpp
        
        Receiver.dsp
        
        Receiver.dsw
      - Sender
        
        Sender.cpp
        
        Sender.dsp
        
        Sender.dsw
    - DeMangle
      - DeMangle.dsp
      - DeMangle.dsw
      - main.cpp
    - DriverMover
      - DriverMover.cpp
      - DriverMover.dsp
      - DriverMover.dsw
      - DriverMover.h
      - DriverMover.rc
      - DriverMoverDialog.cpp
      - DriverMoverDialog.h
      - ReadMe.txt
      - res
        
        DriverMover.ico
        
        DriverMover.rc2
      - resource.h
      - StdAfx.cpp
      - StdAfx.h
    - dump_ntfs_streams.cpp
    - DumpEventLog
      - DumpEventLog.cpp
      - DumpEventLog.mak
    - EnableRASLogging
      - EnableRASLogging.cpp
      - EnableRASLogging.mak
    - EventPager
      - EventPager.cpp
      - EventPager.dsp
      - EventPager.dsw
      - EventPager.mak
      - MAKEMC.CMD
      - messages.h
      - messages.mc
      - messages.rc
    - GetWebPage
      - CNNWeather.cpp
      - CStockQuote.hpp
      - GetStockQuote.cpp
      - GetWebPage.cpp
      - GetWebPage.dsp
      - GetWebPage.dsw
      - GetWebPage.mak
      - wc.html
      - WeatherChannelWeather.cpp
    - HTML
      - html.cpp
      - html.dsp
      - html.dsw
      - html.mak
    - KillDoc
      - KillDoc.dsp
      - KillDoc.dsw
      - main.cpp
    - LastEvent
      - LastEvent.cpp
      - LastEvent.dsp
      - LastEvent.dsw
      - LastEvent.mak
    - Listen
      - Listen.cpp
      - Listen.dsp
      - Listen.dsw
      - Listen.mak
      - sl.cpp
    - ListProcesses
      - list_processes.cpp
      - ListProcesses.dsp
      - ListProcesses.dsw
      - ListProcesses.h
      - main.cpp
      - print_process_list.cpp
    - MAKEMC.CMD
    - Map2Def
      - Map2Def.cpp
      - Map2Def.dsp
      - Map2Def.dsw
      - Map2Def.mak
    - Microphone
      - main.cpp
      - Microphone.dsp
      - Microphone.dsw
    - MIME2HTML
      - Debug
        
        mime.html
      - dump_mime_mappings.cpp
      - dump_mime_type.cpp
      - get_command_line.cpp
      - main.cpp
      - MIME2HTML.dsp
      - MIME2HTML.dsw
      - MIME2HTML.h
      - normalize_string.cpp
      - replace.cpp
    - PasswordFilter
      - DLL
        
        InitializeChangeNotify.cpp
        
        PasswordChangeNotify.cpp
        
        PasswordDLL.cpp
        
        PasswordDLL.dsp
        
        PasswordDLL.dsw
        
        PasswordDLL.h
      - PasswordFilter.cpp
      - PasswordFilter.dsp
      - PasswordFilter.dsw
    - Ping
      - Ping.cpp
      - Ping.dsp
      - Ping.dsw
      - Ping.mak
    - Pinger
      - MAKEMC.CMD
      - messages.h
      - MESSAGES.MC
      - messages.rc
      - Pinger.cpp
      - Pinger.dsp
      - Pinger.dsw
      - Pinger.mak
      - PINGER.RC
      - Pinger.ver
      - resource.h
    - RasAdmin
      - RasAdmin.cpp
      - RasAdmin.dsp
      - RasAdmin.dsw
      - RasAdmin.mak
    - Serial
      - Serial.cpp
      - Serial.dsp
      - Serial.dsw
      - Serial.h
      - Serial.mak
    - SerialTest
      - Normal
        
        Receiver
        
        compute_checksum.cpp
        
        main.cpp
        
        Receiver.dsp
        
        Receiver.dsw
        
        receiver.h
        
        Sender
        
        main.cpp
        
        prepare_buffer.cpp
        
        Sender.dsp
        
        Sender.dsw
        
        sender.h
    - Service
      - Service.cpp
      - Service.dsp
      - Service.dsw
      - Service.mak
    - SkyPage
      - SKYPAGE.CPP
      - SkyPage.dsp
      - SkyPage.dsw
      - SkyPage.mak
    - SprintSpectrum
      - SprintSpectrum.cpp
      - SprintSpectrum.dsp
      - SprintSpectrum.dsw
      - SprintSpectrum.mak
    - Squiggle
      - Squiggle.cpp
      - Squiggle.mak
    - TortureXML
      - create_huge_character_reference.cpp
      - create_huge_element.cpp
      - create_huge_element_and_attribute.cpp
      - create_huge_element_name.cpp
      - create_huge_encoding.cpp
      - create_huge_version.cpp
      - main.cpp
      - TortureXML.dsp
      - TortureXML.dsw
      - TortureXML.h
    - USNOTime
      - main.cpp
      - USNOTime.dsp
      - USNOTime.dsw
    - WatchDog
      - MAKEMC.CMD
      - messages.h
      - messages.mc
      - messages.rc
      - WatchDog.cpp
      - WatchDog.dsp
      - WatchDog.dsw
      - WatchDog.mak
      - WatchDog.rc
      - WatchDog.ver
    - Wfc2Html
      - CCPPToHTMLTranslator.cpp
      - CCPPToHTMLTranslator.hpp
      - load_translator.cpp
      - main.cpp
      - translate_file.cpp
      - Wfc2Html.dsp
      - Wfc2Html.dsw
      - wfc2html.h
    - WinPage
      - res
        
        WinPage.ico
        
        WinPage.rc2
      - resource.h
      - WinPage.cpp
      - WinPage.dsp
      - WinPage.dsw
      - WinPage.h
      - WinPage.mak
      - WinPage.rc
      - WinPageDlg.cpp
      - WinPageDlg.h
    - XML
      - Debug
        
        test2.xml
      - dump_element.cpp
      - dump_tags.cpp
      - get_bytes.cpp
      - main.cpp
      - my_xml.h
      - parse_document.cpp
      - poem.xml
      - test.xml
      - TestSuite.xml
      - XML.DSP
      - XML.dsw
    - XMLCheck
      - check_xml_file.cpp
      - Debug
        
        check.txt
        
        test.xml
        
        TestSuite.xml
        
        TestSuite2.xml
        
        txtfirst.xml
        
        txtlast.xml
      - main.cpp
      - XML
        
        a2.xml
      - XMLCheck.dsp
      - XMLCheck.dsw
      - XMLCheck.h
      - XMLCheck.mak
    - XMLExplorer
      - CMainFrame.cpp
      - CMainFrame.h
      - CXMLExplorerDocument.cpp
      - CXMLExplorerDocument.h
      - CXMLExplorerView.cpp
      - CXMLExplorerView.h
      - MyListView.cpp
      - MyListView.h
      - MyTreeView.cpp
      - MyTreeView.h
      - ReadMe.txt
      - res
        
        bitmap1.bmp
        
        CXMLExplorerDocument.ico
        
        Toolbar.bmp
        
        XMLExplorer.ico
        
        XMLExplorer.rc2
      - resource.h
      - StdAfx.cpp
      - StdAfx.h
      - test.xml
      - XMLExplorer.cpp
      - XMLExplorer.dsp
      - XMLExplorer.dsw
      - XMLExplorer.h
      - XMLExplorer.rc
    - XMLUser
      - add_current_time.cpp
      - add_level.cpp
      - add_machine_name.cpp
      - add_to_xml.cpp
      - enumerate_users.cpp
      - main.cpp
      - parse_document.cpp
      - save_document.cpp
      - users.xml
      - XMLUser.dsp
      - XMLUser.dsw
      - XMLUser.h
  - TEST
    - CQueue_stress_test.cpp
    - dumpexports.cpp
    - Grid
      - Grid.cpp
      - Grid.mak
    - MESSAGES.MC
    - Output.txt
    - Pipe
      - pipe.CPP
      - Pipe.h
      - Pipe.mak
      - Server.CPP
    - REPERR.CPP
    - TCLZFile.CPP
    - TCNet.CPP
    - TCNetCon.CPP
    - TCNetFil.CPP
    - TCNetshs.CPP
    - TCNetUSR.CPP
    - TCNSrc.cpp
    - TCRAS.CPP
    - TCRASPORT.CPP
    - TCREG.CPP
    - TCSess.CPP
    - TCSrvr.CPP
    - TCSvcMgr.CPP
    - TCTape.cpp
    - TEST.CPP
    - TEST.dsp
    - TEST.dsw
    - TEST.H
    - TEST.MAK
    - test_CBase64Coding.cpp
    - test_CBitArray.cpp
    - test_CByteArray.cpp
    - test_CDataParser.cpp
    - test_CDWordArray.cpp
    - test_CFileTransferProtocol.cpp
    - test_CJulianDate.cpp
    - test_CNetwork.CPP
    - test_CPtrArray.cpp
    - test_CQueue.cpp
    - test_CRandomNumberGenerator.cpp
    - test_CReedSolomonErrorCorrectionCode.cpp
    - test_CSerialFile.cpp
    - test_CString.cpp
    - test_CSystemTime.cpp
    - test_CUIntArray.cpp
    - test_CUUCoding.cpp
    - test_CWordArray.cpp
    - test_CXMLDocument.cpp
    - test_XML.cpp
    - TEVNTLOG.CPP
    - TURL.CPP
    - XMLConformanceTest
      - main.cpp
      - XMLConformanceTest.dsp
      - XMLConformanceTest.dsw
      - XMLConformanceTest.h
html.zip
- HTML
  - html.cpp
  - html.dsp
  - html.dsw
  - html.mak

#include <wfc.h>
#pragma hdrstop

/*
** Author: Samuel R. Blackburn
** Internet: wfc@pobox.com
**
** You can use it any way you like as long as you don't try to sell it.
**
** Any attempt to sell WFC in source code form must have the permission
** of the original author. You can produce commercial executables with
** WFC but you can't sell WFC.
**
** Copyright, 2000, Samuel R. Blackburn
**
** $Workfile: namdpipe.cpp $
** $Revision: 23 $
** $Modtime: 3/17/00 4:39p $
** $Reuse Tracing Code: 1 $
*/

#if defined( _DEBUG ) && ! defined( WFC_STL )
#undef THIS_FILE
static char THIS_FILE[] = __FILE__;
#define new DEBUG_NEW
#endif // _DEBUG

CNamedPipe::CNamedPipe( DWORD _input_buffer_size, DWORD _output_buffer_size )
{
   WFCLTRACEINIT( TEXT( "CNamedPipe::CNamedPipe()" ) );
   WFCTRACEVAL( TEXT( "pointer is " ), (VOID *) this );
   m_Initialize( _input_buffer_size, _output_buffer_size );
}

CNamedPipe::~CNamedPipe()
{
   WFCLTRACEINIT( TEXT( "CNamedPipe::~CNamedPipe()" ) );
   WFCTRACEVAL( TEXT( "pointer is " ), (VOID *) this );

   if ( m_AutomaticallyDelete != FALSE )
   {
      WFCTRACE( TEXT( "Automatically Deleting" ) );

      if ( m_PipeHandle != (HANDLE) NULL )
      {
         Close();
      }
   }

   if ( m_InputBuffer != (LPVOID) NULL )
   {
      WFCTRACE( TEXT( "Freeing input buffer" ) );

      /*
      ** Free our memory
      */

      delete [] m_InputBuffer;

      m_InputBuffer     = (LPVOID) NULL;
      m_InputBufferSize = 0L;
   }

   if ( m_OutputBuffer != (LPVOID) NULL )
   {
      WFCTRACE( TEXT( "Freeing output buffer" ) );

      /*
      ** Free our memory
      */

      delete [] m_OutputBuffer;

      m_OutputBuffer     = (LPVOID) NULL;
      m_OutputBufferSize = 0L;
   }
}

void CNamedPipe::m_Initialize( DWORD _input_buffer_size, DWORD _output_buffer_size )
{
   m_AutomaticallyDelete = TRUE;
   m_ErrorCode           = 0L;
   m_PipeHandle          = (HANDLE) INVALID_HANDLE_VALUE;
   m_Timeout             = NMPWAIT_USE_DEFAULT_WAIT;
   m_PipeName.Empty();

   m_InputBufferSize  = _input_buffer_size;
   m_OutputBufferSize = _output_buffer_size;

   try
   {
      m_InputBuffer = new BYTE[ m_InputBufferSize ];
   }
   catch( ... )
   {
      m_InputBuffer = NULL;
   }

   try
   {
      m_OutputBuffer = new BYTE[ m_OutputBufferSize ];
   }
   catch( ... )
   {
      m_OutputBuffer = NULL;
   }
}

#if defined( _DEBUG ) && ! defined( WFC_NO_DUMPING )

void CNamedPipe::Dump( CDumpContext& dump_context ) const
{
   dump_context << TEXT( "m_AutomaticallyDelete = "      ) << m_AutomaticallyDelete      << TEXT( "\n" );
   dump_context << TEXT( "m_PipeHandle = "               ) << m_PipeHandle               << TEXT( "\n" );
   dump_context << TEXT( "m_MaximumNumberOfInstances = " ) << m_MaximumNumberOfInstances << TEXT( "\n" );
   dump_context << TEXT( "m_InputBufferSize = "          ) << m_InputBufferSize          << TEXT( "\n" );
   dump_context << TEXT( "m_OutputBufferSize = "         ) << m_OutputBufferSize         << TEXT( "\n" );
   dump_context << TEXT( "m_NumberOfBytesToWrite = "     ) << m_NumberOfBytesToWrite     << TEXT( "\n" );
   dump_context << TEXT( "m_NumberOfBytesRead = "        ) << m_NumberOfBytesRead        << TEXT( "\n" );
   dump_context << TEXT( "m_Timeout = "                  ) << m_Timeout                  << TEXT( "\n" );
   dump_context << TEXT( "m_PipeName = \""               ) << m_PipeName                 << TEXT( "\"\n" );
   dump_context << TEXT( "m_FullPipeName is " );
   m_FullPipeName.Dump( dump_context );
   dump_context << TEXT( "m_PipeState = "                ) << m_PipeState                << TEXT( "\n" );
   dump_context << TEXT( "m_NumberOfInstances = "        ) << m_NumberOfInstances        << TEXT( "\n" );
   dump_context << TEXT( "m_MaximumNumberOfBytesBeforeRemoteTransmission = "           ) << m_MaximumNumberOfBytesBeforeRemoteTransmission << TEXT( "\n" );
   dump_context << TEXT( "m_MaximumNumberOfMillisecondsBeforeRemoteTransmission = "    ) << m_MaximumNumberOfMillisecondsBeforeRemoteTransmission << TEXT( "\n" );
   dump_context << TEXT( "m_UserNameOfClientProcess = \"" ) << m_UserNameOfClientProcess << TEXT( "\"\n" );
}

#endif // _DEBUG

BOOL CNamedPipe::Call( CString& pipe_name, 
                       LPVOID   write_buffer, 
                       DWORD    size_of_write_buffer, 
                       LPVOID   read_buffer, 
                       DWORD    size_of_read_buffer, 
                       DWORD   *address_of_number_of_bytes_read,
                       DWORD    number_of_milliseconds_to_wait )
{
   WFCLTRACEINIT( TEXT( "CNamedPipe::Call()" ) );

   ASSERT( write_buffer != NULL );
   ASSERT( read_buffer  != NULL );

   if ( write_buffer == NULL || read_buffer == NULL )
   {
      m_ErrorCode = ERROR_INVALID_PARAMETER;
      return( FALSE );
   }

   /*
   ** Writes to the pipe then reads from it
   */

   BOOL return_value = FALSE;

   return_value = ::CallNamedPipe( pipe_name, 
                                   write_buffer,
                                   size_of_write_buffer,
                                   read_buffer,
                                   size_of_read_buffer,
                                   address_of_number_of_bytes_read,
                                   number_of_milliseconds_to_wait );

   if ( return_value == FALSE )
   {
      m_ErrorCode = ::GetLastError();

      WFCTRACE( TEXT( "FAILED!" ) );
      WFCTRACEERROR( m_ErrorCode );

      return( FALSE );
   }
   else
   {
      return( TRUE );
   }
}

void CNamedPipe::Close( void )
{
   WFCLTRACEINIT( TEXT( "CNamedPipe::Close()" ) );

   if ( m_PipeHandle != (HANDLE) INVALID_HANDLE_VALUE )
   {
      ::wfc_close_handle( m_PipeHandle );
      m_PipeHandle = (HANDLE) INVALID_HANDLE_VALUE;
   }
}

BOOL CNamedPipe::Connect( LPOVERLAPPED overlapped_p )
{
   WFCLTRACEINIT( TEXT( "CNamedPipe::Connect()" ) );

   // overlapped_p can be NULL

   BOOL return_value = FALSE;

   return_value = ::ConnectNamedPipe( m_PipeHandle, overlapped_p );

   if ( return_value == FALSE )
   {
      m_ErrorCode = ::GetLastError();

      WFCTRACE( TEXT( "FAILED!" ) );
      WFCTRACEERROR( m_ErrorCode );

      return( FALSE );
   }
   else
   {
      return( TRUE );
   }
}

BOOL CNamedPipe::Create( LPCTSTR server_name,
                         LPCTSTR pipe_name,
                         DWORD   open_mode,
                         DWORD   type_of_pipe,
                         DWORD   number_of_pipes,
           LPSECURITY_ATTRIBUTES security_attributes_p )
{
   WFCLTRACEINIT( TEXT( "CNamedPipe::Create()" ) );

   ASSERT( pipe_name != NULL );

   /*
   ** Check parameters for errors
   */

   if ( pipe_name == NULL )
   {
      m_ErrorCode = ERROR_INVALID_PARAMETER;
      return( FALSE );
   }

   m_PipeName = TEXT( "\\\\" );

   if ( server_name == NULL )
   {
      m_PipeName += TEXT( "." );
   }
   else
   {
      m_PipeName += server_name;
   }

   m_PipeName += TEXT( "\\PIPE\\" );
   m_PipeName += pipe_name;

   WFCTRACEVAL( TEXT( "pipe_name is " ), CString( pipe_name ) );

   CSecurityAttributes security_attributes;
   SECURITY_DESCRIPTOR security_descriptor;

   if ( security_attributes_p == NULL )
   {
      WFCTRACE( TEXT( "Creating security attributes" ) );

      ::InitializeSecurityDescriptor( &security_descriptor, SECURITY_DESCRIPTOR_REVISION );

      ::SetSecurityDescriptorDacl( &security_descriptor, TRUE, NULL, FALSE );
      security_attributes.bInheritHandle = FALSE;
      security_attributes.lpSecurityDescriptor = &security_descriptor;

      security_attributes_p = (SECURITY_ATTRIBUTES *) &security_attributes;
   }

   m_PipeHandle = ::CreateNamedPipe( m_PipeName,
                                     open_mode,
                                     type_of_pipe, 
                                     number_of_pipes,
                                     m_OutputBufferSize,
                                     m_InputBufferSize,
                                     m_Timeout,
                                     security_attributes_p );

   if ( m_PipeHandle == (HANDLE) INVALID_HANDLE_VALUE )
   {
      m_ErrorCode = ::GetLastError();

      WFCTRACE( TEXT( "FAILED!" ) );
      WFCTRACEERROR( m_ErrorCode );

      return( FALSE );
   }
   else
   {
      return( TRUE );
   }
}

BOOL CNamedPipe::Disconnect( void )
{
   WFCLTRACEINIT( TEXT( "CNamedPipe::Disconnect()" ) );

   BOOL return_value = FALSE;

   return_value = ::DisconnectNamedPipe( m_PipeHandle );

   if ( return_value == FALSE )
   {
      m_ErrorCode = ::GetLastError();

      WFCTRACE( TEXT( "FAILED!" ) );
      WFCTRACEERROR( m_ErrorCode );

      return( FALSE );
   }
   else
   {
      return( TRUE );
   }
}

BOOL CNamedPipe::GetInformation( void )
{
   WFCLTRACEINIT( TEXT( "CNamedPipe::GetInformation()" ) );

   BOOL return_value = FALSE;

   DWORD type_of_pipe                = 0;
   DWORD size_of_output_buffer       = 0;
   DWORD size_of_input_buffer        = 0;
   DWORD maximum_number_of_instances = 0;

   return_value = ::GetNamedPipeInfo( m_PipeHandle,
                                     &type_of_pipe,
                                     &size_of_output_buffer,
                                     &size_of_input_buffer,
                                     &maximum_number_of_instances );

   if ( return_value == FALSE )
   {
      m_ErrorCode = ::GetLastError();

      WFCTRACE( TEXT( "FAILED!" ) );
      WFCTRACEERROR( m_ErrorCode );

      return( FALSE );
   }
   else
   {
      return( TRUE );
   }
}

BOOL CNamedPipe::GetState( void )
{
   WFCLTRACEINIT( TEXT( "CNamedPipe::GetState()" ) );

   BOOL return_value = FALSE;

   TCHAR temp_string[ 513 ];

   ::ZeroMemory( temp_string, sizeof( temp_string ) );

   return_value = ::GetNamedPipeHandleState( m_PipeHandle,
                                            &m_PipeState,
                                            &m_NumberOfInstances,
                                            &m_MaximumNumberOfBytesBeforeRemoteTransmission,
                                            &m_MaximumNumberOfMillisecondsBeforeRemoteTransmission,
                                             temp_string,
                                             DIMENSION_OF( temp_string ) );

   m_UserNameOfClientProcess = temp_string;

   if ( return_value == FALSE )
   {
      m_ErrorCode = ::GetLastError();

      WFCTRACE( TEXT( "FAILED!" ) );
      WFCTRACEERROR( m_ErrorCode );

      return( FALSE );
   }
   else
   {
      return( TRUE );
   }
}

#if ! defined( WFC_STL )
BOOL CNamedPipe::Open( LPCTSTR pipe_name, UINT, CFileException * )
#else // WFC_STL
BOOL CNamedPipe::Open( LPCTSTR pipe_name, UINT )
#endif // WFC_STL
{
   WFCLTRACEINIT( TEXT( "CNamedPipe::Open()" ) );

   ASSERT( pipe_name != NULL );

   if ( pipe_name == (LPCTSTR) NULL )
   {
      m_ErrorCode = ERROR_INVALID_PARAMETER;

      return( FALSE );
   }

   /*
   ** pipe_name can be:
   ** "pipe_name" where the pipe will be openend on the local machine
   ** "\\server_name\pipe_name" where the pipe will be opened on the server
   ** "\\server_name\PIPE\pipe_name" which is a fully qualified pipe name
   */

   CUniversalNamingConvention unc( pipe_name );

   WFCTRACEVAL( TEXT( "unc is " ), CString( unc ) );

   if ( unc.ServerName.IsEmpty() != FALSE )
   {
      unc.ServerName = TEXT( "." );
   }

   if ( unc.ShareName.CompareNoCase( TEXT( "PIPE" ) ) != 0 )
   {
      CString temp_string = unc.ShareName;

      unc.ShareName = TEXT( "PIPE" );

      if ( temp_string.GetLength() > 0 )
      {
         unc.PathName = temp_string + TEXT( "\\" ) + unc.PathName;
      }
   }

   unc.Make();

   m_FullPipeName = unc;

   WFCTRACEVAL( TEXT( "Full Pipe Name is " ), CString( unc ) );

   return( Create( unc.ServerName, unc.PathName ) );
}

BOOL CNamedPipe::Peek( LPVOID buffer_address, 
                       DWORD  size_of_buffer,
                       DWORD& number_of_bytes_read,
                       DWORD& number_of_bytes_available,
                       DWORD& number_of_bytes_remaining_in_message )
{
   WFCLTRACEINIT( TEXT( "CNamedPipe::Peek()" ) );

   /*
   ** buffer_address can be NULL
   */

   BOOL return_value = FALSE;

   return_value = ::PeekNamedPipe( m_PipeHandle, 
                                   buffer_address, 
                                   size_of_buffer, 
                                  &number_of_bytes_read,
                                  &number_of_bytes_available,
                                  &number_of_bytes_remaining_in_message );

   if ( return_value == FALSE )
   {
      m_ErrorCode = ::GetLastError();

      WFCTRACE( TEXT( "FAILED!" ) );
      WFCTRACEERROR( m_ErrorCode );

      return( FALSE );
   }
   else
   {
      return( TRUE );
   }
}

BOOL CNamedPipe::SetState( DWORD new_pipe_mode, 
                           DWORD maximum_number_of_bytes_before_transmission, 
                           DWORD maximum_number_of_milliseconds_before_transmission )
{
   WFCLTRACEINIT( TEXT( "CNamedPipe::SetState()" ) );

   BOOL return_value = FALSE;

   return_value = ::SetNamedPipeHandleState( m_PipeHandle,
                                            &new_pipe_mode,
                                            &maximum_number_of_bytes_before_transmission,
                                            &maximum_number_of_milliseconds_before_transmission );

   if ( return_value == FALSE )
   {
      m_ErrorCode = ::GetLastError();

      WFCTRACE( TEXT( "FAILED!" ) );
      WFCTRACEERROR( m_ErrorCode );

      return( FALSE );
   }
   else
   {
      return( TRUE );
   }
}

BOOL CNamedPipe::Transact( LPOVERLAPPED overlapped_p )
{
   WFCLTRACEINIT( TEXT( "CNamedPipe::Transact()" ) );

   // overlapped_p can be NULL

   BOOL return_value = FALSE;

   return_value = ::TransactNamedPipe( m_PipeHandle,
                                       m_OutputBuffer,
                                       m_NumberOfBytesToWrite,
                                       m_InputBuffer,
                                       m_InputBufferSize,
                                      &m_NumberOfBytesRead,
                                       overlapped_p );

   if ( return_value == FALSE )
   {
      m_ErrorCode = ::GetLastError();

      WFCTRACE( TEXT( "FAILED!" ) );
      WFCTRACEERROR( m_ErrorCode );

      return( FALSE );
   }
   else
   {
      return( TRUE );
   }
}

BOOL CNamedPipe::Wait( LPCTSTR name_of_server, LPCTSTR name_of_pipe, DWORD number_of_milliseconds )
{
   WFCLTRACEINIT( TEXT( "CNamedPipe::Wait()" ) );

   ASSERT( name_of_pipe != NULL );

   /*
   ** Check parameters for errors
   */

   if ( name_of_pipe == NULL )
   {
      m_ErrorCode = ERROR_INVALID_PARAMETER;
      return( FALSE );
   }

   BOOL return_value = FALSE;

   CString full_pipe_name( TEXT( "\\\\" ) ); // like \\servername\pipe\pipename

   if ( name_of_server == NULL )
   {
      full_pipe_name += TEXT( "." );
   }
   else
   {
      full_pipe_name += name_of_server;
   }

   full_pipe_name += TEXT( "\\pipe\\" );
   full_pipe_name += name_of_pipe;

   return_value = ::WaitNamedPipe( full_pipe_name, number_of_milliseconds );

   if ( return_value == FALSE )
   {
      m_ErrorCode = ::GetLastError();

      WFCTRACE( TEXT( "FAILED!" ) );
      WFCTRACEERROR( m_ErrorCode );

      return( FALSE );
   }
   else
   {
      return( TRUE );
   }
}

// End of source

By viewing downloads associated with this article you agree to the Terms of Service and the article's licence.

If a file you wish to view isn't highlighted, and is a text file (not binary), please let us know and we'll add colourisation support for it.

License

This article has no explicit license attached to it but may contain usage terms in the article text or the download files themselves. If in doubt please contact the author via the discussion board below.

A list of licenses authors might use can be found here

Written By

Sam Blackburn

United States

I'm just a simple little NT programmer. Most of the work I do is remote controlling equipment in real time. I started out using Windows 3.0. Then came 3.1 and then NT. I started using NT but unfortunately, Microsoft didn't. I started using MFC but unfortunately, Microsoft didn't (and still doesn't) put any real support for NT into MFC so I wrote a bunch of C++ classes to make my life easier. Like all class libraries, mine grew. Now I'm giving it away, I call it Win32 Foundation Classes.

Check out Sam's homepage at www.SamBlackburn.com/wfc/.

The Win32 Foundation Classes (WFC) - Version 45

License

Comments and Discussions