mirror of
https://github.com/ton-blockchain/ton
synced 2025-03-09 15:40:10 +00:00
parent
c56e65739b
commit
2634e63e4f
4 changed files with 4 additions and 4 deletions
|
@ -91,7 +91,7 @@ td::Status AdnlInboundConnection::process_custom_packet(td::BufferSlice &data, b
|
||||||
auto F = fetch_tl_object<ton_api::tcp_authentificate>(data.clone(), true);
|
auto F = fetch_tl_object<ton_api::tcp_authentificate>(data.clone(), true);
|
||||||
if (F.is_ok()) {
|
if (F.is_ok()) {
|
||||||
if (nonce_.size() > 0 || !remote_id_.is_zero()) {
|
if (nonce_.size() > 0 || !remote_id_.is_zero()) {
|
||||||
return td::Status::Error(ErrorCode::protoviolation, "duplicate authentificate");
|
return td::Status::Error(ErrorCode::protoviolation, "duplicate authenticate");
|
||||||
}
|
}
|
||||||
auto f = F.move_as_ok();
|
auto f = F.move_as_ok();
|
||||||
nonce_ = td::SecureString{f->nonce_.size() + 256};
|
nonce_ = td::SecureString{f->nonce_.size() + 256};
|
||||||
|
|
|
@ -105,7 +105,7 @@ td::Result<td::Ref<vm::Cell>> DnsInterface::EntryData::as_cell() const {
|
||||||
return error;
|
return error;
|
||||||
}
|
}
|
||||||
if (res.is_null()) {
|
if (res.is_null()) {
|
||||||
return td::Status::Error("Entry data is emtpy");
|
return td::Status::Error("Entry data is empty");
|
||||||
}
|
}
|
||||||
return res;
|
return res;
|
||||||
//dns_text#1eda _:Text = DNSRecord;
|
//dns_text#1eda _:Text = DNSRecord;
|
||||||
|
|
|
@ -27,7 +27,7 @@ namespace td {
|
||||||
// Generic stream interface
|
// Generic stream interface
|
||||||
// Will to hide implementations details.
|
// Will to hide implementations details.
|
||||||
// CyclicBuffer, ChainBuffer, Bounded ChainBuffer, some clever writers. They all should be interchangable
|
// CyclicBuffer, ChainBuffer, Bounded ChainBuffer, some clever writers. They all should be interchangable
|
||||||
// Most implementaions will assume that reading and writing may happen concurrently
|
// Most implementations will assume that reading and writing may happen concurrently
|
||||||
|
|
||||||
class StreamReaderInterface {
|
class StreamReaderInterface {
|
||||||
public:
|
public:
|
||||||
|
|
|
@ -73,7 +73,7 @@ Result<bool> StreamToFileActor::do_loop() {
|
||||||
// Also it could be useful to check error and stop immediately.
|
// Also it could be useful to check error and stop immediately.
|
||||||
TRY_RESULT(is_closed, is_closed());
|
TRY_RESULT(is_closed, is_closed());
|
||||||
|
|
||||||
// Flush all data that is awailable on the at the beginning of loop
|
// Flush all data that is available on the at the beginning of loop
|
||||||
TRY_STATUS(do_flush_once());
|
TRY_STATUS(do_flush_once());
|
||||||
|
|
||||||
if ((sync_at_ && sync_at_.is_in_past()) || is_closed) {
|
if ((sync_at_ && sync_at_.is_in_past()) || is_closed) {
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue