Package deltavsoft :: Module rcfproto
[frames] | no frames]

Source Code for Module deltavsoft.rcfproto

   1  # This file was automatically generated by SWIG (http://www.swig.org). 
   2  # Version 2.0.4 
   3  # 
   4  # Do not make changes to this file unless you know what you are doing--modify 
   5  # the SWIG interface file instead. 
   6   
   7   
   8   
   9  import google.protobuf 
  10  import google.protobuf.service 
  11   
  12  from sys import version_info 
  13  if version_info >= (2,6,0): 
14 - def swig_import_helper():
15 from os.path import dirname 16 import imp 17 fp = None 18 try: 19 fp, pathname, description = imp.find_module('_rcfproto', [dirname(__file__)]) 20 except ImportError: 21 import _rcfproto 22 return _rcfproto 23 if fp is not None: 24 try: 25 _mod = imp.load_module('_rcfproto', fp, pathname, description) 26 finally: 27 fp.close() 28 return _mod
29 #_rcfproto = swig_import_helper() 30 import util 31 _rcfproto = util.LoadRCFProtoNativeDll() 32 33 del swig_import_helper 34 else: 35 import _rcfproto 36 del version_info 37 try: 38 _swig_property = property 39 except NameError: 40 pass # Python < 2.2 doesn't have 'property'.
41 -def _swig_setattr_nondynamic(self,class_type,name,value,static=1):
42 if (name == "thisown"): return self.this.own(value) 43 if (name == "this"): 44 if type(value).__name__ == 'SwigPyObject': 45 self.__dict__[name] = value 46 return 47 method = class_type.__swig_setmethods__.get(name,None) 48 if method: return method(self,value) 49 if (not static): 50 self.__dict__[name] = value 51 else: 52 raise AttributeError("You cannot add attributes to %s" % self)
53
54 -def _swig_setattr(self,class_type,name,value):
55 return _swig_setattr_nondynamic(self,class_type,name,value,0)
56
57 -def _swig_getattr(self,class_type,name):
58 if (name == "thisown"): return self.this.own() 59 method = class_type.__swig_getmethods__.get(name,None) 60 if method: return method(self) 61 raise AttributeError(name)
62
63 -def _swig_repr(self):
64 try: strthis = "proxy of " + self.this.__repr__() 65 except: strthis = "" 66 return "<%s.%s; %s >" % (self.__class__.__module__, self.__class__.__name__, strthis,)
67 68 try: 69 _object = object 70 _newclass = 1 71 except AttributeError:
72 - class _object : pass
73 _newclass = 0 74 75 76 try: 77 import weakref 78 weakref_proxy = weakref.proxy 79 except: 80 weakref_proxy = lambda x: x 81 82
83 -class SwigPyIterator(_object):
84 __swig_setmethods__ = {} 85 __setattr__ = lambda self, name, value: _swig_setattr(self, SwigPyIterator, name, value) 86 __swig_getmethods__ = {} 87 __getattr__ = lambda self, name: _swig_getattr(self, SwigPyIterator, name)
88 - def __init__(self, *args, **kwargs): raise AttributeError("No constructor defined - class is abstract")
89 __repr__ = _swig_repr 90 __swig_destroy__ = _rcfproto.delete_SwigPyIterator 91 __del__ = lambda self : None;
92 - def Value(self): return _rcfproto.SwigPyIterator_value(self)
93 - def Incr(self, n = 1): return _rcfproto.SwigPyIterator_incr(self, n)
94 - def Decr(self, n = 1): return _rcfproto.SwigPyIterator_decr(self, n)
95 - def Distance(self, *args): return _rcfproto.SwigPyIterator_distance(self, *args)
96 - def Equal(self, *args): return _rcfproto.SwigPyIterator_equal(self, *args)
97 - def Copy(self): return _rcfproto.SwigPyIterator_copy(self)
98 - def Next(self): return _rcfproto.SwigPyIterator_next(self)
99 - def __next__(self): return _rcfproto.SwigPyIterator___next__(self)
100 - def Previous(self): return _rcfproto.SwigPyIterator_previous(self)
101 - def Advance(self, *args): return _rcfproto.SwigPyIterator_advance(self, *args)
102 - def __eq__(self, *args): return _rcfproto.SwigPyIterator___eq__(self, *args)
103 - def __ne__(self, *args): return _rcfproto.SwigPyIterator___ne__(self, *args)
104 - def __iadd__(self, *args): return _rcfproto.SwigPyIterator___iadd__(self, *args)
105 - def __isub__(self, *args): return _rcfproto.SwigPyIterator___isub__(self, *args)
106 - def __add__(self, *args): return _rcfproto.SwigPyIterator___add__(self, *args)
107 - def __sub__(self, *args): return _rcfproto.SwigPyIterator___sub__(self, *args)
108 - def __iter__(self): return self
109 _SwigPyIterator_swigregister = _rcfproto.SwigPyIterator_swigregister 110 _SwigPyIterator_swigregister(SwigPyIterator) 111 112 SHARED_PTR_DISOWN = _rcfproto.SHARED_PTR_DISOWN
113 -class TransportProtocolList(_object):
114 __swig_setmethods__ = {} 115 __setattr__ = lambda self, name, value: _swig_setattr(self, TransportProtocolList, name, value) 116 __swig_getmethods__ = {} 117 __getattr__ = lambda self, name: _swig_getattr(self, TransportProtocolList, name) 118 __repr__ = _swig_repr
119 - def Iterator(self): return _rcfproto.TransportProtocolList_iterator(self)
120 - def __iter__(self): return self.iterator()
121 - def __nonzero__(self): return _rcfproto.TransportProtocolList___nonzero__(self)
122 - def __bool__(self): return _rcfproto.TransportProtocolList___bool__(self)
123 - def __len__(self): return _rcfproto.TransportProtocolList___len__(self)
124 - def Pop(self): return _rcfproto.TransportProtocolList_pop(self)
125 - def __getslice__(self, *args): return _rcfproto.TransportProtocolList___getslice__(self, *args)
126 - def __setslice__(self, *args): return _rcfproto.TransportProtocolList___setslice__(self, *args)
127 - def __delslice__(self, *args): return _rcfproto.TransportProtocolList___delslice__(self, *args)
128 - def __delitem__(self, *args): return _rcfproto.TransportProtocolList___delitem__(self, *args)
129 - def __getitem__(self, *args): return _rcfproto.TransportProtocolList___getitem__(self, *args)
130 - def __setitem__(self, *args): return _rcfproto.TransportProtocolList___setitem__(self, *args)
131 - def Append(self, *args): return _rcfproto.TransportProtocolList_append(self, *args)
132 - def Empty(self): return _rcfproto.TransportProtocolList_empty(self)
133 - def Size(self): return _rcfproto.TransportProtocolList_size(self)
134 - def Clear(self): return _rcfproto.TransportProtocolList_clear(self)
135 - def Swap(self, *args): return _rcfproto.TransportProtocolList_swap(self, *args)
136 - def Get_allocator(self): return _rcfproto.TransportProtocolList_get_allocator(self)
137 - def Begin(self): return _rcfproto.TransportProtocolList_begin(self)
138 - def End(self): return _rcfproto.TransportProtocolList_end(self)
139 - def Rbegin(self): return _rcfproto.TransportProtocolList_rbegin(self)
140 - def Rend(self): return _rcfproto.TransportProtocolList_rend(self)
141 - def Pop_back(self): return _rcfproto.TransportProtocolList_pop_back(self)
142 - def Erase(self, *args): return _rcfproto.TransportProtocolList_erase(self, *args)
143 - def __init__(self, *args):
144 this = _rcfproto.new_TransportProtocolList(*args) 145 try: self.this.append(this) 146 except: self.this = this
147 - def Push_back(self, *args): return _rcfproto.TransportProtocolList_push_back(self, *args)
148 - def Front(self): return _rcfproto.TransportProtocolList_front(self)
149 - def Back(self): return _rcfproto.TransportProtocolList_back(self)
150 - def Assign(self, *args): return _rcfproto.TransportProtocolList_assign(self, *args)
151 - def Resize(self, *args): return _rcfproto.TransportProtocolList_resize(self, *args)
152 - def Insert(self, *args): return _rcfproto.TransportProtocolList_insert(self, *args)
153 - def Reserve(self, *args): return _rcfproto.TransportProtocolList_reserve(self, *args)
154 - def Capacity(self): return _rcfproto.TransportProtocolList_capacity(self)
155 __swig_destroy__ = _rcfproto.delete_TransportProtocolList 156 __del__ = lambda self : None; 157 _TransportProtocolList_swigregister = _rcfproto.TransportProtocolList_swigregister 158 _TransportProtocolList_swigregister(TransportProtocolList) 159 160 161
162 -def Init():
163 """Reference-counted initialization of RCF framework. May be called multiple times (see deinit()). """ 164 165 return _rcfproto.init()
166 init = _rcfproto.init 167 168
169 -def Deinit():
170 """Reference-counted deinitialization of RCF framework. For actual deinitialization to take place, deinit() must be called as many times as init() has been called. """ 171 172 return _rcfproto.deinit()
173 deinit = _rcfproto.deinit
174 -class LogTarget(_object):
175 """Base class for log targets. Log targets are passed to the enableLogging() function, to configure RCF logging. 176 177 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 178 179 __swig_setmethods__ = {} 180 __setattr__ = lambda self, name, value: _swig_setattr(self, LogTarget, name, value) 181 __swig_getmethods__ = {} 182 __getattr__ = lambda self, name: _swig_getattr(self, LogTarget, name)
183 - def __init__(self, *args, **kwargs): raise AttributeError("No constructor defined")
184 __repr__ = _swig_repr 185 __swig_destroy__ = _rcfproto.delete_LogTarget 186 __del__ = lambda self : None;
187 _LogTarget_swigregister = _rcfproto.LogTarget_swigregister 188 _LogTarget_swigregister(LogTarget) 189
190 -class LogToStdout(LogTarget):
191 """Configures log output to be directed to standard output. 192 193 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 194 195 __swig_setmethods__ = {} 196 for _s in [LogTarget]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 197 __setattr__ = lambda self, name, value: _swig_setattr(self, LogToStdout, name, value) 198 __swig_getmethods__ = {} 199 for _s in [LogTarget]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 200 __getattr__ = lambda self, name: _swig_getattr(self, LogToStdout, name) 201 __repr__ = _swig_repr
202 - def __init__(self):
203 this = _rcfproto.new_LogToStdout() 204 try: self.this.append(this) 205 except: self.this = this
206 __swig_destroy__ = _rcfproto.delete_LogToStdout 207 __del__ = lambda self : None; 208 _LogToStdout_swigregister = _rcfproto.LogToStdout_swigregister 209 _LogToStdout_swigregister(LogToStdout) 210
211 -class LogToDebugWindow(LogTarget):
212 """Configures log output to be directed to Windows debug output. 213 214 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 215 216 __swig_setmethods__ = {} 217 for _s in [LogTarget]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 218 __setattr__ = lambda self, name, value: _swig_setattr(self, LogToDebugWindow, name, value) 219 __swig_getmethods__ = {} 220 for _s in [LogTarget]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 221 __getattr__ = lambda self, name: _swig_getattr(self, LogToDebugWindow, name) 222 __repr__ = _swig_repr
223 - def __init__(self):
224 this = _rcfproto.new_LogToDebugWindow() 225 try: self.this.append(this) 226 except: self.this = this
227 __swig_destroy__ = _rcfproto.delete_LogToDebugWindow 228 __del__ = lambda self : None; 229 _LogToDebugWindow_swigregister = _rcfproto.LogToDebugWindow_swigregister 230 _LogToDebugWindow_swigregister(LogToDebugWindow) 231
232 -class LogToEventLog(LogTarget):
233 """Configures log output to be directed to the Windows event log. 234 235 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 236 237 __swig_setmethods__ = {} 238 for _s in [LogTarget]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 239 __setattr__ = lambda self, name, value: _swig_setattr(self, LogToEventLog, name, value) 240 __swig_getmethods__ = {} 241 for _s in [LogTarget]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 242 __getattr__ = lambda self, name: _swig_getattr(self, LogToEventLog, name) 243 __repr__ = _swig_repr
244 - def __init__(self, *args):
245 this = _rcfproto.new_LogToEventLog(*args) 246 try: self.this.append(this) 247 except: self.this = this
248 __swig_destroy__ = _rcfproto.delete_LogToEventLog 249 __del__ = lambda self : None; 250 _LogToEventLog_swigregister = _rcfproto.LogToEventLog_swigregister 251 _LogToEventLog_swigregister(LogToEventLog) 252
253 -class LogToFile(LogTarget):
254 """Configures log output to be directed to a log file. 255 256 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 257 258 __swig_setmethods__ = {} 259 for _s in [LogTarget]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 260 __setattr__ = lambda self, name, value: _swig_setattr(self, LogToFile, name, value) 261 __swig_getmethods__ = {} 262 for _s in [LogTarget]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 263 __getattr__ = lambda self, name: _swig_getattr(self, LogToFile, name) 264 __repr__ = _swig_repr
265 - def __init__(self, *args):
266 this = _rcfproto.new_LogToFile(*args) 267 try: self.this.append(this) 268 except: self.this = this
269 __swig_destroy__ = _rcfproto.delete_LogToFile 270 __del__ = lambda self : None; 271 _LogToFile_swigregister = _rcfproto.LogToFile_swigregister 272 _LogToFile_swigregister(LogToFile) 273 274 275
276 -def EnableLogging(*args):
277 """Configures logging for the RCF runtime. logTarget is where the log output will appear. loglevel is the detail level of the log, ranging from 0 (no logging), 1 (errors-only logging) to 4 (maximum detail logging). logFormat is an optional parameter describing the format of the log output. """ 278 279 return _rcfproto.enableLogging(*args)
280 enableLogging = _rcfproto.enableLogging 281 282
283 -def DisableLogging():
284 """Disables logging for the RCF runtime. """ 285 286 return _rcfproto.disableLogging()
287 disableLogging = _rcfproto.disableLogging 288 Tp_Unspecified = _rcfproto.Tp_Unspecified 289 Tp_Clear = _rcfproto.Tp_Clear 290 Tp_Ntlm = _rcfproto.Tp_Ntlm 291 Tp_Kerberos = _rcfproto.Tp_Kerberos 292 Tp_Negotiate = _rcfproto.Tp_Negotiate 293 Tp_Ssl = _rcfproto.Tp_Ssl 294 Tt_Unknown = _rcfproto.Tt_Unknown 295 Tt_Tcp = _rcfproto.Tt_Tcp 296 Tt_Udp = _rcfproto.Tt_Udp 297 Tt_Win32NamedPipe = _rcfproto.Tt_Win32NamedPipe 298 Tt_UnixNamedPipe = _rcfproto.Tt_UnixNamedPipe 299 Tt_Http = _rcfproto.Tt_Http 300 Tt_Https = _rcfproto.Tt_Https 301 Tt_InProcess = _rcfproto.Tt_InProcess 302 Si_Schannel = _rcfproto.Si_Schannel 303 Si_OpenSsl = _rcfproto.Si_OpenSsl 304 Cl_CurrentUser = _rcfproto.Cl_CurrentUser 305 Cl_LocalMachine = _rcfproto.Cl_LocalMachine 306 Cs_AddressBook = _rcfproto.Cs_AddressBook 307 Cs_AuthRoot = _rcfproto.Cs_AuthRoot 308 Cs_CertificateAuthority = _rcfproto.Cs_CertificateAuthority 309 Cs_Disallowed = _rcfproto.Cs_Disallowed 310 Cs_My = _rcfproto.Cs_My 311 Cs_Root = _rcfproto.Cs_Root 312 Cs_TrustedPeople = _rcfproto.Cs_TrustedPeople 313 Cs_TrustedPublisher = _rcfproto.Cs_TrustedPublisher 314 Cit_Unspecified = _rcfproto.Cit_Unspecified 315 Cit_Win32 = _rcfproto.Cit_Win32 316 Cit_X509 = _rcfproto.Cit_X509
317 -class Certificate(_object):
318 """Base class of all certificate classes. 319 320 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 321 322 __swig_setmethods__ = {} 323 __setattr__ = lambda self, name, value: _swig_setattr(self, Certificate, name, value) 324 __swig_getmethods__ = {} 325 __getattr__ = lambda self, name: _swig_getattr(self, Certificate, name)
326 - def __init__(self, *args, **kwargs): raise AttributeError("No constructor defined")
327 __repr__ = _swig_repr
328 - def _getType(self): return _rcfproto.Certificate__getType(self)
329 - def _downcastToWin32Certificate(self, *args): return _rcfproto.Certificate__downcastToWin32Certificate(self, *args)
330 - def _downcastToX509Certificate(self, *args): return _rcfproto.Certificate__downcastToX509Certificate(self, *args)
331 __swig_destroy__ = _rcfproto.delete_Certificate 332 __del__ = lambda self : None;
333 _Certificate_swigregister = _rcfproto.Certificate_swigregister 334 _Certificate_swigregister(Certificate) 335
336 -class PemCertificate(Certificate):
337 """Use this class to load a certificate in .pem format. Only applicable to OpenSSL. 338 339 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 340 341 __swig_setmethods__ = {} 342 for _s in [Certificate]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 343 __setattr__ = lambda self, name, value: _swig_setattr(self, PemCertificate, name, value) 344 __swig_getmethods__ = {} 345 for _s in [Certificate]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 346 __getattr__ = lambda self, name: _swig_getattr(self, PemCertificate, name) 347 __repr__ = _swig_repr 348
349 - def __init__(self, *args):
350 """Loads a .pem certificate, using the given file path and password. """ 351 352 this = _rcfproto.new_PemCertificate(*args) 353 try: self.this.append(this) 354 except: self.this = this
355 __swig_destroy__ = _rcfproto.delete_PemCertificate 356 __del__ = lambda self : None;
357 _PemCertificate_swigregister = _rcfproto.PemCertificate_swigregister 358 _PemCertificate_swigregister(PemCertificate) 359
360 -class X509Certificate(Certificate):
361 """Represents an in-memory certificate, usually from a remote peer. Only applicable to OpenSSL. 362 363 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 364 365 __swig_setmethods__ = {} 366 for _s in [Certificate]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 367 __setattr__ = lambda self, name, value: _swig_setattr(self, X509Certificate, name, value) 368 __swig_getmethods__ = {} 369 for _s in [Certificate]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 370 __getattr__ = lambda self, name: _swig_getattr(self, X509Certificate, name)
371 - def __init__(self, *args, **kwargs): raise AttributeError("No constructor defined")
372 __repr__ = _swig_repr
373 - def _getType(self): return _rcfproto.X509Certificate__getType(self)
374
375 - def GetCertificateName(self):
376 """Gets the name of the certificate. """ 377 return _rcfproto.X509Certificate_getCertificateName(self)
378
379 - def GetIssuerName(self):
380 """Gets the name of the issuer of the certificate. """ 381 return _rcfproto.X509Certificate_getIssuerName(self)
382 __swig_destroy__ = _rcfproto.delete_X509Certificate 383 __del__ = lambda self : None;
384 _X509Certificate_swigregister = _rcfproto.X509Certificate_swigregister 385 _X509Certificate_swigregister(X509Certificate) 386
387 -class Win32Certificate(Certificate):
388 """Represents an in-memory certificate, usually from a remote peer. Only applicable to Schannel. 389 390 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 391 392 __swig_setmethods__ = {} 393 for _s in [Certificate]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 394 __setattr__ = lambda self, name, value: _swig_setattr(self, Win32Certificate, name, value) 395 __swig_getmethods__ = {} 396 for _s in [Certificate]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 397 __getattr__ = lambda self, name: _swig_getattr(self, Win32Certificate, name)
398 - def __init__(self, *args, **kwargs): raise AttributeError("No constructor defined")
399 __repr__ = _swig_repr
400 - def _getType(self): return _rcfproto.Win32Certificate__getType(self)
401
402 - def GetCertificateName(self):
403 """Gets the name of the certificate. """ 404 return _rcfproto.Win32Certificate_getCertificateName(self)
405
406 - def GetIssuerName(self):
407 """Gets the name of the issuer of the certificate. """ 408 return _rcfproto.Win32Certificate_getIssuerName(self)
409
410 - def ExportToPfx(self, *args):
411 """Exports the certificate in PFX format, to the given file path. """ 412 return _rcfproto.Win32Certificate_exportToPfx(self, *args)
413
414 - def FindRootCertificate(self, *args):
415 """Attempts to locate a root certificate for this certificate, in the given certificate store. Returns the root certificate if found, and otherwise null. """ 416 return _rcfproto.Win32Certificate_findRootCertificate(self, *args)
417 __swig_destroy__ = _rcfproto.delete_Win32Certificate 418 __del__ = lambda self : None;
419 _Win32Certificate_swigregister = _rcfproto.Win32Certificate_swigregister 420 _Win32Certificate_swigregister(Win32Certificate) 421
422 -class PfxCertificate(Win32Certificate):
423 """Use this class to load a certificate from .pfx format. Only applicable to Schannel. 424 425 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 426 427 __swig_setmethods__ = {} 428 for _s in [Win32Certificate]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 429 __setattr__ = lambda self, name, value: _swig_setattr(self, PfxCertificate, name, value) 430 __swig_getmethods__ = {} 431 for _s in [Win32Certificate]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 432 __getattr__ = lambda self, name: _swig_getattr(self, PfxCertificate, name) 433 __repr__ = _swig_repr 434
435 - def __init__(self, *args):
436 """Loads a certificate from a .pfx file, using the given file path, password and certificate name. """ 437 438 this = _rcfproto.new_PfxCertificate(*args) 439 try: self.this.append(this) 440 except: self.this = this
441
442 - def AddToStore(self, *args):
443 """Adds the certificate to the given Windows certificate store. """ 444 return _rcfproto.PfxCertificate_addToStore(self, *args)
445 __swig_destroy__ = _rcfproto.delete_PfxCertificate 446 __del__ = lambda self : None;
447 _PfxCertificate_swigregister = _rcfproto.PfxCertificate_swigregister 448 _PfxCertificate_swigregister(PfxCertificate) 449
450 -class StoreCertificate(Win32Certificate):
451 """Represents a certificate in a Windows certificate store. 452 453 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 454 455 __swig_setmethods__ = {} 456 for _s in [Win32Certificate]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 457 __setattr__ = lambda self, name, value: _swig_setattr(self, StoreCertificate, name, value) 458 __swig_getmethods__ = {} 459 for _s in [Win32Certificate]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 460 __getattr__ = lambda self, name: _swig_getattr(self, StoreCertificate, name) 461 __repr__ = _swig_repr 462
463 - def __init__(self, *args):
464 """Loads a certificate from a certificate store. """ 465 466 this = _rcfproto.new_StoreCertificate(*args) 467 try: self.this.append(this) 468 except: self.this = this
469
470 - def RemoveFromStore(self):
471 """Removes the certificate from the store it was loaded from. """ 472 return _rcfproto.StoreCertificate_removeFromStore(self)
473 __swig_destroy__ = _rcfproto.delete_StoreCertificate 474 __del__ = lambda self : None;
475 _StoreCertificate_swigregister = _rcfproto.StoreCertificate_swigregister 476 _StoreCertificate_swigregister(StoreCertificate) 477
478 -class StoreCertificateIterator(_object):
479 """Iterates over the certificates in a Windows certificate store. 480 481 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 482 483 __swig_setmethods__ = {} 484 __setattr__ = lambda self, name, value: _swig_setattr(self, StoreCertificateIterator, name, value) 485 __swig_getmethods__ = {} 486 __getattr__ = lambda self, name: _swig_getattr(self, StoreCertificateIterator, name) 487 __repr__ = _swig_repr 488
489 - def __init__(self, *args):
490 """Constructs a store iterator for the the given certificate location and store. """ 491 492 this = _rcfproto.new_StoreCertificateIterator(*args) 493 try: self.this.append(this) 494 except: self.this = this
495
496 - def MoveNext(self):
497 """Moves to the next certificate in the store. Returns false if there are no more certificates, and true otherwise. """ 498 return _rcfproto.StoreCertificateIterator_moveNext(self)
499
500 - def Reset(self):
501 """Resets the iterator back to the beginning of the store. """ 502 return _rcfproto.StoreCertificateIterator_reset(self)
503
504 - def Current(self):
505 """Returns the current certificate. """ 506 return _rcfproto.StoreCertificateIterator_current(self)
507 __swig_destroy__ = _rcfproto.delete_StoreCertificateIterator 508 __del__ = lambda self : None;
509 _StoreCertificateIterator_swigregister = _rcfproto.StoreCertificateIterator_swigregister 510 _StoreCertificateIterator_swigregister(StoreCertificateIterator) 511 512 513
514 -def SetDefaultSslImplementation(*args):
515 """Sets the default SSL implementation to use (OpenSSL or Schannel). The default is OpenSSL. """ 516 517 return _rcfproto.setDefaultSslImplementation(*args)
518 setDefaultSslImplementation = _rcfproto.setDefaultSslImplementation 519 520
521 -def GetDefaultSslImplementation():
522 """Gets the default SSL implementation. """ 523 524 return _rcfproto.getDefaultSslImplementation()
525 getDefaultSslImplementation = _rcfproto.getDefaultSslImplementation
526 -class IpAddress(_object):
527 """Represents an IP address (IPv4 or IPv6). 528 529 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 530 531 __swig_setmethods__ = {} 532 __setattr__ = lambda self, name, value: _swig_setattr(self, IpAddress, name, value) 533 __swig_getmethods__ = {} 534 __getattr__ = lambda self, name: _swig_getattr(self, IpAddress, name) 535 __repr__ = _swig_repr 536
537 - def __init__(self, *args):
538 """Construct an IP address from a host name """ 539 540 this = _rcfproto.new_IpAddress(*args) 541 try: self.this.append(this) 542 except: self.this = this
543 __swig_destroy__ = _rcfproto.delete_IpAddress 544 __del__ = lambda self : None;
545 _IpAddress_swigregister = _rcfproto.IpAddress_swigregister 546 _IpAddress_swigregister(IpAddress) 547
548 -class ThreadPool(_object):
549 """Represents a server-side thread pool. 550 551 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 552 553 __swig_setmethods__ = {} 554 __setattr__ = lambda self, name, value: _swig_setattr(self, ThreadPool, name, value) 555 __swig_getmethods__ = {} 556 __getattr__ = lambda self, name: _swig_getattr(self, ThreadPool, name) 557 __repr__ = _swig_repr
558 - def __init__(self, *args):
559 this = _rcfproto.new_ThreadPool(*args) 560 try: self.this.append(this) 561 except: self.this = this
562
563 - def SetThreadMinCount(self, *args):
564 """Sets the minimum number of threads in the thread pool. """ 565 return _rcfproto.ThreadPool_setThreadMinCount(self, *args)
566
567 - def GetThreadMinCount(self):
568 """Returns the minimum number of threads in the thread pool. """ 569 return _rcfproto.ThreadPool_getThreadMinCount(self)
570
571 - def SetThreadMaxCount(self, *args):
572 """Sets the maximum number of threads in the thread pool. """ 573 return _rcfproto.ThreadPool_setThreadMaxCount(self, *args)
574
575 - def GetThreadMaxCount(self):
576 """Returns the maximum number of threads in the thread pool. """ 577 return _rcfproto.ThreadPool_getThreadMaxCount(self)
578
579 - def SetThreadIdleTimeoutMs(self, *args):
580 """Sets the thread idle timeout value, in milliseconds. After a thread has been idle for this time, it will be shut down, unless the thread count is already at the minimum value for the thread pool. """ 581 return _rcfproto.ThreadPool_setThreadIdleTimeoutMs(self, *args)
582
583 - def GetThreadIdleTimeoutMs(self):
584 """Returns the thread idle timeout value, in milliseconds. """ 585 return _rcfproto.ThreadPool_getThreadIdleTimeoutMs(self)
586
587 - def SetReserveLastThread(self, *args):
588 """If this setting is true, clients will receive an error message right away, if all threads in the thread pool are busy. Otherwise, the client will wait for a thread in the thread pool to become free. """ 589 return _rcfproto.ThreadPool_setReserveLastThread(self, *args)
590 - def GetReserveLastThread(self): return _rcfproto.ThreadPool_getReserveLastThread(self)
591
592 - def SetThreadName(self, *args):
593 """Sets the thread name of the thread pool threads, as visible in a debugger. """ 594 return _rcfproto.ThreadPool_setThreadName(self, *args)
595
596 - def GetThreadName(self):
597 """Returns the thread name of the thread pool threads. """ 598 return _rcfproto.ThreadPool_getThreadName(self)
599 __swig_destroy__ = _rcfproto.delete_ThreadPool 600 __del__ = lambda self : None; 601 _ThreadPool_swigregister = _rcfproto.ThreadPool_swigregister 602 _ThreadPool_swigregister(ThreadPool) 603
604 -class Endpoint(_object):
605 """Base class for all network endpoint types. 606 607 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 608 609 __swig_setmethods__ = {} 610 __setattr__ = lambda self, name, value: _swig_setattr(self, Endpoint, name, value) 611 __swig_getmethods__ = {} 612 __getattr__ = lambda self, name: _swig_getattr(self, Endpoint, name)
613 - def __init__(self, *args, **kwargs): raise AttributeError("No constructor defined")
614 __repr__ = _swig_repr 615 __swig_destroy__ = _rcfproto.delete_Endpoint 616 __del__ = lambda self : None;
617 _Endpoint_swigregister = _rcfproto.Endpoint_swigregister 618 _Endpoint_swigregister(Endpoint) 619
620 -class TcpEndpoint(Endpoint):
621 """Represents a TCP endpoint. 622 623 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 624 625 __swig_setmethods__ = {} 626 for _s in [Endpoint]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 627 __setattr__ = lambda self, name, value: _swig_setattr(self, TcpEndpoint, name, value) 628 __swig_getmethods__ = {} 629 for _s in [Endpoint]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 630 __getattr__ = lambda self, name: _swig_getattr(self, TcpEndpoint, name) 631 __repr__ = _swig_repr 632
633 - def __init__(self, *args):
634 """Constructs a TcpEndpoint from a port number. The IP address defaults to 127.0.0.1 . """ 635 636 this = _rcfproto.new_TcpEndpoint(*args) 637 try: self.this.append(this) 638 except: self.this = this
639
640 - def GetIp(self):
641 """Gets the IP address of the TcpEndpoint. """ 642 return _rcfproto.TcpEndpoint_getIp(self)
643
644 - def GetPort(self):
645 """Gets the port number of the TcpEndpoint. """ 646 return _rcfproto.TcpEndpoint_getPort(self)
647
648 - def AsString(self):
649 """Returns a string representation of the TcpEndpoint. """ 650 return _rcfproto.TcpEndpoint_asString(self)
651 __swig_destroy__ = _rcfproto.delete_TcpEndpoint 652 __del__ = lambda self : None;
653 _TcpEndpoint_swigregister = _rcfproto.TcpEndpoint_swigregister 654 _TcpEndpoint_swigregister(TcpEndpoint) 655
656 -class Win32NamedPipeEndpoint(Endpoint):
657 """Represents a Win32 named pipe endpoint. Only available on Windows platforms. 658 659 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 660 661 __swig_setmethods__ = {} 662 for _s in [Endpoint]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 663 __setattr__ = lambda self, name, value: _swig_setattr(self, Win32NamedPipeEndpoint, name, value) 664 __swig_getmethods__ = {} 665 for _s in [Endpoint]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 666 __getattr__ = lambda self, name: _swig_getattr(self, Win32NamedPipeEndpoint, name) 667 __repr__ = _swig_repr 668
669 - def __init__(self, *args):
670 """Constructs a Win32 named pipe endpoint with the given pipe name. """ 671 672 this = _rcfproto.new_Win32NamedPipeEndpoint(*args) 673 try: self.this.append(this) 674 except: self.this = this
675 __swig_destroy__ = _rcfproto.delete_Win32NamedPipeEndpoint 676 __del__ = lambda self : None;
677 _Win32NamedPipeEndpoint_swigregister = _rcfproto.Win32NamedPipeEndpoint_swigregister 678 _Win32NamedPipeEndpoint_swigregister(Win32NamedPipeEndpoint) 679
680 -class UnixLocalEndpoint(Endpoint):
681 """Represents a UNIX local socket endpoint. Only available on UNIX platforms. 682 683 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 684 685 __swig_setmethods__ = {} 686 for _s in [Endpoint]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 687 __setattr__ = lambda self, name, value: _swig_setattr(self, UnixLocalEndpoint, name, value) 688 __swig_getmethods__ = {} 689 for _s in [Endpoint]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 690 __getattr__ = lambda self, name: _swig_getattr(self, UnixLocalEndpoint, name) 691 __repr__ = _swig_repr 692
693 - def __init__(self, *args):
694 """Constructs a UNIX local socket endpoint with the given name. """ 695 696 this = _rcfproto.new_UnixLocalEndpoint(*args) 697 try: self.this.append(this) 698 except: self.this = this
699 __swig_destroy__ = _rcfproto.delete_UnixLocalEndpoint 700 __del__ = lambda self : None;
701 _UnixLocalEndpoint_swigregister = _rcfproto.UnixLocalEndpoint_swigregister 702 _UnixLocalEndpoint_swigregister(UnixLocalEndpoint) 703
704 -class HttpEndpoint(TcpEndpoint):
705 """Represents a HTTP endpoint. 706 707 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 708 709 __swig_setmethods__ = {} 710 for _s in [TcpEndpoint]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 711 __setattr__ = lambda self, name, value: _swig_setattr(self, HttpEndpoint, name, value) 712 __swig_getmethods__ = {} 713 for _s in [TcpEndpoint]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 714 __getattr__ = lambda self, name: _swig_getattr(self, HttpEndpoint, name) 715 __repr__ = _swig_repr 716
717 - def __init__(self, *args):
718 """Constructs an HTTP endpoint on the given port number. """ 719 720 this = _rcfproto.new_HttpEndpoint(*args) 721 try: self.this.append(this) 722 except: self.this = this
723 __swig_destroy__ = _rcfproto.delete_HttpEndpoint 724 __del__ = lambda self : None;
725 _HttpEndpoint_swigregister = _rcfproto.HttpEndpoint_swigregister 726 _HttpEndpoint_swigregister(HttpEndpoint) 727
728 -class HttpsEndpoint(TcpEndpoint):
729 """Represents a HTTPS endpoint. 730 731 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 732 733 __swig_setmethods__ = {} 734 for _s in [TcpEndpoint]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 735 __setattr__ = lambda self, name, value: _swig_setattr(self, HttpsEndpoint, name, value) 736 __swig_getmethods__ = {} 737 for _s in [TcpEndpoint]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 738 __getattr__ = lambda self, name: _swig_getattr(self, HttpsEndpoint, name) 739 __repr__ = _swig_repr 740
741 - def __init__(self, *args):
742 """Constructs an HTTPS endpoint on the given port number. """ 743 744 this = _rcfproto.new_HttpsEndpoint(*args) 745 try: self.this.append(this) 746 except: self.this = this
747 __swig_destroy__ = _rcfproto.delete_HttpsEndpoint 748 __del__ = lambda self : None;
749 _HttpsEndpoint_swigregister = _rcfproto.HttpsEndpoint_swigregister 750 _HttpsEndpoint_swigregister(HttpsEndpoint) 751
752 -class ServerTransport(_object):
753 """Base class for all server transports. 754 755 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 756 757 __swig_setmethods__ = {} 758 __setattr__ = lambda self, name, value: _swig_setattr(self, ServerTransport, name, value) 759 __swig_getmethods__ = {} 760 __getattr__ = lambda self, name: _swig_getattr(self, ServerTransport, name)
761 - def __init__(self, *args, **kwargs): raise AttributeError("No constructor defined - class is abstract")
762 __repr__ = _swig_repr 763
764 - def GetTransportType(self):
765 """Returns the transport type of this server transport. """ 766 return _rcfproto.ServerTransport_getTransportType(self)
767
768 - def SetMaxIncomingMessageLength(self, *args):
769 """Sets maximum incoming message length. Incoming messages that are larger than this size will be dropped. """ 770 return _rcfproto.ServerTransport_setMaxIncomingMessageLength(self, *args)
771
773 """Returns maximum incoming message length. """ 774 return _rcfproto.ServerTransport_getMaxIncomingMessageLength(self)
775
776 - def SetConnectionLimit(self, *args):
777 """Sets the maximum number of simultaneous connections to the server transport. """ 778 return _rcfproto.ServerTransport_setConnectionLimit(self, *args)
779
780 - def GetConnectionLimit(self):
781 """Returns the maximum number of simultaneous connections to the server transport. """ 782 return _rcfproto.ServerTransport_getConnectionLimit(self)
783
784 - def SetInitialNumberOfConnections(self, *args):
785 """Sets the initial number of listening connections that are created when the server transport starts. """ 786 return _rcfproto.ServerTransport_setInitialNumberOfConnections(self, *args)
787
789 """Returns the initial number of listening connections that are created when the server transport starts. """ 790 return _rcfproto.ServerTransport_getInitialNumberOfConnections(self)
791
792 - def SetThreadPool(self, *args):
793 """Sets the thread pool that the server transport will use. """ 794 return _rcfproto.ServerTransport_setThreadPool(self, *args)
795
796 - def SetSupportedProtocols(self, *args):
797 """Sets the list of supported protocols the server transport supports. Clients that connect without using one of the supported protocols are dropped. If the list of supported protocols is empty, all protocols are allowed. """ 798 return _rcfproto.ServerTransport_setSupportedProtocols(self, *args)
799 - def GetSupportedProtocols(self): return _rcfproto.ServerTransport_getSupportedProtocols(self)
800 __swig_destroy__ = _rcfproto.delete_ServerTransport 801 __del__ = lambda self : None;
802 _ServerTransport_swigregister = _rcfproto.ServerTransport_swigregister 803 _ServerTransport_swigregister(ServerTransport) 804
805 -class ClientTransport(_object):
806 """Base class for all client transports. 807 808 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 809 810 __swig_setmethods__ = {} 811 __setattr__ = lambda self, name, value: _swig_setattr(self, ClientTransport, name, value) 812 __swig_getmethods__ = {} 813 __getattr__ = lambda self, name: _swig_getattr(self, ClientTransport, name)
814 - def __init__(self, *args, **kwargs): raise AttributeError("No constructor defined - class is abstract")
815 __repr__ = _swig_repr 816
817 - def GetTransportType(self):
818 """Returns the transport type of this client transport. """ 819 return _rcfproto.ClientTransport_getTransportType(self)
820
821 - def SetMaxIncomingMessageLength(self, *args):
822 """Sets maximum incoming message length. Incoming messages that are larger than this size will be dropped. """ 823 return _rcfproto.ClientTransport_setMaxIncomingMessageLength(self, *args)
824
826 """Returns maximum incoming message length. """ 827 return _rcfproto.ClientTransport_getMaxIncomingMessageLength(self)
828
829 - def GetLastRequestSize(self):
830 """Returns the byte size of the last request sent on the client transport. """ 831 return _rcfproto.ClientTransport_getLastRequestSize(self)
832
833 - def GetLastResponseSize(self):
834 """Returns the byte size of the last response received on the client transport. """ 835 return _rcfproto.ClientTransport_getLastResponseSize(self)
836
837 - def GetRunningTotalBytesSent(self):
838 """Returns the running total of bytes sent on the client transport. """ 839 return _rcfproto.ClientTransport_getRunningTotalBytesSent(self)
840
842 """Returns the running total of bytes received on the client transport. """ 843 return _rcfproto.ClientTransport_getRunningTotalBytesReceived(self)
844
845 - def ResetRunningTotals(self):
846 """Resets the bytes-sent and bytes-received running totals to zero. """ 847 return _rcfproto.ClientTransport_resetRunningTotals(self)
848 __swig_destroy__ = _rcfproto.delete_ClientTransport 849 __del__ = lambda self : None;
850 _ClientTransport_swigregister = _rcfproto.ClientTransport_swigregister 851 _ClientTransport_swigregister(ClientTransport) 852
853 -class _SwigCallbackArgs(_object):
854 __swig_setmethods__ = {} 855 __setattr__ = lambda self, name, value: _swig_setattr(self, _SwigCallbackArgs, name, value) 856 __swig_getmethods__ = {} 857 __getattr__ = lambda self, name: _swig_getattr(self, _SwigCallbackArgs, name) 858 __repr__ = _swig_repr 859 __swig_setmethods__["mErrorString"] = _rcfproto._SwigCallbackArgs_mErrorString_set 860 __swig_getmethods__["mErrorString"] = _rcfproto._SwigCallbackArgs_mErrorString_get 861 if _newclass:mErrorString = _swig_property(_rcfproto._SwigCallbackArgs_mErrorString_get, _rcfproto._SwigCallbackArgs_mErrorString_set) 862 __swig_setmethods__["mCertificatePtr"] = _rcfproto._SwigCallbackArgs_mCertificatePtr_set 863 __swig_getmethods__["mCertificatePtr"] = _rcfproto._SwigCallbackArgs_mCertificatePtr_get 864 if _newclass:mCertificatePtr = _swig_property(_rcfproto._SwigCallbackArgs_mCertificatePtr_get, _rcfproto._SwigCallbackArgs_mCertificatePtr_set)
865 - def __init__(self):
866 this = _rcfproto.new__SwigCallbackArgs() 867 try: self.this.append(this) 868 except: self.this = this
869 __swig_destroy__ = _rcfproto.delete__SwigCallbackArgs 870 __del__ = lambda self : None; 871 __SwigCallbackArgs_swigregister = _rcfproto._SwigCallbackArgs_swigregister 872 __SwigCallbackArgs_swigregister(_SwigCallbackArgs) 873
874 -class _SwigCallback(_object):
875 __swig_setmethods__ = {} 876 __setattr__ = lambda self, name, value: _swig_setattr(self, _SwigCallback, name, value) 877 __swig_getmethods__ = {} 878 __getattr__ = lambda self, name: _swig_getattr(self, _SwigCallback, name) 879 __repr__ = _swig_repr
880 - def __init__(self):
881 if self.__class__ == _SwigCallback: 882 _self = None 883 else: 884 _self = self 885 this = _rcfproto.new__SwigCallback(_self, ) 886 try: self.this.append(this) 887 except: self.this = this
888 __swig_destroy__ = _rcfproto.delete__SwigCallback 889 __del__ = lambda self : None;
890 - def Run(self): return _rcfproto._SwigCallback_Run(self)
891 - def ProtoRpcBegin(self, *args): return _rcfproto._SwigCallback_ProtoRpcBegin(self, *args)
892 - def ValidateCertificate(self, *args): return _rcfproto._SwigCallback_ValidateCertificate(self, *args)
893 - def __disown__(self):
894 self.this.disown() 895 _rcfproto.disown__SwigCallback(self) 896 return weakref_proxy(self)
897 __SwigCallback_swigregister = _rcfproto._SwigCallback_swigregister 898 __SwigCallback_swigregister(_SwigCallback) 899
900 -class RcfProtoChannel(google.protobuf.service.RpcChannel):
901 """Represents a single RPC connection to a server. 902 903 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 904 905 __swig_setmethods__ = {} 906 __setattr__ = lambda self, name, value: _swig_setattr(self, RcfProtoChannel, name, value) 907 __swig_getmethods__ = {} 908 __getattr__ = lambda self, name: _swig_getattr(self, RcfProtoChannel, name) 909 __repr__ = _swig_repr 910
911 - def __init__(self, *args):
912 """Constructs a RPC channel from an endpoint. """ 913 914 this = _rcfproto.new_RcfProtoChannel(*args) 915 try: self.this.append(this) 916 except: self.this = this
917 - def _CallMethodSwig_WithCopy(self, *args): return _rcfproto.RcfProtoChannel__CallMethodSwig_WithCopy(self, *args)
918 - def _GetResponseBuffer_WithCopy(self): return _rcfproto.RcfProtoChannel__GetResponseBuffer_WithCopy(self)
919
920 - def Failed(self):
921 """After a call has finished, returns true if the call failed. The possible reasons for failure depend on the RPC implementation. Failed() must not be called before a call has finished. If Failed() returns true, the contents of the response message are undefined. """ 922 return _rcfproto.RcfProtoChannel_Failed(self)
923
924 - def ErrorText(self):
925 """If Failed() is true, returns a human-readable description of the error. """ 926 return _rcfproto.RcfProtoChannel_ErrorText(self)
927
928 - def StartCancel(self):
929 """Advises the RPC system that the caller desires that the RPC call be canceled. The RPC system may cancel it immediately, may wait awhile and then cancel it, or may not even cancel the call at all. If the call is canceled, the "done" callback will still be called and the RpcController will indicate that the call failed at that time. """ 930 return _rcfproto.RcfProtoChannel_StartCancel(self)
931
932 - def Connect(self):
933 """Connects to the server. """ 934 return _rcfproto.RcfProtoChannel_connect(self)
935
936 - def Disconnect(self):
937 """Disconencts from the server. """ 938 return _rcfproto.RcfProtoChannel_disconnect(self)
939
940 - def SetRemoteCallTimeoutMs(self, *args):
941 """Sets the remote call timeout value, in milliseconds. """ 942 return _rcfproto.RcfProtoChannel_setRemoteCallTimeoutMs(self, *args)
943
944 - def GetRemoteCallTimeoutMs(self):
945 """Gets the remote call timeout value, in milliseconds. """ 946 return _rcfproto.RcfProtoChannel_getRemoteCallTimeoutMs(self)
947
948 - def SetConnectTimeoutMs(self, *args):
949 """Sets the connect timeout value, in milliseconds. """ 950 return _rcfproto.RcfProtoChannel_setConnectTimeoutMs(self, *args)
951
952 - def GetConnectTimeoutMs(self):
953 """Gets the connect timeout value, in milliseconds. """ 954 return _rcfproto.RcfProtoChannel_getConnectTimeoutMs(self)
955
956 - def SetTransportProtocol(self, *args):
957 """Sets the transport protocol being used by the channel. """ 958 return _rcfproto.RcfProtoChannel_setTransportProtocol(self, *args)
959
960 - def GetTransportProtocol(self):
961 """Gets the transport protocol being used by the channel. """ 962 return _rcfproto.RcfProtoChannel_getTransportProtocol(self)
963
964 - def SetEnableAsynchronousRpc(self, *args):
965 """Sets the enable asynchronous RPC setting. By default asynchronous RPC is disabled. """ 966 return _rcfproto.RcfProtoChannel_setEnableAsynchronousRpc(self, *args)
967
968 - def GetEnableAsynchronousRpc(self):
969 """Gets the enable synchronous RPC setting. """ 970 return _rcfproto.RcfProtoChannel_getEnableAsynchronousRpc(self)
971
972 - def SetPingBackIntervalMs(self, *args):
973 """Sets the ping back interval of the connection, in milliseconds. Ping backs are sent from the server back to the client, while a remote call is in progress. """ 974 return _rcfproto.RcfProtoChannel_setPingBackIntervalMs(self, *args)
975
976 - def GetPingBackIntervalMs(self):
977 """Returns the ping back interval of the connection. """ 978 return _rcfproto.RcfProtoChannel_getPingBackIntervalMs(self)
979
980 - def SetHttpProxy(self, *args):
981 """Sets the network address of the HTTP proxy server, through which to route remote calls. Only valid when using a HTTP or HTTPS endpoint. """ 982 return _rcfproto.RcfProtoChannel_setHttpProxy(self, *args)
983
984 - def GetHttpProxy(self):
985 """Returns the network address of the HTTP proxy server. """ 986 return _rcfproto.RcfProtoChannel_getHttpProxy(self)
987
988 - def SetHttpProxyPort(self, *args):
989 """Sets the port number of the HTTP proxy server, through which to route remote calls. Only valid when using a HTTP or HTTPS endpoint. """ 990 return _rcfproto.RcfProtoChannel_setHttpProxyPort(self, *args)
991
992 - def GetHttpProxyPort(self):
993 """Returns the port number of the HTTP proxy server. """ 994 return _rcfproto.RcfProtoChannel_getHttpProxyPort(self)
995
996 - def GetTransportType(self):
997 """Returns the transport type of the connection. """ 998 return _rcfproto.RcfProtoChannel_getTransportType(self)
999
1000 - def SetUsername(self, *args):
1001 """Sets the Windows username to use when connecting. Only valid for NTLM and Kerberos transport protocols. """ 1002 return _rcfproto.RcfProtoChannel_setUsername(self, *args)
1003
1004 - def GetUsername(self):
1005 """Returns the Windows username to use when connecting. """ 1006 return _rcfproto.RcfProtoChannel_getUsername(self)
1007
1008 - def SetPassword(self, *args):
1009 """Sets the Windows password to use when connecting. Only valid for NTLM and Kerberos transport protocols. """ 1010 return _rcfproto.RcfProtoChannel_setPassword(self, *args)
1011
1012 - def GetPassword(self):
1013 """Returns the Windows password to use when connecting. """ 1014 return _rcfproto.RcfProtoChannel_getPassword(self)
1015
1016 - def SetKerberosSpn(self, *args):
1017 """Sets the Kerberos SPN to use when connecting. Only valid for Kerberos transport protocols. """ 1018 return _rcfproto.RcfProtoChannel_setKerberosSpn(self, *args)
1019
1020 - def GetKerberosSpn(self):
1021 """Returns the Kerberos SPN to use when connecting. """ 1022 return _rcfproto.RcfProtoChannel_getKerberosSpn(self)
1023
1024 - def SetEnableCompression(self, *args):
1025 """Sets the transport level compression setting for this connection. """ 1026 return _rcfproto.RcfProtoChannel_setEnableCompression(self, *args)
1027
1028 - def GetEnableCompression(self):
1029 """Returns the transport level compression setting for this connection. """ 1030 return _rcfproto.RcfProtoChannel_getEnableCompression(self)
1031
1032 - def SetCertificate(self, *args):
1033 """Sets the SSL certificate for the channel. """ 1034 return _rcfproto.RcfProtoChannel_setCertificate(self, *args)
1035
1036 - def GetCertificate(self):
1037 """Gets the SSL certificate for the channel. """ 1038 return _rcfproto.RcfProtoChannel_getCertificate(self)
1039
1040 - def SetCaCertificate(self, *args):
1041 """Sets the certificate authority for the channel. """ 1042 return _rcfproto.RcfProtoChannel_setCaCertificate(self, *args)
1043
1044 - def GetCaCertificate(self):
1045 """Gets the certificate authority for the channel. """ 1046 return _rcfproto.RcfProtoChannel_getCaCertificate(self)
1047
1048 - def SetOpenSslCipherSuite(self, *args):
1049 """Sets the OpenSSL cipher suite. Only applicable when using OpenSSL as the SSL implementation. """ 1050 return _rcfproto.RcfProtoChannel_setOpenSslCipherSuite(self, *args)
1051
1052 - def GetOpenSslCipherSuite(self):
1053 """Gets the OpenSSL cipher suite. """ 1054 return _rcfproto.RcfProtoChannel_getOpenSslCipherSuite(self)
1055
1057 """Sets the Schannel certificate validation setting. Only applicable when using Schannel as the SSL implementation. If this setting is non-empty, it will be used by Schannel to automatically validate peer certificates. """ 1058 return _rcfproto.RcfProtoChannel_setEnableSchannelCertificateValidation(self, *args)
1059
1061 """Gets the Schannel certificate validation setting. """ 1062 return _rcfproto.RcfProtoChannel_getEnableSchannelCertificateValidation(self)
1063 - def _setCertificateValidationCallback(self, *args): return _rcfproto.RcfProtoChannel__setCertificateValidationCallback(self, *args)
1064
1065 - def SetSslImplementation(self, *args):
1066 """Sets the SSL implementation to be used by the channel. """ 1067 return _rcfproto.RcfProtoChannel_setSslImplementation(self, *args)
1068
1069 - def GetSslImplementation(self):
1070 """Gets the SSL implementation. """ 1071 return _rcfproto.RcfProtoChannel_getSslImplementation(self)
1072 __swig_destroy__ = _rcfproto.delete_RcfProtoChannel 1073 __del__ = lambda self : None; 1074 1075 # BEGIN INSERTED CODE 1076 1077
1078 - def CallMethod(self, methodDesc, controller, request, responsePrototype, done):
1079 """Gets the certificate validation callback. """ 1080 1081 rcfprotoimpl.RcfProtoChannelImpl.CallMethod(self, methodDesc, controller, request, responsePrototype, done)
1082
1083 - def GetResponse(self):
1084 return rcfprotoimpl.RcfProtoChannelImpl.GetResponse(self);
1085
1086 - def SetCertificateValidationCallback(self, certValidationCallback):
1087 rcfprotoimpl.RcfProtoChannelImpl.SetCertificateValidationCallback(self, certValidationCallback);
1088 1089 # END INSERTED CODE 1090 1091 1092 _RcfProtoChannel_swigregister = _rcfproto.RcfProtoChannel_swigregister 1093 _RcfProtoChannel_swigregister(RcfProtoChannel) 1094
1095 -class RcfProtoSession(_object):
1096 """Represents the server-side session associated with a RPC connection. 1097 1098 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 1099 1100 __swig_setmethods__ = {} 1101 __setattr__ = lambda self, name, value: _swig_setattr(self, RcfProtoSession, name, value) 1102 __swig_getmethods__ = {} 1103 __getattr__ = lambda self, name: _swig_getattr(self, RcfProtoSession, name)
1104 - def __init__(self, *args, **kwargs): raise AttributeError("No constructor defined")
1105 __repr__ = _swig_repr 1106
1107 - def SetFailed(self, *args):
1108 """Causes Failed() to return true on the client side. "reason" will be incorporated into the message returned by ErrorText(). If you find you need to return machine-readable information about failures, you should incorporate it into your response protocol buffer and should NOT call SetFailed(). """ 1109 return _rcfproto.RcfProtoSession_SetFailed(self, *args)
1110
1111 - def IsCanceled(self):
1112 """If true, indicates that the client canceled the RPC, so the server may as well give up on replying to it. The server should still call the final "done" callback. """ 1113 return _rcfproto.RcfProtoSession_IsCanceled(self)
1114 - def _Commit(self, *args): return _rcfproto.RcfProtoSession__Commit(self, *args)
1115 - def _GetRequestBuffer_WithCopy(self): return _rcfproto.RcfProtoSession__GetRequestBuffer_WithCopy(self)
1116 - def _SetResponseBuffer_WithCopy(self, *args): return _rcfproto.RcfProtoSession__SetResponseBuffer_WithCopy(self, *args)
1117
1118 - def GetClientUsername(self):
1119 """Returns the Windows username of the client, if a NTLM or Kerberos transport protocol is being used. """ 1120 return _rcfproto.RcfProtoSession_getClientUsername(self)
1121
1122 - def GetTransportProtocol(self):
1123 """Returns the transport protocol in use on this server session. """ 1124 return _rcfproto.RcfProtoSession_getTransportProtocol(self)
1125
1126 - def GetTransportType(self):
1127 """Returns the transport type of this server session. """ 1128 return _rcfproto.RcfProtoSession_getTransportType(self)
1129
1130 - def GetEnableCompression(self):
1131 """Returns true if compression is enabled for this server session, and false otherwise. Compression is enabled by the client. """ 1132 return _rcfproto.RcfProtoSession_getEnableCompression(self)
1133
1134 - def GetConnectionDuration(self):
1135 """Returns the duration of the client connection, in milliseconds. """ 1136 return _rcfproto.RcfProtoSession_getConnectionDuration(self)
1137
1138 - def GetRemoteCallCount(self):
1139 """Returns the number of remote calls executed on the server session so far. """ 1140 return _rcfproto.RcfProtoSession_getRemoteCallCount(self)
1141
1142 - def GetTotalBytesReceived(self):
1143 """Returns the total number of bytes received by the server session so far. """ 1144 return _rcfproto.RcfProtoSession_getTotalBytesReceived(self)
1145
1146 - def GetTotalBytesSent(self):
1147 """Returns the total number of bytes sent from the server session so far. """ 1148 return _rcfproto.RcfProtoSession_getTotalBytesSent(self)
1149 __swig_destroy__ = _rcfproto.delete_RcfProtoSession 1150 __del__ = lambda self : None;
1151 _RcfProtoSession_swigregister = _rcfproto.RcfProtoSession_swigregister 1152 _RcfProtoSession_swigregister(RcfProtoSession) 1153
1154 -class RcfProtoServer(_object):
1155 """Serves up Protocol Buffer-based services to clients, over one or more server transports. 1156 1157 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 1158 1159 __swig_setmethods__ = {} 1160 __setattr__ = lambda self, name, value: _swig_setattr(self, RcfProtoServer, name, value) 1161 __swig_getmethods__ = {} 1162 __getattr__ = lambda self, name: _swig_getattr(self, RcfProtoServer, name) 1163 __repr__ = _swig_repr
1164 - def __init__(self, *args):
1165 this = _rcfproto.new_RcfProtoServer(*args) 1166 try: self.this.append(this) 1167 except: self.this = this
1168 __swig_destroy__ = _rcfproto.delete_RcfProtoServer 1169 __del__ = lambda self : None; 1170
1171 - def Start(self):
1172 """Starts the RCFProto server. """ 1173 1174 self.callbackTable = rcfprotoimpl.SwigCallback_ServerRpc(self) 1175 return _rcfproto.RcfProtoServer_start(self)
1176 1177
1178 - def Stop(self):
1179 """Stops the RCFProto server. """ 1180 return _rcfproto.RcfProtoServer_stop(self)
1181 - def _setCallbackTable(self, *args): return _rcfproto.RcfProtoServer__setCallbackTable(self, *args)
1182
1183 - def SetThreadPool(self, *args):
1184 """Sets the thread pool the server will use. Thread pools can also be assigned to individual transports. """ 1185 return _rcfproto.RcfProtoServer_setThreadPool(self, *args)
1186
1187 - def GetThreadPool(self):
1188 """Returns the thread pool the server is using. """ 1189 return _rcfproto.RcfProtoServer_getThreadPool(self)
1190
1191 - def AddEndpoint(self, *args):
1192 """Adds a transport endpoint to the server. """ 1193 return _rcfproto.RcfProtoServer_addEndpoint(self, *args)
1194
1195 - def SetSupportedTransportProtocols(self, *args):
1196 """Sets the list of supported protocols the server supports. Clients that connect without using one of the supported protocols are dropped. If the list of supported protocols is empty, all protocols are allowed. Note that supported protocols can also be specified on a server transport, in which case the server transport setting overrides the server setting. """ 1197 return _rcfproto.RcfProtoServer_setSupportedTransportProtocols(self, *args)
1198
1199 - def GetSupportedTransportProtocols(self):
1200 """Returns the list of supported protocols for the server. """ 1201 return _rcfproto.RcfProtoServer_getSupportedTransportProtocols(self)
1202
1203 - def SetSessionTimeoutMs(self, *args):
1204 """Sets the session timeout value, in milliseconds. Client connections that are idle for this amount of time will be dropped by the server. """ 1205 return _rcfproto.RcfProtoServer_setSessionTimeoutMs(self, *args)
1206
1207 - def GetSessionTimeoutMs(self):
1208 """Returns the session timeout value, in milliseconds. """ 1209 return _rcfproto.RcfProtoServer_getSessionTimeoutMs(self)
1210
1211 - def SetSessionHarvestingIntervalMs(self, *args):
1212 """Sets the session harvesting interval, in milliseconds. This setting determines how often the server will scan for idle client connections. """ 1213 return _rcfproto.RcfProtoServer_setSessionHarvestingIntervalMs(self, *args)
1214
1215 - def GetSessionHarvestingIntervalMs(self):
1216 """Returns the session harvesting interval, in milliseconds. """ 1217 return _rcfproto.RcfProtoServer_getSessionHarvestingIntervalMs(self)
1218
1219 - def SetCertificate(self, *args):
1220 """Sets the SSL certificate of the server. """ 1221 return _rcfproto.RcfProtoServer_setCertificate(self, *args)
1222
1223 - def GetCertificate(self):
1224 """Gets the SSL certificate of the server. """ 1225 return _rcfproto.RcfProtoServer_getCertificate(self)
1226
1227 - def SetOpenSslCipherSuite(self, *args):
1228 """Sets the OpenSSL cipher suite. Only applicable when OpenSSL is used as the SSL implementation. """ 1229 return _rcfproto.RcfProtoServer_setOpenSslCipherSuite(self, *args)
1230
1231 - def GetOpenSslCipherSuite(self):
1232 """Gets the OpenSSL cipher suite. """ 1233 return _rcfproto.RcfProtoServer_getOpenSslCipherSuite(self)
1234
1235 - def SetCaCertificate(self, *args):
1236 """Sets the SSL certificate authority of the server. """ 1237 return _rcfproto.RcfProtoServer_setCaCertificate(self, *args)
1238
1239 - def GetCaCertificate(self):
1240 """Gets the SSL certificate authority of the server. """ 1241 return _rcfproto.RcfProtoServer_getCaCertificate(self)
1242
1243 - def SetEnableSchannelCertificateValidation(self, *args):
1244 """Sets the Schannel certificate validation setting. Only applicable when using Schannel as the SSL implementation. If this setting is non-empty, it will be used by Schannel to automatically validate peer certificates. """ 1245 return _rcfproto.RcfProtoServer_setEnableSchannelCertificateValidation(self, *args)
1246
1247 - def GetEnableSchannelCertificateValidation(self):
1248 """Gets the Schannel certificate validation setting. """ 1249 return _rcfproto.RcfProtoServer_getEnableSchannelCertificateValidation(self)
1250 - def SetSslImplementation(self, *args): return _rcfproto.RcfProtoServer_setSslImplementation(self, *args)
1251
1252 - def GetSslImplementation(self):
1253 """Gets the SSL implementation of the server. """ 1254 return _rcfproto.RcfProtoServer_getSslImplementation(self)
1255 # BEGIN INSERTED CODE
1256 - def BindService(self, svc):
1257 rcfprotoimpl.RcfProtoServerImpl.BindService(self, svc)
1258 1259 1260 # END INSERTED CODE 1261 1262 _RcfProtoServer_swigregister = _rcfproto.RcfProtoServer_swigregister 1263 _RcfProtoServer_swigregister(RcfProtoServer) 1264 1265 # This file is compatible with both classic and new-style classes. 1266 1267
1268 -class RcfProtoController(google.protobuf.service.RpcController) :
1269 """RPC controller interface, for both server-side and client-side code. 1270 1271 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 1272 1273
1274 - def __init__(self, channel, session):
1275 if channel: 1276 self.channel = channel 1277 self.session = None 1278 elif session: 1279 self.channel = None 1280 self.session = session
1281 1282
1283 - def Reset(self):
1284 """Resets the RcfProtoController to its initial state so that it may be reused in a new call. Must not be called while an RPC is in progress. """ 1285 1286 self.channel = None 1287 self.session = None
1288 1289
1290 - def Failed(self):
1291 """Client-side: After a call has finished, returns true if the call failed. Failed() must not be called before a call has finished. If Failed() returns true, the contents of the response message are undefined. """ 1292 1293 return self.channel.Failed()
1294 1295 1296
1297 - def ErrorText(self):
1298 """Client-side: If Failed() is true, returns a human-readable description of the error. """ 1299 1300 return self.channel.ErrorText()
1301 1302
1303 - def StartCancel(self):
1304 """Client-side: Cancels an RPC that is in progress. Once canceled, the "done" callback will still be called and the RcfProtoController will indicate that the call failed at that time. """ 1305 1306 self.channel.StartCancel()
1307 1308 # Server-side methods below 1309 1310
1311 - def SetFailed(self, reason):
1312 """Server-side: Causes Failed() to return true on the client-side. "reason" will be incorporated into the message returned by ErrorText(). If you find you need to return machine-readable information about failures, you should incorporate it into your response protocol buffer and should NOT call SetFailed(). """ 1313 1314 self.session.SetFailed(reason)
1315 1316
1317 - def IsCanceled(self):
1318 """Server-side: If true, indicates that the client canceled the RPC, so the server may as well give up on replying to it. The server should still call the final "done" callback. """ 1319 1320 self.session.IsCanceled()
1321 1322
1323 - def NotifyOnCancel(self, callback):
1324 """Asks that the given callback be called when the RPC is canceled. The callback will always be called exactly once. If the RPC completes without being canceled, the callback will be called after completion. If the RPC has already been canceled when NotifyOnCancel() is called, the callback will be called immediately. NotifyOnCancel() must be called no more than once per request. """ 1325 1326 self.session.NotifyOnCancel(callback)
1327
1328 - def GetSession(self):
1329 return self.session
1330
1331 - def GetChannel(self):
1332 return self.channel
1333 1334 1335 import rcfprotoimpl 1336 from rcfprotoimpl import * 1337