常連

python3.9でUDPのブロードキャスト通信をつかい１つのパソコンで送受信をしようとしています。
送信側のプログラムを実行すると sock.sendto(b"Hello, UDP BroadCast",(HOST_NAME, PORT))
OSError: [WinError 10049] 要求したアドレスのコンテキストが無効です。となってしまいます。
原因を教えていただけるとありがたいです。
受信側
```
import socket

HOST_NAME=''
PORT=8080

sock=socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

sock.bind((HOST_NAME, PORT))
 
while True:

    rcv_date, addr = sock.recvfrom(1024)
    print("receive date:[{}] from{}".format(rcv_date,addr))

    sock.close()
```
送信側
```
import socket


HOST_NAME=''
PORT=8080

sock=socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

sock.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)

sock.sendto(b"Hello, UDP BroadCast",(HOST_NAME, PORT))

sock.close()
```

pythonでUDP通信をする

### 前提

C言語でUDP通信を使ったチャットプログラムを製作中、クライアント側からのチャット参加要求の処理に困っています。
### 実現したいこと

ここに実現したいことを箇条書きで書いてください。
- [ ] 線形連結リストを使って、クライアント用のクライアント管理データを作成し、データ集合内に保持する。（可能であれば削除まで）



### 該当のソースコード

```C

//サーバー側のプログラム

#include <stdio.h>
#include <string.h>
#include <arpa/inet.h>
#include <stdlib.h>
#include <unistd.h>
#include <time.h>

#include "MessagePacket.h"

// 静的グローバル変数
static int g_sock;	// チャットクライアントと通信するために利用するソケット

// 構造体の宣言
struct ClientData {
	char srcAddr[INET_ADDRSTRLEN];		// クライアントのアドレス
	u_short srcPort;					// クライアントのポート番号
	char participantName[MSG_BUF_SIZE];	// 参加者名
	time_t lastReceivingTime;			// メッセージを最後に受信した時刻
};

struct Node {
//	struct ClientData client;
//	struct Node* next;
//};

// 静的グローバル変数
static struct Node* g_root;

void SvrInitialize(
	int sock)	// [IN] チャットクライアントと通信するためのソケット
{
	// チャットクライアントと通信するためのソケットをこのファイル内で保持する．
	g_sock = sock;

int SvrJoinRequestHandler(
	struct sockaddr_in clntAddr,	// [IN ] クライアントのアドレス構造体
	char* msgBuf,					// [IN ] メッセージバッファ
	short msgLen)					// [IN ] メッセージの長さ
{
	int result = 1;	// 戻り値

	// 送信元のIPアドレスとポート番号を取得する．
	char srcAddr[INET_ADDRSTRLEN];
	inet_ntop(AF_INET, &clntAddr.sin_addr.s_addr, srcAddr, INET_ADDRSTRLEN);
	u_short srcPort = ntohs(clntAddr.sin_port);

	// クライアントの参加者名として受信した文字列を終端し，表示する．
	msgBuf[msgLen] = '\0';
	printf("クライアント(IPアドレス：%s, ポート番号：%d)からの参加要求：%s\n", srcAddr, srcPort, msgBuf);

	// クライアントからの参加要求を処理する．
	// ※参加要求を送ってきたクライアント用のクライアント管理データを作成し，
	//   データ集合内に保持する必要がある．
	//未実装

	// グループへの参加応答を送信する．
	short sentByte = SendMessagePacket(
		g_sock,				// クライアントとの通信用ソケット
		clntAddr,			// クライアントのアドレス (参加要求送信元のアドレス)
		MSG_JOIN_RESPONSE,	// グループへの参加応答のメッセージID
		msgBuf,				// クライアントの参加者名
		msgLen				// クライアントの参加者名の長さ
	);
	if (sentByte < 0) {
		fprintf(stderr, "error: SvrJoinRequestHandler() -> SendMessagePacket(): %d\n", sentByte);
	}
	// 送信バイト数(エラーの場合を含む)を戻り値として返す．
	result = sentByte;
	return result;
}
```

### 試したこと

ノード構造体の記述までは行うことができました（コード13～27）が、そもそも線形連結リストに慣れていないもので、UDP通信においてのリストの生成や追加については徹夜で調べても分かりませんでした。ヒントでもいいので現状打破のきっかけが欲しいです。


UDP通信とC言語の線形連結リストについて

### 前提

C＃　.NetFrameWork4.6.2で開発を行っております。

UDP送信クラス（同期処理）と受信クラス（非同期処理）をそれぞれ作成したところ、
UDPの送受信が正しく動作する時と動作しない時があり原因がわからず悩んでおります。

UDP送信側はサーバに配置されるコンソールアプリでUDP受信側はクライアントPCに配置されるWindowsFormsアプリを想定しています。
受信側は画面を伴ったアプリの為、画面のロックを回避したいと考えており、
受信待ちの処理と受信後に行う処理は非同期で行う想定で実装しております。

