search for: stdin_read

..."Command output: {output}", + path => $path, + host => $uri->host, + output => $msg))); + } + + return $vol; +} + +sub _connect +{ + my ($host, $username, $path) = @_; + + my ($stdin_read, $stdin_write); + my ($stdout_read, $stdout_write); + my ($stderr_read, $stderr_write); + + pipe($stdin_read, $stdin_write); + pipe($stdout_read, $stdout_write); + pipe($stderr_read, $stderr_write); + + my $pid = fork(); + if ($pid == 0) { + my @command; + push(@c...

...t actually produces the data which gets streamed. * @@ -101,17 +150,21 @@ input_module_t *mod = calloc(1, sizeof(input_module_t)); stdinpcm_state *s; module_param_t *current; + int use_metadata = 1; /* Default to on */ mod->type = ICES_INPUT_PCM; mod->getdata = stdin_read; mod->handle_event = event_handler; - mod->metadata_update = NULL; + mod->metadata_update = metadata_update; mod->internal = malloc(sizeof(stdinpcm_state)); s = mod->internal; s->rate = 44100; /* Defaults */ s->channels = 2; + s->metada...

...path => $path, - host => $uri->host, - output => $msg))); - } - - return $vol; -} - -sub _connect -{ - my ($host, $username, $path) = @_; + my $self = {}; + bless($self, $class); my ($stdin_read, $stdin_write); my ($stdout_read, $stdout_write); @@ -137,22 +44,8 @@ sub _connect my @command; push(@command, 'ssh'); push(@command, '-l', $username) if (defined($username)); - push(@command, $host); - - # Return the size of the remote...