sockets_mgm: rework to bind on each process

Author: razvancrainea

ipc.c

@@ -237,6 +237,25 @@ int ipc_send_rpc(int dst_proc, ipc_rpc_f *rpc, void *param)
 		ipc_rpc_type, rpc, param);
 }
 
+int ipc_send_rpc_all(ipc_rpc_f *rpc, void *param)
+{
+	int p, count = 0;
+
+	for (p = 1; p < counted_max_processes; p++) {
+		if (pt[p].flags & OSS_PROC_NO_IPC)
+			continue;
+		if (p == process_no) {
+			/* run line the cmd for the proc itself */
+			rpc(process_no, param);
+			count++;
+		} else {
+			if (ipc_send_rpc(p, rpc, param) >= 0)
+				count++;
+		}
+	}
+	return count;
+}
+
 int ipc_dispatch_rpc( ipc_rpc_f *rpc, void *param)
 {
 	return __ipc_send_job(ipc_shared_pipe[1], -1, ipc_rpc_type, rpc, param);

ipc.h

@@ -70,6 +70,14 @@ int ipc_send_job(int dst_proc, ipc_handler_type type, void *payload);
  */
 int ipc_send_rpc(int dst_proc, ipc_rpc_f *rpc, void *param);
 
+/*
+ * Push the execution of a function, remotely, on all the processes
+ * that have IPC
+ *
+ * Return: number of processes the function was sent to
+ */
+int ipc_send_rpc_all(ipc_rpc_f *rpc, void *param);
+
 
 /*
  * Send a synchronous message to a specific "dst_proc" process