34 lines
906 B
Python
34 lines
906 B
Python
|
#!/usr/bin/env python3
|
||
|
|
#
|
||
|
|
# Copyright (C) 2021 Intel Corporation.
|
||
|
|
#
|
||
|
|
# SPDX-License-Identifier: BSD-3-Clause
|
||
|
|
#
|
||
|
|
import socket
|
||
|
|
import sys
|
||
|
|
|
||
|
|
class SocketClient:
|
||
|
|
def __init__(self):
|
||
|
|
pass
|
||
|
|
def connect_to_server(self):
|
||
|
|
SOKET_ADDR = '/var/lib/life_mngr/monitor.sock'
|
||
|
|
SHUTDOWN_REQ = 'user_vm_shutdown:' + sys.argv[1]
|
||
|
|
BUF_LEN = 1024
|
||
|
|
|
||
|
|
print(SHUTDOWN_REQ)
|
||
|
|
# unix domain sockets
|
||
|
|
server_address = SOKET_ADDR
|
||
|
|
socket_family = socket.AF_UNIX
|
||
|
|
socket_type = socket.SOCK_STREAM
|
||
|
|
|
||
|
|
sock = socket.socket(socket_family, socket_type)
|
||
|
|
sock.connect(server_address)
|
||
|
|
sock.sendall(SHUTDOWN_REQ.encode())
|
||
|
|
data = sock.recv(BUF_LEN)
|
||
|
|
print(f"Waiting for ACK message...: {data.decode()}")
|
||
|
|
sock.close()
|
||
|
|
|
||
|
|
if __name__ == "__main__":
|
||
|
|
socket_client_obj = SocketClient()
|
||
|
|
socket_client_obj.connect_to_server()
|