Sha256: 8af01527c7fd4b2727e16121f46ffc95115da559f2a0ed724bced543f33ea435
Contents?: true
Size: 1.87 KB
Versions: 4
Compression:
Stored size: 1.87 KB
Contents
package org.mortbay.cometd.client.ext;
import java.util.Map;
import org.cometd.Client;
import org.cometd.Extension;
import org.cometd.Message;
import org.mortbay.util.ajax.JSON;
public class TimesyncClientExtension implements Extension
{
volatile int _lag;
volatile int _offset;
public Message rcv(Client from, Message message)
{
return message;
}
public Message rcvMeta(Client from, Message message)
{
Map<String,Object> ext=message.getExt(false);
if (ext!=null)
{
Map<String,Object> sync=(Map<String,Object>)ext.get("timesync");
if (sync!=null)
{
long now = System.currentTimeMillis();
final long tc=((Number)sync.get("tc")).longValue();
final long ts=((Number)sync.get("ts")).longValue();
final int p=((Number)sync.get("p")).intValue();
// final int a=((Number)sync.get("a")).intValue();
int l2 = (int) ((now - tc - p) / 2);
int o2 = (int) (ts-tc-l2);
_lag=_lag==0?l2:(_lag+l2)/2;
_offset=_offset==0?o2:(_offset+o2)/2;
}
}
return message;
}
public Message send(Client from, Message message)
{
return message;
}
public Message sendMeta(Client from, Message message)
{
Map<String,Object> ext=message.getExt(true);
long now = System.currentTimeMillis();
JSON.Literal timesync=new JSON.Literal("{\"tc\":"+now+",\"l\":"+_lag+",\"o\":"+_offset+"}");
ext.put("timesync",timesync);
return message;
}
public int getOffset()
{
return _offset;
}
public int getLag()
{
return _lag;
}
public long getServerTime()
{
return System.currentTimeMillis()+_offset;
}
}
Version data entries
4 entries across 4 versions & 1 rubygems