Package ganeti :: Module rpc

[frames] | no frames]

Module rpc

source code

Inter-node RPC library.

Classes

[hide private]

_RpcThreadLocal

RpcResult
RPC Result class.

Client
RPC Client class.

RpcRunner
RPC runner class

Functions

[hide private]

Init()
Initializes the module-global HTTP client manager.

source code

Shutdown()
Stops the module-global HTTP client manager.

source code

_ConfigRpcCurl(curl)

source code

_RpcTimeout(secs)
Timeout decorator.

source code

RunWithRPC(fn)
RPC-wrapper decorator.

source code

_EncodeImportExportIO(ieio, ieioargs)
Encodes import/export I/O information.

source code

Variables

[hide private]

_RPC_CONNECT_TIMEOUT = 5

_RPC_CLIENT_HEADERS = ["Content-type: %s" % http.HTTP_APP_JSON...

_TMO_URGENT = 60

_TMO_FAST = 5* 60

_TMO_NORMAL = 15* 60

_TMO_SLOW = 3600

_TMO_4HRS = 4* 3600

_TMO_1DAY = 86400

_TIMEOUTS = {}

_thread_local = _RpcThreadLocal()

Imports: os, logging, zlib, base64, pycurl, threading, utils, objects, http, serializer, constants, errors, netutils, ganeti

Function Details

[hide private]

Init()

source code

Initializes the module-global HTTP client manager.

Must be called before using any RPC function and while exactly one thread is running.

Shutdown()

source code

Stops the module-global HTTP client manager.

Must be called before quitting the program and while exactly one thread is running.

_RpcTimeout(secs)

source code

Timeout decorator.

When applied to a rpc call_* function, it updates the global timeout table with the given function/timeout.

RunWithRPC(fn)

source code

RPC-wrapper decorator.

When applied to a function, it runs it with the RPC system initialized, and it shutsdown the system afterwards. This means the function must be called without RPC being initialized.

Variables Details

[hide private]

_RPC_CLIENT_HEADERS

Value:

["Content-type: %s" % http.HTTP_APP_JSON, "Expect:",]