Windows CCAPI snapshot. Should build & pass ping test

TargetVersion: 1.7
Component: krb5-libs
Ticket: 5594

git-svn-id: svn://anonsvn.mit.edu/krb5/trunk@20203 dc483132-0cff-0310-8789-dd5450dbe970

4 files changed, 813 insertions, 0 deletions

diff --git a/src/ccapi/lib/win/OldCC/ccapi.h b/src/ccapi/lib/win/OldCC/ccapi.h
new file mode 100644
index 0000000000..65a72edb47
--- /dev/null
+++ b/src/ccapi/lib/win/OldCC/ccapi.h
@@ -0,0 +1,284 @@
+

+

+/* this ALWAYS GENERATED file contains the definitions for the interfaces */

+

+

+ /* File created by MIDL compiler version 6.00.0366 */

+/* at Fri Nov 30 10:06:16 2007

+ */

+/* Compiler settings for ccapi.idl:

+    Oic, W1, Zp8, env=Win32 (32b run)

+    protocol : dce , ms_ext, c_ext, oldnames

+    error checks: allocation ref bounds_check enum stub_data 

+    VC __declspec() decoration level: 

+         __declspec(uuid()), __declspec(selectany), __declspec(novtable)

+         DECLSPEC_UUID(), MIDL_INTERFACE()

+*/

+//@@MIDL_FILE_HEADING(  )

+

+#pragma warning( disable: 4049 )  /* more than 64k source lines */

+

+

+/* verify that the <rpcndr.h> version is high enough to compile this file*/

+#ifndef __REQUIRED_RPCNDR_H_VERSION__

+#define __REQUIRED_RPCNDR_H_VERSION__ 440

+#endif

+

+#include "rpc.h"

+#include "rpcndr.h"

+

+#ifndef __ccapi_h__

+#define __ccapi_h__

+

+#if defined(_MSC_VER) && (_MSC_VER >= 1020)

+#pragma once

+#endif

+

+/* Forward Declarations */ 

+

+#ifdef __cplusplus

