1. 包列表
  2. 类列表
  3. com.esotericsoftware.kryonet.FrameworkMessage.Ping

Java 类com.esotericsoftware.kryonet.FrameworkMessage.Ping 实例源码

项目：EsperDist    文件：Connection.java    
void notifyReceived (Object object) {
    if (object instanceof Ping) {
        Ping ping = (Ping)object;
        if (ping.isReply) {
            if (ping.id == lastPingID - 1) {
                returnTripTime = (int)(System.currentTimeMillis() - lastPingSendTime);
                if (TRACE) trace("kryonet", this + " return trip time: " + returnTripTime);
            }
        } else {
            ping.isReply = true;
            sendTCP(ping);
        }
    }
    Listener[] listeners = this.listeners;
    for (int i = 0, n = listeners.length; i < n; i++)
        listeners[i].received(this, object);
}
项目：EsperDist    文件：Connection.java    
void notifyReceived (Object object) {
    if (object instanceof Ping) {
        Ping ping = (Ping)object;
        if (ping.isReply) {
            if (ping.id == lastPingID - 1) {
                returnTripTime = (int)(System.currentTimeMillis() - lastPingSendTime);
                if (TRACE) trace("kryonet", this + " return trip time: " + returnTripTime);
            }
        } else {
            ping.isReply = true;
            sendTCP(ping);
        }
    }
    Listener[] listeners = this.listeners;
    for (int i = 0, n = listeners.length; i < n; i++)
        listeners[i].received(this, object);
}
项目：magic-realm    文件：Connection.java    
void notifyReceived (Object object) {
    if (object instanceof Ping) {
        Ping ping = (Ping)object;
        if (ping.isReply) {
            if (ping.id == lastPingID - 1) {
                returnTripTime = (int)(System.currentTimeMillis() - lastPingSendTime);
                if (TRACE) trace("kryonet", this + " return trip time: " + returnTripTime);
            }
        } else {
            ping.isReply = true;
            sendTCP(ping);
        }
    }
    Listener[] listeners = this.listeners;
    for (int i = 0, n = listeners.length; i < n; i++)
        listeners[i].received(this, object);
}
项目：kingdom    文件：Connection.java    
void notifyReceived (Object object) {
    if (object instanceof Ping) {
        Ping ping = (Ping)object;
        if (ping.isReply) {
            if (ping.id == lastPingID - 1) {
                returnTripTime = (int)(System.currentTimeMillis() - lastPingSendTime);
                if (TRACE) trace("kryonet", this + " return trip time: " + returnTripTime);
            }
        } else {
            ping.isReply = true;
            sendTCP(ping);
        }
    }
    Listener[] listeners = this.listeners;
    for (int i = 0, n = listeners.length; i < n; i++)
        listeners[i].received(this, object);
}
项目：the-erder    文件：Connection.java    
void notifyReceived(Object object) {
    if (object instanceof Ping) {
        Ping ping = (Ping) object;
        if (ping.isReply) {
            if (ping.id == lastPingID - 1) {
                returnTripTime = (int) (System.currentTimeMillis() - lastPingSendTime);
                if (TRACE)
                    trace("kryonet", this + " return trip time: "
                            + returnTripTime);
            }
        } else {
            ping.isReply = true;
            sendTCP(ping);
        }
    }
    Listener[] listeners = this.listeners;
    for (int i = 0, n = listeners.length; i < n; i++)
        listeners[i].received(this, object);
}
项目：kryonet    文件：Connection.java    
void notifyReceived (Object object) {
    if (object instanceof Ping) {
        Ping ping = (Ping)object;
        if (ping.isReply) {
            if (ping.id == lastPingID - 1) {
                returnTripTime = (int)(System.currentTimeMillis() - lastPingSendTime);
                if (TRACE) trace("kryonet", this + " return trip time: " + returnTripTime);
            }
        } else {
            ping.isReply = true;
            sendTCP(ping);
        }
    }
    Listener[] listeners = this.listeners;
    for (int i = 0, n = listeners.length; i < n; i++)
        listeners[i].received(this, object);
}
项目：RuinsOfRevenge    文件：Connection.java    
void notifyReceived (Object object) {
    if (object instanceof Ping) {
        Ping ping = (Ping)object;
        if (ping.isReply) {
            if (ping.id == lastPingID - 1) {
                returnTripTime = (int)(System.currentTimeMillis() - lastPingSendTime);
                if (TRACE) trace("kryonet", this + " return trip time: " + returnTripTime);
            }
        } else {
            ping.isReply = true;
            sendTCP(ping);
        }
    }
    Listener[] listeners = this.listeners;
    for (int i = 0, n = listeners.length; i < n; i++)
        listeners[i].received(this, object);
}
项目：EsperDist    文件：Connection.java    
/** Requests the connection to communicate with the remote computer to determine a new value for the
 * {@link #getReturnTripTime() return trip time}. When the connection receives a {@link FrameworkMessage.Ping} object with
 * {@link Ping#isReply isReply} set to true, the new return trip time is available. */
