[0001]
[0002]
[0003]
[0004]
[0005]
[0006]
[0007]
[0008]
[0009]
[0010]
[0011]
[0012]
[0013]
[0014]
[0015]
[0016]
[0017]
[0018]
[0019]
[0020]
[0021]
[0022]
[0023]
[0024]
[0025]
[0026]
[0027]
[0028]
[0029]
[0030]
[0031]
[0032]
[0033]
[0034]
[0035]
[0036]
[0037]
[0038]
[0039]
[0040]
[0041]
[0042]
[0043]
[0044]
[0045]
[0046]
[0047]
[0048]
[0049]
[0050]
[0051]
[0052]
[0053]
[0054]
[0055]
[0056]
[0057]
[0058]
[0059]
[0060]
[0061]
[0062]
[0063]
[0064]
[0065]
[0066]
[0067]
[0068]
[0069]
[0070]
[0071]
[0072]
[0073]
[0074]
[0075]
[0076]
[0077]
[0078]
[0079]
[0080]
[0081]
[0082]
[0083]
[0084]
[0085]
[0086]
[0087]
[0088]
[0089]
[0090]
[0091]
[0092]
[0093]
[0094]
[0095]
[0096]
[0097]
[0098]
[0099]
[0100]
[0101]
[0102]
[0103]
[0104]
[0105]
[0106]
[0107]
[0108]
[0109]
[0110]
[0111]
[0112]
[0113]
[0114]
[0115]
[0116]
[0117]
[0118]
[0119]
[0120]
[0121]
[0122]
[0123]
[0124]
[0125]
[0126]
[0127]
[0128]
[0129]
[0130]
[0131]
[0132]
[0133]
[0134]
[0135]
[0136]
[0137]
[0138]
[0139]
[0140]
[0141]
[0142]
[0143]
[0144]
[0145]
[0146]
[0147]
[0148]
[0149]
[0150]
[0151]
[0152]
[0153]
[0154]
[0155]
[0156]
[0157]
[0158]
[0159]
[0160]
[0161]
[0162]
[0163]
[0164]
[0165]
[0166]
[0167]
[0168]
[0169]
[0170]
[0171]
[0172]
[0173]
[0174]
[0175]
[0176]
[0177]
[0178]
[0179]
[0180]
[0181]
[0182]
[0183]
[0184]
[0185]
[0186]
[0187]
[0188]
[0189]
[0190]
[0191]
[0192]
[0193]
[0194]
[0195]
[0196]
[0197]
[0198]
[0199]
[0200]
[0201]
[0202]
[0203]
[0204]
[0205]
[0206]
[0207]
[0208]
[0209]
[0210]
[0211]
[0212]
[0213]
[0214]
[0215]
[0216]
[0217]
[0218]
[0219]
[0220]
[0221]
[0222]
[0223]
[0224]
[0225]
[0226]
[0227]
[0228]
[0229]
[0230]
[0231]
[0232]
[0233]
[0234]
[0235]
[0236]
[0237]
[0238]
[0239]
[0240]
[0241]
[0242]
[0243]
[0244]
[0245]
[0246]
[0247]
[0248]
[0249]
[0250]
[0251]
[0252]
[0253]
[0254]
[0255]
[0256]
[0257]
[0258]
[0259]
[0260]
[0261]
[0262]
[0263]
[0264]
[0265]
[0266]
[0267]
[0268]
[0269]
[0270]
[0271]
[0272]
[0273]
[0274]
[0275]
[0276]
[0277]
[0278]
[0279]
[0280]
[0281]
[0282]
[0283]
[0284]
[0285]
[0286]
[0287]
[0288]
[0289]
[0290]
[0291]
[0292]
[0293]
[0294]
[0295]
[0296]
[0297]
[0298]
[0299]
[0300]
[0301]
[0302]
[0303]
[0304]
[0305]
[0306]
[0307]
[0308]
[0309]
[0310]
[0311]
[0312]
[0313]
[0314]
[0315]
[0316]
[0317]
[0318]
[0319]
[0320]
[0321]
[0322]
[0323]
[0324]
[0325]
[0326]
[0327]
[0328]
[0329]
[0330]
[0331]
[0332]
[0333]
[0334]
[0335]
[0336]
[0337]
[0338]
[0339]
[0340]
[0341]
[0342]
[0343]
[0344]
[0345]
[0346]
[0347]
[0348]
[0349]
[0350]
[0351]
[0352]
[0353]
[0354]
[0355]
[0356]
[0357]
[0358]
[0359]
[0360]
[0361]
[0362]
[0363]
[0364]
[0365]
[0366]
[0367]
[0368]
[0369]
[0370]
[0371]
[0372]
[0373]
[0374]
[0375]
[0376]
[0377]
[0378]
[0379]
[0380]
[0381]
[0382]
[0383]
[0384]
[0385]
[0386]
[0387]
[0388]
[0389]
[0390]
[0391]
[0392]
[0393]
[0394]
[0395]
[0396]
[0397]
[0398]
[0399]
[0400]
/*****************************************************************************/
#ifdef COMMENTS_WITH_COMMENTS
/*
ws_bench.c
A test-bench exerciser server script (application) for the WASD WebSocket
development environment. This application is designed to be activated by the
command-line program WSB.C See this for a description of the various
tests/exercises available.
COPYRIGHT
---------
Copyright (C) 2011-2021 Mark G.Daniel
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
VERSION HISTORY
---------------
25-JUN-2011 MGD v1.0.0, initial development
*/
#endif /* COMMENTS_WITH_COMMENTS */
/*****************************************************************************/
#define SOFTWAREVN "1.0.0"
#define SOFTWARENM "WS_BENCH"
#ifdef __ALPHA
# define SOFTWAREID SOFTWARENM " AXP-" SOFTWAREVN
#endif
#ifdef __ia64
# define SOFTWAREID SOFTWARENM " IA64-" SOFTWAREVN
#endif
#ifdef __VAX
# define SOFTWAREID SOFTWARENM " VAX-" SOFTWAREVN
#endif
#ifdef __x86_64
# define SOFTWAREID SOFTWARENM " X86-" SOFTWAREVN
#endif
#include <ctype.h>
#include <errno.h>
#include <stdio.h>
#include <stdlib.h>
#include <stdarg.h>
#include <string.h>
#include <descrip.h>
#include <iodef.h>
#include <iosbdef.h>
#include <ssdef.h>
#include <stsdef.h>
#include "wslib.h"
#define VMSok(x) ((x) & STS$M_SUCCESS)
#define VMSnok(x) !(((x) & STS$M_SUCCESS))
#define Debug 0
#define FI_LI "WS_BENCH", __LINE__
#define EXIT_FI_LI(status) { printf ("[%s:%d]", FI_LI); exit(status); }
int ConcurrentMax,
ConnectedCount,
UpdateMax,
UsageCount;
unsigned int RandomNumber,
RandomFiller;
unsigned int CurrentTime;
unsigned long CurrentBinTime [2];
struct BenchClient {
int ClientCount,
CloseFrame,
DoEcho,
DoPush,
DoPing,
DoPong,
MessageSize,
PingCount,
PingToo,
PongToo,
PushCount,
PushBufferCount;
char *BufferPtr,
*PushBufferPtr;
struct WsLibStruct *WsLibPtr;
};
/* function prototypes */
void AddClient ();
void ClientReadAst (struct WsLibStruct*);
void PingClient (struct WsLibStruct*);
void RemoveClient (struct WsLibStruct*);
void PushClient (struct WsLibStruct*);
/*****************************************************************************/
/*
AST delivery is disabled during client acceptance and the add-client function
is deferred using an AST to help minimise the client setup window with a
potentially busy WebSocket application.
*/
main ()
{
/*********/
/* begin */
/*********/
/* don't want the C-RTL fiddling with the carriage control */
stdout = freopen ("SYS$OUTPUT", "w", stdout, "ctx=bin");
/* no clients is two minutes in seconds */
WsLibSetLifeSecs (2*60);
while (WsLibIsCgiPlus())
{
WsLibCgiVar ("");
sys$setast (0);
UsageCount++;
/* reset the PRNG */
sys$gettim (&RandomNumber);
AddClient ();
WsLibCgiPlusEof ();
sys$setast (1);
}
exit (SS$_NORMAL);
}
/*****************************************************************************/
/*
Allocate a client structure and add it to the head of the list.
*/
void AddClient ()
{
int len, status;
char *cptr;
struct WsLibStruct *wsptr;
struct BenchClient *clptr;
/*********/
/* begin */
/*********/
clptr = calloc (1, sizeof(struct BenchClient));
if (!clptr) EXIT_FI_LI (vaxc$errno);
cptr = WsLibCgiVar("FORM_DO");
if (!strcmp (cptr, "echo"))
clptr->DoEcho = 1;
else
if (!strcmp (cptr, "ping"))
clptr->DoPing = 1;
else
if (!strcmp (cptr, "pong"))
clptr->DoPong = 1;
else
if (!strcmp (cptr, "push"))
clptr->DoPush = 1;
else
EXIT_FI_LI (SS$_BUGCHECK);
/* buffer not specified or as zero then use wsLIB dynamic buffers */
if (cptr = WsLibCgiVarNull("FORM_SIZE"))
clptr->MessageSize = atoi(cptr);
if (clptr->MessageSize)
{
clptr->BufferPtr = calloc (1, clptr->MessageSize);
if (!clptr->BufferPtr) EXIT_FI_LI (vaxc$errno);
}
if (cptr = WsLibCgiVar("FORM_PING")) clptr->PingToo = atoi(cptr);
/* create a WebSocket library structure for the client */
if (!(clptr->WsLibPtr = wsptr = WsLibCreate (clptr, RemoveClient)))
{
/* failed, commonly on some WebSocket protocol issue */
free (clptr);
return;
}
/* open the IPC to the WebSocket (mailboxes) */
status = WsLibOpen (wsptr);
if (VMSnok(status)) EXIT_FI_LI(status);
/* no user interaction is two minutes in seconds */
WsLibSetIdleSecs (wsptr, 2*60);
/* maxiumum of five seconds without received data */
WsLibSetReadSecs (wsptr, 5);
ConnectedCount++;
WsLibRead (wsptr, clptr->BufferPtr, clptr->MessageSize, ClientReadAst);
}
/*****************************************************************************/
/*
Destroy the wsLIB structure and free the client structure memory.
*/
void RemoveClient (struct WsLibStruct *wsptr)
{
struct BenchClient *clptr;
/*********/
/* begin */
/*********/
clptr = WsLibGetUserData(wsptr);
if (clptr->DoPush) sys$cantim (wsptr, 0);
WsLibDestroy (wsptr);
free (clptr);
if (ConnectedCount) ConnectedCount--;
}
/*****************************************************************************/
/*
Read from WebSocket client has concluded. Process according to the test.
*/
void ClientReadAst (struct WsLibStruct *wsptr)
{
int DataCount;
char *DataPtr;
struct BenchClient *clptr;
/*********/
/* begin */
/*********/
WsLibWatchScript (wsptr, FI_LI, "ClientReadAst() %X!8XL !UL",
WsLibReadStatus(wsptr), WsLibReadCount(wsptr));
if (VMSnok (WsLibReadStatus(wsptr)))
{
/* WEBSOCKET_INPUT read error (can be EOF) */
WsLibClose (wsptr, WSLIB_CLOSE_BANG, NULL);
return;
}
clptr = WsLibGetUserData(wsptr);
if (clptr->PingToo) PingClient(wsptr);
DataPtr = WsLibReadData(wsptr);
DataCount = WsLibReadCount(wsptr);
if (clptr->DoEcho)
{
/* just bang it back at the test bench client */
if (WsLibReadIsBinary (wsptr))
WsLibSetBinary (wsptr);
else
if (WsLibReadIsText (wsptr))
{
/* read converted UTF-8 to ASCII, write converting back to UTF-8 */
WsLibSetAscii (wsptr);
}
WsLibWrite (wsptr, DataPtr, DataCount, WSLIB_ASYNCH);
}
else
if (clptr->DoPing || clptr->DoPong)
{
/* the pong should be handled transparently by wsLIB */
}
else
if (clptr->DoPush)
{
sscanf (DataPtr, "C:%d", &clptr->ClientCount);
if (!clptr->ClientCount) EXIT_FI_LI (SS$_BUGCHECK);
if (!clptr->PushBufferPtr)
{
clptr->PushBufferPtr = calloc (1, clptr->MessageSize);
if (!clptr->PushBufferPtr) EXIT_FI_LI (vaxc$errno);
}
memcpy (clptr->PushBufferPtr, DataPtr, DataCount);
clptr->PushBufferCount = DataCount;
/* first read from client kicks off the push */
if (!clptr->PushCount) PushClient (wsptr);
}
else
EXIT_FI_LI (SS$_BUGCHECK);
WsLibRead (wsptr, clptr->BufferPtr, clptr->MessageSize, ClientReadAst);
}
/*****************************************************************************/
/*
Push to the client (client-specified) content at pseudo-random intervals
between approximately 50mS and 1600mS. Client can change content at any time
(and be able to keep checking it's accurate). Client must disconnect. Tests
asynchronous, indeterminate server push.
*/
void PushClient (struct WsLibStruct *wsptr)
{
int len, status,
DataCount;
unsigned long DeltaTime [2];
char *DataPtr;
struct BenchClient *clptr;
/*********/
/* begin */
/*********/
clptr = WsLibGetUserData(wsptr);
if (clptr->PingToo) PingClient(wsptr);
clptr->PushCount++;
DataPtr = clptr->PushBufferPtr;
DataCount = clptr->PushBufferCount;
/* zero the first 24 bytes */
memset (DataPtr, '_', 24);
/* update the client and server count */
len = sprintf (DataPtr, "C:%d S:%d", clptr->ClientCount, clptr->PushCount);
DataPtr[len] = '_';
/* exercises synchronous write */
if (WsLibReadIsText (wsptr))
WsLibSetAscii (wsptr);
else
WsLibSetBinary (wsptr);
WsLibWrite (wsptr, DataPtr, DataCount, 0);
/* 50mS to 1600ms */
RandomNumber = RandomNumber * 69069 + 1;
DeltaTime[0] = -500000 * ((rand() & 31) + 1);
DeltaTime[1] = -1;
status = sys$setimr (0, &DeltaTime, PushClient, wsptr, 0);
if (VMSnok(status)) EXIT_FI_LI (status);
}
/*****************************************************************************/
/*
*/
void PingClient (struct WsLibStruct *wsptr)
{
int cnt;
char PingMsg [128];
struct BenchClient *clptr;
/*********/
/* begin */
/*********/
clptr = WsLibGetUserData(wsptr);
/* one in this many calls */
RandomNumber = RandomNumber * 69069 + 1;
if (RandomNumber % clptr->PingToo) return;
clptr->PingCount++;
cnt = sprintf (PingMsg, "%s ping #%d", SOFTWAREID, clptr->PingCount);
WsLibPing (wsptr, PingMsg, cnt);
}
/*****************************************************************************/