+extern "C"{

+#endif 

+

+void * __RPC_USER MIDL_user_allocate(size_t);

+void __RPC_USER MIDL_user_free( void * ); 

+

+#ifndef __ccapi_INTERFACE_DEFINED__

+#define __ccapi_INTERFACE_DEFINED__

+

+/* interface ccapi */

+/* [implicit_handle][unique][version][uuid] */ 

+

+typedef /* [context_handle] */ struct opaque_handle_CTX *HCTX;

+

+typedef /* [context_handle] */ struct opaque_handle_CACHE *HCACHE;

+

+typedef /* [context_handle] */ struct opaque_handle_CACHE_ITER *HCACHE_ITER;

+

+typedef /* [context_handle] */ struct opaque_handle_CRED_ITER *HCRED_ITER;

+

+typedef unsigned char CC_CHAR;

+

+typedef unsigned char CC_UCHAR;

+

+typedef int CC_INT32;

+

+typedef unsigned int CC_UINT32;

+

+typedef CC_INT32 CC_TIME_T;

+

+

+enum __MIDL_ccapi_0001

+    {	STK_AFS	= 0,

+	STK_DES	= 1

+    } ;

+

+enum __MIDL_ccapi_0002

+    {	CC_API_VER_1	= 1,

+	CC_API_VER_2	= 2

+    } ;

+

+enum __MIDL_ccapi_0003

+    {	KRB_NAME_SZ	= 40,

+	KRB_INSTANCE_SZ	= 40,

+	KRB_REALM_SZ	= 40,

+	MAX_V4_CRED_LEN	= 1250

+    } ;

+typedef struct _NC_INFO

+    {

+    /* [string] */ CC_CHAR *name;

+    /* [string] */ CC_CHAR *principal;

+    CC_INT32 vers;

+    } 	NC_INFO;

+

+typedef struct _NC_INFO_LIST

+    {

+    CC_UINT32 length;

+    /* [size_is] */ NC_INFO *info;

+    } 	NC_INFO_LIST;

+

+typedef struct _V4_CRED

+    {

+    CC_UCHAR kversion;

+    CC_CHAR principal[ 41 ];

+    CC_CHAR principal_instance[ 41 ];

+    CC_CHAR service[ 41 ];

+    CC_CHAR service_instance[ 41 ];

+    CC_CHAR realm[ 41 ];

+    CC_UCHAR session_key[ 8 ];

+    CC_INT32 kvno;

+    CC_INT32 str_to_key;

+    CC_INT32 issue_date;

+    CC_INT32 lifetime;

+    CC_UINT32 address;

+    CC_INT32 ticket_sz;

+    CC_UCHAR ticket[ 1250 ];

+    } 	V4_CRED;

+

+typedef struct _CC_DATA

+    {

+    CC_UINT32 type;

+    CC_UINT32 length;

+    /* [size_is] */ CC_UCHAR *data;

+    } 	CC_DATA;

+

+typedef struct _CC_DATA_LIST

+    {

+    CC_UINT32 count;

+    /* [size_is] */ CC_DATA *data;

+    } 	CC_DATA_LIST;

+

+typedef struct _V5_CRED

+    {

+    /* [string] */ CC_CHAR *client;

+    /* [string] */ CC_CHAR *server;

+    CC_DATA keyblock;

+    CC_TIME_T authtime;

+    CC_TIME_T starttime;

+    CC_TIME_T endtime;

+    CC_TIME_T renew_till;

+    CC_UINT32 is_skey;

+    CC_UINT32 ticket_flags;

+    CC_DATA_LIST addresses;

+    CC_DATA ticket;

+    CC_DATA second_ticket;

+    CC_DATA_LIST authdata;

+    } 	V5_CRED;

+

+typedef /* [switch_type] */ union _CRED_PTR_UNION

+    {

+    /* [case()] */ V4_CRED *pV4Cred;

+    /* [case()] */ V5_CRED *pV5Cred;

+    } 	CRED_PTR_UNION;

+

+typedef struct _CRED_UNION

+    {

+    CC_INT32 cred_type;

+    /* [switch_is] */ CRED_PTR_UNION cred;

+    } 	CRED_UNION;

+

+CC_INT32 rcc_initialize( 

+    /* [out] */ HCTX *pctx);

+

+CC_INT32 rcc_shutdown( 

+    /* [out][in] */ HCTX *pctx);

+

+CC_INT32 rcc_get_change_time( 

+    /* [in] */ HCTX ctx,

+    /* [out] */ CC_TIME_T *time);

+

+CC_INT32 rcc_create( 

+    /* [in] */ HCTX ctx,

+    /* [string][in] */ const CC_CHAR *name,

+    /* [string][in] */ const CC_CHAR *principal,

+    /* [in] */ CC_INT32 vers,

+    /* [in] */ CC_UINT32 flags,

+    /* [out] */ HCACHE *pcache);

+

+CC_INT32 rcc_open( 

+    /* [in] */ HCTX ctx,

+    /* [string][in] */ const CC_CHAR *name,

+    /* [in] */ CC_INT32 vers,

+    /* [in] */ CC_UINT32 flags,

+    /* [out] */ HCACHE *pcache);

+

+CC_INT32 rcc_close( 

+    /* [out][in] */ HCACHE *pcache);

+

+CC_INT32 rcc_destroy( 

+    /* [out][in] */ HCACHE *pcache);

+

+CC_INT32 rcc_seq_fetch_NCs_begin( 

+    /* [in] */ HCTX ctx,

+    /* [out] */ HCACHE_ITER *piter);

+

+CC_INT32 rcc_seq_fetch_NCs_end( 

+    /* [out][in] */ HCACHE_ITER *piter);

+

+CC_INT32 rcc_seq_fetch_NCs_next( 

+    /* [in] */ HCACHE_ITER iter,

+    /* [out] */ HCACHE *pcache);

+

+CC_INT32 rcc_seq_fetch_NCs( 

+    /* [in] */ HCTX ctx,

+    /* [out][in] */ HCACHE_ITER *piter,

+    /* [out] */ HCACHE *pcache);

+

+CC_INT32 rcc_get_NC_info( 

+    /* [in] */ HCTX ctx,

+    /* [out] */ NC_INFO_LIST **info_list);

+

+CC_INT32 rcc_get_name( 

+    /* [in] */ HCACHE cache,

+    /* [string][out] */ CC_CHAR **name);

+

+CC_INT32 rcc_set_principal( 

+    /* [in] */ HCACHE cache,

+    /* [in] */ CC_INT32 vers,

+    /* [string][in] */ const CC_CHAR *principal);

+

+CC_INT32 rcc_get_principal( 

+    /* [in] */ HCACHE cache,

+    /* [string][out] */ CC_CHAR **principal);

+

+CC_INT32 rcc_get_cred_version( 

+    /* [in] */ HCACHE cache,

+    /* [out] */ CC_INT32 *vers);

+

+CC_INT32 rcc_lock_request( 

+    /* [in] */ HCACHE cache,

+    /* [in] */ CC_INT32 lock_type);

+

+CC_INT32 rcc_store( 

+    /* [in] */ HCACHE cache,

+    /* [in] */ CRED_UNION cred);

+

+CC_INT32 rcc_remove_cred( 

+    /* [in] */ HCACHE cache,

+    /* [in] */ CRED_UNION cred);

+

+CC_INT32 rcc_seq_fetch_creds( 

+    /* [in] */ HCACHE cache,

+    /* [out][in] */ HCRED_ITER *piter,

+    /* [out] */ CRED_UNION **cred);

+

+CC_INT32 rcc_seq_fetch_creds_begin( 

+    /* [in] */ HCACHE cache,

+    /* [out] */ HCRED_ITER *piter);

+

+CC_INT32 rcc_seq_fetch_creds_end( 

+    /* [out][in] */ HCRED_ITER *piter);

+

+CC_INT32 rcc_seq_fetch_creds_next( 

+    /* [in] */ HCRED_ITER iter,

+    /* [out] */ CRED_UNION **cred);

+

+CC_UINT32 Connect( 

+    /* [string][in] */ CC_CHAR *name);

+

+void Shutdown( void);

+

+

+extern handle_t ccapi_IfHandle;

+

+

+extern RPC_IF_HANDLE ccapi_ClientIfHandle;

+extern RPC_IF_HANDLE ccapi_ServerIfHandle;

+#endif /* __ccapi_INTERFACE_DEFINED__ */

+

+/* Additional Prototypes for ALL interfaces */

+

+void __RPC_USER HCTX_rundown( HCTX );

+void __RPC_USER HCACHE_rundown( HCACHE );

+void __RPC_USER HCACHE_ITER_rundown( HCACHE_ITER );

+void __RPC_USER HCRED_ITER_rundown( HCRED_ITER );

+

+/* end of Additional Prototypes */

+

+#ifdef __cplusplus

+}

