Skip to content

Commit

Permalink
feat: benchmark private proving (#6409)
Browse files Browse the repository at this point in the history
This PR adds benchmarks for the private kernel running with real BB
proofs. This PR also tracks these stats for individual function calls.

---------

Co-authored-by: PhilWindle <philip.windle@gmail.com>
  • Loading branch information
alexghr and PhilWindle committed May 16, 2024
1 parent 6793a75 commit e9e5526
Show file tree
Hide file tree
Showing 20 changed files with 705 additions and 448 deletions.
4 changes: 2 additions & 2 deletions .github/workflows/ci.yml
Original file line number Diff line number Diff line change
Expand Up @@ -106,7 +106,7 @@ jobs:
timeout-minutes: 40
uses: ./.github/ensure-tester-with-images
with:
runner_type: ${{ matrix.test == 'client-prover-integration' && '32core-tester-x86' || '8core-tester-x86' }}
runner_type: ${{ contains(matrix.test, 'prover') && '64core-tester-x86' || '8core-tester-x86' }}
builder_type: builder-x86
# these are copied to the tester and expected by the earthly command below
# if they fail to copy, it will try to build them on the tester and fail
Expand Down Expand Up @@ -135,7 +135,7 @@ jobs:
uses: ./.github/ensure-tester-with-images
timeout-minutes: 40
with:
runner_type: 16core-tester-x86
runner_type: ${{ contains(matrix.test, 'prover') && '64core-tester-x86' || '16core-tester-x86' }}
builder_type: builder-x86
# these are copied to the tester and expected by the earthly command below
# if they fail to copy, it will try to build them on the tester and fail
Expand Down
2 changes: 2 additions & 0 deletions scripts/logs/download_base_benchmark_from_s3.sh
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,8 @@ BASE_BENCHMARK_FILE_JSON="${BENCH_FOLDER}/base-benchmark.json"
# If on a pull request, get the data from the most recent commit on master where it's available to generate a comment comparing them
if [ -n "${PULL_REQUEST:-}" ]; then
MASTER_COMMIT_HASH=$(curl -s "https://api.github.com/repos/AztecProtocol/aztec-packages/pulls/${PULL_REQUEST##*/}" | jq -r '.base.sha')
# master could have diverged since starting this job, refresh history
git fetch --depth 50 origin master
MASTER_COMMIT_HASHES=($(git log $MASTER_COMMIT_HASH --format="%H" -n 50))

mkdir -p $BENCH_FOLDER
Expand Down
67 changes: 41 additions & 26 deletions yarn-project/bb-prover/src/bb/execute.ts
Original file line number Diff line number Diff line change
Expand Up @@ -32,6 +32,12 @@ export type BBFailure = {

export type BBResult = BBSuccess | BBFailure;

type BBExecResult = {
status: BB_RESULT;
exitCode: number;
signal: string | undefined;
};

/**
* Invokes the Barretenberg binary with the provided command and args
* @param pathToBB - The path to the BB binary
Expand All @@ -47,26 +53,20 @@ export function executeBB(
args: string[],
logger: LogFn,
resultParser = (code: number) => code === 0,
) {
return new Promise<BB_RESULT.SUCCESS | BB_RESULT.FAILURE>((resolve, reject) => {
): Promise<BBExecResult> {
return new Promise<BBExecResult>(resolve => {
// spawn the bb process
const bb = proc.spawn(pathToBB, [command, ...args]);
bb.stdout.on('data', data => {
const message = data.toString('utf-8').replace(/\n$/, '');
logger(message);
const bb = proc.spawn(pathToBB, [command, ...args], {
stdio: 'pipe',
});
bb.stderr.on('data', data => {
const message = data.toString('utf-8').replace(/\n$/, '');
logger(message);
});
bb.on('close', (code: number) => {
if (resultParser(code)) {
resolve(BB_RESULT.SUCCESS);
bb.on('close', (exitCode: number, signal?: string) => {
if (resultParser(exitCode)) {
resolve({ status: BB_RESULT.SUCCESS, exitCode, signal });
} else {
reject();
resolve({ status: BB_RESULT.FAILURE, exitCode, signal });
}
});
}).catch(_ => BB_RESULT.FAILURE);
}).catch(_ => ({ status: BB_RESULT.FAILURE, exitCode: -1, signal: undefined }));
}

const bytecodeHashFilename = 'bytecode_hash';
Expand Down Expand Up @@ -154,14 +154,14 @@ export async function generateKeyForNoirCircuit(
const timer = new Timer();
let result = await executeBB(pathToBB, `write_${key}`, args, log);
// If we succeeded and the type of key if verification, have bb write the 'fields' version too
if (result == BB_RESULT.SUCCESS && key === 'vk') {
if (result.status == BB_RESULT.SUCCESS && key === 'vk') {
const asFieldsArgs = ['-k', `${outputPath}/${VK_FILENAME}`, '-o', `${outputPath}/${VK_FIELDS_FILENAME}`, '-v'];
result = await executeBB(pathToBB, `vk_as_fields`, asFieldsArgs, log);
}
const duration = timer.ms();
// Cleanup the bytecode file
await fs.rm(bytecodePath, { force: true });
if (result == BB_RESULT.SUCCESS) {
if (result.status == BB_RESULT.SUCCESS) {
// Store the bytecode hash so we don't need to regenerate at a later time
await fs.writeFile(bytecodeHashPath, bytecodeHash);
return {
Expand All @@ -173,7 +173,10 @@ export async function generateKeyForNoirCircuit(
};
}
// Not a great error message here but it is difficult to decipher what comes from bb
return { status: BB_RESULT.FAILURE, reason: `Failed to generate key` };
return {
status: BB_RESULT.FAILURE,
reason: `Failed to generate key. Exit code: ${result.exitCode}. Signal ${result.signal}.`,
};
} catch (error) {
return { status: BB_RESULT.FAILURE, reason: `${error}` };
}
Expand Down Expand Up @@ -231,7 +234,7 @@ export async function generateProof(
const duration = timer.ms();
// cleanup the bytecode
await fs.rm(bytecodePath, { force: true });
if (result == BB_RESULT.SUCCESS) {
if (result.status == BB_RESULT.SUCCESS) {
return {
status: BB_RESULT.SUCCESS,
duration,
Expand All @@ -241,7 +244,10 @@ export async function generateProof(
};
}
// Not a great error message here but it is difficult to decipher what comes from bb
return { status: BB_RESULT.FAILURE, reason: `Failed to generate proof` };
return {
status: BB_RESULT.FAILURE,
reason: `Failed to generate proof. Exit code ${result.exitCode}. Signal ${result.signal}.`,
};
} catch (error) {
return { status: BB_RESULT.FAILURE, reason: `${error}` };
}
Expand Down Expand Up @@ -274,11 +280,14 @@ export async function verifyProof(
const timer = new Timer();
const result = await executeBB(pathToBB, 'verify', args, log);
const duration = timer.ms();
if (result == BB_RESULT.SUCCESS) {
if (result.status == BB_RESULT.SUCCESS) {
return { status: BB_RESULT.SUCCESS, duration };
}
// Not a great error message here but it is difficult to decipher what comes from bb
return { status: BB_RESULT.FAILURE, reason: `Failed to verify proof` };
return {
status: BB_RESULT.FAILURE,
reason: `Failed to verify proof. Exit code ${result.exitCode}. Signal ${result.signal}.`,
};
} catch (error) {
return { status: BB_RESULT.FAILURE, reason: `${error}` };
}
Expand Down Expand Up @@ -311,11 +320,14 @@ export async function writeVkAsFields(
const timer = new Timer();
const result = await executeBB(pathToBB, 'vk_as_fields', args, log);
const duration = timer.ms();
if (result == BB_RESULT.SUCCESS) {
if (result.status == BB_RESULT.SUCCESS) {
return { status: BB_RESULT.SUCCESS, duration, vkPath: verificationKeyPath };
}
// Not a great error message here but it is difficult to decipher what comes from bb
return { status: BB_RESULT.FAILURE, reason: `Failed to create vk as fields` };
return {
status: BB_RESULT.FAILURE,
reason: `Failed to create vk as fields. Exit code ${result.exitCode}. Signal ${result.signal}.`,
};
} catch (error) {
return { status: BB_RESULT.FAILURE, reason: `${error}` };
}
Expand Down Expand Up @@ -348,11 +360,14 @@ export async function writeProofAsFields(
const timer = new Timer();
const result = await executeBB(pathToBB, 'proof_as_fields', args, log);
const duration = timer.ms();
if (result == BB_RESULT.SUCCESS) {
if (result.status == BB_RESULT.SUCCESS) {
return { status: BB_RESULT.SUCCESS, duration, proofPath: proofPath };
}
// Not a great error message here but it is difficult to decipher what comes from bb
return { status: BB_RESULT.FAILURE, reason: `Failed to create proof as fields` };
return {
status: BB_RESULT.FAILURE,
reason: `Failed to create proof as fields. Exit code ${result.exitCode}. Signal ${result.signal}.`,
};
} catch (error) {
return { status: BB_RESULT.FAILURE, reason: `${error}` };
}
Expand Down
Loading

0 comments on commit e9e5526

Please sign in to comment.