Changeset 990b85d in mainline

Timestamp:

2018-07-05T21:41:18Z (6 years ago)

Author:

Dzejrou <dzejrou@…>

Branches:

lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export

Children:

f7aaffe0

Parents:

4d30bcd

git-author:

Jaroslav Jindrak <dzejrou@…> (2017-11-04 20:26:38)

git-committer:

Dzejrou <dzejrou@…> (2018-07-05 21:41:18)

Message:

cpp: implemented the rest of streambuf

File:

• uspace/lib/cpp/include/impl/streambuf.hpp (modified) (17 diffs)

uspace/lib/cpp/include/impl/streambuf.hpp

@@ -52 +52 @@
 
             virtual ~basic_streambuf()
-            {
-                // TODO: implement
-            }
+            { /* DUMMY BODY */ }
 
             /**
@@ -62 +60 @@
             locale pubimbue(const locale& loc)
             {
-                // TODO: implement
+                return imbue(loc);
             }
 
             locale& getloc() const
             {
-                // TODO: implement
+                return locale_;
             }
 
@@ -76 +74 @@
             basic_streambuf<Char, Traits>* pubsetbuf(char_type* s, streamsize n)
             {
-                // TODO: implement
+                return setbuf(s, n);
             }
 
@@ -82 +80 @@
                                 ios_base::openmode which = ios_base::in | ios_base::out)
             {
-                // TODO: implement
+                return seekoff(off, way, which);
             }
 
@@ -88 +86 @@
                                 ios_base::in | ios_base::out)
             {
-                // TODO: implement
+                return seekpos(pos, which);
             }
 
             int pubsync()
             {
-                // TODO: implement
+                return sync();
             }
 
@@ -102 +100 @@
             streamsize in_avail()
             {
-                // TODO: implement
+                if (read_avail_())
+                    return egptr() - gptr();
+                else
+                    return showmanyc();
             }
 
             int_type snextc()
             {
-                // TODO: implement
+                if (traits_type::eq(sbumpc, traits_type::eof()))
+                    return traits_type::eof();
+                else
+                    return sgetc();
             }
 
             int_type sbumpc()
             {
-                // TODO: implement
+                if (read_avail_())
+                    return traits_type::to_int_type(*input_next++);
+                else
+                    return uflow();
             }
 
             int_type sgetc()
             {
-                // TODO: implement
+                if (read_avail_())
+                    return traits_type::to_int_type(*input_next++);
+                else
+                    return underflow();
             }
 
             streamsize sgetn(char_type* s, streamsize n)
             {
-                // TODO: implement
+                return xsgetn(s, n);
             }
 
@@ -131 +141 @@
             int_type sputbackc(char_type c)
             {
-                // TODO: implement
+                if (!putback_avail_() || traits_type::eq(c, gptr()[-1]))
+                    return pbackfail(traits_type::to_int_type(c));
+                else
+                    return traits_type::to_int_type(*(--input_next));
             }
 
             int_type sungetc()
             {
-                // TODO: implement
+                if (!putback_avail_())
+                    return pbackfail();
+                else
+                    return traits_type::to_int_type(*(--input_next));
             }
 
@@ -145 +161 @@
             int_type sputc(char_type c)
             {
-                // TODO: implement
+                if (!write_avail_())
+                    return overflow(traits_type::to_int_type(c));
+                else
+                {
+                    traits_type::assign(*output_next_++, c);
+
+                    return traits_type::to_int_type(c);
+                }
             }
 
             streamsize sputn(const char_type* s, streamsize n)
             {
-                // TODO: implement
+                return xsputn(s, n);
             }
 
         protected:
             basic_streambuf()
-            {
-                // TODO: implement
-            }
+                : input_begin_{}, input_next_{}, input_end_{},
+                  output_begin_{}, output_next_{}, output_end_{},
+                  locale_{locale()}
+            { /* DUMMY BODY */ }
 
             basic_streambuf(const basic_streambuf& rhs)
             {
-                // TODO: implement
+                input_begin_ = rhs.input_begin_;
+                input_next_ = rhs.input_next_;
+                input_end_ = rhs.input_end_;
+
+                output_begin_ = rhs.output_begin_;
+                output_next_ = rhs.output_next_;
+                output_end_ = rhs.output_end_;
+
+                locale_ = rhs.locale_;
             }
 
             basic_strambuf& operator=(const basic_streambuf& rhs)
             {
-                // TODO: implement
+                input_begin_ = rhs.input_begin_;
+                input_next_  = rhs.input_next_;
+                input_end_   = rhs.input_end_;
+
+                output_begin_ = rhs.output_begin_;
+                output_next_  = rhs.output_next_;
+                output_end_   = rhs.output_end_;
+
+                locale_ = rhs.locale_;
+
+                return *this;
             }
 
             void swap(basic_streambuf& rhs)
             {
-                // TODO: implement
+                swap(input_begin_, rhs.input_begin_);
+                swap(input_next_, rhs.input_next_);
+                swap(input_end_, rhs.input_end_);
+
+                swap(output_begin_, rhs.output_begin_);
+                swap(output_next_, rhs.output_next_);
+                swap(output_end_, rhs.output_end_);
+
+                swap(locale_, rhs.locale_);
             }
 
