Cleanup program account def (#5833)

This commit is contained in:
Jack May 2019-09-06 17:32:14 -07:00 committed by GitHub
parent 81c36699c4
commit 1833db51a5
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
7 changed files with 86 additions and 53 deletions

View File

@ -1,15 +1,14 @@
//! @brief Example Rust-based BPF program that moves a lamport from one account to another //! @brief Example Rust-based BPF program that moves a lamport from one account to another
extern crate solana_sdk; extern crate solana_sdk;
use solana_sdk::entrypoint; use solana_sdk::{account_info::AccountInfo, entrypoint, entrypoint::SUCCESS, pubkey::Pubkey};
use solana_sdk::entrypoint::*;
use solana_sdk::pubkey::Pubkey;
entrypoint!(process_instruction); entrypoint!(process_instruction);
fn process_instruction(_program_id: &Pubkey, ka: &mut [SolKeyedAccount], _data: &[u8]) -> u32 { fn process_instruction(_program_id: &Pubkey, accounts: &mut [AccountInfo], _data: &[u8]) -> u32 {
// account 0 is the mint and not owned by this program, any debit of its lamports // account 0 is the mint and not owned by this program, any debit of its lamports
// should result in a failed program execution. Test to ensure that this debit // should result in a failed program execution. Test to ensure that this debit
// is seen by the runtime and fails as expected // is seen by the runtime and fails as expected
*ka[0].lamports -= 1; *accounts[0].lamports -= 1;
SUCCESS SUCCESS
} }

View File

@ -3,10 +3,9 @@
#![allow(unreachable_code)] #![allow(unreachable_code)]
extern crate solana_sdk; extern crate solana_sdk;
use solana_sdk::entrypoint::*; use solana_sdk::{
use solana_sdk::log::*; account_info::AccountInfo, entrypoint, entrypoint::SUCCESS, info, log::*, pubkey::Pubkey,
use solana_sdk::pubkey::Pubkey; };
use solana_sdk::{entrypoint, info};
#[derive(Debug, PartialEq)] #[derive(Debug, PartialEq)]
struct SStruct { struct SStruct {
@ -21,7 +20,7 @@ fn return_sstruct() -> SStruct {
} }
entrypoint!(process_instruction); entrypoint!(process_instruction);
fn process_instruction(program_id: &Pubkey, ka: &mut [SolKeyedAccount], data: &[u8]) -> u32 { fn process_instruction(program_id: &Pubkey, accounts: &mut [AccountInfo], data: &[u8]) -> u32 {
info!("Program identifier:"); info!("Program identifier:");
program_id.log(); program_id.log();
@ -29,7 +28,7 @@ fn process_instruction(program_id: &Pubkey, ka: &mut [SolKeyedAccount], data: &[
// the no-op program, no account keys or input data are expected but real // the no-op program, no account keys or input data are expected but real
// programs will have specific requirements so they can do their work. // programs will have specific requirements so they can do their work.
info!("Account keys and instruction input data:"); info!("Account keys and instruction input data:");
sol_log_params(ka, data); sol_log_params(accounts, data);
{ {
// Test - use std methods, unwrap // Test - use std methods, unwrap

View File

@ -2,13 +2,13 @@
extern crate solana_sdk; extern crate solana_sdk;
use byteorder::{ByteOrder, LittleEndian}; use byteorder::{ByteOrder, LittleEndian};
use solana_sdk::entrypoint::*; use solana_sdk::{
use solana_sdk::pubkey::Pubkey; account_info::AccountInfo, entrypoint, entrypoint::SUCCESS, info, pubkey::Pubkey,
use solana_sdk::{entrypoint, info}; };
entrypoint!(process_instruction); entrypoint!(process_instruction);
fn process_instruction(_program_id: &Pubkey, ka: &mut [SolKeyedAccount], _data: &[u8]) -> u32 { fn process_instruction(_program_id: &Pubkey, accounts: &mut [AccountInfo], _data: &[u8]) -> u32 {
let tick_height = LittleEndian::read_u64(ka[2].data); let tick_height = LittleEndian::read_u64(accounts[2].data);
assert_eq!(10u64, tick_height); assert_eq!(10u64, tick_height);
info!("Success"); info!("Success");

48
sdk/src/account_info.rs Normal file
View File

@ -0,0 +1,48 @@
use crate::pubkey::Pubkey;
use std::{cmp, fmt};
/// AccountInfo
pub struct AccountInfo<'a> {
/// Public key of the account
pub key: &'a Pubkey,
/// Public key of the account
pub is_signer: bool,
/// Number of lamports owned by this account
pub lamports: &'a mut u64,
/// On-chain data within this account
pub data: &'a mut [u8],
/// Program that owns this account
pub owner: &'a Pubkey,
}
impl<'a> fmt::Debug for AccountInfo<'a> {
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
let data_len = cmp::min(64, self.data.len());
let data_str = if data_len > 0 {
format!(" data: {}", hex::encode(self.data[..data_len].to_vec()))
} else {
"".to_string()
};
write!(
f,
"AccountInfo {{ lamports: {} data.len: {} owner: {} {} }}",
self.lamports,
self.data.len(),
self.owner,
data_str,
)
}
}
impl<'a> AccountInfo<'a> {
pub fn deserialize_data<T: serde::de::DeserializeOwned>(&self) -> Result<T, bincode::Error> {
bincode::deserialize(&self.data)
}
pub fn serialize_data<T: serde::Serialize>(&mut self, state: &T) -> Result<(), bincode::Error> {
if bincode::serialized_size(state)? > self.data.len() as u64 {
return Err(Box::new(bincode::ErrorKind::SizeLimit));
}
bincode::serialize_into(&mut self.data[..], state)
}
}

View File

@ -1,32 +1,19 @@
//! @brief Solana Rust-based BPF program entrypoint and its parameter types //! @brief Solana Rust-based BPF program entrypoint and its parameter types
extern crate alloc; extern crate alloc;
use crate::pubkey::Pubkey; use crate::{account_info::AccountInfo, pubkey::Pubkey};
use alloc::vec::Vec; use alloc::vec::Vec;
use core::mem::size_of; use core::mem::size_of;
use core::slice::{from_raw_parts, from_raw_parts_mut}; use core::slice::{from_raw_parts, from_raw_parts_mut};
/// Keyed Account
pub struct SolKeyedAccount<'a> {
/// Public key of the account
pub key: &'a Pubkey,
/// Public key of the account
pub is_signer: bool,
/// Number of lamports owned by this account
pub lamports: &'a mut u64,
/// On-chain data within this account
pub data: &'a mut [u8],
/// Program that owns this account
pub owner: &'a Pubkey,
}
/// User implemented program entrypoint /// User implemented program entrypoint
/// ///
/// program_id: Program ID of the currently executing program /// program_id: Program ID of the currently executing program
/// accounts: Accounts passed as part of the instruction /// accounts: Accounts passed as part of the instruction
/// data: Instruction data /// data: Instruction data
pub type ProcessInstruction = pub type ProcessInstruction =
fn(program_id: &Pubkey, accounts: &mut [SolKeyedAccount], data: &[u8]) -> bool; fn(program_id: &Pubkey, accounts: &mut [AccountInfo], data: &[u8]) -> bool;
/// Programs indicate success with a return value of 0 /// Programs indicate success with a return value of 0
pub const SUCCESS: u32 = 0; pub const SUCCESS: u32 = 0;
@ -43,8 +30,8 @@ macro_rules! entrypoint {
#[no_mangle] #[no_mangle]
pub unsafe extern "C" fn entrypoint(input: *mut u8) -> u32 { pub unsafe extern "C" fn entrypoint(input: *mut u8) -> u32 {
unsafe { unsafe {
let (program_id, mut kas, data) = $crate::entrypoint::deserialize(input); let (program_id, mut accounts, data) = $crate::entrypoint::deserialize(input);
$process_instruction(&program_id, &mut kas, &data) $process_instruction(&program_id, &mut accounts, &data)
} }
} }
}; };
@ -52,21 +39,19 @@ macro_rules! entrypoint {
/// Deserialize the input parameters /// Deserialize the input parameters
#[allow(clippy::type_complexity)] #[allow(clippy::type_complexity)]
pub unsafe fn deserialize<'a>( pub unsafe fn deserialize<'a>(input: *mut u8) -> (&'a Pubkey, Vec<AccountInfo<'a>>, &'a [u8]) {
input: *mut u8,
) -> (&'a Pubkey, Vec<SolKeyedAccount<'a>>, &'a [u8]) {
let mut offset: usize = 0; let mut offset: usize = 0;
// Number of KeyedAccounts present // Number of accounts present
#[allow(clippy::cast_ptr_alignment)] #[allow(clippy::cast_ptr_alignment)]
let num_ka = *(input.add(offset) as *const u64) as usize; let num_accounts = *(input.add(offset) as *const u64) as usize;
offset += size_of::<u64>(); offset += size_of::<u64>();
// KeyedAccounts // Account Infos
let mut kas = Vec::with_capacity(num_ka); let mut accounts = Vec::with_capacity(num_accounts);
for _ in 0..num_ka { for _ in 0..num_accounts {
let is_signer = { let is_signer = {
#[allow(clippy::cast_ptr_alignment)] #[allow(clippy::cast_ptr_alignment)]
let is_signer_val = *(input.add(offset) as *const u64); let is_signer_val = *(input.add(offset) as *const u64);
@ -91,7 +76,7 @@ pub unsafe fn deserialize<'a>(
let owner: &Pubkey = &*(input.add(offset) as *const Pubkey); let owner: &Pubkey = &*(input.add(offset) as *const Pubkey);
offset += size_of::<Pubkey>(); offset += size_of::<Pubkey>();
kas.push(SolKeyedAccount { accounts.push(AccountInfo {
key, key,
is_signer, is_signer,
lamports, lamports,
@ -113,5 +98,5 @@ pub unsafe fn deserialize<'a>(
let program_id: &Pubkey = &*(input.add(offset) as *const Pubkey); let program_id: &Pubkey = &*(input.add(offset) as *const Pubkey);
(program_id, kas, data) (program_id, accounts, data)
} }

View File

@ -3,6 +3,8 @@ pub mod pubkey;
// On-chain program modules // On-chain program modules
#[cfg(feature = "program")] #[cfg(feature = "program")]
pub mod account_info;
#[cfg(feature = "program")]
pub mod entrypoint; pub mod entrypoint;
#[cfg(feature = "program")] #[cfg(feature = "program")]
pub mod log; pub mod log;

View File

@ -1,6 +1,6 @@
//! @brief Solana Rust-based BPF program logging //! @brief Solana Rust-based BPF program logging
use crate::entrypoint::SolKeyedAccount; use crate::account_info::AccountInfo;
/// Prints a string /// Prints a string
/// There are two forms and are fast /// There are two forms and are fast
@ -63,20 +63,20 @@ pub fn sol_log_slice(slice: &[u8]) {
/// @param ka - A pointer to an array of `SolKeyedAccounts` to print /// @param ka - A pointer to an array of `SolKeyedAccounts` to print
/// @param data - A pointer to the instruction data to print /// @param data - A pointer to the instruction data to print
#[allow(dead_code)] #[allow(dead_code)]
pub fn sol_log_params(ka: &[SolKeyedAccount], data: &[u8]) { pub fn sol_log_params(accounts: &[AccountInfo], data: &[u8]) {
for (i, k) in ka.iter().enumerate() { for (i, account) in accounts.iter().enumerate() {
sol_log("SolKeyedAccount"); sol_log("SolKeyedAccount");
sol_log_64(0, 0, 0, 0, i as u64); sol_log_64(0, 0, 0, 0, i as u64);
sol_log("- Is signer"); sol_log("- Is signer");
sol_log_64(0, 0, 0, 0, k.is_signer as u64); sol_log_64(0, 0, 0, 0, account.is_signer as u64);
sol_log("- Key"); sol_log("- Key");
k.key.log(); account.key.log();
sol_log("- Lamports"); sol_log("- Lamports");
sol_log_64(0, 0, 0, 0, *k.lamports); sol_log_64(0, 0, 0, 0, *account.lamports);
sol_log("- AccountData"); sol_log("- AccountData");
sol_log_slice(k.data); sol_log_slice(account.data);
sol_log("- Owner"); sol_log("- Owner");
k.owner.log(); account.owner.log();
} }
sol_log("Instruction data"); sol_log("Instruction data");
sol_log_slice(data); sol_log_slice(data);