1 # Copyright (c) 2012 Nicira Networks.
3 # Licensed under the Apache License, Version 2.0 (the "License");
4 # you may not use this file except in compliance with the License.
5 # You may obtain a copy of the License at:
7 # http://www.apache.org/licenses/LICENSE-2.0
9 # Unless required by applicable law or agreed to in writing, software
10 # distributed under the License is distributed on an "AS IS" BASIS,
11 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 # See the License for the specific language governing permissions and
13 # limitations under the License.
25 def connect_to_target(target):
26 error, str_result = ovs.unixctl.socket_name_from_target(target)
28 ovs.util.ovs_fatal(error, str_result)
30 socket_name = str_result
32 error, client = ovs.unixctl.UnixctlClient.create(socket_name)
34 ovs.util.ovs_fatal(error, "cannot connect to \"%s\"" % socket_name)
40 parser = argparse.ArgumentParser(description="Python Implementation of"
42 parser.add_argument("-t", "--target", default="ovs-vswitchd",
43 help="pidfile or socket to contact")
45 parser.add_argument("command", metavar="COMMAND",
46 help="Command to run.")
47 parser.add_argument("argv", metavar="ARG", nargs="*",
48 help="Arguments to the command.")
49 parser.add_argument("-T", "--timeout", metavar="SECS",
50 help="wait at most SECS seconds for a response")
51 args = parser.parse_args()
54 signal.alarm(int(args.timeout))
58 client = connect_to_target(target)
59 err_no, error, result = client.transact(args.command, args.argv)
63 ovs.util.ovs_fatal(err_no, "%s: transaction error" % target)
64 elif error is not None:
65 sys.stderr.write(error)
66 ovs.util.ovs_error(0, "%s: server returned an error" % target)
69 assert result is not None
70 sys.stdout.write(result)
73 if __name__ == '__main__':