Mercurial > jdk8-mips64-public > hotspot / file revision

 /*

  * Copyright (c) 1997, 2011, Oracle and/or its affiliates. All rights reserved.

  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.

  *

  * This code is free software; you can redistribute it and/or modify it

  * under the terms of the GNU General Public License version 2 only, as

  * published by the Free Software Foundation.

  *

  * This code 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

  * version 2 for more details (a copy is included in the LICENSE file that

  * accompanied this code).

  *

  * You should have received a copy of the GNU General Public License version

  * 2 along with this work; if not, write to the Free Software Foundation,

  * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.

  *

  * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA

  * or visit www.oracle.com if you need additional information or have any

  * questions.

  *

  */

 #ifndef SHARE_VM_UTILITIES_OSTREAM_HPP

 #define SHARE_VM_UTILITIES_OSTREAM_HPP

 #include "memory/allocation.hpp"

 #include "runtime/timer.hpp"

 // Output streams for printing

 //

 // Printing guidelines:

 // Where possible, please use tty->print() and tty->print_cr().

 // For product mode VM warnings use warning() which internally uses tty.

 // In places where tty is not initialized yet or too much overhead,

 // we may use jio_printf:

 //     jio_fprintf(defaultStream::output_stream(), "Message");

 // This allows for redirection via -XX:+DisplayVMOutputToStdout and

 // -XX:+DisplayVMOutputToStderr

 class outputStream : public ResourceObj {

  protected:

    int _indentation; // current indentation

    int _width;       // width of the page

    int _position;    // position on the current line

    int _newlines;    // number of '\n' output so far

    julong _precount; // number of chars output, less _position

    TimeStamp _stamp; // for time stamps

    void update_position(const char* s, size_t len);

    static const char* do_vsnprintf(char* buffer, size_t buflen,

                                    const char* format, va_list ap,

                                    bool add_cr,

                                    size_t& result_len);

  public:

    // creation

    outputStream(int width = 80);

    outputStream(int width, bool has_time_stamps);

    // indentation

    void indent();

    void inc() { _indentation++; };

    void dec() { _indentation--; };

    int  indentation() const    { return _indentation; }

    void set_indentation(int i) { _indentation = i;    }

    void fill_to(int col);

    void move_to(int col, int slop = 6, int min_space = 2);

    // sizing

    int width()    const { return _width;    }

    int position() const { return _position; }

    int newlines() const { return _newlines; }

    julong count() const { return _precount + _position; }

    void set_count(julong count) { _precount = count - _position; }

    void set_position(int pos)   { _position = pos; }

    // printing

    void print(const char* format, ...);

    void print_cr(const char* format, ...);

    void vprint(const char *format, va_list argptr);

    void vprint_cr(const char* format, va_list argptr);

    void print_raw(const char* str)            { write(str, strlen(str)); }

    void print_raw(const char* str, int len)   { write(str,         len); }

    void print_raw_cr(const char* str)         { write(str, strlen(str)); cr(); }

    void print_raw_cr(const char* str, int len){ write(str,         len); cr(); }

    void put(char ch);

    void sp(int count = 1);

    void cr();

    void bol() { if (_position > 0)  cr(); }

    // Time stamp

    TimeStamp& time_stamp() { return _stamp; }

    void stamp();

    void stamp(bool guard, const char* prefix, const char* suffix);

    void stamp(bool guard) {

      stamp(guard, "", ": ");

    }

    // Date stamp

    void date_stamp(bool guard, const char* prefix, const char* suffix);

    // A simplified call that includes a suffix of ": "

    void date_stamp(bool guard) {

      date_stamp(guard, "", ": ");

    }

    // portable printing of 64 bit integers

    void print_jlong(jlong value);

    void print_julong(julong value);

    // flushing

    virtual void flush() {}

    virtual void write(const char* str, size_t len) = 0;

    virtual void rotate_log() {} // GC log rotation

    virtual ~outputStream() {}   // close properly on deletion

    void dec_cr() { dec(); cr(); }

    void inc_cr() { inc(); cr(); }

 };

 // standard output

 // ANSI C++ name collision

 extern outputStream* tty;           // tty output

 extern outputStream* gclog_or_tty;  // stream for gc log if -Xloggc:<f>, or tty

 // advisory locking for the shared tty stream:

 class ttyLocker: StackObj {

   friend class ttyUnlocker;

  private:

   intx _holder;

  public:

   static intx  hold_tty();                // returns a "holder" token

   static void  release_tty(intx holder);  // must witness same token

   static bool  release_tty_if_locked();   // returns true if lock was released

   static void  break_tty_lock_for_safepoint(intx holder);

   ttyLocker()  { _holder = hold_tty(); }

   ~ttyLocker() { release_tty(_holder); }

 };

 // Release the tty lock if it's held and reacquire it if it was

 // locked.  Used to avoid lock ordering problems.

 class ttyUnlocker: StackObj {

  private:

   bool _was_locked;

  public:

   ttyUnlocker()  {

     _was_locked = ttyLocker::release_tty_if_locked();

   }

   ~ttyUnlocker() {

     if (_was_locked) {

       ttyLocker::hold_tty();

     }

   }

 };

 // for writing to strings; buffer will expand automatically

 class stringStream : public outputStream {

  protected:

   char*  buffer;

   size_t buffer_pos;

   size_t buffer_length;

   bool   buffer_fixed;

  public:

   stringStream(size_t initial_bufsize = 256);

   stringStream(char* fixed_buffer, size_t fixed_buffer_size);

   ~stringStream();

   virtual void write(const char* c, size_t len);

   size_t      size() { return buffer_pos; }

   const char* base() { return buffer; }

   void  reset() { buffer_pos = 0; _precount = 0; _position = 0; }

   char* as_string();

 };

 class fileStream : public outputStream {

  protected:

   FILE* _file;

   bool  _need_close;

  public:

   fileStream() { _file = NULL; _need_close = false; }

   fileStream(const char* file_name);

   fileStream(const char* file_name, const char* opentype);

   fileStream(FILE* file) { _file = file; _need_close = false; }

   ~fileStream();

   bool is_open() const { return _file != NULL; }

   void set_need_close(bool b) { _need_close = b;}

   virtual void write(const char* c, size_t len);

   size_t read(void *data, size_t size, size_t count) { return ::fread(data, size, count, _file); }

   char* readln(char *data, int count);

   int eof() { return feof(_file); }

   long fileSize();

   void rewind() { ::rewind(_file); }

   void flush();

 };

 // unlike fileStream, fdStream does unbuffered I/O by calling

 // open() and write() directly. It is async-safe, but output

 // from multiple thread may be mixed together. Used by fatal

 // error handler.

 class fdStream : public outputStream {

  protected:

   int  _fd;

   bool _need_close;

  public:

   fdStream(const char* file_name);

   fdStream(int fd = -1) { _fd = fd; _need_close = false; }

   ~fdStream();

   bool is_open() const { return _fd != -1; }

   void set_fd(int fd) { _fd = fd; _need_close = false; }

   int fd() const { return _fd; }

   virtual void write(const char* c, size_t len);

   void flush() {};

 };

 class rotatingFileStream : public fileStream {

  protected:

   char*  _file_name;

   jlong  _bytes_writen;

   uintx  _cur_file_num;             // current logfile rotation number, from 0 to MaxGCLogFileNumbers-1

  public:

   rotatingFileStream(const char* file_name);

   rotatingFileStream(const char* file_name, const char* opentype);

   rotatingFileStream(FILE* file) : fileStream(file) {}

   ~rotatingFileStream();

   virtual void write(const char* c, size_t len);

   virtual void rotate_log();

 };

 void ostream_init();

 void ostream_init_log();

 void ostream_exit();

 void ostream_abort();

 // staticBufferStream uses a user-supplied buffer for all formatting.

 // Used for safe formatting during fatal error handling.  Not MT safe.

 // Do not share the stream between multiple threads.

 class staticBufferStream : public outputStream {

  private:

   char* _buffer;

   size_t _buflen;

   outputStream* _outer_stream;

  public:

   staticBufferStream(char* buffer, size_t buflen,

                      outputStream *outer_stream);

   ~staticBufferStream() {};

   virtual void write(const char* c, size_t len);

   void flush();

   void print(const char* format, ...);

   void print_cr(const char* format, ...);

   void vprint(const char *format, va_list argptr);

   void vprint_cr(const char* format, va_list argptr);

 };

 // In the non-fixed buffer case an underlying buffer will be created and

 // managed in C heap. Not MT-safe.

 class bufferedStream : public outputStream {

  protected:

   char*  buffer;

   size_t buffer_pos;

   size_t buffer_max;

   size_t buffer_length;

   bool   buffer_fixed;

  public:

   bufferedStream(size_t initial_bufsize = 256, size_t bufmax = 1024*1024*10);

   bufferedStream(char* fixed_buffer, size_t fixed_buffer_size, size_t bufmax = 1024*1024*10);

   ~bufferedStream();

   virtual void write(const char* c, size_t len);

   size_t      size() { return buffer_pos; }

   const char* base() { return buffer; }

   void  reset() { buffer_pos = 0; _precount = 0; _position = 0; }

   char* as_string();

 };

 #define O_BUFLEN 2000   // max size of output of individual print() methods

 #ifndef PRODUCT

 class networkStream : public bufferedStream {

   private:

     int _socket;

   public:

     networkStream();

     ~networkStream();

     bool connect(const char *host, short port);

     bool is_open() const { return _socket != -1; }

     int read(char *buf, size_t len);

     void close();

     virtual void flush();

 };

 #endif

 #endif // SHARE_VM_UTILITIES_OSTREAM_HPP