libcamera: Drop emitter object pointer from signal arguments

Many signals used in internal and public APIs carry the emitter pointer
as a signal argument. This was done to allow slots connected to multiple
signal instances to differentiate between emitters. While starting from
a good intention of facilitating the implementation of slots, it turned
out to be a bad API design as the signal isn't meant to know what it
will be connected to, and thus shouldn't carry parameters that are
solely meant to support a use case specific to the connected slot.

These pointers turn out to be unused in all slots but one. In the only
case where it is needed, it can be obtained by wrapping the slot in a
lambda function when connecting the signal. Do so, and drop the emitter
pointer from all signals.

Signed-off-by: Laurent Pinchart <laurent.pinchart@ideasonboard.com>
Reviewed-by: Umang Jain <umang.jain@ideasonboard.com>

include/libcamera/base/event_notifier.h

@@ -34,7 +34,7 @@ public:
 	bool enabled() const { return enabled_; }
 	void setEnabled(bool enable);
 
-	Signal<EventNotifier *> activated;
+	Signal<> activated;
 
 protected:
 	void message(Message *msg) override;

include/libcamera/base/thread.h

@@ -41,7 +41,7 @@ public:
 
 	bool isRunning();
 
-	Signal<Thread *> finished;
+	Signal<> finished;
 
 	static Thread *current();
 	static pid_t currentId();

include/libcamera/base/timer.h

@@ -33,7 +33,7 @@ public:
 
 	std::chrono::steady_clock::time_point deadline() const { return deadline_; }
 
-	Signal<Timer *> timeout;
+	Signal<> timeout;
 
 protected:
 	void message(Message *msg) override;

include/libcamera/camera.h

@@ -86,7 +86,7 @@ public:
 
 	Signal<Request *, FrameBuffer *> bufferCompleted;
 	Signal<Request *> requestCompleted;
-	Signal<Camera *> disconnected;
+	Signal<> disconnected;
 
 	int acquire();
 	int release();

include/libcamera/internal/device_enumerator_udev.h

@@ -59,7 +59,7 @@ private:
 	std::string lookupDeviceNode(dev_t devnum);
 
 	int addV4L2Device(dev_t devnum);
-	void udevNotify(EventNotifier *notifier);
+	void udevNotify();
 
 	struct udev *udev_;
 	struct udev_monitor *monitor_;

include/libcamera/internal/ipc_pipe_unixsocket.h

@@ -35,7 +35,7 @@ private:
 		bool done;
 	};
 
-	void readyRead(IPCUnixSocket *socket);
+	void readyRead();
 	int call(const IPCUnixSocket::Payload &message,
 		 IPCUnixSocket::Payload *response, uint32_t seq);
 

include/libcamera/internal/ipc_unixsocket.h

@@ -37,7 +37,7 @@ public:
 	int send(const Payload &payload);
 	int receive(Payload *payload);
 
-	Signal<IPCUnixSocket *> readyRead;
+	Signal<> readyRead;
 
 private:
 	struct Header {
@@ -48,7 +48,7 @@ private:
 	int sendData(const void *buffer, size_t length, const int32_t *fds, unsigned int num);
 	int recvData(void *buffer, size_t length, int32_t *fds, unsigned int num);
 
-	void dataNotifier(EventNotifier *notifier);
+	void dataNotifier();
 
 	int fd_;
 	bool headerReceived_;

include/libcamera/internal/media_device.h

@@ -53,7 +53,7 @@ public:
 	MediaLink *link(const MediaPad *source, const MediaPad *sink);
 	int disableLinks();
 
-	Signal<MediaDevice *> disconnected;
+	Signal<> disconnected;
 
 protected:
 	std::string logPrefix() const override;

include/libcamera/internal/process.h

@@ -38,7 +38,7 @@ public:
 
 	void kill();
 
-	Signal<Process *, enum ExitStatus, int> finished;
+	Signal<enum ExitStatus, int> finished;
 
 private:
 	void closeAllFdsExcept(const std::vector<int> &fds);
@@ -70,7 +70,7 @@ public:
 private:
 	static ProcessManager *self_;
 
-	void sighandler(EventNotifier *notifier);
+	void sighandler();
 
 	std::list<Process *> processes_;
 

include/libcamera/internal/v4l2_device.h

@@ -65,7 +65,7 @@ private:
 	void updateControls(ControlList *ctrls,
 			    Span<const v4l2_ext_control> v4l2Ctrls);
 
-	void eventAvailable(EventNotifier *notifier);
+	void eventAvailable();
 
 	std::map<unsigned int, struct v4l2_query_ext_ctrl> controlInfo_;
 	std::vector<std::unique_ptr<ControlId>> controlIds_;

include/libcamera/internal/v4l2_videodevice.h

@@ -238,7 +238,7 @@ private:
 	std::unique_ptr<FrameBuffer> createBuffer(unsigned int index);
 	FileDescriptor exportDmabufFd(unsigned int index, unsigned int plane);
 
-	void bufferAvailable(EventNotifier *notifier);
+	void bufferAvailable();
 	FrameBuffer *dequeueBuffer();
 
 	V4L2Capability caps_;

src/libcamera/base/event_dispatcher_poll.cpp

@@ -278,7 +278,7 @@ void EventDispatcherPoll::processNotifiers(const std::vector<struct pollfd> &pol
 			}
 
 			if (pfd.revents & event.events)
-				notifier->activated.emit(notifier);
+				notifier->activated.emit();
 		}
 
 		/* Erase the notifiers_ entry if it is now empty. */
