Skip to content

Commit

Permalink
update exported inline names
Browse files Browse the repository at this point in the history
  • Loading branch information
@noise64
noise64 committed Dec 23, 2024
1 parent 3e6cf27 commit bbeb9f3
Show file tree
Hide file tree
Showing 2 changed files with 69 additions and 17 deletions.
4 changes: 2 additions & 2 deletions golem-worker-executor-base/tests/rust_rpc.rs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -612,7 +612,7 @@ async fn wasm_rpc_bug_32_test(
let result = executor
.invoke_and_await(
&caller_worker_id,
"bug-wasm-rpc-i32",
"rpc:caller-exports/caller-inline-functions.{bug-wasm-rpc-i32}",
vec![Value::Variant {
case_idx: 0,
case_value: None,
Expand Down Expand Up @@ -760,7 +760,7 @@ async fn ephemeral_worker_invocation_via_rpc1(
.await;

let result = executor
.invoke_and_await(&caller_worker_id, "ephemeral-test1", vec![])
.invoke_and_await(&caller_worker_id, "rpc:caller-exports/caller-inline-functions.{ephemeral-test1}", vec![])
.await
.unwrap();

Expand Down
82 changes: 67 additions & 15 deletions golem-worker-executor-base/tests/rust_rpc_stubless.rs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -191,7 +191,11 @@ async fn counter_resource_test_1(
.await;

let result = executor
.invoke_and_await(&caller_worker_id, "test1", vec![])
.invoke_and_await(
&caller_worker_id,
"rpc:caller-exports/caller-inline-functions.{test1}",
vec![],
)
.await;

drop(executor);
Expand Down Expand Up @@ -230,10 +234,18 @@ async fn counter_resource_test_2(
.await;

let result1 = executor
.invoke_and_await(&caller_worker_id, "test2", vec![])
.invoke_and_await(
&caller_worker_id,
"rpc:caller-exports/caller-inline-functions.{test2}",
vec![],
)
.await;
let result2 = executor
.invoke_and_await(&caller_worker_id, "test2", vec![])
.invoke_and_await(
&caller_worker_id,
"rpc:caller-exports/caller-inline-functions.{test2}",
vec![],
)
.await;

drop(executor);
Expand Down Expand Up @@ -266,14 +278,22 @@ async fn counter_resource_test_2_with_restart(
.await;

let result1 = executor
.invoke_and_await(&caller_worker_id, "test2", vec![])
.invoke_and_await(
&caller_worker_id,
"rpc:caller-exports/caller-inline-functions.{test2}",
vec![],
)
.await;

drop(executor);
let executor = start(deps, &context).await.unwrap();

let result2 = executor
.invoke_and_await(&caller_worker_id, "test2", vec![])
.invoke_and_await(
&caller_worker_id,
"rpc:caller-exports/caller-inline-functions.{test2}",
vec![],
)
.await;

drop(executor);
Expand Down Expand Up @@ -306,10 +326,18 @@ async fn counter_resource_test_3(
.await;

let result1 = executor
.invoke_and_await(&caller_worker_id, "test3", vec![])
.invoke_and_await(
&caller_worker_id,
"rpc:caller-exports/caller-inline-functions.{test3}",
vec![],
)
.await;
let result2 = executor
.invoke_and_await(&caller_worker_id, "test3", vec![])
.invoke_and_await(
&caller_worker_id,
"rpc:caller-exports/caller-inline-functions.{test3}",
vec![],
)
.await;

drop(executor);
Expand Down Expand Up @@ -342,14 +370,22 @@ async fn counter_resource_test_3_with_restart(
.await;

let result1 = executor
.invoke_and_await(&caller_worker_id, "test3", vec![])
.invoke_and_await(
&caller_worker_id,
"rpc:caller-exports/caller-inline-functions.{test3}",
vec![],
)
.await;

drop(executor);
let executor = start(deps, &context).await.unwrap();

let result2 = executor
.invoke_and_await(&caller_worker_id, "test3", vec![])
.invoke_and_await(
&caller_worker_id,
"rpc:caller-exports/caller-inline-functions.{test3}",
vec![],
)
.await;

drop(executor);
Expand Down Expand Up @@ -388,7 +424,11 @@ async fn context_inheritance(
.await;

let result = executor
.invoke_and_await(&caller_worker_id, "test4", vec![])
.invoke_and_await(
&caller_worker_id,
"rpc:caller-exports/caller-inline-functions.{test4}",
vec![],
)
.await;

drop(executor);
Expand Down Expand Up @@ -471,7 +511,11 @@ async fn counter_resource_test_5(
executor.log_output(&caller_worker_id).await;

let result = executor
.invoke_and_await(&caller_worker_id, "test5", vec![])
.invoke_and_await(
&caller_worker_id,
"rpc:caller-exports/caller-inline-functions.{test5}",
vec![],
)
.await;

drop(executor);
Expand Down Expand Up @@ -513,15 +557,23 @@ async fn counter_resource_test_5_with_restart(
executor.log_output(&caller_worker_id).await;

let result1 = executor
.invoke_and_await(&caller_worker_id, "test5", vec![])
.invoke_and_await(
&caller_worker_id,
"rpc:caller-exports/caller-inline-functions.{test5}",
vec![],
)
.await;

drop(executor);

let executor = start(deps, &context).await.unwrap();

let result2 = executor
.invoke_and_await(&caller_worker_id, "test5", vec![])
.invoke_and_await(
&caller_worker_id,
"rpc:caller-exports/caller-inline-functions.{test5}",
vec![],
)
.await;

drop(executor);
Expand Down Expand Up @@ -571,7 +623,7 @@ async fn wasm_rpc_bug_32_test(
let result = executor
.invoke_and_await(
&caller_worker_id,
"bug-wasm-rpc-i32",
"rpc:caller-exports/caller-inline-functions.{bug-wasm-rpc-i32}",
vec![Value::Variant {
case_idx: 0,
case_value: None,
Expand Down Expand Up @@ -722,7 +774,7 @@ async fn ephemeral_worker_invocation_via_rpc1(
.await;

let result = executor
.invoke_and_await(&caller_worker_id, "ephemeral-test1", vec![])
.invoke_and_await(&caller_worker_id, "rpc:caller-exports/caller-inline-functions.{ephemeral-test1}", vec![])
.await
.unwrap();

Expand Down

0 comments on commit bbeb9f3

Please sign in to comment.