+#endif

+

+#endif

+

+

diff --git a/src/ccapi/lib/win/OldCC/client.cxx b/src/ccapi/lib/win/OldCC/client.cxx
new file mode 100644
index 0000000000..1f9051093f
--- /dev/null
+++ b/src/ccapi/lib/win/OldCC/client.cxx
@@ -0,0 +1,389 @@
+/*

+ * $Header$

+ *

+ * Copyright 2008 Massachusetts Institute of Technology.

+ * All Rights Reserved.

+ *

+ * Export of this software from the United States of America may

+ * require a specific license from the United States Government.

+ * It is the responsibility of any person or organization contemplating

+ * export to obtain such a license before exporting.

+ *

+ * WITHIN THAT CONSTRAINT, permission to use, copy, modify, and

+ * distribute this software and its documentation for any purpose and

+ * without fee is hereby granted, provided that the above copyright

+ * notice appear in all copies and that both that copyright notice and

+ * this permission notice appear in supporting documentation, and that

+ * the name of M.I.T. not be used in advertising or publicity pertaining

+ * to distribution of the software without specific, written prior

+ * permission.  Furthermore if you modify this software you must label

+ * your software as modified software and not distribute it in such a

+ * fashion that it might be confused with the original M.I.T. software.

+ * M.I.T. makes no representations about the suitability of

+ * this software for any purpose.  It is provided "as is" without express

+ * or implied warranty.

+ */

+

+#include "stdio.h"    // KPKDBG

+

+#include "ccs_request.h"

+

+#include "ccapi.h"

+#include "util.h"

+

+extern "C" {

+#include "cci_debugging.h"

+#include "tls.h"    // KPKDBG

+    }

+

+#include "client.h"

+#include "init.hxx"

+#include "name.h"

+#include "secure.hxx"

+

+#define SECONDS_TO_WAIT 10

+

+#define STARTUP "CLIENT STARTUP: "

+#define DISCONNECT "CLIENT DISCONNECT: "

+

+bool Client::s_init = false;

