{"id":6195,"date":"2023-02-28T10:57:10","date_gmt":"2023-02-28T01:57:10","guid":{"rendered":"https:\/\/solid.kmckk.com\/SOLID\/?p=6195"},"modified":"2023-02-28T10:57:10","modified_gmt":"2023-02-28T01:57:10","slug":"solid%e4%bd%bf%e3%81%a3%e3%81%a6%e3%81%bf%e3%82%88%e3%81%86%e3%82%b7%e3%83%aa%e3%83%bc%e3%82%ba3-%e3%80%8c%e3%82%b3%e3%83%bc%e3%83%89%e3%82%ab%e3%83%90%e3%83%ac%e3%83%83%e3%82%b8%e3%80%8d-2-5-2-2-2-10","status":"publish","type":"post","link":"https:\/\/solid.kmckk.com\/SOLID\/archives\/6195","title":{"rendered":"SOLID for Raspberry Pi 4 (\u9023\u8f0917)"},"content":{"rendered":"
\n
\n\t

(2023\/2\/28)<\/p>\n<\/div>\n<\/div><\/div>

Rust\u306e\u30b9\u30ec\u30c3\u30c9\u9593\u3067\u5909\u6570\u3092\u5171\u6709\u3059\u308b<\/h3>\n
\n\t

 <\/p>\n

\u524d\u56de\u3001Windows PC\u3068Raspberry Pi 4\u3092\u30cd\u30c3\u30c8\u30ef\u30fc\u30af\u3067\u63a5\u7d9a\u3057\u3001TCP\/IP\u901a\u4fe1\u3067Raspberry Pi 4\u304c\u53d6\u5f97\u3057\u305f\u52a0\u901f\u5ea6\u30bb\u30f3\u30b5ADXL345\u306e\u5024\u3092PC\u306b\u6e21\u3059\u30b3\u30fc\u30c9\u304c\u66f8\u3051\u307e\u3057\u305f\u3002<\/p>\n

\u4eca\u56de\u306f\u3001
\n\u305d\u306e\uff11\uff1a\u52a0\u901f\u5ea6\u5024\u53d6\u5f97\u3092\u30b9\u30ec\u30c3\u30c9\u5316
\n\u305d\u306e\uff12\uff1a\u52a0\u901f\u5ea6\u5024\u53d6\u5f97\u30b9\u30ec\u30c3\u30c9\u3068TCP\/IP\u30b5\u30fc\u30d0\u30b9\u30ec\u30c3\u30c9\u3067\u4f7f\u7528\u3067\u304d\u308b\u5171\u6709\u5909\u6570\u8a2d\u7f6e
\n\u305d\u306e\uff13\uff1a\u305d\u308c\u305e\u308c\u306e\u30b9\u30ec\u30c3\u30c9\u304b\u3089\u3001\u6392\u4ed6\u5236\u5fa1\u306b\u3088\u308a\u5171\u6709\u5909\u6570\u4f7f\u7528
\n\u3092\u884c\u3044\u307e\u3059\u3002<\/p>\n

\u524d\u56de\u3001\u6700\u65b0\u306e100\u500b\u3092\u30ea\u30f3\u30b0\u30d0\u30c3\u30d5\u30a1\u306b\u305f\u3081\u3066\u3001\u3001\u3001\u3068\u66f8\u304d\u307e\u3057\u305f\u304c\u3001\u5909\u66f4\u3057\u307e\u3059\u3002
\n\u30d0\u30c3\u30d5\u30a1\u3092\u4e00\u3064\u3001\u3069\u3093\u3063\u3068\u30a2\u30b5\u30a4\u30f3\u3057\u3001\u30ea\u30f3\u30b0\u30d0\u30c3\u30d5\u30a1\u306e\u5f62\u3067\u66f8\u304d\u8fbc\u307f\u306f\u3059\u308b\u306e\u3067\u3059\u304c\u3001PC\u306b\u9001\u4fe1\u3059\u308b\u969b\u306b\u306f\u30d0\u30c3\u30d5\u30a1\u5148\u982d\u304b\u3089\u6700\u65b0\u5024\u307e\u3067\u3092\u9001\u308a\u307e\u3059\u3002<\/p>\n

\"\"<\/a><\/p>\n

\u6642\u9593\u304c\u3042\u308c\u3070\u6b8b\u308a\u306e\u30c7\u30fc\u30bf\u306b\u3064\u3044\u3066\u3082\u9001\u308b\u691c\u8a0e\u3092\u884c\u3044\u305f\u3044\u3068\u306f\u601d\u3044\u307e\u3059\u304c\u3001\u4eca\u56de\u306f\u305d\u3053\u304c\u76ee\u7684\u3067\u306f\u306a\u3044\u306e\u3067\u3001\u30d0\u30c3\u30d5\u30a1\u5236\u5fa1\u306b\u3064\u3044\u3066\u306f\u7c21\u5358\u306b\u3059\u308b\u3068\u3044\u3046\u4e8b\u3067\u3054\u5bb9\u8d66\u304f\u3060\u3055\u3044\u3002<\/p>\n<\/div>\n<\/div><\/div>

\uff11\uff0e\u52a0\u901f\u5ea6\u5024\u53d6\u5f97\u3092\u30b9\u30ec\u30c3\u30c9\u5316<\/h3>\n
\n\t

\u524d\u56de\u53c2\u8003\u306b\u3055\u305b\u3066\u9802\u3044\u305fTCP\/IP\u30b5\u30fc\u30d0\u30b5\u30f3\u30d7\u30eb\u30b3\u30fc\u30c9\u306f\u3001\u5b9f\u306f\u30b9\u30ec\u30c3\u30c9\u3092\u4f7f\u3063\u3066\u3044\u307e\u3059\u3002
\nhttps:\/\/github.com\/KyotoMicrocomputer\/solid-rapi4-examples\/tree\/main\/rust-server-tcpecho-std<\/a><\/p>\n

\n
let send_job_ingress = send_job_ingress.clone();\nstd::thread::spawn(move || worker_loop(Worker(i), send_job_ingress));\n<\/code><\/pre>\n<\/div>\n
thread::spawn\u3067\u3001\u30b9\u30ec\u30c3\u30c9\u8d77\u52d5\u3059\u308b\u3088\u3046\u3067\u3059\u3002\u516c\u5f0f\u30b5\u30a4\u30c8\u3092\u898b\u3066\u307f\u307e\u3059\u3002<\/p>\n
https:\/\/doc.rust-lang.org\/std\/thread\/fn.spawn.html<\/a><\/p>\n
spawn(move|| \u30b9\u30ec\u30c3\u30c9\u3068\u3057\u3066\u3084\u308a\u305f\u3044\u3053\u3068\u3092\u3053\u3053\u306b\u66f8\u304f )
\n\u3067\u5927\u4e08\u592b\u305d\u3046\u3067\u3059\u3002<\/p>\n
move\u30af\u30ed\u30fc\u30b8\u30e3\u30fc\u3092\u3053\u3053\u306b\u66f8\u304f\u7406\u7531\u306f\u3001\u5024\u3092\u4f7f\u7528\u3057\u305f\u3044\u305f\u3081\u4f7f\u7528\u6a29\u3092\u6e21\u3057\u307e\u3059\u3088\u3001\u3068\u7406\u89e3\u3057\u307e\u3057\u305f\u3002<\/p>\n
\u3068\u3044\u3046\u4e8b\u3067\u3001\u52a0\u901f\u5ea6\u5024\u3092\u53d6\u5f97\u3059\u308b\u30b3\u30fc\u30c9\u3092\u307e\u308b\u3063\u3068\u3053\u3053\u306b\u66f8\u3044\u3066\u307f\u307e\u3059\u3002<\/p>\n
\n
    let databuf = [0u8; 4096];\n    let num = 0;\n\n     std::thread::spawn(move || {\n        loop {\n            let axis_array: [f32; 3] =  spi_adxl345::current_acceleration_array();\n\n            let retbytes_x: [u8; 4] = axis_array[0].to_le_bytes();\n            let retbytes_y: [u8; 4] = axis_array[1].to_le_bytes();\n            let retbytes_z: [u8; 4] = axis_array[2].to_le_bytes();\n\n            if num>(4095-12){ \n                num = 0;\n            }\n            for n in 0..4 {\n                databuf[num + n] = retbytes_x[n];\n                databuf[num + n + 4] = retbytes_y[n];\n                databuf[num + n + 8] = retbytes_z[n];\n            }\n            num+=12; \n\n            println!(\"x_axis:{} y_axis:{} z_axis:{} num={}\", axis_array[0], axis_array[1], axis_array[2], num);\n\n            std::thread::sleep(Duration::from_millis(10));\n        }});\n<\/code><\/pre>\n<\/div>\n
\uff08\u3044\u308d\u3044\u308d\u9593\u9055\u3063\u3066\u307e\u3059\u3002\u6709\u8b58\u8005\u306e\u65b9\u3001\u8a00\u3044\u305f\u3044\u3053\u3068\u304c\u6ca2\u5c71\u3042\u308b\u3068\u601d\u3044\u307e\u3059\u3002\uff09
\ndatabuf\u306b\u6e2c\u5b9a\u3057\u305f\u52a0\u901f\u5ea6\u5024\u3092\u5165\u308c\u3066\u3044\u304d\u307e\u3059\u3002
\nnum\u306f\u3001\u6b21\u306e\u6e2c\u5b9a\u5024\u304c\u5165\u308b\u5834\u6240\u3092\u793a\u3057\u307e\u3059\u3002
\n\u52a0\u901f\u5ea6\u30bb\u30f3\u30b5\u306e\u5024\u3092\u8aad\u3093\u3060\u5f8c\u306f10ms\u79d2sleep\u3057\u3001\u518d\u5ea6\u52a0\u901f\u5ea6\u30bb\u30f3\u30b5\u306e\u5024\u3092\u8aad\u3080\u3001\u3092\u7e70\u308a\u8fd4\u3057\u307e\u3059\u3002<\/p>\n
\u203b\u307e\u3060\u30d3\u30eb\u30c9\u306f\u901a\u3057\u307e\u305b\u3093\u3002<\/p>\n
 <\/p>\n<\/div>\n<\/div><\/div><\/div><\/div>
\uff12\uff0e\u5171\u6709\u5909\u6570\u3092\u4ed8\u3051\u308b<\/h3>\n
\n\t
\u3053\u3053\u3067\u3001\u4ee5\u4e0b\uff12\u3064\u306e\u5909\u6570\u306f\u3001\u3053\u306e\u30b9\u30ec\u30c3\u30c9\u3060\u3051\u3067\u306a\u304f\u3001TCP\/IP\u9001\u4fe1\u3092\u884c\u3046\u30b9\u30ec\u30c3\u30c9\u3067\u3082\u4f7f\u3044\u307e\u3059\u3002<\/p>\n
\n
    let databuf = [0u8; 4096];\n    let num = 0;<\/code><\/pre>\n<\/div>\n
\u6392\u4ed6\u5236\u5fa1\u4ed8\u304d\u3067\u3001\u5171\u6709\u5909\u6570\u306b\u3059\u308b\u305f\u3081\u306b\u306f\u3069\u3046\u3059\u308c\u3070\u3088\u3044\u306e\u3067\u3057\u3087\u3046\uff1f<\/p>\n
\u7b54\u3048\u306f\u3053\u306eURL\u306b\u3042\u308a\u307e\u3059\u3002
\nhttps:\/\/doc.rust-lang.org\/std\/sync\/struct.Mutex.html<\/a><\/p>\n
let data_mutex = Arc::new(Mutex::new(vec![1, 2, 3, 4]));
\nlet res_mutex = Arc::new(Mutex::new(0));<\/p>\n
\u3053\u308c\u3001\u3053\u306e\u5f62\u3067\u3059\u3002
\n\u3053\u306e\u30b5\u30a4\u30c8\u5185\u306e\u30b3\u30e1\u30f3\u30c8\u3092\u629c\u7c8b\u3057\u307e\u3059\u3002
\n\/\/ Here we're using an Arc to share memory among threads, and the data inside
\n\/\/ the Arc is protected with a mutex.<\/p>\n
Arc\u3092\u4ed8\u3051\u308b\u3068\u5171\u6709\u30e1\u30e2\u30ea\u306b\u3059\u308b\u3053\u3068\u304c\u3067\u304d\u3066\u3001\u305d\u306e\u5909\u6570\u306fMutex\u3067\u30d7\u30ed\u30c6\u30af\u30c8\u3067\u304d\u308b\u3001\u3068\u66f8\u304b\u308c\u3066\u3044\u307e\u3059\u3002<\/p>\n
\u3058\u3083\u3001\u305d\u3046\u3057\u3066\u307f\u307e\u3057\u3087\u3046\uff01<\/p>\n
\n
    let databuf = Arc::new(Mutex::new([0u8; 4096]));\n    let num = Arc::new(Mutex::new(0));<\/code><\/pre>\n<\/div>\n
\u6b21\u306f\u6392\u4ed6\u5236\u5fa1\u306e\u305f\u3081\u306e\u30b3\u30fc\u30c9\u3092\u66f8\u304b\u306a\u3044\u3068\u3044\u3051\u306a\u3044\u306f\u305a\u3067\u3059\u3002<\/p>\n
\u6392\u4ed6\u5236\u5fa1\uff1a
\n\u30fb\u30b9\u30ec\u30c3\u30c9\u306b\u6301\u3063\u3066\u3044\u304f\u305f\u3081\u3001clone\u3059\u308b
\n\u30fb\u30b9\u30ec\u30c3\u30c9\u5185\u3067\u4f7f\u3046\u3068\u304d\u3001lock \u3059\u308b
\n\u30fblock()\u5f8c\u306bunwrap()\u3059\u308b\u3002
\n\u3068\u3044\u3046\u64cd\u4f5c\u304c\u5fc5\u8981\u3067\u3042\u308b\u3088\u3046\u3067\u3059\u3002<\/p>\n
\u305d\u3057\u3066\u3001<\/span><\/p>\n
unlock\u3055\u308c\u308b\u30bf\u30a4\u30df\u30f3\u30b0\uff1a
\n<\/span>Mutex::lock<\/span><\/a>\u304c\u8fd4\u3057\u305f<\/span>MutexGuard<\/span><\/a>\u304c\u30b9\u30b3\u30fc\u30d7\u3092\u629c\u3051\u3066\u7834\u68c4\u3055\u308c\u308b\u3068unlock\u3055\u308c\u308b\u3002<\/span><\/p>\n
\u65e9\u901f\u4f7f\u3063\u3066\u307f\u307e\u3057\u3087\u3046\uff01<\/p>\n
databuf\u306f\u3001\u30b9\u30ec\u30c3\u30c9\u306b\u6301\u3063\u3066\u3044\u304f\u524d\u306bclone\u3057\u3066databuf_in\u306b\u3057\u307e\u3057\u305f\u3002
\n\u30b9\u30ec\u30c3\u30c9\u5185\u3067lock\u3057databuf_in_1\u3068\u3044\u3046\u540d\u524d\u306b\u3057\u307e\u3057\u305f\u3002<\/p>\n
num\u306b\u3064\u3044\u3066\u306f\u3001\u5171\u6709\u5909\u6570\u306e\u5b9a\u7fa9\u5834\u6240\u3067\u306fpos\u3068\u3044\u3046\u540d\u524d\u306b\u3057\u3001\u30b9\u30ec\u30c3\u30c9\u306b\u6301\u3063\u3066\u3044\u304f\u524d\u306bclone\u3057\u3066pos_in\u306b\u3057\u307e\u3057\u305f\u3002
\n\u30b9\u30ec\u30c3\u30c9\u5185\u3067lock\u3057num\u3068\u3044\u3046\u540d\u524d\u306b\u3057\u307e\u3057\u305f\u3002<\/p>\n
\n
    let databuf = Arc::new(Mutex::new([0u8; 4096]));\n    let pos = Arc::new(Mutex::new(0));\n\n    let databuf_in = Arc::clone(&databuf);\n    let pos_in = Arc::clone(&pos);\n     std::thread::spawn(move || {\n        loop {\n            let axis_array: [f32; 3] =  spi_adxl345::current_acceleration_array();\n\n            let retbytes_x: [u8; 4] = axis_array[0].to_le_bytes();\n            let retbytes_y: [u8; 4] = axis_array[1].to_le_bytes();\n            let retbytes_z: [u8; 4] = axis_array[2].to_le_bytes();\n\n            let mut num = pos_in.lock().unwrap();\n            let mut databuf_in_1 = databuf_in.lock().unwrap();\n\n            if num>(4095-12){   \n                num = 0;\n            }\n            for n in 0..4 {\n                databuf_in_1[num + n] = retbytes_x[n];\n                databuf_in_1[num + n + 4] = retbytes_y[n];\n                databuf_in_1[num + n + 8] = retbytes_z[n];\n            }\n            num+=12; \n\n            println!(\"x_axis:{} y_axis:{} z_axis:{} num={}\", axis_array[0], axis_array[1], axis_array[2], *num);\n\n            std::thread::sleep(Duration::from_millis(10));\n        }});<\/code><\/pre>\n<\/div>\n
\u826f\u3055\u305d\u3046\u3068\u601d\u3063\u305f\u306e\u3067\u3059\u304c\u3001\u30d3\u30eb\u30c9\u3082\u3057\u3066\u3044\u306a\u3044\u306e\u306b\u3001\u3082\u3046\u6012\u3089\u308c\u307e\u3057\u305f\u3002<\/p>\n
\"\"<\/a><\/p>\n
\u4f55\u3084\u3089\u96e3\u3057\u305d\u3046\u306a\u3002\u3002\u3002<\/p>\n
\u3061\u3087\u3063\u3068\u30d3\u30eb\u30c9\u3057\u3066\u307f\u307e\u3057\u3087\u3046\u3002\u4f55\u304b\u6559\u3048\u3066\u304f\u308c\u308b\u304b\u3082\uff01<\/p>\n
\"\"<\/a><\/p>\n
\u6559\u3048\u3066\u304f\u308c\u307e\u3057\u305f\uff01<\/p>\n
\u3042\u308c\u3001\u30a2\u30b9\u30bf\u30ea\u30b9\u30af\u3063\u3066\u4f55\u3060\u3063\u3051\u3002\u4f55\u304b\u3042\u3063\u305f\u3088\u3046\u306a\u6c17\u304c\u3059\u308b\u3002\u3002\u3002<\/p>\n
\u904e\u53bb\u8a18\u4e8b\u3092\u898b\u3066\u307f\u307e\u3057\u305f\u3002<\/p>\n
https:\/\/note.com\/yn_2022\/n\/nf64d5d2b3547
\n<\/a>\u300c\u201d * \u201d\u306b\u3088\u3063\u3066\uff08\uff09\u306e\u4e2d\u8eab\u306e\u751f\u30dd\u30a4\u30f3\u30bf\u3092\u4e00\u65e6\u53c2\u7167\u89e3\u9664\u3057\u53c2\u7167\u5148\u306e\u5834\u6240\u306b\u30a2\u30af\u30bb\u30b9\u3059\u308b\u3088\u3046\u306b\u3057\u307e\u3059\u3002\u300d<\/p>\n
\u53c2\u7167\u89e3\u9664\uff01
\n\u3060\u3060\u3057\u3001\u3053\u3053\u3067\u306f\u751f\u30dd\u30a4\u30f3\u30bf\u3067\u306f\u306a\u304f\u3001<\/span>Mutex::lock<\/span><\/a>\u304c\u8fd4\u3057\u305f<\/span>MutexGuard<\/span><\/a>\u3092\u53c2\u7167\u89e3\u9664\u3057\u3066\u3044\u307e\u3059\u3002<\/span><\/p>\n
\n
            if *num>(4095-12){\n                *num = 0;\n            }\n            for n in 0..4 {\n                databuf_in_1[*num + n] = retbytes_x[n];\n                databuf_in_1[*num + n + 4] = retbytes_y[n];\n                databuf_in_1[*num + n + 8] = retbytes_z[n];\n            }\n            *num+=12;<\/code><\/pre>\n<\/div>\n
\u3058\u3083\u3001\u30d3\u30eb\u30c9\u3057\u3066\u307f\u307e\u3059\u3002
\n\u901a\u308a\u307e\u3057\u305f\uff01<\/p>\n<\/div>\n<\/div><\/div>
\uff13\uff0e\u52a0\u901f\u5ea6\u5024\u3092\u30cd\u30c3\u30c8\u30ef\u30fc\u30af\u7d4c\u7531\u3067\u8fd4\u3059\u3088\u3046\u306b\u3059\u308b<\/h3>\n
\n\t
\u3067\u306f\u305d\u306e\uff12\u3064\u306e\u5171\u6709\u5909\u6570\u3001TCP\/IP\u9001\u4fe1\u90e8\u3067\u4f7f\u3048\u308b\u3088\u3046\u306b\u3057\u307e\u3059\u3002<\/p>\n
 <\/p>\n
3.1 TCP\/IP\u9001\u4fe1\u672c\u4f53\u95a2\u6570\u3067\u4f7f\u7528\u3059\u308b\u305f\u3081\u306e\u6e96\u5099<\/h3>\n
\u307e\u305a\u3001TCP\/IP\u9001\u4fe1\u672c\u4f53\u95a2\u6570\u306b\u3082\u3063\u3066\u3044\u304b\u306a\u3051\u308c\u3070\u3044\u3051\u307e\u305b\u3093\u3002<\/p>\n
\n
    for i in 0..NUM_WORKERS {\n        let send_job_ingress = send_job_ingress.clone();\n        let databuf_out = Arc::clone(&databuf);\n        let pos_out = Arc::clone(&pos);<\/span><\/strong>\n        std::thread::spawn(move || worker_loop(Worker(i), send_job_ingress, databuf_out, pos_out<\/span><\/strong>));\n    }\n<\/code><\/pre>\n<\/div>\n
\u5148\u7a0b\u3068\u540c\u69d8\u3001<\/p>\n
databuf\u306f\u3001\u30b9\u30ec\u30c3\u30c9\u306b\u6301\u3063\u3066\u3044\u304f\u524d\u306bclone\u3057\u3066databuf_out\u306b\u3057\u307e\u3057\u305f\u3002
\npos\u306f\u30b9\u30ec\u30c3\u30c9\u306b\u6301\u3063\u3066\u3044\u304f\u524d\u306bclone\u3057\u3066pos_out\u306b\u3057\u307e\u3057\u305f\u3002<\/p>\n
\u30b9\u30ec\u30c3\u30c9\u672c\u4f53\u306e\u95a2\u6570\u306f\u4ee5\u4e0b\u306b\u306a\u308a\u307e\u3057\u305f\u3002<\/p>\n
\n
fn worker_loop(worker: Worker, send_job_ingress: mpsc::SyncSender, databuf_out: Arc<Mutex<[u8; 4096]>>, pos_out: Arc<Mutex><\/span><\/strong>) {\n    let mut buf = [0u8; 4096]; \n\n    loop {\n        \/\/ Get a new job by sending a FD sender to the acceptor\n        let (send_client_fd, recv_client_fd) = mpsc::sync_channel(1);\n        let _ = send_job_ingress.send(JobIngress { send_client_fd });\n        let Ok(client_fd) = recv_client_fd.recv() else {\n            \/\/ `Err(RecvError)` indicates that `send_client_fd` has been dropped.\n            \/\/\n            \/\/ This implies the `JobIngress` we sent was discarded without being consumed,\n            \/\/ meaning the acceptor exited for some reason. \n            return;\n        };\n\n        \/\/ Serve the client\n        let client_fd_raw = client_fd.as_raw_fd(); \/\/ for logging\n        log::info!(\"{worker:?}: Serving client FD {client_fd_raw}\");\n        if let Err(e) = serve_client(&client_fd, &mut buf, &databuf_out, &pos_out<\/span><\/strong>) {\n            log::info!(\"{worker:?}: Finished serving client FD {client_fd_raw} with error: {e:?}\");\n        } else {\n            log::info!(\"{worker:?}: Finished serving client FD {client_fd_raw} successfully\");\n        }\n    }\n}<\/code><\/pre>\n<\/div>\n
\u672c\u4f53\u306f\u3082\u3046\u4e00\u3064\u4e0b\u3067\u3059\u306d\u3002
\n\u672c\u4f53\u306f\u3053\u3061\u3089\u3067\u3059\u3002<\/p>\n
\n
fn serve_client(client_fd: &TcpStream, buffer: &mut [u8], databuf_out: &Arc<Mutex<[u8; 4096]>>, pos_out: &Arc<Mutex><\/span><\/strong>) -> io::Result<()> {\n    client_fd.set_write_timeout(Some(Duration::from_secs(30)))?;\n    client_fd.set_read_timeout(Some(Duration::from_secs(30)))?; \n\n    loop {\n        \/\/ Read data from the socket\n        let num_read_bytes = (&*client_fd).read(buffer)?;\n        if num_read_bytes == 0 {\n            client_fd.shutdown(Shutdown::Both)?;\n            break; \n        }\n\n        \/\/ Write back the data to the socket\n        let mut num = pos_out.lock().unwrap();\n        let databuf_out_1 = databuf_out.lock().unwrap();<\/span><\/strong>\n\n        match (&*client_fd).write_all(&buffer[..num_read_bytes]) {\n            Err(e) if e.kind() == io::ErrorKind::WriteZero => {\n                break;\n            }\n            result => result?,\n        };\n    }\n\n    Ok(())\n}\n<\/code><\/pre>\n<\/div>\n
\u5b9a\u7fa9\u3057\u305f\u5171\u6709\u5909\u6570\u3092\u3001TCP\/IP\u9001\u4fe1\u95a2\u6570\u5185\u3067\u4f7f\u7528\u3059\u308b\u6e96\u5099\u304c\u6574\u3044\u307e\u3057\u305f\u3002<\/p>\n
 <\/p>\n
3.2 TCP\/IP\u9001\u4fe1\u30c7\u30fc\u30bf\u3092\u30d0\u30c3\u30d5\u30a1\u304b\u3089\u53d6\u5f97\u3059\u308b<\/h3>\n
\u3067\u306f\u3044\u3088\u3044\u3088databuf_out_1\u306e\u4e2d\u306e\u30c7\u30fc\u30bf\u3092\u3001\u30a4\u30f3\u30c7\u30c3\u30af\u30b90\u304b\u3089(num-1)\u307e\u3067TCP\/IP\u9001\u4fe1\u3059\u308b\u30b3\u30fc\u30c9\u3092\u66f8\u304d\u307e\u3059\u3002<\/p>\n
\u307e\u305a\u306flock()\u3057\u3066\u3001\u30a2\u30af\u30bb\u30b9\u6a29\u3092\u53d6\u308a\u307e\u3059\u3002<\/p>\n
\n
let databuf_out_1 = databuf_out.lock().unwrap();\n<\/code><\/pre>\n<\/div>\n
\u305d\u3057\u3066\u3001\u30d0\u30c3\u30d5\u30a1\u306b\u30a2\u30af\u30bb\u30b9\u3057\u307e\u3059\u3002<\/p>\n
\n
match (&*client_fd).write_all(databuf_out_1[..*num]) { \n<\/code><\/pre>\n<\/div>\n
\u3053\u306e\u307e\u307e\u3060\u3068\u3001\u4ee5\u4e0b\u306e\u3088\u3046\u306b\u6307\u6458\u3055\u308c\u307e\u3059\u3002<\/p>\n
\"\"<\/a><\/p>\n
\u307e\u305f\u5b89\u76f4\u306b\u3001\u30d3\u30eb\u30c9\u306b\u983c\u3063\u3066\u307f\u307e\u3059\u3002<\/p>\n
\u30d3\u30eb\u30c9\u3059\u308b\u3068\u3001\u4ee5\u4e0b\u306e\u3088\u3046\u306b\u30a2\u30c9\u30d0\u30a4\u30b9\u9802\u304d\u307e\u3057\u305f\u3002<\/p>\n
\"\"<\/a><\/p>\n
\u3042\u3001\u305d\u3046\u304b\u3002\u53c2\u7167\u3059\u308b\u306b\u306f\uff06\u304c\u3044\u308b\u3093\u3060\u3063\u3051\u3002
\n\u904e\u53bb\u8a18\u4e8b\u306b\u3088\u308b\u3068\u3001\u300c\uff06\u3092\u3064\u3051\u3001\u501f\u7528\u3067\u3042\u308b\u3053\u3068\u3092\u660e\u793a\u7684\u306b\u4f1d\u3048\u307e\u3059\u3002\u300d\u3068\u66f8\u3044\u3066\u3044\u307e\u3059\u3002<\/p>\n
\n
match (&*client_fd).write_all(&databuf_out_1[..*num]) {\n<\/code><\/pre>\n<\/div>\n
 <\/p>\n
3.3\u00a0\u30d0\u30c3\u30d5\u30a1\u5185\u306e\u6700\u65b0\u30c7\u30fc\u30bf\u683c\u7d0d\u4f4d\u7f6e\u3092\u77e5\u308b<\/h3>\n
\u3067\u306f\u3001num\u306e\u5024\u3092\u53d6\u5f97\u3057\u3001\u30d0\u30c3\u30d5\u30a1\u5185\u3067TCP\/IP\u9001\u4fe1\u3059\u308b\u9818\u57df\u3092\u6c7a\u5b9a\u3057\u307e\u3059\u3002<\/p>\n
\u307e\u305a\u306flock()\u3057\u3066\u3001\u30a2\u30af\u30bb\u30b9\u6a29\u3092\u53d6\u308a\u307e\u3059\u3002<\/p>\n
\n
let mut num = pos_out.lock().unwrap();\n<\/code><\/pre>\n<\/div>\n
databuf_out_1\u30d0\u30c3\u30d5\u30a1\u5185\u30a4\u30f3\u30c7\u30c3\u30af\u30b9\u304cnum\u306b\u306a\u308b\u624b\u524d\u307e\u3067\u9001\u4fe1\u3057\u307e\u3059\u3002\uff08\u3053\u306e\u884c\u306f\u5148\u307b\u3069\u65e2\u306b\u66f8\u304d\u307e\u3057\u304c\uff09<\/p>\n
\u3055\u3089\u306b\u3001\u9001\u4fe1\u3057\u7d42\u308f\u3063\u305f\u5f8c\u306bnum\u3092\u30bc\u30ed\u30af\u30ea\u30a2\u3057\u307e\u3059\u3002<\/p>\n
\n
        match (&*client_fd).write_all(&databuf_out_1[..*num]) {\n            Err(e) if e.kind() == io::ErrorKind::WriteZero => {\n                break;\n            }\n            result => result?,\n        };\n        println!(\"num={}\", *num);\n        *num = 0;\n<\/code><\/pre>\n<\/div>\n
\u3067\u304d\u307e\u3057\u305f\uff01
\n\u30d3\u30eb\u30c9\u3082\u901a\u308a\u307e\u3057\u305f\u3002<\/p>\n
 <\/p>\n
 <\/p>\n<\/div>\n<\/div><\/div>
\uff14\uff0e\uff30\uff23\u5074\u30a2\u30d7\u30ea\u306e\u5909\u66f4<\/h3>\n
\n\t
\uff30\uff23\u5074\u306e\uff23\uff03\u30a2\u30d7\u30ea\u3092\u4ee5\u4e0b\u306e\u3088\u3046\u306b\u5909\u66f4\u3057\u307e\u3059\u3002<\/p>\n
\"\"<\/a><\/p>\n
\u4ed5\u69d8\uff1a
\n\u30fbget\u30dc\u30bf\u30f3\u3067\u30c7\u30fc\u30bf\u53d6\u5f97\uff08\u3053\u308c\u306f\u540c\u3058\uff09
\n\u30fb\u53d6\u5f97\u3057\u305f\u30c7\u30fc\u30bf\u306e\u6700\u5f8c\u306e\u52a0\u901f\u5ea6\u5024\u3092\u30c0\u30a4\u30a2\u30ed\u30b0\u306b\u8868\u793a
\n\u30fb\u53d6\u5f97\u3057\u305f\u30c7\u30fc\u30bf\u6570\u3082\u8868\u793a
\n\u30fb\u53d6\u5f97\u3057\u305f\u30c7\u30fc\u30bf\u306f\u3059\u3079\u3066\u30d5\u30a1\u30a4\u30eb\u306b\u30bb\u30fc\u30d6\u3059\u308b\u3002
\n\u30fb\u683c\u7d0d\u3059\u308b\u30d5\u30a1\u30a4\u30eb\u540d\u306f\u3001\u5e74\u6708\u65e5_\u6642\u5206\u79d2.csv\u3002<\/p>\n
 <\/p>\n<\/div>\n<\/div><\/div>
\uff15\uff0e\u5b9f\u884c\uff01<\/h3>\n
\n\t
\u5b9f\u884c\u3067\u304d\u307e\u3057\u305f\uff01<\/p>\n
\u306a\u3093\u3068\u3001\u307e\u305f\u3001SOLID\u5074\u30c7\u30d0\u30c3\u30b0\u4e0d\u8981\u3067\u3057\u305f\uff01
\n\u30d3\u30eb\u30c9\u304c\u901a\u3063\u305f\u3089\u52d5\u304d\u307e\u3057\u305f\u3002<\/p>\n
\u30fb\u52d5\u4f5c\u30ed\u30b0\u51fa\u529b<\/p>\n
\"\"<\/a><\/p>\n
Worker(0)\u3068\u51fa\u3066\u3044\u308b\u3068\u3053\u308d\u3067\u3001TCP\/IP\u53d7\u4fe1\u3057\u307e\u3057\u305f\u3002
\n\u305d\u3053\u304b\u3089num=3324\u3068\u51fa\u3066\u3044\u308b\u3068\u3053\u308d\u307e\u3067\u306e\u9593\u3067\u3001\u305f\u307e\u3063\u305f\u52a0\u901f\u5ea6\u30bb\u30f3\u30b5\u306e\u5024\u3092PC\u306bTCP\/IP\u9001\u4fe1\u3057\u3066\u3044\u307e\u3059\u3002<\/p>\n
\u9001\u4fe1\u30c7\u30fc\u30bf\u306f3324\u30d0\u30a4\u30c8\u3002X\/Y\/Z\u8ef8\u306e\u30c7\u30fc\u30bf\u4e00\u5f0f\u304c12\u30d0\u30a4\u30c8\u306a\u306e\u3067\u3001
\n3324\/12=277\u30bb\u30c3\u30c8\u306e\u30c7\u30fc\u30bf\u304c\u9001\u3089\u308c\u3066\u3044\u307e\u3059\u3002<\/p>\n
 <\/p>\n
\u30fbPC\u5074\u30a2\u30d7\u30ea\u8868\u793a<\/p>\n
\"\"<\/a><\/p>\n
277\u30bb\u30c3\u30c8\u5206\u306e\u30c7\u30fc\u30bf\u304c\u9001\u3089\u308c\u3066\u3044\u308b\u3053\u3068\u304c\u308f\u304b\u308a\u307e\u3059\u3002
\n\u6700\u7d42\u52a0\u901f\u5ea6\u5024\u306f\u3001\u8868\u793a\u3057\u3066\u3044\u308b\u901a\u308a\u3067\u3059\u3002\u4e0a\u8a18\u30bf\u30fc\u30df\u30ca\u30eb\u306e\u5024\u3068\u540c\u69d8\u3067\u3059\u3002<\/p>\n
 <\/p>\n
\u30fb\u30d5\u30a1\u30a4\u30eb\u30bb\u30fc\u30d6\u5185\u5bb9<\/p>\n
\u30bb\u30fc\u30d6\u3057\u305f\u30d5\u30a1\u30a4\u30eb\u306e\u5148\u982d\u3067\u3059\u3002<\/p>\n
\"\"<\/a><\/p>\n
\u6700\u5f8c\u306f\u3053\u3046\u306a\u3063\u3066\u3044\u307e\u3059\u3002<\/p>\n
\"\"<\/a><\/p>\n
CSV\u30d5\u30a1\u30a4\u30eb\u306b\u3057\u3001Excel\u3067\u30b0\u30e9\u30d5\u8868\u793a\u3057\u3066\u307f\u307e\u3057\u305f\u3002<\/p>\n
\"\"<\/a><\/p>\n
Raspberry Pi 4\u3092\u5165\u308c\u305f\u5bb9\u5668\u3092\u6307\u30d4\u30f3\u3057\u3066\u307f\u307e\u3057\u305f\u3002\u3053\u3093\u306a\u611f\u3058\u3067\u53d6\u308c\u307e\u3057\u305f\u3002<\/p>\n
\"\"<\/a><\/p>\n
\u6700\u5f8c\u306b\u3001\u30c7\u30d0\u30c3\u30b0\u7528\u306b\u52a0\u901f\u5ea6\u30bb\u30f3\u30b5\u306e\u5024\u3092\u8aad\u3093\u3060\u76f4\u5f8c\u306b\u305d\u306e\u5024\u3092\u8868\u793a\u3057\u3066\u3044\u308b\u90e8\u5206\u3092\u524a\u9664\uff08\u30b3\u30e1\u30f3\u30c8\u30a2\u30a6\u30c8\uff09\u3057\u307e\u3057\u305f\u3002
\n\u3053\u308c\u304c\u3042\u308b\u3068UART\u51fa\u529b\u306e\u305f\u3081\u306b\u6642\u9593\u3092\u8981\u3059\u308b\u305f\u3081\u3001\u3067\u3059\u3002<\/p>\n
\"\"<\/a><\/p>\n
\u3042\u307e\u308a\u5909\u308f\u3089\u306a\u3044\u3067\u3059\u306d\u3002<\/p>\n
\u203b\u52a0\u901f\u5ea6\u30bb\u30f3\u30b5\u3092\u8aad\u3093\u3060\u5f8c\u306bsleep\u3059\u308b\u6642\u9593\u30921ms\u306b\u3057\u3066\u307f\u307e\u3057\u305f\u304c\u3001\u6b63\u3057\u3044\u5024\u304c\u30bb\u30f3\u30b5\u304b\u3089\u8aad\u3081\u306a\u3044\u3088\u3046\u3060\u3063\u305f\u306e\u3067\u3001\u6df1\u8ffd\u3044\u305b\u305a\u65ad\u5ff5\u3057\u307e\u3057\u305f\u3002<\/p>\n
\u3044\u308d\u3044\u308d\u3042\u308a\u307e\u3057\u305f\u304c\u3001\u3053\u3053\u307e\u3067\u52d5\u304b\u3059\u3053\u3068\u304c\u3067\u304d\u307e\u3057\u305f\uff01
\n\u53c2\u7167\u306e\uff06\u3068\uff0a\u304c\u3001\u81ea\u767a\u7684\u306b\u4f7f\u3048\u308b\u307b\u3069\u7406\u89e3\u306f\u3057\u3066\u3044\u306a\u3044\u3067\u3059\u304c\u3001\u4eca\u56de\u306e\u5185\u5bb9\u306b\u3064\u3044\u3066\u306f\u30a8\u30e9\u30fc\u30e1\u30c3\u30bb\u30fc\u30b8\u306b\u52a9\u3051\u3089\u308c\u3066\u66f8\u304f\u3053\u3068\u304c\u3067\u304d\u307e\u3057\u305f\u3002<\/p>\n
\u6b21\u56de\u306f\u3001\u6709\u8b58\u8005\u30c1\u30a7\u30c3\u30af\u3092\u3057\u3066\u9802\u3044\u3066\u3001\u305d\u306e\u7d50\u679c\u3092\u66f8\u304d\u305f\u3044\u3068\u601d\u3044\u307e\u3059\u3002<\/p>\n<\/div>\n<\/div><\/div><\/div><\/div>
<\/div><\/div>
<\/div><\/div>
<\/div><\/div>
<\/div><\/div>
<\/div><\/div>
<\/div><\/div>
<\/div><\/div>
<\/div><\/div><\/div>","protected":false},"excerpt":{"rendered":"
(2023\/2\/28)   \u524d\u56de\u3001Windows PC\u3068Raspberry Pi 4\u3092\u30cd\u30c3\u30c8\u30ef\u30fc\u30af\u3067\u63a5\u7d9a\u3057\u3001TCP\/IP\u901a\u4fe1\u3067Raspberry Pi 4\u304c\u53d6\u5f97\u3057\u305f\u52a0\u901f\u5ea6\u30bb\u30f3\u30b5ADXL345\u306e\u5024\u3092PC\u306b\u6e21\u3059\u30b3\u30fc […]<\/p>\n","protected":false},"author":15,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[],"class_list":["post-6195","post","type-post","status-publish","format-standard","hentry","category-1"],"_links":{"self":[{"href":"https:\/\/solid.kmckk.com\/SOLID\/wp-json\/wp\/v2\/posts\/6195","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/solid.kmckk.com\/SOLID\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/solid.kmckk.com\/SOLID\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/solid.kmckk.com\/SOLID\/wp-json\/wp\/v2\/users\/15"}],"replies":[{"embeddable":true,"href":"https:\/\/solid.kmckk.com\/SOLID\/wp-json\/wp\/v2\/comments?post=6195"}],"version-history":[{"count":0,"href":"https:\/\/solid.kmckk.com\/SOLID\/wp-json\/wp\/v2\/posts\/6195\/revisions"}],"wp:attachment":[{"href":"https:\/\/solid.kmckk.com\/SOLID\/wp-json\/wp\/v2\/media?parent=6195"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/solid.kmckk.com\/SOLID\/wp-json\/wp\/v2\/categories?post=6195"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/solid.kmckk.com\/SOLID\/wp-json\/wp\/v2\/tags?post=6195"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}