mozilla
/
gecko-dev
зеркало из https://github.com/mozilla/gecko-dev.git
1
0
Форкнуть 0
Код Задачи Пакеты Проекты Релизы Вики Активность

Bug 1675791 - Fix CamerasParents log macro and put logs in all failure paths. r=dminor 

Differential Revision: https://phabricator.services.mozilla.com/D96192
This commit is contained in:
Paul Adenot 2020-11-09 08:01:42 +00:00
Родитель 8adcd4f2b6
Коммит fdfb0c1263
1 изменённых файлов: 80 добавлений и 65 удалений
Показать статистику Скачать Patch файл Скачать Diff файл Показать все файлы Свернуть все файлы

145
dom/media/systemservices/CamerasParent.cpp
Просмотреть файл

@ -34,9 +34,10 @@
#undef LOG_VERBOSE #undef LOG_VERBOSE
#undef LOG_ENABLED #undef LOG_ENABLED
mozilla::LazyLogModule gCamerasParentLog("CamerasParent"); mozilla::LazyLogModule gCamerasParentLog("CamerasParent");
#define LOG(args) MOZ_LOG(gCamerasParentLog, mozilla::LogLevel::Debug, args) #define LOG(...) \
#define LOG_VERBOSE(args) \ MOZ_LOG(gCamerasParentLog, mozilla::LogLevel::Debug, (__VA_ARGS__))
MOZ_LOG(gCamerasParentLog, mozilla::LogLevel::Verbose, args) #define LOG_VERBOSE(...) \
MOZ_LOG(gCamerasParentLog, mozilla::LogLevel::Verbose, (__VA_ARGS__))
#define LOG_ENABLED() MOZ_LOG_TEST(gCamerasParentLog, mozilla::LogLevel::Debug) #define LOG_ENABLED() MOZ_LOG_TEST(gCamerasParentLog, mozilla::LogLevel::Debug)
namespace mozilla { namespace mozilla {
@ -105,12 +106,13 @@ StaticMutex CamerasParent::sMutex;
// InputObserver is owned by CamerasParent, and it has a ref to CamerasParent // InputObserver is owned by CamerasParent, and it has a ref to CamerasParent
void InputObserver::OnDeviceChange() { void InputObserver::OnDeviceChange() {
LOG(("%s", __PRETTY_FUNCTION__)); LOG("%s", __PRETTY_FUNCTION__);
MOZ_ASSERT(mParent); MOZ_ASSERT(mParent);
RefPtr<InputObserver> self(this); RefPtr<InputObserver> self(this);
RefPtr<nsIRunnable> ipc_runnable = NewRunnableFrom([self]() { RefPtr<nsIRunnable> ipc_runnable = NewRunnableFrom([self]() {
if (self->mParent->IsShuttingDown()) { if (self->mParent->IsShuttingDown()) {
LOG("OnDeviceChanged failure: parent shutting down.");
return NS_ERROR_FAILURE; return NS_ERROR_FAILURE;
} }
Unused << self->mParent->SendDeviceChange(); Unused << self->mParent->SendDeviceChange();
@ -197,6 +199,8 @@ nsresult CamerasParent::DispatchToVideoCaptureThread(RefPtr<Runnable> event) {
sThreadMonitor->Wait(); sThreadMonitor->Wait();
} }
if (!sVideoCaptureThread || !sVideoCaptureThread->IsRunning()) { if (!sVideoCaptureThread || !sVideoCaptureThread->IsRunning()) {
LOG("Can't dispatch to video capture thread: thread not present or not "
"running");
return NS_ERROR_FAILURE; return NS_ERROR_FAILURE;
} }
sVideoCaptureThread->message_loop()->PostTask(event.forget()); sVideoCaptureThread->message_loop()->PostTask(event.forget());
@ -204,7 +208,7 @@ nsresult CamerasParent::DispatchToVideoCaptureThread(RefPtr<Runnable> event) {
} }
void CamerasParent::StopVideoCapture() { void CamerasParent::StopVideoCapture() {
LOG(("%s", __PRETTY_FUNCTION__)); LOG("%s", __PRETTY_FUNCTION__);
// We are called from the main thread (xpcom-shutdown) or // We are called from the main thread (xpcom-shutdown) or
// from PBackground (when the Actor shuts down). // from PBackground (when the Actor shuts down).
// Shut down the WebRTC stack (on the capture thread) // Shut down the WebRTC stack (on the capture thread)
@ -233,7 +237,7 @@ void CamerasParent::StopVideoCapture() {
return NS_OK; return NS_OK;
})); }));
if (NS_FAILED(rv)) { if (NS_FAILED(rv)) {
LOG(("Could not dispatch VideoCaptureThread destruction")); LOG("Could not dispatch VideoCaptureThread destruction");
} }
return rv; return rv;
})); }));
@ -257,7 +261,7 @@ int CamerasParent::DeliverFrameOverIPC(CaptureEngine capEng, uint32_t aStreamId,
ShmemBuffer shMemBuff = mShmemPool.Get(this, aProps.bufferSize()); ShmemBuffer shMemBuff = mShmemPool.Get(this, aProps.bufferSize());
if (!shMemBuff.Valid()) { if (!shMemBuff.Valid()) {
LOG(("No usable Video shmem in DeliverFrame (out of buffers?)")); LOG("No usable Video shmem in DeliverFrame (out of buffers?)");
// We can skip this frame if we run out of buffers, it's not a real error. // We can skip this frame if we run out of buffers, it's not a real error.
return 0; return 0;
} }
@ -295,7 +299,7 @@ void CallbackHelper::OnFrame(const webrtc::VideoFrame& aVideoFrame) {
ShmemBuffer shMemBuffer = mParent->GetBuffer(properties.bufferSize()); ShmemBuffer shMemBuffer = mParent->GetBuffer(properties.bufferSize());
if (!shMemBuffer.Valid()) { if (!shMemBuffer.Valid()) {
// Either we ran out of buffers or they're not the right size yet // Either we ran out of buffers or they're not the right size yet
LOG(("Correctly sized Video shmem not available in DeliverFrame")); LOG("Correctly sized Video shmem not available in DeliverFrame");
// We will do the copy into a(n extra) temporary buffer inside // We will do the copy into a(n extra) temporary buffer inside
// the DeliverFrameRunnable constructor. // the DeliverFrameRunnable constructor.
} else { } else {
@ -322,7 +326,7 @@ mozilla::ipc::IPCResult CamerasParent::RecvReleaseFrame(
} }
bool CamerasParent::SetupEngine(CaptureEngine aCapEngine) { bool CamerasParent::SetupEngine(CaptureEngine aCapEngine) {
LOG(("%s", __PRETTY_FUNCTION__)); LOG("%s", __PRETTY_FUNCTION__);
StaticRefPtr<VideoEngine>& engine = sEngines[aCapEngine]; StaticRefPtr<VideoEngine>& engine = sEngines[aCapEngine];
if (!engine) { if (!engine) {
@ -347,7 +351,7 @@ bool CamerasParent::SetupEngine(CaptureEngine aCapEngine) {
webrtc::CaptureDeviceType::Camera); webrtc::CaptureDeviceType::Camera);
break; break;
default: default:
LOG(("Invalid webrtc Video engine")); LOG("Invalid webrtc Video engine");
MOZ_CRASH(); MOZ_CRASH();
break; break;
} }
@ -356,7 +360,7 @@ bool CamerasParent::SetupEngine(CaptureEngine aCapEngine) {
engine = VideoEngine::Create(std::move(config)); engine = VideoEngine::Create(std::move(config));
if (!engine) { if (!engine) {
LOG(("VideoEngine::Create failed")); LOG("VideoEngine::Create failed");
return false; return false;
} }
} }
@ -374,7 +378,7 @@ bool CamerasParent::SetupEngine(CaptureEngine aCapEngine) {
} }
void CamerasParent::CloseEngines() { void CamerasParent::CloseEngines() {
LOG(("%s", __PRETTY_FUNCTION__)); LOG("%s", __PRETTY_FUNCTION__);
if (!mWebRTCAlive) { if (!mWebRTCAlive) {
return; return;
} }
@ -384,7 +388,7 @@ void CamerasParent::CloseEngines() {
while (mCallbacks.Length()) { while (mCallbacks.Length()) {
auto capEngine = mCallbacks[0]->mCapEngine; auto capEngine = mCallbacks[0]->mCapEngine;
auto streamNum = mCallbacks[0]->mStreamId; auto streamNum = mCallbacks[0]->mStreamId;
LOG(("Forcing shutdown of engine %d, capturer %d", capEngine, streamNum)); LOG("Forcing shutdown of engine %d, capturer %d", capEngine, streamNum);
StopCapture(capEngine, streamNum); StopCapture(capEngine, streamNum);
Unused << ReleaseCaptureDevice(capEngine, streamNum); Unused << ReleaseCaptureDevice(capEngine, streamNum);
} }
@ -421,7 +425,7 @@ VideoEngine* CamerasParent::EnsureInitialized(int aEngine) {
} }
CaptureEngine capEngine = static_cast<CaptureEngine>(aEngine); CaptureEngine capEngine = static_cast<CaptureEngine>(aEngine);
if (!SetupEngine(capEngine)) { if (!SetupEngine(capEngine)) {
LOG(("CamerasParent failed to initialize engine")); LOG("CamerasParent failed to initialize engine");
return nullptr; return nullptr;
} }
@ -435,8 +439,8 @@ VideoEngine* CamerasParent::EnsureInitialized(int aEngine) {
// perhaps via Promises. // perhaps via Promises.
mozilla::ipc::IPCResult CamerasParent::RecvNumberOfCaptureDevices( mozilla::ipc::IPCResult CamerasParent::RecvNumberOfCaptureDevices(
const CaptureEngine& aCapEngine) { const CaptureEngine& aCapEngine) {
LOG(("%s", __PRETTY_FUNCTION__)); LOG("%s", __PRETTY_FUNCTION__);
LOG(("CaptureEngine=%d", aCapEngine)); LOG("CaptureEngine=%d", aCapEngine);
RefPtr<CamerasParent> self(this); RefPtr<CamerasParent> self(this);
RefPtr<Runnable> webrtc_runnable = NewRunnableFrom([self, aCapEngine]() { RefPtr<Runnable> webrtc_runnable = NewRunnableFrom([self, aCapEngine]() {
int num = -1; int num = -1;
@ -447,16 +451,17 @@ mozilla::ipc::IPCResult CamerasParent::RecvNumberOfCaptureDevices(
} }
RefPtr<nsIRunnable> ipc_runnable = NewRunnableFrom([self, num]() { RefPtr<nsIRunnable> ipc_runnable = NewRunnableFrom([self, num]() {
if (!self->mChildIsAlive) { if (!self->mChildIsAlive) {
LOG("RecvNumberOfCaptureDevices failure: child not alive");
return NS_ERROR_FAILURE; return NS_ERROR_FAILURE;
} }
if (num < 0) { if (num < 0) {
LOG(("RecvNumberOfCaptureDevices couldn't find devices")); LOG("RecvNumberOfCaptureDevices couldn't find devices");
Unused << self->SendReplyFailure(); Unused << self->SendReplyFailure();
return NS_ERROR_FAILURE; return NS_ERROR_FAILURE;
} }
LOG(("RecvNumberOfCaptureDevices: %d", num)); LOG("RecvNumberOfCaptureDevices: %d", num);
Unused << self->SendReplyNumberOfCaptureDevices(num); Unused << self->SendReplyNumberOfCaptureDevices(num);
return NS_OK; return NS_OK;
}); });
@ -469,7 +474,7 @@ mozilla::ipc::IPCResult CamerasParent::RecvNumberOfCaptureDevices(
mozilla::ipc::IPCResult CamerasParent::RecvEnsureInitialized( mozilla::ipc::IPCResult CamerasParent::RecvEnsureInitialized(
const CaptureEngine& aCapEngine) { const CaptureEngine& aCapEngine) {
LOG(("%s", __PRETTY_FUNCTION__)); LOG("%s", __PRETTY_FUNCTION__);
RefPtr<CamerasParent> self(this); RefPtr<CamerasParent> self(this);
RefPtr<Runnable> webrtc_runnable = NewRunnableFrom([self, aCapEngine]() { RefPtr<Runnable> webrtc_runnable = NewRunnableFrom([self, aCapEngine]() {
@ -477,16 +482,17 @@ mozilla::ipc::IPCResult CamerasParent::RecvEnsureInitialized(
RefPtr<nsIRunnable> ipc_runnable = NewRunnableFrom([self, result]() { RefPtr<nsIRunnable> ipc_runnable = NewRunnableFrom([self, result]() {
if (!self->mChildIsAlive) { if (!self->mChildIsAlive) {
LOG("RecvEnsureInitialized: child not alive");
return NS_ERROR_FAILURE; return NS_ERROR_FAILURE;
} }
if (!result) { if (!result) {
LOG(("RecvEnsureInitialized failed")); LOG("RecvEnsureInitialized failed");
Unused << self->SendReplyFailure(); Unused << self->SendReplyFailure();
return NS_ERROR_FAILURE; return NS_ERROR_FAILURE;
} }
LOG(("RecvEnsureInitialized succeeded")); LOG("RecvEnsureInitialized succeeded");
Unused << self->SendReplySuccess(); Unused << self->SendReplySuccess();
return NS_OK; return NS_OK;
}); });
@ -499,8 +505,8 @@ mozilla::ipc::IPCResult CamerasParent::RecvEnsureInitialized(
mozilla::ipc::IPCResult CamerasParent::RecvNumberOfCapabilities( mozilla::ipc::IPCResult CamerasParent::RecvNumberOfCapabilities(
const CaptureEngine& aCapEngine, const nsCString& unique_id) { const CaptureEngine& aCapEngine, const nsCString& unique_id) {
LOG(("%s", __PRETTY_FUNCTION__)); LOG("%s", __PRETTY_FUNCTION__);
LOG(("Getting caps for %s", unique_id.get())); LOG("Getting caps for %s", unique_id.get());
RefPtr<CamerasParent> self(this); RefPtr<CamerasParent> self(this);
RefPtr<Runnable> webrtc_runnable = NewRunnableFrom([self, unique_id, RefPtr<Runnable> webrtc_runnable = NewRunnableFrom([self, unique_id,
@ -513,16 +519,17 @@ mozilla::ipc::IPCResult CamerasParent::RecvNumberOfCapabilities(
} }
RefPtr<nsIRunnable> ipc_runnable = NewRunnableFrom([self, num]() { RefPtr<nsIRunnable> ipc_runnable = NewRunnableFrom([self, num]() {
if (!self->mChildIsAlive) { if (!self->mChildIsAlive) {
LOG("RecvNumberOfCapabilities: child not alive");
return NS_ERROR_FAILURE; return NS_ERROR_FAILURE;
} }
if (num < 0) { if (num < 0) {
LOG(("RecvNumberOfCapabilities couldn't find capabilities")); LOG("RecvNumberOfCapabilities couldn't find capabilities");
Unused << self->SendReplyFailure(); Unused << self->SendReplyFailure();
return NS_ERROR_FAILURE; return NS_ERROR_FAILURE;
} }
LOG(("RecvNumberOfCapabilities: %d", num)); LOG("RecvNumberOfCapabilities: %d", num);
Unused << self->SendReplyNumberOfCapabilities(num); Unused << self->SendReplyNumberOfCapabilities(num);
return NS_OK; return NS_OK;
}); });
@ -536,8 +543,8 @@ mozilla::ipc::IPCResult CamerasParent::RecvNumberOfCapabilities(
mozilla::ipc::IPCResult CamerasParent::RecvGetCaptureCapability( mozilla::ipc::IPCResult CamerasParent::RecvGetCaptureCapability(
const CaptureEngine& aCapEngine, const nsCString& unique_id, const CaptureEngine& aCapEngine, const nsCString& unique_id,
const int& num) { const int& num) {
LOG(("%s", __PRETTY_FUNCTION__)); LOG("%s", __PRETTY_FUNCTION__);
LOG(("RecvGetCaptureCapability: %s %d", unique_id.get(), num)); LOG("RecvGetCaptureCapability: %s %d", unique_id.get(), num);
RefPtr<CamerasParent> self(this); RefPtr<CamerasParent> self(this);
RefPtr<Runnable> webrtc_runnable = NewRunnableFrom([self, unique_id, RefPtr<Runnable> webrtc_runnable = NewRunnableFrom([self, unique_id,
@ -565,15 +572,17 @@ mozilla::ipc::IPCResult CamerasParent::RecvGetCaptureCapability(
RefPtr<nsIRunnable> ipc_runnable = RefPtr<nsIRunnable> ipc_runnable =
NewRunnableFrom([self, webrtcCaps, error]() { NewRunnableFrom([self, webrtcCaps, error]() {
if (!self->mChildIsAlive) { if (!self->mChildIsAlive) {
LOG("RecvGetCaptureCapability: child not alive");
return NS_ERROR_FAILURE; return NS_ERROR_FAILURE;
} }
VideoCaptureCapability capCap( VideoCaptureCapability capCap(
webrtcCaps.width, webrtcCaps.height, webrtcCaps.maxFPS, webrtcCaps.width, webrtcCaps.height, webrtcCaps.maxFPS,
static_cast<int>(webrtcCaps.videoType), webrtcCaps.interlaced); static_cast<int>(webrtcCaps.videoType), webrtcCaps.interlaced);
LOG(("Capability: %u %u %u %d %d", webrtcCaps.width, LOG("Capability: %u %u %u %d %d", webrtcCaps.width, webrtcCaps.height,
webrtcCaps.height, webrtcCaps.maxFPS, webrtcCaps.maxFPS, static_cast<int>(webrtcCaps.videoType),
static_cast<int>(webrtcCaps.videoType), webrtcCaps.interlaced)); webrtcCaps.interlaced);
if (error) { if (error) {
LOG("RecvGetCaptureCapability: reply failure");
Unused << self->SendReplyFailure(); Unused << self->SendReplyFailure();
return NS_ERROR_FAILURE; return NS_ERROR_FAILURE;
} }
@ -589,7 +598,7 @@ mozilla::ipc::IPCResult CamerasParent::RecvGetCaptureCapability(
mozilla::ipc::IPCResult CamerasParent::RecvGetCaptureDevice( mozilla::ipc::IPCResult CamerasParent::RecvGetCaptureDevice(
const CaptureEngine& aCapEngine, const int& aListNumber) { const CaptureEngine& aCapEngine, const int& aListNumber) {
LOG(("%s", __PRETTY_FUNCTION__)); LOG("%s", __PRETTY_FUNCTION__);
RefPtr<CamerasParent> self(this); RefPtr<CamerasParent> self(this);
RefPtr<Runnable> webrtc_runnable = NewRunnableFrom([self, aCapEngine, RefPtr<Runnable> webrtc_runnable = NewRunnableFrom([self, aCapEngine,
@ -617,14 +626,14 @@ mozilla::ipc::IPCResult CamerasParent::RecvGetCaptureDevice(
return NS_ERROR_FAILURE; return NS_ERROR_FAILURE;
} }
if (error) { if (error) {
LOG(("GetCaptureDevice failed: %d", error)); LOG("GetCaptureDevice failed: %d", error);
Unused << self->SendReplyFailure(); Unused << self->SendReplyFailure();
return NS_ERROR_FAILURE; return NS_ERROR_FAILURE;
} }
bool scary = (devicePid == getpid()); bool scary = (devicePid == getpid());
LOG(("Returning %s name %s id (pid = %d)%s", name.get(), LOG("Returning %s name %s id (pid = %d)%s", name.get(),
uniqueId.get(), devicePid, (scary ? " (scary)" : ""))); uniqueId.get(), devicePid, (scary ? " (scary)" : ""));
Unused << self->SendReplyGetCaptureDevice(name, uniqueId, scary); Unused << self->SendReplyGetCaptureDevice(name, uniqueId, scary);
return NS_OK; return NS_OK;
}); });
@ -701,7 +710,7 @@ static bool HasCameraPermission(const uint64_t& aWindowId) {
mozilla::ipc::IPCResult CamerasParent::RecvAllocateCaptureDevice( mozilla::ipc::IPCResult CamerasParent::RecvAllocateCaptureDevice(
const CaptureEngine& aCapEngine, const nsCString& unique_id, const CaptureEngine& aCapEngine, const nsCString& unique_id,
const uint64_t& aWindowID) { const uint64_t& aWindowID) {
LOG(("%s: Verifying permissions", __PRETTY_FUNCTION__)); LOG("%s: Verifying permissions", __PRETTY_FUNCTION__);
RefPtr<CamerasParent> self(this); RefPtr<CamerasParent> self(this);
RefPtr<Runnable> mainthread_runnable = NewRunnableFrom([self, aCapEngine, RefPtr<Runnable> mainthread_runnable = NewRunnableFrom([self, aCapEngine,
unique_id, unique_id,
@ -714,11 +723,9 @@ mozilla::ipc::IPCResult CamerasParent::RecvAllocateCaptureDevice(
if (Preferences::GetBool("media.navigator.permission.disabled", false) || if (Preferences::GetBool("media.navigator.permission.disabled", false) ||
Preferences::GetBool("media.navigator.permission.fake")) { Preferences::GetBool("media.navigator.permission.fake")) {
allowed = true; allowed = true;
LOG( LOG("No permission but checks are disabled or fake sources active");
("No permission but checks are disabled or fake sources "
"active"));
} else { } else {
LOG(("No camera permission for this origin")); LOG("No camera permission for this origin");
} }
} }
// After retrieving the permission (or not) on the main thread, // After retrieving the permission (or not) on the main thread,
@ -740,15 +747,17 @@ mozilla::ipc::IPCResult CamerasParent::RecvAllocateCaptureDevice(
RefPtr<nsIRunnable> ipc_runnable = RefPtr<nsIRunnable> ipc_runnable =
NewRunnableFrom([self, numdev, error]() { NewRunnableFrom([self, numdev, error]() {
if (!self->mChildIsAlive) { if (!self->mChildIsAlive) {
LOG("RecvAllocateCaptureDevice: child not alive");
return NS_ERROR_FAILURE; return NS_ERROR_FAILURE;
} }
if (error) { if (error) {
Unused << self->SendReplyFailure(); Unused << self->SendReplyFailure();
LOG("RecvAllocateCaptureDevice: WithEntry error");
return NS_ERROR_FAILURE; return NS_ERROR_FAILURE;
} }
LOG(("Allocated device nr %d", numdev)); LOG("Allocated device nr %d", numdev);
Unused << self->SendReplyAllocateCaptureDevice(numdev); Unused << self->SendReplyAllocateCaptureDevice(numdev);
return NS_OK; return NS_OK;
}); });
@ -774,8 +783,8 @@ int CamerasParent::ReleaseCaptureDevice(const CaptureEngine& aCapEngine,
mozilla::ipc::IPCResult CamerasParent::RecvReleaseCaptureDevice( mozilla::ipc::IPCResult CamerasParent::RecvReleaseCaptureDevice(
const CaptureEngine& aCapEngine, const int& numdev) { const CaptureEngine& aCapEngine, const int& numdev) {
LOG(("%s", __PRETTY_FUNCTION__)); LOG("%s", __PRETTY_FUNCTION__);
LOG(("RecvReleaseCamera device nr %d", numdev)); LOG("RecvReleaseCamera device nr %d", numdev);
RefPtr<CamerasParent> self(this); RefPtr<CamerasParent> self(this);
RefPtr<Runnable> webrtc_runnable = NewRunnableFrom([self, aCapEngine, RefPtr<Runnable> webrtc_runnable = NewRunnableFrom([self, aCapEngine,
@ -783,17 +792,18 @@ mozilla::ipc::IPCResult CamerasParent::RecvReleaseCaptureDevice(
int error = self->ReleaseCaptureDevice(aCapEngine, numdev); int error = self->ReleaseCaptureDevice(aCapEngine, numdev);
RefPtr<nsIRunnable> ipc_runnable = NewRunnableFrom([self, error, numdev]() { RefPtr<nsIRunnable> ipc_runnable = NewRunnableFrom([self, error, numdev]() {
if (!self->mChildIsAlive) { if (!self->mChildIsAlive) {
LOG("RecvReleaseCaptureDevice: child not alive");
return NS_ERROR_FAILURE; return NS_ERROR_FAILURE;
} }
if (error) { if (error) {
Unused << self->SendReplyFailure(); Unused << self->SendReplyFailure();
LOG(("Failed to free device nr %d", numdev)); LOG("RecvReleaseCaptureDevice: Failed to free device nr %d", numdev);
return NS_ERROR_FAILURE; return NS_ERROR_FAILURE;
} }
Unused << self->SendReplySuccess(); Unused << self->SendReplySuccess();
LOG(("Freed device nr %d", numdev)); LOG("Freed device nr %d", numdev);
return NS_OK; return NS_OK;
}); });
self->mPBackgroundEventTarget->Dispatch(ipc_runnable, NS_DISPATCH_NORMAL); self->mPBackgroundEventTarget->Dispatch(ipc_runnable, NS_DISPATCH_NORMAL);
@ -806,12 +816,12 @@ mozilla::ipc::IPCResult CamerasParent::RecvReleaseCaptureDevice(
mozilla::ipc::IPCResult CamerasParent::RecvStartCapture( mozilla::ipc::IPCResult CamerasParent::RecvStartCapture(
const CaptureEngine& aCapEngine, const int& capnum, const CaptureEngine& aCapEngine, const int& capnum,
const VideoCaptureCapability& ipcCaps) { const VideoCaptureCapability& ipcCaps) {
LOG(("%s", __PRETTY_FUNCTION__)); LOG("%s", __PRETTY_FUNCTION__);
RefPtr<CamerasParent> self(this); RefPtr<CamerasParent> self(this);
RefPtr<Runnable> webrtc_runnable = NewRunnableFrom([self, aCapEngine, capnum, RefPtr<Runnable> webrtc_runnable = NewRunnableFrom([self, aCapEngine, capnum,
ipcCaps]() { ipcCaps]() {
LOG(("%s", __PRETTY_FUNCTION__)); LOG("%s", __PRETTY_FUNCTION__);
CallbackHelper** cbh; CallbackHelper** cbh;
int error = -1; int error = -1;
if (self->EnsureInitialized(aCapEngine)) { if (self->EnsureInitialized(aCapEngine)) {
@ -913,6 +923,7 @@ mozilla::ipc::IPCResult CamerasParent::RecvStartCapture(
} }
RefPtr<nsIRunnable> ipc_runnable = NewRunnableFrom([self, error]() { RefPtr<nsIRunnable> ipc_runnable = NewRunnableFrom([self, error]() {
if (!self->mChildIsAlive) { if (!self->mChildIsAlive) {
LOG("RecvStartCapture failure: child is not alive");
return NS_ERROR_FAILURE; return NS_ERROR_FAILURE;
} }
@ -921,6 +932,7 @@ mozilla::ipc::IPCResult CamerasParent::RecvStartCapture(
return NS_OK; return NS_OK;
} }
LOG("RecvStartCapture failure: StartCapture failed");
Unused << self->SendReplyFailure(); Unused << self->SendReplyFailure();
return NS_ERROR_FAILURE; return NS_ERROR_FAILURE;
}); });
@ -933,32 +945,35 @@ mozilla::ipc::IPCResult CamerasParent::RecvStartCapture(
mozilla::ipc::IPCResult CamerasParent::RecvFocusOnSelectedSource( mozilla::ipc::IPCResult CamerasParent::RecvFocusOnSelectedSource(
const CaptureEngine& aCapEngine, const int& aCapNum) { const CaptureEngine& aCapEngine, const int& aCapNum) {
LOG(("%s", __PRETTY_FUNCTION__)); LOG("%s", __PRETTY_FUNCTION__);
RefPtr<Runnable> webrtc_runnable = NewRunnableFrom( RefPtr<Runnable> webrtc_runnable = NewRunnableFrom(
[self = RefPtr<CamerasParent>(this), aCapEngine, aCapNum]() { [self = RefPtr<CamerasParent>(this), aCapEngine, aCapNum]() {
if (auto engine = self->EnsureInitialized(aCapEngine)) { if (auto engine = self->EnsureInitialized(aCapEngine)) {
engine->WithEntry(aCapNum, [self](VideoEngine::CaptureEntry& cap) { engine->WithEntry(aCapNum, [self](VideoEngine::CaptureEntry& cap) {
if (cap.VideoCapture()) { if (cap.VideoCapture()) {
bool result = cap.VideoCapture()->FocusOnSelectedSource(); bool result = cap.VideoCapture()->FocusOnSelectedSource();
RefPtr<nsIRunnable> ipc_runnable = RefPtr<nsIRunnable> ipc_runnable = NewRunnableFrom([self,
NewRunnableFrom([self, result]() { result]() {
if (!self->mChildIsAlive) { if (!self->mChildIsAlive) {
return NS_ERROR_FAILURE; LOG("RecvFocusOnSelectedSource failure: child is not alive");
} return NS_ERROR_FAILURE;
}
if (result) { if (result) {
Unused << self->SendReplySuccess(); Unused << self->SendReplySuccess();
return NS_OK; return NS_OK;
} }
Unused << self->SendReplyFailure(); Unused << self->SendReplyFailure();
return NS_ERROR_FAILURE; LOG("RecvFocusOnSelectedSource failure.");
}); return NS_ERROR_FAILURE;
});
self->mPBackgroundEventTarget->Dispatch(ipc_runnable, self->mPBackgroundEventTarget->Dispatch(ipc_runnable,
NS_DISPATCH_NORMAL); NS_DISPATCH_NORMAL);
} }
}); });
} }
LOG("RecvFocusOnSelectedSource CameraParent not initialized");
return NS_ERROR_FAILURE; return NS_ERROR_FAILURE;
}); });
DispatchToVideoCaptureThread(webrtc_runnable); DispatchToVideoCaptureThread(webrtc_runnable);
@ -995,7 +1010,7 @@ void CamerasParent::StopCapture(const CaptureEngine& aCapEngine,
mozilla::ipc::IPCResult CamerasParent::RecvStopCapture( mozilla::ipc::IPCResult CamerasParent::RecvStopCapture(
const CaptureEngine& aCapEngine, const int& capnum) { const CaptureEngine& aCapEngine, const int& capnum) {
LOG(("%s", __PRETTY_FUNCTION__)); LOG("%s", __PRETTY_FUNCTION__);
RefPtr<CamerasParent> self(this); RefPtr<CamerasParent> self(this);
RefPtr<Runnable> webrtc_runnable = RefPtr<Runnable> webrtc_runnable =
@ -1033,7 +1048,7 @@ void CamerasParent::StopIPC() {
} }
mozilla::ipc::IPCResult CamerasParent::RecvAllDone() { mozilla::ipc::IPCResult CamerasParent::RecvAllDone() {
LOG(("%s", __PRETTY_FUNCTION__)); LOG("%s", __PRETTY_FUNCTION__);
// Don't try to send anything to the child now // Don't try to send anything to the child now
mChildIsAlive = false; mChildIsAlive = false;
IProtocol* mgr = Manager(); IProtocol* mgr = Manager();
@ -1045,7 +1060,7 @@ mozilla::ipc::IPCResult CamerasParent::RecvAllDone() {
void CamerasParent::ActorDestroy(ActorDestroyReason aWhy) { void CamerasParent::ActorDestroy(ActorDestroyReason aWhy) {
// No more IPC from here // No more IPC from here
LOG(("%s", __PRETTY_FUNCTION__)); LOG("%s", __PRETTY_FUNCTION__);
StopIPC(); StopIPC();
// Shut down WebRTC (if we're not in full shutdown, else this // Shut down WebRTC (if we're not in full shutdown, else this
// will already have happened) // will already have happened)
@ -1070,7 +1085,7 @@ CamerasParent::CamerasParent()
mChildIsAlive(true), mChildIsAlive(true),
mDestroyed(false), mDestroyed(false),
mWebRTCAlive(true) { mWebRTCAlive(true) {
LOG(("CamerasParent: %p", this)); LOG("CamerasParent: %p", this);
StaticMutexAutoLock slock(sMutex); StaticMutexAutoLock slock(sMutex);
if (sNumOfCamerasParents++ == 0) { if (sNumOfCamerasParents++ == 0) {
@ -1081,7 +1096,7 @@ CamerasParent::CamerasParent()
MOZ_ASSERT(mPBackgroundEventTarget != nullptr, MOZ_ASSERT(mPBackgroundEventTarget != nullptr,
"GetCurrentThreadEventTarget failed"); "GetCurrentThreadEventTarget failed");
LOG(("Spinning up WebRTC Cameras Thread")); LOG("Spinning up WebRTC Cameras Thread");
RefPtr<CamerasParent> self(this); RefPtr<CamerasParent> self(this);
NS_DispatchToMainThread(NewRunnableFrom([self]() { NS_DispatchToMainThread(NewRunnableFrom([self]() {
@ -1111,7 +1126,7 @@ CamerasParent::CamerasParent()
} }
CamerasParent::~CamerasParent() { CamerasParent::~CamerasParent() {
LOG(("~CamerasParent: %p", this)); LOG("~CamerasParent: %p", this);
StaticMutexAutoLock slock(sMutex); StaticMutexAutoLock slock(sMutex);
if (--sNumOfCamerasParents == 0) { if (--sNumOfCamerasParents == 0) {
delete sThreadMonitor; delete sThreadMonitor;