Initial commit of TCF python scripting support.

6 files changed, 606 insertions, 0 deletions

diff --git a/python/src/tcf/services/remote/BreakpointsProxy.py b/python/src/tcf/services/remote/BreakpointsProxy.py
new file mode 100644
index 000000000..3458e52bd
--- /dev/null
+++ b/python/src/tcf/services/remote/BreakpointsProxy.py
@@ -0,0 +1,140 @@
+# *******************************************************************************

+# * Copyright (c) 2011 Wind River Systems, Inc. and others.

+# * All rights reserved. This program and the accompanying materials

+# * are made available under the terms of the Eclipse Public License v1.0

+# * which accompanies this distribution, and is available at

+# * http://www.eclipse.org/legal/epl-v10.html

+# *

+# * Contributors:

+# *     Wind River Systems - initial API and implementation

+# *******************************************************************************

+

+import exceptions

+from tcf import channel

+from tcf.services import breakpoints

+from tcf.channel.Command import Command

+

+class BPCommand(Command):

+    def __init__(self, service, cmd, cb, *args):

+        super(BPCommand, self).__init__(service.channel, service, cmd, args)

+        self.__cb = cb

+    def done(self, error, args):

+        if not error:

+            assert len(args) == 1

+            error = self.toError(args[0])

+        self.__cb.doneCommand(self.token, error)

+

+

+class ChannelEventListener(channel.EventListener):

+    def __init__(self, service, listener):

+        self.service = service

+        self.listener = listener

+    def event(self, name, data):

+        try:

+            args = channel.fromJSONSequence(data)

+            if name == "status":

+                assert len(args) == 2

+                self.listener.breakpointStatusChanged(args[0], args[1])

+            elif name == "contextAdded":

+                assert len(args) == 1

+                self.listener.contextAdded(args[0])

+            elif name == "contextChanged":

+                assert len(args) == 1

+                self.listener.contextChanged(args[0])

+            elif name == "contextRemoved":

+                assert len(args) == 1

+                self.listener.contextRemoved(args[0])

+            else:

+                raise IOError("Breakpoints service: unknown event: " + name);

+        except exceptions.Exception as x:

+            self.service.channel.terminate(x)

+

+class BreakpointsProxy(breakpoints.BreakpointsService):

+    def __init__(self, channel):

+        self.channel = channel

+        self.listeners = {}

+

+    def set(self, properties, done):

+        return BPCommand(self, "set", done, properties).token

+

+    def add(self, properties, done):

+        return BPCommand(self, "add", done, properties).token

+

+    def change(self, properties, done):

+        return BPCommand(self, "change", done, properties).token

+

+    def disable(self, ids, done):

+        return BPCommand(self, "disable", done, ids).token

+

+    def enable(self, ids, done):

+        return BPCommand(self, "enable", done, ids).token

+

+    def remove(self, ids, done):

+        return BPCommand(self, "remove", done, ids).token

+

+    def getIDs(self, done):

+        service = self

+        class GetIDsCommand(Command):

+            def __init__(self):

+                super(GetIDsCommand, self).__init__(service.channel, service, "getIDs", None)

+            def done(self, error, args):

+                ids = None

+                if not error:

+                    assert len(args) == 2

+                    error = self.toError(args[0])

+                    ids = args[1]

+                done.doneGetIDs(self.token, error, ids)

+        return GetIDsCommand().token

+

+    def getProperties(self, id, done):

+        service = self

+        class GetPropertiesCommand(Command):

+            def __init__(self):

+                super(GetPropertiesCommand, self).__init__(service.channel, service, "getProperties", (id,))

+            def done(self, error, args):

+                map = None

+                if not error:

+                    assert len(args) == 2

+                    error = self.toError(args[0])

+                    map = args[1]

+                done.doneGetProperties(self.token, error, map)

+        return GetPropertiesCommand().token

+

+    def getStatus(self, id, done):

+        service = self

+        class GetStatusCommand(Command):

+            def __init__(self):

+                super(GetStatusCommand, self).__init__(service.channel, service, "getStatus", (id,))

+            def done(self, error, args):

+                map = None

+                if not error:

+                    assert len(args) == 2

+                    error = self.toError(args[0])

+                    map = args[1]

+                done.doneGetStatus(self.token, error, map)

+        return GetStatusCommand().token

+

+    def getCapabilities(self, id, done):

+        service = self

+        class GetCapabilitiesCommand(Command):

+            def __init__(self):

+                super(GetCapabilitiesCommand, self).__init__(service.channel, service, "getCapabilities", (id,))

+            def done(self, error, args):

+                map = None

