mirror of
https://github.com/ChronosX88/psyced.git
synced 2024-11-09 12:01:00 +00:00
36 lines
784 B
Plaintext
36 lines
784 B
Plaintext
|
# contributed by fippo
|
||
|
|
||
|
Stdio.File socket;
|
||
|
int count;
|
||
|
array(int) start, stop;
|
||
|
|
||
|
void logon(int success) {
|
||
|
socket->set_nonblocking(read_cb);
|
||
|
socket->write(".\n");
|
||
|
}
|
||
|
|
||
|
void read_cb(int id, string data) {
|
||
|
//werror("read_cb:\n%s\n---\n", data);
|
||
|
count++;
|
||
|
if (count == 2) {
|
||
|
start = System.gettimeofday()[..1];
|
||
|
socket->write(":_target\tpsyc://localhost/~fippo\n\n_request_version\n.\n");
|
||
|
}
|
||
|
if (count > 2) {
|
||
|
stop = System.gettimeofday()[..1];
|
||
|
werror("latency is %d\n", (stop[0] - start[0])*1000000 + (stop[1] - start[1]));
|
||
|
if (count < 500) {
|
||
|
socket->write(":_target\tpsyc://localhost/\n\n_request_version\n.\n");
|
||
|
start = stop;
|
||
|
}
|
||
|
}
|
||
|
|
||
|
}
|
||
|
|
||
|
int main() {
|
||
|
socket = Stdio.File();
|
||
|
socket->async_connect("localhost", 4404, logon);
|
||
|
|
||
|
return -1;
|
||
|
}
|