/** {@inheritDoc} */
public void writeExternal( ObjectOutput out ) throws IOException {
// VERSION
out.writeByte( 1 );
// SUPER
super.writeExternal( out );
// NUMBER OF ENTRIES
out.writeInt( _size );
// LOAD FACTOR -- Added version 1
out.writeFloat( _loadFactor );
// NO ENTRY VALUE -- Added version 1
out.writeInt( no_entry_value );
// ENTRIES
for ( int i = _states.length; i-- > 0; ) {
if ( _states[i] == FULL ) {
out.writeInt( _set[i] );
}
}
}
java类java.io.ObjectOutput的实例源码
TIntHashSet.java 文件源码
项目:HCFCore
阅读 23
收藏 0
点赞 0
评论 0
StreamRemoteCall.java 文件源码
项目:openjdk-jdk10
阅读 46
收藏 0
点赞 0
评论 0
/**
* Returns an output stream (may put out header information
* relating to the success of the call).
* @param success If true, indicates normal return, else indicates
* exceptional return.
* @exception StreamCorruptedException If result stream previously
* acquired
* @exception IOException For any other problem with I/O.
*/
public ObjectOutput getResultStream(boolean success) throws IOException {
/* make sure result code only marshaled once. */
if (resultStarted)
throw new StreamCorruptedException("result already in progress");
else
resultStarted = true;
// write out return header
// return header, part 1 (read by Transport)
DataOutputStream wr = new DataOutputStream(conn.getOutputStream());
wr.writeByte(TransportConstants.Return);// transport op
getOutputStream(true); // creates a MarshalOutputStream
// return header, part 2 (read by client-side RemoteCall)
if (success) //
out.writeByte(TransportConstants.NormalReturn);
else
out.writeByte(TransportConstants.ExceptionalReturn);
out.writeID(); // write id for gcAck
return out;
}
ComparableObjectSeriesTests.java 文件源码
项目:parabuild-ci
阅读 29
收藏 0
点赞 0
评论 0
/**
* Serialize an instance, restore it, and check for equality.
*/
public void testSerialization() {
MyComparableObjectSeries s1 = new MyComparableObjectSeries("A");
s1.add(new Integer(1), "ABC");
MyComparableObjectSeries s2 = null;
try {
ByteArrayOutputStream buffer = new ByteArrayOutputStream();
ObjectOutput out = new ObjectOutputStream(buffer);
out.writeObject(s1);
out.close();
ObjectInput in = new ObjectInputStream(
new ByteArrayInputStream(buffer.toByteArray()));
s2 = (MyComparableObjectSeries) in.readObject();
in.close();
}
catch (Exception e) {
e.printStackTrace();
}
assertEquals(s1, s2);
}
VectorRendererTests.java 文件源码
项目:parabuild-ci
阅读 26
收藏 0
点赞 0
评论 0
/**
* Serialize an instance, restore it, and check for equality.
*/
public void testSerialization() {
VectorRenderer r1 = new VectorRenderer();
VectorRenderer r2 = null;
try {
ByteArrayOutputStream buffer = new ByteArrayOutputStream();
ObjectOutput out = new ObjectOutputStream(buffer);
out.writeObject(r1);
out.close();
ObjectInput in = new ObjectInputStream(
new ByteArrayInputStream(buffer.toByteArray()));
r2 = (VectorRenderer) in.readObject();
in.close();
}
catch (Exception e) {
e.printStackTrace();
}
assertEquals(r1, r2);
}
TLongArrayList.java 文件源码
项目:HCFCore
阅读 25
收藏 0
点赞 0
评论 0
public void writeExternal( ObjectOutput out ) throws IOException {
// VERSION
out.writeByte( 0 );
// POSITION
out.writeInt( _pos );
// NO_ENTRY_VALUE
out.writeLong( no_entry_value );
// ENTRIES
int len = _data.length;
out.writeInt( len );
for( int i = 0; i < len; i++ ) {
out.writeLong( _data[ i ] );
}
}
TShortArrayList.java 文件源码
项目:xcc
阅读 27
收藏 0
点赞 0
评论 0
public void writeExternal( ObjectOutput out ) throws IOException {
// VERSION
out.writeByte( 0 );
// POSITION
out.writeInt( _pos );
// NO_ENTRY_VALUE
out.writeShort( no_entry_value );
// ENTRIES
int len = _data.length;
out.writeInt( len );
for( int i = 0; i < len; i++ ) {
out.writeShort( _data[ i ] );
}
}
RecentFiles.java 文件源码
项目:jaer
阅读 26
收藏 0
点赞 0
评论 0
void putPrefs(){
try {
// Serialize to a byte array
ByteArrayOutputStream bos = new ByteArrayOutputStream() ;
ObjectOutput out = new ObjectOutputStream(bos) ;
out.writeObject(fileList);
out.close();
// Get the bytes of the serialized object
byte[] buf = bos.toByteArray();
prefs.putByteArray("recentFiles", buf);
} catch (IOException e) {
e.printStackTrace();
}catch(IllegalArgumentException e2){
log.warning("RecentFiles tried to store too many files in Preferences, fileList has "+fileList.size()+" files");
}
}
SymbolicAxisTests.java 文件源码
项目:parabuild-ci
阅读 29
收藏 0
点赞 0
评论 0
/**
* Serialize an instance, restore it, and check for equality.
*/
public void testSerialization() {
String[] tickLabels = new String[] {"One", "Two", "Three"};
SymbolicAxis a1 = new SymbolicAxis("Test Axis", tickLabels);
SymbolicAxis a2 = null;
try {
ByteArrayOutputStream buffer = new ByteArrayOutputStream();
ObjectOutput out = new ObjectOutputStream(buffer);
out.writeObject(a1);
out.close();
ObjectInput in = new ObjectInputStream(new ByteArrayInputStream(buffer.toByteArray()));
a2 = (SymbolicAxis) in.readObject();
in.close();
}
catch (Exception e) {
System.out.println(e.toString());
}
assertEquals(a1, a2);
}
TIntArrayList.java 文件源码
项目:xcc
阅读 26
收藏 0
点赞 0
评论 0
public void writeExternal( ObjectOutput out ) throws IOException {
// VERSION
out.writeByte( 0 );
// POSITION
out.writeInt( _pos );
// NO_ENTRY_VALUE
out.writeInt( no_entry_value );
// ENTRIES
int len = _data.length;
out.writeInt( len );
for( int i = 0; i < len; i++ ) {
out.writeInt( _data[ i ] );
}
}
TFloatArrayList.java 文件源码
项目:xcc
阅读 28
收藏 0
点赞 0
评论 0
public void writeExternal( ObjectOutput out ) throws IOException {
// VERSION
out.writeByte( 0 );
// POSITION
out.writeInt( _pos );
// NO_ENTRY_VALUE
out.writeFloat( no_entry_value );
// ENTRIES
int len = _data.length;
out.writeInt( len );
for( int i = 0; i < len; i++ ) {
out.writeFloat( _data[ i ] );
}
}
MutableCompositeModification.java 文件源码
项目:hashsdn-controller
阅读 27
收藏 0
点赞 0
评论 0
@Override
public void writeExternal(ObjectOutput out) throws IOException {
super.writeExternal(out);
out.writeInt(modifications.size());
if (modifications.size() > 1) {
SerializationUtils.REUSABLE_WRITER_TL.set(NormalizedNodeInputOutput.newDataOutput(out));
}
try {
for (Modification mod: modifications) {
out.writeByte(mod.getType());
mod.writeExternal(out);
}
} finally {
SerializationUtils.REUSABLE_WRITER_TL.remove();
}
}
TShortHashSet.java 文件源码
项目:xcc
阅读 44
收藏 0
点赞 0
评论 0
/** {@inheritDoc} */
public void writeExternal( ObjectOutput out ) throws IOException {
// VERSION
out.writeByte( 1 );
// SUPER
super.writeExternal( out );
// NUMBER OF ENTRIES
out.writeInt( _size );
// LOAD FACTOR -- Added version 1
out.writeFloat( _loadFactor );
// NO ENTRY VALUE -- Added version 1
out.writeShort( no_entry_value );
// ENTRIES
for ( int i = _states.length; i-- > 0; ) {
if ( _states[i] == FULL ) {
out.writeShort( _set[i] );
}
}
}
TLongHashSet.java 文件源码
项目:xcc
阅读 31
收藏 0
点赞 0
评论 0
/** {@inheritDoc} */
public void writeExternal( ObjectOutput out ) throws IOException {
// VERSION
out.writeByte( 1 );
// SUPER
super.writeExternal( out );
// NUMBER OF ENTRIES
out.writeInt( _size );
// LOAD FACTOR -- Added version 1
out.writeFloat( _loadFactor );
// NO ENTRY VALUE -- Added version 1
out.writeLong( no_entry_value );
// ENTRIES
for ( int i = _states.length; i-- > 0; ) {
if ( _states[i] == FULL ) {
out.writeLong( _set[i] );
}
}
}
IntervalCategoryLabelGeneratorTests.java 文件源码
项目:parabuild-ci
阅读 27
收藏 0
点赞 0
评论 0
/**
* Serialize an instance, restore it, and check for equality.
*/
public void testSerialization() {
IntervalCategoryLabelGenerator g1
= new IntervalCategoryLabelGenerator("{3} - {4}", DateFormat.getInstance());
IntervalCategoryLabelGenerator g2 = null;
try {
ByteArrayOutputStream buffer = new ByteArrayOutputStream();
ObjectOutput out = new ObjectOutputStream(buffer);
out.writeObject(g1);
out.close();
ObjectInput in = new ObjectInputStream(new ByteArrayInputStream(buffer.toByteArray()));
g2 = (IntervalCategoryLabelGenerator) in.readObject();
in.close();
}
catch (Exception e) {
System.out.println(e.toString());
}
assertEquals(g1, g2);
}
TCharHashSet.java 文件源码
项目:xcc
阅读 30
收藏 0
点赞 0
评论 0
/** {@inheritDoc} */
public void writeExternal( ObjectOutput out ) throws IOException {
// VERSION
out.writeByte( 1 );
// SUPER
super.writeExternal( out );
// NUMBER OF ENTRIES
out.writeInt( _size );
// LOAD FACTOR -- Added version 1
out.writeFloat( _loadFactor );
// NO ENTRY VALUE -- Added version 1
out.writeChar( no_entry_value );
// ENTRIES
for ( int i = _states.length; i-- > 0; ) {
if ( _states[i] == FULL ) {
out.writeChar( _set[i] );
}
}
}
TCharIntHash.java 文件源码
项目:xcc
阅读 28
收藏 0
点赞 0
评论 0
/** {@inheritDoc} */
public void writeExternal( ObjectOutput out ) throws IOException {
// VERSION
out.writeByte( 0 );
// SUPER
super.writeExternal( out );
// NO_ENTRY_KEY
out.writeChar( no_entry_key );
// NO_ENTRY_VALUE
out.writeInt( no_entry_value );
}
Ser.java 文件源码
项目:jdk8u-jdk
阅读 26
收藏 0
点赞 0
评论 0
private static void writeInternal(byte type, Object object, ObjectOutput out) throws IOException {
out.writeByte(type);
switch (type) {
case CHRONO_TYPE:
((AbstractChronology) object).writeExternal(out);
break;
case CHRONO_LOCAL_DATE_TIME_TYPE:
((ChronoLocalDateTimeImpl<?>) object).writeExternal(out);
break;
case CHRONO_ZONE_DATE_TIME_TYPE:
((ChronoZonedDateTimeImpl<?>) object).writeExternal(out);
break;
case JAPANESE_DATE_TYPE:
((JapaneseDate) object).writeExternal(out);
break;
case JAPANESE_ERA_TYPE:
((JapaneseEra) object).writeExternal(out);
break;
case HIJRAH_DATE_TYPE:
((HijrahDate) object).writeExternal(out);
break;
case MINGUO_DATE_TYPE:
((MinguoDate) object).writeExternal(out);
break;
case THAIBUDDHIST_DATE_TYPE:
((ThaiBuddhistDate) object).writeExternal(out);
break;
case CHRONO_PERIOD_TYPE:
((ChronoPeriodImpl) object).writeExternal(out);
break;
default:
throw new InvalidClassException("Unknown serialized type");
}
}
GerenciadorPartes.java 文件源码
项目:brModelo
阅读 30
收藏 0
点赞 0
评论 0
public static boolean SaveData(GerenciadorPartes obj, String fileName) {
try {
FileOutputStream fo = new FileOutputStream(fileName);
try (ObjectOutput out = new ObjectOutputStream(fo)) {
out.writeObject(obj);
}
obj.setMudou(false);
return true;
} catch (IOException iOException) {
util.BrLogger.Logger("ERROR_TEMPLATE_SAVELOAD", iOException.getMessage());
return false;
}
}
RegionProjection.java 文件源码
项目:Higher-Cloud-Computing-Project
阅读 27
收藏 0
点赞 0
评论 0
/** {@inheritDoc} */
@Override public void writeExternal(ObjectOutput out) throws IOException {
out.writeInt(sampleIndexes.length);
for (Integer sampleIndex : sampleIndexes)
out.writeInt(sampleIndex);
out.writeObject(data);
out.writeInt(depth);
}
ValueExpressionImpl.java 文件源码
项目:lams
阅读 28
收藏 0
点赞 0
评论 0
public void writeExternal(ObjectOutput out) throws IOException {
out.writeUTF(this.expr);
out.writeUTF((this.expectedType != null) ? this.expectedType.getName()
: "");
out.writeObject(this.fnMapper);
out.writeObject(this.varMapper);
}
TByteIntHash.java 文件源码
项目:HCFCore
阅读 26
收藏 0
点赞 0
评论 0
/** {@inheritDoc} */
public void writeExternal( ObjectOutput out ) throws IOException {
// VERSION
out.writeByte( 0 );
// SUPER
super.writeExternal( out );
// NO_ENTRY_KEY
out.writeByte( no_entry_key );
// NO_ENTRY_VALUE
out.writeInt( no_entry_value );
}
TFloatLongHash.java 文件源码
项目:xcc
阅读 28
收藏 0
点赞 0
评论 0
/** {@inheritDoc} */
public void writeExternal( ObjectOutput out ) throws IOException {
// VERSION
out.writeByte( 0 );
// SUPER
super.writeExternal( out );
// NO_ENTRY_KEY
out.writeFloat( no_entry_key );
// NO_ENTRY_VALUE
out.writeLong( no_entry_value );
}
TDoubleFloatHash.java 文件源码
项目:xcc
阅读 27
收藏 0
点赞 0
评论 0
/** {@inheritDoc} */
public void writeExternal( ObjectOutput out ) throws IOException {
// VERSION
out.writeByte( 0 );
// SUPER
super.writeExternal( out );
// NO_ENTRY_KEY
out.writeDouble( no_entry_key );
// NO_ENTRY_VALUE
out.writeFloat( no_entry_value );
}
TIntShortHash.java 文件源码
项目:HCFCore
阅读 27
收藏 0
点赞 0
评论 0
/** {@inheritDoc} */
public void writeExternal( ObjectOutput out ) throws IOException {
// VERSION
out.writeByte( 0 );
// SUPER
super.writeExternal( out );
// NO_ENTRY_KEY
out.writeInt( no_entry_key );
// NO_ENTRY_VALUE
out.writeShort( no_entry_value );
}
XWaitListedSection.java 文件源码
项目:unitimes
阅读 27
收藏 0
点赞 0
评论 0
@Override
public void writeExternal(ObjectOutput out) throws IOException {
super.writeExternal(out);
out.writeLong(iWaitListId == null ? -1l : iWaitListId);
out.writeBoolean(iTimeStamp != null);
if (iTimeStamp != null)
out.writeLong(iTimeStamp.getTime());
out.writeInt(iType.ordinal());
}
TCharArrayStack.java 文件源码
项目:HCFCore
阅读 27
收藏 0
点赞 0
评论 0
public void writeExternal( ObjectOutput out ) throws IOException {
// VERSION
out.writeByte( 0 );
// LIST
out.writeObject( _list );
}
TLongLongHash.java 文件源码
项目:xcc
阅读 31
收藏 0
点赞 0
评论 0
/** {@inheritDoc} */
public void writeExternal( ObjectOutput out ) throws IOException {
// VERSION
out.writeByte( 0 );
// SUPER
super.writeExternal( out );
// NO_ENTRY_KEY
out.writeLong( no_entry_key );
// NO_ENTRY_VALUE
out.writeLong( no_entry_value );
}
TCharDoubleHash.java 文件源码
项目:HCFCore
阅读 26
收藏 0
点赞 0
评论 0
/** {@inheritDoc} */
public void writeExternal( ObjectOutput out ) throws IOException {
// VERSION
out.writeByte( 0 );
// SUPER
super.writeExternal( out );
// NO_ENTRY_KEY
out.writeChar( no_entry_key );
// NO_ENTRY_VALUE
out.writeDouble( no_entry_value );
}
TByteCharHash.java 文件源码
项目:HCFCore
阅读 29
收藏 0
点赞 0
评论 0
/** {@inheritDoc} */
public void writeExternal( ObjectOutput out ) throws IOException {
// VERSION
out.writeByte( 0 );
// SUPER
super.writeExternal( out );
// NO_ENTRY_KEY
out.writeByte( no_entry_key );
// NO_ENTRY_VALUE
out.writeChar( no_entry_value );
}
InstallSnapshotReply.java 文件源码
项目:hashsdn-controller
阅读 27
收藏 0
点赞 0
评论 0
@Override
public void writeExternal(ObjectOutput out) throws IOException {
out.writeLong(installSnapshotReply.getTerm());
out.writeObject(installSnapshotReply.followerId);
out.writeInt(installSnapshotReply.chunkIndex);
out.writeBoolean(installSnapshotReply.success);
}