+                if not error:

+                    assert len(args) == 2

+                    error = self.toError(args[0])

+                    map = args[1]

+                done.doneGetCapabilities(self.token, error, map)

+        return GetCapabilitiesCommand().token

+

+    def addListener(self, listener):

+        l = ChannelEventListener(self, listener)

+        self.channel.addEventListener(self, l)

+        self.listeners[listener] = l

+

+    def removeListener(self, listener):

+        l = self.listeners.get(listener)

+        if l:

+            del self.listeners[listener]

+            self.channel.removeEventListener(self, l)

diff --git a/python/src/tcf/services/remote/LocatorProxy.py b/python/src/tcf/services/remote/LocatorProxy.py
new file mode 100644
index 000000000..f95303bb5
--- /dev/null
+++ b/python/src/tcf/services/remote/LocatorProxy.py
@@ -0,0 +1,147 @@
+# *******************************************************************************

+# * Copyright (c) 2011 Wind River Systems, Inc. and others.

+# * All rights reserved. This program and the accompanying materials

+# * are made available under the terms of the Eclipse Public License v1.0

+# * which accompanies this distribution, and is available at

+# * http://www.eclipse.org/legal/epl-v10.html

+# *

+# * Contributors:

+# *     Wind River Systems - initial API and implementation

+# *******************************************************************************

+

+import exceptions

+from tcf import protocol, locator, peer, channel

+from tcf.channel.Command import Command

+

+class Peer(peer.TransientPeer):

+    def __init__(self, parent, attrs):

+        super(Peer, self).__init__(attrs)

+        self.parent = parent

+    def openChannel(self):

+        assert protocol.isDispatchThread()

+        c = self.parent.openChannel()

+        c.redirect(self.getID())

+        return c

+

+class ChannelEventListener(channel.EventListener):

+    def __init__(self, proxy):

+        self.proxy = proxy

+        self.channel = proxy.channel

+    def event(self, name, data):

+        try:

+            args = channel.fromJSONSequence(data)

+            if name == "peerAdded":

+                assert len(args) == 1

+                peer = Peer(self.channel.getRemotePeer(), args[0])

+                if self.proxy.peers.get(peer.getID()):

+                    protocol.log("Invalid peerAdded event", exceptions.Exception())

+                    return

+                self.proxy.peers[peer.getID()] = peer

+                for l in self.proxy.listeners:

+                    try:

+                        l.peerAdded(peer)

+                    except exceptions.Exception as x:

+                        protocol.log("Unhandled exception in Locator listener", x)

+            elif name == "peerChanged":

+                assert len(args) == 1

+                m = args[0]

+                if not m: raise exceptions.Exception("Locator service: invalid peerChanged event - no peer ID")

+                peer = self.proxy.peers.get(m.get(peer.ATTR_ID))

+                if not peer: return

+                self.proxy.peers[peer.getID()] = peer

+                for l in self.proxy.listeners:

+                    try:

+                        l.peerChanged(peer)

+                    except exceptions.Exception as x:

+                        protocol.log("Unhandled exception in Locator listener", x)

+            elif name == "peerRemoved":

+                assert len(args) == 1

+                id = args[0]

+                peer = self.proxy.peers.get(id)

+                if not peer: return

+                del self.proxy.peers[id]

+                for l in self.proxy.listeners:

+                    try:

+                        l.peerRemoved(id)

+                    except exceptions.Exception as x:

+                        protocol.log("Unhandled exception in Locator listener", x)

+            elif name == "peerHeartBeat":

+                assert len(args) == 1

+                id = args[0]

+                peer = self.proxy.peers.get(id)

+                if not peer: return

+                for l in self.proxy.listeners:

+                    try:

+                        l.peerHeartBeat(id)

+                    except exceptions.Exception as x:

+                        protocol.log("Unhandled exception in Locator listener", x)

+            else:

+                raise exceptions.IOError("Locator service: unknown event: " + name)

+        except exceptions.Exception as x:

+            self.channel.terminate(x)

+

+class LocatorProxy(locator.LocatorService):

+    peers = {}

+    listeners = []

+    get_peers_done = False

+

+    def __init__(self, channel):

+        self.channel = channel;

+        self.event_listener = ChannelEventListener(self)

+        channel.addEventListener(self, self.event_listener)

+

+    def getPeers(self):

+        return self.peers

+

+    def redirect(self, peer, done):

+        service = self

+        class RedirectCommand(Command):

+            def __init__(self):

+                super(RedirectCommand, self).__init__(service.channel, service, "redirect", [peer])

+            def done(self, error, args):

+                if not error:

