1 /*
2 * CustomTextualInputOutputPort.cpp -
3 *
4 * Copyright (c) 2008 Higepon(Taro Minowa) <higepon@users.sourceforge.jp>
5 *
6 * Redistribution and use in source and binary forms, with or without
7 * modification, are permitted provided that the following conditions
8 * are met:
9 *
10 * 1. Redistributions of source code must retain the above copyright
11 * notice, this list of conditions and the following disclaimer.
12 *
13 * 2. Redistributions in binary form must reproduce the above copyright
14 * notice, this list of conditions and the following disclaimer in the
15 * documentation and/or other materials provided with the distribution.
16 *
17 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
18 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
19 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
20 * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
21 * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
22 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED
23 * TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
24 * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
25 * LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
26 * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
27 * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
28 *
29 * $Id: CustomTextualInputPort.cpp 183 2008-07-04 06:19:28Z higepon $
30 */
31
32
33 #include "Object.h"
34 #include "Object-inl.h"
35 #include "Pair.h"
36 #include "Pair-inl.h"
37 #include "ByteVector.h"
38 #include "CustomTextualInputOutputPort.h"
39 #include "Bignum.h"
40 #include "SString.h"
41 #include "VM.h"
42 #include "Transcoder.h"
43 #include "OSCompat.h"
44
45 using namespace scheme;
46
CustomTextualInputOutputPort(VM * theVM,const ucs4string & id,Object readProc,Object writeProc,Object getPositionProc,Object setPositionProc,Object closeProc)47 CustomTextualInputOutputPort::CustomTextualInputOutputPort(VM* theVM,
48 const ucs4string& id,
49 Object readProc,
50 Object writeProc,
51 Object getPositionProc,
52 Object setPositionProc,
53 Object closeProc)
54 : theVM_(theVM),
55 id_(id),
56 readProc_(readProc),
57 writeProc_(writeProc),
58 getPositionProc_(getPositionProc),
59 setPositionProc_(setPositionProc),
60 closeProc_(closeProc),
61 buffer_(UC("")),
62 line_(1),
63 isClosed_(false)
64 {
65 MOSH_ASSERT(readProc_.isProcedure());
66 MOSH_ASSERT(getPositionProc_.isProcedure() || getPositionProc_.isFalse());
67 MOSH_ASSERT(setPositionProc_.isProcedure() || setPositionProc_.isFalse());
68 MOSH_ASSERT(closeProc_.isProcedure() || closeProc_.isFalse());
69
70 }
71
~CustomTextualInputOutputPort()72 CustomTextualInputOutputPort::~CustomTextualInputOutputPort()
73 {
74 }
75
getChar()76 ucs4char CustomTextualInputOutputPort::getChar()
77 {
78 ucs4char c;
79 if (buffer_.empty()) {
80 const Object text = UC(" ");
81 const Object start = Object::makeFixnum(0);
82 const Object count = Object::makeFixnum(1);
83 const Object result = theVM_->callClosure3(readProc_, text, start, count);
84 MOSH_ASSERT(result.isFixnum());
85 if (0 == result.toFixnum()) {
86 return EOF;
87 }
88 c = text.toString()->data()[0];
89 } else {
90 c = buffer_[buffer_.size() - 1];
91 buffer_.erase(buffer_.size() - 1, 1);
92 }
93 if (c == '\n') ++line_;
94 return c;
95 }
96
getLineNo() const97 int CustomTextualInputOutputPort::getLineNo() const
98 {
99 return line_;
100 }
101
unGetChar(ucs4char c)102 void CustomTextualInputOutputPort::unGetChar(ucs4char c)
103 {
104 if (EOF == c) return;
105 buffer_ += c;
106 }
107
transcoder() const108 Transcoder* CustomTextualInputOutputPort::transcoder() const
109 {
110 return createNativeTranscoder();
111 }
112
hasPosition() const113 bool CustomTextualInputOutputPort::hasPosition() const
114 {
115 return !getPositionProc_.isFalse();
116 }
117
hasSetPosition() const118 bool CustomTextualInputOutputPort::hasSetPosition() const
119 {
120 return !setPositionProc_.isFalse();
121 }
122
position() const123 Object CustomTextualInputOutputPort::position() const
124 {
125 // hasPosition() should be checked by the user of this class.
126 MOSH_ASSERT(hasPosition());
127 const Object position = theVM_->callClosure0(getPositionProc_);
128 if (position.isFixnum() && !buffer_.empty()) {
129 return Object::makeFixnum(position.toFixnum() - buffer_.size());
130 } else {
131 return position;
132 }
133 }
134
setPosition(int64_t position)135 bool CustomTextualInputOutputPort::setPosition(int64_t position)
136 {
137 MOSH_ASSERT(hasSetPosition());
138 // we need to reset the cache
139 buffer_.clear();
140 theVM_->callClosure1(setPositionProc_, Bignum::makeIntegerFromS64(position));
141 return true;
142 }
143
toString()144 ucs4string CustomTextualInputOutputPort::toString()
145 {
146 ucs4string ret = UC("<custom-textual-input/output-port ");
147 ret += id_;
148 ret += UC(">");
149 return ret;
150 }
151
close()152 int CustomTextualInputOutputPort::close()
153 {
154 if (closeProc_.isCallable()) {
155 theVM_->callClosure0(closeProc_);
156 }
157 isClosed_ = true;
158 return 0;
159 }
160
isClosed() const161 bool CustomTextualInputOutputPort::isClosed() const
162 {
163 return isClosed_;
164 }
165
flush()166 void CustomTextualInputOutputPort::flush()
167 {
168 }
169
bufferMode() const170 enum OutputPort::bufferMode CustomTextualInputOutputPort::bufferMode() const
171 {
172 return OutputPort::NONE;
173 }
174
putChar(ucs4char c)175 void CustomTextualInputOutputPort::putChar(ucs4char c)
176 {
177 const Object text = UC(" ");
178 const Object start = Object::makeFixnum(0);
179 const Object count = Object::makeFixnum(1);
180 text.toString()->data()[0] = c;
181 const Object result = theVM_->callClosure3(writeProc_, text, start, count);
182 MOSH_ASSERT(result.isFixnum());
183 (void)result;
184 return;
185 }
186