mirror of
https://github.com/msgpack/msgpack-c.git
synced 2025-10-21 07:45:02 +02:00
106 lines
2.7 KiB
Java
106 lines
2.7 KiB
Java
//
|
|
// MessagePack for Java
|
|
//
|
|
// Copyright (C) 2009-2010 FURUHASHI Sadayuki
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
//
|
|
package org.msgpack.schema;
|
|
|
|
import java.nio.ByteBuffer;
|
|
import java.io.IOException;
|
|
import java.io.UnsupportedEncodingException;
|
|
import org.msgpack.*;
|
|
|
|
public class RawSchema extends Schema {
|
|
public RawSchema() {
|
|
super("raw");
|
|
}
|
|
|
|
public String getFullName() {
|
|
return "byte[]";
|
|
}
|
|
|
|
@Override
|
|
public void pack(Packer pk, Object obj) throws IOException {
|
|
// FIXME instanceof GenericObject
|
|
if(obj instanceof byte[]) {
|
|
byte[] d = (byte[])obj;
|
|
pk.packRaw(d.length);
|
|
pk.packRawBody(d);
|
|
|
|
} else if(obj instanceof ByteBuffer) {
|
|
ByteBuffer d = (ByteBuffer)obj;
|
|
if(!d.hasArray()) {
|
|
throw MessageTypeException.invalidConvert(obj, this);
|
|
}
|
|
pk.packRaw(d.capacity());
|
|
pk.packRawBody(d.array(), d.position(), d.capacity());
|
|
|
|
} else if(obj instanceof String) {
|
|
try {
|
|
byte[] d = ((String)obj).getBytes("UTF-8");
|
|
pk.packRaw(d.length);
|
|
pk.packRawBody(d);
|
|
} catch (UnsupportedEncodingException e) {
|
|
throw MessageTypeException.invalidConvert(obj, this);
|
|
}
|
|
|
|
} else if(obj == null) {
|
|
pk.packNil();
|
|
|
|
} else {
|
|
throw MessageTypeException.invalidConvert(obj, this);
|
|
}
|
|
}
|
|
|
|
@Override
|
|
public Object convert(Object obj) throws MessageTypeException {
|
|
// FIXME instanceof GenericObject
|
|
if(obj instanceof byte[]) {
|
|
// FIXME copy?
|
|
//byte[] d = (byte[])obj;
|
|
//byte[] v = new byte[d.length];
|
|
//System.arraycopy(d, 0, v, 0, d.length);
|
|
//return v;
|
|
return obj;
|
|
|
|
} else if(obj instanceof ByteBuffer) {
|
|
ByteBuffer d = (ByteBuffer)obj;
|
|
byte[] v = new byte[d.capacity()];
|
|
int pos = d.position();
|
|
d.get(v);
|
|
d.position(pos);
|
|
return v;
|
|
|
|
} else if(obj instanceof String) {
|
|
try {
|
|
return ((String)obj).getBytes("UTF-8");
|
|
} catch (UnsupportedEncodingException e) {
|
|
throw MessageTypeException.invalidConvert(obj, this);
|
|
}
|
|
|
|
} else {
|
|
throw MessageTypeException.invalidConvert(obj, this);
|
|
}
|
|
}
|
|
|
|
@Override
|
|
public Object createFromRaw(byte[] b, int offset, int length) {
|
|
byte[] d = new byte[length];
|
|
System.arraycopy(b, offset, d, 0, length);
|
|
return d;
|
|
}
|
|
}
|
|
|