Skip to content

Commit 433047f

Browse files
committed
Fix max chunk length, remove console.logs
1 parent d03c754 commit 433047f

File tree

4 files changed

+6
-216
lines changed

4 files changed

+6
-216
lines changed

package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@
3939
"clean:modules": "find -name node_modules -or -name __pypackages__ -prune -exec rm -rf {} ';' 2> /dev/null",
4040
"lint": "TIMING=1 NODE_OPTIONS=\"--max-old-space-size=3072\" eslint . --ext .ts --ext .js --cache --cache-strategy=content --cache-location=.eslintcache_scramjet-csi",
4141
"lint:uncached": "rm .eslintcache_scramjet-csi && yarn lint",
42-
"start": "node dist/sth/bin/hub.js",
42+
"start": "node --trace-warnings dist/sth/bin/hub.js",
4343
"start:dev": "ts-node packages/sth/src/bin/hub.ts",
4444
"start:dev:cli": "ts-node packages/cli/src/bin/index.ts",
4545
"install:clean": "yarn clean && yarn clean:modules && yarn install",

packages/tecemux/src/codecs/frame-encoder.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ import { FrameData, ITeCeMux } from "../types";
88
import { calculateChecksum } from "./utils";
99

1010
export class FrameEncoder extends Transform {
11-
MAX_CHUNK_SIZE = 64 * 1024 - HEADER_LENGTH;
11+
MAX_CHUNK_SIZE = 32 * 1024 - HEADER_LENGTH;
1212

1313
tecemux: ITeCeMux;
1414
total = 0;

packages/tecemux/src/tecemux.ts

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -100,13 +100,13 @@ export class TeceMux extends TypedEmitter<TeceMuxEvents> {
100100
if (flags.ACK && flags.SYN) {
101101
channel?.encoder.pause();
102102
this.framesKeeper.handleACK(acknowledgeNumber);
103-
//console.log("Pause channel command received", channel?._id);
103+
//console.log("Pause channel command received", channel?._id);
104104
return 0;
105105
}
106106

107107
if (flags.ACK) {
108108
if (channel?.encoder.isPaused()) {
109-
console.log("Pause and receive ack", channel._id);
109+
//console.log("Pause and receive ack", channel._id);
110110
}
111111
this.logger.trace("Received ACK flag for sequenceNumber", acknowledgeNumber);
112112
this.framesKeeper.handleACK(acknowledgeNumber);
@@ -150,12 +150,12 @@ export class TeceMux extends TypedEmitter<TeceMuxEvents> {
150150
channel.sendPauseACK(sequenceNumber);
151151

152152
channel.once("resume", () => {
153-
console.log("resumed, send ack to resume");
153+
//console.log("resumed, send ack to resume");
154154
//channel?.encoder.resume();
155155
channel?.sendACK(sequenceNumber);
156156
});
157157
channel.once("drain", () => {
158-
console.log("drained, send ack to resume");
158+
//console.log("drained, send ack to resume");
159159
//channel?.encoder.resume();
160160
channel?.sendACK(sequenceNumber);
161161
});

yarn.lock

Lines changed: 0 additions & 210 deletions
Original file line numberDiff line numberDiff line change
@@ -1179,211 +1179,6 @@
11791179
resolved "https://registry.yarnpkg.com/@protobufjs/utf8/-/utf8-1.1.0.tgz#a777360b5b39a1a2e5106f8e858f2fd2d060c570"
11801180
integrity sha512-Vvn3zZrhQZkkBE8LSuW3em98c0FwgO4nxzv6OdSxPKJIEKY2bGbHn+mhGIPerzI4twdxaP8/0+06HBpwf345Lw==
11811181

1182-
"@scramjet/adapters@^0.36.1":
1183-
version "0.36.1"
1184-
resolved "https://registry.yarnpkg.com/@scramjet/adapters/-/adapters-0.36.1.tgz#022c2ddc3cdc5594f80802e72e08bc250c179ae1"
1185-
integrity sha512-GTj9boNlyy7E39mtag1lsyZGRrORUf4JmFGVtrJYNRK5uzLyKBE+X4nCQQhUGlIame/DsZHQqbK6jQIC6AuWdQ==
1186-
dependencies:
1187-
"@kubernetes/client-node" "^0.17.1"
1188-
"@scramjet/model" "^0.36.1"
1189-
"@scramjet/obj-logger" "^0.36.1"
1190-
"@scramjet/pre-runner" "^0.36.1"
1191-
"@scramjet/python-runner" "^0.36.1"
1192-
"@scramjet/runner" "^0.36.1"
1193-
"@scramjet/sth-config" "^0.36.1"
1194-
"@scramjet/symbols" "^0.36.1"
1195-
"@scramjet/utility" "^0.36.1"
1196-
dockerode "^3.3.4"
1197-
scramjet "^4.36.9"
1198-
shell-escape "^0.2.0"
1199-
systeminformation "^5.21.7"
1200-
ts.data.json "^2.2.0"
1201-
1202-
"@scramjet/api-client@^0.36.1":
1203-
version "0.36.1"
1204-
resolved "https://registry.yarnpkg.com/@scramjet/api-client/-/api-client-0.36.1.tgz#c039e2fa0269839385866679f95e5d5f42efeb3f"
1205-
integrity sha512-hRnYi39ovMbnvN0GwAma8D2ISnqxg8VKnixb3lbUse5DyIC3qUwwH70UH+DXxheE5nuqfyU9BPA1FEY1InRD0A==
1206-
dependencies:
1207-
"@scramjet/client-utils" "^0.36.1"
1208-
"@scramjet/sth-config" "^0.36.1"
1209-
"@scramjet/symbols" "^0.36.1"
1210-
n-readlines "^1.0.1"
1211-
scramjet "^4.36.9"
1212-
1213-
"@scramjet/api-server@^0.36.1":
1214-
version "0.36.1"
1215-
resolved "https://registry.yarnpkg.com/@scramjet/api-server/-/api-server-0.36.1.tgz#1ea88b4d8827dc57221968b35e7247fe1052b2c8"
1216-
integrity sha512-s8R2gnWBw66ZVmKcTVOaylIwAcLDvU7qoWft2TWHyhmqoh1kgb0/PdcjcOsVG5uK8D+/RXtMqNBoAB/isNjpiQ==
1217-
dependencies:
1218-
"0http" "^3.4.1"
1219-
"@scramjet/model" "^0.36.1"
1220-
"@scramjet/obj-logger" "^0.36.1"
1221-
"@scramjet/symbols" "^0.36.1"
1222-
"@scramjet/utility" "^0.36.1"
1223-
http-status-codes "^2.2.0"
1224-
scramjet "^4.36.9"
1225-
1226-
"@scramjet/client-utils@^0.36.1":
1227-
version "0.36.1"
1228-
resolved "https://registry.yarnpkg.com/@scramjet/client-utils/-/client-utils-0.36.1.tgz#2c68d1786a1508f1658bd1eda2e6d7f56207933e"
1229-
integrity sha512-06DG2Q316OVUN7gXzLRvk4PCtCSXWVK0wL2iU3d77Ks54Jvw7v9N307p0mfQ0M3AE/c1gT7iaI2lwfMb0vrwuw==
1230-
dependencies:
1231-
"@scramjet/model" "^0.36.1"
1232-
"@scramjet/obj-logger" "^0.36.1"
1233-
"@scramjet/sth-config" "^0.36.1"
1234-
"@scramjet/symbols" "^0.36.1"
1235-
"@scramjet/utility" "^0.36.1"
1236-
"@types/node-fetch" "^2.6.4"
1237-
abort-controller "^3.0.0"
1238-
n-readlines "^1.0.1"
1239-
node-fetch "^2.6.7"
1240-
normalize-url "4"
1241-
scramjet "^4.36.9"
1242-
1243-
"@scramjet/host@^0.36.1":
1244-
version "0.36.1"
1245-
resolved "https://registry.yarnpkg.com/@scramjet/host/-/host-0.36.1.tgz#961306c78057edc57a2f2ef1fedbd8620890d803"
1246-
integrity sha512-55Et6PiezYB2AktDuBlNtzGna/9FTRGTnRedgJmjIRtQUKVhBFUHBzg2WsL5hPO/OMjxtdsnTES9YYcXRawaTA==
1247-
dependencies:
1248-
"@scramjet/adapters" "^0.36.1"
1249-
"@scramjet/api-server" "^0.36.1"
1250-
"@scramjet/load-check" "^0.36.1"
1251-
"@scramjet/model" "^0.36.1"
1252-
"@scramjet/module-loader" "^0.36.1"
1253-
"@scramjet/obj-logger" "^0.36.1"
1254-
"@scramjet/sth-config" "^0.36.1"
1255-
"@scramjet/symbols" "^0.36.1"
1256-
"@scramjet/telemetry" "^0.36.1"
1257-
"@scramjet/utility" "^0.36.1"
1258-
"@scramjet/verser" "^0.36.1"
1259-
bpmux "^8.2.1"
1260-
ext-ip "^0.3.9"
1261-
find-package-json "^1.2.0"
1262-
http-status-codes "^2.2.0"
1263-
minimist "^1.2.6"
1264-
pico-s3 "^2.0.0"
1265-
rereadable-stream "^1.4.14"
1266-
scramjet "^4.36.9"
1267-
systeminformation "^5.21.7"
1268-
1269-
"@scramjet/load-check@^0.36.1":
1270-
version "0.36.1"
1271-
resolved "https://registry.yarnpkg.com/@scramjet/load-check/-/load-check-0.36.1.tgz#211374c6776a1b0f94d36be750c3fad9105b9fe3"
1272-
integrity sha512-R3hhICDItTpHjAsWsjF7C6ko/gm3NBx2JmwB++Spb4zs3xeu9Sz6mK4WmJSKbMAmfMaS/dTYJyOImee1ZkQSzA==
1273-
dependencies:
1274-
"@scramjet/obj-logger" "^0.36.1"
1275-
"@scramjet/utility" "^0.36.1"
1276-
scramjet "^4.36.9"
1277-
systeminformation "^5.21.7"
1278-
uuid "^8.3.2"
1279-
1280-
"@scramjet/logger@^0.36.1":
1281-
version "0.36.1"
1282-
resolved "https://registry.yarnpkg.com/@scramjet/logger/-/logger-0.36.1.tgz#933e844115dae3863ba8ad8982499f53184141be"
1283-
integrity sha512-HX6cgSJtDOy+wOAyCKLUdqCOUSoI2qVhmWDrXnhPNescWzcYQ9LuinhRrqGb85qIQPIGYa1i/QVaKheSFk8s3A==
1284-
dependencies:
1285-
scramjet "^4.36.9"
1286-
1287-
"@scramjet/manager-api-client@^0.36.1":
1288-
version "0.36.1"
1289-
resolved "https://registry.yarnpkg.com/@scramjet/manager-api-client/-/manager-api-client-0.36.1.tgz#7eb8be766a4b0f285b532ffd6e90d95838a69712"
1290-
integrity sha512-B9HiBbckoWszT/w5nO68h8PUF29Ry73oECCYmBsVtZgRJG3nR2NKhBg7iu9AGM1DlG1RANSLFjloG50ZolUNGQ==
1291-
dependencies:
1292-
"@scramjet/api-client" "^0.36.1"
1293-
"@scramjet/client-utils" "^0.36.1"
1294-
1295-
"@scramjet/middleware-api-client@^0.36.1":
1296-
version "0.36.1"
1297-
resolved "https://registry.yarnpkg.com/@scramjet/middleware-api-client/-/middleware-api-client-0.36.1.tgz#988018d741f003f7e760d73c6cdbc08b414bcb93"
1298-
integrity sha512-slIV+9n7Lrda6a5BR89qezR9WfmfvRNUGm9acP1z7I5PW9cS9zNq8NlWo63tuFJ8q5OOdp5MfBaqbj1irKl+yg==
1299-
dependencies:
1300-
"@scramjet/api-client" "^0.36.1"
1301-
"@scramjet/client-utils" "^0.36.1"
1302-
"@scramjet/manager-api-client" "^0.36.1"
1303-
"@scramjet/multi-manager-api-client" "^0.36.1"
1304-
1305-
"@scramjet/model@^0.36.1":
1306-
version "0.36.1"
1307-
resolved "https://registry.yarnpkg.com/@scramjet/model/-/model-0.36.1.tgz#89bbad5e324d6fcb7db7bbb685f1b4e2c1f74bc9"
1308-
integrity sha512-HRSsiunjmXIFiNbHr55c6fT3u3WMLdY+mKGepINHDA6F/D0y4MfTHwt0xirUlmFxMzX6iXvTGtgvknI8EZemcQ==
1309-
dependencies:
1310-
"@scramjet/obj-logger" "^0.36.1"
1311-
"@scramjet/symbols" "^0.36.1"
1312-
scramjet "^4.36.9"
1313-
uuid "^8.3.2"
1314-
1315-
"@scramjet/module-loader@^0.36.1":
1316-
version "0.36.1"
1317-
resolved "https://registry.yarnpkg.com/@scramjet/module-loader/-/module-loader-0.36.1.tgz#b73883c0ffc95133e01cf50a241a20a0fcda805d"
1318-
integrity sha512-R3PTA2XjSjHFAI7DHnykKvChO+FYqjsFIRv+1TdzHXLKHlVWtfERgYx3IWlQSIAcIJL0+AtSM/0RaZMjVQ3OoQ==
1319-
dependencies:
1320-
"@scramjet/obj-logger" "^0.36.1"
1321-
1322-
"@scramjet/multi-manager-api-client@^0.36.1":
1323-
version "0.36.1"
1324-
resolved "https://registry.yarnpkg.com/@scramjet/multi-manager-api-client/-/multi-manager-api-client-0.36.1.tgz#bf6d62a8d754f1ed07601ef17e79b76a701a3938"
1325-
integrity sha512-9ZsMRJUXav3d8shX3zKL3pY7tZTOrucgqL5KFwLJFtSkoFf/egLKjaifl9PE6Tj0zufRtXi3HTWfXtPE/IFlHw==
1326-
dependencies:
1327-
"@scramjet/api-client" "^0.36.1"
1328-
"@scramjet/client-utils" "^0.36.1"
1329-
"@scramjet/manager-api-client" "^0.36.1"
1330-
1331-
"@scramjet/obj-logger@^0.36.1":
1332-
version "0.36.1"
1333-
resolved "https://registry.yarnpkg.com/@scramjet/obj-logger/-/obj-logger-0.36.1.tgz#e7d15c33f22444f3871e62cd5ce3964c2f1d0fce"
1334-
integrity sha512-3yDell8/QKf+W4lGCgm74tf+bNS/S0U0//xO/7FyZbiE69ajJhd3f9C70Q2Xf9xYBMyhpJuK+vTteGAJiJCtdQ==
1335-
dependencies:
1336-
"@scramjet/utility" "^0.36.1"
1337-
scramjet "^4.36.9"
1338-
1339-
"@scramjet/pre-runner@^0.36.1":
1340-
version "0.36.1"
1341-
resolved "https://registry.yarnpkg.com/@scramjet/pre-runner/-/pre-runner-0.36.1.tgz#eb4dd97510a7603c005f75d583ea4778d21a484f"
1342-
integrity sha512-0KJv85S7w21YjLNbpunWlx4wXE2J1oPI5iOmJ8LinyAa/t87iuQA+4BTVWIdRRP8F8/Z9puI+GQbZ2oYBMuRag==
1343-
1344-
"@scramjet/python-runner@^0.36.1":
1345-
version "0.36.1"
1346-
resolved "https://registry.yarnpkg.com/@scramjet/python-runner/-/python-runner-0.36.1.tgz#9c82bebe661523aa4faea7b907ac5b611359c29e"
1347-
integrity sha512-4gQrbzXQlYWNT1ms7RhpRlSyfuZjqTZT9oAkcFE52mtYbif6MmHbGt89mChnuab7RwgtdcjWqO6S/0EE+79a+A==
1348-
1349-
"@scramjet/sth-config@^0.36.1":
1350-
version "0.36.1"
1351-
resolved "https://registry.yarnpkg.com/@scramjet/sth-config/-/sth-config-0.36.1.tgz#73c939b6771df48500fcc3cd7df79cfeea199efa"
1352-
integrity sha512-xV5pAx8Ulp0onotBke4ZozP1xBNsF8u0stuxw0ONNBl7v0ZIpcSiZF6ASUVCSwQ7Cv7yoSMwRCcT+vI4QRKAog==
1353-
dependencies:
1354-
"@scramjet/utility" "^0.36.1"
1355-
1356-
"@scramjet/symbols@^0.36.1":
1357-
version "0.36.1"
1358-
resolved "https://registry.yarnpkg.com/@scramjet/symbols/-/symbols-0.36.1.tgz#9777a3c33d6228572ea053bddac32c652a0d6229"
1359-
integrity sha512-gDjEOuKoYn/Tl0MdbkliHnJzMOFlHuf3HKMERVnptdF6oqU3VR+azm0nQ2cnZUjv/VTuI51QMXmgk1HKnq9i5g==
1360-
1361-
"@scramjet/telemetry@^0.36.1":
1362-
version "0.36.1"
1363-
resolved "https://registry.yarnpkg.com/@scramjet/telemetry/-/telemetry-0.36.1.tgz#3b35aab94a4035273293018e5ea5d2156d2af718"
1364-
integrity sha512-gt/uS0BvzJFpUGKrUZd+6nJcTJmO+GZBc0arc93xqnADK73/4Qlh1eTSSmtCo36/JO3oZNRFQzRQd1ffL7hBtw==
1365-
dependencies:
1366-
"@scramjet/obj-logger" "^0.36.1"
1367-
"@scramjet/utility" "^0.36.1"
1368-
winston "^3.8.2"
1369-
winston-loki "^6.0.6"
1370-
1371-
"@scramjet/types@^0.36.1":
1372-
version "0.36.1"
1373-
resolved "https://registry.yarnpkg.com/@scramjet/types/-/types-0.36.1.tgz#659aeb6e129faed2190cd528d9109b740e8968da"
1374-
integrity sha512-K40buwGRHSVfDy464YxbDLrYTrczpkMWxbskUtTYAUsgKbiKiQEELmjyUP3yS9AUt4UQZDwKWn2eUmhUWl1sGg==
1375-
dependencies:
1376-
"@scramjet/symbols" "^0.36.1"
1377-
http-status-codes "^2.2.0"
1378-
1379-
"@scramjet/utility@^0.36.1":
1380-
version "0.36.1"
1381-
resolved "https://registry.yarnpkg.com/@scramjet/utility/-/utility-0.36.1.tgz#a92b25093afa6d68904aac5cb9a1f541a7c146eb"
1382-
integrity sha512-sDanZi5evXaTs+LsR/O1znCZuAa7sJv5EDwGLEF2RpW5fBFOWGhtcCJJ3yJN4qQeyMtjTu/J6c4wnBiZNK4JHQ==
1383-
dependencies:
1384-
normalize-url "4"
1385-
yaml "^2.2.2"
1386-
13871182
"@sinclair/typebox@^0.27.8":
13881183
version "0.27.8"
13891184
resolved "https://registry.yarnpkg.com/@sinclair/typebox/-/typebox-0.27.8.tgz#6667fac16c436b5434a387a34dedb013198f6e6e"
@@ -8460,11 +8255,6 @@ syncpack@^5.8.15:
84608255
read-yaml-file "2.1.0"
84618256
semver "7.3.5"
84628257

8463-
systeminformation@^5.21.7:
8464-
version "5.21.7"
8465-
resolved "https://registry.yarnpkg.com/systeminformation/-/systeminformation-5.21.7.tgz#53ef75daaf5d756d015f4bb02e059126ccac74f2"
8466-
integrity sha512-K3LjnajrazTLTD61+87DFg8IXFk5ljx6nSBqB8pQLtC1UPivAjDtTYGPZ8jaBFxcesPaCOkvLRtBq+RFscrsLw==
8467-
84688258
systeminformation@^5.21.7:
84698259
version "5.21.15"
84708260
resolved "https://registry.yarnpkg.com/systeminformation/-/systeminformation-5.21.15.tgz#d40fb97462580e99522efa585b1c643cf930e788"

0 commit comments

Comments
 (0)