Feature #11371
full server-side support of FWD clients
80%
Related issues
History
#1 Updated by Constantin Asofiei 5 months ago
- Related to Bug #11271: server-side streams and files with frames/redirected terminal added
#3 Updated by Constantin Asofiei 5 months ago
Batch processes can be made to work similar to PASOE agents, full server-side, assuming that there is no need of interactive terminal.
There are not many static fields in the p2j.ui package remaining. After we clean this up and make them context-local, what we need to do is run a FWD client only on server-side.
Initial proposal is to do this still via ClientDriver, which after authentication, if it sees server-side-resources=ALL, it switches automatically to this 'headless' mode (i.e. closes the socket, etc) and initializes ThinClient and other needed UI resources on server-side.
But, this does not get rid of the OS process launch, which can be problematic when many clients need to be launch at the same time.
Instead, the solution will be to provide FWD Java APIs to launch a batch process fully server-side, in 'headless' mode, directly from the applications code. This way, there will no longer be an OS process.
An additional complication is OS-GETENV. There are applications which pass state to the launched batch process via OS environment variables. This can't be made to work without adding a separate mechanism of passing these env vars to the FWD Java API launching the OS batch process, so that we still have context-local separation of OS-GETENV (otherwise, all clients would read FWD Server's env vars).
#4 Updated by Constantin Asofiei 5 months ago
Constantin Asofiei wrote:
Instead, the solution will be to provide FWD Java APIs to launch a batch process fully server-side, in 'headless' mode, directly from the applications code. This way, there will no longer be an OS process.
Greg, an additional note: do we want to have REST APIs instead of Java APIs to launch the batch processes?
#6 Updated by Constantin Asofiei 5 months ago
Greg Shah wrote:
This would be part of our REST Admin APIs, and:I would generally prefer that. But I want to make sure that we plan for the most likely usage scenario. How would it be used to replace the launching of
_progresorprosessions in a script?
- the REST API will authenticate with a FWD account which has the correct permissions to launch batch processes
- the payload will specify the FWD account under which to run the batch program, plus all the other configurations to initialize the FWD context (bootstrap config, OS env vars, workingDir, etc)
Also, this would make FWD easier to integrate with other apps. And also does not rely on a JVM process to connect to the FWD server and launch this.
#8 Updated by Hynek Cihlar 5 months ago
- Related to Feature #9055: server-side processing of client platform dependencies in the UI added
#9 Updated by Hynek Cihlar 5 months ago
The initial work on running client-side UI in server context was implemented in 9055a. It added very limited set of use cases, like the MESSAGE statement.
#10 Updated by Constantin Asofiei about 1 month ago
- mixed mode PUT and DISPLAY:
- trunk server-side filesystem,streams: 11525ms/9869ms
- trunk no-server-side: 11135ms/9936ms
- 11371 server-side all: 2677ms/1823ms
- only PUT:
- trunk server-side filesystem,streams: 121ms/4085ms
- trunk no-server-side: 3919ms/3446ms
- 11371 server-side all: 58ms/68ms
- only DISPLAY
- 11371 server-side all: 2461ms/1717ms
I'll cleanup the changes, run automated review and start more extensive testing in real applications (I want to see if I can modify the batch launch code to actually be server-side=all for them). I also want to do some profiling to see where time is spent for the mixed PUT/DISPLAY case, the difference compared only with PUT is too high.
Notes:- the refactoring of the
FileStreamto keep an in-memory buffer was not yet made. I'll work on this in a separate branch (I've been thinking about this, but there are caveats to know when to flush to binary buffer, what happens when cursor is moved, etc). - the configuration for
server-side-resourcesremains in the directory - it can not be configured via bootstrap configurations. There are lots of 'chicken and the egg' issues and to add it complicates things a lot. - REST APIs added:
- Greg - do we want an ACL to allow a batch account to be used via REST?
GET /admin/launch- gets the list of all batch processes which can be launched; it skips only batch accounts configured as server or appserver.{ "processes": { "serversidebatch": true, "appserver_agent": true } }POST /admin/launch/<batchprocess>- launches a batch process, where the payload can specify custom OS properties and bootstrap configurations:{ "properties" : { "customproperty" : "blabla" }, "configs" : { "client:cmd-line-option:startup-procedure" : "test1.p" } }
- launching can also be done via
ServerDriver -b- it will honor theserver-side-resources=allfrom the directory
#11 Updated by Constantin Asofiei about 1 month ago
- Assignee set to Constantin Asofiei
- Status changed from New to WIP
- % Done changed from 0 to 80
#12 Updated by Greg Shah about 1 month ago
to allow a batch account to be used via REST
What do you mean by this? Used how or in what way?
#13 Updated by Constantin Asofiei about 1 month ago
Greg Shah wrote:
to allow a batch account to be used via REST
What do you mean by this? Used how or in what way?
I mean to be launched via REST. To allow explicitly this feauture for a process account.
Also I need to check what ACLs we have for the startup program - do we allow any program for REST launching?
I know the launching is secured via the token (so only an authenticated admin user can run this). So is more if we want another layer of checks.
#14 Updated by Constantin Asofiei 30 days ago
About security: we already have EntryPointResource to secure the entry points. This should be enough.
Current changes are in 11371a rev 16687. I've also added server-side-resources=all support for launching classic appserver agents - in this mode, there will be no JVM for a FWD Client. This will help reducing the need for system memory usage if these clients are server-side, plus the FWD server startup time.
- there is an issue with WAIT-FOR (is not blocking). I'm looking into this.
- all STDOUT or other client-side output in this mode will go to the FWD Server's JVM STODUT or logging - this is the same as for MSA, I don't think we have another approach for this.
- currently filesystem and streams can work on server-side only and only if ALL are server-side. To keep this, we need back the #11271 support. But, considering the findings from this work (any terminal requirement like unnamed streams or UI statements must have the stream on the client), this is not something viable. I don't think we have any applications currently configured with server-side filesystem for interactive clients (not batch).
- more testing including MSA, classic agents and normal clients.
#15 Updated by Constantin Asofiei 29 days ago
- Status changed from WIP to Review
- reviewer Hynek Cihlar added
WAIT-FOR is now working (just had to enable TC.typeAhead).
Another thing left: combinations of individual server-side-resources (like sockets, etc), and not ALL. filesystem/streams still remain only for ALL.
Hynek: please do a review. Note that claude still has some complaints left.
#16 Updated by Constantin Asofiei 29 days ago
Greg - currently only REST allows specifying custom bootstrap config and OS environment overrides. I'm thinking to add this support also for ServerDriver -b, IMO it will complicate things if we want to launch these via shell scripts (i.e. maintaining the REST ADMIN user and password, ACLs, etc).
#17 Updated by Constantin Asofiei 29 days ago
Constantin Asofiei wrote:
Greg - currently only REST allows specifying custom bootstrap config and OS environment overrides. I'm thinking to add this support also for
ServerDriver -b, IMO it will complicate things if we want to launch these via shell scripts (i.e. maintaining the REST ADMIN user and password, ACLs, etc).
This support is in 11371a/16690; the syntax is:
ServerDriver -bcfg client:cmd-line-option:startup-procedure=asyncreq4.p ... <list of config overrides> -benv somevar=foo ... <list of environment variables> -b <processname>
I'll look into changing scripts for existing apps to use ServerDriver -b to launch a batch process in server-side mode (the bootstrap config and environment needs to be the same as the batch process case with its own JVM).
#19 Updated by Constantin Asofiei 9 days ago
For server-side=all, I need to change SESSION_FWD-LOGFILE_Attribute to return the server's log file, as in this case there is no FWD-specific client log file.
#20 Updated by Constantin Asofiei 8 days ago
Constantin Asofiei wrote:
For server-side=all, I need to change SESSION_FWD-LOGFILE_Attribute to return the server's log file, as in this case there is no FWD-specific client log file.
Fixed in rev 16730.
#22 Updated by Constantin Asofiei 7 days ago
Hynek - please take a look at the changes.
The last part I have on my list is to see how the logs which were on FWD client-side can still be on a separate file.
#23 Updated by Constantin Asofiei 7 days ago
Constantin Asofiei wrote:
The last part I have on my list is to see how the logs which were on FWD client-side can still be on a separate file.
This part we can not do easily. Loggers are created via CentralLogger.get, for both FWD client and server code. More, there are classes which are used both on server and client (BDTs, UnimplementedFeature and more). So we can not separate even via lets say CentralLoggerClient.get, so we can control which kind of logging is used. Analyzing the stack is expensive (i.e. to determine if we are executing server or client code).
OTOH, all client code (which executes now server-side) will execute via local proxies (which are via LocalStaticRedirector and LocalRedirector handlers). So we can intercept this and switch the CentralLogger from server to client (or vice-versa) before the call, and restore it after the call. I'll look into how this can be done.
#24 Updated by Constantin Asofiei 7 days ago
LocalStaticRedirectorandLocalRedirectordo not apply the changes from the response - the invoke should have been like this:public Object invokeCore(Object proxy, Method method, Object[] args) throws Throwable { if (!methods.contains(method)) { throw new SilentUnwindException(); } if (state != null) { state.sync(); } try { return method.invoke(instance, args); } finally { if (state != null) { state.reverseSync(); } } }
wherereverseSyncjust gets the changes from thesinkand applies them to thesource. I recall checking this early on this work, I sawLT.getChanges()but I missed thatLT.applyChangesis not being called after the response.- for MSA agents (and classic agents), I'd like to use a single log file (rotated). Why: we can trim and start agents for 1000s of times per day maybe. We will just spam the OS filesystem with files (many of them I think just empty files).
#25 Updated by Greg Shah 6 days ago
for MSA agents (and classic agents), I'd like to use a single log file (rotated). Why: we can trim and start agents for 1000s of times per day maybe. We will just spam the OS filesystem with files (many of them I think just empty files)
Isn't this how OE does it? (that is what I recall) If so, then the customers will accept it.
I will note that I also recall hearing a customer say they liked the separate logs. Perhaps we make this configurable.
#26 Updated by Hynek Cihlar 6 days ago
- Status changed from Review to WIP
Code review 11371a. I'm assuming interactive client drivers are out of scope for this work.
1. ThinClient.getJavaCPInternal null guard is inverted
src/com/goldencode/p2j/ui/chui/ThinClient.java:27476
ThinClient tc = getInstance();
if (tc == null || tc.javaCPInternal != null)
{
// 'tc' can be null if it has not been initialized yet; 'javaCPInternal' is calculated in
// 'initializePost', after 'tc' is created. but 'ConsolePrimitives.character' needs this when
// creating the native ChUI terminal.
return tc.javaCPInternal;
}
return getDefaultJavaCharset();
2. SET-WORKING-DIRECTORY performs a process-wide chdir when the filesystem is server-side
src/com/goldencode/p2j/util/FileSystemOps.java:1630 -> src/com/goldencode/p2j/util/osresource/FileSystemDaemon.java:1726
// FileSystemOps.setWorkingDirectory - no serverSideFs branch
work.obtain().fs.setWorkingDirectory(workDir.toStringMessage());
// FileSystemDaemon.setWorkingDirectory - inherited by ServerFileSystemDaemon, not overridden
if (setWorkingDir(newWorkingDir)) // native chdir(), process-wide
{
System.setProperty("user.dir", newWorkingDir); // JVM-global
}
3. The Admin process launch applies no allowlist to caller-supplied bootstrap config
src/com/goldencode/p2j/main/StandardServer.java:1093-1121
// overwrite with explicitly sent overrides; this can set i.e. the target p2j-entry to launch
for (Map.Entry<String, String> entry : otherConfigs.entrySet())
{
cfgOverrides.put(entry.getKey(), entry.getValue()); // REST payload wins over the directory
}
...
String[] keys = key.split(":");
if (keys.length != 3) { ... continue; }
cfg.setConfigItem(keys[0], keys[1], keys[2], value); // only validation is "has 3 parts"
The configs object of POST /admin/launch/<process> (ProcessRestHandler.java:331, via BaseAdminRestHandler.loadStringMap) reaches this unfiltered. The only ACL check in the path is EntryPointResource.isAllowed(startupProcedure) at StandardServer.java:633, covering one key. The comment at 587 ("these values need no security check since the directory is an inherently trusted source") no longer holds once a REST caller can overwrite them.
Arbitrary file write as the FWD server's OS user:
POST /admin/launch/nightlyreport
{ "configs": { "client:cmd-line-option:clientlog": "/opt/fwd/scripts/somefile.sh" } }
4. %pid no longer distinguishes legacy log files, and the collision is swallowed
src/com/goldencode/p2j/util/LegacyLogManagerClientServiceImpl.java:210 and 306
FileLock lock = wa.channel.lock();
wa.channel.write(byteBuffer);
lock.release();
...
catch (Exception e)
{
LOG.log(Level.WARNING, e, "Couldn't write log %s to file %s.", logRecord, wa.filePath);
return false; // record dropped
}
5. Should the interactive GUI drivers be explicitly checked and denied for all-server client?
6. ServerStreamDaemon context-local has no cleanup(), open streams leak
src/com/goldencode/p2j/util/ServerStreamDaemon.java:78
private static final ContextLocal<WorkArea> local = new ContextLocal<>()
{
protected WorkArea initialValue() { ... }
// no cleanup(WorkArea) override
};
7. -bcfg/-benv argument accounting uses map size instead of tokens consumed
src/com/goldencode/p2j/main/ServerDriver.java:475
batchConfigOverrides = new HashMap<>(); collectKeyValueArgs(args, current, batchConfigOverrides); skip = batchConfigOverrides.size() + 1;
collectKeyValueArgs (1090-1103) does m.put(k, v), so a duplicate key collapses two consumed tokens into one entry. ServerDriver -bcfg foo=1 foo=2 -b proc under-advances by one in CommonDriver.process() (458-468).
8. Dead osResources collection makes a config branch permanently false
src/com/goldencode/p2j/util/osresource/OSResourceManager.java:147,150,161
Collection<OsResourceType> osResources = new HashSet<>(); // never populated IS_ALL_SERVER_SIDE = osResources.contains(OsResourceType.ALL) || OsResourceType.ALL.getName().equals(res); ... osResources.forEach(type -> serverSideResources.put(type, Boolean.TRUE)); // no-op
The actual parsing happens in the res.split(",") loop below, so the first disjunct at 150 and the whole statement at 161 are dead.
Btw. neither 150 nor isAllServerSideResources() at 233 trims the directory value. server-side-resources=" all" yields IS_ALL_SERVER_SIDE == false while the split loop still sets serverSideResources[ALL] = TRUE, i.e. a half-configured state from a value an admin could plausibly type.
9. Non-defensive cleanup in the headless launch finally
src/com/goldencode/p2j/main/StandardServer.java:1159-1172 runs session.terminate(), ThinClient.terminate(), driver.shutdown() and SessionManager.get().terminateServerSession() in sequence with no per-step guard. session.terminate() goes to SessionManager.endSession() (1431-1501) which performs several unguarded operations. If any throws, the remaining steps are skipped, notably terminateServerSession() which does restoreContext(); dropInitialContext(); (1156-1160). That launch's security context then stays undropped for the server's lifetime.
10. The following exception catches in ProcessRestHandler.java only log the message:
:220 catch (IOException e) LOG.log(Level.WARNING, "Could not write response due to " + e.getMessage());
:236 catch (IOException e) LOG.log(Level.WARNING, "Could not write response due to " + e.getMessage());
:250 catch (IOException e) LOG.log(Level.WARNING, "Could not write response due to " + e.getMessage());
:293 catch (JsonProcessingException e) LOG.log(Level.WARNING, "Unable to parse JSON due to " + e.getMessage());
:323 catch (IOException ex) LOG.log(Level.WARNING, "Could not write response due to " + ex.getMessage());
:428 catch (IOException e) LOG.log(Level.WARNING, "Could not write response due to " + e.getMessage());
:441 catch (IOException e) LOG.log(Level.WARNING, "Could not write response due to " + e.getMessage());
:454 catch (IOException e) LOG.log(Level.WARNING, "Could not write response due to " + e.getMessage());
#27 Updated by Constantin Asofiei 6 days ago
Hynek Cihlar wrote:
Code review 11371a. I'm assuming interactive client drivers are out of scope for this work.
1.
ThinClient.getJavaCPInternalnull guard is inverted
I'll fix this.
2.
SET-WORKING-DIRECTORYperforms a process-wide chdir when the filesystem is server-side
This is a FWD extension. I'll disallow this for server-side filesystem.
There is no ACL support for generic bootstrap configs (just the entry point). The REST API is supposed to be ran by admins (secured) accounts, who lets say know what they are doing. But the policy discussion is good:3. The Admin process launch applies no allowlist to caller-supplied bootstrap config
- do we allow just the entry point in the REST payload and everything else is from the directory?
- do we add ACLs to specify allowed configs sent via REST?
4.
%pidno longer distinguishes legacy log files, and the collision is swallowed
I'll check this.
5. Should the interactive GUI drivers be explicitly checked and denied for all-server client?
I can add the check.
6.
ServerStreamDaemoncontext-local has nocleanup(), open streams leak
I don't understand this one; streams are closed by the scopeable support - when that is reached, is assumed there are no streams active.
7.
-bcfg/-benvargument accounting uses map size instead of tokens consumed
I'll fix this.
8. Dead
osResourcescollection makes a config branch permanently false
Fixed.
9. Non-defensive cleanup in the headless launch
finally
Yes, I'll protect each part in a try/catch block.
10. The following exception catches in
ProcessRestHandler.javaonly log the message:
This is the 'standard' for all Admin handlers - there is no error stacktrace logged. If we fix it, we need to fix it in all.
#28 Updated by Constantin Asofiei 6 days ago
Greg Shah wrote:
for MSA agents (and classic agents), I'd like to use a single log file (rotated). Why: we can trim and start agents for 1000s of times per day maybe. We will just spam the OS filesystem with files (many of them I think just empty files)
Isn't this how OE does it? (that is what I recall) If so, then the customers will accept it.
OE has a single log file (for the agent) with the OE-specific messages. I'll make the FWD log file (not the legacy file) configurable via directory.
I will note that I also recall hearing a customer say they liked the separate logs. Perhaps we make this configurable.
Most likely those were the legacy logs. I'll double-check these if they can be per-agent or per-appserver (including for MSA).
#29 Updated by Hynek Cihlar 5 days ago
Constantin Asofiei wrote:
6.
ServerStreamDaemoncontext-local has nocleanup(), open streams leakI don't understand this one; streams are closed by the scopeable support - when that is reached, is assumed there are no streams active.
Unless I'm reading the code wrong, streams not closed in 4GL stay in StreamDaemon.WorkArea.streams and are dropped without closing on client/session termination. This is a pre-existing issue.