Vector<Driver> getDrivers() throws IOException { if (mDrivers == null) { mDrivers = new Vector<Driver>(); LineNumberReader r = new LineNumberReader(new FileReader("/proc/tty/drivers")); String l; while((l = r.readLine()) != null) { // Issue 3: // Since driver name may contain spaces, we do not extract driver name with split() String drivername = l.substring(0, 0x15).trim(); String[] w = l.split(" +"); if ((w.length >= 5) && (w[w.length-1].equals("serial"))) { Log.d(TAG, "Found new driver " + drivername + " on " + w[w.length-4]); mDrivers.add(new Driver(drivername, w[w.length-4])); } } r.close(); } return mDrivers; }
/** * 获取Mac */ private String getMac() { String macSerial = null; String str = null; try { Process pp = Runtime.getRuntime().exec("cat /sys/class/net/wlan0/address "); InputStreamReader ir = new InputStreamReader(pp.getInputStream()); LineNumberReader input = new LineNumberReader(ir); for (; null != str; ) { str = input.readLine(); if (str != null) { macSerial = str.trim();// 去空格 break; } } } catch (IOException ex) { // 赋予默认值 ex.printStackTrace(); } return macSerial; }
/** * Get PID from the {xtest.workdir}/ide.pid file. * * @return */ private String getPID() { String xtestWorkdir = System.getProperty("xtest.workdir"); if (xtestWorkdir == null) { fail("xtest.workdir property is not specified"); } File ideRunning = new File(xtestWorkdir, "ide.pid"); if (!ideRunning.exists()) { fail("Cannot find file containing PID of running IDE (" + ideRunning.getAbsolutePath()); } try { LineNumberReader reader = new LineNumberReader(new FileReader(ideRunning)); String pid = reader.readLine().trim(); log("PID = " + pid); return pid; } catch (Exception exc) { exc.printStackTrace(getLog()); fail("Exception rises when reading PID from ide.pid file"); } return ""; }
public static Result newSingleColumnStringResult(String colName, String contents) { Result result = Result.newSingleColumnResult(colName); LineNumberReader lnr = new LineNumberReader(new StringReader(contents)); while (true) { String line = null; try { line = lnr.readLine(); } catch (Exception e) {} if (line == null) { break; } result.getNavigator().add(new Object[]{ line }); } return result; }
public static TextTrackImpl parse(InputStream is) throws IOException { LineNumberReader r = new LineNumberReader(new InputStreamReader(is, "UTF-8")); TextTrackImpl track = new TextTrackImpl(); String numberString; while ((numberString = r.readLine()) != null) { String timeString = r.readLine(); String lineString = ""; String s; while (!((s = r.readLine()) == null || s.trim().equals(""))) { lineString += s + "\n"; } long startTime = parse(timeString.split("-->")[0]); long endTime = parse(timeString.split("-->")[1]); track.getSubs().add(new TextTrackImpl.Line(startTime, endTime, lineString)); } return track; }
public static Result newSingleColumnStringResult(String colName, String contents) { Result result = Result.newSingleColumnResult("OPERATION", Type.SQL_VARCHAR); LineNumberReader lnr = new LineNumberReader(new StringReader(contents)); while (true) { String line = null; try { line = lnr.readLine(); } catch (Exception e) {} if (line == null) { break; } result.getNavigator().add(new Object[]{ line }); } return result; }
public static List<LinuxSocketInfo> getSockets(String type) throws FileNotFoundException { final String jvmName = ManagementFactory.getRuntimeMXBean().getName(); final int index = jvmName.indexOf('@'); String pid = (jvmName.substring(0, index)); ArrayList<LinuxSocketInfo> sockets = new ArrayList<>(); String line; try(FileReader tcp = new FileReader("/proc/" + pid + "/net/"+type);LineNumberReader lnr = new LineNumberReader(tcp)) { lnr.readLine(); while ((line=lnr.readLine())!=null) { LinuxSocketInfo socketInfo =parseSocket(line.trim(),type); sockets.add(socketInfo); } } catch (Throwable e) { _logger.warn("read linux tcp file failed",e); } return sockets; }
@Override public void seek(Offset offset) { if (offset.getRecordOffset() < 0) { throw new IllegalArgumentException("Record offset must be greater than 0"); } try { if (offset.getRecordOffset() < reader.getLineNumber()) { this.reader = new LineNumberReader(new InputStreamReader(getFs().open(getFilePath()))); currentLine = null; } while ((currentLine = reader.readLine()) != null) { if (reader.getLineNumber() - 1 == offset.getRecordOffset()) { this.offset.setOffset(reader.getLineNumber()); return; } } this.offset.setOffset(reader.getLineNumber()); } catch (IOException ioe) { throw new ConnectException("Error seeking file " + getFilePath(), ioe); } }
/** * 根据ip地址获取mac地址 * @param ip * @return */ public String getMACAddress(String ip) { String str = ""; String macAddress = ""; try { Process p = Runtime.getRuntime().exec("nbtstat -A " + ip); InputStreamReader ir = new InputStreamReader(p.getInputStream()); LineNumberReader input = new LineNumberReader(ir); for (int i = 1; i < 100; i++) { str = input.readLine(); if (str != null) { if (str.indexOf("MAC Address") > 1) { macAddress = str.substring( str.indexOf("MAC Address") + 14, str.length()); break; } } } } catch (IOException e) { e.printStackTrace(); } return macAddress; }
private String getStringFromFile(String error) { try { File file=new File(error); BufferedReader bufferedReader=new BufferedReader(new FileReader(file)); LineNumberReader lineNumberReader=new LineNumberReader(bufferedReader); StringBuilder stringBuilder=new StringBuilder(); String line; while ((line = lineNumberReader.readLine()) != null) { stringBuilder.append(line).append("\n"); } return stringBuilder.toString(); } catch (IOException e) { e.printStackTrace(); LogUtil.e("从文件中获取信息失败"+e.getMessage()); } return null; }
private void performLoad ( final Reader stream ) { final Set<ConnectionDescriptor> result = new HashSet<ConnectionDescriptor> (); final LineNumberReader reader = new LineNumberReader ( stream ); String line; try { while ( ( line = reader.readLine () ) != null ) { final ConnectionDescriptor info = convert ( line ); if ( info != null ) { result.add ( info ); } } } catch ( final IOException e ) { } setConnections ( result ); }
/** * convert a Throwable into an array of Strings * @param throwable * @return string representation of the throwable */ public static String[] getThrowableStrRep(Throwable throwable) { StringWriter sw = new StringWriter(); PrintWriter pw = new PrintWriter(sw); throwable.printStackTrace(pw); pw.flush(); LineNumberReader reader = new LineNumberReader(new StringReader(sw.toString())); ArrayList<String> lines = new ArrayList<String>(); try { String line = reader.readLine(); while (line != null) { lines.add(line); line = reader.readLine(); } } catch (IOException ex) { lines.add(ex.toString()); } String[] rep = new String[lines.size()]; lines.toArray(rep); return rep; }
public static String loadOptions(FileReader fr, String filename) { LineNumberReader lnr = new LineNumberReader(fr); Group.restoreAllDefaults(); String line; try { while ((line = lnr.readLine()) != null) { String reason = Group.root.setOption(line); if (reason != null) { System.err.println("Option "+line+ " at line "+lnr.getLineNumber()+ " ignored: "+reason); } } } catch (IOException e) { Group.restoreAllDefaults(); return ("IO Error reading "+filename+ " at line "+lnr.getLineNumber()); } return null; }
private Vector<Driver> getDrivers() throws IOException { if (mDrivers == null) { mDrivers = new Vector<>(); LineNumberReader r = new LineNumberReader(new FileReader("/proc/tty/drivers")); String line; while ((line = r.readLine()) != null) { // 设备名称可能存在空格 // we do not extract driver name with split() 21 String drivername = line.substring(0, 0x15).trim(); String[] w = line.split(" +"); if ((w.length >= 5) && ("serial".equals(w[w.length - 1]))) { mDrivers.add(new Driver(drivername, w[w.length - 4])); } } r.close(); } return mDrivers; }
/** * Count and return data pjson line. * @return Total line number */ public long countDataPJson() { Path pathInZip = pathMap.get(DATA_PJSON); try (BufferedReader bufReader = Files.newBufferedReader(pathInZip, Charsets.UTF_8)) { LineNumberReader reader = new LineNumberReader(bufReader); while (true) { long readByte = reader.skip(SKIP_DATA_NUM); if (readByte == 0) { break; } } return reader.getLineNumber(); } catch (IOException e) { throw PersoniumCoreException.Common.FILE_IO_ERROR.params("read data pjson from snapshot file").reason(e); } }
Vector<Driver> getDrivers() throws IOException { if (mDrivers == null) { mDrivers = new Vector<Driver>(); LineNumberReader r = new LineNumberReader(new FileReader("/proc/tty/drivers")); String l; while ((l = r.readLine()) != null) { // Issue 3: // Since driver name may contain spaces, we do not extract driver name with split() String drivername = l.substring(0, 0x15).trim(); String[] w = l.split(" +"); if ((w.length >= 5) && (w[w.length - 1].equals("serial"))) { Log.d(TAG, "Found new driver " + drivername + " on " + w[w.length - 4]); mDrivers.add(new Driver(drivername, w[w.length - 4])); } } r.close(); } return mDrivers; }
/** * Read a script from the provided {@code LineNumberReader}, using the supplied * comment prefix and statement separator, and build a {@code String} containing * the lines. * <p>Lines <em>beginning</em> with the comment prefix are excluded from the * results; however, line comments anywhere else — for example, within * a statement — will be included in the results. * @param lineNumberReader the {@code LineNumberReader} containing the script * to be processed * @param commentPrefix the prefix that identifies comments in the SQL script — * typically "--" * @param separator the statement separator in the SQL script — typically ";" * @return a {@code String} containing the script lines * @throws IOException in case of I/O errors */ public static String readScript(LineNumberReader lineNumberReader, String commentPrefix, String separator) throws IOException { String currentStatement = lineNumberReader.readLine(); StringBuilder scriptBuilder = new StringBuilder(); while (currentStatement != null) { if (commentPrefix != null && !currentStatement.startsWith(commentPrefix)) { if (scriptBuilder.length() > 0) { scriptBuilder.append('\n'); } scriptBuilder.append(currentStatement); } currentStatement = lineNumberReader.readLine(); } appendSeparatorToScriptIfNecessary(scriptBuilder, separator); return scriptBuilder.toString(); }
public static void main(String[] args) throws IOException { final byte[] bytes2 = Base64.getDecoder().decode("YnsLfVSN"); System.out.println(new HexBinaryAdapter().marshal(bytes2)); if(true) { return; } String filename = "/Users/esinev/Library/Preferences/IdeaIC15/scratches/docker-create-endpoint.txt"; LineNumberReader reader = new LineNumberReader(new FileReader(filename)); String line; while (( line = reader.readLine()) != null) { // System.out.println(line); if(line.length() >= 50 && line.charAt(48) == ' ' && line.charAt(49) == ' ') { String hex = line.substring(0, 49); final byte[] bytes = new HexBinaryAdapter().unmarshal(hex.replace(" ", "")); String value = new String(bytes); System.out.print(value); // line = line.substring(50); } else { System.out.println(line); } // System.out.println(line); } }
/** * Initializes the XML reader. * * @param stream the input for the XML data. * * @throws java.io.IOException * if an I/O error occurred */ public StdXMLReader(InputStream stream) throws IOException { PushbackInputStream pbstream = new PushbackInputStream(stream); StringBuffer charsRead = new StringBuffer(); Reader reader = this.stream2reader(stream, charsRead); this.currentReader = new StackedReader(); this.readers = new Stack(); this.currentReader.lineReader = new LineNumberReader(reader); this.currentReader.pbReader = new PushbackReader(this.currentReader.lineReader, 2); this.currentReader.publicId = ""; try { this.currentReader.systemId = new URL("file:."); } catch (MalformedURLException e) { // never happens } this.startNewStream(new StringReader(charsRead.toString())); }
/** * Parse a resource file into an RSLP stemmer description. * @return a Map containing the named Steps in this description. */ protected static Map<String,Step> parse(Class<? extends RSLPStemmerBase> clazz, String resource) { // TODO: this parser is ugly, but works. use a jflex grammar instead. try { InputStream is = clazz.getResourceAsStream(resource); LineNumberReader r = new LineNumberReader(new InputStreamReader(is, StandardCharsets.UTF_8)); Map<String,Step> steps = new HashMap<>(); String step; while ((step = readLine(r)) != null) { Step s = parseStep(r, step); steps.put(s.name, s); } r.close(); return steps; } catch (IOException e) { throw new RuntimeException(e); } }
public void testPartialReadAndLineNo() throws IOException { MockLineReader r = new MockLineReader(5); LineNumberReader lr = new LineNumberReader(r); char[] buf = new char[5]; lr.read(buf, 0, 5); assertEquals(0, lr.getLineNumber(), "LineNumberReader start with line 0"); assertEquals(1, r.getLineNumber(), "MockLineReader start with line 1"); assertEquals(new String(buf), "Line "); String l1 = lr.readLine(); assertEquals(l1, "1", "Remaining of the first line"); assertEquals(1, lr.getLineNumber(), "Line 1 is read"); assertEquals(1, r.getLineNumber(), "MockLineReader not yet go next line"); lr.read(buf, 0, 4); assertEquals(1, lr.getLineNumber(), "In the middle of line 2"); assertEquals(new String(buf, 0, 4), "Line"); ArrayList<String> ar = lr.lines() .peek(l -> assertEquals(lr.getLineNumber(), r.getLineNumber())) .collect(ArrayList::new, ArrayList::add, ArrayList::addAll); assertEquals(ar.get(0), " 2", "Remaining in the second line"); for (int i = 1; i < ar.size(); i++) { assertEquals(ar.get(i), "Line " + (i + 2), "Rest are full lines"); } }
/** * Prints out a note about the GPL if ProGuard is linked against unknown * code. */ public static void check() { ByteArrayOutputStream out = new ByteArrayOutputStream(); new Exception().printStackTrace(new PrintStream(out)); LineNumberReader reader = new LineNumberReader( new InputStreamReader( new ByteArrayInputStream(out.toByteArray()))); Set unknownPackageNames = unknownPackageNames(reader); if (unknownPackageNames.size() > 0) { String uniquePackageNames = uniquePackageNames(unknownPackageNames); System.out.println("ProGuard is released under the GNU General Public License. You therefore"); System.out.println("must ensure that programs that link to it ("+uniquePackageNames+"...)"); System.out.println("carry the GNU General Public License as well. Alternatively, you can"); System.out.println("apply for an exception with the author of ProGuard."); } }
private long parseDataStartTimeFromAeDatFile(AEFileInputStream aeis) throws FileNotFoundException, IOException { // # DataStartTime: System.currentTimeMillis() 1481800498468 File f = aeis.getFile(); LineNumberReader is = new LineNumberReader(new InputStreamReader(new FileInputStream(f))); while (is.getLineNumber() < 5000) { String line = is.readLine(); if (line.contains("DataStartTime")) { Scanner s = new Scanner(line); s.next(); s.next(); s.next(); aeDatStartTimeMs = s.nextLong(); return aeDatStartTimeMs; } } log.warning("could not find data start time DataStartTime in AEDAT file"); return -1; }
public static JsonObject getJsonErrorMessage(String info) throws IOException { JsonObject jInfo = new JsonObject(); // Error message here comes from ZCash 1.0.7+ and is like: //zcash-cli getinfo //error code: -28 //error message: //Loading block index... LineNumberReader lnr = new LineNumberReader(new StringReader(info)); int errCode = Integer.parseInt(lnr.readLine().substring(11).trim()); jInfo.set("code", errCode); lnr.readLine(); jInfo.set("message", lnr.readLine().trim()); return jInfo; }
/** * 通过Wifi获取MAC ADDRESS作为DEVICE ID * 缺点：如果Wifi关闭的时候，硬件设备可能无法返回MAC ADDRESS.。 * @return */ public static String getMacAddress() { String macSerial = null; String str = ""; try { Process pp = Runtime.getRuntime().exec("cat /sys/class/net/wlan0/address "); InputStreamReader ir = new InputStreamReader(pp.getInputStream()); LineNumberReader input = new LineNumberReader(ir); for (; null != str;) { str = input.readLine(); if (str != null) { macSerial = str.trim();// 去空格 break; } } } catch (IOException ex) { // 赋予默认值 ex.printStackTrace(); } return macSerial; }
public List<String[]> getLineToData(Path path, int lineNo) throws IOException { BufferedReader br = new BufferedReader(new InputStreamReader(fs.open(path))); LineNumberReader reader = new LineNumberReader(br); reader.setLineNumber(lineNo); String str = ""; List<String[]> lls = new ArrayList<String[]>(); if (lineNo == 1 && (str = reader.readLine()) != null) { if(str.indexOf(",")>0) { lls.add(str.split(",")); }else{ lls.add(str.split("\t")); } return lls; } else if (lineNo >= 2 && (str = reader.readLine()) != null) { while ((str = reader.readLine()) != null) { if(str.indexOf(",")>0) { lls.add(str.split(",")); }else { lls.add(str.split("\t")); } } return lls; } else { System.out.println("This is a EMPTY File"); return null; } }
private void compareTextFiles(File goledFile, File outFile) throws IOException { InputStreamReader goldenIsr = new InputStreamReader(new FileInputStream(goledFile),"UTF-8"); LineNumberReader goldenReader = new LineNumberReader(goldenIsr); InputStreamReader isr = new InputStreamReader(new FileInputStream(outFile),"UTF-8"); LineNumberReader reader = new LineNumberReader(isr); String goldenLine = ""; String line = ""; while(goldenLine != null && goldenLine.equals(line)) { goldenLine = goldenReader.readLine(); line = reader.readLine(); } assertEquals("File "+goledFile.getAbsolutePath()+" and "+outFile.getAbsolutePath()+" differs on line "+goldenReader.getLineNumber(), goldenLine, line); }
/** * Default constructor for TestUtil usage. * Sections start at lines beginning with any non-space character. * SQL comment lines are ignored. */ public LineGroupReader(LineNumberReader reader) { this.sectionContinuations = defaultContinuations; this.sectionStarts = ValuePool.emptyStringArray; this.ignoredStarts = defaultIgnoredStarts; this.reader = reader; try { getSection(); } catch (Exception e) {} }
/** * Constructor for sections starting with specified strings. */ public LineGroupReader(LineNumberReader reader, String[] sectionStarts) { this.sectionStarts = sectionStarts; this.sectionContinuations = ValuePool.emptyStringArray; this.ignoredStarts = ValuePool.emptyStringArray; this.reader = reader; try { getSection(); } catch (Exception e) {} }
DDLStatement getNextStatement(LineNumberReader reader, VoltCompiler compiler) throws VoltCompiler.VoltCompilerException { DDLStatement retval = new DDLStatement(); try { String stmt = ""; // skip over any empty lines to read first real line while (stmt.equals("") || stmt.startsWith("--")) { stmt = reader.readLine(); if (stmt == null) return null; stmt = stmt.trim(); } // record the line number retval.lineNo = reader.getLineNumber(); // add all lines until one ends with a semicolon while ((stmt.endsWith(";") == false) && (stmt.endsWith(";\n") == false)) { String newline = reader.readLine(); if (newline == null) { String msg = "Schema file ended mid statment (no semicolon found)"; throw compiler.new VoltCompilerException(msg, retval.lineNo); } newline = newline.trim(); if (newline.equals("")) continue; if (newline.startsWith("--")) continue; stmt += newline + "\n"; } retval.statement = stmt; } catch (IOException e) { throw compiler.new VoltCompilerException("Unable to read from file"); } return retval; }
/** * */ public void testReadFileFromJarfile() throws IOException { String catalog0 = this.catalog.serialize(); assertTrue(catalog0.length() > 0); String catalog1 = JarReader.readFileFromJarfile(this.jarPath.getAbsolutePath(), CatalogUtil.CATALOG_FILENAME); assertTrue(catalog1.length() > 0); assertEquals(catalog0.length(), catalog1.length()); LineNumberReader reader0 = new LineNumberReader(new CharArrayReader(catalog0.toCharArray())); LineNumberReader reader1 = new LineNumberReader(new CharArrayReader(catalog1.toCharArray())); try { int lines = 0; while (reader0.ready()) { assertEquals(reader0.ready(), reader1.ready()); assertEquals(reader0.readLine(), reader1.readLine()); lines++; } assertTrue(lines > 0); reader0.close(); reader1.close(); } catch (Exception ex) { ex.printStackTrace(); assertTrue(false); } }