+                    assert len(args) == 1

+                    error = self.toError(args[0])

+                done.doneRedirect(self.token, error)

+        return RedirectCommand().token

+

+    def sync(self, done):

+        service = self

+        class SyncCommand(Command):

+            def __init__(self):

+                super(SyncCommand, self).__init__(service.channel, service, "sync", None)

+            def done(self, error, args):

+                if error: service.channel.terminate(error)

+                done.doneSync(self.token)

+        return SyncCommand().token

+

+    def addListener(self, listener):

+        self.listeners.add(listener)

+        if not self.get_peers_done:

+            service = self

+            class GetPeersCommand(Command):

+                def __init__(self):

+                    super(GetPeersCommand, self).__init__(service.channel, service, "getPeers", None)

+                def done(self, error, args):

+                    if not error:

+                        assert len(args) == 2

+                        error = self.toError(args[0])

+                    if error:

+                        protocol.log("Locator error", error)

+                        return

+                    c = args[1]

+                    if c:

+                        for m in c:

+                            id = m.get(peer.ATTR_ID)

+                            if service.peers.get(id): continue;

+                            peer = Peer(service.channel.getRemotePeer(), m)

+                            service.peers[id] = peer

+                            for l in service.listeners:

+                                try:

+                                    l.peerAdded(peer)

+                                except exceptions.Exception as x:

+                                    protocol.log("Unhandled exception in Locator listener", x)

+            self.get_peers_done = True

+

+    def removeListener(self, listener):

+        self.listeners.remove(listener)

diff --git a/python/src/tcf/services/remote/RunControlProxy.py b/python/src/tcf/services/remote/RunControlProxy.py
new file mode 100644
index 000000000..6b1103542
--- /dev/null
+++ b/python/src/tcf/services/remote/RunControlProxy.py
@@ -0,0 +1,152 @@
+# *******************************************************************************

+# * Copyright (c) 2011 Wind River Systems, Inc. and others.

+# * All rights reserved. This program and the accompanying materials

+# * are made available under the terms of the Eclipse Public License v1.0

+# * which accompanies this distribution, and is available at

+# * http://www.eclipse.org/legal/epl-v10.html

+# *

+# * Contributors:

+# *     Wind River Systems - initial API and implementation

+# *******************************************************************************

+

+import exceptions

+from tcf import channel

+from tcf.services import runcontrol

+from tcf.channel.Command import Command

+

+class RunContext(runcontrol.RunControlContext):

+    def __init__(self, service, props):

+        super(RunContext, self).__init__(props)

+        self.service = service

+

+    def getState(self, done):

+        service = self.service

+        id = self.getID()

+        class GetStateCommand(Command):

+            def __init__(self):

+                super(GetStateCommand, self).__init__(service.channel, service, "getState", (id,))

+            def done(self, error, args):

+                susp = False

+                pc = None

+                reason = None

+                map = None

+                if not error:

+                    assert len(args) == 5

+                    error = self.toError(args[0])

+                    susp = args[1]

+                    if args[2]: pc = str(args[2])

+                    reason = args[3]

+                    map = args[4]

+                done.doneGetState(self.token, error, susp, pc, reason, map)

+        return GetStateCommand().token

+

+#    def resume(self, mode, count, done):

+#        return self._command("resume", [self.getID(), mode, count], done)

+

+    def resume(self, mode, count, params, done):

+        if not params:

+            return self._command("resume", (self.getID(), mode, count), done)

+        else:

+            return self._command("resume", (self.getID(), mode, count, params), done)

+

+    def suspend(self, done):

+        return self._command("suspend", (self.getID(),), done)

+

+    def terminate(self, done):

+        return self._command("terminate", (self.getID(),), done)

+

+    def _command(self, cmd, args, done):

+        service = self.service

+        class RCCommand(Command):

+            def __init__(self, cmd, args):

+                super(RCCommand, self).__init__(service.channel, service, cmd, args)

+            def done(self, error, args):

+                if not error:

+                    assert len(args) == 1

+                    error = self.toError(args[0])

+                done.doneCommand(self.token, error)

+        return RCCommand(cmd, args).token

+

+    def __str__(self):

+        return "[Run Control Context %s]" % str(self._props)

+

+

+class ChannelEventListener(channel.EventListener):

+    def __init__(self, service, listener):

+        self.service = service

+        self.listener = listener

+    def event(self, name, data):

+        try:

+            args = channel.fromJSONSequence(data)

+            if name == "contextSuspended":

+                assert len(args) == 4

+                self.listener.contextSuspended(args[0], args[1], args[2], args[3])

