averello/swift-mirror
1
0
Fork 0
mirror of https://github.com/apple/swift.git synced 2025-12-14 20:36:38 +01:00
Code Issues Packages Projects Releases Wiki Activity

wip

Browse Source
This commit is contained in:
Konrad `ktoso` Malawski
2022-01-06 15:33:21 +09:00
parent 69e7fed09d
commit 24a628e7c0
2 changed files with 5 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
stdlib/public/Concurrency/Actor.cpp
View File

@@ -2064,12 +2064,13 @@ void ::swift_distributed_execute_target(
auto *accessor = findDistributedAccessor(targetNameStart, targetNameLength); auto *accessor = findDistributedAccessor(targetNameStart, targetNameLength);
if (!accessor) { if (!accessor) {
assert(false && "no distributed accessor accessor"); assert(false && "no distributed accessor accessor");
return; return; // FIXME(distributed): return -1 here so the lib can fail the call
} }
fprintf(stderr, "[%s:%d] (%s) found accessor\n", __FILE__, __LINE__, __FUNCTION__); fprintf(stderr, "[%s:%d] (%s) found accessor\n", __FILE__, __LINE__, __FUNCTION__);
auto *asyncFnPtr = reinterpret_cast< auto *asyncFnPtr = reinterpret_cast<
const AsyncFunctionPointer<DistributedAccessorSignature> *>(accessor); const AsyncFunctionPointer<DistributedAccessorSignature> *>(
accessor->Function.get());
assert(asyncFnPtr && "no function pointer for distributed_execute_target"); assert(asyncFnPtr && "no function pointer for distributed_execute_target");
DistributedAccessorSignature::FunctionType *accessorEntry = DistributedAccessorSignature::FunctionType *accessorEntry =

7
test/Distributed/Runtime/distributed_actor_remoteCall.swift
View File

@@ -1,5 +1,5 @@
// XXX: %target-swift-frontend -primary-file %s -emit-sil -parse-as-library -enable-experimental-distributed -disable-availability-checking | %FileCheck %s --enable-var-scope --dump-input=always // XXX: %target-swift-frontend -primary-file %s -emit-sil -parse-as-library -enable-experimental-distributed -disable-availability-checking | %FileCheck %s --enable-var-scope --dump-input=always
// TODO: %target-run-simple-swift( -Xfrontend -module-name=main -Xfrontend -disable-availability-checking -Xfrontend -enable-experimental-distributed -parse-as-library) | %FileCheck %s --dump-input=always // RUN: %target-run-simple-swift( -Xfrontend -module-name=main -Xfrontend -disable-availability-checking -Xfrontend -enable-experimental-distributed -parse-as-library) | %FileCheck %s --dump-input=always
// REQUIRES: executable_test // REQUIRES: executable_test
// REQUIRES: concurrency // REQUIRES: concurrency
@@ -12,9 +12,6 @@
// FIXME(distributed): Distributed actors currently have some issues on windows, isRemote always returns false. rdar://82593574 // FIXME(distributed): Distributed actors currently have some issues on windows, isRemote always returns false. rdar://82593574
// UNSUPPORTED: windows // UNSUPPORTED: windows
// TODO(distributed): work in progress
// XFAIL: *
import _Distributed import _Distributed
final class Obj: @unchecked Sendable, Codable {} final class Obj: @unchecked Sendable, Codable {}
@@ -110,7 +107,7 @@ func test() async throws {
let local = Greeter(system: system) let local = Greeter(system: system)
// act as if we decoded an Invocation: // act as if we decoded an Invocation:
var invocation = FakeInvocation() let invocation = FakeInvocation()
try await system.executeDistributedTarget( try await system.executeDistributedTarget(
on: local, on: local,