Semi-finish exec call signature implementation #133

api/process.capnp

@@ -11,13 +11,13 @@ using Tools = import "/experiments/tools.capnp";
 interface Executor {
     # Executor has the ability to create and run WASM processes given the
     # WASM bytecode.
-    exec @0 (bytecode :Data, caps :List(Capability)) -> (process :Process);
+    exec @0 (bytecode :Data, spid :Data,  caps :List(Capability)) -> (process :Process);
     # Exec creates an runs a process from the provided bytecode. Optionally, a
     # capability can be passed through the `cap` parameter. This capability will
     # be available at the process inbox.
     #
     # The Process capability is associated to the created process.
-    execFromCache @1 (md5sum :Data, caps :List(Capability)) -> (process :Process);
+    execFromCache @1 (md5sum :Data, spid :Data, caps :List(Capability)) -> (process :Process);
     # Same as Exec, but the bytecode is directly from the BytecodeRegistry.
     # Provides a significant performance improvement for medium to large
     # WASM streams.

pkg/csp/executor.go

@@ -19,11 +19,16 @@ func (ex Executor) Release() {
 	capnp.Client(ex).Release()
 }
 
-func (ex Executor) Exec(ctx context.Context, src []byte, caps ...capnp.Client) (Proc, capnp.ReleaseFunc) {
+func (ex Executor) Exec(ctx context.Context, src []byte, spid []byte, caps ...capnp.Client) (Proc, capnp.ReleaseFunc) {
 	f, release := api.Executor(ex).Exec(ctx, func(ps api.Executor_exec_Params) error {
 		if err := ps.SetBytecode(src); err != nil {
 			return err
 		}
+		if spid != nil {
+			if err := ps.SetSpid(spid); err != nil {
+				return err
+			}
+		}
 		if caps == nil {
 			return nil
 		}
@@ -37,11 +42,16 @@ func (ex Executor) Exec(ctx context.Context, src []byte, caps ...capnp.Client) (
 	return Proc(f.Process()), release
 }
 
-func (ex Executor) ExecFromCache(ctx context.Context, md5sum []byte, caps ...capnp.Client) (Proc, capnp.ReleaseFunc) {
+func (ex Executor) ExecFromCache(ctx context.Context, md5sum []byte, spid []byte, caps ...capnp.Client) (Proc, capnp.ReleaseFunc) {
 	f, release := api.Executor(ex).ExecFromCache(ctx, func(ps api.Executor_execFromCache_Params) error {
 		if err := ps.SetMd5sum(md5sum); err != nil {
 			return err
 		}
+		if spid != nil {
+			if err := ps.SetSpid(spid); err != nil {
+				return err
+			}
+		}
 		if caps == nil {
 			return nil
 		}