+CcOsLock Client::sLock;

+

+static DWORD bind_client(char* ep OPTIONAL, Init::InitInfo& info, LPSTR* endpoint) {

+    DWORD status = 0;

+    unsigned char * pszStringBinding = NULL;

+

+    if (!ep) {

+        status = alloc_name(endpoint, "ep", isNT());

+        } 

+    else {

+        *endpoint = ep;

+        }

+

+    if (!status) {

+        /* Use a convenience function to concatenate the elements of */

+        /* the string binding into the proper sequence.              */

+        status = RpcStringBindingCompose(0,            // uuid

+                                         (unsigned char*)"ncalrpc",    // protseq

+                                         0,            // address

+                                         (unsigned char*)(*endpoint),  // endpoint

+                                         0,            // options

+                                         &pszStringBinding);

+        cci_check_error(status);

+        }

+            

+    if (!status) {

+        /* Set the binding handle that will be used to bind to the server. */

+        status = RpcBindingFromStringBinding(pszStringBinding, &ccs_request_IfHandle);

+        cci_check_error(status);

+        }

+

+    if (!status) {

+        // Win9x might call RpcBindingSetAuthInfo (not Ex), but it does not

+        // quite work on Win9x...

+        if (isNT()) {

+            RPC_SECURITY_QOS qos;

+            qos.Version = RPC_C_SECURITY_QOS_VERSION;

+            qos.Capabilities = RPC_C_QOS_CAPABILITIES_DEFAULT;

+            qos.IdentityTracking = RPC_C_QOS_IDENTITY_STATIC;

+            qos.ImpersonationType = RPC_C_IMP_LEVEL_IDENTIFY;

+

+            status = info.fRpcBindingSetAuthInfoEx(ccs_request_IfHandle,

+                                                   0, // principal

+                                                   RPC_C_AUTHN_LEVEL_CONNECT,

+                                                   RPC_C_AUTHN_WINNT,

+                                                   0, // current address space

+                                                   RPC_C_AUTHZ_NAME,

+                                                   &qos);

+            cci_check_error(status);

+            }

+        }

+

+    if (pszStringBinding) {

+        DWORD status = RpcStringFree(&pszStringBinding); 

+        cci_check_error(status);

+        }

+    return cci_check_error(status);

+    }

+

+DWORD find_server(Init::InitInfo& info, LPSTR endpoint) {

+    DWORD               status      = 0;

+    LPSTR               event_name  = 0;

+    HANDLE              hEvent      = 0;

+    SECURITY_ATTRIBUTES sa          = { 0 };

+    PSECURITY_ATTRIBUTES psa        = 0;

+    STARTUPINFO         si          = { 0 };

+    PROCESS_INFORMATION pi          = { 0 };

+    char*               szExe       = 0;

+    char*               szDir       = 0;

+    BOOL                bRes        = FALSE;

+    char*               cmdline     = NULL;

+#if 0

+    HANDLE hToken = 0;

+#endif

+

+    psa = isNT() ? &sa : 0;

+

+//    cci_debug_printf("%s Looking for server; ccs_request_IfHandle:0x%X", __FUNCTION__, ccs_request_IfHandle);

+    status = cci_check_error(RpcMgmtIsServerListening(ccs_request_IfHandle));

+    if (status == RPC_S_NOT_LISTENING) {

+//        cci_debug_printf("  Server *NOT* found!");

+        si.cb = sizeof(si);

+

+        status = alloc_module_dir_name(CCAPI_DLL, &szDir);

+

+        if (!status) {

+            status = alloc_module_dir_name_with_file(CCAPI_DLL, CCAPI_EXE, &szExe);

+            }

+

+        if (!status) {

+            status = alloc_name(&event_name, "startup", isNT());

+            cci_check_error(status);

+            }

+

+        if (!status) {

+            if (isNT()) {

+                sa.nLength = sizeof(sa);

+                status = alloc_own_security_descriptor_NT(&sa.lpSecurityDescriptor);

+                cci_check_error(status);

+                }

+            }

+

+        if (!status) {

+            hEvent = CreateEvent(psa, FALSE, FALSE, event_name);

+            cci_debug_printf("  CreateEvent(... %s) returned hEvent 0x%X", event_name, hEvent);

+            if (!hEvent) status = GetLastError();

+            }

+

+        if (!status) {

+

+#if 0

+            if (SecureClient::IsImp()) {

+                cci_debug_printf(STARTUP "Token is impersonation token"));

+                SecureClient::DuplicateImpAsPrimary(hToken);

+                } 

+            else {

+                cci_debug_printf(STARTUP "Token is NOT impersonation token"));

+                }

+#endif

+

+#if 0

+            if (hToken)

+                bRes = CreateProcessAsUser(hToken,

+                                       szExe, // app name

+                                       NULL, // cmd line

+                                       psa, // SA

+                                       psa, // SA

+                                       FALSE, 

+                                       CREATE_NEW_PROCESS_GROUP | 

+                                       //CREATE_NEW_CONSOLE |

+                                       NORMAL_PRIORITY_CLASS |

+                                       // CREATE_NO_WINDOW |

+                                       DETACHED_PROCESS |

+                                       0

+                                       ,

+                                       NULL, // environment

+                                       szDir, // current dir

+                                       &si,

+                                       &pi);

+            else

+#endif

+                alloc_cmdline_2_args(szExe, endpoint, "-D", &cmdline);

+                bRes = CreateProcess(  szExe,       // app name

+                                       NULL, //cmdline,     // cmd line is <server endpoint -[DC]>

+                                       psa,         // SA

+                                       psa,         // SA

+                                       FALSE, 

+                                       CREATE_NEW_PROCESS_GROUP | 

+                                       CREATE_NEW_CONSOLE |

+                                       NORMAL_PRIORITY_CLASS |

+                                       // CREATE_NO_WINDOW |

+                                       // DETACHED_PROCESS |    /* KPK TODO: was set - restore */

+                                       0

+                                       ,

+                                       NULL,        // environment

+                                       szDir,       // current dir

+                                       &si,

+                                       &pi);

+            if (!bRes) {

+                status = GetLastError();

+                cci_debug_printf("  CreateProcess returned %d; LastError: %d", bRes, status);

+                }

+            cci_debug_printf("  Waiting...");

+            }

