Revision efc6b445 ncclient/rpc.py
b/ncclient/rpc.py | ||
---|---|---|
12 | 12 |
# See the License for the specific language governing permissions and |
13 | 13 |
# limitations under the License. |
14 | 14 |
|
15 |
import content |
|
16 |
|
|
17 | 15 |
from threading import Event |
18 | 16 |
|
19 |
from listener import RPCReplyListener
|
|
17 |
from listener import SessionListener
|
|
20 | 18 |
|
21 | 19 |
class RPC: |
22 | 20 |
|
... | ... | |
52 | 50 |
@property |
53 | 51 |
def listener(self): |
54 | 52 |
if RPC.listeners[self._sid] is None: |
55 |
RPC.listeners[self.sid] = listener.RPCReplyListener()
|
|
53 |
RPC.listeners[self.sid] = SessionListener()
|
|
56 | 54 |
return RPC.listeners[self._sid] |
57 |
|
|
58 |
@property |
|
59 |
def ok(self): |
|
60 |
pass |
|
61 |
|
|
55 |
|
|
62 | 56 |
def _next_id(self): |
63 | 57 |
RPC.current_id[self._session.id] = RPC.current_id.get(self._session.id, 0) + 1 |
64 | 58 |
return RPC.current_id[self._sid] |
65 |
|
|
66 |
class RPCReply: |
|
67 |
|
|
68 |
def __init__(self, id, raw): |
|
69 |
self._id = id |
|
70 |
self._raw = raw |
|
71 |
|
|
72 |
@property |
|
73 |
def id(self): |
|
74 |
return self._id |
|
75 |
|
|
76 |
class RPCError(NETCONFError): |
|
77 |
pass |
Also available in: Unified diff