(self, keepalive_interval=5, keepalive_count=5)
| 232 | |
| 233 | class wvmConnectionManager(object): |
| 234 | def __init__(self, keepalive_interval=5, keepalive_count=5): |
| 235 | self.keepalive_interval = keepalive_interval |
| 236 | self.keepalive_count = keepalive_count |
| 237 | |
| 238 | # connection dict |
| 239 | # maps hostnames to a list of connection objects for this hostname |
| 240 | # atm it is possible to create more than one connection per hostname |
| 241 | # with different logins or auth methods |
| 242 | # connections are shared between all threads, see: |
| 243 | # http://wiki.libvirt.org/page/FAQ#Is_libvirt_thread_safe.3F |
| 244 | self._connections = dict() |
| 245 | self._connections_lock = ReadWriteLock() |
| 246 | |
| 247 | # start event loop to handle keepalive requests and other events |
| 248 | self._event_loop = wvmEventLoop() |
| 249 | self._event_loop.start() |
| 250 | |
| 251 | def _search_connection(self, host, login, passwd, conn): |
| 252 | """ |
nothing calls this directly
no test coverage detected