wiresharkを使用してパケットを確認したところ動作しない時はUDP送信は行われているため
受信側の実装に不備があるものと思われます。

知識不足により見よう見まねで作成しているため非同期処理の部分がうまく出来ていないのではないかと
考えておりますが、実装不備な箇所をご指摘いただけないでしょうか。

### 実現したいこと

UDP受信が行われない事があるため、
ソフト面・ハード面のどちらが原因であるか突き止め、
ソフトが原因であれば対応を行いたい。

### 該当のソースコード
送信側クラス
```C#
    public class SendHelper : IDisposable
    {
        UdpClient client { get; set; }

        public SendHelper(int port)
        {
            client = new UdpClient(port);
        }

        public void SendMessage(string message, string destinationAddress, int destinationPort)
        {
            client.Connect(new IPEndPoint(IPAddress.Parse(destinationAddress), destinationPort));
            var enc = Encoding.GetEncoding("utf-8");
            var s = Encoding.UTF8.GetBytes(message);
            client.Send(s, enc.GetByteCount(message));
        }

        public async void SendMessageAsync(string message, string destinationAddress, int destinationPort)
        {
            client.Connect(new IPEndPoint(IPAddress.Parse(destinationAddress), destinationPort));
            await client.SendAsync(Encoding.UTF8.GetBytes(message), message.Length);
        }

        ~SendHelper()
        {
            Dispose();
        }

        public void Dispose()
        {
            if (client != null)
            {
                client.Close();
                client = null;
            }
        }
    }
```
受信側クラス
```C#
    public class RecieveHelper : IDisposable
    {
        UdpClient client { get; set; }

        public RecieveHelper(string ipAddress, int port)
        {
            var address = IPAddress.Parse(ipAddress);
            client = new UdpClient(new IPEndPoint(address, port));
        }

        ~RecieveHelper()
        {
            Dispose();
        }

        public void Dispose()
        {
            if (client != null)
            {
                // 排他制御
                lock (this)
                {
                    client.Close();
                    client = null;
                }
            }
        }

        public delegate void OnRecieveAction(string s);

        public async void ListenStart(OnRecieveAction action)
        {
            while (true)
            {
                Task<UdpReceiveResult> receiveTask;
                // 排他制御
                lock (this)
                {
                    if (client == null)
                    {
                        // Disposeされたのでループを抜ける
                        break;
                    }
                    // ヌルポ回避　←上記if文と下記コードが無い場合、Dispose()で破棄された時に例外が発生
                    receiveTask = client.ReceiveAsync();
                }
                // 非同期で受信待機
                var result = await receiveTask;

                var data = Encoding.UTF8.GetString(result.Buffer);
                await Task.Run(() => {
                    action(data);
                });
            }
        }
    }
```

受信側クラスを使用しているコード
```C#
RecieveHelper = new RecieveHelper(AppConfig.IPAddress, AppConfig.Port);

RecieveHelper.ListenStart(str =>
{
   try
   {
        //受信後の処理
    }
    catch (Exception e)
    {
          // エラー処理
     }
});
```


C#　UDP受信処理を非同期で行いたい

<概要>
DJI社のドローン「Tello」のSDKを用いた動画のストリーム表示がうまくできなくて困っています。

<詳細>
「tello」のSDKに従い、PCにUDPサーバーを立てて「tello」から動画を受信し、opencvでウィンドウ表示させることができない状況です。
（※UDPクライアントを使った「Tello」の離陸と着陸はできています。初心者のため、IPアドレスやポートの設定が間違っていると思うのですが、どのように直して良いのか全くわかりません…お助けいただけると非常に助かりますorz）

<参考にしているページ>
[DJI社の公式SDKガイドPDF]
https://dl-cdn.ryzerobotics.com/downloads/Tello/Tello%20SDK%202.0%20User%20Guide.pdf
[類似の開発ブログ]
http://kodamap.hatenablog.com/entry/2018/12/08/000000
https://qiita.com/mozzio369/items/8e0fb12dc30c493f5cc4
[ソケット通信の勉強]
https://qiita.com/__init__/items/5c89fa5b37b8c5ed32a4

<OSなど>
OS：Windows10
Opencvバージョン：4.0.0
Pythonバージョン：3.7

<エラー内容>
warning: Error opening file (/build/opencv/modules/videoio/src/cap_ffmpeg_impl.hpp:901)
warning: udp://192.168.10.2:11111 (/build/opencv/modules/videoio/src/cap_ffmpeg_impl.hpp:902)
Traceback (most recent call last):
  File "tello_demo.py", line 36, in <module>
    cv2.imshow('frame', frame)
