1 files changed, 9 insertions, 9 deletions

diff --git a/libusbmuxd/libusbmuxd.c b/libusbmuxd/libusbmuxd.c
index 6a54765..2fbe139 100644
--- a/libusbmuxd/libusbmuxd.c
+++ b/libusbmuxd/libusbmuxd.c
@@ -88,7 +88,7 @@ static int usbmuxd_get_result(int sfd, uint32_t tag, uint32_t * result)
  * A reference to a populated usbmuxd_event_t with information about the event
  * and the corresponding device will be passed to the callback function.
  */
-static void generate_event(usbmuxd_event_cb_t callback, const usbmuxd_device_info_t *dev, enum usbmuxd_device_event event)
+static void generate_event(usbmuxd_event_cb_t callback, const usbmuxd_device_info_t *dev, enum usbmuxd_device_event event, void *user_data)
 {
 	usbmuxd_event_t ev;
 
@@ -101,7 +101,7 @@ static void generate_event(usbmuxd_event_cb_t callback, const usbmuxd_device_inf
 
 	printf("%s: event=%d, handle=%d\n", __func__, ev.event, ev.device.handle);
 
-	callback(&ev);
+	callback(&ev, user_data);
 }
 
 /**
@@ -157,7 +157,7 @@ static int usbmuxd_listen()
  * Waits for an event to occur, i.e. a packet coming from usbmuxd.
  * Calls generate_event to pass the event via callback to the client program.
  */
-int get_next_event(int sfd, usbmuxd_event_cb_t callback)
+int get_next_event(int sfd, usbmuxd_event_cb_t callback, void *user_data)
 {
 	int recv_len;
 	struct usbmuxd_listen_request req;
@@ -173,7 +173,7 @@ int get_next_event(int sfd, usbmuxd_event_cb_t callback)
 		// is still present so applications know about it
 		// TODO: is this behaviour correct?
 		FOREACH(usbmuxd_device_info_t *dev, &devices) {
-			generate_event(callback, dev, UE_DEVICE_REMOVE);
+			generate_event(callback, dev, UE_DEVICE_REMOVE, user_data);
 		} ENDFOREACH
 		collection_free(&devices);
 		return recv_len;
@@ -201,7 +201,7 @@ int get_next_event(int sfd, usbmuxd_event_cb_t callback)
 			memcpy(devinfo->uuid, dev.serial_number, sizeof(devinfo->uuid));
 
 			collection_add(&devices, devinfo);
-			generate_event(callback, devinfo, UE_DEVICE_ADD);
+			generate_event(callback, devinfo, UE_DEVICE_ADD, user_data);
 		} else if (hdr.message == MESSAGE_DEVICE_REMOVE) {
 			uint32_t handle;
 			usbmuxd_device_info_t *dev;
@@ -219,7 +219,7 @@ int get_next_event(int sfd, usbmuxd_event_cb_t callback)
 			if (!dev) {
 				fprintf(stderr, "WARNING: got device remove message for handle %d, but couldn't find the corresponding handle in the device list. This event will be ignored.\n", handle);
 			} else {
-				generate_event(callback, dev, UE_DEVICE_REMOVE);
+				generate_event(callback, dev, UE_DEVICE_REMOVE, user_data);
 				collection_remove(&devices, dev);
 			}
 		} else {
@@ -250,7 +250,7 @@ static void *device_monitor(void *data)
 
 		while (event_cb) {
 			printf("waiting for events\n");
-			int res = get_next_event(listenfd, event_cb);
+			int res = get_next_event(listenfd, event_cb, data);
 			if (res < 0) {
 			    fprintf(stderr, "%s: closing connection (code %d)\n", __func__, res);
 			    break;
@@ -264,7 +264,7 @@ static void *device_monitor(void *data)
 	return NULL;
 }
 
-int usbmuxd_subscribe(usbmuxd_event_cb_t callback)
+int usbmuxd_subscribe(usbmuxd_event_cb_t callback, void *user_data)
 {
 	int res;
 
@@ -273,7 +273,7 @@ int usbmuxd_subscribe(usbmuxd_event_cb_t callback)
 	}
 	event_cb = callback;
 
-	res = pthread_create(&devmon, NULL, device_monitor, NULL);
+	res = pthread_create(&devmon, NULL, device_monitor, user_data);
 	if (res != 0) {
 		fprintf(stderr, "ERROR: Could not start device watcher thread!\n");
 		return res;