Examples of Encoder


Examples of javax.websocket.Encoder

    protected void setEncoders(EndpointConfig endpointConfig)
            throws DeploymentException {
        encoderEntries.clear();
        for (Class<? extends Encoder> encoderClazz :
                endpointConfig.getEncoders()) {
            Encoder instance;
            try {
                instance = encoderClazz.newInstance();
                instance.init(endpointConfig);
            } catch (InstantiationException | IllegalAccessException e) {
                throw new DeploymentException(
                        sm.getString("wsRemoteEndpoint.invalidEncoder",
                                encoderClazz.getName()), e);
            }
View Full Code Here

Examples of javax.websocket.Encoder

                }
            }
        }
        if (encoders != null) {
            for (InstanceHandle<? extends Encoder> decoderHandle : encoders) {
                Encoder decoder = decoderHandle.getInstance();
                if (decoder instanceof Encoder.Text) {
                    return ((Encoder.Text) decoder).encode(o);
                } else {
                    try {
                        StringWriter out = new StringWriter();
View Full Code Here

Examples of javax.websocket.Encoder

                }
            }
        }
        if (encoders != null) {
            for (InstanceHandle<? extends Encoder> decoderHandle : encoders) {
                Encoder decoder = decoderHandle.getInstance();
                if (decoder instanceof Encoder.Binary) {
                    return ((Encoder.Binary) decoder).encode(o);
                } else {
                    try {
                        ByteArrayOutputStream out = new ByteArrayOutputStream();
View Full Code Here

Examples of javax.websocket.Encoder

            throws DeploymentException {

        for (Class<? extends Encoder> encoder : encoders) {
            // Need to instantiate decoder to ensure it is valid and that
            // deployment can be failed if it is not
            @SuppressWarnings("unused")
            Encoder instance;
            try {
                encoder.newInstance();
            } catch(InstantiationException e) {
                throw new DeploymentException(sm.getString(
View Full Code Here

Examples of jj2000.j2k.encoder.Encoder

        {
          sb.append("-" + e.getKey() + " " + e.getValue() + " ");
        }
       
       
        dec = new Encoder(pl);
        showStatus("Encoding... parameters " + sb.toString());
        dec.run();
  }
View Full Code Here

Examples of lzma.sdk.lzma.Encoder

            throw new IllegalArgumentException(String.format(
                    "numFastBytes: %d (expected: %d-%d)", numFastBytes, MIN_FAST_BYTES, MAX_FAST_BYTES
            ));
        }

        encoder = new Encoder();
        encoder.setDictionarySize(dictionarySize);
        encoder.setEndMarkerMode(endMarkerMode);
        encoder.setMatchFinder(DEFAULT_MATCH_FINDER);
        encoder.setNumFastBytes(numFastBytes);
        encoder.setLcLpPb(lc, lp, pb);
View Full Code Here

Examples of macromedia.abc.Encoder

    }
  }

  private void merge(List<DoABC> doABCs, boolean debug, boolean runPeephole, String name)
  {
    Encoder encoder;
    Decoder decoder;

    boolean skipFrame = false;
    int majorVersion = 0, minorVersion = 0, abcSize = doABCs.size(), flag = 1;

    if (abcSize == 0)
    {
      return;
    }
    else if (abcSize == 1)
    {
      flag = doABCs.get(0).flag;
    }
    else
    {
      flag = 1;
    }

    Decoder[] decoders = new Decoder[abcSize];
    ConstantPool[] pools = new ConstantPool[abcSize];

    // create decoders...
    for (int j = 0; j < abcSize; j++)
    {
      DoABC tag = doABCs.get(j);
      BytecodeBuffer in = new BytecodeBuffer(tag.abc);

      try
      {
        // ThreadLocalToolkit.logInfo(tag.name);
        decoders[j] = new Decoder(in);
        majorVersion = decoders[j].majorVersion;
        minorVersion = decoders[j].minorVersion;
        pools[j] = decoders[j].constantPool;
      }
      catch (Throwable ex)
      {
        StringWriter stringWriter = new StringWriter();
        ex.printStackTrace(new PrintWriter(stringWriter));
        assert false : stringWriter.toString();
        skipFrame = true;
        break;
      }
    }

    if (skipFrame)
    {
      return;
    }

    encoder = new Encoder(majorVersion, minorVersion);
    // all the constant pools are merged here...
    try
    {
      encoder.addConstantPools(pools);
      if (!debug)
      {
        encoder.disableDebugging();
      }

      // always remove metadata...
      encoder.removeMetadata();

      // keep the following metadata
      for (int m = 0; as3metadata != null && m < as3metadata.length; m++)
      {
        encoder.addMetadataToKeep(as3metadata[m]);
      }
     
      // always enable peephole optimization...
      if (runPeephole)
      {
        encoder.enablePeepHole();
      }

      encoder.configure(decoders);
    }
    catch (Throwable ex)
    {
      StringWriter stringWriter = new StringWriter();
      ex.printStackTrace(new PrintWriter(stringWriter));
      assert false : stringWriter.toString();
      return;
    }


    // decode methodInfo...
    for (int j = 0; j < abcSize; j++)
    {
      decoder = decoders[j];
      encoder.useConstantPool(j);

      Decoder.MethodInfo methodInfo = decoder.methodInfo;

      try
      {
        for (int k = 0, infoSize = methodInfo.size(); k < infoSize; k++)
        {
          methodInfo.decode(k, encoder);
        }
      }
      catch (Throwable ex)
      {
        StringWriter stringWriter = new StringWriter();
        ex.printStackTrace(new PrintWriter(stringWriter));
        assert false : stringWriter.toString();
        skipFrame = true;
        break;
      }
    }

    if (skipFrame)
    {
      return;
    }

    // decode metadataInfo...
    for (int j = 0; j < abcSize; j++)
    {
      decoder = decoders[j];
      encoder.useConstantPool(j);

      Decoder.MetaDataInfo metadataInfo = decoder.metadataInfo;

      try
      {
        for (int k = 0, infoSize = metadataInfo.size(); k < infoSize; k++)
        {
          metadataInfo.decode(k, encoder);
        }
      }
      catch (Throwable ex)
      {
        StringWriter stringWriter = new StringWriter();
        ex.printStackTrace(new PrintWriter(stringWriter));
        assert false : stringWriter.toString();
        skipFrame = true;
        break;
      }
    }

    if (skipFrame)
    {
      return;
    }

    // decode classInfo...

    for (int j = 0; j < abcSize; j++)
    {
      decoder = decoders[j];
      encoder.useConstantPool(j);

      Decoder.ClassInfo classInfo = decoder.classInfo;

      try
      {
        for (int k = 0, infoSize = classInfo.size(); k < infoSize; k++)
        {
          classInfo.decodeInstance(k, encoder);
        }
      }
      catch (Throwable ex)
      {
        StringWriter stringWriter = new StringWriter();
        ex.printStackTrace(new PrintWriter(stringWriter));
        assert false : stringWriter.toString();
        skipFrame = true;
        break;
      }
    }

    if (skipFrame)
    {
      return;
    }

    for (int j = 0; j < abcSize; j++)
    {
      decoder = decoders[j];
      encoder.useConstantPool(j);

      Decoder.ClassInfo classInfo = decoder.classInfo;

      try
      {
        for (int k = 0, infoSize = classInfo.size(); k < infoSize; k++)
        {
          classInfo.decodeClass(k, 0, encoder);
        }
      }
      catch (Throwable ex)
      {
        StringWriter stringWriter = new StringWriter();
        ex.printStackTrace(new PrintWriter(stringWriter));
        assert false : stringWriter.toString();
        skipFrame = true;
        break;
      }
    }

    if (skipFrame)
    {
      return;
    }

    // decode scripts...
    for (int j = 0; j < abcSize; j++)
    {
      decoder = decoders[j];
      encoder.useConstantPool(j);

      Decoder.ScriptInfo scriptInfo = decoder.scriptInfo;

      try
      {
        for (int k = 0, scriptSize = scriptInfo.size(); k < scriptSize; k++)
        {
          scriptInfo.decode(k, encoder);
        }
      }
      catch (Throwable ex)
      {
        StringWriter stringWriter = new StringWriter();
        ex.printStackTrace(new PrintWriter(stringWriter));
        assert false : stringWriter.toString();
        skipFrame = true;
        break;
      }
    }

    if (skipFrame)
    {
      return;
    }

    // decode method bodies...
    for (int j = 0; j < abcSize; j++)
    {
      decoder = decoders[j];
      encoder.useConstantPool(j);

      Decoder.MethodBodies methodBodies = decoder.methodBodies;

      try
      {
        for (int k = 0, bodySize = methodBodies.size(); k < bodySize; k++)
        {
          methodBodies.decode(k, 2, encoder);
        }
      }
      catch (Throwable ex)
      {
        StringWriter stringWriter = new StringWriter();
        ex.printStackTrace(new PrintWriter(stringWriter));
        assert false : stringWriter.toString();
        skipFrame = true;
        break;
      }
    }

    if (skipFrame)
    {
      return;
    }

    // 0: eager
    // 1: lazy
    DoABC doABC = new DoABC(name, flag);
    doABC.abc = encoder.toABC();

    if (doABC.abc != null)
    {
      doABCs.clear();
      doABCs.add(doABC);
View Full Code Here

Examples of marauroa.common.net.Encoder

    /*
     * Create the perception and serialize it.
     */
    Perception p=zone.getPerception(obj, Perception.SYNC);
    MessageS2CPerception msg=new MessageS2CPerception(null, p);
    Encoder enc=Encoder.get();
    byte[] data=enc.encode(msg);
   
    Decoder dec=Decoder.get();
    List<Message> msgs=dec.decode(null, data);
   
    /*
     * There should only be one message.
     */
    assertEquals(1, msgs.size());
   
    MessageS2CPerception recv=(MessageS2CPerception)msgs.get(0);
    assertTrue(recv.getModifiedAddedRPObjects().isEmpty());
    assertTrue(recv.getModifiedDeletedRPObjects().isEmpty());
    assertTrue(recv.getDeletedRPObjects().isEmpty());
   
    List<RPObject> added=recv.getAddedRPObjects();
    assertEquals(1, added.size());
   
    RPObject recreated=added.get(0);
    assertNotNull(recreated);
    recreatedZone.add(recreated);
   
    assertEquals(obj, recreated);
   
    /*
     * Let's move Zone to the next turn.
     */
    zone.nextTurn();
    recreatedZone.nextTurn();

    /*
     * Remove object from lhand.
     */
    RPSlot lhand = obj.getSlot("lhand");
    RPObject pocket=lhand.getFirst();
    RPObject removed=lhand.remove(pocket.getID());
   
    assertNotNull(removed);
    assertEquals(removed,pocket);
   
    zone.modify(obj);
   
    /*
     * Create the perception and serialize it.
     */
    p=zone.getPerception(obj, Perception.DELTA);
    msg=new MessageS2CPerception(null, p);
    data=enc.encode(msg);
   
    msgs=dec.decode(null, data);
   
    assertEquals("there should only be one message",1, msgs.size());
   
View Full Code Here

Examples of net.hasor.rsf.serialize.Encoder

        return decoder.decode(this.returnData);
    }
    /**设置要返回的值*/
    public void setReturnData(Object data, SerializeFactory serializeFactory) throws Throwable {
        String codeName = this.getSerializeType();
        Encoder encoder = serializeFactory.getEncoder(codeName);
        //
        this.returnData = encoder.encode(data);
    }
View Full Code Here

Examples of net.tomp2p.message.Encoder

    int intVal = 42;

    Message m1 = Utils2.createDummyMessage();
    m1.intValue(intVal);
   
    Encoder encoder = new Encoder(null); // TODO signaturefactory?

    AlternativeCompositeByteBuf buf = AlternativeCompositeByteBuf.compBuffer(); // TODO what buffer to use?
   
    encoder.write(buf, m1, null);
   
    byte[] bytes = buf.array();
    writeToFile(bytes);
   
  }
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.