summaryrefslogtreecommitdiff
path: root/src/dev/terminal.cc
diff options
context:
space:
mode:
authorAndreas Sandberg <andreas.sandberg@arm.com>2017-07-20 11:58:06 +0100
committerAndreas Sandberg <andreas.sandberg@arm.com>2017-11-08 20:04:53 +0000
commit20de3bb759a36dbffed10adae2159e376b7cb68c (patch)
tree8984162e7204528cd5297e5514a4e6deda4536a3 /src/dev/terminal.cc
parent74d3f8a1765869765b542fd91114628a62947ba9 (diff)
downloadgem5-20de3bb759a36dbffed10adae2159e376b7cb68c.tar.xz
dev: Move generic serial devices to src/dev/serial
Change-Id: I104227fc460f8b561e7375b329a541c1fce881b2 Signed-off-by: Andreas Sandberg <andreas.sandberg@arm.com> Reviewed-by: Curtis Dunham <curtis.dunham@arm.com> Reviewed-on: https://gem5-review.googlesource.com/4291 Reviewed-by: Gabe Black <gabeblack@google.com>
Diffstat (limited to 'src/dev/terminal.cc')
-rw-r--r--src/dev/terminal.cc345
1 files changed, 0 insertions, 345 deletions
diff --git a/src/dev/terminal.cc b/src/dev/terminal.cc
deleted file mode 100644
index 4f9881ddd..000000000
--- a/src/dev/terminal.cc
+++ /dev/null
@@ -1,345 +0,0 @@
-/*
- * Copyright (c) 2001-2005 The Regents of The University of Michigan
- * All rights reserved.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions are
- * met: redistributions of source code must retain the above copyright
- * notice, this list of conditions and the following disclaimer;
- * redistributions in binary form must reproduce the above copyright
- * notice, this list of conditions and the following disclaimer in the
- * documentation and/or other materials provided with the distribution;
- * neither the name of the copyright holders nor the names of its
- * contributors may be used to endorse or promote products derived from
- * this software without specific prior written permission.
- *
- * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
- * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
- * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
- * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
- * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
- * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
- * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
- * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
- * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
- * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
- * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
- *
- * Authors: Nathan Binkert
- * Ali Saidi
- */
-
-/* @file
- * Implements the user interface to a serial terminal
- */
-
-#include <sys/ioctl.h>
-
-#if defined(__FreeBSD__)
-#include <termios.h>
-
-#else
-#include <sys/termios.h>
-
-#endif
-#include "dev/terminal.hh"
-
-#include <poll.h>
-#include <unistd.h>
-
-#include <cctype>
-#include <cerrno>
-#include <fstream>
-#include <iostream>
-#include <sstream>
-#include <string>
-
-#include "base/atomicio.hh"
-#include "base/misc.hh"
-#include "base/output.hh"
-#include "base/socket.hh"
-#include "base/trace.hh"
-#include "debug/Terminal.hh"
-#include "debug/TerminalVerbose.hh"
-#include "dev/platform.hh"
-#include "dev/uart.hh"
-
-using namespace std;
-
-
-/*
- * Poll event for the listen socket
- */
-Terminal::ListenEvent::ListenEvent(Terminal *t, int fd, int e)
- : PollEvent(fd, e), term(t)
-{
-}
-
-void
-Terminal::ListenEvent::process(int revent)
-{
- term->accept();
-}
-
-/*
- * Poll event for the data socket
- */
-Terminal::DataEvent::DataEvent(Terminal *t, int fd, int e)
- : PollEvent(fd, e), term(t)
-{
-}
-
-void
-Terminal::DataEvent::process(int revent)
-{
- // As a consequence of being called from the PollQueue, we might
- // have been called from a different thread. Migrate to "our"
- // thread.
- EventQueue::ScopedMigration migrate(term->eventQueue());
-
- if (revent & POLLIN)
- term->data();
- else if (revent & POLLNVAL)
- term->detach();
-}
-
-/*
- * Terminal code
- */
-Terminal::Terminal(const Params *p)
- : SerialDevice(p), listenEvent(NULL), dataEvent(NULL),
- number(p->number), data_fd(-1), txbuf(16384), rxbuf(16384),
- outfile(p->output ? simout.findOrCreate(p->name) : NULL)
-#if TRACING_ON == 1
- , linebuf(16384)
-#endif
-{
- if (outfile)
- outfile->stream()->setf(ios::unitbuf);
-
- if (p->port)
- listen(p->port);
-}
-
-Terminal::~Terminal()
-{
- if (data_fd != -1)
- ::close(data_fd);
-
- if (listenEvent)
- delete listenEvent;
-
- if (dataEvent)
- delete dataEvent;
-}
-
-
-///////////////////////////////////////////////////////////////////////
-// socket creation and terminal attach
-//
-
-void
-Terminal::listen(int port)
-{
- if (ListenSocket::allDisabled()) {
- warn_once("Sockets disabled, not accepting terminal connections");
- return;
- }
-
- while (!listener.listen(port, true)) {
- DPRINTF(Terminal,
- ": can't bind address terminal port %d inuse PID %d\n",
- port, getpid());
- port++;
- }
-
- int p1, p2;
- p2 = name().rfind('.') - 1;
- p1 = name().rfind('.', p2);
- ccprintf(cerr, "Listening for %s connection on port %d\n",
- name().substr(p1+1,p2-p1), port);
-
- listenEvent = new ListenEvent(this, listener.getfd(), POLLIN);
- pollQueue.schedule(listenEvent);
-}
-
-void
-Terminal::accept()
-{
- if (!listener.islistening())
- panic("%s: cannot accept a connection if not listening!", name());
-
- int fd = listener.accept(true);
- if (data_fd != -1) {
- char message[] = "terminal already attached!\n";
- atomic_write(fd, message, sizeof(message));
- ::close(fd);
- return;
- }
-
- data_fd = fd;
- dataEvent = new DataEvent(this, data_fd, POLLIN);
- pollQueue.schedule(dataEvent);
-
- stringstream stream;
- ccprintf(stream, "==== m5 slave terminal: Terminal %d ====", number);
-
- // we need an actual carriage return followed by a newline for the
- // terminal
- stream << "\r\n";
-
- write((const uint8_t *)stream.str().c_str(), stream.str().size());
-
- DPRINTFN("attach terminal %d\n", number);
- char buf[1024];
- for (size_t i = 0; i < txbuf.size(); i += sizeof(buf)) {
- const size_t chunk_len(std::min(txbuf.size() - i, sizeof(buf)));
- txbuf.peek(buf, i, chunk_len);
- write((const uint8_t *)buf, chunk_len);
- }
-}
-
-void
-Terminal::detach()
-{
- if (data_fd != -1) {
- ::close(data_fd);
- data_fd = -1;
- }
-
- pollQueue.remove(dataEvent);
- delete dataEvent;
- dataEvent = NULL;
-
- DPRINTFN("detach terminal %d\n", number);
-}
-
-void
-Terminal::data()
-{
- uint8_t buf[1024];
- int len;
-
- len = read(buf, sizeof(buf));
- if (len) {
- rxbuf.write((char *)buf, len);
- notifyInterface();
- }
-}
-
-size_t
-Terminal::read(uint8_t *buf, size_t len)
-{
- if (data_fd < 0)
- panic("Terminal not properly attached.\n");
-
- ssize_t ret;
- do {
- ret = ::read(data_fd, buf, len);
- } while (ret == -1 && errno == EINTR);
-
-
- if (ret < 0)
- DPRINTFN("Read failed.\n");
-
- if (ret <= 0) {
- detach();
- return 0;
- }
-
- return ret;
-}
-
-// Terminal output.
-size_t
-Terminal::write(const uint8_t *buf, size_t len)
-{
- if (data_fd < 0)
- panic("Terminal not properly attached.\n");
-
- ssize_t ret = atomic_write(data_fd, buf, len);
- if (ret < len)
- detach();
-
- return ret;
-}
-
-#define MORE_PENDING (ULL(1) << 61)
-#define RECEIVE_SUCCESS (ULL(0) << 62)
-#define RECEIVE_NONE (ULL(2) << 62)
-#define RECEIVE_ERROR (ULL(3) << 62)
-
-uint8_t
-Terminal::readData()
-{
- uint8_t c;
-
- assert(!rxbuf.empty());
- rxbuf.read((char *)&c, 1);
-
- DPRINTF(TerminalVerbose, "in: \'%c\' %#02x more: %d\n",
- isprint(c) ? c : ' ', c, !rxbuf.empty());
-
- return c;
-}
-
-uint64_t
-Terminal::console_in()
-{
- uint64_t value;
-
- if (dataAvailable()) {
- value = RECEIVE_SUCCESS | readData();
- if (!rxbuf.empty())
- value |= MORE_PENDING;
- } else {
- value = RECEIVE_NONE;
- }
-
- DPRINTF(TerminalVerbose, "console_in: return: %#x\n", value);
-
- return value;
-}
-
-void
-Terminal::writeData(uint8_t c)
-{
-#if TRACING_ON == 1
- if (DTRACE(Terminal)) {
- static char last = '\0';
-
- if ((c != '\n' && c != '\r') || (last != '\n' && last != '\r')) {
- if (c == '\n' || c == '\r') {
- int size = linebuf.size();
- char *buffer = new char[size + 1];
- linebuf.read(buffer, size);
- buffer[size] = '\0';
- DPRINTF(Terminal, "%s\n", buffer);
- delete [] buffer;
- } else {
- linebuf.write(&c, 1);
- }
- }
-
- last = c;
- }
-#endif
-
- txbuf.write(&c, 1);
-
- if (data_fd >= 0)
- write(c);
-
- if (outfile)
- outfile->stream()->put((char)c);
-
- DPRINTF(TerminalVerbose, "out: \'%c\' %#02x\n",
- isprint(c) ? c : ' ', (int)c);
-
-}
-
-Terminal *
-TerminalParams::create()
-{
- return new Terminal(this);
-}