Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
20935d2380 | ||
|
|
727d8c41ca |
No files matched your search
@@ -9,6 +9,8 @@ bytes = "1"
|
||||
tonic = "0.12"
|
||||
prost = "0.13"
|
||||
crossbeam-queue = "0.3"
|
||||
hex = "0.4"
|
||||
snow = "0.9"
|
||||
|
||||
[profile.release]
|
||||
opt-level = "z"
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
use tonic::{Request, Response, Status};
|
||||
use coordinator::coordinator_client::CoordinatorClient as GeneratedCoordinatorClient;
|
||||
use coordinator::{RegisterRequest, RegisterResponse, HeartbeatRequest, HeartbeatResponse, PeerRequest, PeerResponse};
|
||||
use crate::coordinator::coordinator_client::CoordinatorClient as GeneratedCoordinatorClient;
|
||||
use crate::coordinator::{RegisterRequest, RegisterResponse, HeartbeatRequest, HeartbeatResponse, PeerRequest, PeerResponse};
|
||||
|
||||
pub struct CoordinatorClient {
|
||||
client: GeneratedCoordinatorClient<tonic::transport::Channel>,
|
||||
|
||||
+3
-3
@@ -1,4 +1,4 @@
|
||||
use std::ffi::{c_void, OSString, OsString};
|
||||
use std::ffi::{c_void, OsString};
|
||||
use std::os::windows::ffi::OsStrExt;
|
||||
use std::ptr::{null_mut};
|
||||
use std::io::{self, Read, Write};
|
||||
@@ -42,7 +42,7 @@ unsafe impl Sync for TunInterface {}
|
||||
|
||||
impl TunInterface {
|
||||
pub fn new(name: &str) -> io::Result<Self> {
|
||||
let wide_name: Vec<u16> = OSString::from(name).encode_utf16().chain(std::iter::once(0)).collect();
|
||||
let wide_name: Vec<u16> = OsString::from(name).encode_utf16().chain(std::iter::once(0)).collect();
|
||||
|
||||
unsafe {
|
||||
let adapter = WintunOpenAdapter(wide_name.as_ptr());
|
||||
@@ -94,7 +94,7 @@ impl TunInterface {
|
||||
let packet_ptr = *packet_ptr_ptr;
|
||||
std::ptr::copy_nonoverlapping(buf.as_ptr(), packet_ptr, buf.len());
|
||||
|
||||
if WintunSendPacket(self.tx_ring, &mut packet_ptr_ptr) {
|
||||
if WintunSendPacket(self.tx_ring, packet_ptr_ptr) {
|
||||
Ok(buf.len())
|
||||
} else {
|
||||
Err(io::Error::new(io::ErrorKind::Other, "Failed to send packet"))
|
||||
|
||||
Reference in new issue
Block a user