I run for standalone, its correct. Any changes from my previous code?
On Fri, May 30, 2008 at 9:11 AM, Emmanuel Lecharny <[EMAIL PROTECTED]>
wrote:
> Hi,
>
> I have ported your code on a standalone class to test it :
>
>
> import java.io.BufferedReader;
> import java.io.IOException;
> import java.io.Reader;
> import java.io.StringReader;
> import java.nio.charset.CharacterCodingException;
> import java.nio.charset.Charset;
> import java.nio.charset.CharsetDecoder;
> import java.util.HashMap;
> import java.util.HashSet;
> import java.util.Map;
> import java.util.Set;
>
> import org.apache.mina.common.ByteBuffer;
> import org.apache.mina.common.IoSession;
> import org.apache.mina.filter.codec.demux.MessageDecoderResult;
>
> public class FSResponseDecoder {
>
> private static final byte[] CONTENT_LENGTH = new
> String("Content-Length:").getBytes();
>
> private CharsetDecoder decoder = Charset.defaultCharset().newDecoder();
>
> public FSResponseDecoder() {
> }
>
> synchronized public MessageDecoderResult decodable(IoSession session,
> ByteBuffer in) {
> try {
> return messageComplete(in) ? MessageDecoderResult.OK
> : MessageDecoderResult.NEED_DATA;
> } catch (Exception ex) {
> ex.printStackTrace();
> }
>
> return MessageDecoderResult.NOT_OK;
> }
>
> public MessageDecoderResult decode(IoSession session, ByteBuffer in)
> throws Exception {
> // Try to decode body
>
> System.out.println("[[[[[ Decode function on session "+session);
>
> decodeBody(in);
>
> System.out.println("]]]]] Finish decode function on session
> "+session);
>
> return MessageDecoderResult.OK;
> }
>
> private String getBufferString(ByteBuffer in) {
> int size = in.remaining();
>
> if (size == 0) {
> return "empty";
> }
>
> StringBuffer out = new StringBuffer(size);
>
> while(in.hasRemaining()) {
> out.append((char) in.get());
> }
>
> in.flip();
>
> return out.toString();
> }
>
> private int getEndOfHeader(ByteBuffer in,int last) {
> int eoh = -1;
> for (int i = 0; i < last; i++) {
> if (in.get(i) == (byte) 0x0A && in.get(i + 1) == (byte) 0x0A) {
> eoh = i + 1;
> break;
> }
> }
> return eoh;
> }
>
> private boolean messageComplete(ByteBuffer in) throws Exception {
> int sizeToRead = 0;
> int last = in.remaining() - 1;
>
> System.out.println("***** New Buffer to analyze *****");
>
> String str = getBufferString(in); // in.getHexDump();
>
> System.out.println("Buffer Dump\n"+str);
>
> int eoh = getEndOfHeader(in, last);
>
> if (eoh == -1)
> return false;
>
>
> if (in.get(0) == (byte) 'C' && in.get(1) == (byte) 'o' &&
> in.get(2) == (byte) 'n' &&
> in.get(3) == (byte) 't' && in.get(4) == (byte) 'e' &&
> in.get(5) == (byte) 'n' &&
> in.get(6) == (byte) 't' && in.get(7) == (byte) '-' &&
> in.get(8) == (byte) 'L' &&
> in.get(9) == (byte) 'e' && in.get(10) == (byte) 'n' &&
> in.get(11) == (byte) 'g' &&
> in.get(12) == (byte) 't' && in.get(13) == (byte) 'h')
> {
>
> int contentLength = getContentLength(in, last);
>
> boolean result;
>
> if (contentLength>0) {
> result = contentLength + eoh <= in.remaining();
> sizeToRead = contentLength + (eoh+1);
> System.out.println("content_length["+contentLength+"]
> eoh["+eoh+"] == in.remaining["+in.remaining()+"] ==> "+result);
> if (result)
> System.out.println("sizeToRead is >>>> "+sizeToRead);
> }
> else
> result = false;
>
> return (result);
>
> }
>
> sizeToRead = eoh+1;
> System.out.println("sizeToRead is >>>> "+sizeToRead);
>
> return true;
> }
>
>
> private int getContentLength(ByteBuffer in, int last) {
>
> String str = getBufferString(in); // in.getHexDump();
> System.out.println("last = "+last);
> System.out.println("***** Buffer in getContentLength 1 *****\n"+str);
>
> for (int i = 0; i < last; i++) {
> boolean found = false;
> for (int j = 0; j < CONTENT_LENGTH.length; j++) {
> if (in.get(i + j) != CONTENT_LENGTH[j]) {
> found = false;
> break;
> }
> found = true;
> }
> if (found) {
> // retrieve value from this position till next 0x0D 0x0A
> System.out.println("Found content-length index at "+i);
>
> StringBuilder contentLength = new StringBuilder();
> for (int j = i + CONTENT_LENGTH.length; j < last; j++) {
> if (in.get(j) == 0x0A)
> break;
> contentLength.append(new String( new byte[] { in.get(j)
> }));
> System.out.println("["+new String( new byte[]
> {in.get(j)})+"]");
> }
> // if content-length worth of data has been received then the
> message is complete
>
> str = getBufferString(in); // in.getHexDump();
> System.out.println("***** Buffer in getContentLength
> 2*****\n"+str);
>
> System.out.println("ContentLength = "+contentLength);
> System.out.println("total buffer length = "+in.remaining());
> return Integer.parseInt(contentLength.toString().trim());
> }
> }
> return -1;
> }
>
> private void decodeBody(ByteBuffer in) {
> try {
>
> int sizeToRead = 0;
> int last = in.remaining() - 1;
> int eoh = getEndOfHeader(in, last);
>
> if (in.get(0) == (byte) 'C' && in.get(1) == (byte) 'o' &&
> in.get(2) == (byte) 'n' &&
> in.get(3) == (byte) 't' && in.get(4) == (byte) 'e'
> && in.get(5) == (byte) 'n' &&
> in.get(6) == (byte) 't' && in.get(7) == (byte) '-'
> && in.get(8) == (byte) 'L' &&
> in.get(9) == (byte) 'e' && in.get(10) == (byte) 'n'
> && in.get(11) == (byte) 'g' &&
> in.get(12) == (byte) 't' && in.get(13) == (byte)
> 'h')
> {
> int contentLength = getContentLength(in, last);
> sizeToRead = contentLength + (eoh+1);
> }
> else
> sizeToRead = eoh+1;
>
> System.out.println("Parsing request with sizeToRead =
> "+sizeToRead);
> parseRequest(new StringReader(in.getString(sizeToRead,
> decoder)));
> } catch (CharacterCodingException ex) {
> ex.printStackTrace();
> } catch (Exception e) {
> // TODO Auto-generated catch block
> e.printStackTrace();
> }
> }
>
> private void parseRequest(Reader is) {
>
> BufferedReader rdr = new BufferedReader(is);
> Map<String, String> response = new HashMap<String,String>();
>
> try {
> // Get request URL.
> String line;
>
> // Read header
> System.out.println("Reading parameters:");
> while ((line = rdr.readLine()) != null && line.length() > 0) {
> String[] tokens = line.split(": ");
> response.put(tokens[0], tokens[1] );
> System.out.println(tokens[0]+": "+tokens[1]);
> }
>
> // determine content-type of this response
> String contentType = response.get("Content-Type");
>
> // If method 'POST' then read Content-Length worth of data
> if (contentType.equalsIgnoreCase("text/event-xml") ||
> contentType.equalsIgnoreCase("text/event-plain")) {
> int len = Integer.parseInt(response.get("Content-Length"));
> char[] buf = new char[len];
> if (rdr.read(buf) == len) {
> line = String.copyValueOf(buf);
> }
> String str = line;
> response.put("Event-Data", str);
> }
>
> } catch (IOException ex) {
> ex.printStackTrace();
> }
>
> }
>
> public static void main(String[] args) throws Exception
> {
> FSResponseDecoder decoder = new FSResponseDecoder();
> String str =
> "Content-Length: 1619\n"+
> "Content-Type: text/event-plain\n"+
> "\n"+
> "Channel-State: CS_NEW\n"+
> "Channel-State-Number: 0\n"+
> "Channel-Name: sofia/external/nobody%40192.168.3.12\n"+
> "Unique-ID: fd2229c0-2d6c-11dd-9acd-0b28d09a52aa\n"+
> "Call-Direction: inbound\n"+
> "Answer-State: ringing\n"+
> "variable_sip_from_user: nobody\n"+
> "variable_sip_from_uri: nobody%40192.168.3.12\n"+
> "variable_sip_from_host: 192.168.3.12\n"+
> "variable_sip_from_tag: 02H917ryecvgp\n"+
> "variable_sofia_profile_name: external\n"+
> "variable_sofia_profile_domain_name: external\n"+
> "variable_sip_req_user: 6001\n"+
> "variable_sip_req_port: 5080\n"+
> "variable_sip_req_uri: 6001%40192.168.3.11%3A5080\n"+
> "variable_sip_req_host: 192.168.3.11\n"+
> "variable_sip_to_user: 6001\n"+
> "variable_sip_to_port: 5080\n"+
> "variable_sip_to_uri: 6001%40192.168.3.11%3A5080\n"+
> "variable_sip_to_host: 192.168.3.11\n"+
> "variable_sip_contact_user: mod_sofia\n"+
> "variable_sip_contact_port: 5060\n"+
> "variable_sip_contact_uri: mod_sofia%40192.168.3.12%3A5060\n"+
> "variable_sip_contact_host: 192.168.3.12\n"+
> "variable_channel_name: sofia/external/nobody%40192.168.3.12\n"+
> "variable_endpoint_disposition: INBOUND%20CALL\n"+
> "variable_sip_call_id: 824f7531-a82e-122b-8485-000f1f644b48\n"+
> "variable_sip_user_agent: FreeSWITCH-mod_sofia/1.0.pre4-8539\n"+
> "variable_sip_via_host: 192.168.3.12\n"+
> "variable_sip_via_rport: 5060\n"+
> "variable_max_forwards: 70\n"+
> "Event-Name: CHANNEL_CREATE\n"+
> "Core-UUID: ed9888ba-2c94-11dd-";
> int capacity = str.getBytes().length;
> ByteBuffer bb = ByteBuffer.allocate( capacity );
> bb.put( str.getBytes() );
> decoder.decode( null, bb );
> }
> }
>
>
> Here are the logs :
>
> [[[[[ Decode function on session null
> last = 752
> ***** Buffer in getContentLength 1 *****
>
>
> seems correct. Can you test it ?
>
>
> --
> --
> cordialement, regards,
> Emmanuel Lécharny
> www.iktek.com
> directory.apache.org
>
>
>
