system/pipewire
system/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire synced 2024-09-20 00:11:31 +00:00
Code Issues Packages Projects Releases Wiki Activity

node: dispatch RequestProcess event and command

Browse source 
The event is send to the driver node.
The command is sent to node directly.
This commit is contained in:
Wim Taymans 2021-10-19 16:01:08 +02:00
parent 3471391e0e
commit b5080a0395
2 changed files with 11 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/modules/module-client-node/remote-node.c
View file

@ -511,7 +511,9 @@ static int client_node_command(void *object, const struct spa_command *command)
pw_proxy_error(proxy, res, "suspend failed"); pw_proxy_error(proxy, res, "suspend failed");
} }
break; break;
case SPA_NODE_COMMAND_RequestProcess:
res = pw_impl_node_send_command(data->node, command);
break;
default: default:
pw_log_warn("unhandled node command %d", SPA_NODE_COMMAND_ID(command)); pw_log_warn("unhandled node command %d", SPA_NODE_COMMAND_ID(command));
res = -ENOTSUP; res = -ENOTSUP;

9
src/pipewire/impl-node.c
View file

@ -1437,8 +1437,15 @@ static void node_event(void *data, const struct spa_event *event)
node_update_state(node, PW_NODE_STATE_ERROR, node_update_state(node, PW_NODE_STATE_ERROR,
-EFAULT, strdup("Received error event")); -EFAULT, strdup("Received error event"));
break; break;
case SPA_NODE_EVENT_RequestProcess:
pw_log_debug("request process");
if (!node->driving) {
pw_impl_node_send_command(node->driver_node,
&SPA_NODE_COMMAND_INIT(SPA_NODE_COMMAND_RequestProcess));
}
break;
default: default:
pw_log_debug("unhandled event"); pw_log_debug("unhandled event %d", SPA_NODE_EVENT_ID(event));
break; break;
} }
pw_impl_node_emit_event(node, event); pw_impl_node_emit_event(node, event);