/*
* Application can be unregistered before so
* this is possible hence simply stopping the
* update.
*/
DBG3("UST app update failed to find app sock %d", app_sock);
/*
* Application can be unregistered before so
* this is possible hence simply stopping the
* update.
*/
DBG3("UST app update failed to find app sock %d", app_sock);
if (pollfd == wait_node->app->sock && (revents & (LPOLLHUP | LPOLLERR))) {
cds_list_del(&wait_node->head);
wait_queue->count--;
if (pollfd == wait_node->app->sock && (revents & (LPOLLHUP | LPOLLERR))) {
cds_list_del(&wait_node->head);
wait_queue->count--;
/*
* Silence warning of use-after-free in
* cds_list_for_each_entry_safe which uses
* __typeof__(*wait_node).
*/
/*
* Silence warning of use-after-free in
* cds_list_for_each_entry_safe which uses
* __typeof__(*wait_node).
*/
- struct ust_command *ust_cmd = NULL;
- struct ust_reg_wait_node *wait_node = NULL, *tmp_wait_node;
+ struct ust_command *ust_cmd = nullptr;
+ struct ust_reg_wait_node *wait_node = nullptr, *tmp_wait_node;
/* Dequeue command for registration */
node = cds_wfcq_dequeue_blocking(¬ifiers->ust_cmd_queue->head,
¬ifiers->ust_cmd_queue->tail);
/* Dequeue command for registration */
node = cds_wfcq_dequeue_blocking(¬ifiers->ust_cmd_queue->head,
¬ifiers->ust_cmd_queue->tail);
/*
* We have to continue here since we don't have the notify
* socket and the application MUST be added to the hash table
/*
* We have to continue here since we don't have the notify
* socket and the application MUST be added to the hash table
ret = send_socket_to_thread(
notifiers->apps_cmd_notify_pipe_write_fd, app->notify_sock);
if (ret < 0) {
ret = send_socket_to_thread(
notifiers->apps_cmd_notify_pipe_write_fd, app->notify_sock);
if (ret < 0) {
/* Dequeue command for registration */
node = cds_wfcq_dequeue_blocking(¬ifiers->ust_cmd_queue->head,
¬ifiers->ust_cmd_queue->tail);
/* Dequeue command for registration */
node = cds_wfcq_dequeue_blocking(¬ifiers->ust_cmd_queue->head,
¬ifiers->ust_cmd_queue->tail);