report ProcessAsyncEvent when process finished

Signed-off-by: Lai Jiangshan <jiangshanlai@gmail.com>

Author: laijs

src/api.h

@@ -1,33 +1,35 @@
 #ifndef _HYPERSTART_API_H_
 #define _HYPERSTART_API_H_
 
-#define APIVERSION 4242
+// when APIVERSION < 1000000, the version MUST be exactly matched on both sides
+#define APIVERSION 4243
 
 // control command id
 enum {
-	GETVERSION,
+	GETVERSION,			// 0
 	STARTPOD,
 	GETPOD_DEPRECATED,
 	STOPPOD_DEPRECATED,
 	DESTROYPOD,
-	RESTARTCONTAINER_DEPRECATED,
+	RESTARTCONTAINER_DEPRECATED,	// 5
 	EXECCMD,
 	CMDFINISHED_DEPRECATED,
 	READY,
 	ACK,
-	ERROR,
+	ERROR,				// 10
 	WINSIZE,
 	PING,
 	PODFINISHED_DEPRECATED,
 	NEXT,
-	WRITEFILE,
+	WRITEFILE,			// 15
 	READFILE,
 	NEWCONTAINER,
 	KILLCONTAINER,
 	ONLINECPUMEM,
-	SETUPINTERFACE,
+	SETUPINTERFACE,			// 20
 	SETUPROUTE,
 	REMOVECONTAINER,
+	PROCESSASYNCEVENT,
 };
 
 /*

src/exec.c

@@ -56,7 +56,13 @@ static int hyper_send_exec_eof(struct hyper_exec *exec) {
 }
 
 static int hyper_send_exec_code(struct hyper_exec *exec) {
-	return send_exec_finishing(exec->seq, 13, exec->code);
+	char *pae; // ProcessAsyncEvent
+#define PAE "{\"container\":\"%s\",\"process\":\"%s\",\"event\":\"finished\",\"status\":%d}"
+	if (asprintf(&pae, PAE, exec->container_id, exec->id, exec->code) < 0) {
+		return -1;
+	}
+#undef PAE
+	return hyper_ctl_append_msg(&hyper_epoll.ctl, PROCESSASYNCEVENT, (uint8_t *)pae, strlen(pae));
 }
 
 static void pts_hup(struct hyper_event *de, int efd, struct hyper_exec *exec)

src/hyper.h

@@ -85,6 +85,7 @@ int hyper_open_serial(char *tty);
 void hyper_cleanup_pod(struct hyper_pod *pod);
 int hyper_enter_sandbox(struct hyper_pod *pod, int pidpipe);
 void hyper_pod_destroyed(int failed);
+int hyper_ctl_append_msg(struct hyper_event *he, uint32_t type, uint8_t *data, uint32_t len);
 
 extern struct hyper_pod global_pod;
 extern struct hyper_epoll hyper_epoll;

src/init.c

@@ -42,7 +42,6 @@ struct hyper_epoll hyper_epoll;
 sigset_t orig_mask;
 
 static int hyper_handle_exit(struct hyper_pod *pod);
-static int hyper_ctl_append_msg(struct hyper_event *he, uint32_t type, uint8_t *data, uint32_t len);
 
 static int hyper_set_win_size(struct hyper_pod *pod, char *json, int length)
 {
@@ -1060,7 +1059,7 @@ static int hyper_ttyfd_read(struct hyper_event *he, int efd, int events)
 	return ret == 0 ? 0 : -1;
 }
 
-static int hyper_ctl_append_msg(struct hyper_event *he, uint32_t type, uint8_t *data, uint32_t len)
+int hyper_ctl_append_msg(struct hyper_event *he, uint32_t type, uint8_t *data, uint32_t len)
 {
 	int ret = -1;
 	fprintf(stdout, "hyper ctl append type %d, len %d\n", type, len);