Lines Matching refs:sk_state
385 let sk_state = new_test_state(history.clone(), 2); in test_sk_state_batching() localVariable
386 sk_state.inner.unwrap().delete_ids(&[VM_ID1, VM_ID2, VM_ID3, VM_ID4, VM_ID5]); in test_sk_state_batching()
401 let sk_state = new_test_state(history.clone(), 6); in test_sk_state_no_batching() localVariable
402 sk_state.inner.unwrap().delete_ids(&[VM_ID1, VM_ID2, VM_ID3, VM_ID4, VM_ID5]); in test_sk_state_no_batching()
410 let mut sk_state = new_test_state(history.clone(), 2); in test_sk_state() localVariable
412 get_db(&mut sk_state).add_vm_id(&VM_ID1, USER1, APP_A).unwrap(); in test_sk_state()
413 get_db(&mut sk_state).add_vm_id(&VM_ID2, USER1, APP_A).unwrap(); in test_sk_state()
414 get_db(&mut sk_state).add_vm_id(&VM_ID3, USER2, APP_B).unwrap(); in test_sk_state()
415 get_db(&mut sk_state).add_vm_id(&VM_ID4, USER3, APP_A).unwrap(); in test_sk_state()
416 get_db(&mut sk_state).add_vm_id(&VM_ID5, USER3, APP_C).unwrap(); in test_sk_state()
419 sk_state.delete_ids_for_app(USER2, APP_B).unwrap(); in test_sk_state()
422 sk_state.delete_ids_for_user(USER3).unwrap(); in test_sk_state()
428 assert_eq!(vec![VM_ID1, VM_ID2], get_db(&mut sk_state).vm_ids_for_user(USER1).unwrap()); in test_sk_state()
431 get_db(&mut sk_state).vm_ids_for_app(USER1, APP_A).unwrap() in test_sk_state()
434 assert_eq!(empty, get_db(&mut sk_state).vm_ids_for_app(USER2, APP_B).unwrap()); in test_sk_state()
435 assert_eq!(empty, get_db(&mut sk_state).vm_ids_for_user(USER3).unwrap()); in test_sk_state()
441 let mut sk_state = new_test_state(history.clone(), 2); in test_sk_state_delete_id() localVariable
443 get_db(&mut sk_state).add_vm_id(&VM_ID1, USER1, APP_A).unwrap(); in test_sk_state_delete_id()
444 get_db(&mut sk_state).add_vm_id(&VM_ID2, USER1, APP_A).unwrap(); in test_sk_state_delete_id()
445 get_db(&mut sk_state).add_vm_id(&VM_ID3, USER2, APP_B).unwrap(); in test_sk_state_delete_id()
449 sk_state.delete_id(&VM_ID4, USER1 as u32, APP_A as u32); in test_sk_state_delete_id()
453 sk_state.delete_id(&VM_ID1, USER1 as u32, APP_B as u32); in test_sk_state_delete_id()
457 sk_state.delete_id(&VM_ID1, USER2 as u32, APP_A as u32); in test_sk_state_delete_id()
461 sk_state.delete_id(&VM_ID1, USER1 as u32, APP_A as u32); in test_sk_state_delete_id()
464 assert_eq!(vec![VM_ID2], get_db(&mut sk_state).vm_ids_for_user(USER1).unwrap()); in test_sk_state_delete_id()
465 assert_eq!(vec![VM_ID3], get_db(&mut sk_state).vm_ids_for_user(USER2).unwrap()); in test_sk_state_delete_id()
471 let mut sk_state = new_test_state(history.clone(), 20); in test_sk_state_reconcile() localVariable
473 get_db(&mut sk_state).add_vm_id(&VM_ID1, USER1, APP_A).unwrap(); in test_sk_state_reconcile()
474 get_db(&mut sk_state).add_vm_id(&VM_ID2, USER1, APP_A).unwrap(); in test_sk_state_reconcile()
475 get_db(&mut sk_state).add_vm_id(&VM_ID3, USER2, APP_B).unwrap(); in test_sk_state_reconcile()
476 get_db(&mut sk_state).add_vm_id(&VM_ID4, USER2, CORE_APP_A).unwrap(); in test_sk_state_reconcile()
477 get_db(&mut sk_state).add_vm_id(&VM_ID5, USER3, APP_C).unwrap(); in test_sk_state_reconcile()
479 assert_eq!(vec![VM_ID1, VM_ID2], get_db(&mut sk_state).vm_ids_for_user(USER1).unwrap()); in test_sk_state_reconcile()
482 get_db(&mut sk_state).vm_ids_for_app(USER1, APP_A).unwrap() in test_sk_state_reconcile()
484 assert_eq!(vec![VM_ID3], get_db(&mut sk_state).vm_ids_for_app(USER2, APP_B).unwrap()); in test_sk_state_reconcile()
485 assert_eq!(vec![VM_ID5], get_db(&mut sk_state).vm_ids_for_user(USER3).unwrap()); in test_sk_state_reconcile()
494 sk_state.reconcile(&callback).unwrap(); in test_sk_state_reconcile()
497 assert_eq!(empty, get_db(&mut sk_state).vm_ids_for_user(USER1).unwrap()); in test_sk_state_reconcile()
498 assert_eq!(empty, get_db(&mut sk_state).vm_ids_for_app(USER1, APP_A).unwrap()); in test_sk_state_reconcile()
500 assert_eq!(vec![VM_ID4], get_db(&mut sk_state).vm_ids_for_user(USER2).unwrap()); in test_sk_state_reconcile()
501 assert_eq!(empty, get_db(&mut sk_state).vm_ids_for_app(USER2, APP_B).unwrap()); in test_sk_state_reconcile()
502 assert_eq!(vec![VM_ID5], get_db(&mut sk_state).vm_ids_for_user(USER3).unwrap()); in test_sk_state_reconcile()
508 let mut sk_state = new_test_state(history.clone(), 20); in test_sk_state_too_many_vms() localVariable
514 sk_state.add_id(&vm_id, USER1 as u32, APP_A as u32).unwrap(); in test_sk_state_too_many_vms()
515 assert_eq!(idx + 1, get_db(&mut sk_state).count_vm_ids_for_app(USER1, APP_A).unwrap()); in test_sk_state_too_many_vms()
519 get_db(&mut sk_state).count_vm_ids_for_app(USER1, APP_A).unwrap() in test_sk_state_too_many_vms()
526 sk_state.add_id(&vm_id, USER1 as u32, APP_A as u32).unwrap(); in test_sk_state_too_many_vms()
529 get_db(&mut sk_state).count_vm_ids_for_app(USER1, APP_A).unwrap() in test_sk_state_too_many_vms()
534 get_db(&mut sk_state).count_vm_ids_for_app(USER1, APP_A).unwrap() in test_sk_state_too_many_vms()
553 let mut sk_state = new_test_state(history.clone(), 20); in test_sk_state_reconcile_not_needed() localVariable
555 get_db(&mut sk_state).add_vm_id(&VM_ID1, USER1, APP_A).unwrap(); in test_sk_state_reconcile_not_needed()
556 get_db(&mut sk_state).add_vm_id(&VM_ID2, USER1, APP_A).unwrap(); in test_sk_state_reconcile_not_needed()
557 get_db(&mut sk_state).add_vm_id(&VM_ID3, USER2, APP_B).unwrap(); in test_sk_state_reconcile_not_needed()
558 get_db(&mut sk_state).add_vm_id(&VM_ID5, USER3, APP_C).unwrap(); in test_sk_state_reconcile_not_needed()
559 sk_state.delete_ids_for_user(USER1).unwrap(); in test_sk_state_reconcile_not_needed()
560 sk_state.delete_ids_for_user(USER2).unwrap(); in test_sk_state_reconcile_not_needed()
561 sk_state.delete_ids_for_user(USER3).unwrap(); in test_sk_state_reconcile_not_needed()
568 sk_state.reconcile(&callback).unwrap(); in test_sk_state_reconcile_not_needed()