+        cci_check_error(status);

+

+        if (!status) {

+            status = WaitForSingleObject(hEvent, (SECONDS_TO_WAIT)*1000);

+            status = RpcMgmtIsServerListening(ccs_request_IfHandle);

+            }

+        } 

+    else if (status) {

+            cci_debug_printf("  unexpected error while looking for server: 0D%d / 0U%u / 0X%X", status, status, status);

+            } 

+

+#if 0

+    if (hToken)

+        CloseHandle(hToken);

+#endif

+    if (szDir)                      free_alloc_p(&szDir);

+    if (szExe)                      free_alloc_p(&szExe);

+    if (hEvent)                     CloseHandle(hEvent);

+    if (pi.hThread)                 CloseHandle(pi.hThread);

+    if (pi.hProcess)                CloseHandle(pi.hProcess);

+    if (sa.lpSecurityDescriptor)    free_alloc_p(&sa.lpSecurityDescriptor);

+    return cci_check_error(status);

+

+}

+

+static

+DWORD

+authenticate_server(Init::InitInfo& info) {

+    DWORD               challenge       = 17; // XXX - maybe use random number

+    DWORD               desired_response= challenge + 1;

+    HANDLE              hMap            = 0;

+    LPSTR               mem_name        = 0;

+    PDWORD              pvalue          = 0;

+    CC_UINT32           response        = 0;

+    SECURITY_ATTRIBUTES sa              = { 0 };

+    DWORD               status          = 0;

+

+    cci_debug_printf("%s entry", __FUNCTION__);

+

+    status = alloc_name(&mem_name, "auth", isNT());

+    cci_check_error(status);

+

+    if (!status) {

+        if (isNT()) {

+            sa.nLength = sizeof(sa);

+            status = alloc_own_security_descriptor_NT(&sa.lpSecurityDescriptor);

+            }

+        }

+    cci_check_error(status);

+

+    if (!status) {

+        hMap = CreateFileMapping(INVALID_HANDLE_VALUE, isNT() ? &sa : 0, 

+                                 PAGE_READWRITE, 0, sizeof(DWORD), mem_name);

+        if (!hMap)

+        status = GetLastError();

+        }

+    cci_check_error(status);

+

+    if (!status) {

+        pvalue = (PDWORD)MapViewOfFile(hMap, FILE_MAP_ALL_ACCESS, 0, 0, 0);

+        if (!pvalue) status = GetLastError();

+        }

+    cci_check_error(status);

+

+    if (!status) {

+        *pvalue = challenge;

+

+        RpcTryExcept {

+            response = ccs_authenticate( (CC_CHAR*)mem_name );

+            }

+        RpcExcept(1) {

+            status = RpcExceptionCode();

+            cci_check_error(status);

+            }

+        RpcEndExcept;

+        }

+    cci_check_error(status);

+

+    if (!status) {

+        // Check response

+        if ((response != desired_response) && (*pvalue != desired_response)) {

+            cci_debug_printf("  Could not authenticate server.");

+            status = ERROR_ACCESS_DENIED; // XXX - CO_E_NOMATCHINGSIDFOUND?

+            } 

+        else {

+            cci_debug_printf("  Server authenticated!");

+            }

+        cci_check_error(status);

+        }

+

+    free_alloc_p(&mem_name);

+    free_alloc_p(&sa.lpSecurityDescriptor);

+    if (pvalue) {

+        BOOL ok = UnmapViewOfFile(pvalue);

+//        DEBUG_ASSERT(ok);

+        }

+    if (hMap) CloseHandle(hMap);

+    return status;

+}

