-
Notifications
You must be signed in to change notification settings - Fork 61
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[wip] Fixing memory leaks #1170
base: main
Are you sure you want to change the base?
Conversation
public var events: ClusterEventStream { | ||
self._events | ||
} | ||
|
||
internal var _events: ClusterEventStream |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Don't know why I've added this 🫠 revert back
The failure was #1089 again. We can merge with it failing as we need to investigate that one separately |
We can disable the test until then as well |
@@ -424,7 +428,7 @@ public class ClusterSystem: DistributedActorSystem, @unchecked Sendable { | |||
|
|||
deinit { | |||
// self.shutdownFlag.destroy() | |||
|
|||
print("\(Self.self) DEINIT") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
don't forget to remove
@@ -57,7 +57,7 @@ public final class _ActorShell<Message: Codable>: _ActorContext<Message>, Abstra | |||
internal let _dispatcher: MessageDispatcher | |||
|
|||
@usableFromInline | |||
internal var _system: ClusterSystem? | |||
internal weak var _system: ClusterSystem? |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
heh yeah i can see that... previously actor trees destroyed things and now we don't i guess
@@ -161,8 +162,9 @@ extension TestMetrics { | |||
} | |||
|
|||
func getSWIMCounter(_ swimShell: SWIMActor, _ body: (SWIM.Metrics.ShellMetrics) -> Counter) async throws -> TestCounter? { | |||
let counter = await swimShell.whenLocal { __secretlyKnownToBeLocal in // TODO(distributed): rename once https://github.com/apple/swift/pull/42098 is implemented |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
yep!
|
||
self.lazyInitializationLock.withWriterLockVoid { | ||
self._serialization = nil | ||
} |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
nice thx
Still missing the latest changes probably and requiring 6.0? |
939bee8
to
990ba04
Compare
RP to fix #1168