On Wed, Mar 13, 2013 at 01:29:10PM +0900, YAMAMOTO Takashi wrote:
> this will be used by cli app.
>
> Signed-off-by: YAMAMOTO Takashi <[email protected]>
> ---
> ryu/call_via_pipe.py | 100
> +++++++++++++++++++++++++++++++++++++++++++++++++++
> 1 file changed, 100 insertions(+)
> create mode 100644 ryu/call_via_pipe.py
>
> diff --git a/ryu/call_via_pipe.py b/ryu/call_via_pipe.py
> new file mode 100644
> index 0000000..4e96d9a
> --- /dev/null
> +++ b/ryu/call_via_pipe.py
> @@ -0,0 +1,100 @@
> +# Copyright (C) 2013 Nippon Telegraph and Telephone Corporation.
> +# Copyright (C) 2013 YAMAMOTO Takashi <yamamoto at valinux co jp>
> +#
> +# Licensed under the Apache License, Version 2.0 (the "License");
> +# you may not use this file except in compliance with the License.
> +# You may obtain a copy of the License at
> +#
> +# http://www.apache.org/licenses/LICENSE-2.0
> +#
> +# Unless required by applicable law or agreed to in writing, software
> +# distributed under the License is distributed on an "AS IS" BASIS,
> +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
> +# implied.
> +# See the License for the specific language governing permissions and
> +# limitations under the License.
> +
> +# IPC mechanism using pipe
> +
> +import os
> +import pickle
> +import struct
> +
> +
> +HEADER_FORMAT = 'I'
> +HEADER_SIZE = struct.calcsize(HEADER_FORMAT)
Please add prefix '_' because those constants are internal use.
Except this, looks good.
thanks,
> +
> +
> +def send_msg(fd, msg):
> + msg_str = pickle.dumps(msg)
> + blen = len(msg_str)
> + hdr = struct.pack(HEADER_FORMAT, blen)
> + os.write(fd, hdr)
> + os.write(fd, msg_str)
> +
> +
> +def recv_msg(fd):
> + hdr = os.read(fd, HEADER_SIZE)
> + blen, = struct.unpack(HEADER_FORMAT, hdr)
> + msg_str = os.read(fd, blen)
> + return pickle.loads(msg_str)
> +
> +
> +class ByNameCall(object):
> + def __init__(self, obj, method, *args, **kwargs):
> + self.obj = obj
> + self.method = method
> + self.args = args
> + self.kwargs = kwargs
> +
> + def __call__(self, dicts):
> + for dict in dicts:
> + try:
> + obj = dict[self.obj]
> + break
> + except:
> + pass
> + method = getattr(obj, self.method)
> + return method(*self.args, **self.kwargs)
> +
> + def __str__(self):
> + return "CallByName %s %s %s %s" % (self.obj, self.method, self.args,
> + self.kwargs)
> +
> +
> +class CallViaPipeReply(object):
> + def __init__(self, type, value):
> + self.type = type
> + self.value = value
> +
> + def __call__(self):
> + if self.type == "exception":
> + raise(self.value)
> + return self.value
> +
> +
> +class CallViaPipe(object):
> + def __init__(self, rpipe, wpipe, basecls):
> + self.rpipe = rpipe
> + self.wpipe = wpipe
> + self.basecls = basecls
> +
> + def __getattr__(self, name):
> + def method(*args, **kwargs):
> + send_msg(self.wpipe,
> + ByNameCall(self.basecls, name, *args, **kwargs))
> + return recv_msg(self.rpipe)()
> + return method
> +
> +
> +def serve(rpipe, wpipe, dicts):
> + """
> + serve a single call
> + """
> + f = recv_msg(rpipe)
> + try:
> + ret = f(dicts)
> + result = CallViaPipeReply("return", ret)
> + except Exception, e:
> + result = CallViaPipeReply("exception", e)
> + send_msg(wpipe, result)
> --
> 1.8.0.1
>
>
> ------------------------------------------------------------------------------
> Everyone hates slow websites. So do we.
> Make your web apps faster with AppDynamics
> Download AppDynamics Lite for free today:
> http://p.sf.net/sfu/appdyn_d2d_mar
> _______________________________________________
> Ryu-devel mailing list
> [email protected]
> https://lists.sourceforge.net/lists/listinfo/ryu-devel
>
--
yamahata
------------------------------------------------------------------------------
Everyone hates slow websites. So do we.
Make your web apps faster with AppDynamics
Download AppDynamics Lite for free today:
http://p.sf.net/sfu/appdyn_d2d_mar
_______________________________________________
Ryu-devel mailing list
[email protected]
https://lists.sourceforge.net/lists/listinfo/ryu-devel
