DIRECTORY
Atom USING [GetPName, MakeAtom],
LoganBerry,
LoganBerrySunRPC,
LoganBerrySunRPCServer,
Rope USING [Equal];

LoganBerrySunRPCToLoganBerry: CEDAR PROGRAM
IMPORTS Atom, LoganBerry, Rope 
EXPORTS LoganBerrySunRPCServer
~ BEGIN
OPEN LoganBerrySunRPC, LoganBerrySunRPCServer;

Error: PUBLIC ERROR [ec: ErrorCode, explanation: ROPE м NIL] = CODE;

Null: PUBLIC NullType ~ {
NULL;
};

Open: PUBLIC OpenType ~ {
ENABLE LoganBerry.Error => ERROR Error[Atom.GetPName[ec], explanation];
db м LoganBerry.Open[NIL, dbName];
};

ReadEntry: PUBLIC ReadEntryType ~ {
ENABLE LoganBerry.Error => ERROR Error[Atom.GetPName[ec], explanation];
lbentry: LoganBerry.Entry;
[lbentry, others] м LoganBerry.ReadEntry[NIL, db, Atom.MakeAtom[key], value];
entry м EntryToSr[lbentry];
};

GenerateEntries: PUBLIC GenerateEntriesType ~ {
ENABLE LoganBerry.Error => ERROR Error[Atom.GetPName[ec], explanation];
cursor м LoganBerry.GenerateEntries[NIL, db, Atom.MakeAtom[key], IF Rope.Equal[start, ""] THEN NIL ELSE start, IF Rope.Equal[end, ""] THEN NIL ELSE end];
};

NextEntry: PUBLIC NextEntryType ~ {
ENABLE LoganBerry.Error => ERROR Error[Atom.GetPName[ec], explanation];
lbentry: LoganBerry.Entry;
lbentry м LoganBerry.NextEntry[NIL, cursor, IF dir=increasing THEN increasing ELSE decreasing];
entry м EntryToSr[lbentry];
};

EndGenerate: PUBLIC EndGenerateType ~ {
ENABLE LoganBerry.Error => ERROR Error[Atom.GetPName[ec], explanation];
LoganBerry.EndGenerate[NIL, cursor];
};

WriteEntry: PUBLIC WriteEntryType ~ {
ENABLE LoganBerry.Error => ERROR Error[Atom.GetPName[ec], explanation];
LoganBerry.WriteEntry[NIL, db, SrToEntry[entry], log, replace];
};

DeleteEntry: PUBLIC DeleteEntryType ~ {
ENABLE LoganBerry.Error => ERROR Error[Atom.GetPName[ec], explanation];
LoganBerry.DeleteEntry[NIL, db, Atom.MakeAtom[key], value];
};

Close: PUBLIC CloseType ~ {
ENABLE LoganBerry.Error => ERROR Error[Atom.GetPName[ec], explanation];
LoganBerry.Close[NIL, db];
};

BuildIndices: PUBLIC BuildIndicesType ~ {
ENABLE LoganBerry.Error => ERROR Error[Atom.GetPName[ec], explanation];
LoganBerry.BuildIndices[NIL, db];
};

CompactLogs: PUBLIC CompactLogsType ~ {
ENABLE LoganBerry.Error => ERROR Error[Atom.GetPName[ec], explanation];
LoganBerry.CompactLogs[NIL, db];
};

Describe: PUBLIC DescribeType ~ {
ENABLE LoganBerry.Error => ERROR Error[Atom.GetPName[ec], explanation];
lbinfo: LoganBerry.SchemaInfo;
lbinfo м LoganBerry.Describe[NIL, db];
info м SchemaInfoToSr[lbinfo];
};
SrToEntry: PROC [srEntry: LoganBerrySunRPC.Entry] RETURNS [entry: LoganBerry.Entry] ~ {
entry м NIL;
FOR i: CARDINAL DECREASING IN [0..srEntry.length) DO
attr: LoganBerry.Attribute м [Atom.MakeAtom[srEntry[i].type], srEntry[i].value];
entry м CONS[attr, entry];
ENDLOOP;
};

