/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Net.Sockets/tests/FunctionalTests/ |
H A D | ArgumentValidationTests.cs | 79 GetSocket().ReceiveBufferSize = -1; in SetReceiveBufferSize_Negative_ArgumentOutOfRange() 88 GetSocket().SendBufferSize = -1; in SetSendBufferSize_Negative_ArgumentOutOfRange() 97 GetSocket().ReceiveTimeout = int.MinValue; in SetReceiveTimeout_LessThanNegativeOne_Throws_ArgumentOutOfRange() 106 GetSocket().SendTimeout = int.MinValue; in SetSendTimeout_LessThanNegativeOne_Throws_ArgumentOutOfRange() 115 GetSocket().Ttl = -1; in SetTtl_OutOfRange_Throws_ArgumentOutOfRange() 119 GetSocket().Ttl = 256; in SetTtl_OutOfRange_Throws_ArgumentOutOfRange() 134 GetSocket(AddressFamily.InterNetworkV6).DontFragment = true; in SetDontFragment_Throws_NotSupported() 141 Assert.Throws<ArgumentNullException>(() => GetSocket().Bind(null)); in Bind_Throws_NullEndPoint_Throws_ArgumentNull() 147 Assert.Throws<ArgumentNullException>(() => GetSocket().Connect(null)); in Connect_EndPoint_NullEndPoint_Throws_ArgumentNull() 216 Assert.Throws<InvalidOperationException>(() => GetSocket().Accept()); in Accept_NotBound_Throws_InvalidOperation() [all …]
|
/dports/net/Sockets/Sockets-2.3.9.9/ |
H A D | UdpSocket.cpp | 162 if (GetSocket() == INVALID_SOCKET) in Bind() 166 if (GetSocket() != INVALID_SOCKET) in Bind() 169 int n = bind(GetSocket(), ad, ad); in Bind() 174 n = bind(GetSocket(), ad, ad); in Bind() 238 if (GetSocket() == INVALID_SOCKET) in Open() 242 if (GetSocket() != INVALID_SOCKET) in Open() 264 if (GetSocket() == INVALID_SOCKET) in CreateConnection() 278 if (GetSocket() == INVALID_SOCKET) in CreateConnection() 336 if (GetSocket() == INVALID_SOCKET) in SendToBuf() 340 if (GetSocket() != INVALID_SOCKET) in SendToBuf() [all …]
|
H A D | Socket.cpp | 246 SOCKET Socket::GetSocket() in GetSocket() function in SOCKETS_NAMESPACE::Socket 722 Attach( sock -> GetSocket() ); in CopyConnection() 975 if (setsockopt(GetSocket(), IPPROTO_IP, IP_OPTIONS, (char *)p, len) == -1) in SetIpOptions() 1061 if (setsockopt(GetSocket(), IPPROTO_IP, IP_TOS, (char *)&tos, sizeof(tos)) == -1) in SetIpTOS() 1079 if (getsockopt(GetSocket(), IPPROTO_IP, IP_TOS, (char *)&tos, &len) == -1) in IpTOS() 1111 if (getsockopt(GetSocket(), IPPROTO_IP, IP_TTL, (char *)&ttl, &len) == -1) in IpTTL() 1172 if (getsockopt(GetSocket(), IPPROTO_IP, IP_MTU, (char *)&mtu, &len) == -1) in IpMtu() 1445 if (getsockopt(GetSocket(), SOL_SOCKET, SO_ERROR, (char *)&value, &len) == -1) in SoError() 1634 if (getsockopt(GetSocket(), SOL_SOCKET, SO_RCVBUF, (char *)&value, &len) == -1) in SoRcvbuf() 1679 if (getsockopt(GetSocket(), SOL_SOCKET, SO_SNDBUF, (char *)&value, &len) == -1) in SoSndbuf() [all …]
|
H A D | SctpSocket.cpp | 89 if (GetSocket() == INVALID_SOCKET) in Bind() 93 if (GetSocket() != INVALID_SOCKET) in Bind() 95 int n = bind(GetSocket(), ad, ad); in Bind() 132 if (GetSocket() == INVALID_SOCKET) in AddAddress() 169 if (GetSocket() == INVALID_SOCKET) in RemoveAddress() 206 if (GetSocket() == INVALID_SOCKET) in Open() 210 if (GetSocket() != INVALID_SOCKET) in Open() 216 int n = connect(GetSocket(), ad, ad); in Open() 264 if (GetSocket() == INVALID_SOCKET) in AddConnection() 287 int n = sctp_getpaddrs(GetSocket(), id, &p); in getpaddrs() [all …]
|
/dports/graphics/urho3d/Urho3D-1.7.1/Source/ThirdParty/kNet/src/ |
H A D | NetworkWorkerThread.cpp | 192 if (connection.GetSocket()) in MainLoop() 193 connection.GetSocket()->Close(); in MainLoop() 196 …n.GetConnectionState() == ConnectionClosed || !connection.GetSocket() || !connection.GetSocket()->… in MainLoop() 204 Event readEvent = connection.GetSocket()->GetOverlappedReceiveEvent(); in MainLoop() 205 if (readEvent.IsNull() || connection.GetSocket()->IsUDPSlaveSocket()) in MainLoop() 215 …bool socketSendReady = connection.GetSocket()->IsOverlappedSendReady() || connection.GetSocket()->… in MainLoop() 221 if (connection.GetSocket()->TransportLayer() == SocketOverUDP) in MainLoop() 234 Event sendEvent = connection.GetSocket()->GetOverlappedSendEvent(); in MainLoop() 301 if (connection->GetSocket()) in MainLoop() 302 connection->GetSocket()->Close(); in MainLoop()
|
H A D | NetworkSimulator.cpp | 60 if (!owner || !owner->GetSocket()) in Free() 64 owner->GetSocket()->AbortSend(queuedBuffers[i].buffer); in Free() 72 if (owner && owner->GetSocket()) in SubmitSendBuffer() 73 owner->GetSocket()->AbortSend(buffer); in SubmitSendBuffer() 113 if (owner && owner->GetSocket()) in Process() 114 owner->GetSocket()->EndSend(queuedBuffers[i].buffer); in Process()
|
/dports/multimedia/kodi-addon-pvr.hts/pvr.hts-19.0.4-Matrix/src/tvheadend/utilities/ |
H A D | TCPSocket.cpp | 38 auto socket = GetSocket(true); in Open() 56 auto socket = GetSocket(); in Shutdown() 71 auto socket = GetSocket(); in Close() 87 auto socket = GetSocket(); in Read() 152 auto socket = GetSocket(); in Write() 167 std::shared_ptr<kissnet::tcp_socket> TCPSocket::GetSocket(bool bCreate /*= false*/) in GetSocket() function in TCPSocket
|
/dports/lang/mono/mono-5.10.1.57/mcs/class/System/Test/System.Net.Sockets/ |
H A D | TcpListenerTest.cs | 134 public Socket GetSocket () in GetSocket() method in MonoTests.System.Net.Sockets.TcpListenerTest.MyListener 152 Assert.IsTrue (null != listener.GetSocket (), "#02"); in PreStartStatus() 183 Assert.IsTrue (null != listener.GetSocket (), "#02"); in PostStartStatus() 185 Socket sock = listener.GetSocket (); in PostStartStatus() 188 Assert.IsTrue (null != listener.GetSocket (), "#04"); in PostStartStatus() 194 Assert.IsTrue (null != listener.GetSocket (), "#07"); in PostStartStatus() 195 Assert.IsTrue (sock != listener.GetSocket (), "#08"); in PostStartStatus()
|
/dports/misc/thrill/thrill-12c5b59bca66df93b66628b3829027bd0f110dd9/thrill/net/tcp/ |
H A D | construct.cpp | 241 tcp.GetSocket().SetNonBlocking(true); in AsyncConnect() 242 int res = tcp.GetSocket().connect(address); in AsyncConnect() 356 int err = _err ? _err : tcp.GetSocket().GetError(); in OnConnected() 373 << " fd=" << tcp.GetSocket().fd() in OnConnected() 397 die_unless(tcp.GetSocket().IsValid()); in OnConnected() 402 << " fd=" << tcp.GetSocket().fd() in OnConnected() 403 << " to=" << tcp.GetSocket().GetPeerAddress() in OnConnected() 438 die_unless(tcp.GetSocket().IsValid()); in OnIncomingWelcome() 473 die_unless(tcp.GetSocket().IsValid()); in OnIncomingWelcomeAndReply() 521 connections_.emplace_back(tcp.GetSocket().accept()); in OnIncomingConnection() [all …]
|
H A D | connection.hpp | 127 { return std::to_string(GetSocket().fd()); } in ToString() 130 Socket& GetSocket() in GetSocket() function in thrill::net::tcp::Connection 134 const Socket& GetSocket() const in GetSocket() function in thrill::net::tcp::Connection 153 { return GetSocket().fd() == c.GetSocket().fd(); } in operator ==() 220 << " fd=" << GetSocket().fd(); in OutputOstream()
|
H A D | select_dispatcher.hpp | 116 int fd = tc.GetSocket().fd(); in AddRead() 124 int fd = tc.GetSocket().fd(); in AddWrite() 138 int fd = tc.GetSocket().fd(); in SetExcept() 151 int fd = tc.GetSocket().fd(); in Cancel()
|
/dports/multimedia/kodi/xbmc-19.3-Matrix/xbmc/platform/posix/network/ |
H A D | NetworkPosix.cpp | 42 if (ioctl(m_network->GetSocket(), SIOCGIFFLAGS, &ifr) < 0) in IsEnabled() 54 if (ioctl(m_network->GetSocket(), SIOCGIFFLAGS, &ifr) < 0) in IsConnected() 60 if (ioctl(m_network->GetSocket(), SIOCGIFADDR, &ifr) < 0) in IsConnected() 74 if (ioctl(m_network->GetSocket(), SIOCGIFADDR, &ifr) >= 0) in GetCurrentIPAddress() 89 if (ioctl(m_network->GetSocket(), SIOCGIFNETMASK, &ifr) >= 0) in GetCurrentNetmask()
|
/dports/multimedia/zoneminder/zoneminder-1.36.5/dep/RtspServer/src/net/ |
H A D | TcpConnection.h | 43 SOCKET GetSocket() const in GetSocket() function 44 { return channel_->GetSocket(); } in GetSocket() 47 { return SocketUtil::GetPeerPort(channel_->GetSocket()); } in GetPort() 50 { return SocketUtil::GetPeerIp(channel_->GetSocket()); } in GetIp()
|
H A D | SelectTaskScheduler.cpp | 35 SOCKET socket = channel->GetSocket(); in UpdateChannel() 63 SOCKET fd = channel->GetSocket(); in RemoveChannel() 102 SOCKET fd = iter.second->GetSocket(); in HandleEvent() 174 SOCKET socket = iter.second->GetSocket(); in HandleEvent()
|
H A D | EpollTaskScheduler.cpp | 31 int fd = channel->GetSocket(); in UpdateChannel() 60 if(::epoll_ctl(epollfd_, operation, channel->GetSocket(), &event) < 0) { in Update() 70 int fd = channel->GetSocket(); in RemoveChannel()
|
/dports/x11-toolkits/wxgtk31/wxWidgets-3.1.5/src/osx/core/ |
H A D | sockosx.cpp | 55 CFSocketRef GetSocket() /* const */ in GetSocket() function in __anond6addeeb0111::wxSocketImplMac 266 if ( socket->GetSocket() ) in Install_Callback() 267 CFSocketEnableCallBacks(socket->GetSocket(), GetCFCallback(socket, event)); in Install_Callback() 275 if ( socket->GetSocket() ) in Uninstall_Callback() 276 CFSocketDisableCallBacks(socket->GetSocket(), GetCFCallback(socket, event)); in Uninstall_Callback()
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/extensions/browser/api/socket/ |
H A D | socket_api.cc | 168 Socket* socket = GetSocket(socket_id); in OnFirewallHoleOpened() 312 Socket* socket = GetSocket(socket_id_); in AsyncWorkStart() 358 Socket* socket = GetSocket(socket_id_); in StartConnect() 381 Socket* socket = GetSocket(socket_id_); in Work() 403 Socket* socket = GetSocket(socket_id_); in AsyncWorkStart() 433 Socket* socket = GetSocket(socket_id_); in OnCompleted() 461 Socket* socket = GetSocket(params_->socket_id); in AsyncWorkStart() 487 Socket* socket = GetSocket(params_->socket_id); in OnCompleted() 602 Socket* socket = GetSocket(socket_id_); in AsyncWorkStart() 696 Socket* socket = GetSocket(socket_id_); in AsyncWorkStart() [all …]
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/extensions/browser/api/socket/ |
H A D | socket_api.cc | 167 Socket* socket = GetSocket(socket_id); in OnFirewallHoleOpened() 311 Socket* socket = GetSocket(socket_id_); in AsyncWorkStart() 357 Socket* socket = GetSocket(socket_id_); in StartConnect() 380 Socket* socket = GetSocket(socket_id_); in Work() 402 Socket* socket = GetSocket(socket_id_); in AsyncWorkStart() 432 Socket* socket = GetSocket(socket_id_); in OnCompleted() 460 Socket* socket = GetSocket(params_->socket_id); in AsyncWorkStart() 486 Socket* socket = GetSocket(params_->socket_id); in OnCompleted() 603 Socket* socket = GetSocket(socket_id_); in AsyncWorkStart() 699 Socket* socket = GetSocket(socket_id_); in AsyncWorkStart() [all …]
|
/dports/sysutils/helmfile/helmfile-0.138.7/vendor/google.golang.org/grpc/channelz/grpc_channelz_v1/ |
H A D | channelz_grpc.pb.go | 35 GetSocket func(context.Context, *GetSocketRequest) (*GetSocketResponse, error) member 159 if s.GetSocket == nil { 167 return s.GetSocket(ctx, in) 174 return s.GetSocket(ctx, req.(*GetSocketRequest)) 259 GetSocket(context.Context, *GetSocketRequest) (*GetSocketResponse, error) 261 ns.GetSocket = h.GetSocket 285 GetSocket(context.Context, *GetSocketRequest) (*GetSocketResponse, error) methodSpec
|
/dports/audio/musicpd/mpd-0.23.6/src/event/ |
H A D | MultiSocketMonitor.hxx | 61 SocketDescriptor GetSocket() const noexcept { in GetSocket() function in MultiSocketMonitor::SingleFD 62 return event.GetSocket(); in GetSocket() 191 unsigned events = e(i->GetSocket()); in UpdateSocketList() 218 f(i.GetSocket(), i.GetReturnedEvents()); in ForEachReturnedEvent()
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/extensions/browser/api/bluetooth_socket/ |
H A D | bluetooth_socket_api.cc | 158 BluetoothApiSocket* BluetoothSocketAsyncApiFunction::GetSocket( in GetSocket() function in extensions::api::BluetoothSocketAsyncApiFunction 201 BluetoothApiSocket* socket = GetSocket(params->socket_id); in Run() 222 BluetoothApiSocket* socket = GetSocket(params->socket_id); in Run() 261 BluetoothApiSocket* socket = GetSocket(socket_id()); in OnGetAdapter() 297 BluetoothApiSocket* api_socket = GetSocket(socket_id()); in OnCreateService() 434 BluetoothApiSocket* socket = GetSocket(params_->socket_id); in OnGetAdapter() 512 BluetoothApiSocket* socket = GetSocket(params->socket_id); in Run() 533 BluetoothApiSocket* socket = GetSocket(params->socket_id); in Run() 556 BluetoothApiSocket* socket = GetSocket(params_->socket_id); in Run() 587 BluetoothApiSocket* socket = GetSocket(params->socket_id); in Run() [all …]
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/extensions/browser/api/bluetooth_socket/ |
H A D | bluetooth_socket_api.cc | 158 BluetoothApiSocket* BluetoothSocketAsyncApiFunction::GetSocket( in GetSocket() function in extensions::api::BluetoothSocketAsyncApiFunction 201 BluetoothApiSocket* socket = GetSocket(params->socket_id); in Run() 222 BluetoothApiSocket* socket = GetSocket(params->socket_id); in Run() 261 BluetoothApiSocket* socket = GetSocket(socket_id()); in OnGetAdapter() 296 BluetoothApiSocket* api_socket = GetSocket(socket_id()); in OnCreateService() 437 BluetoothApiSocket* socket = GetSocket(params_->socket_id); in OnGetAdapter() 515 BluetoothApiSocket* socket = GetSocket(params->socket_id); in Run() 536 BluetoothApiSocket* socket = GetSocket(params->socket_id); in Run() 559 BluetoothApiSocket* socket = GetSocket(params_->socket_id); in Run() 590 BluetoothApiSocket* socket = GetSocket(params->socket_id); in Run() [all …]
|
/dports/multimedia/zoneminder/zoneminder-1.36.5/dep/RtspServer/src/xop/ |
H A D | RtspPusher.cpp | 63 SOCKET sockfd = rtspConn->GetSocket(); in OpenUrl() 79 rtsp_conn_.reset(new RtspConnection(shared_from_this(), task_scheduler_, tcpSocket.GetSocket())); in OpenUrl() 97 SOCKET sockfd = rtspConn->GetSocket(); in OpenUrl() 114 SOCKET sockfd = rtsp_conn->GetSocket(); in Close()
|
/dports/games/armagetronad/armagetronad-0.2.8.3.5/src/network/ |
H A D | nSocket.h | 160 inline int GetSocket( void ) const; //!< Gets the raw socket 161 inline nSocket const & GetSocket( int & socket ) const; //!< Gets the raw socket 311 int nSocket::GetSocket( void ) const in GetSocket() function 327 nSocket const & nSocket::GetSocket( int & socket ) const in GetSocket() function
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/components/cast_channel/ |
H A D | cast_message_handler.cc | 88 CastSocket* socket = socket_service_->GetSocket(channel_id); in EnsureConnection() 101 CastSocket* socket = socket_service_->GetSocket(channel_id); in CloseConnection() 161 CastSocket* socket = socket_service_->GetSocket(channel_id); in RequestReceiverStatus() 178 CastSocket* socket = socket_service_->GetSocket(channel_id); in SendBroadcastMessage() 200 CastSocket* socket = socket_service_->GetSocket(channel_id); in LaunchSession() 227 CastSocket* socket = socket_service_->GetSocket(channel_id); in StopSession() 249 CastSocket* socket = socket_service_->GetSocket(channel_id); in SendCastMessage() 273 CastSocket* socket = socket_service_->GetSocket(channel_id); in SendMediaRequest() 291 CastSocket* socket = socket_service_->GetSocket(channel_id); in SendSetVolumeRequest() 381 if (!socket_service_->GetSocket(channel_id)) { in HandleCastInternalMessage()
|