URL https://opencores.org/ocsvn/w11/w11/trunk

Subversion Repositories w11

[/] [w11/] [tags/] [w11a_V0.74/] [tools/] [src/] [librlink/] [RlinkPortFifo.cpp] - Blame information for rev 38

Details | Compare with Previous | View Log


// $Id: RlinkPortFifo.cpp 666 2015-04-12 21:17:54Z mueller $
//
// Copyright 2011-2015 by Walter F.J. Mueller <W.F.J.Mueller@gsi.de>
//
// This program is free software; you may redistribute and/or modify it under
// the terms of the GNU General Public License as published by the Free
// Software Foundation, either version 2, 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 complete details.
// 
// Revision History: 
// Date         Rev Version  Comment
// 2015-04-12   666   1.2    add xon,noinit attributes
// 2013-02-23   492   1.1    use RparseUrl
// 2011-03-27   374   1.0    Initial version
// 2011-01-15   356   0.1    First draft
// ---------------------------------------------------------------------------
 
/*!
  \file
  \version $Id: RlinkPortFifo.cpp 666 2015-04-12 21:17:54Z mueller $
  \brief   Implemenation of RlinkPortFifo.
*/
 
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <errno.h>
 
#include "RlinkPortFifo.hpp"
 
using namespace std;
 
/*!
  \class Retro::RlinkPortFifo
  \brief FIXME_docs
*/
 
// all method definitions in namespace Retro
namespace Retro {
 
//------------------------------------------+-----------------------------------
//! Default constructor
 
RlinkPortFifo::RlinkPortFifo()
  : RlinkPort()
{}
 
//------------------------------------------+-----------------------------------
//! Destructor
 
RlinkPortFifo::~RlinkPortFifo()
{
  // no need to call Close() here, no RlinkPortFifo::Close()
  // cleanup will be done by ~RlinkPort()
}
 
//------------------------------------------+-----------------------------------
//! FIXME_docs
 
bool RlinkPortFifo::Open(const std::string& url, RerrMsg& emsg)
{
  if (IsOpen()) Close();
 
  if (!fUrl.Set(url, "|keep|xon|noinit|", emsg)) return false;
 
  // Note: _rx fifo must be opened before the _tx fifo, otherwise the test
  //       bench might close with EOF on read prematurely (is a race condition).
 
  fFdWrite = OpenFifo(fUrl.Path() + "_rx", true, emsg);
  if (fFdWrite < 0) return false;
 
  fFdRead = OpenFifo(fUrl.Path() + "_tx", false, emsg);
  if (fFdRead < 0) {
    close(fFdWrite);
    fFdWrite = -1;
    return false;
  }
 
  fXon = fUrl.FindOpt("xon");
  fIsOpen = true;
 
  return true;
}
 
//------------------------------------------+-----------------------------------
//! FIXME_docs
 
int RlinkPortFifo::OpenFifo(const std::string& name, bool snd, RerrMsg& emsg)
{
  struct stat stat_fifo;
 
  int irc;
 
  irc = stat(name.c_str(), &stat_fifo);
  if (irc == 0) {
    if ((stat_fifo.st_mode & S_IFIFO) == 0) {
      emsg.Init("RlinkPortFifo::OpenFiFo()",
                string("'") + name + "' exists but is not a pipe");
      return -1;
    }
  } else {
    mode_t mode = S_IRUSR | S_IWUSR;        // user read and write allowed
    irc = ::mkfifo(name.c_str(), mode);
    if (irc != 0) {
      emsg.InitErrno("RlinkPortFifo::OpenFifo()",
                     string("mkfifo() for '") + name + "' failed: ",
                     errno);
      return -1;
    }
  }
 
  irc = ::open(name.c_str(), snd ? O_WRONLY : O_RDONLY);
  if (irc < 0) {
    emsg.InitErrno("RlinkPortFifo::OpenFifo()",
                   string("open() for '") + name + "' failed: ",
                   errno);
    return -1;
  }
 
  return irc;
}
 
} // end namespace Retro

