LSST Applications g0f08755f38+9c285cab97,g1635faa6d4+bcae251498,g1653933729+a8ce1bb630,g1a0ca8cf93+bf6eb00ceb,g28da252d5a+0829b12dee,g29321ee8c0+18ecbd06b3,g2bbee38e9b+9634bc57db,g2bc492864f+9634bc57db,g2cdde0e794+c2c89b37c4,g3156d2b45e+41e33cbcdc,g347aa1857d+9634bc57db,g35bb328faa+a8ce1bb630,g3a166c0a6a+9634bc57db,g3e281a1b8c+9f2c4e2fc3,g414038480c+077ccc18e7,g41af890bb2+fde0dd39b6,g5fbc88fb19+17cd334064,g7642f7d749+9c285cab97,g781aacb6e4+a8ce1bb630,g80478fca09+55a9465950,g82479be7b0+ed77629bff,g858d7b2824+9c285cab97,g9125e01d80+a8ce1bb630,g9726552aa6+10f999ec6a,ga5288a1d22+2a84bb7594,gacf8899fa4+c69c5206e8,gae0086650b+a8ce1bb630,gb58c049af0+d64f4d3760,gbd46683f8f+1c79523530,gc28159a63d+9634bc57db,gcf0d15dbbd+4b7d09cae4,gda3e153d99+9c285cab97,gda6a2b7d83+4b7d09cae4,gdaeeff99f8+1711a396fd,ge2409df99d+dfd3d5294a,ge79ae78c31+9634bc57db,gf0baf85859+147a0692ba,gf3967379c6+02b11634a5,w.2024.46
LSST Data Management Base Package
Loading...
Searching...
No Matches
Channel.cc
Go to the documentation of this file.
1/*
2 * LSST Data Management System
3 * Copyright 2017 AURA/LSST.
4 *
5 * This product includes software developed by the
6 * LSST Project (http://www.lsst.org/).
7 *
8 * This program is free software: you can redistribute it and/or modify
9 * it under the terms of the GNU General Public License as published by
10 * the Free Software Foundation, either version 3 of the License, or
11 * (at your option) any later version.
12 *
13 * This program is distributed in the hope that it will be useful,
14 * but WITHOUT ANY WARRANTY; without even the implied warranty of
15 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
16 * GNU General Public License for more details.
17 *
18 * You should have received a copy of the LSST License Statement and
19 * the GNU General Public License along with this program. If not,
20 * see <https://www.lsstcorp.org/LegalNotices/>.
21 */
22
23#include "astshim/base.h"
24#include "astshim/KeyMap.h"
25#include "astshim/Object.h"
26#include "astshim/Stream.h"
27#include "astshim/Channel.h"
28
29namespace ast {
30
32 : Channel(astChannel(detail::source, detail::sink, "%s", options.c_str()), stream) {
33 assertOK();
34}
35
36Channel::Channel(AstChannel *chan, Stream &stream, bool isFits)
37 : Object(reinterpret_cast<AstObject *>(chan)), _stream(stream) {
38 astPutChannelData(getRawPtr(), &_stream);
39 _stream.setIsFits(isFits);
40 assertOK();
41}
42
43Channel::Channel(AstChannel *chan) : Object(reinterpret_cast<AstObject *>(chan)), _stream() { assertOK(); }
44
46 if (_stream.hasStdStream()) {
47 // avoid any attempt to read or write while the stream is being destroyed
48 astPutChannelData(getRawPtr(), nullptr);
49 }
50}
51
53 AstObject *rawRet = reinterpret_cast<AstObject *>(astRead(getRawPtr()));
54 assertOK(rawRet);
55 if (!rawRet) {
56 throw std::runtime_error("Could not read an AST object from this channel");
57 }
58 return Object::fromAstObject<Object>(rawRet, false);
59}
60
61int Channel::write(Object const &object) {
62 int ret = astWrite(getRawPtr(), object.getRawPtr());
63 assertOK();
64 return ret;
65}
66
68 AstKeyMap *rawKeyMap =
69 reinterpret_cast<AstKeyMap *>(astWarnings(reinterpret_cast<AstChannel const *>(getRawPtr())));
70 assertOK();
71 return rawKeyMap ? KeyMap(rawKeyMap) : KeyMap();
72}
73
74} // namespace ast
Channel provides input/output of AST objects.
Definition Channel.h:60
virtual ~Channel()
Definition Channel.cc:45
KeyMap warnings() const
Return a KeyMap holding the text of any warnings issued as a result of the previous invocation of rea...
Definition Channel.cc:67
Channel(Stream &stream, std::string const &options="")
Construct a channel that uses a provided Stream.
Definition Channel.cc:31
std::shared_ptr< Object > read()
Read an object from a channel.
Definition Channel.cc:52
int write(Object const &object)
Write an object to a channel.
Definition Channel.cc:61
KeyMap is used to store a set of values with associated keys which identify the values.
Definition KeyMap.h:83
Abstract base class for all AST objects.
Definition Object.h:51
AstObject const * getRawPtr() const
Get the raw AST pointer.
Definition Object.h:292
A stream for ast::Channel.
Definition Stream.h:41
bool hasStdStream()
Return true if this Stream has an input or output std::stream.
Definition Stream.h:73
void setIsFits(bool isFits)
set isFits
Definition Stream.h:129
AST wrapper classes and functions.
void assertOK(AstObject *rawPtr1=nullptr, AstObject *rawPtr2=nullptr)
Throw std::runtime_error if AST's state is bad.
Definition base.cc:49