[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index] [win-pv-devel] [PATCH 3/6] Add XenIfaceDevice
XenIfaceDevice is a CDevice subclass that abstracts the IOCTL interface by managing the conversion to/from IOCTL inputs/outputs. Signed-off-by: Owen Smith <owen.smith@xxxxxxxxxx> --- src/xenagent/service.cpp | 2 +- src/xenagent/service.h | 1 + src/xenagent/xenifacedevice.cpp | 153 +++++++++++++++++++++++++++++++++++++++ src/xenagent/xenifacedevice.h | 64 ++++++++++++++++ vs2012/xenagent/xenagent.vcxproj | 2 + vs2013/xenagent/xenagent.vcxproj | 2 + 6 files changed, 223 insertions(+), 1 deletion(-) create mode 100644 src/xenagent/xenifacedevice.cpp create mode 100644 src/xenagent/xenifacedevice.h diff --git a/src/xenagent/service.cpp b/src/xenagent/service.cpp index fec8e95..bd085f6 100644 --- a/src/xenagent/service.cpp +++ b/src/xenagent/service.cpp @@ -171,7 +171,7 @@ CXenAgent::~CXenAgent() /*virtual*/ CDevice* CXenAgent::Create(const wchar_t* path) { - return new CDevice(path); + return new CXenIfaceDevice(path); } /*virtual*/ void CXenAgent::OnDeviceAdded(CDevice* dev) diff --git a/src/xenagent/service.h b/src/xenagent/service.h index ba3f430..e31dcfd 100644 --- a/src/xenagent/service.h +++ b/src/xenagent/service.h @@ -39,6 +39,7 @@ #define SVC_DESC "Monitors and provides various metrics to XenStore" #include "devicelist.h" +#include "xenifacedevice.h" class CXenAgent : public IDeviceCreator { diff --git a/src/xenagent/xenifacedevice.cpp b/src/xenagent/xenifacedevice.cpp new file mode 100644 index 0000000..16189d2 --- /dev/null +++ b/src/xenagent/xenifacedevice.cpp @@ -0,0 +1,153 @@ +/* Copyright (c) Citrix Systems Inc. + * All rights reserved. + * + * Redistribution and use in source and binary forms, + * with or without modification, are permitted provided + * that the following conditions are met: + * + * * Redistributions of source code must retain the above + * copyright notice, this list of conditions and the + * following disclaimer. + * * Redistributions in binary form must reproduce the above + * copyright notice, this list of conditions and the + * following disclaimer in the documentation and/or other + * materials provided with the distribution. + * + * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND + * CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, + * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF + * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE + * DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR + * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, + * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, + * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR + * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS + * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, + * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING + * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE + * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF + * SUCH DAMAGE. + */ + +#include <windows.h> +#include "xenifacedevice.h" +#include "devicelist.h" +#include "xeniface_ioctls.h" + +CXenIfaceDevice::CXenIfaceDevice(const wchar_t* path) : CDevice(path) +{} + +/*virtual*/ CXenIfaceDevice::~CXenIfaceDevice() +{} + +// store interface +bool CXenIfaceDevice::StoreRead(const std::string& path, std::string& value) +{ + DWORD bytes(0); + char* buffer; + bool result; + + Ioctl(IOCTL_XENIFACE_STORE_READ, + (void*)path.c_str(), (DWORD)path.length() + 1, + NULL, 0, + &bytes); + + buffer = new char[bytes + 1]; + if (buffer == NULL) + return false; + + result = Ioctl(IOCTL_XENIFACE_STORE_READ, + (void*)path.c_str(), (DWORD)path.length() + 1, + buffer, bytes); + + buffer[bytes] = 0; + if (result) + value = buffer; + + delete [] buffer; + return result; +} + +bool CXenIfaceDevice::StoreWrite(const std::string& path, const std::string& value) +{ + bool result; + size_t length = path.length() + 1 + value.length() + 1 + 1; + char* buffer = new char[length]; + if (buffer == NULL) + return false; + + memcpy(buffer, path.c_str(), path.length()); + buffer[path.length()] = 0; + + memcpy(buffer + path.length() + 1, value.c_str(), value.length()); + buffer[path.length() + 1 + value.length()] = 0; + buffer[length - 1] = 0; + + result = Ioctl(IOCTL_XENIFACE_STORE_WRITE, buffer, (DWORD)length, NULL, 0); + delete [] buffer; + return result; +} + +bool CXenIfaceDevice::StoreRemove(const std::string& path) +{ + return Ioctl(IOCTL_XENIFACE_STORE_REMOVE, + (void*)path.c_str(), (DWORD)path.length() + 1, + NULL, 0); +} + +bool CXenIfaceDevice::StoreAddWatch(const std::string& path, HANDLE evt, void** ctxt) +{ + XENIFACE_STORE_ADD_WATCH_IN in = { (PCHAR)path.c_str(), (DWORD)path.length() + 1, evt }; + XENIFACE_STORE_ADD_WATCH_OUT out = { NULL }; + if (!Ioctl(IOCTL_XENIFACE_STORE_ADD_WATCH, + &in, (DWORD)sizeof(in), + &out, (DWORD)sizeof(out))) + return false; + *ctxt = out.Context; + return true; +} + +bool CXenIfaceDevice::StoreRemoveWatch(void* ctxt) +{ + XENIFACE_STORE_REMOVE_WATCH_IN in = { ctxt }; + return Ioctl(IOCTL_XENIFACE_STORE_REMOVE_WATCH, + &in, (DWORD)sizeof(in), + NULL, 0); +} + +// suspend interface +bool CXenIfaceDevice::SuspendRegister(HANDLE evt, void** ctxt) +{ + XENIFACE_SUSPEND_REGISTER_IN in = { evt }; + XENIFACE_SUSPEND_REGISTER_OUT out = { NULL }; + if (!Ioctl(IOCTL_XENIFACE_SUSPEND_REGISTER, + &in, (DWORD)sizeof(in), + &out, (DWORD)sizeof(out))) + return false; + *ctxt = out.Context; + return true; +} + +bool CXenIfaceDevice::SuspendDeregister(void* ctxt) +{ + XENIFACE_SUSPEND_REGISTER_OUT in = { ctxt }; + return Ioctl(IOCTL_XENIFACE_SUSPEND_DEREGISTER, + &in, (DWORD)sizeof(in), + NULL, 0); +} + +// sharedinfo interface +bool CXenIfaceDevice::SharedInfoGetTime(FILETIME* time) +{ + return Ioctl(IOCTL_XENIFACE_SHAREDINFO_GET_TIME, + NULL, 0, + time, sizeof(FILETIME)); +} + +// logging +bool CXenIfaceDevice::Log(const std::string& msg) +{ + return Ioctl(IOCTL_XENIFACE_LOG, + (void*)msg.c_str(), (DWORD)msg.length() + 1, + NULL, 0); +} diff --git a/src/xenagent/xenifacedevice.h b/src/xenagent/xenifacedevice.h new file mode 100644 index 0000000..ee0104c --- /dev/null +++ b/src/xenagent/xenifacedevice.h @@ -0,0 +1,64 @@ +/* Copyright (c) Citrix Systems Inc. + * All rights reserved. + * + * Redistribution and use in source and binary forms, + * with or without modification, are permitted provided + * that the following conditions are met: + * + * * Redistributions of source code must retain the above + * copyright notice, this list of conditions and the + * following disclaimer. + * * Redistributions in binary form must reproduce the above + * copyright notice, this list of conditions and the + * following disclaimer in the documentation and/or other + * materials provided with the distribution. + * + * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND + * CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, + * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF + * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE + * DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR + * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, + * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, + * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR + * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS + * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, + * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING + * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE + * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF + * SUCH DAMAGE. + */ + +#ifndef __XENAGENT_XENIFACEDEVICE_H__ +#define __XENAGENT_XENIFACEDEVICE_H__ + +#include <windows.h> +#include <string> +#include "devicelist.h" + +class CXenIfaceDevice : public CDevice +{ +public: + CXenIfaceDevice(const wchar_t* path); + virtual ~CXenIfaceDevice(); + +public: // store interface + bool StoreRead(const std::string& path, std::string& value); + bool StoreWrite(const std::string& path, const std::string& value); + bool StoreRemove(const std::string& path); + bool StoreAddWatch(const std::string& path, HANDLE evt, void** ctxt); + bool StoreRemoveWatch(void* ctxt); + +public: // suspend interface + bool SuspendRegister(HANDLE evt, void** ctxt); + bool SuspendDeregister(void* ctxt); + +public: // sharedinfo interface + bool SharedInfoGetTime(FILETIME* time); + +public: // logging + bool Log(const std::string& msg); +}; + +#endif + diff --git a/vs2012/xenagent/xenagent.vcxproj b/vs2012/xenagent/xenagent.vcxproj index 6c9c91c..37db3fd 100644 --- a/vs2012/xenagent/xenagent.vcxproj +++ b/vs2012/xenagent/xenagent.vcxproj @@ -195,10 +195,12 @@ <ItemGroup> <ClCompile Include="..\..\src\xenagent\service.cpp"/> <ClCompile Include="..\..\src\xenagent\devicelist.cpp"/> + <ClCompile Include="..\..\src\xenagent\xenifacedevice.cpp"/> </ItemGroup> <ItemGroup> <ClInclude Include="..\..\src\xenagent\service.h" /> <ClInclude Include="..\..\src\xenagent\devicelist.h" /> + <ClInclude Include="..\..\src\xenagent\xenifacedevice.h" /> </ItemGroup> <ItemGroup> <CustomBuild Include="..\..\src\xenagent\messages.mc"> diff --git a/vs2013/xenagent/xenagent.vcxproj b/vs2013/xenagent/xenagent.vcxproj index d312626..f5c1730 100644 --- a/vs2013/xenagent/xenagent.vcxproj +++ b/vs2013/xenagent/xenagent.vcxproj @@ -199,10 +199,12 @@ <ItemGroup> <ClCompile Include="..\..\src\xenagent\service.cpp"/> <ClCompile Include="..\..\src\xenagent\devicelist.cpp"/> + <ClCompile Include="..\..\src\xenagent\xenifacedevice.cpp"/> </ItemGroup> <ItemGroup> <ClInclude Include="..\..\src\xenagent\service.h" /> <ClInclude Include="..\..\src\xenagent\devicelist.h" /> + <ClInclude Include="..\..\src\xenagent\xenifacedevice.h" /> </ItemGroup> <ItemGroup> <CustomBuild Include="..\..\src\xenagent\xenagent.mc"> -- 1.9.4.msysgit.1 _______________________________________________ win-pv-devel mailing list win-pv-devel@xxxxxxxxxxxxxxxxxxxx http://lists.xenproject.org/cgi-bin/mailman/listinfo/win-pv-devel
|
Lists.xenproject.org is hosted with RackSpace, monitoring our |