cv2.error: OpenCV(4.0.0) C:\projects\opencv-python\opencv\modules\highgui\src\window.cpp:350: error: (-215:Assertion failed) size.width>0 && size.height>0 in function 'cv::imshow'

<コード内容>
```python
# tello操作用
import socket
import time

# 画像処理用
import cv2

# telloへのアクセス用
tello_ip = '192.168.10.1'
tello_port = 8889
tello_address = (tello_ip, tello_port)

# telloからのデータ受領用
host = '192.168.10.2'
port = 11111
mypc_address = (host, port)

# 通信用のソケットを作成
# ※アドレスファミリ：AF_INET（IPv4）、ソケットタイプ：SOCK_DGRAM（UDP）
socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

# リッスン状態にする
socket.bind(mypc_address)

# コマンドモードを使うため'command'というテキストを投げる
socket.sendto('command'.encode('utf-8'), tello_address)

# ビデオストリーミングを開始させるため、'streamon'というテキストを投げる
socket.sendto('streamon'.encode('utf-8'), tello_address)
print("ストリーミング開始")

# ビデオストリーミングを取得して、ウィンドウに表示
capture = cv2.VideoCapture('udp://192.168.10.2:11111')
while True:
    ret, frame = capture.read()
    cv2.imshow('frame', frame)
    if cv2.waitKey(1) & 0xFF == ord('q'):
        break
capture.release()
cv2.destroyAllWindows()

# ビデオストリーミングを停止させるため、'streamoff'というテキストを投げる
socket.sendto('streamoff'.encode('utf-8'), tello_address)

```

どうぞ、よろしくお願い致します。

ドローン「Tello」を使った動画のストリーム表示が出来ません！

スイッチングハブのLINK/ACTランプが激しく明滅していたので、Wiresharkでパケットキャプチャを行うと、以下の様なarpブロードキャストのパケットが頻繁に流れていました。

> Who has "デフォルトゲートウェイのIPアドレス" Tell "機器AのIPアドレス"

このような現象の原因は、何が考えられるでしょうか？
よろしくお願いします。

arpの"Who has *** Tell ***"パケットが大量に流れる

### 前提
python3.9を用いて，UDP/TCPによるソケット通信を行っています．サーバは，複数のクライアントからUDPでデータを受け取り，そのデータを加工し，TCPでクライアントに返送します．

### 実現したいこと
複数のクライアントからのUDPのデータを一台のサーバで並列(非同期)で捌きたいと考えています．
その際に，**asyncioでタスクを複数作り，同時にUDPデータをrecvfrom()したい**と考えています

### 発生している問題・エラーメッセージ

1つ目のクライアントからのデータは正常に受け取れますが，2つめのクライアントからのデータは受け取れず，recvfromがそのままタイムアウトしてしまいます．

ちなみに，asyncioは並列処理ではなく，シングルスレッドで動作していることは理解していますが，全く知見はありません．

### 該当のソースコード

10つのクライアントからUDPを受信しようと考えているため，def main()内のfor処理を10回繰り返し，10個のタスクを生成しています．


※主にソケット生成/受信/送信部分を見てもらえればよいと思います．

```async.py
import socket
import asyncio


M_Group = "239.1.2.3"
LOCALHOST = socket.gethostbyname(socket.gethostname())
PORT = 1234


FILE_NAME = 'send.txt'

# UDPソケットの設定
udp_sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
udp_sock.setsockopt(socket.IPPROTO_IP, socket.IP_MULTICAST_IF, socket.inet_aton(LOCALHOST))
udp_sock.setsockopt(
    socket.IPPROTO_IP, socket.IP_ADD_MEMBERSHIP,
    socket.inet_aton(M_Group) + socket.inet_aton(LOCALHOST)
)
# 自分の送ったマルチキャストパケットを自身で受け取らない
udp_sock.setsockopt(socket.IPPROTO_IP, socket.IP_MULTICAST_LOOP, 0)
udp_sock.bind(('', PORT))
udp_sock.settimeout(5)

# udp_sock.connect((M_Group, PORT)) 

# TCPソケットの設定
tcp_sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)


file_data = ""
len_data = 0

with open(FILE_NAME, 'r') as f:
    file_data = f.read()
    len_data = len(file_data)


async def recv_loss_packet():    

    print("time to wait for response...")
    try:
        res_data, (src_ip, src_port) = udp_sock.recvfrom(1024)

        print(f'src_ip: {src_ip}, src_port: {src_port}')
        
        
        # packet loss seq split
        recv_seq_ary = res_data.decode().split(",")
        recv_seq_ary.pop(-1)

        recv_seq_ary = list(map(int, recv_seq_ary))
        print(recv_seq_ary)

        # packet loss data resend
        tcp_sock.connect((src_ip, src_port))
        
        for i in recv_seq_ary:
            chunk = file_data[i*10:i*10+10]
            chunk = str(i) + ":" + chunk
            print(chunk)
            
            tcp_sock.send(chunk.encode())
            
    except:
        print(f"Timeout!")


async def main():
    count = 0

    # データを指定バイトごとに分割
    chunks = [file_data[i:i+10] for i in range(0, len_data, 10)]

    for chunk in chunks:
        count+=1
        chunk = str(count) + ":" + chunk
        print(chunk)
   
        udp_sock.sendto(chunk.encode(), (M_Group, PORT))
        time.sleep(0.05)

    for i in range(10):
        asyncio.create_task(recv_loss_packet())

    await asyncio.sleep(10)

asyncio.run(main())

```

