2
amscommon.c: common functions used by libams, amsd,
3
and the transport service adapters.
5
Author: Scott Burleigh, JPL
7
Copyright (c) 2005, California Institute of Technology.
8
ALL RIGHTS RESERVED. U.S. Government Sponsorship
11
#include "amscommon.h"
13
#define EPOCH_OFFSET_1958 (378691200)
14
#define MAX_GW_EID (255)
16
extern void destroyAmsEndpoint(LystElt elt, void *userdata);
18
static void eraseContinuum(Continuum *contin)
27
MRELEASE(contin->name);
30
if (contin->description)
32
MRELEASE(contin->description);
38
void eraseSubject(Venture *venture, Subject *subj)
40
if (venture == NULL || subj == NULL)
45
if (subj->elt) /* Must remove from hashtable. */
47
lyst_delete(subj->elt);
55
if (subj->description)
57
MRELEASE(subj->description);
60
if (subj->symmetricKeyName)
62
MRELEASE(subj->symmetricKeyName);
65
if (subj->authorizedSenders)
67
lyst_destroy(subj->authorizedSenders);
70
if (subj->authorizedReceivers)
72
lyst_destroy(subj->authorizedReceivers);
77
lyst_destroy(subj->modules);
80
venture->subjects[subj->nbr] = NULL;
84
void eraseRole(Venture *venture, AppRole *role)
86
if (venture == NULL || role == NULL)
96
if (role->publicKeyName)
98
MRELEASE(role->publicKeyName);
101
if (role->privateKeyName)
103
MRELEASE(role->privateKeyName);
106
venture->roles[role->nbr] = NULL;
110
void eraseMsgspace(Venture *venture, Subject *msgspace)
112
if (venture == NULL || msgspace == NULL)
119
MRELEASE(msgspace->gwEid);
122
if (msgspace->symmetricKeyName)
124
MRELEASE(msgspace->symmetricKeyName);
127
if (msgspace->authorizedSenders)
129
lyst_destroy(msgspace->authorizedSenders);
132
if (msgspace->authorizedReceivers)
134
lyst_destroy(msgspace->authorizedReceivers);
137
if (msgspace->modules)
139
lyst_destroy(msgspace->modules);
142
venture->msgspaces[0 - msgspace->nbr] = NULL;
146
static void eraseModule(Module *module)
151
if (module->amsEndpoints)
153
for (elt = lyst_first(module->amsEndpoints); elt; elt = nextElt)
155
nextElt = lyst_next(elt);
159
lyst_destroy(module->amsEndpoints);
162
if (module->subjects)
164
for (elt = lyst_first(module->subjects); elt; elt = nextElt)
166
nextElt = lyst_next(elt);
170
lyst_destroy(module->subjects);
173
clearMamsEndpoint(&module->mamsEndpoint);
178
void eraseUnit(Venture *venture, Unit *unit)
187
if (venture == NULL || unit == NULL)
194
MRELEASE(unit->name);
197
/* Erase all local cell data. */
200
clearMamsEndpoint(&cell->mamsEndpoint);
201
for (i = 1; i <= MAX_MODULE_NBR; i++)
203
if (cell->modules[i])
205
eraseModule(cell->modules[i]);
209
/* Reattach erased unit's subunits directly to its
210
* superunit, if any. */
212
superunit = unit->superunit;
213
for (elt = lyst_first(unit->subunits); elt; elt = nextElt)
215
nextElt = lyst_next(elt);
216
subunit = (Unit *) lyst_data(elt);
217
lyst_delete(subunit->inclusionElt);
220
subunit->inclusionElt =
221
lyst_insert_last(superunit->subunits, subunit);
225
subunit->inclusionElt = NULL;
228
subunit->superunit = superunit;
231
lyst_destroy(unit->subunits);
233
/* Detach erased unit from its own superunit. */
235
if (unit->inclusionElt)
237
lyst_delete(unit->inclusionElt);
240
unit->superunit = NULL;
242
/* Erase the unit object itself. */
244
venture->units[unit->nbr] = NULL;
248
void eraseVenture(Venture *venture)
258
if (venture->authorityName)
260
MRELEASE(venture->authorityName);
263
for (i = 0; i <= MAX_UNIT_NBR; i++)
265
eraseUnit(venture, venture->units[i]);
268
for (i = 1; i <= MAX_ROLE_NBR; i++)
270
if (venture->roles[i])
272
eraseRole(venture, venture->roles[i]);
276
for (i = 0; i <= MAX_SUBJ_NBR; i++)
278
if (venture->subjects[i])
280
eraseSubject(venture, venture->subjects[i]);
284
for (i = 0; i < SUBJ_LIST_CT; i++)
286
if (venture->subjLysts[i])
288
lyst_destroy(venture->subjLysts[i]);
292
for (i = 1; i <= MAX_CONTIN_NBR; i++)
294
if (venture->msgspaces[i])
296
eraseMsgspace(venture, venture->msgspaces[i]);
300
(_mib(NULL))->ventures[venture->nbr] = NULL;
305
static void eraseMib(AmsMib *mib)
309
/* Note: no need to lockMib() because this function
310
* is called only from inside _mib(), which has
311
* already called lockMib(). */
313
if (mib->csPublicKeyName)
315
MRELEASE(mib->csPublicKeyName);
318
if (mib->csPrivateKeyName)
320
MRELEASE(mib->csPrivateKeyName);
323
if (mib->amsEndpointSpecs)
325
lyst_destroy(mib->amsEndpointSpecs);
328
if (mib->applications)
330
lyst_destroy(mib->applications);
333
if (mib->csEndpoints)
335
lyst_destroy(mib->csEndpoints);
338
for (i = 1; i <= MAX_CONTIN_NBR; i++)
340
if (mib->continua[i])
342
eraseContinuum(mib->continua[i]);
346
for (i = 1; i <= MAX_VENTURE_NBR; i++)
348
if (mib->ventures[i])
350
eraseVenture(mib->ventures[i]);
357
static void eraseAmsEpspec(AmsEpspec *amses)
362
static void destroyAmsEpspec(LystElt elt, void *userdata)
364
AmsEpspec *amses = (AmsEpspec *) lyst_data(elt);
366
eraseAmsEpspec(amses);
369
void eraseApp(AmsApp *app)
381
if (app->publicKeyName)
383
MRELEASE(app->publicKeyName);
386
if (app->privateKeyName)
388
MRELEASE(app->privateKeyName);
394
static void destroyApplication(LystElt elt, void *userdata)
396
AmsApp *app = (AmsApp *) lyst_data(elt);
401
static void eraseCsEndpoint(MamsEndpoint *ep)
403
clearMamsEndpoint(ep);
407
static void destroyCsEndpoint(LystElt elt, void *userdata)
409
MamsEndpoint *ep = (MamsEndpoint *) lyst_data(elt);
415
extern void udptsLoadTs(TransSvc *ts);
418
extern void dgrtsLoadTs(TransSvc *ts);
421
extern void vmqtsLoadTs(TransSvc *ts);
424
extern void tcptsLoadTs(TransSvc *ts);
427
static void addTs(AmsMib *mib, TsLoadFn loadTs)
432
/* Note: no need to lockMib() because this function
433
* is called only from inside initializeMib(), which
434
* is only called from inside _mib(), which has
435
* already called lockMib(). */
437
idx = mib->transportServiceCount;
438
ts = &(mib->transportServices[idx]);
439
loadTs(ts); /* Execute the transport service loader. */
440
mib->transportServiceCount++;
443
static int initializeMib(AmsMib *mib, int continuumNbr, char *ptsName,
444
char *pubkeyname, char *privkeyname)
446
int amsMemory = getIonMemoryMgr();
450
/* Note: transport service loaders in this table appear
451
* in descending order of preference. "Preference"
452
* corresponds broadly to nominal throughput rate. */
454
static TsLoadFn transportServiceLoaders[] =
470
static int transportServiceCount =
471
sizeof transportServiceLoaders /
474
/* Note: no need to lockMib() because this function
475
* is called only from inside _mib(), which has already
476
* called lockMib(). */
478
if (transportServiceCount > TS_INDEX_LIMIT)
480
putErrmsg("Transport service table overflow.", NULL);
484
for (i = 0; i < transportServiceCount; i++)
486
addTs(mib, transportServiceLoaders[i]);
487
if (strcmp(mib->transportServices[i].name, ptsName) == 0)
489
mib->pts = &(mib->transportServices[i]);
493
if (mib->pts == NULL)
495
putErrmsg("No loader for primary transport service.", ptsName);
499
mib->amsEndpointSpecs = lyst_create_using(amsMemory);
500
CHKERR(mib->amsEndpointSpecs);
501
lyst_delete_set(mib->amsEndpointSpecs, destroyAmsEpspec, NULL);
502
mib->applications = lyst_create_using(amsMemory);
503
CHKERR(mib->applications);
504
lyst_delete_set(mib->applications, destroyApplication, NULL);
505
mib->csEndpoints = lyst_create_using(amsMemory);
506
CHKERR(mib->csEndpoints);
507
lyst_delete_set(mib->csEndpoints, destroyCsEndpoint, NULL);
508
mib->localContinuumNbr = continuumNbr;
511
length = strlen(pubkeyname) + 1;
512
mib->csPublicKeyName = MTAKE(length);
513
CHKERR(mib->csPublicKeyName);
514
memcpy(mib->csPublicKeyName, pubkeyname, length);
519
length = strlen(privkeyname) + 1;
520
mib->csPrivateKeyName = MTAKE(length);
521
CHKERR(mib->csPrivateKeyName);
522
memcpy(mib->csPrivateKeyName, privkeyname, length);
525
if (createContinuum(continuumNbr, "local", 0, "this continuum") == NULL)
527
putErrmsg("Can't create local continuum object.", NULL);
534
static int initializeMemMgt(int continuumNbr)
538
if (ionAttach() == 0)
540
return 0; /* ION is already started. */
543
writeMemo("[i] ION not started yet. Starting ION from inside AMS.");
544
if (readIonParms(NULL, &ionParms) < 0)
546
putErrmsg("AMS can't load ION parameters.", NULL);
551
if (ionInitialize(&ionParms, continuumNbr) < 0)
553
putErrmsg("AMS can't start ION.", itoa(continuumNbr));
561
static void _mibLock(int lock)
563
static ResourceLock mibLock;
565
/* The MIB is shared among threads, so access to it must
568
if (initResourceLock(&mibLock) == 0)
573
killResourceLock(&mibLock);
577
unlockResource(&mibLock);
581
lockResource(&mibLock);
596
AmsMib *_mib(AmsMibParameters *parms)
598
static AmsMib *mib = NULL;
603
if (parms->continuumNbr == 0) /* Terminating. */
614
else /* Initializing. */
618
writeMemo("[i] AMS MIB already created.");
622
if (parms->continuumNbr < 1
623
|| parms->continuumNbr > MAX_CONTIN_NBR
624
|| parms->ptsName == NULL)
626
putErrmsg("Invalid MIB parms.", NULL);
631
if (initializeMemMgt(parms->continuumNbr) < 0)
633
putErrmsg("Can't attach to ION.", NULL);
638
mib = (AmsMib *) MTAKE(sizeof(AmsMib));
641
putErrmsg("Can't create MIB.",
648
memset((char *) mib, 0, sizeof(AmsMib));
649
if (initializeMib(mib, parms->continuumNbr,
651
parms->publicKeyName,
652
parms->privateKeyName) < 0)
654
putErrmsg("Can't initialize MIB.",
671
char *_rejectionMemos(int idx)
673
static char *memos[] = {
675
"duplicate registrar",
681
if (idx < 0 || idx > 4)
689
/* * * Checksum computation * * * */
691
unsigned short computeAmsChecksum(unsigned char *cursor, int pduLength)
693
unsigned int sum = 0;
694
unsigned short addend;
696
while (pduLength > 0)
699
addend <<= 8; /* Low-order byte is now zero pad. */
702
if (pduLength > 0) /* Replace pad with byte. */
709
sum += addend; /* Okay if it overflows. */
712
return sum & 0x0000ffff;
715
/* * * Conditions * * * * */
717
int time_to_stop(Llcv llcv)
722
int llcv_reply_received(Llcv llcv)
724
return (lyst_compare_get(llcv->list) == NULL ? 1 : 0);
727
/* * * MIB lookup functions * * * */
729
static LystElt findApplication(char *appName)
735
for (elt = lyst_first((_mib(NULL))->applications); elt;
736
elt = lyst_next(elt))
738
app = (AmsApp *) lyst_data(elt);
739
if (strcmp(app->name, appName) == 0)
750
AmsApp *lookUpApplication(char *appName)
754
elt = findApplication(appName);
757
return (AmsApp *) lyst_data(elt);
763
static int hashSubjectName(char *name)
765
/* Hash function adapted from Dr. Dobbs, April 1996. */
767
int length = strlen(name);
772
for (i = 0; i < length; i++, name++)
774
h = (h << 4) + *name;
784
return h % SUBJ_LIST_CT;
787
Subject *lookUpSubject(Venture *venture, char *subjectName)
793
idx = hashSubjectName(subjectName);
794
for (elt = lyst_first(venture->subjLysts[idx]); elt;
795
elt = lyst_next(elt))
797
subject = (Subject *) lyst_data(elt);
798
if (strcmp(subject->name, subjectName) == 0)
807
AppRole *lookUpRole(Venture *venture, char *roleName)
812
for (i = 1; i <= MAX_ROLE_NBR; i++)
814
role = venture->roles[i];
820
if (strcmp(role->name, roleName) == 0)
829
Venture *lookUpVenture(char *appName, char *authName)
834
if (appName == NULL || authName == NULL)
840
for (i = 1; i <= MAX_VENTURE_NBR; i++)
842
venture = (_mib(NULL))->ventures[i];
843
if (venture == NULL) /* Number not in use. */
848
if (strcmp(venture->app->name, appName) == 0
849
&& strcmp(venture->authorityName, authName) == 0)
860
Unit *lookUpUnit(Venture *venture, char *unitName)
865
for (i = 0; i <= MAX_UNIT_NBR; i++)
867
unit = venture->units[i];
868
if (unit == NULL) /* Number not in use. */
873
if (strcmp(unit->name, unitName) == 0)
882
int lookUpContinuum(char *contName)
885
Continuum *continuum;
888
for (i = 1; i <= MAX_CONTIN_NBR; i++)
890
continuum = (_mib(NULL))->continua[i];
891
if (continuum == NULL)
893
continue; /* Undefined continuum. */
896
if (strcmp(continuum->name, contName) == 0)
907
static int getKey(char *keyName, int *authKeyLen, char *authKey)
911
keyLen = sec_get_key(keyName, authKeyLen, authKey);
917
*authKeyLen = keyLen;
921
static int getAuthenticationParms(int ventureNbr, int unitNbr, int roleNbr,
922
Venture **venture, Unit **unit, int sending,
923
char **authName, char *authKey, int *authKeyLen)
925
AmsMib *mib = _mib(NULL);
926
AppRole *role = NULL;
935
if (ventureNbr > MAX_VENTURE_NBR
936
|| (*venture = mib->ventures[ventureNbr]) == NULL)
938
writeMemoNote("[?] MAMS msg from unknown msgspace",
944
if (unitNbr > MAX_UNIT_NBR
945
|| (*unit = (*venture)->units[unitNbr]) == NULL)
947
writeMemoNote("[?] MAMS msg from unknown cell",
956
if (roleNbr > MAX_ROLE_NBR || *venture == NULL
957
|| (role = (*venture)->roles[roleNbr]) == NULL)
959
writeMemoNote("[?] MAMS message dropped; unknown role",
966
if (role) /* Sender is module. */
968
*authName = role->name;
971
keyName = role->privateKeyName;
976
else if (getKey(keyName, authKeyLen, authKey) < 0)
978
writeMemoNote("[?] Can't get role private key",
979
role->privateKeyName);
984
keyName = role->publicKeyName;
989
else if (getKey(keyName, authKeyLen, authKey) < 0)
991
writeMemoNote("[?] Can't get role public key",
992
role->publicKeyName);
996
else if (*venture) /* Sender is registrar. */
998
*authName = (*venture)->app->name;
1001
keyName = (*venture)->app->privateKeyName;
1002
if (keyName == NULL)
1006
else if (getKey(keyName, authKeyLen, authKey) < 0)
1008
writeMemoNote("[?] Can't get app private key",
1009
(*venture)->app->privateKeyName);
1014
keyName = (*venture)->app->publicKeyName;
1015
if (keyName == NULL)
1019
else if (getKey(keyName, authKeyLen, authKey) < 0)
1021
writeMemoNote("[?] Can't get app public key",
1022
(*venture)->app->publicKeyName);
1026
else /* Sender is CS. */
1028
*authName = mib->continua[mib->localContinuumNbr]->name;
1031
keyName = mib->csPrivateKeyName;
1032
if (keyName == NULL)
1036
else if (getKey(keyName, authKeyLen, authKey) < 0)
1038
writeMemoNote("[?] Can't get CS private key",
1039
mib->csPrivateKeyName);
1044
keyName = mib->csPublicKeyName;
1045
if (keyName == NULL)
1049
else if (getKey(keyName, authKeyLen, authKey) < 0)
1051
writeMemoNote("[?] Can't get CS public key",
1052
mib->csPublicKeyName);
1061
/* * * MIB loading functions * * * */
1063
static RamsNetProtocol parseGwEid(char *gwEidString, char **gwEid,
1066
char *atSign = NULL;
1067
RamsNetProtocol protocol = RamsNoProtocol; /* default */
1068
unsigned short portNbr;
1069
unsigned int ipAddress;
1071
if (gwEidString == NULL || gwEid == NULL)
1076
*gwEid = NULL; /* default */
1077
atSign = strchr(gwEidString, '@');
1078
if (atSign == NULL) /* Malformed. */
1083
*gwEid = atSign + 1;
1084
if (**gwEid == '\0' /* Endpoint ID is a NULL string. */
1085
|| strlen(*gwEid) > MAX_GW_EID) /* Invalid. */
1091
if (strcmp(gwEidString, "bp") == 0)
1095
else if (strcmp(gwEidString, "udp") == 0)
1099
/* Must convert to canonical hostnbr:portnbr
1100
* form to enable recvfrom lookup to succeed. */
1102
parseSocketSpec(*gwEid, &portNbr, &ipAddress);
1103
isprintf(gwEidBuffer, MAX_GW_EID + 1, "%u:%hu", ipAddress,
1105
*gwEid = gwEidBuffer;
1108
*atSign = '@'; /* Restore original string. */
1112
static void destroyFanModule(LystElt elt, void *userdata)
1114
FanModule *fan = (FanModule *) lyst_data(elt);
1119
Subject *createSubject(Venture *venture, int nbr, char *name,
1120
char *description, char *symmetricKeyName,
1121
char *marshalFnName, char *unmarshalFnName)
1123
int amsMemory = getIonMemoryMgr();
1130
CHKNULL(nbr <= MAX_SUBJ_NBR);
1131
CHKNULL(venture->subjects[nbr] == NULL);
1133
length = strlen(name);
1134
CHKNULL(length <= MAX_SUBJ_NAME);
1135
subj = (Subject *) MTAKE(sizeof(Subject));
1137
memset((char *) subj, 0, sizeof(Subject));
1139
subj->isContinuum = 0;
1141
subj->name = MTAKE(length);
1142
CHKNULL(subj->name);
1143
istrcpy(subj->name, name, length);
1146
length = strlen(description) + 1;
1147
subj->description = MTAKE(length);
1148
CHKNULL(subj->description);
1149
istrcpy(subj->description, description, length);
1152
if (symmetricKeyName)
1154
length = strlen(symmetricKeyName) + 1;
1155
subj->symmetricKeyName = MTAKE(length);
1156
CHKNULL(subj->symmetricKeyName);
1157
memcpy(subj->symmetricKeyName, symmetricKeyName, length);
1162
length = strlen(marshalFnName) + 1;
1163
subj->marshalFnName = MTAKE(length);
1164
CHKNULL(subj->marshalFnName);
1165
memcpy(subj->marshalFnName, marshalFnName, length);
1168
if (unmarshalFnName)
1170
length = strlen(unmarshalFnName) + 1;
1171
subj->unmarshalFnName = MTAKE(length);
1172
CHKNULL(subj->unmarshalFnName);
1173
memcpy(subj->unmarshalFnName, unmarshalFnName, length);
1176
subj->authorizedSenders = NULL;
1177
subj->authorizedReceivers = NULL;
1178
subj->modules = lyst_create_using(amsMemory);
1179
CHKNULL(subj->modules);
1180
lyst_delete_set(subj->modules, destroyFanModule, NULL);
1181
venture->subjects[nbr] = subj;
1182
idx = hashSubjectName(name);
1183
subj->elt = lyst_insert_last(venture->subjLysts[idx], subj);
1188
AppRole *createRole(Venture *venture, int nbr, char *name, char *publicKeyName,
1189
char *privateKeyName)
1196
CHKNULL(nbr <= MAX_ROLE_NBR);
1197
CHKNULL(venture->roles[nbr] == NULL);
1199
length = strlen(name);
1200
CHKNULL(length <= MAX_ROLE_NAME);
1201
role = (AppRole *) MTAKE(sizeof(AppRole));
1203
memset((char *) role, 0, sizeof(AppRole));
1206
role->name = MTAKE(length);
1207
CHKNULL(role->name);
1208
istrcpy(role->name, name, length);
1211
length = strlen(publicKeyName) + 1;
1212
role->publicKeyName = MTAKE(length);
1213
CHKNULL(role->publicKeyName);
1214
memcpy(role->publicKeyName, publicKeyName, length);
1219
length = strlen(privateKeyName) + 1;
1220
role->privateKeyName = MTAKE(length);
1221
CHKNULL(role->privateKeyName);
1222
memcpy(role->privateKeyName, privateKeyName, length);
1225
venture->roles[nbr] = role;
1229
static void deleteAuthorization(char *roleName, Lyst *authorizations)
1236
for (elt = lyst_first(*authorizations); elt; elt = lyst_next(elt))
1238
name = (char *) lyst_data(elt);
1239
result = strcmp(name, roleName);
1240
if (result < 0) /* Try the next one. */
1250
return; /* Already deleted. */
1253
name = (char *) lyst_data(elt);
1256
if (lyst_length(*authorizations) == 0)
1258
lyst_destroy(*authorizations);
1259
*authorizations = NULL;
1263
void deleteAuthorizedSender(Subject *subj, char *senderRoleName)
1266
deleteAuthorization(senderRoleName, &subj->authorizedSenders);
1269
void deleteAuthorizedReceiver(Subject *subj, char *receiverRoleName)
1272
deleteAuthorization(receiverRoleName, &subj->authorizedReceivers);
1275
static void destroyAuthorization(LystElt elt, void *userdata)
1277
char *roleName = (char *) lyst_data(elt);
1282
static int addAuthorization(Venture *venture, char *roleName,
1283
Lyst *authorizations)
1292
if (lookUpRole(venture, roleName) == NULL)
1297
if (*authorizations == NULL)
1299
*authorizations = lyst_create_using(getIonMemoryMgr());
1300
CHKERR(*authorizations);
1301
lyst_delete_set(*authorizations, destroyAuthorization,
1305
for (elt = lyst_first(*authorizations); elt; elt = lyst_next(elt))
1307
name = (char *) lyst_data(elt);
1308
result = strcmp(name, roleName);
1309
if (result < 0) /* Try the next one. */
1316
return 0; /* Already in list. */
1319
break; /* Insert before this one. */
1322
length = strlen(roleName);
1323
name = MTAKE(length + 1);
1325
istrcpy(name, roleName, length + 1);
1328
elt = lyst_insert_before(elt, name);
1332
elt = lyst_insert_last(*authorizations, name);
1344
int addAuthorizedSender(Venture *venture, Subject *subj,
1345
char *senderRoleName)
1348
return addAuthorization(venture, senderRoleName,
1349
&(subj->authorizedSenders));
1352
int addAuthorizedReceiver(Venture *venture, Subject *subj,
1353
char *receiverRoleName)
1356
return addAuthorization(venture, receiverRoleName,
1357
&(subj->authorizedReceivers));
1360
LystElt createApp(char *name, char *publicKeyName, char *privateKeyName)
1367
length = strlen(name);
1368
CHKNULL(length <= MAX_APP_NAME);
1369
app = (AmsApp *) MTAKE(sizeof(AmsApp));
1371
memset((char *) app, 0, sizeof(AmsApp));
1373
app->name = MTAKE(length);
1375
istrcpy(app->name, name, length);
1378
length = strlen(publicKeyName) + 1;
1379
app->publicKeyName = MTAKE(length);
1380
CHKNULL(app->publicKeyName);
1381
memcpy(app->publicKeyName, publicKeyName, length);
1386
length = strlen(privateKeyName) + 1;
1387
app->privateKeyName = MTAKE(length);
1388
CHKNULL(app->privateKeyName);
1389
memcpy(app->privateKeyName, privateKeyName, length);
1393
elt = lyst_insert_last((_mib(NULL))->applications, app);
1399
Subject *createMsgspace(Venture *venture, int continNbr, char *gwEidString,
1400
char *symmetricKeyName)
1402
int amsMemory = getIonMemoryMgr();
1404
RamsNetProtocol ramsProtocol;
1406
char gwEidBuffer[MAX_GW_EID + 1];
1410
CHKNULL(continNbr > 0);
1411
CHKNULL(continNbr <= MAX_CONTIN_NBR);
1412
CHKNULL((_mib(NULL))->continua[continNbr] != NULL);
1413
CHKNULL(venture->msgspaces[continNbr] == NULL);
1414
msgspace = (Subject *) MTAKE(sizeof(Subject));
1416
memset((char *) msgspace, 0, sizeof(Subject));
1417
msgspace->nbr = 0 - continNbr; /* Negative subj number. */
1418
msgspace->isContinuum = 1;
1419
ramsProtocol = parseGwEid(gwEidString, &gwEid, gwEidBuffer);
1420
if (ramsProtocol == RamsNoProtocol)
1422
ramsProtocol = RamsBp;
1423
isprintf(gwEidBuffer, sizeof gwEidBuffer, "ipn:%d.%d",
1424
continNbr, venture->nbr);
1425
gwEid = gwEidBuffer;
1428
length = strlen(gwEid) + 1;
1429
msgspace->gwEid = MTAKE(length);
1430
CHKNULL(msgspace->gwEid);
1431
istrcpy(msgspace->gwEid, gwEid, length);
1432
if (symmetricKeyName)
1434
length = strlen(symmetricKeyName) + 1;
1435
msgspace->symmetricKeyName = MTAKE(length);
1436
CHKNULL(msgspace->symmetricKeyName);
1437
memcpy(msgspace->symmetricKeyName, symmetricKeyName, length);
1440
msgspace->authorizedSenders = NULL;
1441
msgspace->authorizedReceivers = NULL;
1442
msgspace->modules = lyst_create_using(amsMemory);
1443
CHKNULL(msgspace->modules);
1444
lyst_delete_set(msgspace->modules, destroyFanModule, NULL);
1445
venture->msgspaces[continNbr] = msgspace;
1449
static void destroySubjOfInterest(LystElt elt, void *userdata)
1451
SubjOfInterest *subj = (SubjOfInterest *) lyst_data(elt);
1453
lyst_destroy(subj->subscriptions);
1454
lyst_destroy(subj->invitations);
1455
lyst_delete(subj->fanElt);
1459
static Module *createModule(Cell *cell, int moduleNbr)
1461
int amsMemory = getIonMemoryMgr();
1464
module = (Module *) MTAKE(sizeof(Module));
1466
memset((char *) module, 0, sizeof(Module));
1467
module->unitNbr = cell->unit->nbr;
1468
module->nbr = moduleNbr;
1469
module->role = NULL;
1470
module->amsEndpoints = lyst_create_using(amsMemory);
1471
CHKNULL(module->amsEndpoints);
1472
lyst_delete_set(module->amsEndpoints, destroyAmsEndpoint, NULL);
1473
module->subjects = lyst_create_using(amsMemory);
1474
CHKNULL(module->subjects);
1475
lyst_delete_set(module->subjects, destroySubjOfInterest, NULL);
1476
cell->modules[moduleNbr] = module;
1480
static Unit *initializeUnit(Venture *venture, int nbr, char *name,
1481
int length, int resyncPeriod, Unit *superunit,
1492
unit = (Unit *) MTAKE(sizeof(Unit));
1494
memset((char *) unit, 0, sizeof(Unit));
1495
unit->cell = &(unit->cellData);
1499
nameLen = length + 1;
1500
unit->name = MTAKE(nameLen);
1501
CHKNULL(unit->name);
1502
istrcpy(unit->name, name, nameLen);
1504
/* Initialize cell data of unit. */
1506
for (i = 1; i <= MAX_MODULE_NBR; i++)
1508
if (createModule(cell, i) < 0)
1510
eraseUnit(venture, unit);
1515
cell->resyncPeriod = resyncPeriod;
1517
/* Insert new unit as subunit of its superunit. */
1519
unit->superunit = superunit;
1520
if (superunit != NULL)
1522
unit->inclusionElt = lyst_insert_last(superunit->subunits,
1524
CHKNULL(unit->inclusionElt);
1527
/* Assert new unit as superunit of its subunits. */
1529
for (elt = lyst_first(subunits); elt; elt = nextElt)
1531
nextElt = lyst_next(elt);
1532
subunit = (Unit *) lyst_data(elt);
1533
if (subunit->superunit != superunit)
1535
/* This is a subunit of some subunit of
1536
* the new unit, not of the new unit
1543
/* Detach this unit from its current superunit
1544
* (the new module's superunit) and insert it as
1545
* a subunit of the new unit. */
1547
lyst_delete(subunit->inclusionElt);
1548
subunit->inclusionElt = elt;
1549
subunit->superunit = unit;
1552
unit->subunits = subunits;
1553
venture->units[nbr] = unit;
1557
Unit *createUnit(Venture *venture, int nbr, char *name, int resyncPeriod)
1569
CHKNULL(nbr <= MAX_UNIT_NBR);
1570
CHKNULL(venture->units[nbr] == NULL);
1572
namelen = strlen(name);
1573
CHKNULL(namelen > 0);
1574
CHKNULL(namelen <= MAX_UNIT_NAME);
1575
CHKNULL(resyncPeriod >= 0);
1577
/* Unit whose name is the longest prefix of the new
1578
* unit's name is the new unit's superunit. Every
1579
* unit whose name is prefixed by the new unit's name
1580
* is a candidate subunit of the new unit. */
1582
subunits = lyst_create_using(getIonMemoryMgr());
1585
superunit = venture->units[0]; /* Default is root cell. */
1586
for (i = 0; i <= MAX_UNIT_NBR; i++)
1588
if ((unit = venture->units[i]) == NULL) continue;
1591
if (unit->name[j] == '\0')
1595
/* May be the superunit. */
1604
if (name[j] == '\0')
1606
/* May be a subunit. */
1608
if (lyst_insert_last(subunits, unit) == NULL)
1610
lyst_destroy(subunits);
1617
if (unit->name[j] != name[j])
1624
if (bestLength == namelen) /* Perfect match for name. */
1626
writeMemoNote("[?] Duplicate unit name", name);
1627
lyst_destroy(subunits);
1631
unit = initializeUnit(venture, nbr, name, namelen, resyncPeriod,
1632
superunit, subunits);
1635
lyst_destroy(subunits);
1641
static Venture *createVenture2(int nbr, char *appname, char *authname,
1642
char *gwEidString, int ramsNetIsTree,
1643
int rootCellResyncPeriod)
1645
AmsMib *mib = _mib(NULL);
1646
int amsMemory = getIonMemoryMgr();
1653
RamsNetProtocol ramsProtocol;
1655
char gwEidBuffer[MAX_GW_EID + 1];
1656
AppRole *gatewayRole;
1657
AppRole *shutdownRole;
1658
Subject *allSubjects;
1661
Subject *msgspace; /* In local continuum. */
1664
CHKNULL(nbr <= MAX_VENTURE_NBR);
1665
CHKNULL(mib->ventures[nbr] == NULL);
1668
length = strlen(authname);
1669
CHKNULL(length <= MAX_AUTH_NAME);
1670
CHKNULL(rootCellResyncPeriod >= 0);
1671
for (elt = lyst_first(mib->applications); elt; elt = lyst_next(elt))
1673
app = (AmsApp *) lyst_data(elt);
1674
if (strcmp(app->name, appname) == 0)
1682
writeMemoNote("[?] Adding venture for unknown application",
1687
venture = (Venture *) MTAKE(sizeof(Venture));
1689
memset((char *) venture, 0, sizeof(Venture));
1692
authnameLen = length + 1;
1693
venture->authorityName = MTAKE(authnameLen);
1694
CHKNULL(venture->authorityName);
1695
istrcpy(venture->authorityName, authname, authnameLen);
1696
for (i = 0; i < SUBJ_LIST_CT; i++)
1698
venture->subjLysts[i] = lyst_create_using(amsMemory);
1699
CHKNULL(venture->subjLysts[i]);
1702
ramsProtocol = parseGwEid(gwEidString, &gwEid, gwEidBuffer);
1703
if (ramsProtocol == RamsNoProtocol)
1705
ramsProtocol = RamsBp;
1708
venture->gwProtocol = ramsProtocol;
1709
venture->ramsNetIsTree = ramsNetIsTree;
1710
mib->ventures[nbr] = venture;
1712
/* Automatically create venture's RAMS gateway role. */
1714
gatewayRole = createRole(venture, 1, "RAMS", NULL, NULL);
1715
shutdownRole = createRole(venture, MAX_ROLE_NBR, "stop", NULL, NULL);
1716
if (gatewayRole == NULL || shutdownRole == NULL)
1718
eraseVenture(venture);
1719
putErrmsg("Can't create standard roles for venture.",
1724
/* Automatically create venture's "all subjects" subject. */
1726
allSubjects = createSubject(venture, 0, "everything",
1727
"messages on all subjects", NULL, NULL, NULL);
1728
if (allSubjects == NULL)
1730
eraseVenture(venture);
1731
putErrmsg("Can't create 'everything' subject for venture.",
1736
/* Automatically create venture's root unit. */
1738
subunits = lyst_create_using(amsMemory);
1740
rootUnit = initializeUnit(venture, 0, "", 0, rootCellResyncPeriod,
1742
if (rootUnit == NULL)
1744
putErrmsg("Can't initialize root unit for venture.", appname);
1745
lyst_destroy(subunits);
1746
eraseVenture(venture);
1750
/* Automatically create the local message space. */
1752
msgspace = createMsgspace(venture, mib->localContinuumNbr, gwEidString,
1754
if (msgspace == NULL)
1756
putErrmsg("Can't create local msgspace for venture.", appname);
1757
eraseVenture(venture);
1764
Venture *createVenture(int nbr, char *appname, char *authname,
1765
char *gwEidString, int ramsNetIsTree, int rootCellResyncPeriod)
1770
result = createVenture2(nbr, appname, authname, gwEidString,
1771
ramsNetIsTree, rootCellResyncPeriod);
1776
static Continuum *createContinuum2(int nbr, char *name, int isNeighbor,
1779
AmsMib *mib = _mib(NULL);
1786
CHKNULL(nbr <= MAX_CONTIN_NBR);
1787
CHKNULL(mib->continua[nbr] == NULL);
1789
length = strlen(name);
1790
CHKNULL(length <= MAX_SUBJ_NAME);
1791
contin = (Continuum *) MTAKE(sizeof(Continuum));
1793
memset((char *) contin, 0, sizeof(Continuum));
1795
contin->isNeighbor = 1 - (isNeighbor == 0);
1796
nameLen = length + 1;
1797
contin->name = MTAKE(nameLen);
1798
CHKNULL(contin->name);
1799
istrcpy(contin->name, name, nameLen);
1802
descLen = strlen(description) + 1;
1803
contin->description = MTAKE(descLen);
1804
CHKNULL(contin->description);
1805
istrcpy(contin->description, description, descLen);
1808
mib->continua[nbr] = contin;
1812
Continuum *createContinuum(int nbr, char *name, int isNeighbor,
1818
result = createContinuum2(nbr, name, isNeighbor, description);
1823
LystElt createCsEndpoint(char *endpointSpec, LystElt nextElt)
1825
AmsMib *mib = _mib(NULL);
1827
char endpointName[MAX_EP_NAME + 1];
1831
/* Note: no need to lockMib() because this function
1832
* is called only from inside loadMib, which has
1833
* already called lockMib(). */
1835
CHKNULL(endpointSpec);
1836
if (mib->pts->csepNameFn(endpointSpec, endpointName) < 0)
1838
putErrmsg("Can't compute CS endpoint name.", endpointSpec);
1842
len = strlen(endpointName);
1843
ep = (MamsEndpoint *) MTAKE(sizeof(MamsEndpoint));
1845
memset((char *) ep, 0, sizeof(MamsEndpoint));
1846
if (constructMamsEndpoint(ep, len, endpointName) < 0)
1848
putErrmsg("Can't construct MAMS endpoint for CS.", NULL);
1849
eraseCsEndpoint(ep);
1855
elt = lyst_insert_before(nextElt, ep);
1859
elt = lyst_insert_last(mib->csEndpoints, ep);
1866
LystElt createAmsEpspec(char *tsname, char *epspec)
1868
AmsMib *mib = _mib(NULL);
1872
AmsEpspec *amsesPtr;
1875
/* Note: no need to lockMib() because this function
1876
* is called only from inside loadMib, which has
1877
* already called lockMib(). */
1881
if (strlen(epspec) > MAX_EP_SPEC)
1883
writeMemoNote("[?] AMS endpoint spec is too long", epspec);
1887
istrcpy(amses.epspec, epspec, sizeof amses.epspec);
1889
for (i = 0, ts = mib->transportServices; i < mib->transportServiceCount;
1892
if (strcmp(tsname, ts->name) == 0)
1899
if (amses.ts == NULL)
1901
writeMemoNote("[?] Unknown transport service for AMS endpoint \
1906
amsesPtr = (AmsEpspec *) MTAKE(sizeof(AmsEpspec));
1908
memcpy((char *) amsesPtr, &amses, sizeof(AmsEpspec));
1909
elt = lyst_insert_last(mib->amsEndpointSpecs, amsesPtr);
1914
/* * * MIB management functions * * */
1916
int computeModuleId(int roleNbr, int unitNbr, int moduleNbr)
1918
unsigned int moduleId;
1920
moduleId = (roleNbr << 24) + (unitNbr << 8) + moduleNbr;
1921
return (int) moduleId;
1924
int parseModuleId(int memo, int *roleNbr, int *unitNbr, int *moduleNbr)
1926
unsigned int moduleId = (unsigned int) memo;
1931
*roleNbr = (moduleId >> 24) & 0x000000ff;
1932
if (*roleNbr < 1 || *roleNbr > MAX_ROLE_NBR)
1934
writeMemoNote("[?] Role nbr invalid", itoa(*roleNbr));
1938
*unitNbr = (moduleId >> 8) & 0x0000ffff;
1939
if (*unitNbr > MAX_UNIT_NBR)
1941
writeMemoNote("[?] Unit nbr invalid", itoa(*unitNbr));
1945
*moduleNbr = moduleId & 0x000000ff;
1946
if (*moduleNbr < 1 || *moduleNbr > MAX_MODULE_NBR)
1948
writeMemoNote("[?] Module nbr invalid", itoa(*moduleNbr));
1955
char *parseString(char **cursor, int *bytesRemaining, int *len)
1957
char *string = *cursor;
1960
while (*bytesRemaining > 0)
1962
if (**cursor == '\0') /* End of string. */
1964
(*cursor)++; /* Skip over the NULL. */
1965
(*bytesRemaining)--;
1969
/* This is one of the characters of the string. */
1972
(*bytesRemaining)--;
1976
return NULL; /* Not a NULL-terminated string. */
1979
int constructMamsEndpoint(MamsEndpoint *endpoint, int eptLength, char *ept)
1983
endpoint->ept = MTAKE(eptLength + 1);
1984
CHKERR(endpoint->ept);
1985
memcpy(endpoint->ept, ept, eptLength);
1986
endpoint->ept[eptLength] = '\0';
1988
/* The primary transport service's endpoint parsing
1989
* function examines the endpoint name text and fills
1990
* in the tsep of the endpoint. */
1993
result = ((_mib(NULL))->pts->parseMamsEndpointFn)(endpoint);
1997
writeMemoNote("[?] Can't parse endpoint name", ept);
2004
void clearMamsEndpoint(MamsEndpoint *ep)
2007
(_mib(NULL))->pts->clearMamsEndpointFn(ep);
2017
int rememberModule(Module *module, AppRole *role, int eptLength, char *ept)
2019
if (constructMamsEndpoint(&(module->mamsEndpoint), eptLength, ept))
2021
putErrmsg("Can't store module's MAMS endpoint.", NULL);
2025
module->role = role;
2029
void forgetModule(Module *module)
2034
for (elt = lyst_first(module->amsEndpoints); elt; elt = nextElt)
2036
nextElt = lyst_next(elt);
2040
for (elt = lyst_first(module->subjects); elt; elt = nextElt)
2042
nextElt = lyst_next(elt);
2046
clearMamsEndpoint(&module->mamsEndpoint);
2047
module->role = NULL;
2050
/* * * MAMS message transmission * * * */
2052
int sendMamsMsg(MamsEndpoint *endpoint, MamsInterface *tsif,
2053
MamsPduType type, unsigned int memo,
2054
unsigned short supplementLength, char *supplement)
2060
int authKeyLen = sizeof authKey;
2063
unsigned char authenticator[AUTHENTICAT_LEN];
2065
int authenticatorLength = 0;
2068
unsigned char timeTag[5];
2072
unsigned short checksum;
2077
if (getAuthenticationParms(tsif->ventureNbr, tsif->unitNbr,
2078
tsif->roleNbr, &venture, &unit, 1, &authName, authKey,
2081
putErrmsg("Can't get authentication parameters.", NULL);
2085
if (authName == NULL) /* Invalid parameters. */
2087
return 0; /* Don't send message. */
2092
authNameLen = strlen(authName);
2093
if (authNameLen == 0 || authNameLen > (AUTHENTICAT_LEN - 9))
2095
putErrmsg("Bad authentication name.", authName);
2099
encryptLength = authNameLen + 4;
2101
memcpy(authenticator, (char *) &nonce, 4);/* Clear. */
2102
memcpy(authenticator + 4, (char *) &nonce, 4);
2103
istrcpy((char *) (authenticator + 8), authName,
2104
sizeof authenticator - 8);
2105
encryptUsingPrivateKey((char *) (authenticator + 4),
2106
&encryptLength, authKey, authKeyLen,
2107
(char *) (authenticator + 4), encryptLength);
2108
authenticatorLength = encryptLength + 4;
2111
/* Time tag is CCSDS Unsegmented Time (CUC) with preamble.
2112
* The preamble (P-field) is always a single octet whose
2113
* bits have the following significance:
2115
* 001 time code ID (Epoch 1958 TAI)
2116
* 11 indicates 4 octets of coarse time (sec)
2117
* 00 indicates 0 octets of fine time
2118
* Note that the CCSDS spec actually requires TAI time for
2119
* time code 001, but the operating system only gives us
2120
* UTC, so the time tags inserted here will be in error by
2121
* some number of leap seconds. For the purposes of AMS
2122
* this error is not significant. */
2124
unixTime = time(NULL); /* Epoch 1970. */
2125
u4 = unixTime + EPOCH_OFFSET_1958; /* Now epoch 1958. */
2127
timeTag[0] = 28; /* Preamble. */
2128
memcpy(timeTag + 1, (char *) &u4, 4); /* Coarse time. */
2130
/* 12 bytes of message length are fixed by specification.
2131
* 5 bytes are time tag, which in the JPL implementation
2132
* is always of length 5. 2 bytes are checksum, which
2133
* in the JPL implementation is always present. */
2135
msgLength = 12 + 5 + authenticatorLength + supplementLength + 2;
2136
msg = MTAKE(msgLength);
2139
/* Construct the message. First octet is two bits of
2140
* version number (which is always 00 for now) followed
2141
* by checksum flag (always 1 in this implementation of
2142
* MAMS) followed by 5 bits of MPDU type. */
2145
*msg = 0x20 + (u4 & 0x0000001f);
2146
*(msg + 1) = tsif->ventureNbr;
2149
memcpy(msg + 2, (char *) &u2, 2);
2150
*(msg + 4) = tsif->roleNbr;
2151
*(msg + 5) = authenticatorLength;
2152
u2 = supplementLength;
2154
memcpy(msg + 6, (char *) &u2, 2);
2156
memcpy(msg + 8, (char *) &u4, 4);
2157
memcpy(msg + 12, timeTag, 5);
2159
/* Optionally append digital signature to header. */
2161
if (authenticatorLength > 0)
2163
memcpy(msg + 17, authenticator, authenticatorLength);
2166
/* Append supplementary data to message. */
2168
if (supplementLength > 0)
2170
memcpy(msg + 17 + authenticatorLength, supplement,
2174
/* For this implementation, always append checksum to
2177
checksum = computeAmsChecksum(msg, msgLength - 2);
2178
checksum = htons(checksum);
2179
memcpy(msg + (msgLength -2), (char *) &checksum, 2);
2181
/* Send the message. */
2184
result = (_mib(NULL))->pts->sendMamsFn(endpoint, tsif, (char *) msg,
2191
/* * * Event queueing functions * * */
2193
int enqueueMamsEvent(Llcv eventsQueue, AmsEvt *evt, char *ancillaryBlock,
2199
llcv_lock(eventsQueue);
2201
/* Events that shut down event loops are inserted at
2202
* the start of the events queue, for immediate handling. */
2204
if (evt->type == CRASH_EVT)
2206
elt = lyst_insert_first(eventsQueue->list, evt);
2207
llcv_unlock(eventsQueue);
2210
putErrmsg("Can't insert event.", NULL);
2214
llcv_signal(eventsQueue, time_to_stop);
2218
/* A hack, which works in the absence of a Lyst user
2219
* data variable. In order to make the current query
2220
* ID number accessible to an llcv condition function,
2221
* we stuff it into the "compare" function pointer in
2222
* the Lyst structure. */
2224
queryNbr = (long) lyst_compare_get(eventsQueue->list);
2225
if (queryNbr != 0) /* Need response to specfic msg. */
2227
if (responseNbr == queryNbr) /* This is it. */
2229
elt = lyst_insert_first(eventsQueue->list, evt);
2230
if (elt) /* Must erase query nbr. */
2232
lyst_compare_set(eventsQueue->list, NULL);
2233
llcv_signal_while_locked(eventsQueue,
2234
llcv_reply_received);
2237
else /* This isn't it; deal with it later. */
2239
elt = lyst_insert_last(eventsQueue->list, evt);
2242
else /* Any event is worth waking up the thread for. */
2244
elt = lyst_insert_last(eventsQueue->list, evt);
2247
llcv_signal_while_locked(eventsQueue,
2248
llcv_lyst_not_empty);
2252
llcv_unlock(eventsQueue);
2255
putErrmsg("Can't insert event.", NULL);
2262
int enqueueMamsMsg(Llcv eventsQueue, int length, unsigned char *msgBuffer)
2264
unsigned int preamble; /* Describes time tag. */
2266
int coarseTimeLength;
2270
unsigned char *cursor;
2272
unsigned short checksum;
2274
int authenticatorLength;
2275
unsigned char *authenticator = NULL;
2276
unsigned char *supplement;
2281
int authKeyLen = sizeof authKey;
2283
unsigned char nonce[4];
2287
CHKERR(eventsQueue);
2288
CHKERR(length >= 0);
2292
writeMemoNote("[?] MAMS msg header incomplete", itoa(length));
2296
/* First get time tag, since its size affects the
2297
* location of the authenticator and supplement. */
2299
preamble = *(msgBuffer + 12); /* "P-field." */
2300
timeCode = (preamble >> 4) & 0x07;
2303
writeMemoNote("[?] Unknown time code in MAMS msg header",
2308
coarseTimeLength = ((preamble >> 2) & 0x03) + 1;
2309
fineTimeLength = preamble & 0x03;
2310
expectedLength = 12 + 1 + coarseTimeLength + fineTimeLength;
2311
if (length < expectedLength)
2313
writeMemo("[?] MAMS message truncated.");
2318
cursor = msgBuffer + 13; /* After preamble. */
2319
while (coarseTimeLength > 0)
2327
u4 = ntohl(u4); /* Epoch 1958. */
2328
msg.timeTag = u4 - EPOCH_OFFSET_1958; /* Now epoch 1970. */
2329
while (fineTimeLength > 0)
2331
cursor++; /* Ignore fine time. */
2335
/* Now look for checksum. */
2337
if (*msgBuffer & 0x20) /* Checksum present. */
2339
expectedLength += 2;
2340
if (length < expectedLength)
2342
writeMemo("[?] MAMS message truncated.");
2346
memcpy((char *) &checksum, msgBuffer + (length - 2), 2);
2347
checksum = ntohs(checksum);
2348
if (checksum != computeAmsChecksum(msgBuffer, length - 2))
2350
writeMemo("[?] Checksum failed, MAMS msg discarded.");
2355
/* Now extract the rest of the MAMS message. */
2357
msg.type = *msgBuffer & 0x1f;
2358
msg.ventureNbr = *(msgBuffer + 1);
2359
memcpy((char *) &u2, msgBuffer + 2, 2);
2362
msg.roleNbr = *(msgBuffer + 4);
2363
authenticatorLength = *(msgBuffer + 5);
2364
expectedLength += authenticatorLength;
2365
if (authenticatorLength > 0)
2367
authenticator = cursor; /* Starts after time tag. */
2368
cursor += authenticatorLength;
2371
memcpy((char *) &u2, msgBuffer + 6, 2);
2373
msg.supplementLength = u2;
2374
expectedLength += msg.supplementLength;
2375
supplement = cursor; /* After time tag, authenticator. */
2376
if (length != expectedLength)
2378
length -= expectedLength;
2379
writeMemoNote("[?] MAMS message length error", itoa(length));
2383
if (getAuthenticationParms(msg.ventureNbr, msg.unitNbr, msg.roleNbr,
2384
&venture, &unit, 0, &authName, authKey, &authKeyLen))
2386
putErrmsg("Can't get authentication parameters.", NULL);
2390
if (authName == NULL) /* Invalid parameters. */
2392
return 0; /* Don't deliver message. */
2397
/* Authentication is required. */
2399
authNameLen = strlen(authName);
2400
CHKERR(authNameLen > 0);
2401
CHKERR(authNameLen <= (AUTHENTICAT_LEN - 9));
2402
if (authenticatorLength != authNameLen + 8)
2404
writeMemo("[?] MAMS msg discarded; bad authenticator.");
2408
memcpy(nonce, authenticator, 4);
2409
decryptUsingPublicKey((char *) (authenticator + 4),
2410
&decryptLength, authKey, authKeyLen,
2411
(char *) (authenticator + 4),
2412
authenticatorLength - 4);
2413
if (memcmp(nonce, authenticator + 4, 4) != 0
2414
|| memcmp(authName, authenticator + 8, authNameLen) != 0)
2416
writeMemo("[?] MAMS msg discarded; auth. failed.");
2421
/* Construct message event, enqueue, and signal arrival. */
2423
memcpy((char *) &u4, msgBuffer + 8, 4);
2426
if (msg.supplementLength > 0)
2428
msg.supplement = MTAKE(msg.supplementLength);
2429
CHKERR(msg.supplement);
2430
memcpy(msg.supplement, supplement, msg.supplementLength);
2434
msg.supplement = NULL;
2437
evt = MTAKE(1 + sizeof(MamsMsg));
2439
evt->type = MAMS_MSG_EVT;
2440
memcpy(evt->value, (char *) &msg, sizeof(MamsMsg));
2441
if (enqueueMamsEvent(eventsQueue, evt, msg.supplement, msg.memo))
2443
putErrmsg("Can't enqueue MAMS message.", NULL);
2447
MRELEASE(msg.supplement);
2456
int enqueueMamsCrash(Llcv eventsQueue, char *text)
2469
textLength = strlen(text);
2472
evt = (AmsEvt *) MTAKE(1 + textLength + 1);
2474
evt->type = CRASH_EVT;
2475
memcpy(evt->value, text, textLength);
2476
evt->value[textLength] = '\0';
2477
if (enqueueMamsEvent(eventsQueue, evt, NULL, 0))
2479
putErrmsg("Can't enqueue MAMS crash.", NULL);
2487
int enqueueMamsStubEvent(Llcv eventsQueue, int eventType)
2491
evt = (AmsEvt *) MTAKE(sizeof(AmsEvt));
2493
evt->type = eventType;
2494
if (enqueueMamsEvent(eventsQueue, evt, NULL, 0))
2496
putErrmsg("Can't enqueue stub event.", NULL);
2504
void recycleEvent(AmsEvt *evt)
2508
if (evt == NULL) return;
2509
if (evt->type == MAMS_MSG_EVT)
2511
msg = (MamsMsg *) (evt->value);
2512
if (msg->supplement)
2514
MRELEASE(msg->supplement);
2521
void destroyEvent(LystElt elt, void *userdata)
2523
AmsEvt *evt = (AmsEvt *) lyst_data(elt);
added
removed
ams/library/amscommon.c
