List of finishObjectInput() Examples

Examples of finishObjectInput()

org.infinispan.commons.marshall.StreamingMarshaller.finishObjectInput()
Finish using the given ObjectInput. After opening a ObjectInput and calling objectFromObjectStream() multiple times, use this method to flush the data and close if necessary @param oi data input that finished using
org.infinispan.marshall.Marshaller.finishObjectInput()
Finish using the given ObjectInput. After opening a ObjectInput and calling objectFromObjectStream() mutliple times, use this method to flush the data and close if necessary @param oi data input that finished using
org.infinispan.marshall.StreamingMarshaller.finishObjectInput()
Finish using the given ObjectInput. After opening a ObjectInput and calling objectFromObjectStream() mutliple times, use this method to flush the data and close if necessary @param oi data input that finished using

Examples of org.infinispan.commons.marshall.StreamingMarshaller.finishObjectInput()

            int topologyId = input.readInt();
            ((TopologyAffectedCommand)cacheRpcCommand).setTopologyId(topologyId);
         }
         return cacheRpcCommand;
      } finally {
         marshaller.finishObjectInput(paramsInput);
      }
   }


   @Override
   public Integer getId() {

View Full Code Here

Examples of org.infinispan.commons.marshall.StreamingMarshaller.finishObjectInput()

      try {
         assert oi.readInt() == 1 : "we have 3 different buckets";
         assert oi.readObject().equals(fcs.getLockFromKey("k1") + "");
         assert oi.readInt() > 0; //size on disk
      } finally {
         marshaller.finishObjectInput(oi);
      }
   }


   public void testLongKeyValuesToStream() throws Exception {
      String k1 = "SESSION_173";

View Full Code Here

Examples of org.infinispan.commons.marshall.StreamingMarshaller.finishObjectInput()

      ByteArrayInputStream in = new ByteArrayInputStream(out.toByteArray());
      ObjectInput oi = marshaller.startObjectInput(in, false);
      try {
         cs.fromStream(new UnclosableObjectInputStream(oi));
      } finally {
         marshaller.finishObjectInput(oi);
      }


      Set<InternalCacheEntry> set = cs.loadAll();
      assert set.size() == 2;
      Set<String> expected = new HashSet<String>();

View Full Code Here

Examples of org.infinispan.commons.marshall.StreamingMarshaller.finishObjectInput()

      ByteArrayInputStream in = new ByteArrayInputStream(out.toByteArray());
      ObjectInput oi = marshaller.startObjectInput(in, false);
      try {
         cs.fromStream(new UnclosableObjectInputStream(oi));
      } finally {
         marshaller.finishObjectInput(oi);
         in.close();
      }


      Set<InternalCacheEntry> set = cs.loadAll();
      assert set.size() == 3;

View Full Code Here

Examples of org.infinispan.commons.marshall.StreamingMarshaller.finishObjectInput()

         cs.fromStream(new UnclosableObjectInputStream(oi));
         bytesRead = oi.read(dummy, 0, 8);
         assert bytesRead == 8;
         for (int i = 8; i > 0; i--) assert dummy[8 - i] == i : "Start byte stream corrupted!";
      } finally {
         marshaller.finishObjectInput(oi);
         in.close();
      }


      Set<InternalCacheEntry> set = cs.loadAll();
      assert set.size() == 3;

View Full Code Here

Examples of org.infinispan.commons.marshall.StreamingMarshaller.finishObjectInput()

            /** END: Special treatment **/


            try {
               assertEquals(cmd, cacheOI.readObject());
            } finally {
               cacheMarshaller.finishObjectInput(cacheOI);
            }
         } finally {
            globalMarshal.finishObjectInput(globalOI);
         }
      } finally {

View Full Code Here

Examples of org.infinispan.commons.marshall.StreamingMarshaller.finishObjectInput()

         ByteArrayInputStream bais = new ByteArrayInputStream(bytes);
         ObjectInput globalOI = globalMarshal.startObjectInput(bais, false);
         try {
            assertEquals(address, globalOI.readObject());
         } finally {
            globalMarshal.finishObjectInput(globalOI);
         }
      } finally {
         cm.stop();
      }
   }

View Full Code Here

Examples of org.infinispan.commons.marshall.StreamingMarshaller.finishObjectInput()

            /** END: Special treatment **/


            try {
               assertEquals(cmd, cacheOI.readObject());
            } finally {
               cacheMarshaller.finishObjectInput(cacheOI);
            }
         } finally {
            globalMarshal.finishObjectInput(globalOI);
         }
      } finally {

View Full Code Here

Examples of org.infinispan.commons.marshall.StreamingMarshaller.finishObjectInput()

         ByteArrayInputStream bais = new ByteArrayInputStream(bytes);
         ObjectInput globalOI = globalMarshal.startObjectInput(bais, false);
         try {
            assertEquals(address, globalOI.readObject());
         } finally {
            globalMarshal.finishObjectInput(globalOI);
         }
      } finally {
         cm.stop();
      }
   }

View Full Code Here

Examples of org.infinispan.commons.marshall.StreamingMarshaller.finishObjectInput()

            int topologyId = input.readInt();
            ((TopologyAffectedCommand)cacheRpcCommand).setTopologyId(topologyId);
         }
         return cacheRpcCommand;
      } finally {
         marshaller.finishObjectInput(paramsInput);
      }
   }


   @Override
   public Integer getId() {

View Full Code Here

0 1 2 3 4 5

TOP

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.