You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
1145 lines
36 KiB
1145 lines
36 KiB
//+---------------------------------------------------------------------------
|
|
//
|
|
// Microsoft Windows
|
|
// Copyright (C) Microsoft Corporation, 1991 - 2000.
|
|
//
|
|
// File: VQuery.Cxx
|
|
//
|
|
// Contents: Query interface functions
|
|
//
|
|
// Functions: ProxyErrorToCIError
|
|
// EvalQuery
|
|
// EvalMetadataQuery
|
|
// ForceMasterMerge
|
|
// AbortMerges
|
|
// CiState
|
|
// AddScopeToCI
|
|
// RemoveScopeFromCI
|
|
// BeginCacheTransaction
|
|
// SetupCacheEx
|
|
// SetupCache
|
|
// EndCacheTransaction
|
|
// DumpWorkId
|
|
// SetCatalogState
|
|
//
|
|
// History: 18-Aug-91 KyleP Created.
|
|
// 16-Sep-96 dlee made it work with cisvc
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
#include <pch.cxx>
|
|
#pragma hdrstop
|
|
|
|
#include "svcquery.hxx"
|
|
|
|
#include <isearch.hxx>
|
|
#include <svccatpx.hxx>
|
|
#include <cidbprop.hxx>
|
|
#include <dbprputl.hxx>
|
|
#include <fsciclnt.h>
|
|
#include <ciframe.hxx>
|
|
#include <fsci.hxx>
|
|
#include <cifwexp.hxx>
|
|
#include <ciregkey.hxx>
|
|
#include <fsciexps.hxx>
|
|
|
|
|
|
|
|
typedef SCODE (* T_FsCiShutdown)(void);
|
|
|
|
static GUID clsidStorageDocStoreLocator = CLSID_StorageDocStoreLocator;
|
|
static XLibHandle gxCiFrmWrk;
|
|
static T_MakeGenericQueryForDocStore gprocMakeGenericQuery = 0;
|
|
|
|
extern CStaticMutexSem g_mtxCommandCreator;
|
|
|
|
|
|
void SetIDbProperties( IDBProperties * pIDbProp,
|
|
WCHAR const * pwcCatalog,
|
|
WCHAR const * pwcMachine,
|
|
GUID & clientGuid,
|
|
WCHAR const * pwcScope = 0,
|
|
CiMetaData eType = CiAdminOp);
|
|
|
|
//+-------------------------------------------------------------------------
|
|
//
|
|
// Function: ProxyErrorToCIError, public
|
|
//
|
|
// Synopsis: Attempt to translate an error code from the proxy into
|
|
// a CI error code.
|
|
//
|
|
// Arguments: [sc] -- source error
|
|
//
|
|
// Returns: The translated or original error
|
|
//
|
|
// History: 06-Jan-98 dlee Created
|
|
//
|
|
//--------------------------------------------------------------------------
|
|
|
|
SCODE ProxyErrorToCIError( CException & e )
|
|
{
|
|
SCODE sc = GetScodeError( e );
|
|
|
|
if ( HRESULT_FROM_WIN32( ERROR_FILE_NOT_FOUND ) == sc )
|
|
sc = CI_E_NOT_RUNNING;
|
|
else if ( STATUS_NOT_FOUND == sc )
|
|
sc = CI_E_NOT_FOUND;
|
|
else if ( sc == HRESULT_FROM_WIN32( ERROR_SEM_TIMEOUT ) ||
|
|
sc == HRESULT_FROM_WIN32( ERROR_PIPE_BUSY ) )
|
|
sc = CI_E_TIMEOUT;
|
|
|
|
return sc;
|
|
} //ProxyErrorToCIError
|
|
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Function: CreateDbProperties
|
|
//
|
|
// Synopsis: Helper function to create an IDBProperties and set the
|
|
// given parameters as DBPROPS in the IDBProperties.
|
|
//
|
|
// Arguments: [pwcCatalog] - Name or location of the catalog.
|
|
// [pwcMachine] - Name of the machine to connect to.
|
|
// [pwcScopes ] - (first scope) directory.
|
|
// [eType] - query type
|
|
//
|
|
// Returns: Pointer to an initilized IDBProperties interface.
|
|
//
|
|
// History: 1-15-97 srikants Created
|
|
// 5-14-97 mohamedn use SetIDbProperties
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
IDBProperties * CreateDbProperties( WCHAR const * pwcCatalog,
|
|
WCHAR const * pwcMachine,
|
|
WCHAR const * pwcScopes = 0,
|
|
CiMetaData eType = CiAdminOp )
|
|
{
|
|
XInterface<IDBProperties> xdbp( new CDbProperties );
|
|
if ( xdbp.IsNull() )
|
|
THROW( CException( E_OUTOFMEMORY ) );
|
|
|
|
SetIDbProperties( xdbp.GetPointer(),
|
|
pwcCatalog,
|
|
pwcMachine,
|
|
clsidStorageDocStoreLocator,
|
|
pwcScopes,
|
|
eType );
|
|
|
|
return xdbp.Acquire();
|
|
}
|
|
|
|
|
|
//+-------------------------------------------------------------------------
|
|
//
|
|
// Function: LoadCiFrmWrkLibrary, private
|
|
//
|
|
// Synopsis: Loads the appropriate framework library
|
|
//
|
|
// Arguments: None
|
|
//
|
|
// Returns: Handle to library
|
|
//
|
|
// History: 22-Apr-97 KrishnaN Created
|
|
// 02-Jun-97 KrishnaN Decide between olympus/ci version
|
|
// based on registry entry.
|
|
//
|
|
//--------------------------------------------------------------------------
|
|
|
|
inline HINSTANCE LoadCiFrmWrkLibrary()
|
|
{
|
|
HINSTANCE hLib;
|
|
WCHAR awszLibName[MAX_PATH];
|
|
|
|
//
|
|
// We want to be able to load the right version of the framework dll.
|
|
// The olympus and ci versions are for the most part similar, but not
|
|
// identical. So when Olympus is installed, we should lookup in the
|
|
// registry to find out what dll to use. If that registry entry is
|
|
// not found, we default to query.dll.
|
|
//
|
|
|
|
wcscpy(awszLibName, L"QUERY.DLL");
|
|
|
|
HKEY hKey;
|
|
|
|
long sc = RegOpenKeyEx(HKEY_LOCAL_MACHINE, // Root
|
|
wcsRegCommonAdminSubKey, // key
|
|
0, // Reserved
|
|
KEY_READ, // Access
|
|
&hKey); // Handle
|
|
|
|
// For a smoother transition, if we don't find it in the
|
|
// newly defined commonadminsubkey, look for it in the old place
|
|
if (ERROR_SUCCESS != sc)
|
|
sc = RegOpenKeyEx(HKEY_LOCAL_MACHINE, // Root
|
|
L"Software\\Microsoft\\Site Server\\3.0\\Search\\CiFramework",
|
|
0, // Reserved
|
|
KEY_READ, // Access
|
|
&hKey); // Handle
|
|
|
|
if (ERROR_SUCCESS == sc)
|
|
{
|
|
DWORD dwType = REG_SZ;
|
|
DWORD dwSize = MAX_PATH * sizeof(WCHAR);
|
|
// If we successfully read the value, the full path name will be read in
|
|
sc = RegQueryValueEx(hKey,
|
|
L"CiFrmWrkDll",
|
|
0,
|
|
&dwType,
|
|
(LPBYTE)awszLibName,
|
|
&dwSize
|
|
);
|
|
RegCloseKey(hKey);
|
|
}
|
|
|
|
hLib = LoadLibraryW(awszLibName);
|
|
|
|
if ( 0 == hLib )
|
|
{
|
|
ciDebugOut(( DEB_ERROR, "Error %d occurred in LoadLibrary on %ws\n",
|
|
GetLastError(), awszLibName ));
|
|
THROW(CException( E_UNEXPECTED ));
|
|
}
|
|
|
|
gprocMakeGenericQuery = (T_MakeGenericQueryForDocStore)
|
|
GetProcAddress( hLib, "MakeGenericQueryForDocStore" );
|
|
if (0 == gprocMakeGenericQuery)
|
|
{
|
|
ciDebugOut((DEB_ERROR, "Failed to locate MakeGenericQueryForDocStore"
|
|
" in the framework dll\n"));
|
|
THROW(CException( E_UNEXPECTED ));
|
|
}
|
|
|
|
return hLib;
|
|
}
|
|
|
|
//+-------------------------------------------------------------------------
|
|
//
|
|
// Function: EvalQuery, public
|
|
//
|
|
// Synopsis: Simulates bind to to ci object store
|
|
//
|
|
// Arguments: [ppQuery] -- returns the PIInternalQuery
|
|
// [idbProps] -- object exposing IDBProperties
|
|
// [pDocStore] -- doc store interface pointer
|
|
//
|
|
// Returns: SCODE result
|
|
//
|
|
// History: 12 Dec 95 AlanW Created
|
|
// 08-Feb-96 KyleP Add virtual path support
|
|
// 01-Nov-96 dlee Add multi-scope support, return scode
|
|
// 14-May-97 mohamedn hidden fs/core property set details.
|
|
//
|
|
//--------------------------------------------------------------------------
|
|
|
|
SCODE EvalQuery(
|
|
PIInternalQuery ** ppQuery,
|
|
CDbProperties & idbProps,
|
|
ICiCDocStore * pDocStore)
|
|
{
|
|
SCODE sc = S_OK;
|
|
PIInternalQuery * pQuery = 0;
|
|
|
|
CTranslateSystemExceptions xlate;
|
|
TRY
|
|
{
|
|
if ( pDocStore )
|
|
{
|
|
//
|
|
// If the framework library is not loaded, load it and get the
|
|
// generic query
|
|
//
|
|
|
|
if ( 0 == gxCiFrmWrk.Get() )
|
|
{
|
|
//
|
|
// we don't want to go through this crit sect for each
|
|
// invocation of EvalQuery. So first check for the handle
|
|
// to be null, and then take a lock.
|
|
// Multiple threads running simultaeneously could get past
|
|
// the check for null handle, but only the first one that gets
|
|
// the lock will have the chance to set the gxCiFrmWrk variable.
|
|
// The remaining will find that the second check for null
|
|
// handle doesn't hold and will do nothing.
|
|
//
|
|
|
|
CLock lock(g_mtxCommandCreator);
|
|
if (0 == gxCiFrmWrk.Get())
|
|
{
|
|
Win4Assert( 0 == gprocMakeGenericQuery);
|
|
gxCiFrmWrk.Set(LoadCiFrmWrkLibrary());
|
|
}
|
|
}
|
|
|
|
sc = gprocMakeGenericQuery( &idbProps, pDocStore, &pQuery);
|
|
}
|
|
else
|
|
{
|
|
CGetDbProps dbProp;
|
|
|
|
dbProp.GetProperties( &idbProps , CGetDbProps::eMachine );
|
|
|
|
WCHAR const *pwcMachine = dbProp.GetMachine();
|
|
|
|
if ( 0 != pwcMachine )
|
|
{
|
|
pQuery = new CSvcQuery( pwcMachine,
|
|
&idbProps );
|
|
}
|
|
else
|
|
{
|
|
THROW( CException(E_INVALIDARG) );
|
|
}
|
|
}
|
|
}
|
|
CATCH( CException, e )
|
|
{
|
|
vqDebugOut(( DEB_ERROR,
|
|
"Catastrophic error 0x%x in EvalQuery\n",
|
|
e.GetErrorCode() ));
|
|
pQuery = 0;
|
|
|
|
//
|
|
// NOTE: Fix for bug 86178. This is a lower level routine and it should
|
|
// propogate errors untranslated to the upper layer (ICommand::Execute).
|
|
//
|
|
|
|
sc = e.GetErrorCode();
|
|
}
|
|
END_CATCH;
|
|
|
|
*ppQuery = pQuery;
|
|
return sc;
|
|
} //EvalQuery
|
|
|
|
//+-------------------------------------------------------------------------
|
|
//
|
|
// Function: EvalMetadataQuery, public
|
|
//
|
|
// Synopsis: Simulates bind to PIInternalQuery for ci object store
|
|
//
|
|
// Arguments: [ppQuery] - returns the PIInternalQuery
|
|
// [eType] - Type of metadata
|
|
// [wcsCat] - Catalog location
|
|
// [pwcsMachine] - Machine on which catalog resides
|
|
//
|
|
// Returns: SCODE result
|
|
//
|
|
// History: 12 Dec 95 AlanW Created
|
|
// 08-Feb-96 KyleP Add virtual path support
|
|
//
|
|
//--------------------------------------------------------------------------
|
|
|
|
SCODE EvalMetadataQuery(
|
|
PIInternalQuery ** ppQuery,
|
|
CiMetaData eType,
|
|
WCHAR const * wcsCat,
|
|
WCHAR const * wcsMachine )
|
|
{
|
|
*ppQuery = 0;
|
|
PIInternalQuery * pQuery = 0;
|
|
SCODE sc = S_OK;
|
|
|
|
CTranslateSystemExceptions xlate;
|
|
TRY
|
|
{
|
|
XInterface<IDBProperties> xDbProps( CreateDbProperties( wcsCat,
|
|
wcsMachine,
|
|
0,
|
|
eType ) );
|
|
Win4Assert( 0 != wcsMachine );
|
|
pQuery = new CSvcQuery( wcsMachine, xDbProps.GetPointer() );
|
|
}
|
|
CATCH( CException, e )
|
|
{
|
|
vqDebugOut(( DEB_ERROR,
|
|
"Catastrophic error 0x%x in EvalMetadataQuery\n",
|
|
e.GetErrorCode() ));
|
|
pQuery = 0;
|
|
|
|
//
|
|
// NOTE: Fix for bug 86178. This is a lower level routine and it should
|
|
// propogate errors untranslated to the upper layer (ICommand::Execute).
|
|
//
|
|
|
|
sc = e.GetErrorCode();
|
|
}
|
|
END_CATCH;
|
|
|
|
*ppQuery = pQuery;
|
|
return sc;
|
|
} //EvalMetadataQuery
|
|
|
|
|
|
//+-------------------------------------------------------------------------
|
|
//
|
|
// Function: ForceMasterMerge, public
|
|
//
|
|
// Synopsis: Forces a master merge on the partition ID specified
|
|
//
|
|
// Arguments: [wcsDrive] - Drive to force merge on
|
|
// [pwcsCat] - Catalog name
|
|
// [pwcsMachine] - Machine on which catalog resides
|
|
// [partId] - PartitionID to force merge on
|
|
//
|
|
// History: 01-Nov-95 DwightKr Created
|
|
//
|
|
//--------------------------------------------------------------------------
|
|
|
|
SCODE ForceMasterMerge(
|
|
WCHAR const * wcsDrive,
|
|
WCHAR const * pwcsCat,
|
|
WCHAR const * pwcsMachine,
|
|
ULONG partId )
|
|
{
|
|
SCODE status = S_OK;
|
|
|
|
//
|
|
// Verify that we have legal parameters
|
|
//
|
|
|
|
if ( (0==wcsDrive) || (1!=partId) )
|
|
return E_INVALIDARG;
|
|
|
|
CTranslateSystemExceptions xlate;
|
|
TRY
|
|
{
|
|
XInterface<IDBProperties> xDbProps( CreateDbProperties( pwcsCat,
|
|
pwcsMachine,
|
|
wcsDrive ) );
|
|
|
|
Win4Assert( 0 != pwcsMachine );
|
|
CSvcCatProxy cat( pwcsMachine, xDbProps.GetPointer() );
|
|
cat.ForceMerge( partId );
|
|
}
|
|
CATCH( CException, e )
|
|
{
|
|
status = ProxyErrorToCIError( e );
|
|
}
|
|
END_CATCH
|
|
|
|
return status;
|
|
} //ForceMasterMerge
|
|
|
|
|
|
//+-------------------------------------------------------------------------
|
|
//
|
|
// Function: AbortMerges, public
|
|
//
|
|
// Synopsis: Aborts any merge in progress in the specified partid.
|
|
//
|
|
// Arguments: [wcsDrive] -- Drive to force merge on
|
|
// [partId] -- PartitionID to force merge on
|
|
//
|
|
// History: 01-Nov-95 DwightKr Created
|
|
//
|
|
//--------------------------------------------------------------------------
|
|
|
|
SCODE AbortMerges(
|
|
WCHAR const * wcsDrive,
|
|
WCHAR const * pwcsCat,
|
|
WCHAR const * pwcsMachine,
|
|
ULONG partId )
|
|
{
|
|
SCODE status = S_OK;
|
|
|
|
//
|
|
// Verify that we have legal parameters
|
|
//
|
|
|
|
if ( (0==wcsDrive) || (1!=partId) )
|
|
return E_INVALIDARG;
|
|
|
|
CTranslateSystemExceptions xlate;
|
|
TRY
|
|
{
|
|
XInterface<IDBProperties> xDbProps( CreateDbProperties( pwcsCat,
|
|
pwcsMachine,
|
|
wcsDrive ) );
|
|
Win4Assert( 0 != pwcsMachine );
|
|
CSvcCatProxy cat( pwcsMachine, xDbProps.GetPointer() );
|
|
cat.AbortMerge( partId );
|
|
}
|
|
CATCH( CException, e )
|
|
{
|
|
status = ProxyErrorToCIError( e );
|
|
}
|
|
END_CATCH
|
|
|
|
return status;
|
|
} //AbortMerges
|
|
|
|
|
|
//+-------------------------------------------------------------------------
|
|
//
|
|
// Function: CIState, public
|
|
//
|
|
// Synopsis: Returns the state of the CI for the drive specified.
|
|
//
|
|
// Arguments: [pwcsCat] -- Catalog
|
|
// [pwcsMachine] -- Machine name
|
|
// [pCiState] -- Current state of the CI
|
|
//
|
|
// History: 01-Nov-95 DwightKr Created
|
|
//
|
|
//--------------------------------------------------------------------------
|
|
|
|
SCODE CIState( WCHAR const * pwcsCat,
|
|
WCHAR const * pwcsMachine,
|
|
CI_STATE * pCiState )
|
|
{
|
|
// Verify that we have legal parameters
|
|
|
|
if ( 0 == pCiState ||
|
|
0 == pwcsCat ||
|
|
pCiState->cbStruct < sizeof pCiState->cbStruct )
|
|
return E_INVALIDARG;
|
|
|
|
if ( 0 == pwcsMachine )
|
|
pwcsMachine = L".";
|
|
|
|
SCODE status = S_OK;
|
|
|
|
CTranslateSystemExceptions xlate;
|
|
TRY
|
|
{
|
|
XInterface<IDBProperties> xDbProps( CreateDbProperties( pwcsCat, pwcsMachine ) );
|
|
|
|
CSvcCatProxy cat( pwcsMachine, xDbProps.GetPointer() );
|
|
cat.CiState( *pCiState );
|
|
}
|
|
CATCH( CException, e )
|
|
{
|
|
status = ProxyErrorToCIError( e );
|
|
}
|
|
END_CATCH
|
|
|
|
return status;
|
|
} //CiState
|
|
|
|
//+-------------------------------------------------------------------------
|
|
//
|
|
// Function: UpdateContentIndex, public
|
|
//
|
|
// Synopsis: Registers documents for indexing.
|
|
//
|
|
// Arguments: [wcsRoot] -- Root of scope to scan for updates
|
|
// [wcsCat] -- Override for catalog location
|
|
//
|
|
// Returns:
|
|
//
|
|
// History: 23-Jun-93 KyleP Added header
|
|
//
|
|
//--------------------------------------------------------------------------
|
|
|
|
ULONG UpdateContentIndex(
|
|
WCHAR const * wcsRoot,
|
|
WCHAR const * wcsCat,
|
|
WCHAR const * wcsMachine,
|
|
BOOL fFull )
|
|
{
|
|
SCODE status = S_OK;
|
|
|
|
CTranslateSystemExceptions xlate;
|
|
TRY
|
|
{
|
|
IDBProperties * pDbProps = CreateDbProperties( wcsCat, wcsMachine );
|
|
XInterface<IDBProperties> xProps( pDbProps );
|
|
|
|
CSvcCatProxy cat( wcsMachine, pDbProps );
|
|
cat.UpdateDocuments( wcsRoot, fFull ? UPD_FULL : UPD_INCREM );
|
|
}
|
|
CATCH( CException, e )
|
|
{
|
|
status = ProxyErrorToCIError( e );
|
|
}
|
|
END_CATCH
|
|
|
|
return (ULONG) status;
|
|
} //UpdateContentIndex
|
|
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: AddScopeToCI
|
|
//
|
|
// Synopsis: Adds a scope for down level ContentIndex. All documents in
|
|
// the specified scope will be indexed.
|
|
//
|
|
// Arguments: [wcsRoot] - Scope to add
|
|
// [wcsCat] - Alternate location for catalog
|
|
// [wcsMachine] - Machine on which catalog resides, L"." for
|
|
// the local machine
|
|
//
|
|
// Returns: Status code
|
|
//
|
|
// History: 1-21-96 srikants Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
SCODE AddScopeToCI (
|
|
WCHAR const * wcsRoot,
|
|
WCHAR const * wcsCat,
|
|
WCHAR const * wcsMachine )
|
|
{
|
|
SCODE sc = S_OK;
|
|
|
|
CTranslateSystemExceptions xlate;
|
|
TRY
|
|
{
|
|
IDBProperties * pDbProps = CreateDbProperties( wcsCat, wcsMachine );
|
|
XInterface<IDBProperties> xProps( pDbProps );
|
|
|
|
CSvcCatProxy cat( wcsMachine, pDbProps );
|
|
cat.AddScopeToCI( wcsRoot );
|
|
}
|
|
CATCH( CException, e )
|
|
{
|
|
sc = GetOleError( e );
|
|
}
|
|
END_CATCH
|
|
|
|
return sc;
|
|
} //AddScopeToCI
|
|
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: RemoveScopeFromCI
|
|
//
|
|
// Synopsis: Removes a scope for down level ContentIndex. All documents in
|
|
// the specified scope will be deleted.
|
|
//
|
|
// Arguments: [wcsRoot] - Scope to remove
|
|
// [wcsCat] - Alternate location for catalog
|
|
// [wcsMachine] - Machine on which catalog resides, L"." for
|
|
// the local machine
|
|
//
|
|
// Returns: Status code
|
|
//
|
|
// History: 1-21-96 srikants Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
SCODE RemoveScopeFromCI(
|
|
WCHAR const * wcsRoot,
|
|
WCHAR const * wcsCat,
|
|
WCHAR const * wcsMachine )
|
|
{
|
|
SCODE sc = S_OK;
|
|
|
|
CTranslateSystemExceptions xlate;
|
|
TRY
|
|
{
|
|
IDBProperties * pDbProps = CreateDbProperties( wcsCat, wcsMachine );
|
|
XInterface<IDBProperties> xProps( pDbProps );
|
|
|
|
CSvcCatProxy cat( wcsMachine, pDbProps );
|
|
cat.RemoveScopeFromCI( wcsRoot );
|
|
}
|
|
CATCH( CException, e )
|
|
{
|
|
sc = GetOleError( e );
|
|
}
|
|
END_CATCH
|
|
|
|
return sc;
|
|
} //RemoveScopeFromCI
|
|
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Function: BeginCacheTransaction, public
|
|
//
|
|
// Synopsis: Begin a cache update session.
|
|
//
|
|
// Arguments: [pulToken] - Token representing transaction returned here.
|
|
// [wcsRoot] - Root of scope to scan for updates
|
|
// [wcsCat] - Override for catalog location
|
|
// [wcsMachine] - Machine on which catalog resides, L"." for
|
|
// the local machine
|
|
//
|
|
// History: 20-Jun-96 KyleP Created.
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
SCODE BeginCacheTransaction(
|
|
ULONG_PTR * pulToken,
|
|
WCHAR const * wcsRoot,
|
|
WCHAR const * wcsCat,
|
|
WCHAR const * wcsMachine )
|
|
{
|
|
SCODE sc = S_OK;
|
|
|
|
CTranslateSystemExceptions xlate;
|
|
TRY
|
|
{
|
|
XInterface<IDBProperties> xDbProps( CreateDbProperties( wcsCat,
|
|
wcsMachine ) );
|
|
|
|
CSvcCatProxy cat( wcsMachine, xDbProps.GetPointer() );
|
|
*pulToken = 0; // Catch access violation
|
|
*pulToken = cat.BeginCacheTransaction();
|
|
}
|
|
CATCH( CException, e )
|
|
{
|
|
sc = ProxyErrorToCIError( e );
|
|
}
|
|
END_CATCH
|
|
|
|
return sc;
|
|
} //BeginCacheTransaction
|
|
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Function: SetupCacheEx, public
|
|
//
|
|
// Synopsis: Modify cache to store (or not store) property.
|
|
//
|
|
// Arguments: [ps] - Property to cache.
|
|
// [vt] - Datatype of property. VT_VARIANT if unknown.
|
|
// [cbMaxLen] - Soft-maximum length for variable length
|
|
// properties. This much space is pre-allocated
|
|
// in original record. A length of 0 will remove
|
|
// property from cache.
|
|
// [ulToken] - Token indentifying open transaction
|
|
// [fModifiable]- Is meta info modifiable?
|
|
// [dwLevel] - Primary or secondary store?
|
|
// [wcsRoot] - Root of scope to scan for updates
|
|
// [wcsCat] - Override for catalog location
|
|
// [wcsMachine] - Machine on which catalog resides, L"." for
|
|
// the local machine
|
|
//
|
|
// History: 18-Nov-97 KrishnaN Created.
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
SCODE SetupCacheEx(
|
|
FULLPROPSPEC const * ps,
|
|
ULONG vt,
|
|
ULONG cbMaxLen,
|
|
ULONG_PTR ulToken,
|
|
BOOL fModifiable,
|
|
DWORD dwStoreLevel,
|
|
WCHAR const * wcsRoot,
|
|
WCHAR const * wcsCat,
|
|
WCHAR const * wcsMachine )
|
|
{
|
|
Win4Assert(PRIMARY_STORE == dwStoreLevel ||
|
|
SECONDARY_STORE == dwStoreLevel);
|
|
|
|
SCODE sc = S_OK;
|
|
|
|
CTranslateSystemExceptions xlate;
|
|
TRY
|
|
{
|
|
XInterface<IDBProperties> xDbProps( CreateDbProperties( wcsCat,
|
|
wcsMachine ) );
|
|
CSvcCatProxy cat( wcsMachine, xDbProps.GetPointer() );
|
|
cat.SetupCache( *(CFullPropSpec const *)(ULONG_PTR)ps,
|
|
vt,
|
|
cbMaxLen,
|
|
ulToken,
|
|
fModifiable,
|
|
dwStoreLevel );
|
|
}
|
|
CATCH( CException, e )
|
|
{
|
|
sc = ProxyErrorToCIError( e );
|
|
}
|
|
END_CATCH
|
|
|
|
return sc;
|
|
} //SetupCacheEx
|
|
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Function: SetupCache, public
|
|
//
|
|
// Synopsis: Modify cache to store (or not store) property.
|
|
//
|
|
// Arguments: [ps] - Property to cache.
|
|
// [vt] - Datatype of property. VT_VARIANT if unknown.
|
|
// [cbMaxLen] - Soft-maximum length for variable length
|
|
// properties. This much space is pre-allocated
|
|
// in original record. A length of 0 will remove
|
|
// property from cache.
|
|
// [ulToken] - Token indentifying open transaction
|
|
// [wcsRoot] - Root of scope to scan for updates
|
|
// [wcsCat] - Override for catalog location
|
|
// [wcsMachine] - Machine on which catalog resides, L"." for
|
|
// the local machine
|
|
//
|
|
// History: 20-Jun-96 KyleP Created.
|
|
// 18-Nov-97 KrishnaN Used SetupCacheEx.
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
SCODE SetupCache(
|
|
FULLPROPSPEC const * ps,
|
|
ULONG vt,
|
|
ULONG cbMaxLen,
|
|
ULONG_PTR ulToken,
|
|
WCHAR const * wcsRoot,
|
|
WCHAR const * wcsCat,
|
|
WCHAR const * wcsMachine )
|
|
{
|
|
// Default fModifiable = TRUE and storeLevel = PRIMARY
|
|
return SetupCacheEx(ps, vt, cbMaxLen, ulToken, TRUE,
|
|
PRIMARY_STORE, wcsRoot, wcsCat, wcsMachine);
|
|
} //SetupCache
|
|
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Function: EndCacheTransaction, public
|
|
//
|
|
// Synopsis: Ends a cache update session.
|
|
//
|
|
// Arguments: [ulToken] - Token representing transaction.
|
|
// [fCommit] - TRUE if transaction should be commited.
|
|
// [wcsRoot] - Root of scope to scan for updates
|
|
// [wcsCat] - Override for catalog location
|
|
// [wcsMachine] - Machine on which catalog resides, L"." for
|
|
// the local machine
|
|
//
|
|
// History: 20-Jun-96 KyleP Created.
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
SCODE EndCacheTransaction(
|
|
ULONG_PTR ulToken,
|
|
BOOL fCommit,
|
|
WCHAR const * wcsRoot,
|
|
WCHAR const * wcsCat,
|
|
WCHAR const * wcsMachine )
|
|
{
|
|
SCODE sc = S_OK;
|
|
|
|
CTranslateSystemExceptions xlate;
|
|
TRY
|
|
{
|
|
XInterface<IDBProperties> xDbProps( CreateDbProperties( wcsCat,
|
|
wcsMachine ) );
|
|
CSvcCatProxy cat( wcsMachine, xDbProps.GetPointer() );
|
|
cat.EndCacheTransaction( ulToken, fCommit );
|
|
}
|
|
CATCH( CException, e )
|
|
{
|
|
sc = ProxyErrorToCIError( e );
|
|
}
|
|
END_CATCH
|
|
|
|
return sc;
|
|
} //EndCacheTransaction
|
|
|
|
//+-------------------------------------------------------------------------
|
|
//
|
|
// Function: DumpWorkId, public
|
|
//
|
|
// Synopsis: Dump all data for a particular workid
|
|
//
|
|
// Arguments: [wcsDrive] - Drive to query
|
|
// [wid] - Wid to search for
|
|
// [pb] - Buffer provided for writing results
|
|
// [cb] - Size of [pb]
|
|
// [pwcsCat] - Override for catalog location
|
|
// [wcsMachine] - Machine on which catalog resides, L"." for
|
|
// the local machine
|
|
//
|
|
// History: 03-Apr-95 KyleP Created
|
|
//
|
|
//--------------------------------------------------------------------------
|
|
|
|
SCODE DumpWorkId(
|
|
WCHAR const * wcsDrive,
|
|
ULONG wid,
|
|
BYTE * pb,
|
|
ULONG & cb,
|
|
WCHAR const * pwcsCat,
|
|
WCHAR const * pwcsMachine,
|
|
ULONG iid )
|
|
{
|
|
|
|
#if 0
|
|
|
|
#if CIDBG == 1
|
|
SCODE status = S_OK;
|
|
|
|
BYTE * pbStart = pb;
|
|
|
|
CTranslateSystemExceptions xlate;
|
|
TRY
|
|
{
|
|
PCatalog * pCat = GetOne( wcsDrive, pwcsCat );
|
|
|
|
if ( 0 != pCat )
|
|
{
|
|
ULONG UNALIGNED * pul = (ULONG *)pb;
|
|
pul += 2;
|
|
*pul = 0; // Initial bookmark of zero
|
|
|
|
unsigned const cbBuffer = 1024 * 32;
|
|
|
|
while ( cb >= cbBuffer )
|
|
{
|
|
pCat->DumpWorkId( wid, iid, pb, cbBuffer );
|
|
|
|
//
|
|
// Find end of buffer.
|
|
//
|
|
|
|
for ( char * psz = (char *)pb; *psz; psz++ )
|
|
continue;
|
|
|
|
//
|
|
// Check for null ulong
|
|
//
|
|
|
|
psz++;
|
|
pul = (ULONG UNALIGNED *)psz;
|
|
if ( *pul == 0 )
|
|
{
|
|
pb = (BYTE *)psz;
|
|
break;
|
|
}
|
|
else
|
|
{
|
|
psz--;
|
|
unsigned const cbBookmark = sizeof(ULONG) + sizeof(WORKID) + sizeof(CKeyBuf);
|
|
memmove( psz, psz+1, cbBookmark );
|
|
|
|
cb -= (BYTE *)psz - pb;;
|
|
pb = (BYTE *)psz;
|
|
}
|
|
}
|
|
}
|
|
else
|
|
{
|
|
status = STATUS_NOT_FOUND;
|
|
}
|
|
}
|
|
CATCH( CException, e )
|
|
{
|
|
status = e.GetErrorCode();
|
|
}
|
|
END_CATCH
|
|
|
|
cb = pb - pbStart;
|
|
|
|
return( status );
|
|
#else // CIDBG == 1
|
|
return( STATUS_NOT_IMPLEMENTED );
|
|
#endif // CIDBG == 1
|
|
|
|
#endif // 0
|
|
|
|
return STATUS_NOT_IMPLEMENTED;
|
|
|
|
} //DumpWorkId
|
|
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Member: CIShutdown
|
|
//
|
|
// Synopsis: Calls through to FsCiShutdown
|
|
//
|
|
// History: 3-06-97 srikants Created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
void CIShutdown()
|
|
{
|
|
FsCiShutdown();
|
|
} //CIShutdown
|
|
|
|
//+---------------------------------------------------------------------------
|
|
//
|
|
// Function: SetIDbProperties
|
|
//
|
|
// Synopsis: Sets scope properties on IDBProperties
|
|
//
|
|
// Arguments: [pIDbProp] -- IDBProperties interface to set scope props on.
|
|
// [pwcCatalog] -- catalog name
|
|
// [pwcMachine] -- machine name
|
|
// [clientGuid] -- client guid
|
|
// [pwcScope] -- scope path
|
|
// [eType] -- query type
|
|
//
|
|
// History: 14-May-97 mohamedn created
|
|
//
|
|
//----------------------------------------------------------------------------
|
|
|
|
void SetIDbProperties( IDBProperties * pIDbProp,
|
|
WCHAR const * pwcCatalog,
|
|
WCHAR const * pwcMachine,
|
|
CLSID & clientGuid,
|
|
WCHAR const * pwcScope,
|
|
CiMetaData eType )
|
|
{
|
|
const unsigned cElements = 1;
|
|
|
|
XBStr pxMachines[cElements];
|
|
XBStr pxCatalogs[cElements];
|
|
XBStr pxScopes [cElements];
|
|
DWORD aDepths [cElements];
|
|
|
|
//
|
|
// set machine name in a BSTR
|
|
//
|
|
|
|
if ( 0 != pwcMachine )
|
|
pxMachines[0].SetText( (WCHAR *)pwcMachine);
|
|
else
|
|
pxMachines[0].SetText(L".");
|
|
|
|
//
|
|
// set catalog name in a BSTR
|
|
//
|
|
if ( pwcCatalog )
|
|
{
|
|
pxCatalogs[0].SetText( (WCHAR *)pwcCatalog);
|
|
}
|
|
else
|
|
{
|
|
Win4Assert( !"No-Catalog set. Fatal Error" );
|
|
THROW ( CException(E_INVALIDARG) );
|
|
}
|
|
|
|
//
|
|
// set scope name in a BSTR
|
|
//
|
|
if ( pwcScope )
|
|
pxScopes[0].SetText( (WCHAR *)pwcScope );
|
|
else
|
|
pxScopes[0].SetText( L"\\" );
|
|
|
|
//
|
|
// set client guid
|
|
//
|
|
WCHAR awcClientGuid[ 40 ]; // 39 is all we need
|
|
|
|
int cb = StringFromGUID2( clientGuid,
|
|
awcClientGuid,
|
|
sizeof awcClientGuid / sizeof WCHAR );
|
|
Win4Assert( 0 != cb );
|
|
|
|
XBStr xbstrClientGuid;
|
|
xbstrClientGuid.SetText( awcClientGuid );
|
|
|
|
//
|
|
// set query type and defualt Depth
|
|
//
|
|
|
|
aDepths[0] = QUERY_DEEP;
|
|
|
|
//
|
|
// assemble safe arrays of the properties to set
|
|
//
|
|
SAFEARRAY saScope = { 1, // Dimension
|
|
FADF_AUTO | FADF_BSTR, // Flags: on stack, contains BSTRs
|
|
sizeof(BSTR), // Size of an element
|
|
1, // Lock count. 1 for safety.
|
|
(void *)pxScopes, // The data
|
|
{ cElements, 0 } }; // Bounds (element count, low bound)
|
|
|
|
SAFEARRAY saDepth = { 1, // Dimension
|
|
FADF_AUTO, // Flags: on stack
|
|
sizeof(LONG), // Size of an element
|
|
1, // Lock count. 1 for safety.
|
|
(void *)aDepths, // The data
|
|
{ cElements, 0 } }; // Bounds (element count, low bound)
|
|
|
|
SAFEARRAY saCatalog = { 1, // Dimension
|
|
FADF_AUTO | FADF_BSTR,// Flags: on stack, contains BSTRs
|
|
sizeof(BSTR), // Size of an element
|
|
1, // Lock count. 1 for safety.
|
|
(void *)pxCatalogs, // The data
|
|
{ cElements, 0 } }; // Bounds (element count, low bound)
|
|
|
|
SAFEARRAY saMachine = { 1, // Dimension
|
|
FADF_AUTO | FADF_BSTR,// Flags: on stack, contains BSTRs
|
|
sizeof(BSTR), // Size of an element
|
|
1, // Lock count. 1 for safety.
|
|
(void *)pxMachines, // The data
|
|
{ cElements, 0 } }; // Bounds (element count, low bound)
|
|
|
|
SAFEARRAY saClientGuid = { 1, // Dimension
|
|
FADF_AUTO | FADF_BSTR,// Flags: on stack, contains BSTRs
|
|
sizeof(BSTR), // Size of an element
|
|
1, // Lock count. 1 for safety.
|
|
(void *)&xbstrClientGuid, // The data
|
|
{ 1, 0 } }; // Bounds (element count, low bound)
|
|
//
|
|
// assemble property sets
|
|
//
|
|
|
|
DBPROP aQueryProps[4] = { { DBPROP_CI_INCLUDE_SCOPES, 0, DBPROPSTATUS_OK, {0, 0, 0}, { VT_BSTR | VT_ARRAY, 0, 0, 0, (ULONG_PTR)&saScope } },
|
|
{ DBPROP_CI_DEPTHS , 0, DBPROPSTATUS_OK, {0, 0, 0}, { VT_I4 | VT_ARRAY, 0, 0, 0, (ULONG_PTR)&saDepth } },
|
|
{ DBPROP_CI_CATALOG_NAME , 0, DBPROPSTATUS_OK, {0, 0, 0}, { VT_BSTR | VT_ARRAY, 0, 0, 0, (ULONG_PTR)&saCatalog } },
|
|
{ DBPROP_CI_QUERY_TYPE , 0, DBPROPSTATUS_OK, {0, 0, 0}, { VT_I4 , 0, 0, 0, eType } } };
|
|
|
|
DBPROP aCoreProps[2] = { { DBPROP_MACHINE , 0, DBPROPSTATUS_OK, {0, 0, 0}, { VT_BSTR | VT_ARRAY, 0, 0, 0, (ULONG_PTR)&saMachine } },
|
|
{ DBPROP_CLIENT_CLSID , 0, DBPROPSTATUS_OK, {0, 0, 0}, { VT_BSTR | VT_ARRAY, 0, 0, 0, (ULONG_PTR)&saClientGuid } } };
|
|
|
|
DBPROPSET aAllPropsets[2] = { {aQueryProps, 4, DBPROPSET_FSCIFRMWRK_EXT } ,
|
|
{aCoreProps , 2, DBPROPSET_CIFRMWRKCORE_EXT } };
|
|
|
|
//
|
|
// set property sets
|
|
//
|
|
SCODE sc = pIDbProp->SetProperties( 2, aAllPropsets );
|
|
|
|
if ( FAILED( sc ) )
|
|
THROW( CException( sc ) );
|
|
} //SetIDbProperties
|
|
|
|
//+-------------------------------------------------------------------------
|
|
//
|
|
// Function: SetCatalogState, public
|
|
//
|
|
// Synopsis: Change the catalog's state on the partition ID specified
|
|
//
|
|
// Arguments: [pwcsCat] - passed in as ADMINISTRATOR for connection
|
|
// without docstore assocication
|
|
// [pwcsMachine] - Machine on which catalog resides
|
|
// [dwNewState] - The state which catalog's going to be
|
|
// changed into
|
|
// [pdwOldState] - Output, catalog's original state
|
|
//
|
|
// History: 06-May-98 KitmanH Created
|
|
//
|
|
//--------------------------------------------------------------------------
|
|
|
|
SCODE SetCatalogState( WCHAR const * pwcsCat,
|
|
WCHAR const * pwcsMachine,
|
|
DWORD dwNewState,
|
|
DWORD * pdwOldState )
|
|
{
|
|
SCODE status = S_OK;
|
|
|
|
if ( 0 == pdwOldState )
|
|
return E_INVALIDARG;
|
|
|
|
if ( 0 == pwcsMachine )
|
|
pwcsMachine = L".";
|
|
|
|
//
|
|
// Verify that we have legal parameters
|
|
//
|
|
|
|
CTranslateSystemExceptions xlate;
|
|
TRY
|
|
{
|
|
XInterface<IDBProperties> xDbProps( CreateDbProperties( CIADMIN,
|
|
pwcsMachine ) );
|
|
CSvcCatProxy cat( pwcsMachine, xDbProps.GetPointer() );
|
|
|
|
cat.SetCatState( 1, pwcsCat, dwNewState, pdwOldState );
|
|
}
|
|
CATCH( CException, e )
|
|
{
|
|
status = ProxyErrorToCIError( e );
|
|
}
|
|
END_CATCH
|
|
|
|
return status;
|
|
} //SetCatalogState
|
|
|