@@ -300,7 +300,7 @@ void EventDispatcherPoll::processTimers()
 
 		timers_.pop_front();
 		timer->stop();
-		timer->timeout.emit(timer);
+		timer->timeout.emit();
 	}
 }
 

src/libcamera/base/thread.cpp

@@ -384,7 +384,7 @@ void Thread::finishThread()
 	data_->running_ = false;
 	data_->mutex_.unlock();
 
-	finished.emit(this);
+	finished.emit();
 	data_->cv_.notify_all();
 }
 

src/libcamera/camera.cpp

@@ -688,7 +688,7 @@ void Camera::disconnect()
 	LOG(Camera, Debug) << "Disconnecting camera " << id();
 
 	_d()->disconnect();
-	disconnected.emit(this);
+	disconnected.emit();
 }
 
 int Camera::exportFrameBuffers(Stream *stream,

src/libcamera/device_enumerator.cpp

@@ -288,7 +288,7 @@ void DeviceEnumerator::removeDevice(const std::string &deviceNode)
 	LOG(DeviceEnumerator, Debug)
 		<< "Media device for node " << deviceNode << " removed.";
 
-	media->disconnected.emit(media.get());
+	media->disconnected.emit();
 }
 
 /**

src/libcamera/device_enumerator_udev.cpp

@@ -327,7 +327,7 @@ int DeviceEnumeratorUdev::addV4L2Device(dev_t devnum)
 	return 0;
 }
 
-void DeviceEnumeratorUdev::udevNotify([[maybe_unused]] EventNotifier *notifier)
+void DeviceEnumeratorUdev::udevNotify()
 {
 	struct udev_device *dev = udev_monitor_receive_device(monitor_);
 	std::string action(udev_device_get_action(dev));

src/libcamera/ipc_pipe_unixsocket.cpp

@@ -82,7 +82,7 @@ int IPCPipeUnixSocket::sendAsync(const IPCMessage &data)
 	return 0;
 }
 
-void IPCPipeUnixSocket::readyRead([[maybe_unused]] IPCUnixSocket *socket)
+void IPCPipeUnixSocket::readyRead()
 {
 	IPCUnixSocket::Payload payload;
 	int ret = socket_->receive(&payload);

src/libcamera/ipc_unixsocket.cpp

@@ -311,7 +311,7 @@ int IPCUnixSocket::recvData(void *buffer, size_t length,
 	return 0;
 }
 
-void IPCUnixSocket::dataNotifier([[maybe_unused]] EventNotifier *notifier)
+void IPCUnixSocket::dataNotifier()
 {
 	int ret;
 
@@ -342,7 +342,7 @@ void IPCUnixSocket::dataNotifier([[maybe_unused]] EventNotifier *notifier)
 		return;
 
 	notifier_->setEnabled(false);
-	readyRead.emit(this);
+	readyRead.emit();
 }
 
 } /* namespace libcamera */

src/libcamera/pipeline_handler.cpp

@@ -448,7 +448,7 @@ void PipelineHandler::registerCamera(std::shared_ptr<Camera> camera)
  */
 void PipelineHandler::hotplugMediaDevice(MediaDevice *media)
 {
-	media->disconnected.connect(this, &PipelineHandler::mediaDeviceDisconnected);
+	media->disconnected.connect(this, [=]() { mediaDeviceDisconnected(media); });
 }
 
 /**

src/libcamera/process.cpp

@@ -66,7 +66,7 @@ void sigact(int signal, siginfo_t *info, void *ucontext)
 
 } /* namespace */
 
-void ProcessManager::sighandler([[maybe_unused]] EventNotifier *notifier)
+void ProcessManager::sighandler()
 {
 	char data;
 	ssize_t ret = read(pipe_[0], &data, sizeof(data));
@@ -326,7 +326,7 @@ void Process::died(int wstatus)
 	exitStatus_ = WIFEXITED(wstatus) ? NormalExit : SignalExit;
 	exitCode_ = exitStatus_ == NormalExit ? WEXITSTATUS(wstatus) : -1;
 
-	finished.emit(this, exitStatus_, exitCode_);
+	finished.emit(exitStatus_, exitCode_);
 }
 
 /**

src/libcamera/v4l2_device.cpp

@@ -705,12 +705,11 @@ void V4L2Device::updateControls(ControlList *ctrls,
 
 /**
  * \brief Slot to handle V4L2 events from the V4L2 device
- * \param[in] notifier The event notifier
  *
  * When this slot is called, a V4L2 event is available to be dequeued from the
  * device.
  */