public void updateReturnTripTime () {
    Ping ping = new Ping();
    ping.id = lastPingID++;
    lastPingSendTime = System.currentTimeMillis();
    sendTCP(ping);
}
项目：EsperDist    文件：KryoSerialization.java    
public KryoSerialization (Kryo kryo) {
    this.kryo = kryo;

    kryo.register(RegisterTCP.class);
    kryo.register(RegisterUDP.class);
    kryo.register(KeepAlive.class);
    kryo.register(DiscoverHost.class);
    kryo.register(Ping.class);

    input = new Input(byteBufferInputStream, 512);
    output = new Output(byteBufferOutputStream, 512);
}
项目：EsperDist    文件：JsonSerialization.java    
public JsonSerialization () {
    json.addClassTag("RegisterTCP", RegisterTCP.class);
    json.addClassTag("RegisterUDP", RegisterUDP.class);
    json.addClassTag("KeepAlive", KeepAlive.class);
    json.addClassTag("DiscoverHost", DiscoverHost.class);
    json.addClassTag("Ping", Ping.class);

    json.setWriter(writer);
}
项目：EsperDist    文件：Connection.java    
/** Requests the connection to communicate with the remote computer to determine a new value for the
 * {@link #getReturnTripTime() return trip time}. When the connection receives a {@link FrameworkMessage.Ping} object with
 * {@link Ping#isReply isReply} set to true, the new return trip time is available. */
public void updateReturnTripTime () {
    Ping ping = new Ping();
    ping.id = lastPingID++;
    lastPingSendTime = System.currentTimeMillis();
    sendTCP(ping);
}
项目：EsperDist    文件：KryoSerialization.java    
public KryoSerialization (Kryo kryo) {
    this.kryo = kryo;

    kryo.register(RegisterTCP.class);
    kryo.register(RegisterUDP.class);
    kryo.register(KeepAlive.class);
    kryo.register(DiscoverHost.class);
    kryo.register(Ping.class);

    input = new Input(byteBufferInputStream, 512);
    output = new Output(byteBufferOutputStream, 512);
}
项目：EsperDist    文件：JsonSerialization.java    
public JsonSerialization () {
    json.addClassTag("RegisterTCP", RegisterTCP.class);
    json.addClassTag("RegisterUDP", RegisterUDP.class);
    json.addClassTag("KeepAlive", KeepAlive.class);
    json.addClassTag("DiscoverHost", DiscoverHost.class);
    json.addClassTag("Ping", Ping.class);

    json.setWriter(writer);
}
项目：magic-realm    文件：Connection.java    
/** Requests the connection to communicate with the remote computer to determine a new value for the
 * {@link #getReturnTripTime() return trip time}. When the connection receives a {@link FrameworkMessage.Ping} object with
 * {@link Ping#isReply isReply} set to true, the new return trip time is available. */
public void updateReturnTripTime () {
    Ping ping = new Ping();
    ping.id = lastPingID++;
    lastPingSendTime = System.currentTimeMillis();
    sendTCP(ping);
}
项目：magic-realm    文件：KryoSerialization.java    
public KryoSerialization (Kryo kryo) {
    this.kryo = kryo;

    kryo.register(RegisterTCP.class);
    kryo.register(RegisterUDP.class);
    kryo.register(KeepAlive.class);
    kryo.register(DiscoverHost.class);
    kryo.register(Ping.class);

    input = new ByteBufferInput();
    output = new ByteBufferOutput();
}
项目：magic-realm    文件：JsonSerialization.java    
public JsonSerialization () {
    json.addClassTag("RegisterTCP", RegisterTCP.class);
    json.addClassTag("RegisterUDP", RegisterUDP.class);
    json.addClassTag("KeepAlive", KeepAlive.class);
    json.addClassTag("DiscoverHost", DiscoverHost.class);
    json.addClassTag("Ping", Ping.class);

    json.setWriter(writer);
}
项目：flume2storm    文件：MyKryoSerialization.java    
public MyKryoSerialization(Kryo kryo, int objectSize) {
  this.kryo = kryo;

  kryo.register(RegisterTCP.class);
  kryo.register(RegisterUDP.class);
  kryo.register(KeepAlive.class);
  kryo.register(DiscoverHost.class);
  kryo.register(Ping.class);

  input = new Input(byteBufferInputStream, objectSize);
  output = new Output(byteBufferOutputStream, objectSize);
}
项目：kingdom    文件：Connection.java    
/** Requests the connection to communicate with the remote computer to determine a new value for the
 * {@link #getReturnTripTime() return trip time}. When the connection receives a {@link FrameworkMessage.Ping} object with
 * {@link Ping#isReply isReply} set to true, the new return trip time is available. */
