public class org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy extends java.lang.Object implements org.apache.camel.component.file.GenericFileExclusiveReadLockStrategy
{
private static final org.slf4j.Logger LOG;
private boolean markerFile;
private boolean deleteOrphanLockFiles;
public void <init>()
{
org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy v;
v := @this: org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy: boolean markerFile> = 1;
v.<org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy: boolean deleteOrphanLockFiles> = 1;
return;
}
public void prepareOnStartup(org.apache.camel.component.file.GenericFileOperations, org.apache.camel.component.file.GenericFileEndpoint)
{
org.apache.camel.component.file.GenericFileFilter v, v;
long v, v;
org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy v;
byte v;
java.lang.Long v;
java.lang.String v, v;
boolean v, v;
org.apache.camel.component.file.GenericFileEndpoint v;
org.slf4j.Logger v, v;
org.apache.camel.component.file.GenericFileConfiguration v, v;
org.apache.camel.util.StopWatch v;
java.io.File v;
org.apache.camel.component.file.GenericFileOperations v;
java.util.regex.Pattern v, v;
v := @this: org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy;
v := @parameter: org.apache.camel.component.file.GenericFileOperations;
v := @parameter: org.apache.camel.component.file.GenericFileEndpoint;
v = v.<org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy: boolean deleteOrphanLockFiles>;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.camel.component.file.GenericFileEndpoint: org.apache.camel.component.file.GenericFileConfiguration getConfiguration()>();
v = virtualinvoke v.<org.apache.camel.component.file.GenericFileConfiguration: java.lang.String getDirectory()>();
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
v = <org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Prepare on startup by deleting orphaned lock files from: {}", v);
v = virtualinvoke v.<org.apache.camel.component.file.GenericFileEndpoint: java.util.regex.Pattern getExcludePattern()>();
v = virtualinvoke v.<org.apache.camel.component.file.GenericFileEndpoint: java.util.regex.Pattern getIncludePattern()>();
v = virtualinvoke v.<org.apache.camel.component.file.GenericFileEndpoint: org.apache.camel.component.file.GenericFileConfiguration getConfiguration()>();
v = virtualinvoke v.<org.apache.camel.component.file.GenericFileConfiguration: java.lang.String getDirectory()>();
v = new org.apache.camel.util.StopWatch;
specialinvoke v.<org.apache.camel.util.StopWatch: void <init>()>();
v = virtualinvoke v.<org.apache.camel.component.file.GenericFileEndpoint: boolean isRecursive()>();
v = virtualinvoke v.<org.apache.camel.component.file.GenericFileEndpoint: org.apache.camel.component.file.GenericFileFilter getFilter()>();
v = virtualinvoke v.<org.apache.camel.component.file.GenericFileEndpoint: org.apache.camel.component.file.GenericFileFilter getAntFilter()>();
staticinvoke <org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy: void deleteLockFiles(java.io.File,boolean,java.lang.String,org.apache.camel.component.file.GenericFileFilter,org.apache.camel.component.file.GenericFileFilter,java.util.regex.Pattern,java.util.regex.Pattern)>(v, v, v, v, v, v, v);
v = virtualinvoke v.<org.apache.camel.util.StopWatch: long taken()>();
v = v cmp 1000L;
if v <= 0 goto label;
v = <org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.camel.util.StopWatch: long taken()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object,java.lang.Object)>("Prepared on startup by deleting orphaned lock files from: {} took {} millis to complete.", v, v);
label:
return;
}
public boolean acquireExclusiveReadLock(org.apache.camel.component.file.GenericFileOperations, org.apache.camel.component.file.GenericFile, org.apache.camel.Exchange) throws java.lang.Exception
{
org.slf4j.Logger v;
org.apache.camel.component.file.GenericFile v;
org.apache.camel.Exchange v;
java.io.File v;
org.apache.camel.component.file.GenericFileOperations v;
org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy v;
java.lang.Boolean v;
java.lang.String v, v, v;
boolean v, v;
v := @this: org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy;
v := @parameter: org.apache.camel.component.file.GenericFileOperations;
v := @parameter: org.apache.camel.component.file.GenericFile;
v := @parameter: org.apache.camel.Exchange;
v = v.<org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy: boolean markerFile>;
if v != 0 goto label;
return 1;
label:
v = staticinvoke <org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy: java.lang.String getLockFileName(org.apache.camel.component.file.GenericFile)>(v);
v = <org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String,java.lang.Object,java.lang.Object)>("Locking the file: {} using the lock file name: {}", v, v);
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
v = staticinvoke <org.apache.camel.util.FileUtil: boolean createNewFile(java.io.File)>(v);
v = staticinvoke <org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy: java.lang.String asReadLockKey(org.apache.camel.component.file.GenericFile,java.lang.String)>(v, "CamelFileLockFileAcquired");
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
interfaceinvoke v.<org.apache.camel.Exchange: void setProperty(java.lang.String,java.lang.Object)>(v, v);
v = staticinvoke <org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy: java.lang.String asReadLockKey(org.apache.camel.component.file.GenericFile,java.lang.String)>(v, "CamelFileLockFileName");
interfaceinvoke v.<org.apache.camel.Exchange: void setProperty(java.lang.String,java.lang.Object)>(v, v);
return v;
}
public void releaseExclusiveReadLockOnAbort(org.apache.camel.component.file.GenericFileOperations, org.apache.camel.component.file.GenericFile, org.apache.camel.Exchange) throws java.lang.Exception
{
org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy v;
org.apache.camel.component.file.GenericFile v;
org.apache.camel.Exchange v;
org.apache.camel.component.file.GenericFileOperations v;
v := @this: org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy;
v := @parameter: org.apache.camel.component.file.GenericFileOperations;
v := @parameter: org.apache.camel.component.file.GenericFile;
v := @parameter: org.apache.camel.Exchange;
virtualinvoke v.<org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy: void doReleaseExclusiveReadLock(org.apache.camel.component.file.GenericFileOperations,org.apache.camel.component.file.GenericFile,org.apache.camel.Exchange)>(v, v, v);
return;
}
public void releaseExclusiveReadLockOnRollback(org.apache.camel.component.file.GenericFileOperations, org.apache.camel.component.file.GenericFile, org.apache.camel.Exchange) throws java.lang.Exception
{
org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy v;
org.apache.camel.component.file.GenericFile v;
org.apache.camel.Exchange v;
org.apache.camel.component.file.GenericFileOperations v;
v := @this: org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy;
v := @parameter: org.apache.camel.component.file.GenericFileOperations;
v := @parameter: org.apache.camel.component.file.GenericFile;
v := @parameter: org.apache.camel.Exchange;
virtualinvoke v.<org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy: void doReleaseExclusiveReadLock(org.apache.camel.component.file.GenericFileOperations,org.apache.camel.component.file.GenericFile,org.apache.camel.Exchange)>(v, v, v);
return;
}
public void releaseExclusiveReadLockOnCommit(org.apache.camel.component.file.GenericFileOperations, org.apache.camel.component.file.GenericFile, org.apache.camel.Exchange) throws java.lang.Exception
{
org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy v;
org.apache.camel.component.file.GenericFile v;
org.apache.camel.Exchange v;
org.apache.camel.component.file.GenericFileOperations v;
v := @this: org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy;
v := @parameter: org.apache.camel.component.file.GenericFileOperations;
v := @parameter: org.apache.camel.component.file.GenericFile;
v := @parameter: org.apache.camel.Exchange;
virtualinvoke v.<org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy: void doReleaseExclusiveReadLock(org.apache.camel.component.file.GenericFileOperations,org.apache.camel.component.file.GenericFile,org.apache.camel.Exchange)>(v, v, v);
return;
}
protected void doReleaseExclusiveReadLock(org.apache.camel.component.file.GenericFileOperations, org.apache.camel.component.file.GenericFile, org.apache.camel.Exchange) throws java.lang.Exception
{
org.apache.camel.component.file.GenericFile v;
org.apache.camel.Exchange v;
org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy v;
java.lang.Boolean v, v;
java.lang.String v, v;
boolean v, v, v, v;
org.slf4j.Logger v, v;
java.io.File v;
org.apache.camel.component.file.GenericFileOperations v;
java.lang.Object v, v;
v := @this: org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy;
v := @parameter: org.apache.camel.component.file.GenericFileOperations;
v := @parameter: org.apache.camel.component.file.GenericFile;
v := @parameter: org.apache.camel.Exchange;
v = v.<org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy: boolean markerFile>;
if v != 0 goto label;
return;
label:
v = staticinvoke <org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy: java.lang.String asReadLockKey(org.apache.camel.component.file.GenericFile,java.lang.String)>(v, "CamelFileLockFileAcquired");
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(0);
v = interfaceinvoke v.<org.apache.camel.Exchange: java.lang.Object getProperty(java.lang.String,java.lang.Object,java.lang.Class)>(v, v, class "Ljava/lang/Boolean;");
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
v = staticinvoke <org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy: java.lang.String asReadLockKey(org.apache.camel.component.file.GenericFile,java.lang.String)>(v, "CamelFileLockFileName");
v = interfaceinvoke v.<org.apache.camel.Exchange: java.lang.Object getProperty(java.lang.String,java.lang.Class)>(v, class "Ljava/lang/String;");
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<java.io.File: boolean exists()>();
if v == 0 goto label;
v = <org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String,java.lang.Object)>("Unlocking file: {}", v);
v = staticinvoke <org.apache.camel.util.FileUtil: boolean deleteFile(java.io.File)>(v);
v = <org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy: org.slf4j.Logger LOG>;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String,java.lang.Object,java.lang.Object)>("Lock file: {} was deleted: {}", v, v);
label:
return;
}
public void setTimeout(long)
{
org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy v;
long v;
v := @this: org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy;
v := @parameter: long;
return;
}
public void setCheckInterval(long)
{
org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy v;
long v;
v := @this: org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy;
v := @parameter: long;
return;
}
public void setReadLockLoggingLevel(org.apache.camel.LoggingLevel)
{
org.apache.camel.LoggingLevel v;
org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy v;
v := @this: org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy;
v := @parameter: org.apache.camel.LoggingLevel;
return;
}
public void setMarkerFiler(boolean)
{
org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy v;
boolean v;
v := @this: org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy;
v := @parameter: boolean;
v.<org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy: boolean markerFile> = v;
return;
}
public void setDeleteOrphanLockFiles(boolean)
{
org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy v;
boolean v;
v := @this: org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy;
v := @parameter: boolean;
v.<org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy: boolean deleteOrphanLockFiles> = v;
return;
}
private static void deleteLockFiles(java.io.File, boolean, java.lang.String, org.apache.camel.component.file.GenericFileFilter, org.apache.camel.component.file.GenericFileFilter, java.util.regex.Pattern, java.util.regex.Pattern)
{
boolean v, v, v, v, v, v;
java.util.regex.Pattern v, v;
org.apache.camel.component.file.GenericFileFilter v, v;
int v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
org.slf4j.Logger v;
java.io.File v, v, v, v, v;
java.io.File[] v;
v := @parameter: java.io.File;
v := @parameter: boolean;
v := @parameter: java.lang.String;
v := @parameter: org.apache.camel.component.file.GenericFileFilter;
v := @parameter: org.apache.camel.component.file.GenericFileFilter;
v := @parameter: java.util.regex.Pattern;
v := @parameter: java.util.regex.Pattern;
v = virtualinvoke v.<java.io.File: java.io.File[] listFiles()>();
if v == null goto label;
v = lengthof v;
if v != 0 goto label;
label:
return;
label:
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<java.io.File: java.lang.String getName()>();
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>(".");
if v != 0 goto label;
if v != null goto label;
if v != null goto label;
if v != null goto label;
if v == null goto label;
label:
v = v;
v = virtualinvoke v.<java.io.File: java.lang.String getName()>();
v = virtualinvoke v.<java.lang.String: boolean endsWith(java.lang.String)>(".camelLock");
if v == 0 goto label;
v = virtualinvoke v.<java.io.File: java.lang.String getName()>();
v = virtualinvoke v.<java.io.File: java.lang.String getName()>();
v = virtualinvoke v.<java.lang.String: int length()>();
v = ".camelLock";
v = virtualinvoke v.<java.lang.String: int length()>();
v = v - v;
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int,int)>(0, v);
v = virtualinvoke v.<java.io.File: java.lang.String getParent()>();
if v == null goto label;
v = new java.io.File;
v = virtualinvoke v.<java.io.File: java.lang.String getParent()>();
specialinvoke v.<java.io.File: void <init>(java.lang.String,java.lang.String)>(v, v);
v = v;
goto label;
label:
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
v = v;
label:
v = staticinvoke <org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy: boolean acceptFile(java.io.File,java.lang.String,org.apache.camel.component.file.GenericFileFilter,org.apache.camel.component.file.GenericFileFilter,java.util.regex.Pattern,java.util.regex.Pattern)>(v, v, v, v, v, v);
if v == 0 goto label;
label:
v = virtualinvoke v.<java.io.File: java.lang.String getName()>();
v = virtualinvoke v.<java.lang.String: boolean endsWith(java.lang.String)>(".camelLock");
if v == 0 goto label;
v = <org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object)>("Deleting orphaned lock file: {}", v);
staticinvoke <org.apache.camel.util.FileUtil: boolean deleteFile(java.io.File)>(v);
goto label;
label:
if v == 0 goto label;
v = virtualinvoke v.<java.io.File: boolean isDirectory()>();
if v == 0 goto label;
staticinvoke <org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy: void deleteLockFiles(java.io.File,boolean,java.lang.String,org.apache.camel.component.file.GenericFileFilter,org.apache.camel.component.file.GenericFileFilter,java.util.regex.Pattern,java.util.regex.Pattern)>(v, 1, v, v, v, v, v);
label:
v = v + 1;
goto label;
label:
return;
}
private static boolean acceptFile(java.io.File, java.lang.String, org.apache.camel.component.file.GenericFileFilter, org.apache.camel.component.file.GenericFileFilter, java.util.regex.Pattern, java.util.regex.Pattern)
{
java.util.regex.Matcher v, v;
boolean v, v, v, v, v, v, v, v;
java.util.regex.Pattern v, v;
org.apache.camel.component.file.GenericFileFilter v, v;
org.apache.camel.component.file.GenericFile v;
long v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.io.File v, v, v, v;
v := @parameter: java.io.File;
v := @parameter: java.lang.String;
v := @parameter: org.apache.camel.component.file.GenericFileFilter;
v := @parameter: org.apache.camel.component.file.GenericFileFilter;
v := @parameter: java.util.regex.Pattern;
v := @parameter: java.util.regex.Pattern;
v = new org.apache.camel.component.file.GenericFile;
specialinvoke v.<org.apache.camel.component.file.GenericFile: void <init>()>();
virtualinvoke v.<org.apache.camel.component.file.GenericFile: void setEndpointPath(java.lang.String)>(v);
virtualinvoke v.<org.apache.camel.component.file.GenericFile: void setFile(java.lang.Object)>(v);
v = virtualinvoke v.<java.io.File: java.lang.String getName()>();
virtualinvoke v.<org.apache.camel.component.file.GenericFile: void setFileNameOnly(java.lang.String)>(v);
v = virtualinvoke v.<java.io.File: long length()>();
virtualinvoke v.<org.apache.camel.component.file.GenericFile: void setFileLength(long)>(v);
v = virtualinvoke v.<java.io.File: boolean isDirectory()>();
virtualinvoke v.<org.apache.camel.component.file.GenericFile: void setDirectory(boolean)>(v);
v = staticinvoke <org.apache.camel.util.FileUtil: boolean isAbsolute(java.io.File)>(v);
virtualinvoke v.<org.apache.camel.component.file.GenericFile: void setAbsolute(boolean)>(v);
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
virtualinvoke v.<org.apache.camel.component.file.GenericFile: void setAbsoluteFilePath(java.lang.String)>(v);
v = virtualinvoke v.<java.io.File: long lastModified()>();
virtualinvoke v.<org.apache.camel.component.file.GenericFile: void setLastModified(long)>(v);
v = staticinvoke <org.apache.camel.util.FileUtil: java.lang.String normalizePath(java.lang.String)>(v);
v = virtualinvoke v.<java.io.File: java.lang.String getPath()>();
v = <java.io.File: java.lang.String separator>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001\u0001");
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>(v);
if v == 0 goto label;
v = new java.io.File;
v = virtualinvoke v.<java.io.File: java.lang.String getPath()>();
v = <java.io.File: java.lang.String separator>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001\u0001");
v = staticinvoke <org.apache.camel.util.StringHelper: java.lang.String after(java.lang.String,java.lang.String)>(v, v);
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
v = v;
goto label;
label:
v = new java.io.File;
v = virtualinvoke v.<java.io.File: java.lang.String getPath()>();
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
v = v;
label:
v = virtualinvoke v.<java.io.File: java.lang.String getParent()>();
if v == null goto label;
v = virtualinvoke v.<java.io.File: java.lang.String getParent()>();
v = <java.io.File: java.lang.String separator>;
v = virtualinvoke v.<java.io.File: java.lang.String getName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String)>(v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001\u0001\u0001");
virtualinvoke v.<org.apache.camel.component.file.GenericFile: void setRelativeFilePath(java.lang.String)>(v);
goto label;
label:
v = virtualinvoke v.<java.io.File: java.lang.String getName()>();
virtualinvoke v.<org.apache.camel.component.file.GenericFile: void setRelativeFilePath(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.camel.component.file.GenericFile: java.lang.String getRelativeFilePath()>();
virtualinvoke v.<org.apache.camel.component.file.GenericFile: void setFileName(java.lang.String)>(v);
if v == null goto label;
v = interfaceinvoke v.<org.apache.camel.component.file.GenericFileFilter: boolean accept(org.apache.camel.component.file.GenericFile)>(v);
if v != 0 goto label;
return 0;
label:
v = virtualinvoke v.<java.io.File: boolean isDirectory()>();
if v == 0 goto label;
return 1;
label:
if v == null goto label;
v = interfaceinvoke v.<org.apache.camel.component.file.GenericFileFilter: boolean accept(org.apache.camel.component.file.GenericFile)>(v);
if v != 0 goto label;
return 0;
label:
if v == null goto label;
v = virtualinvoke v.<java.io.File: java.lang.String getName()>();
v = virtualinvoke v.<java.util.regex.Pattern: java.util.regex.Matcher matcher(java.lang.CharSequence)>(v);
v = virtualinvoke v.<java.util.regex.Matcher: boolean matches()>();
if v == 0 goto label;
return 0;
label:
if v == null goto label;
v = virtualinvoke v.<java.io.File: java.lang.String getName()>();
v = virtualinvoke v.<java.util.regex.Pattern: java.util.regex.Matcher matcher(java.lang.CharSequence)>(v);
v = virtualinvoke v.<java.util.regex.Matcher: boolean matches()>();
if v != 0 goto label;
return 0;
label:
return 1;
}
private static java.lang.String getLockFileName(org.apache.camel.component.file.GenericFile)
{
java.lang.String v, v;
org.apache.camel.component.file.GenericFile v;
v := @parameter: org.apache.camel.component.file.GenericFile;
v = virtualinvoke v.<org.apache.camel.component.file.GenericFile: java.lang.String getAbsoluteFilePath()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u.camelLock");
return v;
}
private static java.lang.String asReadLockKey(org.apache.camel.component.file.GenericFile, java.lang.String)
{
org.apache.camel.component.file.GenericFile v;
java.lang.String v, v, v, v;
v := @parameter: org.apache.camel.component.file.GenericFile;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.camel.component.file.GenericFile: java.lang.String getCopyFromAbsoluteFilePath()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.component.file.GenericFile: java.lang.String getCopyFromAbsoluteFilePath()>();
goto label;
label:
v = virtualinvoke v.<org.apache.camel.component.file.GenericFile: java.lang.String getAbsoluteFilePath()>();
label:
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001-\u0001");
return v;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/camel/component/file/strategy/MarkerFileExclusiveReadLockStrategy;");
<org.apache.camel.component.file.strategy.MarkerFileExclusiveReadLockStrategy: org.slf4j.Logger LOG> = v;
return;
}
}