Skip to content

Commit

Permalink
Add logger.
Browse files Browse the repository at this point in the history
  • Loading branch information
cryscan committed Jul 24, 2023
1 parent 516aaea commit a5f6e4e
Show file tree
Hide file tree
Showing 2 changed files with 14 additions and 4 deletions.
2 changes: 2 additions & 0 deletions Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,8 @@ itertools = "0.11"
flume = "0.10"
futures-util = "0.3"
anyhow = "1"
log = "0.4"
simple_logger = { version = "4.2", features = ["stderr"] }

[profile.release]
lto = true
16 changes: 12 additions & 4 deletions src/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -120,7 +120,6 @@ fn load_model(env: &Environment, path: PathBuf) -> Result<Model> {
let file = File::open(path)?;
let map = unsafe { Mmap::map(&file)? };
let model = env.create_model_from_bytes(&map)?;
print!("{:#?}\n{:#?}\n\n", env.adapter.get_info(), model.info());
Ok(model)
}

Expand All @@ -130,9 +129,17 @@ fn model_task(
tokenizer: PathBuf,
receiver: Receiver<ThreadRequest>,
) -> Result<()> {
simple_logger::SimpleLogger::new()
.with_level(log::LevelFilter::Warn)
.with_module_level("ai00_server", log::LevelFilter::Trace)
.init()?;

let tokenizer = load_tokenizer(tokenizer)?;
let model = load_model(&env, model)?;

log::info!("{:#?}", env.adapter.get_info());
log::info!("{:#?}", model.info());

let penalty_free_tokens = {
let mut set = HashSet::new();
for token in 0..u16::MAX {
Expand Down Expand Up @@ -185,8 +192,7 @@ fn model_task(
RequestKind::Embedding(request) => request.into(),
};

println!("{:#?}", sampler);
std::io::stdout().flush()?;
log::info!("{:#?}", sampler);

let state = model.create_state();
let remain = {
Expand All @@ -197,8 +203,10 @@ fn model_task(
.and_then(|backed| state.load(backed).ok())
.is_some()
{
log::info!("state cache hit");
remain.split_off(prefix.len())
} else {
log::info!("state cache miss");
remain
}
};
Expand Down Expand Up @@ -234,7 +242,7 @@ fn model_task(
.and_then(|x| String::from_utf8(x).ok())
.unwrap_or_default();

print!("{}", word);
print!("{word}");
std::io::stdout().flush()?;

model_text += &word;
Expand Down

0 comments on commit a5f6e4e

Please sign in to comment.