bundles/org.simantics.databoard/src/org/simantics/databoard/util/binary/OutputStreamWriteable.java

   1 /*******************************************************************************\r
   2  *  Copyright (c) 2010 Association for Decentralized Information Management in\r
   3  *  Industry THTH ry.\r
   4  *  All rights reserved. This program and the accompanying materials\r
   5  *  are made available under the terms of the Eclipse Public License v1.0\r
   6  *  which accompanies this distribution, and is available at\r
   7  *  http://www.eclipse.org/legal/epl-v10.html\r
   8  *\r
   9  *  Contributors:\r
  10  *      VTT Technical Research Centre of Finland - initial API and implementation\r
  11  *******************************************************************************/\r
  12 package org.simantics.databoard.util.binary;
  13
  14 import java.io.IOException;\r
  15 import java.io.OutputStream;\r
  16 import java.nio.ByteBuffer;\r
  17
  18 public class OutputStreamWriteable implements BinaryWriteable {
  19
  20         OutputStream out;
  21
  22         public OutputStreamWriteable(OutputStream out)
  23         {
  24                 if (out==null) throw new IllegalArgumentException("null arg");
  25                 this.out = out;
  26         }
  27
  28         public OutputStream getStream()
  29         {
  30                 return out;
  31         }
  32
  33         void _put(int value)
  34         throws IOException
  35         {
  36                 out.write(value);
  37         }
  38
  39         @Override
  40         public void write(int b) throws IOException {
  41                 _put(b);
  42         }\r
  43         \r
  44         @Override\r
  45         public void writeByte(int b) throws IOException {\r
  46                 _put(b);\r
  47         }       \r
  48         @Override\r
  49         public void writeBoolean(boolean v) throws IOException {\r
  50                 _put( v ? 1 : 0);\r
  51         }
  52
  53         @Override
  54         public void writeFully(ByteBuffer src) throws IOException {
  55                 if (src.hasArray()) {
  56                         byte array[] = src.array();
  57                         write(array, src.position(), src.remaining());
  58                         src.position(src.limit());
  59                 } else
  60                         for (;src.hasRemaining();)
  61                                 _put(src.get());
  62         }
  63
  64         @Override
  65         public void writeFully(ByteBuffer src, int length) throws IOException {
  66                 if (src.hasArray()) {
  67                         byte array[] = src.array();
  68                         write(array, src.position(), length);
  69                         src.position(length);
  70                 } else {
  71                         for (int i=0; i<length; i++)
  72                                 _put(src.get());
  73                 }
  74         }
  75
  76         @Override
  77         public void write(byte[] src, int offset, int length) throws IOException {
  78                 out.write(src, offset, length);
  79         }
  80
  81         @Override
  82         public void write(byte[] src) throws IOException {
  83                 out.write(src);
  84         }
  85
  86         @Override
  87         public void writeDouble(double value) throws IOException {
  88                 writeLong(Double.doubleToLongBits(value));
  89         }
  90
  91         @Override
  92         public void writeFloat(float value) throws IOException {
  93                 writeInt(Float.floatToIntBits(value));
  94         }
  95
  96         @Override
  97         public void writeInt(int value) throws IOException {
  98                 _put(value >> 24);
  99                 _put(value >> 16);
 100                 _put(value >> 8);
 101                 _put(value);
 102         }
 103
 104         @Override
 105         public void writeLong(long value) throws IOException {
 106                 _put((int) (value >> 56));
 107                 _put((int) (value >> 48));
 108                 _put((int) (value >> 40));
 109                 _put((int) (value >> 32));
 110                 _put((int) (value >> 24));
 111                 _put((int) (value >> 16));
 112                 _put((int) (value >> 8));
 113                 _put((int) (value));
 114         }
 115
 116         @Override
 117         public void writeShort(int value) throws IOException {
 118                 _put(value >> 8);
 119                 _put(value);
 120         }\r
 121         \r
 122         @Override\r
 123         public void writeChar(int value) throws IOException {\r
 124                 _put(value >> 8);\r
 125                 _put(value);\r
 126         }       \r
 127         \r
 128         @Override\r
 129         public void writeBytes(String s) throws IOException {\r
 130                 int len = s.length();\r
 131                 for (int i = 0 ; i < len ; i++) {\r
 132                     _put((byte)s.charAt(i));\r
 133                 }\r
 134         }\r
 135
 136         @Override\r
 137         public void writeChars(String s) throws IOException {\r
 138         int len = s.length();\r
 139         for (int i = 0 ; i < len ; i++) {\r
 140             int v = s.charAt(i);\r
 141             _put((v >>> 8) & 0xFF); \r
 142             _put((v >>> 0) & 0xFF); \r
 143         }\r
 144         }\r
 145         \r
 146         @Override\r
 147         public void writeUTF(String s) throws IOException {\r
 148                 int len = UTF8.getModifiedUTF8EncodingByteLength(s);\r
 149                 writeShort(len);\r
 150                 UTF8.writeModifiedUTF(this, s);\r
 151         }\r
 152
 153         @Override
 154         public void flush() throws IOException {
 155                 out.flush();
 156         }
 157
 158 }
 159
 160