Skip to content

Commit

Permalink
Moving demo server to separate project
Browse files Browse the repository at this point in the history
  • Loading branch information
rkbalgi committed Aug 24, 2020
1 parent d7bfbf6 commit efaf276
Show file tree
Hide file tree
Showing 4 changed files with 4 additions and 232 deletions.
2 changes: 1 addition & 1 deletion Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 1 addition & 1 deletion Cargo.toml
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
[package]
name = "iso8583_rs"
version = "0.1.9"
version = "0.1.10"
authors = ["Raghavendra Balgi <rkbalgi@gmail.com>"]
edition = "2018"
description = "A library to define/parse/assemble and send/receive (via TCP) an ISO8583 message"
Expand Down
12 changes: 2 additions & 10 deletions src/iso8583/server.rs
Original file line number Diff line number Diff line change
Expand Up @@ -125,21 +125,13 @@ fn new_client(iso_server: &ISOServer, stream_: TcpStream) {
let mut reading_mli = true;
let mut mli: u32 = 0;

let mut reader = BufReader::with_capacity(10240, &stream);
let mut reader = BufReader::with_capacity(8192, &stream);
let mut writer: Box<dyn Write> = Box::new(&stream);

let mut t1 = std::time::Instant::now();
'done:
loop {
debug!(":::::::{}", reader.buffer().len());

if reading_mli {
/*match server.mli.is_available(&stream) {
Ok(true) => true,
Ok(false) => false,
Err(_e) => break 'done,
};*/

match server.mli.parse(&mut reader) {
Ok(n) => {
mli = n;
Expand Down Expand Up @@ -176,7 +168,7 @@ fn new_client(iso_server: &ISOServer, stream_: TcpStream) {
(&mut resp_data).write_all(resp.0.as_slice()).unwrap();
writer.write_all(resp_data.as_slice()).unwrap();
writer.flush().unwrap();
info!("request processing time = {} millis", std::time::Instant::now().duration_since(t1).as_millis());
debug!("request processing time = {} millis", std::time::Instant::now().duration_since(t1).as_millis());
}
Err(e) => {
error!("failed to construct mli {}", e.msg)
Expand Down
220 changes: 0 additions & 220 deletions src/main.rs

This file was deleted.

0 comments on commit efaf276

Please sign in to comment.