goto out_err;
}
- waiter_register(waitset, client->fd, WAIT_IN, discover_client_process,
- client);
+ waiter_register_io(waitset, client->fd, WAIT_IN,
+ discover_client_process, client);
return client;
return rc;
}
+
+int discover_client_cancel_default(struct discover_client *client)
+{
+ struct pb_protocol_message *message;
+
+ message = pb_protocol_create_message(client,
+ PB_PROTOCOL_ACTION_CANCEL_DEFAULT, 0);
+
+ if (!message)
+ return -1;
+
+ return pb_protocol_write_message(client->fd, message);
+}