### 試したこと

"発生している問題"でも述べましたが，2つのクライアントで試してみたところ，1つめのクライアントからは受け取れて，2つめのクライアントからは，データを受け取れませんでした．

並列処理ではないため，2つのクライアントからの送信を，十分な間隔(2秒)を空けて送信しましたが結果は変わりませんでした．




Python: asyncioを用いて，複数クライアントからUDPデータを同時に受け取りたい

ESP32間でudp通信にて直接メッセージを送りたいと考えています。

2台のESP32に対し、ネット上のコードを参考に、Arduno IDEで送信用と受信用のプログラムを書きました。
しかし知識に乏しいため、案の定、UDP通信には失敗します。
以下のプログラムに対し、アドバイスを頂ければと思います。

自分の疑問点として、
①UDP通信を行う際に、どちらかのAPにもう片方が接続する必要があるか(接続してもudp通信には失敗しました)
②esp32をAPモードにする必要があるのか(IPアドレスの設定のためなのかもしれません)
③通常ルーターが割り振るローカルipアドレスを、ルーターなしに、勝手に自分で定義できるのか
といったものがあります。

おそらく根本的に理解できていないことが原因と考えておりますが、
修正の手がかりを見つけられればと思い質問させていただきました。
知見をお持ちの方、認識不足の点のご指摘だけでも構いませんので、何卒宜しくお願い致します。

```Arduino
//UDP送信用
#include <WiFi.h>
#include <WiFiUdp.h>

const char ssid[] = "esp32_1"; 
const char pass[] = "esp32esp32";  
const int localPort = 10000;      

const IPAddress ip(192, 168, 30, 1);      
const IPAddress subnet(255, 255, 255, 0); 

const IPAddress ip_send(192, 168, 30, 255);//送信先のIPアドレス
 //できれば最後を255に設定し、複数クライアントに送信したいと思います。現在では、ここを送信先IPの192.168.30.2に設定しても失敗します。

byte send_byte = 0x05;//送信する値

WiFiUDP udp;

void setup() {
  Serial.begin(115200);

  WiFi.softAP(ssid, pass);           
  delay(100);                        
  WiFi.softAPConfig(ip, ip, subnet); 

  Serial.print("AP IP address: ");
  IPAddress myIP = WiFi.softAPIP();
  Serial.println(myIP);

  Serial.println("Starting UDP");
  udp.begin(localPort);

  Serial.print("Local port: ");
  Serial.println(localPort);
}


void loop(){
    udp.beginPacket(ip_send,localPort);
    udp.print(send_byte);
    udp.endPacket();
    delay(1000);
}

```
```Arduino
//UDP受信用
#include <WiFi.h>
#include <WiFiUdp.h>

const char ssid[] = "esp32_2"; 
const char pass[] = "esp32esp32"; 
const int localPort = 10000;    

const IPAddress ip(192, 168, 30, 2); 
const IPAddress subnet(255, 255, 255, 0); 

WiFiUDP udp;

void setup() {
  Serial.begin(115200);

  WiFi.softAP(ssid, pass);       
  delay(100);                 
  WiFi.softAPConfig(ip, ip, subnet); 

  Serial.print("AP IP address: ");
  IPAddress myIP = WiFi.softAPIP();
  Serial.println(myIP);

  Serial.println("Starting UDP");
  udp.begin(localPort); 

  Serial.print("Local port: ");
  Serial.println(localPort);
}

void loop() {
  int packetSize = udp.parsePacket();
 
  if (packetSize) {
  Serial.println("ok"); } 
  else{
  Serial.println("no"); }

  delay(1000);
}

```

esp32間でのudp通信について


以下のサイトのプログラムをベースに構造体をUDP通信での送受信をしようとしたのですがちょっと詰まってしました。
https://qiita.com/srs/items/c9286b5cff99e741b993

一応送る構造体は以下のものを想定しています。
```
typedef struct {
  int x;
  int y;
  int z;
}msg;

msg msg_test = { 0, 1 , 2};
```
構造体を宣言してsendtoの部分を書き換えればいけると思ったのですが，どうやらうまくいかないようで...。
多分凄い初歩的な部分だと思われますが，解決策を教えていただけるとありがたいです。