+            elif name == "contextResumed":

+                assert len(args) == 1

+                self.listener.contextResumed(args[0])

+            elif name == "contextAdded":

+                assert len(args) == 1

+                self.listener.contextAdded(args[0])

+            elif name == "contextChanged":

+                assert len(args) == 1

+                self.listener.contextChanged(args[0])

+            elif name == "contextRemoved":

+                assert len(args) == 1

+                self.listener.contextRemoved(args[0])

+            elif name == "contextException":

+                assert len(args) == 2

+                self.listener.contextException(args[0], args[1])

+            elif name == "containerSuspended":

+                assert len(args) == 5

+                self.listener.containerSuspended(args[0], args[1], args[2], args[3], args[4])

+            elif name == "containerResumed":

+                assert len(args) == 1

+                self.listener.containerResumed(args[0])

+            else:

+                raise IOError("RunControl service: unknown event: " + name);

+        except exceptions.Exception as x:

+            self.service.channel.terminate(x)

+

+class RunControlProxy(runcontrol.RunControlService):

+    def __init__(self, channel):

+        self.channel = channel

+        self.listeners = {}

+

+    def addListener(self, listener):

+        l = ChannelEventListener(self, listener)

+        self.channel.addEventListener(self, l)

+        self.listeners[listener] = l

+

+    def removeListener(self, listener):

+        l = self.listeners.get(listener)

+        if l:

+            del self.listeners[listener]

+            self.channel.removeEventListener(self, l)

+

+    def getContext(self, context_id, done):

+        service = self

+        class GetContextCommand(Command):

+            def __init__(self):

+                super(GetContextCommand, self).__init__(service.channel, service, "getContext", (context_id,))

+            def done(self, error, args):

+                ctx = None

+                if not error:

+                    assert len(args) == 2

+                    error = self.toError(args[0])

+                    if args[1]: ctx = RunContext(service, args[1])

+                done.doneGetContext(self.token, error, ctx)

+        return GetContextCommand().token

+

+    def getChildren(self, parent_context_id, done):

+        service = self

+        class GetChildrenCommand(Command):

+            def __init__(self):

+                super(GetChildrenCommand, self).__init__(service.channel, service, "getChildren", (parent_context_id,))

+            def done(self, error, args):

+                contexts = None

+                if not error:

+                    assert len(args) == 2

+                    error = self.toError(args[0])

+                    contexts = args[1]

+                done.doneGetChildren(self.token, error, contexts)

+        return GetChildrenCommand().token

diff --git a/python/src/tcf/services/remote/StackTraceProxy.py b/python/src/tcf/services/remote/StackTraceProxy.py
new file mode 100644
index 000000000..350db8295
--- /dev/null
+++ b/python/src/tcf/services/remote/StackTraceProxy.py
@@ -0,0 +1,52 @@
+# *******************************************************************************

+# * Copyright (c) 2011 Wind River Systems, Inc. and others.

+# * All rights reserved. This program and the accompanying materials

+# * are made available under the terms of the Eclipse Public License v1.0

+# * which accompanies this distribution, and is available at

+# * http://www.eclipse.org/legal/epl-v10.html

+# *

+# * Contributors:

+# *     Wind River Systems - initial API and implementation

+# *******************************************************************************

+

+from tcf.services import stacktrace

+from tcf.channel.Command import Command

+

+class StackTraceProxy(stacktrace.StackTraceService):

+    def __init__(self, channel):

+        self.channel = channel

+

+    def getChildren(self, parent_context_id, done):

+        service = self

+        class GetChildrenCommand(Command):

+            def __init__(self):

+                super(GetChildrenCommand, self).__init__(service.channel, service, "getChildren", (parent_context_id,))

+            def done(self, error, args):

+                contexts = None

+                if not error:

+                    assert len(args) == 2

+                    error = self.toError(args[0])

+                    contexts = args[1]

+                done.doneGetChildren(self.token, error, contexts)

+        return GetChildrenCommand().token

+

+    def getContext(self, ids, done):

+        service = self

+        class GetContextCommand(Command):

+            def __init__(self):

+                super(GetContextCommand, self).__init__(service.channel, service, "getContext", (ids,))

+            def done(self, error, args):

+                ctxs = None

+                if not error:

+                    assert len(args) == 2

+                    error = self.toError(args[1])

+                    ctxs = service.toContextArray(args[0])

+                done.doneGetContext(self.token, error, ctxs)

+        return GetContextCommand().token

+

+    def toContextArray(self, ctxProps):

+        if ctxProps is None: return None

+        ctxs = []

+        for props in ctxProps:

