--- /dev/null
+/*******************************************************************************\r
+ * ============LICENSE_START====================================================\r
+ * * org.onap.aaf\r
+ * * ===========================================================================\r
+ * * Copyright © 2017 AT&T Intellectual Property. All rights reserved.\r
+ * * ===========================================================================\r
+ * * Licensed under the Apache License, Version 2.0 (the "License");\r
+ * * you may not use this file except in compliance with the License.\r
+ * * You may obtain a copy of the License at\r
+ * * \r
+ * * http://www.apache.org/licenses/LICENSE-2.0\r
+ * * \r
+ * * Unless required by applicable law or agreed to in writing, software\r
+ * * distributed under the License is distributed on an "AS IS" BASIS,\r
+ * * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
+ * * See the License for the specific language governing permissions and\r
+ * * limitations under the License.\r
+ * * ============LICENSE_END====================================================\r
+ * *\r
+ * * ECOMP is a trademark and service mark of AT&T Intellectual Property.\r
+ * *\r
+ ******************************************************************************/\r
+package org.onap.aaf.authz.local;\r
+\r
+import java.io.File;\r
+import java.io.FileNotFoundException;\r
+import java.io.IOException;\r
+import java.io.RandomAccessFile;\r
+import java.nio.ByteBuffer;\r
+import java.nio.IntBuffer;\r
+import java.nio.MappedByteBuffer;\r
+import java.nio.channels.FileChannel;\r
+import java.nio.channels.FileChannel.MapMode;\r
+\r
+public class DataFile {\r
+ private RandomAccessFile rafile;\r
+ private FileChannel channel;\r
+ public MappedByteBuffer mapBuff;\r
+ private final File file;\r
+ private final String access;\r
+ \r
+ public DataFile(File file, String access) {\r
+ this.file = file;\r
+ this.access = access;\r
+ }\r
+ public void open() throws IOException {\r
+ if(!file.exists()) throw new FileNotFoundException();\r
+ rafile = new RandomAccessFile(file,access);\r
+ channel = rafile.getChannel();\r
+ mapBuff = channel.map("r".equals(access)?MapMode.READ_ONLY:MapMode.READ_WRITE,0,channel.size());\r
+ }\r
+ public void close() throws IOException {\r
+ if(channel!=null){channel.close();}\r
+ if(rafile!=null) {rafile.close();}\r
+ mapBuff = null;\r
+ }\r
+\r
+ public long size() throws IOException {\r
+ return channel.size();\r
+ }\r
+\r
+ private synchronized int load(Token t) {\r
+ int len = Math.min(mapBuff.limit()-t.next,t.buff.length);\r
+ if(len>0) {\r
+ mapBuff.position(t.next);\r
+ mapBuff.get(t.buff,0,len);\r
+ }\r
+ return len<0?0:len;\r
+ }\r
+ \r
+ public class Token {\r
+ private byte[] buff;\r
+ int pos, next, end;\r
+ \r
+ public Token(int size) {\r
+ buff = new byte[size];\r
+ pos = next = end = 0;\r
+ }\r
+ \r
+ public boolean pos(int to) {\r
+ pos = next = to;\r
+ return (end=load(this))>0;\r
+ }\r
+ \r
+ public boolean nextLine() {\r
+ end = load(this);\r
+ pos = next;\r
+ for(int i=0;i<end;++i) {\r
+ if(buff[i]=='\n') {\r
+ end = i;\r
+ next += i+1;\r
+ return true;\r
+ }\r
+ }\r
+ return false;\r
+ }\r
+ \r
+ public IntBuffer getIntBuffer() {\r
+ return ByteBuffer.wrap(buff).asIntBuffer();\r
+ }\r
+\r
+\r
+\r
+ public String toString() {\r
+ return new String(buff,0,end);\r
+ }\r
+ public class Field {\r
+ char delim;\r
+ int idx;\r
+ ByteBuffer bb;\r
+\r
+ public Field(char delimiter) {\r
+ delim = delimiter;\r
+ idx = 0;\r
+ bb = null;\r
+ }\r
+ \r
+ public Field reset() {\r
+ idx = 0;\r
+ return this;\r
+ }\r
+ \r
+ public String next() {\r
+ if(idx>=end)return null;\r
+ int start = idx;\r
+ byte c=0;\r
+ int endStr = -1;\r
+ while(idx<end && idx<buff.length && (c=buff[idx])!=delim && c!='\n') { // for DOS\r
+ if(c=='\r')endStr=idx;\r
+ ++idx;\r
+ }\r
+ \r
+ if(endStr<0) {\r
+ endStr=idx-start;\r
+ } else {\r
+ endStr=endStr-start;\r
+ }\r
+ ++idx;\r
+ return new String(buff,start,endStr);\r
+ }\r
+\r
+ public String at(int fieldOffset) {\r
+ int start;\r
+ byte c=0;\r
+ for(int count = idx = start = 0; idx<end && idx<buff.length; ++idx) {\r
+ if((c=buff[idx])==delim || c=='\n') {\r
+ if(count++ == fieldOffset) {\r
+ break;\r
+ }\r
+ start = idx+1;\r
+ }\r
+ }\r
+ return new String(buff,start,(idx-start-(c=='\r'?1:0)));\r
+ }\r
+ \r
+ public String atToEnd(int fieldOffset) {\r
+ int start;\r
+ byte c=0;\r
+ for(int count = idx = start = 0; idx<end && idx<buff.length; ++idx) {\r
+ if((c=buff[idx])==delim || c=='\n') {\r
+ if(count++ == fieldOffset) {\r
+ break;\r
+ }\r
+ start = idx+1;\r
+ }\r
+ }\r
+ \r
+ for(; idx<end && idx<buff.length && (c=buff[idx])!='\n'; ++idx) {\r
+ ++idx;\r
+ }\r
+ return new String(buff,start,(idx-start-((c=='\r' || idx>=end)?1:0)));\r
+ }\r
+\r
+ }\r
+\r
+ public int pos() {\r
+ return pos;\r
+ }\r
+ }\r
+\r
+ public File file() {\r
+ return file;\r
+ }\r
+ \r
+}\r
Code Review / aaf / authz.git / blobdiff