Public Member Functions | |
boolean | initRegisterFile () |
Static Public Member Functions | |
static void | registerFalseFile (LSDExtQueueMember member, String message) |
static void | registerFalseFile (String filename, String message) |
static void | registerTrueFile (LSDExtQueueMember member, boolean createOKFile) |
Public Attributes | |
long | targetIdip = LSDConstants.invalide_idx |
Static Public Attributes | |
static final String | extOK = ".ok" |
static final String | extKO = ".ko" |
Protected Member Functions | |
int | privateInitializeArgs (String[] args, int curargs) |
int | initializeArgs (String[] args, int curargs) |
LSDImportAbstract (LSDLoadConfig llc, boolean blockmode) | |
LSDImportAbstract (LSDDbAdmin admin, boolean blockmode) | |
boolean | getIndexFromString (String line) |
boolean | initOptions (String[]args, int curargs) |
boolean | initOneFileOption (int curargs, String[]args) |
boolean | initOptionsAuto (String[]args, int curargs) |
boolean | initConnection () |
boolean | prepareImportQueue () |
boolean | joinConnection () |
boolean | errorFromPrepareImportQueue () |
boolean | finalizeAfterImport () |
boolean | finishAfterAutoImport () |
boolean | finalizeAfterAutoImport () |
boolean | finalizeConnection () |
void | finalizeRegisterFile () |
boolean | getClientPutInfo (LSDDbLegacy legacy, boolean compressedClient, boolean keepalived) |
boolean | getClientPutInfoFromIpPort (LSDDbLegacy legacy, LSDDbIpPort ipportUser1, LSDDbIpPort ipportProt1, boolean keepalived) |
LSDDbLegacy | getLegacy (long lid) |
LSDDbIpPort | getIpPortC (LSDDbLegacy legacy) |
LSDDbIpPort | getIpPortP (LSDDbLegacy legacy) |
Protected Attributes | |
LSDDbAdmin | admin = null |
LSDLoadConfig | llc = null |
boolean | isSameLid = false |
long | sameLid = LSDConstants.invalide_idx |
LSDDbLegacy | sameLegacy = null |
boolean | todelete = true |
int | option = -1 |
String | file0 = null |
long | lid0 = LSDConstants.invalide_idx |
LSDBusiness | lsdb = null |
LSDExtClientInfo | lci = null |
LSDClientPut | lcp = null |
LSDClientDelete | lcd = null |
String | passwd = null |
String | dir1 = null |
String | ext1 = null |
String | source2 = null |
boolean | blockmode = false |
ConcurrentLinkedQueue < LSDExtQueueMember > | todoQueue = null |
ConcurrentLinkedQueue < LSDExtQueueMembers > | todoQueueB = null |
ConcurrentLinkedQueue < LSDExtQueueMember > | doneQueue = null |
int | nbFile = 1 |
int | nbthread = 1 |
String | extidb = null |
boolean | sameDbConnMyltithread = false |
boolean | async = false |
boolean | isCompressed = false |
LSDClientPut[] | lcps = null |
LSDDbAdmin[] | dbconns = null |
File[] | listFiles = null |
LinkedList< String > | listline = null |
ConcurrentLinkedQueue < LSDExtQueueMember >[] | todoQueues = null |
ConcurrentLinkedQueue < LSDExtQueueMembers >[] | todoQueuesB = null |
ConcurrentLinkedQueue < LSDExtQueueMember > | todoQueueLocal = null |
ConcurrentLinkedQueue < LSDExtQueueMembers > | todoQueueBLocal = null |
LinkedList< String > | errorList = null |
String | extStop = null |
String | filename2Out = null |
Static Protected Attributes | |
static long | KO = 0 |
static boolean | istesting = false |
static Date | date_debut = null |
static boolean | use2Out = false |
static FileWriter | fileOK = null |
static FileWriter | fileKO = null |
static long | countKO = 0 |
static long | countOK = 0 |
openlsd.appli.autoimport.commonimport.LSDImportAbstract.LSDImportAbstract | ( | LSDLoadConfig | llc, | |
boolean | blockmode | |||
) | [protected] |
Create a LSDImport from args
llc | ||
blockmode |
openlsd.appli.autoimport.commonimport.LSDImportAbstract.LSDImportAbstract | ( | LSDDbAdmin | admin, | |
boolean | blockmode | |||
) | [protected] |
int openlsd.appli.autoimport.commonimport.LSDImportAbstract.privateInitializeArgs | ( | String[] | args, | |
int | curargs | |||
) | [protected] |
Function to override for specific initialization values
args | ||
curargs |
Reimplemented in openlsd.appli.autoimport.LSDAutoImport, and openlsd.appli.autoimport.LSDAutoImportBlock.
int openlsd.appli.autoimport.commonimport.LSDImportAbstract.initializeArgs | ( | String[] | args, | |
int | curargs | |||
) | [protected] |
Get arguments
args | ||
curargs |
Reimplemented in openlsm.autoimport.commonimport.LSMImportAbstract.
boolean openlsd.appli.autoimport.commonimport.LSDImportAbstract.getIndexFromString | ( | String | line | ) | [protected] |
Get file, lid and idb from the String line where a blank character is a separator. Should be override to explicitly specify how to use the correct business implementation.
line |
Reimplemented in openlsm.autoimport.commonimport.LSMImportAbstract.
boolean openlsd.appli.autoimport.commonimport.LSDImportAbstract.initOptions | ( | String[] | args, | |
int | curargs | |||
) | [protected] |
Finalize Init options from args
args | ||
curargs |
Reimplemented in openlsm.autoimport.commonimport.LSMImportAbstract.
boolean openlsd.appli.autoimport.commonimport.LSDImportAbstract.initOneFileOption | ( | int | curargs, | |
String[] | args | |||
) | [protected] |
Init one File option form args and current position (must be override)
curargs | ||
args |
boolean openlsd.appli.autoimport.commonimport.LSDImportAbstract.initRegisterFile | ( | ) |
Create OK and KO files
static void openlsd.appli.autoimport.commonimport.LSDImportAbstract.registerFalseFile | ( | LSDExtQueueMember | member, | |
String | message | |||
) | [static] |
Register a File as member as False import
member | ||
message |
static void openlsd.appli.autoimport.commonimport.LSDImportAbstract.registerFalseFile | ( | String | filename, | |
String | message | |||
) | [static] |
Register a File as filename as False import
filename | ||
message |
static void openlsd.appli.autoimport.commonimport.LSDImportAbstract.registerTrueFile | ( | LSDExtQueueMember | member, | |
boolean | createOKFile | |||
) | [static] |
Register a File as True import
member | ||
createOKFile |
boolean openlsd.appli.autoimport.commonimport.LSDImportAbstract.initOptionsAuto | ( | String[] | args, | |
int | curargs | |||
) | [protected] |
Finalize Init options from args for AutoImport
args | ||
curargs |
boolean openlsd.appli.autoimport.commonimport.LSDImportAbstract.initConnection | ( | ) | [protected] |
InitConnection. Must be followed later on by joinConnection()
Reimplemented in openlsm.autoimport.commonimport.LSMImportAbstract.
boolean openlsd.appli.autoimport.commonimport.LSDImportAbstract.prepareImportQueue | ( | ) | [protected] |
Prepare the Import Queue
Reimplemented in openlsd.server.autoimport.commonimport.LSDServerImportAbstract, and openlsm.autoimport.commonimport.LSMImportAbstract.
boolean openlsd.appli.autoimport.commonimport.LSDImportAbstract.joinConnection | ( | ) | [protected] |
Finalize connection if they are pending
boolean openlsd.appli.autoimport.commonimport.LSDImportAbstract.errorFromPrepareImportQueue | ( | ) | [protected] |
Set the error status from prepareImportQueue
boolean openlsd.appli.autoimport.commonimport.LSDImportAbstract.finalizeAfterImport | ( | ) | [protected] |
Finalize status and object after import and close LSD connections
Reimplemented in openlsm.autoimport.commonimport.LSMImportAbstract.
boolean openlsd.appli.autoimport.commonimport.LSDImportAbstract.finishAfterAutoImport | ( | ) | [protected] |
Finalize status and object after import for AutoImport
Reimplemented in openlsm.autoimport.commonimport.LSMImportAbstract.
boolean openlsd.appli.autoimport.commonimport.LSDImportAbstract.finalizeAfterAutoImport | ( | ) | [protected] |
Finalize and close LSD connections for AutoImport
boolean openlsd.appli.autoimport.commonimport.LSDImportAbstract.finalizeConnection | ( | ) | [protected] |
Finalize connection (database)
Reimplemented in openlsm.autoimport.commonimport.LSMImportAbstract.
void openlsd.appli.autoimport.commonimport.LSDImportAbstract.finalizeRegisterFile | ( | ) | [protected] |
Finalize registered files for OK and KO
boolean openlsd.appli.autoimport.commonimport.LSDImportAbstract.getClientPutInfo | ( | LSDDbLegacy | legacy, | |
boolean | compressedClient, | |||
boolean | keepalived | |||
) | [protected] |
Get a LSDClientPut and LSDClientInfo and LSDClientDelete for the Legacy and using the extension of PutSessionHandler and InfoSessionHandler.
legacy | ||
compressedClient | ||
keepalived |
boolean openlsd.appli.autoimport.commonimport.LSDImportAbstract.getClientPutInfoFromIpPort | ( | LSDDbLegacy | legacy, | |
LSDDbIpPort | ipportUser1, | |||
LSDDbIpPort | ipportProt1, | |||
boolean | keepalived | |||
) | [protected] |
Get a LSDClientPut and LSDClientInfo and LSDClientDelete for the Legacy and using the extension of PutSessionHandler and InfoSessionHandler.
legacy | ||
ipportUser1 | ||
ipportProt1 | ||
keepalived |
LSDDbLegacy openlsd.appli.autoimport.commonimport.LSDImportAbstract.getLegacy | ( | long | lid | ) | [protected] |
Get the Legacy corresponding to the Legacy lid
lid |
LSDDbIpPort openlsd.appli.autoimport.commonimport.LSDImportAbstract.getIpPortC | ( | LSDDbLegacy | legacy | ) | [protected] |
Get the IpPort correspondig to the Legacy for Compress
legacy |
LSDDbIpPort openlsd.appli.autoimport.commonimport.LSDImportAbstract.getIpPortP | ( | LSDDbLegacy | legacy | ) | [protected] |
Get the IpPort correspondig to the Legacy for Protected
legacy |
LSDDbAdmin openlsd.appli.autoimport.commonimport.LSDImportAbstract.admin = null [protected] |
DB Admin object
LSDLoadConfig openlsd.appli.autoimport.commonimport.LSDImportAbstract.llc = null [protected] |
LoadConfig from file
boolean openlsd.appli.autoimport.commonimport.LSDImportAbstract.isSameLid = false [protected] |
Does this Import using the same Legacy for all files
long openlsd.appli.autoimport.commonimport.LSDImportAbstract.sameLid = LSDConstants.invalide_idx [protected] |
If Same Legacy, which Legacy Id
LSDDbLegacy openlsd.appli.autoimport.commonimport.LSDImportAbstract.sameLegacy = null [protected] |
If Same Legacy, which Legacy Object
boolean openlsd.appli.autoimport.commonimport.LSDImportAbstract.todelete = true [protected] |
Does the file after successful import should be deleted
int openlsd.appli.autoimport.commonimport.LSDImportAbstract.option = -1 [protected] |
Which mode: 0 = file lid idb, 1 = dir extension, 2 = sourcefile
String openlsd.appli.autoimport.commonimport.LSDImportAbstract.file0 = null [protected] |
Mode 0: the file
long openlsd.appli.autoimport.commonimport.LSDImportAbstract.lid0 = LSDConstants.invalide_idx [protected] |
Mode 0: the Legacy Id
LSDBusiness openlsd.appli.autoimport.commonimport.LSDImportAbstract.lsdb = null [protected] |
Mode 0: the ID Business
LSDExtClientInfo openlsd.appli.autoimport.commonimport.LSDImportAbstract.lci = null [protected] |
Info Client
LSDClientPut openlsd.appli.autoimport.commonimport.LSDImportAbstract.lcp = null [protected] |
Put Client
LSDClientDelete openlsd.appli.autoimport.commonimport.LSDImportAbstract.lcd = null [protected] |
Delete Client
String openlsd.appli.autoimport.commonimport.LSDImportAbstract.passwd = null [protected] |
Password for Delete Client
String openlsd.appli.autoimport.commonimport.LSDImportAbstract.dir1 = null [protected] |
Mode 1: Directory
String openlsd.appli.autoimport.commonimport.LSDImportAbstract.ext1 = null [protected] |
Mode 1: Extension
String openlsd.appli.autoimport.commonimport.LSDImportAbstract.source2 = null [protected] |
Mode 2: Source filename
boolean openlsd.appli.autoimport.commonimport.LSDImportAbstract.blockmode = false [protected] |
Mode block
ConcurrentLinkedQueue<LSDExtQueueMember> openlsd.appli.autoimport.commonimport.LSDImportAbstract.todoQueue = null [protected] |
Queue of files to import in non block mode
ConcurrentLinkedQueue<LSDExtQueueMembers> openlsd.appli.autoimport.commonimport.LSDImportAbstract.todoQueueB = null [protected] |
Queue of files to import in block mode
ConcurrentLinkedQueue<LSDExtQueueMember> openlsd.appli.autoimport.commonimport.LSDImportAbstract.doneQueue = null [protected] |
Queue of imported files
int openlsd.appli.autoimport.commonimport.LSDImportAbstract.nbFile = 1 [protected] |
Number of Files
long openlsd.appli.autoimport.commonimport.LSDImportAbstract.KO = 0 [static, protected] |
Number of KO files
int openlsd.appli.autoimport.commonimport.LSDImportAbstract.nbthread = 1 [protected] |
Number of threads
boolean openlsd.appli.autoimport.commonimport.LSDImportAbstract.istesting = false [static, protected] |
test only
String openlsd.appli.autoimport.commonimport.LSDImportAbstract.extidb = null [protected] |
test only
Date openlsd.appli.autoimport.commonimport.LSDImportAbstract.date_debut = null [static, protected] |
test only
boolean openlsd.appli.autoimport.commonimport.LSDImportAbstract.sameDbConnMyltithread = false [protected] |
Is DB Conn using thread shared connection
boolean openlsd.appli.autoimport.commonimport.LSDImportAbstract.async = false [protected] |
Should the connection done as async (join with a future)
boolean openlsd.appli.autoimport.commonimport.LSDImportAbstract.isCompressed = false [protected] |
Using compression
LSDClientPut [] openlsd.appli.autoimport.commonimport.LSDImportAbstract.lcps = null [protected] |
Client connections
LSDDbAdmin [] openlsd.appli.autoimport.commonimport.LSDImportAbstract.dbconns = null [protected] |
Database connections
File [] openlsd.appli.autoimport.commonimport.LSDImportAbstract.listFiles = null [protected] |
List of files from -dir option
LinkedList<String> openlsd.appli.autoimport.commonimport.LSDImportAbstract.listline = null [protected] |
List of line from -source option
ConcurrentLinkedQueue<LSDExtQueueMember> [] openlsd.appli.autoimport.commonimport.LSDImportAbstract.todoQueues = null [protected] |
todo Queues for non block mode
ConcurrentLinkedQueue<LSDExtQueueMembers> [] openlsd.appli.autoimport.commonimport.LSDImportAbstract.todoQueuesB = null [protected] |
todo Queues for block mode
ConcurrentLinkedQueue<LSDExtQueueMember> openlsd.appli.autoimport.commonimport.LSDImportAbstract.todoQueueLocal = null [protected] |
todo local Queue for non block mode
ConcurrentLinkedQueue<LSDExtQueueMembers> openlsd.appli.autoimport.commonimport.LSDImportAbstract.todoQueueBLocal = null [protected] |
todo local Queue for block mode
LinkedList<String> openlsd.appli.autoimport.commonimport.LSDImportAbstract.errorList = null [protected] |
List of files in error from init part
String openlsd.appli.autoimport.commonimport.LSDImportAbstract.extStop = null [protected] |
File that stops the process when it exists for AutoImport
boolean openlsd.appli.autoimport.commonimport.LSDImportAbstract.use2Out = false [static, protected] |
Should we use two files as exit (OK and KO) or one KO by file
String openlsd.appli.autoimport.commonimport.LSDImportAbstract.filename2Out = null [protected] |
Basename for 2out files
FileWriter openlsd.appli.autoimport.commonimport.LSDImportAbstract.fileOK = null [static, protected] |
FileWriter for OK status if use2Out is true
FileWriter openlsd.appli.autoimport.commonimport.LSDImportAbstract.fileKO = null [static, protected] |
FileWriter for KO status if use2Out is true
long openlsd.appli.autoimport.commonimport.LSDImportAbstract.countKO = 0 [static, protected] |
Number of KO files
long openlsd.appli.autoimport.commonimport.LSDImportAbstract.countOK = 0 [static, protected] |
Number of OK files
Target if any by default (implies the use of -samelid option) (ML Support)
final String openlsd.appli.autoimport.commonimport.LSDImportAbstract.extOK = ".ok" [static] |
Extension for OK files
final String openlsd.appli.autoimport.commonimport.LSDImportAbstract.extKO = ".ko" [static] |
Extension for KO files