How to use get_addr method of end.end.end Package

Best Unobtainium_ruby code snippet using end.end.end.get_addr

Manager.java

Source:Manager.java Github

copy

Full Screen

...355 * @throws IOException 356 */357 private void listen() throws IOException {358 try{359 _log.info("start to create server socket: " + _self.get_addr().toString());360 SSLServerSocketFactory servFac = _sslCtx.getServerSocketFactory();361 _server = (SSLServerSocket) servFac.createServerSocket(_self.get_addr().getPort(), 4, _self.get_addr().getAddress());362 _server.setSoTimeout(10000);// accept unblock every 5 secs363 ((SSLServerSocket)_server).setNeedClientAuth(true); //require client auth364 }catch(IOException ex){365 _log.error("create server socket failure: " + _self.get_addr().getAddress().getHostAddress() + ":" + _self.get_addr().getPort());366 }367 } 368 /**369 * init VoteContent;370 * specify who's eligible;371 * specify deadline 372 * set two timer for registration and vote-casting373 * 374 * @throws SignatureException 375 * @throws NoSuchAlgorithmException 376 * @throws InvalidKeyException 377 * @throws IOException 378 */379 private void prepare() throws InvalidKeyException, NoSuchAlgorithmException, SignatureException, IOException {380 ///init VoteContent first381 _log.info("Manager: prepare start");382 Vector<String> briefAndOptions = _ui.getContentAndOptions();383 String brief = briefAndOptions.remove(0);384 Vector<String> options = briefAndOptions; 385 386 String sessionId = String.valueOf(new Random().nextLong());387 388 _voteContent = new VoteContent();389 _voteContent.init(sessionId, brief, options.toArray(new String[0]), _priKey);390 391 Date deadline = _ui.getDeadline();392 _voteContent.set_deadline(deadline);393 394 Date regDeadline = _ui.getRegDeadline();395 _voteContent.set_regDeadline(regDeadline);396 397 String curveName = _prop.getProperty(PROP_CURVENAME);398 _voteContent.set_CurveName(curveName);399 400 _eliRule = _ui.getEligibleRule(); 401 402 ///set timers403 Calendar c = Calendar.getInstance(TimeZone.getTimeZone(Utility.TIMEZONE_STR));404 long seconds = (regDeadline.getTime() - c.getTime().getTime())/1000;405 Thread rtt = new RegTimerThread(seconds);406 rtt.setDaemon(true);407 rtt.start();408 409 seconds = (deadline.getTime() - c.getTime().getTime()) / 1000;410 Thread vtt = new VoteTimerThread(seconds);411 vtt.setDaemon(true);412 vtt.start();413 }414 415 public void run() throws RegisterException, InvalidKeyException, NoSuchAlgorithmException, SignatureException, IOException {416 _log.info("start to run");417 prepare(); //prepare vote brief, options, eligibility, deadline418 419 serve(); //serve the incoming request420 }421 422 private void serve() {423 _log.info("ready to serve incoming connections");424 while(true){ 425 SSLSocket soc;426 try{ 427 soc = (SSLSocket)_server.accept();428 Utility.logInConnection(soc, _self.get_id()); //log connection429 Thread thr = new ServerThread(soc);430 thr.start();431 }catch(SocketTimeoutException e){432 if(_bStopServing){433 _log.info("Server stop serving...");434 break;435 }436 }catch(IOException ex){437 _log.warn("server socket accpet failure", ex);438 }catch (CertificateException ex) {439 _log.warn("server socket verification failure", ex); 440 } 441 }442 }443 444 /**445 * stop registration,446 * choose some voters to upgrade to Bulletin, send `Upgrade' to them,447 * and send `StartGenPubKey' to bulletins448 * @throws UnsupportedEncodingException 449 * @throws SignatureException 450 * @throws NoSuchAlgorithmException 451 * @throws InvalidKeyException 452 */453 private void stopRegistration() throws InvalidKeyException, NoSuchAlgorithmException, SignatureException, UnsupportedEncodingException{454 _bRunRegistration = false;455 _log.info("stop Registration");456 int authNum = Integer.parseInt(_prop.getProperty(PROP_AUTH_NUMBER));457 //TODO : use some digest alg to determine which voter to be authority458 if(authNum > _voters.size()){459 _log.warn("We didn't got enough voters involved");460 _bStopServing = true;461 return;462 }463 for(int i=0; i<authNum; ++i){464 VoterInfo vi = _voters.get(i);465 _log.debug("Promote: " + vi.get_id());466 _authorities.add(new AuthorityInfo(vi.get_addr(), vi.get_id()));467 }468 469 ///send `Upgrade' to these to-be-authorities470 Document upgradeDoc = new Document(new Element(Manager.UPGRADE));471 Element upRoot = upgradeDoc.getRootElement();472 Element eBuls = new Element(Manager.UPGRADE_BULLETINS); 473 for(int i=0; i<authNum; ++i){474 AuthorityInfo ainfo = _authorities.get(i);475 Element eAddr = new Element(Manager.UPGRADE_BULLETINS_ADDR);476 eAddr.setAttribute(Manager.UPGRADE_BULLETINS_ADDR_ID, ainfo.get_authId());477 eAddr.setText(ainfo.get_addr().toString());478 eBuls.addContent(eAddr);479 }480 upRoot.addContent(eBuls);481 Element eVoters = new Element(Manager.UPGRADE_VOTERS);482 for(int i=0; i<_voters.size(); ++i){483 VoterInfo vinfo = _voters.get(i);484 Element eAddr = new Element(Manager.UPGRADE_VOTERS_ADDR);485 eAddr.setAttribute(Manager.UPGRADE_BULLETINS_ADDR_ID, vinfo.get_id());486 eAddr.setText(vinfo.get_addr().toString());487 eVoters.addContent(eAddr);488 }489 upRoot.addContent(eVoters);490 Element eCurve = new Element(Manager.UPGRADE_CURVENAME);491 eCurve.setText(_prop.getProperty(Manager.PROP_CURVENAME));492 upRoot.addContent(eCurve);493 494 //create sig495 String serialXML = Utility.XMLElemToString(eBuls, eVoters, eCurve);496 String sig64 = Utility.genSignature(_priKey, serialXML);497 Element eSig = new Element(Manager.UPGRADE_SIG);498 eSig.setText(sig64); 499 upRoot.addContent(eSig);500 ///create `Upgrade' doc,,,done501 502 ///send doc to authorities, make sure they reply [sync way]503 Utility.syncSendXMLDocToPeer(upgradeDoc, _self.get_id(),504 _authorities, _sslCtx);505 506 ///send `StartGenPubKey' to authorities507 Document startDoc = new Document(new Element(Manager.STARTGENPUBKEY));508 for(AuthorityInfo ainfo : _authorities){509 Utility.sendXMLDocToPeer(startDoc, _self.get_id(),510 ainfo.get_addr(), ainfo.get_authId(), _sslCtx);511 }512 }513 514 /**515 * stop vote casting,516 * send `VoteEnd' to bulletins517 */518 private void stopVoteCasting(){519 _bRunVoting = false;520 521 _log.info("stop VoteCasting");522 Document docEnd = new Document(new Element(Manager.VOTEEND));523 for(AuthorityInfo ainfo : _authorities){524 Utility.sendXMLDocToPeer(docEnd, _self.get_id(),525 ainfo.get_addr(), ainfo.get_authId(), _sslCtx);526 }527 }528} ...

Full Screen

Full Screen

DataGenerator.java

Source:DataGenerator.java Github

copy

Full Screen

1import com.github.javafaker.Faker;2import com.github.javafaker.service.FakeValuesService;3import com.github.javafaker.service.RandomService;4import java.text.DateFormat;5import java.text.ParseException;6import java.text.SimpleDateFormat;7import java.time.Instant;8import java.util.*;9import java.util.regex.Matcher;10import java.util.regex.Pattern;11public class DataGenerator {12 private static final int Random_num = new Random().nextInt();13 private static final Instant beginTime = Instant.parse("2020-01-01T12:00:00.00Z");14 private static final Faker faker = new Faker(new Locale("zh-CN"));15 public static final String allChar = "0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ";16 public static final String letterChar = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ";17 public static final String upperLetterChar = "ABCDEFGHIJKLMNOPQRSTUVWXYZ";18 public static final String lowerLetterChar = "abcdefghijklmnopqrstuvwxyz";19 public static final String numberChar = "0123456789";20 public static final String numberLowerLetterChar = "0123456789abcdefghijklmnopqrstuvwxyz";21 public static final String numberUpperLetterChar = "0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZ";22 public static final DateFormat fmt =new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");23 public static final FakeValuesService fakeValuesService = new FakeValuesService(24 new Locale("en-GB"), new RandomService());25// public DataGenerator2(ArrayList<String> column_list) {26//27// }28 public static enum ColumnType {29 INT,30 VARCHAR,31 DATE32 }33 public DataGenerator(String args)34 {};35 public static StringJoiner get_all(ArrayList<String> column_list, String delimiter) throws Exception {36// StringBuilder sb = new StringBuilder();37 StringJoiner sb = new StringJoiner(delimiter, "", "\n");38 // 出现多线程问题（between抛异常）尝试添加锁，39// synchronized (DataGenerator.class) {40 for (String i: column_list) {41 List<String> result = Arrays.asList(i.split(","));42 String columnType = result.get(0);43// ColumnType x = result.get(0);44 switch (columnType) {45 default:46 int num = Integer.parseInt(result.get(1));47 sb.add(DataGenerator.getRandomALLChar(num));48 break;49 case "int" :50 int num3 = Integer.parseInt(result.get(1));51 sb.add(DataGenerator.get_Integer(num3));52 break;53 case "varchar" :54 int num2 = Integer.parseInt(result.get(1));55 sb.add(DataGenerator.getRandomALLChar(num2));56 break;57// case "date" :58// String start = result.get(1);59// String end = result.get(2);60// sb.add(DataGenerator.between(start, end));61// break;62 case "name" :63 sb.add(DataGenerator.get_Name());64 break;65 case "quote" :66 sb.add(DataGenerator.get_Quote());67 break;68 case "telephone" :69 sb.add(DataGenerator.get_Tel());70 break;71 case "address" :72 sb.add(DataGenerator.get_Addr());73 break;74 }75 }76// }77 // 获得 column list, 构造78 return sb;79 }80 public static String getRandomNumberChar(int n) {81 StringBuilder sb = new StringBuilder();82 Random random = new Random();83 for(int i = 0; i < n; i++) { sb.append( numberChar.charAt( random.nextInt( numberChar.length() ) ) );}84 return sb.toString();85 };86 public static String getRandomALLChar(int n) {87 StringBuilder sb = new StringBuilder();88 Random random = new Random();89 for(int i = 0; i < n; i++) { sb.append( allChar.charAt( random.nextInt( allChar.length() ) ));}90 return sb.toString();91 }92 public static String getRandomALLChar2(int n) {93 // 没有 原生的快，数量级的差距94// FakeValuesService fakeValuesService = new FakeValuesService(95// new Locale("en-GB"), new RandomService());96// return fakeValuesService.regexify(String.format("[a-z1-9]{%s}", n));97 return fakeValuesService.letterify(String.format("[a-z]{%s}", n));98// Matcher alphaNumericMatcher = Pattern.compile("[a-z1-9]{10}").matcher(alphaNumericString);99 }100 public static String get_Integer(int num) {101 return String.valueOf(faker.number().randomNumber(num, true));102 }103 public static String get_date(String start, String end) throws ParseException {104 Date from = fmt.parse(start);105 Date to = fmt.parse(end);106 return String.valueOf(faker.date().between(from, to));107 }108 public static String get_String(int num) {109 return faker.name().username();110 }111 public static String get_Quote() {112 return faker.rickAndMorty().quote();113 }114// public static String between(String start, String end) throws IllegalArgumentException, ParseException {115// synchronized (DataGenerator.class) {116//117// Date from = fmt.parse(start);118// Date to = fmt.parse(end);119// if (to.before(from)) {120// throw new IllegalArgumentException("Invalid date range, the upper bound date is before the lower bound.");121// } else if (from.equals(to)) {122// return end;123// } else {124// long offsetMillis = faker.random().nextLong(to.getTime() - from.getTime());125// Date new_date = new Date(from.getTime() + offsetMillis);126// return fmt.format(new_date);127// }128// }129//}130 public static String get_Name() {131 return faker.name().fullName();132 }133 public static String get_Addr() {134 return faker.address().city();135 }136 public static String get_Tel() {137 return faker.phoneNumber().cellPhone();138 }139 public static void main(String[] args) throws ParseException {140// DataGenerator2 x = DataGenerator2;141 DateFormat fmt =new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");142// String xx = DataGenerator.between("2010-01-01 10:00:00","2020-12-12 10:00:00");143// System.out.println(String.format("%s",144// xx));145 // 方法性能对比146 //1 耗时：42147 //2 耗时：20148 long s = System.currentTimeMillis();149 for (int i = 0; i < 100000; i++) {150// String num1 = DataGenerator.getRandomNumberChar(8);151 String num1 = DataGenerator.getRandomALLChar(8);152 }153 System.out.println("1 耗时：" + (System.currentTimeMillis()-s));154 long s2 = System.currentTimeMillis();155 for (int i = 0; i < 100000; i++) {156// String num2 = DataGenerator.get_Integer(8);157 String num1 = DataGenerator.getRandomALLChar2(8);158 }159 System.out.println("2 耗时：" + (System.currentTimeMillis()-s2));160// Faker faker = new Faker(new Locale("zh-CN"));161// faker.date().between()162// StringBuilder sb = new StringBuilder();163// sb.append(x.get_Integer(8));164// sb.append(x.get_Quote());165// sb.append(x.get_String(8));166//167// StringJoiner sj = new StringJoiner(",", "", "\n");168// sj.add(x.get_Integer(8));169// sj.add(x.get_Integer(8));170// sj.add(x.get_Quote());171// sj.add(x.getRandomALLChar(8));172//173// System.out.println(String.format("%s",174// sj));175// System.out.println(String.format("%s\n%s",176// x.get_Integer(8), x.get_String(2)));177// Faker faker = new Faker(new Locale("zh-CN"));178// faker.date().between()179//180// String name = faker.name().fullName(); // Miss Samanta Schmidt181// String firstName = faker.name().firstName(); // Emory182// String lastName = faker.name().lastName(); // Barton183//184// String streetAddress = faker.address().streetAddress(); // 60018 Sawayn Brooks Suite 449185//186// String streetName = faker.address().streetName();187// String number = faker.address().buildingNumber();188// String city = faker.address().city();189// String country = faker.address().country();190//191// System.out.println(String.format("%s\n%s\n%s\n%s",192// number,193// streetName,194// city,195// country));196 }197}...

Full Screen

Full Screen

T.java

Source:T.java Github

copy

Full Screen

...33public class T {34 static {35 Native.register("test");36 }37 public static final Pointer long10pow = T.get_addr("long10pow");38 public static final Pointer pow2 = T.get_addr("pow2");39 public static final Pointer pow2len = T.get_addr("pow2len");40 public static final Pointer fnBlocks = T.get_addr("fnBlocks");41 public static final Pointer fdBlocks = T.get_addr("fdBlocks");42 public static final Pointer fnLen = T.get_addr("fnLen");43 public static final Pointer fdLen = T.get_addr("fdLen");44 public static final Pointer s = T.get_addr("s");45 public static final Pointer pChars = T.get_addr("pChars");46 public static final Pointer qChars = T.get_addr("qChars");47 public static final Pointer pBlocks = T.get_addr("pBlocks");48 public static final Pointer qBlocks = T.get_addr("qBlocks");49 public static final StructBlockBuffer p = new StructBlockBuffer(T.get_addr("p"));50 public static final StructBlockBuffer q = new StructBlockBuffer(T.get_addr("q"));51 public static final Pointer curpow = T.get_addr("curpow");52 public static final Pointer diff_high = T.get_addr("diff_high");53 public static final Pointer diff_hi = T.get_addr("diff_hi");54 public static final Pointer diff_lo = T.get_addr("diff_lo");55 public static final Pointer ieeeBits = T.get_addr("ieeeBits");56 public static final Pointer infBits = T.get_addr("infBits");57 public static final Pointer supBits = T.get_addr("supBits");58 public static native Pointer get_addr(String var);59 public static native int get_num_digit_blocks();60 public static native void diff_add_mult(long x, long y);61 public static native void add_mult_pd(int n, Pointer p, Pointer fd);62 public static native void diff_sub_mult(long x, long y);63 public static native void sub_mult_qn(int n, Pointer q, Pointer fn);64 public static native void diff_mult_this_by(long x);65 public static native int multiply_mod_ten(Pointer dst, Pointer src, int srcLen, long m);66 public static native long mul_1(Pointer dst, Pointer src, int srcLen, long m);67 public static native int init_mult(Pointer dst, int e, long m);68 public static native void init_f(long fBits);69 public static native void loop_init_f(int count, long[] fBits);70 public static native char get_s(int i);71 public static native long get_partial_block(Pointer p, int l);72 public static native long get_full_block(Pointer p);...

Full Screen

Full Screen

get_addr

Using AI Code Generation

copy

Full Screen

1 @addr = Socket.getaddrinfo('localhost', 'http')[0][3]2 @addr = Socket.getaddrinfo('localhost', 'http')[0][3]3 @addr = Socket.getaddrinfo('localhost', 'http')[0][3]4 @addr = Socket.getaddrinfo('localhost', 'http')[0][3]5 @addr = Socket.getaddrinfo('localhost', 'http')[0][3]

Full Screen

Full Screen

get_addr

Using AI Code Generation

copy

Full Screen

1 @addr = Socket.getaddrinfo('localhost', 'http')[0][3]2 @addr = Socket.getaddrinfo('localhost', 'http')[0][3]3 @addr = Socket.getaddrinfo('localhost', 'http')[0][3]4 @addr = Socket.getaddrinfo('localhost', 'http')[0][3]5 @addr = Socket.getaddrinfo('localhost', 'http')[0][3]

Full Screen

Full Screen

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.

LambdaTest Learning Hubs:

YouTube

You could also refer to video tutorials over LambdaTest YouTube channel to get step by step demonstration from industry experts.

Run Unobtainium_ruby automation tests on LambdaTest cloud grid

Perform automation testing on 3000+ real desktop and mobile devices online.

... View sample repo... View DocumentationSign up Free
›
_

Most used method in

Try LambdaTest Now !!

Get 100 minutes of automation test minutes FREE!!

...
Sign up with GoogleSign up with Email
Next-Gen App & Browser Testing Cloud

Was this article helpful?

Helpful

NotHelpful