Local Access Points (LAPs) are a low overhead mechanism for calling service routines in supervisor actors on the local site by both user and supervisor actor calls.
The following is an example of the use of local access points. Refer to the lapInvoke(2K),svLapBind(2K), svLapCreate(2K), and svLapDelete(2K) man pages.
(file: progov/lap.c) #include <stdio.h> #include <stdlib.h> #include <errno.h> #include <chorus.h> #include <lap/chLap.h> #include <am/afexec.h> #include <exec/chExec.h> AcParam param; KnCap actorCap; KnLapDesc lapDesc; char* lapArgument; KnTimeVal timeval; void lapHandler(char* message, char* cookie) { int res; res = actorSelf(&actorCap); if (res != K_OK) { printf("actorSelf failed, returns %d\n",res); exit(1); } printf("LAP handler is running \n"); printf(" thread LI = %d, actor UI = 0x%x 0x%x\n", threadSelf(), actorCap.ui.uiHead, actorCap.ui.uiTail); printf(" Argument = %s, cookie = %s\n",message, cookie); } int main(int argc, char** argv, char** envp) { int res; KnCap clientCap; KnActorPrivilege actorP; char* cookie = "Chorus"; res = actorPrivilege(K_MYACTOR, &actorP, NULL); if (res != K_OK) { printf("Cannot get actor privilege, error %d\n", res); exit(1); } if (actorP != K_SUPACTOR) { printf("This program must be run in supervisor mode\n"); exit(1); } if (argc == 1) { printf("Must be run with one argument: LAP name\n"); exit(1); } if (argc == 2) { /* * This is the Server actor. * connect a LAP handler, * bind a symbolic name to this LAP (name given as argv[1]) * spawn a client actor (give the LAP symbolic name in argument) * wait one minute for Lap invocation */ /* * Spawn the client actor */ param.acFlags = AFX_SUPERVISOR_SPACE; res = afexeclp(argv[0], &clientCap, ¶m , argv[0], argv[1], "ARGH", NULL); if (res == -1) { printf("Cannot spawn client actor, error %d\n", errno); exit(1); } /* * Create the LAP */ res = svLapCreate(K_MYACTOR, (KnLapHdl) lapHandler, cookie, K_LAP_SETJMP, &lapDesc); if (res != K_OK) { printf("svLapCreate failed, returns %d\n",res); exit(1); } /* * Bind a symbolic name */ res = svLapBind(&lapDesc, argv[1], 0); if (res != K_OK) { printf("svLapBind failed, returns %d\n",res); exit(1); } /* * Wait one minute * Other client actors can be run from the console: * rsh target arun lap.r lap-name lap-argument * */ timeval.tmSec = 60; timeval.tmNSec = 0; threadDelay(&timeval); /* * Unbind the LAP name and Delete the LAP */ res = svLapUnbind(argv[1]); if (res != K_OK) { printf("svLapUnBind failed, returns %d\n",res); exit(1); } res = svLapDelete(&lapDesc); if (res != K_OK) { printf("svLapDelete failed, returns %d\n",res); exit(1); } printf("Server actor is leaving ...\n"); } else { /* * This is the Client Actor: * argv[1] is the LAP name, argv[2] is the LAP argument. * get the LAP descriptor and invoke the LAP handler. */ res = actorSelf(&actorCap); if (res != K_OK) { printf("actorSelf failed ! Return code = %d\n",res); exit(1); } printf("Client actor is running, thread li = %d, " "actor UI = 0x%x 0x%x\n", threadSelf(), actorCap.ui.uiHead, actorCap.ui.uiTail); /* * Get the LAP descriptor knowing its name */ res = lapResolve(&lapDesc, argv[1], 0); if (res != K_OK) { printf("lapResolve failed, returns %d\n", res); exit(1); } /* * Invoke the LAP handler */ res = lapInvoke(&lapDesc, argv[2]); if (res != K_OK) { printf("lapInvoke failed, returns %d\n", res); exit(1); } printf("Client actor is leaving ...\n"); } return 0; }
The main thread:
checks if it is running as a supervisor actor
spawns another copy of itself using afexec()
creates a Local Access Point and connects a LAP handler which prints the unique identifier of the current thread (Actor UI + thread LI), the LAP argument and the LAP cookie on the console
binds a symbolic name received as the first argument
waits for one minute for LAP invocations
frees the LAP and its name, then terminates the program
The spawned actor:
receives two arguments: the symbolic LAP name and the argument to be passed to the LAP handler
retrieves the LAP descriptor
invokes the LAP handler, then terminates