Package org.jruby.util

Examples of org.jruby.util.ByteList.unsafeBytes()

1809
1810
1811
1812
1813
1814
1815
1816
1817
1818
1819
                 * #    Comment
                 * =    Assignment preceding command name
                 * %    (used in Parameter Expansion)
                 */
                ByteList progByteList = prog.getByteList();
                pBytes = progByteList.unsafeBytes();
                for (p = 0; p < progByteList.length(); p++){
                    if (progByteList.get(p) == ' ' || progByteList.get(p) == '\t'){
                        if (first.unsafeBytes() != DUMMY_ARRAY && first.length() == 0) first.setRealSize(p - first.begin());
                    }
                    else{
View Full Code Here
16
17
18
19
20
21
22
23
24
25
26
public class SnappyModule {
  @JRubyMethod(module = true, name = {"deflate", "compress", "dump"})
  public static IRubyObject deflate(ThreadContext context, IRubyObject self, IRubyObject str) throws IOException {
    ByteList input = str.convertToString().getByteList();
    byte[] compressed = new byte[Snappy.maxCompressedLength(input.length())];
    int compressedLength = Snappy.compress(input.unsafeBytes(), input.begin(), input.length(), compressed, 0);
    return RubyString.newStringNoCopy(context.runtime, compressed, 0, compressedLength);
  }

  @JRubyMethod(module = true, name = {"inflate", "uncompress", "load"})
  public static IRubyObject inflate(ThreadContext context, IRubyObject self, IRubyObject str) throws IOException {
View Full Code Here
23
24
25
26
27
28
29
30
31
32
  }

  @JRubyMethod(module = true, name = {"inflate", "uncompress", "load"})
  public static IRubyObject inflate(ThreadContext context, IRubyObject self, IRubyObject str) throws IOException {
    ByteList input = str.convertToString().getByteList();
    byte[] uncompressed = new byte[Snappy.uncompressedLength(input.unsafeBytes(), input.begin(), input.length())];
    int uncompressedLength = Snappy.uncompress(input.unsafeBytes(), input.begin(), input.length(), uncompressed, 0);
    return RubyString.newStringNoCopy(context.runtime, uncompressed, 0, uncompressedLength);
  }
}
View Full Code Here
24
25
26
27
28
29
30
31
32
  @JRubyMethod(module = true, name = {"inflate", "uncompress", "load"})
  public static IRubyObject inflate(ThreadContext context, IRubyObject self, IRubyObject str) throws IOException {
    ByteList input = str.convertToString().getByteList();
    byte[] uncompressed = new byte[Snappy.uncompressedLength(input.unsafeBytes(), input.begin(), input.length())];
    int uncompressedLength = Snappy.uncompress(input.unsafeBytes(), input.begin(), input.length(), uncompressed, 0);
    return RubyString.newStringNoCopy(context.runtime, uncompressed, 0, uncompressedLength);
  }
}
View Full Code Here
211
212
213
214
215
216
217
218
219
220
221
                statement.setBinaryStream(index, ((RubyIO) value).getInStream());
            }
            else { // should be a RubyString
                final ByteList blob = value.asString().getByteList();
                statement.setBinaryStream(index,
                    new ByteArrayInputStream(blob.unsafeBytes(), blob.getBegin(), blob.getRealSize()),
                    blob.getRealSize() // length
                );
            }
        }
    }
View Full Code Here
69
70
71
72
73
74
75
76
77
78
79
    @JRubyMethod(name = "quote_string", required = 1, frame = false)
    public static IRubyObject quote_string(final ThreadContext context,
        final IRubyObject recv, final IRubyObject string) {

        final ByteList stringBytes = ((RubyString) string).getByteList();
        final byte[] bytes = stringBytes.unsafeBytes();
        final int begin = stringBytes.getBegin();
        final int realSize = stringBytes.getRealSize();

        ByteList quotedBytes = null; int appendFrom = begin;
        for ( int i = begin; i < begin + realSize; i++ ) {
View Full Code Here
57
58
59
60
61
62
63
64
65
66
67
            final RubyString string,
            final char value, final char quote,
            final int newOffset, final int newSizeDiff) {

        final ByteList stringBytes = string.getByteList();
        final byte[] bytes = stringBytes.unsafeBytes();
        final int begin = stringBytes.getBegin();
        final int realSize = stringBytes.getRealSize();

        ByteList quotedBytes = null; int appendFrom = begin;
        for ( int i = begin; i < begin + realSize; i++ ) {
View Full Code Here
2954
2955
2956
2957
2958
2959
2960
2961
2962
2963
2964
                statement.setBinaryStream(index, ((RubyIO) value).getInStream());
            }
            else { // should be a RubyString
                final ByteList blob = value.asString().getByteList();
                statement.setBinaryStream(index,
                    new ByteArrayInputStream(blob.unsafeBytes(), blob.getBegin(), blob.getRealSize()),
                    blob.getRealSize() // length
                );
                // JDBC 4.0 :
                //statement.setBlob(index,
                //    new ByteArrayInputStream(bytes.unsafeBytes(), bytes.getBegin(), bytes.getRealSize())
View Full Code Here
301
302
303
304
305
306
307
308
309
310
311
        }
    }

    public static String rubyStringToString(RubyString str) {
        ByteList byteList = str.getByteList();
        byte[] data = byteList.unsafeBytes();
        int offset = byteList.begin();
        int len = byteList.length();
        ByteBuffer buf = ByteBuffer.wrap(data, offset, len);
        return getCharsetUTF8().decode(buf).toString();
    }
View Full Code Here
91
92
93
94
95
96
97
98
99
100
101
    if (returnValue.isNil())
      return -1;

    ByteList bytes = returnValue.asString().getByteList();
    int length = bytes.length();
    System.arraycopy(bytes.unsafeBytes(), bytes.getBegin(), b, off + copyLength, length);
    return length + copyLength;
  }

  @Override
  public int read() {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.