Line No.	Rev	Author	Line
1	30	wfjm	`// $Id: RlinkPortFifo.cpp 666 2015-04-12 21:17:54Z mueller $`
2	10	wfjm	`//`
3	30	wfjm	`// Copyright 2011-2015 by Walter F.J. Mueller <W.F.J.Mueller@gsi.de>`
4	10	wfjm	`//`
5			`// This program is free software; you may redistribute and/or modify it under`
6			`// the terms of the GNU General Public License as published by the Free`
7			`// Software Foundation, either version 2, or at your option any later version.`
8			`//`
9			`// This program is distributed in the hope that it will be useful, but`
10			`// WITHOUT ANY WARRANTY, without even the implied warranty of MERCHANTABILITY`
11			`// or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License`
12			`// for complete details.`
13			`//`
14			`// Revision History:`
15			`// Date Rev Version Comment`
16	30	wfjm	`// 2015-04-12 666 1.2 add xon,noinit attributes`
17	19	wfjm	`// 2013-02-23 492 1.1 use RparseUrl`
18	10	wfjm	`// 2011-03-27 374 1.0 Initial version`
19			`// 2011-01-15 356 0.1 First draft`
20			`// ---------------------------------------------------------------------------`
21
22			`/*!`
23			`\file`
24	30	wfjm	`\version $Id: RlinkPortFifo.cpp 666 2015-04-12 21:17:54Z mueller $`
25	10	wfjm	`\brief Implemenation of RlinkPortFifo.`
26			`*/`
27
28			`#include <sys/types.h>`
29			`#include <sys/stat.h>`
30			`#include <fcntl.h>`
31			`#include <errno.h>`
32
33			`#include "RlinkPortFifo.hpp"`
34
35			`using namespace std;`
36
37			`/*!`
38			`\class Retro::RlinkPortFifo`
39	19	wfjm	`\brief FIXME_docs`
40	10	wfjm	`*/`
41
42	19	wfjm	`// all method definitions in namespace Retro`
43			`namespace Retro {`
44
45	10	wfjm	`//------------------------------------------+-----------------------------------`
46			`//! Default constructor`
47
48			`RlinkPortFifo::RlinkPortFifo()`
49			`: RlinkPort()`
50			`{}`
51
52			`//------------------------------------------+-----------------------------------`
53			`//! Destructor`
54
55			`RlinkPortFifo::~RlinkPortFifo()`
56	17	wfjm	`{`
57			`// no need to call Close() here, no RlinkPortFifo::Close()`
58			`// cleanup will be done by ~RlinkPort()`
59			`}`
60	10	wfjm
61			`//------------------------------------------+-----------------------------------`
62	19	wfjm	`//! FIXME_docs`
63	10	wfjm
64			`bool RlinkPortFifo::Open(const std::string& url, RerrMsg& emsg)`
65			`{`
66			`if (IsOpen()) Close();`
67
68	30	wfjm	`if (!fUrl.Set(url, "\|keep\|xon\|noinit\|", emsg)) return false;`
69	10	wfjm
70			`// Note: _rx fifo must be opened before the _tx fifo, otherwise the test`
71			`// bench might close with EOF on read prematurely (is a race condition).`
72
73	19	wfjm	`fFdWrite = OpenFifo(fUrl.Path() + "_rx", true, emsg);`
74	10	wfjm	`if (fFdWrite < 0) return false;`
75
76	19	wfjm	`fFdRead = OpenFifo(fUrl.Path() + "_tx", false, emsg);`
77	10	wfjm	`if (fFdRead < 0) {`
78			`close(fFdWrite);`
79			`fFdWrite = -1;`
80			`return false;`
81			`}`
82
83	30	wfjm	`fXon = fUrl.FindOpt("xon");`
84			`fIsOpen = true;`
85	10	wfjm
86			`return true;`
87			`}`
88
89			`//------------------------------------------+-----------------------------------`
90	19	wfjm	`//! FIXME_docs`
91	10	wfjm
92			`int RlinkPortFifo::OpenFifo(const std::string& name, bool snd, RerrMsg& emsg)`
93			`{`
94			`struct stat stat_fifo;`
95
96			`int irc;`
97
98			`irc = stat(name.c_str(), &stat_fifo);`
99			`if (irc == 0) {`
100			`if ((stat_fifo.st_mode & S_IFIFO) == 0) {`
101			`emsg.Init("RlinkPortFifo::OpenFiFo()",`
102	21	wfjm	`string("'") + name + "' exists but is not a pipe");`
103	10	wfjm	`return -1;`
104			`}`
105			`} else {`
106			`mode_t mode = S_IRUSR \| S_IWUSR; // user read and write allowed`
107	27	wfjm	`irc = ::mkfifo(name.c_str(), mode);`
108	10	wfjm	`if (irc != 0) {`
109			`emsg.InitErrno("RlinkPortFifo::OpenFifo()",`
110	21	wfjm	`string("mkfifo() for '") + name + "' failed: ",`
111	10	wfjm	`errno);`
112			`return -1;`
113			`}`
114			`}`
115
116	27	wfjm	`irc = ::open(name.c_str(), snd ? O_WRONLY : O_RDONLY);`
117	10	wfjm	`if (irc < 0) {`
118			`emsg.InitErrno("RlinkPortFifo::OpenFifo()",`
119	21	wfjm	`string("open() for '") + name + "' failed: ",`
120	10	wfjm	`errno);`
121			`return -1;`
122			`}`
123
124			`return irc;`
125			`}`
126
127	19	wfjm	`} // end namespace Retro`

Browse

Tools

Subversion Repositories w11

[/] [w11/] [tags/] [w11a_V0.74/] [tools/] [src/] [librlink/] [RlinkPortFifo.cpp] - Blame information for rev 38