OW_CIMOMLocatorSLP.cpp

Go to the documentation of this file.

/*******************************************************************************
* Copyright (C) 2001-2004 Vintela, 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.
*
*  - Neither the name of Vintela, Inc. nor the names of its
*    contributors may be used to endorse or promote products derived from this
*    software without specific prior written permission.
*
* 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 Vintela, Inc. OR THE 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 "OW_config.h"
#include "OW_CIMOMLocatorSLP.hpp"
#include "OW_CIMOMInfo.hpp"
#include "OW_Array.hpp"
#include "OW_String.hpp"
#include "OW_Format.hpp"

#ifdef OW_HAVE_SLP_H

namespace OW_NAMESPACE
{

struct CBData
{
   Array<String> urls;
   Array<UInt16> lifetimes;
   SLPError errcode;
};
extern "C"
{
SLPBoolean MySLPSrvURLCallback( SLPHandle /*hslp*/, 
   const char* srvurl, 
   unsigned short lifetime, 
   SLPError errcode, 
   void* cookie ) 
{
   switch (errcode)
   {
      case SLP_OK:
         (static_cast<CBData*>(cookie))->urls.push_back(srvurl);
         (static_cast<CBData*>(cookie))->lifetimes.push_back(lifetime);
         break;
      case SLP_LAST_CALL:
         (static_cast<CBData*>(cookie))->errcode = SLP_OK; 
         break;
      default:
         (static_cast<CBData*>(cookie))->errcode = errcode;
         break;
   }
   /* return SLP_TRUE because we want to be called again */ 
   /* if more services were found                        */ 
   return SLP_TRUE; 
} 
SLPBoolean MySLPAttrCallback(SLPHandle /*hslp*/, 
                     const char* attrlist, 
                     SLPError errcode, 
                     void* cookie ) 
{ 
   if (errcode == SLP_OK) 
   { 
      (*static_cast<String*>(cookie)) = attrlist;
   } 
   
   return SLP_FALSE; 
}
} // extern "C"
CIMOMLocatorSLP::CIMOMLocatorSLP()  
{
   SLPError err = SLPOpen("en", SLP_FALSE, &m_hslp);
   if (err != SLP_OK)
   {
      SLPClose(m_hslp);
      OW_THROW(CIMOMLocatorException, 
         Format("Error opening SLP handle: %1", err).c_str());
   }
}
// STATIC
void
CIMOMLocatorSLP::processAttributes(const String& attrs, 
      CIMOMInfo& info)
{
   String sattrs(attrs);
   size_t idx = sattrs.indexOf('(');
   while (idx != String::npos)
   {
      sattrs = sattrs.substring(idx + 1);
      size_t endIdx = sattrs.indexOf('=');
      String key = sattrs.substring(0, endIdx);
      sattrs = sattrs.substring(endIdx + 1);
      endIdx = sattrs.indexOf(')');
      String val = sattrs.substring(0, endIdx);
      info[key] = val;
      idx = sattrs.indexOf('(');
   }
}
CIMOMInfoArray 
CIMOMLocatorSLP::findCIMOMs()
{
   SLPError err;
   CBData data;
   CIMOMInfoArray rval;
   err = SLPFindSrvs(m_hslp, OW_CIMOM_SLP_SERVICE_TYPE, 0, 0, MySLPSrvURLCallback, &data);
   if ((err != SLP_OK) || (data.errcode != SLP_OK)) 
   { 
      OW_THROW(CIMOMLocatorException, 
         Format("Error finding service: %1.  SLP Error code: %2",
            OW_CIMOM_SLP_SERVICE_TYPE, err).c_str());
   } 
   for (size_t i = 0; i < data.urls.size(); ++i)
   {
      CIMOMInfo info;
      String SLPUrl = data.urls[i];
      size_t idx = SLPUrl.indexOf("http");
      info.setURL(SLPUrl.substring(idx));
      String attrList;
      err = SLPFindAttrs(m_hslp, data.urls[i].c_str(), "", "", 
         MySLPAttrCallback, &attrList);
      if (err != SLP_OK)
      {
         OW_THROW(CIMOMLocatorException, 
            Format("Error retrieving attributes for %1",
               data.urls[i]).c_str());
      }
      processAttributes(attrList, info);
      
      String url = info.getURL();
      char* cpUrl = 0;
      err = SLPUnescape(url.c_str(), &cpUrl, SLP_FALSE);
      if (err != SLP_OK)
      {
         if (cpUrl)
         {
            SLPFree(cpUrl);
         }
         OW_THROW(CIMOMLocatorException, 
            Format("Error unescaping URL: %1", err).c_str());
      }
      url = cpUrl;
      SLPFree(cpUrl);
      info.setURL(url);
      rval.push_back(info);
   }
   
   return rval;
}
CIMOMLocatorSLP::~CIMOMLocatorSLP() 
{
   SLPClose(m_hslp);
}

} // end namespace OW_NAMESPACE

#endif // OW_HAVE_SLP_H

---