Skip to content
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.

Sign up for GitHub

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

Jump to bottom

[wasm] Port CFStream for no-dispatch platforms #4909

Merged
merged 1 commit into from Mar 8, 2024
Merged

[wasm] Port CFStream for no-dispatch platforms #4909

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
20 changes: 20 additions & 0 deletions CoreFoundation/Stream.subproj/CFStream.c
View file
Open in desktop
Expand Up @@ -93,6 +93,7 @@ CF_INLINE CFRunLoopSourceRef _CFStreamCopySource(struct _CFStream* stream) {
}

CF_INLINE void _CFStreamSetSource(struct _CFStream* stream, CFRunLoopSourceRef source, Boolean invalidateOldSource) {
#if __HAS_DISPATCH__
CFRunLoopSourceRef oldSource = NULL;

if (stream) {
Expand All @@ -119,6 +120,7 @@ CF_INLINE void _CFStreamSetSource(struct _CFStream* stream, CFRunLoopSourceRef s
// And lose the one that held it in our stream as well
CFRelease(oldSource);
}
#endif
}

CF_INLINE const struct _CFStreamCallBacks *_CFStreamGetCallBackPtr(struct _CFStream *stream) {
Expand All @@ -135,6 +137,7 @@ CF_INLINE void _CFStreamSetStatusCode(struct _CFStream *stream, CFStreamStatus n
}

CF_INLINE void _CFStreamScheduleEvent(struct _CFStream *stream, CFStreamEventType event) {
#if __HAS_DISPATCH__
if (stream->client && (stream->client->when & event)) {
CFRunLoopSourceRef source = _CFStreamCopySource(stream);
if (source) {
Expand All @@ -145,6 +148,7 @@ CF_INLINE void _CFStreamScheduleEvent(struct _CFStream *stream, CFStreamEventTyp
_wakeUpRunLoop(stream);
}
}
#endif
}

CF_INLINE void _CFStreamSetStreamError(struct _CFStream *stream, CFStreamError *err) {
Expand Down Expand Up @@ -203,6 +207,7 @@ static void _CFStreamDetachSource(struct _CFStream* stream) {

CFAssert(CFArrayGetFirstIndexOfValue(list, CFRangeMake(0, CFArrayGetCount(list)), stream) == kCFNotFound, __kCFLogAssertion, "CFStreamClose: stream found twice in its shared source's list");

#if __HAS_DISPATCH__
if (count == 0) {
CFRunLoopSourceRef source = _CFStreamCopySource(stream);
if (source) {
Expand All @@ -211,6 +216,7 @@ static void _CFStreamDetachSource(struct _CFStream* stream) {
}
CFDictionaryRemoveValue(sSharedSources, runLoopAndSourceKey);
}
#endif

CFDictionaryRemoveValue(sSharedSources, stream);

Expand Down Expand Up @@ -653,6 +659,7 @@ static void _cfstream_shared_signalEventSync(void* info)
break;
}
}
#if __HAS_DISPATCH__

/* And then we also signal any other streams in this array so that we get them next go? */
for (; i < c; i++) {
Expand All @@ -675,6 +682,7 @@ static void _cfstream_shared_signalEventSync(void* info)
break;
}
}
#endif

__CFUnlock(&sSourceLock);

Expand Down Expand Up @@ -788,6 +796,7 @@ CF_PRIVATE void _CFStreamSignalEvent(struct _CFStream *stream, CFStreamEventType
_CFStreamSetStatusCode(stream, kCFStreamStatusError);
}

#if __HAS_DISPATCH__
// Now signal any pertinent event - if not already signaled
if (stream->client && (stream->client->when & event) != 0 && (stream->client->whatToSignal & event) == 0) {
CFRunLoopSourceRef source = _CFStreamCopySource(stream);
Expand Down Expand Up @@ -824,6 +833,7 @@ CF_PRIVATE void _CFStreamSignalEvent(struct _CFStream *stream, CFStreamEventType
CFRelease(source);
}
}
#endif
}

CF_PRIVATE CFStreamStatus _CFStreamGetStatus(struct _CFStream *stream) {
Expand Down Expand Up @@ -1469,6 +1479,7 @@ CF_PRIVATE void _CFStreamScheduleWithRunLoop(struct _CFStream *stream, CFRunLoop
count--;
}

#if __HAS_DISPATCH__
if (count == 0) {
CFRunLoopSourceRef source = _CFStreamCopySource(stream);
if (source) {
Expand All @@ -1477,6 +1488,7 @@ CF_PRIVATE void _CFStreamScheduleWithRunLoop(struct _CFStream *stream, CFRunLoop
}
CFDictionaryRemoveValue(sSharedSources, runLoopAndSourceKey);
}
#endif

CFDictionaryRemoveValue(sSharedSources, stream);

Expand Down Expand Up @@ -1518,6 +1530,7 @@ CF_PRIVATE void _CFStreamScheduleWithRunLoop(struct _CFStream *stream, CFRunLoop
__CFBitClear(stream->flags, CALLING_CLIENT);
}

#if __HAS_DISPATCH__
/*
* If we've got events pending, we need to wake up and signal
*/
Expand All @@ -1529,6 +1542,7 @@ CF_PRIVATE void _CFStreamScheduleWithRunLoop(struct _CFStream *stream, CFRunLoop
_wakeUpRunLoop(stream);
}
}
#endif
}

CF_EXPORT void CFReadStreamScheduleWithRunLoop(CFReadStreamRef stream, CFRunLoopRef runLoop, CFStringRef runLoopMode) {
Expand Down Expand Up @@ -1568,11 +1582,13 @@ CF_PRIVATE void _CFStreamUnscheduleFromRunLoop(struct _CFStream *stream, CFRunLo
if (!stream->client->rlSource) return;

if (!__CFBitIsSet(stream->flags, SHARED_SOURCE)) {
#if __HAS_DISPATCH__
CFRunLoopSourceRef source = _CFStreamCopySource(stream);
if (source) {
CFRunLoopRemoveSource(runLoop, source, runLoopMode);
CFRelease(source);
}
#endif
} else {
CFArrayRef runLoopAndSourceKey;
CFMutableArrayRef list;
Expand All @@ -1590,6 +1606,7 @@ CF_PRIVATE void _CFStreamUnscheduleFromRunLoop(struct _CFStream *stream, CFRunLo
count--;
}

#if __HAS_DISPATCH__
if (count == 0) {
CFRunLoopSourceRef source = _CFStreamCopySource(stream);
if (source) {
Expand All @@ -1598,6 +1615,7 @@ CF_PRIVATE void _CFStreamUnscheduleFromRunLoop(struct _CFStream *stream, CFRunLo
}
CFDictionaryRemoveValue(sSharedSources, runLoopAndSourceKey);
}
#endif

CFDictionaryRemoveValue(sSharedSources, stream);

Expand Down Expand Up @@ -1850,6 +1868,7 @@ dispatch_queue_t CFWriteStreamCopyDispatchQueue(CFWriteStreamRef stream)
#endif

static void waitForOpen(struct _CFStream *stream) {
#if __HAS_DISPATCH__
CFRunLoopRef runLoop = CFRunLoopGetCurrent();
CFStringRef privateMode = CFSTR("_kCFStreamBlockingOpenMode");
_CFStreamScheduleWithRunLoop(stream, runLoop, privateMode);
Expand All @@ -1858,6 +1877,7 @@ static void waitForOpen(struct _CFStream *stream) {
CFRunLoopRunInMode(privateMode, 1e+20, TRUE);
}
_CFStreamUnscheduleFromRunLoop(stream, runLoop, privateMode);
#endif
}

CF_PRIVATE CFArrayRef _CFReadStreamCopyRunLoopsAndModes(CFReadStreamRef readStream) {
Expand Down