2020-07-20 11:41:15 +02:00
|
|
|
"use strict";
|
|
|
|
|
|
2020-06-13 20:50:34 +02:00
|
|
|
const { SRT } = require('../index.js');
|
2020-06-13 09:43:20 +02:00
|
|
|
|
|
|
|
|
const srt = new SRT();
|
|
|
|
|
const socket = srt.createSocket();
|
2020-06-13 18:04:12 +02:00
|
|
|
if (socket !== -1) {
|
|
|
|
|
console.log("Created socket: " + socket);
|
2020-07-20 11:41:15 +02:00
|
|
|
}
|
2020-06-13 09:43:20 +02:00
|
|
|
|
2020-06-13 18:04:12 +02:00
|
|
|
let result;
|
|
|
|
|
result = srt.bind(socket, "0.0.0.0", 1234);
|
|
|
|
|
if (!result) {
|
|
|
|
|
console.log("Bind success");
|
|
|
|
|
} else {
|
|
|
|
|
console.log(result);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
result = srt.listen(socket, 2);
|
|
|
|
|
if (!result) {
|
|
|
|
|
console.log("Listen success");
|
|
|
|
|
} else {
|
|
|
|
|
console.log(result);
|
|
|
|
|
}
|
2020-06-13 20:50:34 +02:00
|
|
|
|
|
|
|
|
console.log("Waiting for client to connect");
|
2020-07-20 11:41:15 +02:00
|
|
|
const fhandle = srt.accept(socket);
|
2020-06-13 20:50:34 +02:00
|
|
|
|
|
|
|
|
if (fhandle) {
|
|
|
|
|
console.log("Client connected");
|
2020-06-18 19:17:32 +02:00
|
|
|
const chunk = srt.read(fhandle, 1316);
|
|
|
|
|
console.log("Read chunk: " + chunk.length);
|
2020-07-20 11:41:15 +02:00
|
|
|
}
|