+            ctxs.append(stacktrace.StackTraceContext(props))

+        return ctxs

diff --git a/python/src/tcf/services/remote/SymbolsProxy.py b/python/src/tcf/services/remote/SymbolsProxy.py
new file mode 100644
index 000000000..7debc1bc7
--- /dev/null
+++ b/python/src/tcf/services/remote/SymbolsProxy.py
@@ -0,0 +1,115 @@
+# *******************************************************************************

+# * Copyright (c) 2011 Wind River Systems, Inc. and others.

+# * All rights reserved. This program and the accompanying materials

+# * are made available under the terms of the Eclipse Public License v1.0

+# * which accompanies this distribution, and is available at

+# * http://www.eclipse.org/legal/epl-v10.html

+# *

+# * Contributors:

+# *     Wind River Systems - initial API and implementation

+# *******************************************************************************

+

+from tcf import channel

+from tcf.services import symbols

+from tcf.channel.Command import Command

+

+

+class Context(symbols.Symbol):

+    def __init__(self, props):

+        super(Context, self).__init__(props)

+        self.value = channel.toByteArray(props.get(symbols.PROP_VALUE))

+

+    def getValue(self):

+        return self.value

+

+

+class SymbolsProxy(symbols.SymbolsService):

+    def __init__(self, channel):

+        self.channel = channel

+

+    def getContext(self, id, done):

+        service = self

+        class GetContextCommand(Command):

+            def __init__(self):

+                super(GetContextCommand, self).__init__(service.channel, service, "getContext", (id,))

+            def done(self, error, args):

+                ctx = None

+                if not error:

+                    assert len(args) == 2

+                    error = self.toError(args[0])

+                    if args[1]: ctx = Context(args[1])

+                done.doneGetContext(self.token, error, ctx)

+        return GetContextCommand().token

+

+    def getChildren(self, parent_context_id, done):

+        service = self

+        class GetChildrenCommand(Command):

+            def __init__(self):

+                super(GetChildrenCommand, self).__init__(service.channel, service, "getChildren", (parent_context_id,))

+            def done(self, error, args):

+                contexts = None

+                if not error:

+                    assert len(args) == 2

+                    error = self.toError(args[0])

+                    contexts = args[1]

+                done.doneGetChildren(self.token, error, contexts)

+        return GetChildrenCommand().token

+

+    def find(self, context_id, ip, name, done):

+        service = self

+        class FindCommand(Command):

+            def __init__(self):

+                super(FindCommand, self).__init__(service.channel, service, "find", (context_id, ip, name))

+            def done(self, error, args):

+                id = None

+                if not error:

+                    assert len(args) == 2

+                    error = self.toError(args[0])

+                    id = args[1]

+                done.doneFind(self.token, error, id)

+        return FindCommand().token

+

+    def findByAddr(self, context_id, addr, done):

+        service = self

+        class FindByAddrCommand(Command):

+            def __init__(self):

+                super(FindByAddrCommand, self).__init__(service.channel, service, "findByAddr", (context_id, addr))

+            def done(self, error, args):

+                id = None

+                if not error:

+                    assert len(args) == 2

+                    error = self.toError(args[0])

+                    id = args[1]

+                done.doneFind(self.token, error, id)

+        return FindByAddrCommand().token

+

+    def list(self, context_id, done):

+        service = self

+        class ListCommand(Command):

+            def __init__(self):

+                super(ListCommand, self).__init__(service.channel, service, "list", (context_id,))

+            def done(self, error, args):

+                lst = None

+                if not error:

+                    assert len(args) == 2

+                    error = self.toError(args[0])

+                    lst = args[1]

+                done.doneList(self.token, error, lst)

+        return ListCommand().token

+

+    def findFrameInfo(self, context_id, address, done):

+        service = self

+        class FindFrameInfoCommand(Command):

+            def __init__(self):

+                super(FindFrameInfoCommand, self).__init__(service.channel, service, "findFrameInfo", (context_id, address))

+            def done(self, error, args):

+                address = None

+                size = None

+                fp_cmds = None

+                reg_cmds = None

+                if not error:

+                    assert len(args) == 5

+                    error = self.toError(args[0])

+                    address, size, fp_cmds, reg_cmds = args[1:4]

+                done.doneList(self.token, error, address, size, fp_cmds, reg_cmds)

+        return FindFrameInfoCommand().token

diff --git a/python/src/tcf/services/remote/__init__.py b/python/src/tcf/services/remote/__init__.py
new file mode 100644
index 000000000..e69de29bb
--- /dev/null
+++ b/python/src/tcf/services/remote/__init__.py