EntryToSr: PROC [entry: LoganBerry.Entry] RETURNS [crEntry: LoganBerrySunRPC.Entry] ~ {
count: CARDINAL м 0;
FOR e: LoganBerry.Entry м entry, e.rest WHILE e # NIL DO
count м count + 1;
ENDLOOP;
crEntry м NEW[LoganBerrySunRPC.EntryObject[count]];
count м 0;
FOR e: LoganBerry.Entry м entry, e.rest WHILE e # NIL DO
crEntry[count].type м Atom.GetPName[e.first.type];
crEntry[count].value м e.first.value;
count м count + 1;
ENDLOOP;
};

SrToSchemaInfo: PROC [crInfo: LoganBerrySunRPC.SchemaInfo] RETURNS [info: LoganBerry.SchemaInfo] ~ {
SrToLogList: PROC [crLogs: LoganBerrySunRPC.LogList] RETURNS [logs: LIST OF LoganBerry.LogInfo] ~ {
logs м NIL;
FOR i: CARDINAL DECREASING IN [0..crLogs.length) DO
loginfo: LoganBerry.LogInfo м NEW[LoganBerry.LogInfoRec м [crLogs[i].id, crLogs[i].file]];
logs м CONS[loginfo, logs];
ENDLOOP;
};
SrToIndexList: PROC [crIndices: LoganBerrySunRPC.IndexList] RETURNS [indices: LIST OF LoganBerry.IndexInfo] ~ {
indices м NIL;
FOR i: CARDINAL DECREASING IN [0..crIndices.length) DO
indexinfo: LoganBerry.IndexInfo м NEW[LoganBerry.IndexInfoRec м [Atom.MakeAtom[crIndices[i].key], crIndices[i].file, Atom.MakeAtom[crIndices[i].order]]];
indices м CONS[indexinfo, indices];
ENDLOOP;
};
info м NEW[LoganBerry.SchemaInfoRec м [crInfo.dbName, SrToLogList[crInfo.logs], SrToIndexList[crInfo.indices]]];
};

SchemaInfoToSr: PROC [info: LoganBerry.SchemaInfo] RETURNS [crInfo: LoganBerrySunRPC.SchemaInfo] ~ {
LogListToSr: PROC [logs: LIST OF LoganBerry.LogInfo] RETURNS [crLogs: LoganBerrySunRPC.LogList] ~ {
count: CARDINAL м 0;
FOR i: LIST OF LoganBerry.LogInfo м logs, i.rest WHILE i # NIL DO
count м count + 1;
ENDLOOP;
crLogs м NEW[LoganBerrySunRPC.LogListObject[count]];
count м 0;
FOR i: LIST OF LoganBerry.LogInfo м logs, i.rest WHILE i # NIL DO
crLogs[count].id м i.first.id;
crLogs[count].file м i.first.file;
count м count + 1;
ENDLOOP;
};
IndexListToSr: PROC [indices: LIST OF LoganBerry.IndexInfo] RETURNS [crIndices: LoganBerrySunRPC.IndexList] ~ {
count: CARDINAL м 0;
FOR i: LIST OF LoganBerry.IndexInfo м indices, i.rest WHILE i # NIL DO
count м count + 1;
ENDLOOP;
crIndices м NEW[LoganBerrySunRPC.IndexListObject[count]];
count м 0;
FOR i: LIST OF LoganBerry.IndexInfo м indices, i.rest WHILE i # NIL DO
crIndices[count].key м Atom.GetPName[i.first.key];
crIndices[count].file м i.first.file;
crIndices[count].order м Atom.GetPName[i.first.order];
count м count + 1;
ENDLOOP;
};
crInfo.dbName м info.dbName;
crInfo.logs м LogListToSr[info.logs];
crInfo.indices м IndexListToSr[info.indices];
};