+

+DWORD

+Client::Disconnect() {

+    DWORD status = 0;

+    if (ccs_request_IfHandle) {

+        /*  The calls to the remote procedures are complete. */

+        /*  Free the binding handle           */

+        status = RpcBindingFree(&ccs_request_IfHandle);

+        }

+    s_init  = false;

+    return status;

+    }

+

+DWORD

+Client::Connect(char* ep OPTIONAL) {

+    LPSTR   endpoint    = 0;

+    DWORD   status      = 0;

+

+    if (!ccs_request_IfHandle) {

+        Init::InitInfo info;

+

+        status = Init::Info(info);

+        cci_check_error(status);

+

+        if (!status) {

+            status = bind_client(ep, info, &endpoint);

+            cci_check_error(status);

+            }

+

+        if (!status) {

+            status = find_server(info, endpoint);

+            cci_check_error(status);

+            }

+

+        if (!status) {

+            status = authenticate_server(info);

+            cci_check_error(status);

+            }

+        }

+

+

+    if (endpoint && (endpoint != ep)) free_alloc_p(&endpoint);

+    

+    if (status) Client::Disconnect();

+    return status;

+    }

+

+DWORD Client::Initialize(char* ep OPTIONAL) {

+    CcAutoLock AL(Client::sLock);

+    SecureClient s;

+    ccs_request_IfHandle  = NULL;

+    if (s_init) return 0;

+    DWORD status = Client::Connect(ep);

+    if (!status) s_init = true;

+    return status;

+    }

+

+DWORD Client::Cleanup() {

+    CcAutoLock AL(Client::sLock);

+    SecureClient s;

+    return Client::Disconnect();

+    }

+

+DWORD Client::Reconnect(char* ep OPTIONAL) {

+    CcAutoLock AL(Client::sLock);

+    SecureClient s;

+    DWORD status = 0;

+

+    if (Initialized()) {

+        DWORD status = Client::Cleanup();

+        }

+    if ( (!status) ) {

+        status = Client::Initialize(ep);

+        }

+

+    return status;

+    }

diff --git a/src/ccapi/lib/win/OldCC/client.h b/src/ccapi/lib/win/OldCC/client.h
new file mode 100644
index 0000000000..f263ce1c0e
--- /dev/null
+++ b/src/ccapi/lib/win/OldCC/client.h
@@ -0,0 +1,61 @@
+/*

+ * $Header$

+ *

+ * Copyright 2008 Massachusetts Institute of Technology.

+ * All Rights Reserved.

+ *

+ * Export of this software from the United States of America may

+ * require a specific license from the United States Government.

+ * It is the responsibility of any person or organization contemplating

+ * export to obtain such a license before exporting.

+ *

+ * WITHIN THAT CONSTRAINT, permission to use, copy, modify, and

+ * distribute this software and its documentation for any purpose and

+ * without fee is hereby granted, provided that the above copyright

+ * notice appear in all copies and that both that copyright notice and

+ * this permission notice appear in supporting documentation, and that

+ * the name of M.I.T. not be used in advertising or publicity pertaining

+ * to distribution of the software without specific, written prior

+ * permission.  Furthermore if you modify this software you must label

+ * your software as modified software and not distribute it in such a

+ * fashion that it might be confused with the original M.I.T. software.

+ * M.I.T. makes no representations about the suitability of

+ * this software for any purpose.  It is provided "as is" without express

+ * or implied warranty.

+ */