public void updateReturnTripTime () {
    Ping ping = new Ping();
    ping.id = lastPingID++;
    lastPingSendTime = System.currentTimeMillis();
    sendTCP(ping);
}
项目：kingdom    文件：KryoSerialization.java    
public KryoSerialization (Kryo kryo) {
    this.kryo = kryo;

    kryo.register(RegisterTCP.class);
    kryo.register(RegisterUDP.class);
    kryo.register(KeepAlive.class);
    kryo.register(DiscoverHost.class);
    kryo.register(Ping.class);

    input = new Input(byteBufferInputStream, 512);
    output = new Output(byteBufferOutputStream, 512);
}
项目：kingdom    文件：JsonSerialization.java    
public JsonSerialization () {
    json.addClassTag("RegisterTCP", RegisterTCP.class);
    json.addClassTag("RegisterUDP", RegisterUDP.class);
    json.addClassTag("KeepAlive", KeepAlive.class);
    json.addClassTag("DiscoverHost", DiscoverHost.class);
    json.addClassTag("Ping", Ping.class);

    json.setWriter(writer);
}
项目：the-erder    文件：KryoSerialization.java    
public KryoSerialization(Kryo kryo) {
    this.kryo = kryo;

    kryo.register(RegisterTCP.class);
    kryo.register(RegisterUDP.class);
    kryo.register(KeepAlive.class);
    kryo.register(DiscoverHost.class);
    kryo.register(Ping.class);

    input = new ByteBufferInput();
    output = new ByteBufferOutput();
}
项目：the-erder    文件：JsonSerialization.java    
public JsonSerialization() {
    json.addClassTag("RegisterTCP", RegisterTCP.class);
    json.addClassTag("RegisterUDP", RegisterUDP.class);
    json.addClassTag("KeepAlive", KeepAlive.class);
    json.addClassTag("DiscoverHost", DiscoverHost.class);
    json.addClassTag("Ping", Ping.class);

    json.setWriter(writer);
}
项目：kryonet    文件：Connection.java    
/** Requests the connection to communicate with the remote computer to determine a new value for the
 * {@link #getReturnTripTime() return trip time}. When the connection receives a {@link FrameworkMessage.Ping} object with
 * {@link Ping#isReply isReply} set to true, the new return trip time is available. */
public void updateReturnTripTime () {
    Ping ping = new Ping();
    ping.id = lastPingID++;
    lastPingSendTime = System.currentTimeMillis();
    sendTCP(ping);
}
项目：kryonet    文件：KryoSerialization.java    
public KryoSerialization (Kryo kryo) {
    this.kryo = kryo;

    kryo.register(RegisterTCP.class);
    kryo.register(RegisterUDP.class);
    kryo.register(KeepAlive.class);
    kryo.register(DiscoverHost.class);
    kryo.register(Ping.class);

    input = new ByteBufferInput();
    output = new ByteBufferOutput();
}
项目：kryonet    文件：JsonSerialization.java    
public JsonSerialization () {
    json.addClassTag("RegisterTCP", RegisterTCP.class);
    json.addClassTag("RegisterUDP", RegisterUDP.class);
    json.addClassTag("KeepAlive", KeepAlive.class);
    json.addClassTag("DiscoverHost", DiscoverHost.class);
    json.addClassTag("Ping", Ping.class);

    json.setWriter(writer);
}
项目：RuinsOfRevenge    文件：Connection.java    
/** Requests the connection to communicate with the remote computer to determine a new value for the
 * {@link #getReturnTripTime() return trip time}. When the connection receives a {@link FrameworkMessage.Ping} object with
 * {@link Ping#isReply isReply} set to true, the new return trip time is available. */
public void updateReturnTripTime () {
    Ping ping = new Ping();
    ping.id = lastPingID++;
    lastPingSendTime = System.currentTimeMillis();
    sendTCP(ping);
}
项目：RuinsOfRevenge    文件：KryoSerialization.java    
public KryoSerialization (Kryo kryo) {
    this.kryo = kryo;

    kryo.register(RegisterTCP.class);
    kryo.register(RegisterUDP.class);
    kryo.register(KeepAlive.class);
    kryo.register(DiscoverHost.class);
    kryo.register(Ping.class);

    input = new Input(byteBufferInputStream, 512);
    output = new Output(byteBufferOutputStream, 512);
}
项目：RuinsOfRevenge    文件：JsonSerialization.java    
public JsonSerialization () {
    json.addClassTag("RegisterTCP", RegisterTCP.class);
    json.addClassTag("RegisterUDP", RegisterUDP.class);
    json.addClassTag("KeepAlive", KeepAlive.class);
    json.addClassTag("DiscoverHost", DiscoverHost.class);
    json.addClassTag("Ping", Ping.class);
}
项目：the-erder    文件：Connection.java    
/**
 * Requests the connection to communicate with the remote computer to
 * determine a new value for the {@link #getReturnTripTime() return trip
 * time}. When the connection receives a {@link FrameworkMessage.Ping}
 * object with {@link Ping#isReply isReply} set to true, the new return trip
 * time is available.
 */
public void updateReturnTripTime() {
    Ping ping = new Ping();
    ping.id = lastPingID++;
    lastPingSendTime = System.currentTimeMillis();
    sendTCP(ping);
}