protocol/Result: convert to Client method
This commit is contained in:
@@ -265,7 +265,6 @@ sources = [
|
|||||||
version_cxx,
|
version_cxx,
|
||||||
'src/Main.cxx',
|
'src/Main.cxx',
|
||||||
'src/protocol/ArgParser.cxx',
|
'src/protocol/ArgParser.cxx',
|
||||||
'src/protocol/Result.cxx',
|
|
||||||
'src/command/CommandError.cxx',
|
'src/command/CommandError.cxx',
|
||||||
'src/command/PositionArg.cxx',
|
'src/command/PositionArg.cxx',
|
||||||
'src/command/AllCommands.cxx',
|
'src/command/AllCommands.cxx',
|
||||||
|
@@ -154,6 +154,10 @@ public:
|
|||||||
return Write(s.data(), s.size());
|
return Write(s.data(), s.size());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
bool WriteOK() noexcept {
|
||||||
|
return Write("OK\n");
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* returns the uid of the client process, or a negative value
|
* returns the uid of the client process, or a negative value
|
||||||
* if the uid is unknown
|
* if the uid is unknown
|
||||||
|
@@ -20,7 +20,6 @@
|
|||||||
#include "Client.hxx"
|
#include "Client.hxx"
|
||||||
#include "Config.hxx"
|
#include "Config.hxx"
|
||||||
#include "Domain.hxx"
|
#include "Domain.hxx"
|
||||||
#include "protocol/Result.hxx"
|
|
||||||
#include "command/AllCommands.hxx"
|
#include "command/AllCommands.hxx"
|
||||||
#include "Log.hxx"
|
#include "Log.hxx"
|
||||||
#include "util/StringAPI.hxx"
|
#include "util/StringAPI.hxx"
|
||||||
@@ -72,7 +71,7 @@ Client::ProcessLine(char *line) noexcept
|
|||||||
if (idle_waiting) {
|
if (idle_waiting) {
|
||||||
/* send empty idle response and leave idle mode */
|
/* send empty idle response and leave idle mode */
|
||||||
idle_waiting = false;
|
idle_waiting = false;
|
||||||
command_success(*this);
|
WriteOK();
|
||||||
}
|
}
|
||||||
|
|
||||||
/* do nothing if the client wasn't idling: the client
|
/* do nothing if the client wasn't idling: the client
|
||||||
@@ -108,7 +107,7 @@ Client::ProcessLine(char *line) noexcept
|
|||||||
"list returned {}", id, unsigned(ret));
|
"list returned {}", id, unsigned(ret));
|
||||||
|
|
||||||
if (ret == CommandResult::OK)
|
if (ret == CommandResult::OK)
|
||||||
command_success(*this);
|
WriteOK();
|
||||||
|
|
||||||
return ret;
|
return ret;
|
||||||
} else {
|
} else {
|
||||||
@@ -144,7 +143,7 @@ Client::ProcessLine(char *line) noexcept
|
|||||||
return CommandResult::CLOSE;
|
return CommandResult::CLOSE;
|
||||||
|
|
||||||
if (ret == CommandResult::OK)
|
if (ret == CommandResult::OK)
|
||||||
command_success(*this);
|
WriteOK();
|
||||||
|
|
||||||
return ret;
|
return ret;
|
||||||
}
|
}
|
||||||
|
@@ -21,7 +21,6 @@
|
|||||||
#include "Client.hxx"
|
#include "Client.hxx"
|
||||||
#include "Response.hxx"
|
#include "Response.hxx"
|
||||||
#include "command/CommandError.hxx"
|
#include "command/CommandError.hxx"
|
||||||
#include "protocol/Result.hxx"
|
|
||||||
|
|
||||||
ThreadBackgroundCommand::ThreadBackgroundCommand(Client &_client) noexcept
|
ThreadBackgroundCommand::ThreadBackgroundCommand(Client &_client) noexcept
|
||||||
:thread(BIND_THIS_METHOD(_Run)),
|
:thread(BIND_THIS_METHOD(_Run)),
|
||||||
@@ -57,7 +56,7 @@ ThreadBackgroundCommand::DeferredFinish() noexcept
|
|||||||
PrintError(response, error);
|
PrintError(response, error);
|
||||||
} else {
|
} else {
|
||||||
SendResponse(response);
|
SendResponse(response);
|
||||||
command_success(client);
|
client.WriteOK();
|
||||||
}
|
}
|
||||||
|
|
||||||
/* delete this object */
|
/* delete this object */
|
||||||
|
@@ -1,27 +0,0 @@
|
|||||||
/*
|
|
||||||
* Copyright 2003-2021 The Music Player Daemon Project
|
|
||||||
* http://www.musicpd.org
|
|
||||||
*
|
|
||||||
* This program is free software; you can redistribute it and/or modify
|
|
||||||
* it under the terms of the GNU General Public License as published by
|
|
||||||
* the Free Software Foundation; either version 2 of the License, or
|
|
||||||
* (at your option) any later version.
|
|
||||||
*
|
|
||||||
* This program is distributed in the hope that it will be useful,
|
|
||||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
||||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
||||||
* GNU General Public License for more details.
|
|
||||||
*
|
|
||||||
* You should have received a copy of the GNU General Public License along
|
|
||||||
* with this program; if not, write to the Free Software Foundation, Inc.,
|
|
||||||
* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
|
|
||||||
*/
|
|
||||||
|
|
||||||
#include "Result.hxx"
|
|
||||||
#include "client/Client.hxx"
|
|
||||||
|
|
||||||
void
|
|
||||||
command_success(Client &client)
|
|
||||||
{
|
|
||||||
client.Write("OK\n");
|
|
||||||
}
|
|
@@ -1,28 +0,0 @@
|
|||||||
/*
|
|
||||||
* Copyright 2003-2021 The Music Player Daemon Project
|
|
||||||
* http://www.musicpd.org
|
|
||||||
*
|
|
||||||
* This program is free software; you can redistribute it and/or modify
|
|
||||||
* it under the terms of the GNU General Public License as published by
|
|
||||||
* the Free Software Foundation; either version 2 of the License, or
|
|
||||||
* (at your option) any later version.
|
|
||||||
*
|
|
||||||
* This program is distributed in the hope that it will be useful,
|
|
||||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
||||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
||||||
* GNU General Public License for more details.
|
|
||||||
*
|
|
||||||
* You should have received a copy of the GNU General Public License along
|
|
||||||
* with this program; if not, write to the Free Software Foundation, Inc.,
|
|
||||||
* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
|
|
||||||
*/
|
|
||||||
|
|
||||||
#ifndef MPD_PROTOCOL_RESULT_HXX
|
|
||||||
#define MPD_PROTOCOL_RESULT_HXX
|
|
||||||
|
|
||||||
class Client;
|
|
||||||
|
|
||||||
void
|
|
||||||
command_success(Client &client);
|
|
||||||
|
|
||||||
#endif
|
|
Reference in New Issue
Block a user