* Copyright 2005, Ingo Weinhold, bonefish@users.sf.net.
* Distributed under the terms of the MIT License.
*/
#include <stdio.h>
#include <string.h>
#include <OS.h>
#include "external_commands.h"
#include "fs_shell_command_beos.h"
static port_id sReplyPort = -1;
static port_id
get_command_port()
{
static port_id port = -1;
static bool initialized = false;
if (!initialized) {
port = create_port(10, kFSShellCommandPort);
initialized = true;
}
return port;
}
bool
FSShell::get_external_command(char *input, int len)
{
port_id port = get_command_port();
if (port < 0) {
fprintf(stderr, "Error: Failed to create command port: %s\n",
strerror(port));
return false;
}
while (true) {
char _message[sizeof(external_command_message) + kMaxCommandLength];
external_command_message* message = (external_command_message*)_message;
ssize_t bytesRead;
do {
int32 code;
bytesRead = read_port(port, &code, message, sizeof(_message));
} while (bytesRead == B_INTERRUPTED);
if (bytesRead < 0) {
fprintf(stderr, "Error: Reading from port failed: %s\n",
strerror(bytesRead));
return false;
}
int commandLen = _message + bytesRead - message->command;
if (commandLen <= 1) {
fprintf(stderr, "Error: No command given.\n");
continue;
}
if (commandLen > len) {
fprintf(stderr, "Error: Command too long. Ignored.\n");
continue;
}
memcpy(input, message->command, commandLen);
input[len - 1] = '\0';
sReplyPort = message->reply_port;
return true;
}
}
void
FSShell::reply_to_external_command(int result)
{
if (sReplyPort >= 0) {
external_command_reply reply;
reply.error = result;
status_t error;
do {
error = write_port(sReplyPort, 0, &reply, sizeof(reply));
} while (error == B_INTERRUPTED);
sReplyPort = -1;
if (error != B_OK) {
fprintf(stderr, "Error: Failed to send command result to reply "
"port: %s\n", strerror(error));
}
}
}
void
FSShell::external_command_cleanup()
{
}
