#!/usr/bin/python2

import socket
import sys
import rpc_pb2 as rpc
import argparse
import subprocess

print('Connecting to CRIU in swrk mode to check the version:')

css = socket.socketpair(socket.AF_UNIX, socket.SOCK_SEQPACKET)
swrk = subprocess.Popen(['./criu', "swrk", "%d" % css[0].fileno()])
css[0].close()

s = css[1]

# Create criu msg, set it's type to dump request
# and set dump options. Checkout more options in protobuf/rpc.proto
req = rpc.criu_req()
req.type = rpc.VERSION

# Send request
s.send(req.SerializeToString())

# Recv response
resp = rpc.criu_resp()
MAX_MSG_SIZE = 1024
resp.ParseFromString(s.recv(MAX_MSG_SIZE))

if resp.type != rpc.VERSION:
	print('RPC: Unexpected msg type')
	sys.exit(-1)
else:
	if resp.success:
		print('RPC: Success')
		print('CRIU major %d' % resp.version.major)
		print('CRIU minor %d' % resp.version.minor)
		if resp.version.HasField('gitid'):
			print('CRIU gitid %s' % resp.version.gitid)
		if resp.version.HasField('sublevel'):
			print('CRIU sublevel %s' % resp.version.sublevel)
		if resp.version.HasField('extra'):
			print('CRIU extra %s' % resp.version.extra)
		if resp.version.HasField('name'):
			print('CRIU name %s' % resp.version.name)
	else:
		print 'Fail'
		sys.exit(-1)