END.

  `  
LoganBerrySunRPCToLoganBerry.mesa
Copyright ╙ 1987, 1992 by Xerox Corporation.  All rights reserved.
Doug Terry, August 22, 1989 6:08:14 pm PDT
Adapted from LoganBerryCrServerImpl.mesa

Exports LoganBerrySunRPCServer, which is called by LoganBerrySunRPCServerStub, and calls the real LoganBerry routines.

LoganBerry operations
Data conversion
 Э╩b  ХNewlineDelimiter
Ц(cedarcode) styleЩ codeЪЬ!Щ!KЪЬ
╧eЬ7ЩBKЪЬ*Щ*KЪЬ(Щ(KЩ KЪЬvЩvKЩ ЧЪ╧k	Ш	KЪЬЮЬШ KШKЪЬШKЪЬШKЪЬЮЬ	ШЧKШ KЪ╧nЬЮЬЮШ+KЪЮЬШKЪЮЬШЪЬЮШKЪЮЬ*Ш.KШ ЧheadЩIcode0ЪЯЬЮЬЮЬЮЬЮЬЮЬШDMШ ЪЯЬЮЬШKЪЮЬШKЪЬШKШ ЧЪЯЬЮЬШKЪЮЬЮЬ'ШGKЪЬЮЬ
Ш"KЪЬШЧKШ ЪЯ	ЬЮЬШ#KЪЮЬЮЬ'ШGKЪЬШKЪЬ)ЮЬ!ШMKШKШЧKШ ЪЯЬЮЬШ/KЪЮЬЮЬ'ШGKЪЬ$ЮЬЮЬЮЬЮЬЮЬЮЬЮЬЮЬЮЬШЩKЪЬШЧKШ ЪЯ	ЬЮЬШ#KЪЮЬЮЬ'ШGKЪЬШKЪ	ЬЮЬ
ЮЬЮЬЮЬШ_KШKШЧKШ ЪЯЬЮЬШ'KЪЮЬЮЬ'ШGKЪЬЮЬ
Ш$KШЧKШ ЪЯ
ЬЮЬШ%KЪЮЬЮЬ'ШGKЪЬЮЬ&Ш?KШЧKШ ЪЯЬЮЬШ'KЪЮЬЮЬ'ШGKЪЬЮЬ!Ш;KШЧKШ ЪЯЬЮЬШKЪЮЬЮЬ'ШGKЪЬЮЬШKШЧKШ ЪЯЬЮЬШ)KЪЮЬЮЬ'ШGKЪЬЮЬШ!KЪЬШЧKШ ЪЯЬЮЬШ'KЪЮЬЮЬ'ШGKЪЬЮЬШ KШЧKШ ЪЯЬЮЬШ!KЪЮЬЮЬ'ШGKЪЬШKЪЬЮЬШ&KШKШЧЧЩЪЯ	ЬЮЬ#ЮЬШWKЪЬЮЬШЪ	ЮЬЮЬЮ
ЬЮЬЮШ4KШPKЪЬЮЬШKЪЮЬШЧKШKШ ЧЪЯ	ЬЮЬЮЬ&ШWKЪЬЮЬШЪЮЬ%ЮЬЮЬЮШ8KШKЪЮЬШЧKЪЬ
ЮЬ&Ш3KШ
ЪЮЬ%ЮЬЮЬЮШ8KШ2KШ%KШKЪЮЬШЧKШKШ ЧЪЯЬЮЬ'ЮЬ"ШdЪ
ЯЬЮЬ$ЮЬЮЬЮЬШcKЪЬЮЬШЪ	ЮЬЮЬЮ
ЬЮЬЮШ3KЪЬЮЬ9ШZKЪЬЮЬШKЪЮЬШЧKШЧЪ
ЯЬЮЬ)ЮЬЮЬЮЬШoKЪЬ
ЮЬШЪ	ЮЬЮЬЮ
ЬЮЬЮШ6KЪЬ"ЮЬtШЩKЪЬ
ЮЬШ#KЪЮЬШЧKШЧKЪЬЮЬfШpKШKШ ЧЪЯЬЮЬЮЬ*ШdЪ
ЯЬЮЬЮЬЮЬЮЬ'ШcKЪЬЮЬШЪЮЬЮЬЮЬ#ЮЬЮЬЮШAKШKЪЮЬШЧKЪЬ	ЮЬ(Ш4KШ
ЪЮЬЮЬЮЬ#ЮЬЮЬЮШAKШKШ"KШKЪЮЬШЧKШЧЪ
ЯЬЮЬЮЬЮЬЮЬ,ШoKЪЬЮЬШЪЮЬЮЬЮЬ(ЮЬЮЬЮШFKШKЪЮЬШЧKЪЬЮЬ*Ш9KШ
ЪЮЬЮЬЮЬ(ЮЬЮЬЮШFKШ2KШ%KШ6KШKЪЮЬШЧKШЧKШKШ%KШ-KШKШ ЧЧKШ KЪЮЬШKШ Ч ЕЧ    а  b  