+

+#ifndef __DLL_CLIENT_H__

+#define __DLL_CLIENT_H__

+

+#include "autolock.hxx"

+#include "init.hxx"

+

+class Client {

+public:

+    static DWORD Initialize(char* ep OPTIONAL);

+    static DWORD Cleanup();

+    static DWORD Reconnect(char* ep OPTIONAL);

+

+    static bool Initialized() { return s_init; }

+

+    static CcOsLock sLock;

+

+private:

+    static bool s_init;

+

+    static DWORD Disconnect();

+    static DWORD Connect(char* ep OPTIONAL);

+    };

+

+#define CLIENT_INIT_EX(trap, error) \

+do \

+{ \

+    INIT_INIT_EX(trap, error); \

+    if (!Client::Initialized()) \

+    { \

+        DWORD status = Client::Initialize(0); \

+        if (status) return (trap) ? (error) : status; \

+    } \

+} while(0)

+

+#endif

diff --git a/src/ccapi/lib/win/OldCC/rpc.cxx b/src/ccapi/lib/win/OldCC/rpc.cxx
new file mode 100644
index 0000000000..332f1c503b
--- /dev/null
+++ b/src/ccapi/lib/win/OldCC/rpc.cxx
@@ -0,0 +1,79 @@
+/*

+ * $Header$

+ *

+ * Copyright 2008 Massachusetts Institute of Technology.

+ * All Rights Reserved.

+ *

+ * Export of this software from the United States of America may

+ * require a specific license from the United States Government.

+ * It is the responsibility of any person or organization contemplating

+ * export to obtain such a license before exporting.

+ *

+ * WITHIN THAT CONSTRAINT, permission to use, copy, modify, and

+ * distribute this software and its documentation for any purpose and

+ * without fee is hereby granted, provided that the above copyright

+ * notice appear in all copies and that both that copyright notice and

+ * this permission notice appear in supporting documentation, and that

+ * the name of M.I.T. not be used in advertising or publicity pertaining

+ * to distribution of the software without specific, written prior

+ * permission.  Furthermore if you modify this software you must label

+ * your software as modified software and not distribute it in such a

+ * fashion that it might be confused with the original M.I.T. software.

+ * M.I.T. makes no representations about the suitability of

+ * this software for any purpose.  It is provided "as is" without express

+ * or implied warranty.

+ */

+

+#include <stdlib.h>

+#include <stdio.h>

+

+extern "C" {

+#include "CredentialsCache.h"

+#include "secure.hxx"

+#include "client.h"

+#include "autolock.hxx"

+#include "cci_debugging.h"

+    }

+

+extern HANDLE hCCAPIv2Mutex;

+

+#define MAKE_RPC_CALL(rc, x) \

+do { \

+    WaitForSingleObject( hCCAPIv2Mutex, INFINITE ); \

+    SecureClient* s = 0; \

+    SecureClient::Start(s); \

+    CcAutoLock* a = 0; \

+    CcAutoLock::Start(a, Client::sLock); \

+    RpcTryExcept { \

+    cci_debug_printf("RpcTry: #x"); \

+        x; \

+    } \

+    RpcExcept(1) { \

+        rc = handle_exception(RpcExceptionCode()); \

+    } \

+    RpcEndExcept; \

+    CcAutoLock::Stop(a); \

+    SecureClient::Stop(s); \

+    ReleaseMutex( hCCAPIv2Mutex ); \

+} while (0)

+

+static

+DWORD

+handle_exception(DWORD code) {

+    cci_debug_printf("Runtime reported exception %u", code);

+    if (code == RPC_S_SERVER_UNAVAILABLE) {

+        Client::Reconnect(0);

+        }

+    return 4;

+    }

+

+//////////////////////////////////////////////////////////////////////////////

+

+cc_int32 cc_initialize() {

+

+    CLIENT_INIT_EX(true, 4);

+    cc_int32 rc = ccNoError;

+

+    MAKE_RPC_CALL(rc, rc = 5);

+    return rc;

+    }
\ No newline at end of file