-void V4L2Device::eventAvailable([[maybe_unused]] EventNotifier *notifier)
+void V4L2Device::eventAvailable()
 {
 	struct v4l2_event event{};
 	int ret = ioctl(VIDIOC_DQEVENT, &event);

src/libcamera/v4l2_videodevice.cpp

@@ -1524,7 +1524,6 @@ int V4L2VideoDevice::queueBuffer(FrameBuffer *buffer)
 
 /**
  * \brief Slot to handle completed buffer events from the V4L2 video device
- * \param[in] notifier The event notifier
  *
  * When this slot is called, a Buffer has become available from the device, and
  * will be emitted through the bufferReady Signal.
@@ -1532,7 +1531,7 @@ int V4L2VideoDevice::queueBuffer(FrameBuffer *buffer)
  * For Capture video devices the FrameBuffer will contain valid data.
  * For Output video devices the FrameBuffer can be considered empty.
  */
-void V4L2VideoDevice::bufferAvailable([[maybe_unused]] EventNotifier *notifier)
+void V4L2VideoDevice::bufferAvailable()
 {
 	FrameBuffer *buffer = dequeueBuffer();
 	if (!buffer)

test/event-thread.cpp

@@ -66,7 +66,7 @@ public:
 	}
 
 private:
-	void readReady([[maybe_unused]] EventNotifier *notifier)
+	void readReady()
 	{
 		size_ = read(notifier_->fd(), data_, sizeof(data_));
 		notified_ = true;

test/event.cpp

@@ -22,7 +22,7 @@ using namespace libcamera;
 class EventTest : public Test
 {
 protected:
-	void readReady([[maybe_unused]] EventNotifier *notifier)
+	void readReady()
 	{
 		size_ = read(notifier_->fd(), data_, sizeof(data_));
 		notified_ = true;

test/ipa/ipa_interface_test.cpp

@@ -153,7 +153,7 @@ protected:
 	}
 
 private:
-	void readTrace([[maybe_unused]] EventNotifier *notifier)
+	void readTrace()
 	{
 		ssize_t s = read(notifier_->fd(), &trace_, sizeof(trace_));
 		if (s < 0) {

test/ipc/unixsocket.cpp

@@ -68,7 +68,7 @@ public:
 	}
 
 private:
-	void readyRead([[maybe_unused]] IPCUnixSocket *ipc)
+	void readyRead()
 	{
 		IPCUnixSocket::Payload message, response;
 		int ret;
@@ -447,7 +447,7 @@ private:
 		return 0;
 	}
 
-	void readyRead([[maybe_unused]] IPCUnixSocket *ipc)
+	void readyRead()
 	{
 		if (!callResponse_) {
 			cerr << "Read ready without expecting data, fail." << endl;

test/ipc/unixsocket_ipc.cpp

@@ -65,7 +65,7 @@ public:
 	}
 
 private:
-	void readyRead([[maybe_unused]] IPCUnixSocket *ipc)
+	void readyRead()
 	{
 		IPCUnixSocket::Payload message;
 		int ret;

test/log/log_process.cpp

@@ -126,8 +126,7 @@ protected:
 	}
 
 private:
-	void procFinished([[maybe_unused]] Process *proc,
+	void procFinished(enum Process::ExitStatus exitStatus, int exitCode)
-			  enum Process::ExitStatus exitStatus, int exitCode)
 	{
 		exitStatus_ = exitStatus;
 		exitCode_ = exitCode;

test/process/process_test.cpp

@@ -81,8 +81,7 @@ protected:
 	}
 
 private:
-	void procFinished([[maybe_unused]] Process *proc,
+	void procFinished(enum Process::ExitStatus exitStatus, int exitCode)
-			  enum Process::ExitStatus exitStatus, int exitCode)
 	{
 		exitStatus_ = exitStatus;
 		exitCode_ = exitCode;

test/timer-thread.cpp

@@ -39,7 +39,7 @@ public:
 	}
 
 private:
-	void timeoutHandler([[maybe_unused]] Timer *timer)
+	void timeoutHandler()
 	{
 		timeout_ = true;
 	}

test/timer.cpp

@@ -56,7 +56,7 @@ public:
 	}
 
 private:
-	void timeoutHandler([[maybe_unused]] Timer *timer)
+	void timeoutHandler()
 	{
 		expiration_ = std::chrono::steady_clock::now();
 		count_++;

utils/ipc/generators/libcamera_templates/module_ipa_proxy_worker.cpp.tmpl

@@ -57,7 +57,7 @@ public:
 
 	~{{proxy_worker_name}}() {}
 
-	void readyRead([[maybe_unused]] IPCUnixSocket *socket)
+	void readyRead()
 	{
 		IPCUnixSocket::Payload _message;
 		int _retRecv = socket_.receive(&_message);