[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]
/*****************************************************************************/
#ifdef COMMENTS_WITH_COMMENTS
/*
ws_mouse.c
A demonstrator for CGIplus Web Socket scripts.
The JavaScript-driven client-side of this demonstrator is in
WASD_ROOT:[SRC.WEBSOCKET]WS_MOUSE.HTML
To help manage potential bandwidth consumption the update rate is explicitly
limited. To disable this for experimentation with maximum granularity define
the logical name "WS_MOUSE_UPDATE_MAX" and HTTPD/DO=DCL=DELETE.
Suppress host name lookup by defining the logical name WS_MOUSE_NO_LOOKUP.
Experiment with the WsLibOnNextRequest() approach to request synchronisation by
defining the logical name WS_MOUSE_ON_NEXT_REQUEST.
COPYRIGHT
---------
Copyright (C) 2010-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
---------------
18-AUG-2014 MGD v1.2.0, demonstrate WsLibOnNextRequest()
21-JUL-2012 MGD v1.1.1, WsLibDestroy() deprecated
03-DEC-2011 MGD v1.1.0, a touch more sophistication
24-JUL-2010 MGD v1.0.0, initial development
*/
#endif /* COMMENTS_WITH_COMMENTS */
/*****************************************************************************/
#define SOFTWAREVN "1.2.0"
#define SOFTWARENM "WS_MOUSE"
#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 <stdio.h>
#include <stdlib.h>
#include <stdarg.h>
#include <string.h>
#include <ctype.h>
#include <errno.h>
#include <netdb.h>
#include <descrip.h>
#include <iodef.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_MOUSE", __LINE__
#define EXIT_FI_LI(status) { printf ("[%s:%d]", FI_LI); exit(status); }
int ConcurrentMax,
ConnectedCount,
UpdateMax,
UsageCount;
void (*UpdateFunction)() = NULL;
struct MouseClient
{
int UpdateCount,
YouIdent;
char ConnectTime [32],
InputBuffer [256],
MouseCoord [32],
RemoteHostPort [128+16];
struct WsLibStruct *WsLibPtr;
};
/* function prototypes */
void AddClient ();
void NextRequest ();
void RemoveClient (struct WsLibStruct*);
void RemoteHostPort (struct MouseClient*);
void UpdateClient (struct WsLibStruct*);
void UpdateAllClients ();
/*****************************************************************************/
/*
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");
UpdateMax = (getenv("WS_MOUSE_UPDATE_MAX") != NULL);
/* no clients is two minutes in seconds */
WsLibSetLifeSecs (2*60);
if (!WsLibIsCgiPlus())
{
fprintf (stdout, "Status: 500\r\n\r\n\
WebSocket needs to be CGIplus!\n");
}
else
if (getenv("WS_MOUSE_ON_NEXT_REQUEST") != NULL)
{
WsLibOnNextRequest (NextRequest);
/* asynchronous from here-on-in */
for (;;) sys$hiber();
}
else
{
for (;;)
{
WsLibCgiVar ("");
sys$setast (0);
UsageCount++;
AddClient (0);
WsLibCgiPlusEof ();
sys$setast (1);
}
}
exit (SS$_NORMAL);
}
/*****************************************************************************/
/*
Asynchronous notification the next request is available. This function is
called at AST-delivery level and so no need to disable ASTs. Add the client
and then notify the server we're ready for another.
*/
void NextRequest ()
{
/*********/
/* begin */
/*********/
UsageCount++;
AddClient (1);
WsLibCgiPlusEof ();
}
/*****************************************************************************/
/*
Allocate a client structure and add it to the head of the list.
*/
void AddClient (int OnNext)
{
int len, status;
char ConnectTime [32],
YouString [32];
$DESCRIPTOR (TimeFaoDsc, "!20%D\0");
$DESCRIPTOR (TimeDsc, "");
struct WsLibStruct *wsptr;
struct MouseClient *clptr;
/*********/
/* begin */
/*********/
clptr = calloc (1, sizeof(struct MouseClient));
if (!clptr) EXIT_FI_LI (vaxc$errno);
RemoteHostPort (clptr);
TimeDsc.dsc$a_pointer = clptr->ConnectTime;
TimeDsc.dsc$w_length = sizeof(clptr->ConnectTime);
sys$fao (&TimeFaoDsc, 0, &TimeDsc, 0);
clptr->YouIdent = UsageCount;
/* create a WebSocket library structure for the client */
if (!(clptr->WsLibPtr = wsptr = WsLibCreate (clptr, RemoveClient)))
{
/* failed, commonly on some WebSocket protocol issue */
/* if asynchronous next-request convey this to the JavaScript client */
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);
len = sprintf (YouString, "you=%u", clptr->YouIdent);
WsLibWrite (wsptr, YouString, len, WSLIB_ASYNCH);
/* if maximum granularity then convey this to the JavaScript client */
if (UpdateMax) WsLibWrite (wsptr, "update=max", 10, WSLIB_ASYNCH);
/* if asynchronous next-request convey this to the JavaScript client */
if (OnNext) WsLibWrite (wsptr, "OnNext", 6, WSLIB_ASYNCH);
ConnectedCount++;
WsLibRead (wsptr, clptr->InputBuffer,
sizeof(clptr->InputBuffer),
UpdateClient);
}
/*****************************************************************************/
/*
Destory the wsLIB structure and free the client structure memory.
*/
void RemoveClient (struct WsLibStruct *wsptr)
{
struct MouseClient *clptr;
/*********/
/* begin */
/*********/
clptr = WsLibGetUserData (wsptr);
free (clptr);
if (ConnectedCount) ConnectedCount--;
}
/*****************************************************************************/
/*
Read from WebSocket client has concluded. These are the mouse coordinates.
Ensure they look like they should and store them. Update all (other) clients
with this change.
*/
void UpdateClient (struct WsLibStruct *wsptr)
{
static unsigned long OneTenthDelta [2] = { -1000000, -1 };
int mx, my, status;
struct MouseClient *clptr;
/*********/
/* begin */
/*********/
if (!UpdateFunction)
{
UpdateFunction = UpdateAllClients;
status = sys$setimr (0, &OneTenthDelta, UpdateFunction, 1, 0);
if (VMSnok(status)) EXIT_FI_LI (status);
}
if (VMSnok (WsLibReadStatus(wsptr)))
{
/* WEBSOCKET_INPUT read error (can be EOF) */
WsLibClose (wsptr, 0, NULL);
return;
}
clptr = WsLibGetUserData(wsptr);
clptr->UpdateCount++;
if (clptr->InputBuffer[0])
{
sscanf (clptr->InputBuffer, "%d,%d", &mx, &my);
sprintf (clptr->MouseCoord, "%d,%d", mx, my);
}
else
clptr->MouseCoord[0] = '\0';
WsLibRead (wsptr,
clptr->InputBuffer,
sizeof(clptr->InputBuffer),
UpdateClient);
}
/*****************************************************************************/
/*
Build a string buffer with the details of all connected clients. Write this
buffer to all connected clients simultaneously updating all with the new
details. No UTF-8 conversion is required because the text is all 7 bit ASCII.
By default the update rate is explicitly limited to 100mS.
*/
void UpdateAllClients ()
{
static char UpdateBuffer [2048];
int cnt = 0,
status;
char *sptr, *zptr;
struct WsLibStruct *wsptr;
struct MouseClient *clptr;
/*********/
/* begin */
/*********/
UpdateFunction = NULL;
zptr = (sptr = UpdateBuffer) + sizeof(UpdateBuffer)-128;
for (wsptr = NULL; WsLibNext(&wsptr);)
{
clptr = WsLibGetUserData(wsptr);
sptr += sprintf (sptr, "%u|%d|%s|%s|%d|%s\n",
clptr->YouIdent, ++cnt, clptr->ConnectTime,
clptr->RemoteHostPort, clptr->UpdateCount,
clptr->MouseCoord);
if (sptr > zptr) break;
}
if (sptr > zptr) sptr += sprintf (sptr, "[overflow]||||||");
*sptr = '\0';
for (wsptr = NULL; WsLibNext(&wsptr);)
WsLibWrite (wsptr, UpdateBuffer, sptr-UpdateBuffer, WSLIB_ASYNCH);
}
/*****************************************************************************/
/*
Get the remote host name/address and port number (blocking, IPv4 only).
*/
void RemoteHostPort (struct MouseClient *clptr)
{
int IpAddr;
struct hostent *HostEntryPtr;
/*********/
/* begin */
/*********/
/* if the server has host name resolution enabled */
strcpy (clptr->RemoteHostPort, WsLibCgiVar("REMOTE_HOST"));
/* otherwise resolve it ourselves */
if (!strcmp (clptr->RemoteHostPort, WsLibCgiVar("REMOTE_ADDR")))
if (!getenv ("WS_MOUSE_NO_LOOKUP"))
if ((IpAddr = inet_addr (clptr->RemoteHostPort)) != -1)
if (HostEntryPtr = gethostbyaddr (&IpAddr, 4, AF_INET))
strcpy (clptr->RemoteHostPort, HostEntryPtr->h_name);
strcat (clptr->RemoteHostPort, ":");
strcat (clptr->RemoteHostPort, WsLibCgiVar("REMOTE_PORT"));
}
/*****************************************************************************/