%BigData.SQMMsgConnection
hidden class %BigData.SQMMsgConnection extends %Library.SystemBase
Property Inventory
- cliECPServerName
- cliMessageSemName
- cliQuerySem1Name
- cliQuerySem2Name
- cliQuerySem2Names
- cliSqmExtRefEnv
- cliTempExtRefEnv
- cliTempName
- currentPrimaryExtRefEnv
- devIndex
- execLoc
- isMirrored
- messageSemaphore
- querySemaphore1
- querySqms
- savedPrimary
- srvECPServerName
- srvHost
- srvMessageSemName
- srvNamespace
- srvQuerySem1Name
- srvQuerySem2Name
- srvSqmExtRefEnv
- syncSqm
- synchronous
Method Inventory
Properties
property cliECPServerName as %String;
Name of ECP server configured on server, pointing to client
Needed on server
property cliMessageSemName as %String;
property cliQuerySem1Name as %String;
property cliQuerySem2Name as %String;
Root name for all client querySem2Names
property cliQuerySem2Names [ MultiDimensional ];
Array of client querySem2Names, subscripted by query id
property cliSqmExtRefEnv as %String;
Extended reference env passed as localSystem argument to WorkMgr QueueShard method.
property cliTempExtRefEnv as %String;
Extended reference prefix pointing to client's IRISTEMP
Needed on server
property cliTempName as %String;
Name (subscript) of message node in client's IRISTEMP, to which to write replies
Needed on server
property currentPrimaryExtRefEnv as %String;
Extended reference environment of remote global storing $lb(host,port,ns) of current primary
property devIndex as %Integer;
Subscript of this device in $$$SNCom.devs($NAMESPACE)
property execLoc as %String;
property isMirrored as %Boolean;
Is this a mirrored connection?
property messageSemaphore as %RawString;
Semaphore for coordinating message exchange between client and server sides of connection.
On the client side, this is used to wait to receive replies from server.
On the server side, this is used to send replies to the client.
property querySemaphore1 as %RawString;
Semaphore to increment when writing query result rows to remote temp file, to cause the writes to be
synchronized asynchronously. This resides in IRISTEMP on the client side of the connection,
but is only used on the server side of the connection (client never decrements it).
It is created on client side as well so client can delete it if necessary.
property querySqms [ MultiDimensional ];
ShardWorkMgr object used for queries (subscripted by query id)
property savedPrimary as %List;
$lb(host,port,ns) of mirror member which was primary when we last checked
property srvECPServerName as %String;
Name of ECP server configured on client, pointing to server
property srvHost as %String;
property srvMessageSemName as %String;
Semaphore names
property srvNamespace as %String;
property srvQuerySem1Name as %String;
property srvQuerySem2Name as %String;
property srvSqmExtRefEnv as %String;
Extended reference env (i.e. prefix) passed as remoteSystem argument to WorkMgr QueueShard method.
Format: "^^"
property syncSqm as %RawString;
The ShardWorkMgr object used for synchronous operations
property synchronous as %Boolean;
Is message synchronous? (If so, delete sqm object in clirecv)
Methods
method %OnNew(pInitSem As %Boolean, pCliECPServerName As %String, pCliTempExtRefEnv As %String, pCliTempName As %String, pSrvMessageSemName As %String, pSrvQuerySem1Name As %String, pSrvQuerySem2Name As %String, pSrvSqmExtRefEnv As %String, pSrvECPServerName As %String, pCliMessageSemName As %String, pCliQuerySem1Name As %String, pCliQuerySem2Name As %String, pCliSqmExtRefEnv As %String, pSrvNamespace As %String, pSrvHost As %String, pDevIndex As %Integer, pExecLoc As %String) as %Library.Status