@@ -180 +230 @@
             char_type* eback() const
             {
-                // TODO: implement
+                return input_begin_;
             }
 
             char_type* gptr() const
             {
-                // TODO: implement
+                return input_next_;
             }
 
             char_type* egptr() const
             {
-                // TODO: implement
+                return input_end_;
             }
 
             void gbump(int n)
             {
-                // TODO: implement
+                input_next_ += n;
             }
 
             void setg(char_type* gbeg, char_type* gnext, char_type* gend)
             {
-                // TODO: implement
+                input_begin_ = gbeg;
+                input_next_  = gnext;
+                input_end_   = gend;
             }
 
@@ -209 +261 @@
             char_type* pbase() const
             {
-                // TODO: implement
+                return output_begin_;
             }
 
             char_type* pptr() const
             {
-                // TODO: implement
+                return output_next_;
             }
 
             char_type* epptr() const
             {
-                // TODO: implement
+                return output_end_;
             }
 
             void pbump(int n)
             {
-                // TODO: implement
+                output_next_ += n;
             }
 
             void setp(char_type* pbeg, char_type* pend)
             {
-                // TODO: implement
+                output_begin_ = pbeg;
+                output_next_  = pbeg;
+                output_end_   = pend;
             }
 
@@ -237 +291 @@
 
             virtual void imbue(const locale& loc)
-            {
-                // TODO: implement
-            }
+            { /* DUMMY BODY */ }
 
             /**
@@ -248 +300 @@
             setbuf(char_type* s, streamsize n)
             {
-                // TODO: implement
+                return *this;
             }
 
@@ -254 +306 @@
                                      ios_base::openmode which = ios_base::in | ops_base::out)
             {
-                // TODO: implement
+                return pos_type(off_type(-1));
             }
 
@@ -260 +312 @@
                                      ios_base::in | ios_base::out)
             {
-                // TODO: implement
+                return pos_type(off_type(-1));
             }
 
             virtual int sync()
             {
-                // TODO: implement
+                return 0;
             }
 
@@ -274 +326 @@
             virtual streamsize showmanyc()
             {
-                // TODO: implement
+                return 0;
             }
 
             virtual streamsize xsgetn(char_type* s, streamsize n)
             {
-                // TODO: implement
+                if (!s || n == 0)
+                    return 0;
+
+                streamsize i{0};
+                auto eof = traits_type::eof();
+                for (; i <= n; ++i)
+                {
+                    if (!read_avail_() && traits_type::eq_int_type(uflow(), eof))
+                        break;
+
+                    traits_type::asign(*s++, *input_next_++);
+                }
+
+                return i;
             }
 
             virtual int_type underflow()
             {
-                // TODO: implement
+                return traits_type::eof();
             }
 
             virtual int_type uflow()
             {
-                // TODO: implement
+                auto res = underflow();
+                if (traits_type::eq_int_type(res, traits_type::eof()))
+                    return traits_type::eof();
+                else
+                    return traits_type::to_int_type(*input_next_++);
             }
 
@@ -298 +367 @@
             virtual int_type pbackfail(int_type c = traits_type::eof())
             {
-                // TODO: implement
+                return traits_type::eof();
             }
 
@@ -307 +376 @@
             virtual streamsize xsputn(const char_type* s, streamsize n)
             {
-                // TODO: implement
+                if (!s || n == 0)
+                    return 0;
+
+                char* = &s[0];
+                streamsize i{0};
+                for (; i <= n; ++i)
+                {
+                    if (!write_avail_() && traits_type::eq_int_type(overflow(), eof))
+                        break;
+
+                    traits_type::assign(*s++, *output_next_++);
+                }
+
+                return i;
             }
 
             virtual int_type overflow(int_type c = traits_type::eof())
             {
-                // TODO: implement
+                return traits_type::eof();
             }
 
         private:
-            // TODO: implement
+            value_type* input_begin_;
+            value_type* input_next_;
+            value_type* input_end_;
+
+            value_type* output_begin_;
+            value_type* output_next_;
+            value_type* output_end_;
+
+            locale locale_;
+
+            bool write_avail_() const
+            {
+                return output_next_ && output_next_ < output_end_;
+            }
+
+            bool putback_avail_() const
+            {
+                return input_next_ && input_begin_ < input_next_;
+            }
+
+            bool read_avail_() const
+            {
+                return input_next_ && input_next_ < input_end_;
+            }
     };