/dports/security/cryptlib/cryptlib-3.4.3/io/ |
H A D | net_trans.c | 78 if( netStream->timeout < 0 || netStream->timeout > 300 ) in sanityCheckFn() 85 if( netStream->writeBuffer != NULL || netStream->writeBufSize != 0 || \ in sanityCheckFn() 86 netStream->writeBufEnd != 0 ) in sanityCheckFn() 107 if( netStream->timeout < 0 || netStream->timeout > 300 ) in sanityCheckBufferedFunction() 133 netStream->writeBufEnd > netStream->writeBufSize ) in sanityCheckBufferedFunction() 690 memmove( netStream->writeBuffer, netStream->writeBuffer + bytesWritten, in processIncompleteWrite() 731 netStream->writeBufEnd + byteCount <= netStream->writeBufSize ) in bufferedTransportWriteFunction() 733 memcpy( netStream->writeBuffer + netStream->writeBufEnd, buffer, in bufferedTransportWriteFunction() 751 bytesToCopy = netStream->writeBufSize - netStream->writeBufEnd; in bufferedTransportWriteFunction() 756 memcpy( netStream->writeBuffer + netStream->writeBufEnd, buffer, in bufferedTransportWriteFunction() [all …]
|
H A D | http_wr.c | 179 if( netStream->nFlags & STREAM_NFLAG_HTTPTUNNEL ) in writeRequestHeader() 196 netStream->hostLen ); in writeRequestHeader() 197 if( netStream->port != 80 ) in writeRequestHeader() 203 netStream->port ); in writeRequestHeader() 209 if( netStream->path != NULL && netStream->pathLen > 0 ) in writeRequestHeader() 212 netStream->pathLen ); in writeRequestHeader() 245 swrite( &headerStream, netStream->host, netStream->hostLen ); in writeRequestHeader() 316 if( netStream->nFlags & STREAM_NFLAG_LASTMSGW ) in writeResponseHeader() 383 if( netStream->nFlags & STREAM_NFLAG_ISSERVER ) in writeFunction() 414 REQUIRES( netStream->host != NULL && netStream->hostLen > 0 ); in writeFunction() [all …]
|
H A D | tcp.c | 2081 netStream->netSocket = CRYPT_ERROR; in preOpenSocket() 2147 netStream->netSocket = netSocket; in preOpenSocket() 2154 netStream->netSocket = netSocket; in preOpenSocket() 2181 status = ioWait( netStream, min( netStream->timeout, 500000L ), FALSE, in completeOpen() 2447 return( mapError( netStream, in openServerSocket() 2463 status = ioWait( netStream, min( netStream->timeout, 30000000L ), FALSE, in openServerSocket() 2537 &netStream->clientPort ); in openServerSocket() 2559 netStream->netSocket = netSocket; in openServerSocket() 2705 netStream->netSocket = netStream->listenSocket = CRYPT_ERROR; in closeSocketFunction() 2785 netStream->timeout; in readSocketFunction() [all …]
|
H A D | net.c | 215 netStream->nFlags |= \ in checkForProxy() 289 return( transportConnectFunction( netStream, netStream->host, in openNetworkConnection() 290 netStream->hostLen, netStream->port ) ); in openNetworkConnection() 298 netStream->host, netStream->hostLen ); in openNetworkConnection() 357 netStream->protocol = protocol; in initStream() 359 netStream->netSocket = netStream->listenSocket = CRYPT_ERROR; in initStream() 391 netStream->timeout = timeout; in initStream() 439 zeroise( netStream, sizeof( NET_STREAM_INFO ) + netStream->storageSize ); in cleanupStream() 746 NET_STREAM_INFO *netStream = \ in completeConnect() local 801 NET_STREAM_INFO netStream; in sNetConnect() local [all …]
|
H A D | http_rd.c | 121 REQUIRES( netStream->nFlags & STREAM_NFLAG_ISSERVER ); 325 if( netStream->nFlags & STREAM_NFLAG_HTTPGET ) 473 netStream->closeSocketFunction( stream ); 474 clFree( "readResponseHeader", netStream->host ); 475 netStream->host = NULL; 549 if( netStream->nFlags & STREAM_NFLAG_LASTMSGR ) in readFunction() 558 if( netStream->nFlags & STREAM_NFLAG_ISSERVER ) in readFunction() 691 FNPTR_SET( netStream->readFunction, readFunction ); in setStreamLayerHTTP() 692 setStreamLayerHTTPwrite( netStream ); in setStreamLayerHTTP() 696 netStream->nFlags |= STREAM_NFLAG_HTTPPOST; in setStreamLayerHTTP() [all …]
|
H A D | stream.c | 61 NET_STREAM_INFO *netStream = \ in sanityCheck() local 64 if( netStream->timeout < 0 || netStream->timeout > 300 ) in sanityCheck() 96 NET_STREAM_INFO *netStream = \ in sanityCheck() local 108 netStream->writeBufEnd != 0 ) in sanityCheck() 117 netStream->writeBufSize <= 0 || \ in sanityCheck() 121 netStream->writeBufEnd > netStream->writeBufSize ) in sanityCheck() 452 NET_STREAM_INFO *netStream = \ in sread() local 560 NET_STREAM_INFO *netStream = \ in sread() local 1415 netStream->timeout = value; in sioctlSet() 1438 netStream->timeout = netStream->savedTimeout; in sioctlSet() [all …]
|
H A D | net_proxy.c | 80 mputWord( bufPtr, netStream->port ); 86 netStream->transportDisconnectFunction( stream, TRUE ); 105 netStream->transportDisconnectFunction( stream, TRUE ); 119 netStream->transportDisconnectFunction( stream, TRUE ); 129 netStream->errorCode = socksBuffer[ 1 ]; 153 FNPTR_GET( netStream->writeFunction ); in connectViaHttpProxy() 155 FNPTR_GET( netStream->readFunction ); in connectViaHttpProxy() 165 REQUIRES_S( netStream != NULL ); in connectViaHttpProxy() 175 setStreamLayerHTTP( netStream ); in connectViaHttpProxy() 185 setStreamLayerDirect( netStream ); in connectViaHttpProxy() [all …]
|
H A D | dns_srv.c | 204 static int getSrvFQDN( INOUT NET_STREAM_INFO *netStream, in getSrvFQDN() argument 219 assert( isWritePtr( netStream, sizeof( NET_STREAM_INFO ) ) ); in getSrvFQDN() 268 return( setSocketError( netStream, in getSrvFQDN() 282 return( setSocketError( netStream, in getSrvFQDN() 296 int findHostInfo( INOUT NET_STREAM_INFO *netStream, in findHostInfo() argument 308 assert( isWritePtr( netStream, sizeof( NET_STREAM_INFO ) ) ); in findHostInfo() 420 assert( isWritePtr( netStream, sizeof( NET_STREAM_INFO ) ) ); in getFQDN() 487 int findHostInfo( INOUT NET_STREAM_INFO *netStream, in findHostInfo() argument 503 assert( isWritePtr( netStream, sizeof( NET_STREAM_INFO ) ) ); in findHostInfo() 565 return( setSocketError( netStream, in findHostInfo() [all …]
|
H A D | stream_int.h | 239 int ( *STM_TRANSPORTCONNECT_FUNCTION )( INOUT struct NS *netStream, 246 void ( *STM_TRANSPORTDISCONNECT_FUNCTION )( INOUT struct NS *netStream, 267 int ( *STM_TRANSPORTCHECK_FUNCTION )( INOUT struct NS *netStream ); 462 void setAccessMethodTCP( INOUT NET_STREAM_INFO *netStream ); 464 void setStreamLayerHTTP( INOUT NET_STREAM_INFO *netStream ); 466 void setStreamLayerCMP( INOUT NET_STREAM_INFO *netStream ); 468 void setStreamLayerDirect( INOUT NET_STREAM_INFO *netStream ); 470 void setStreamLayerBuffering( INOUT NET_STREAM_INFO *netStream, 474 void setAccessMethodTransportSession( INOUT NET_STREAM_INFO *netStream ); 476 #define setAccessMethodTransportSession( netStream ) argument
|
/dports/graphics/gnash/gnash-2b3bdede0305c4fc3ad21a0a4197330606c9b880/testsuite/misc-ming.all/ |
H A D | oflaDemo.as | 43 function checkAfter (netStream) { 44 note("Time :" + netStream.time); 45 check(netStream.bufferLength > 0); 46 check_equals(netStream.bufferTime, '3'); 47 xcheck(netStream.decodedFrames > 0); 48 check(netStream.time > 0); 54 test1 = function(netStream) { 70 netStream.play("square"); 71 netStream.setBufferTime(3); 93 netStream = new NetStream(this); [all …]
|
/dports/www/xsp/xsp-4.5/src/Mono.WebServer.XSP/ |
H A D | XSPWorker.cs | 49 readonly LingeringNetworkStream netStream; field in Mono.WebServer.XSP.XSPWorker 75 netStream = new LingeringNetworkStream (client, true); in XSPWorker() 82 stream = netStream; in XSPWorker() 231 if (stream != netStream) { in Close() 232 netStream.Close (); in Close() 233 } else if (!netStream.OwnsSocket) { in Close() 250 netStream.EnableLingering = false; in Close() 252 if (stream != netStream) in Close() 253 netStream.Close (); in Close() 260 return netStream.Connected; in IsConnected() [all …]
|
/dports/www/xsp/xsp-4.5/test/1.1/webservice/ |
H A D | CompressExtension.cs | 25 Stream netStream; field in CompressExtension 36 netStream = stream; in ChainStream() 87 netStream.WriteByte ((byte)'C'); // Compressing flag in Compress() 88 netStream.Write (compBytes, 0, compBytes.Length); in Compress() 90 netStream.Flush (); in Compress() 95 netStream.WriteByte ((byte)'N'); // Not Compressing flag in Compress() 96 netStream.Write (tempStream.GetBuffer(), 0, (int) tempStream.Length); in Compress() 97 netStream.Flush (); in Compress() 103 char cf = (char) netStream.ReadByte (); in Decompress() 107 StreamReader sr = new StreamReader (netStream, Encoding.UTF8); in Decompress() [all …]
|
/dports/devel/flex-sdk/flex-sdk-4.6.0.23201/frameworks/projects/osmf/src/org/osmf/net/ |
H A D | NetStreamAudioTrait.as | 49 public function NetStreamAudioTrait(netStream:NetStream) 53 this.netStream = netStream; 58 var soundTransform:SoundTransform = netStream.soundTransform; 60 netStream.soundTransform = soundTransform; 65 var soundTransform:SoundTransform = netStream.soundTransform; 67 netStream.soundTransform = soundTransform; 72 var soundTransform:SoundTransform = netStream.soundTransform; 74 netStream.soundTransform = soundTransform; 77 private var netStream:NetStream;
|
H A D | NetStreamBufferTrait.as | 48 public function NetStreamBufferTrait(netStream:NetStream) 52 this.netStream = netStream; 53 bufferTime = netStream.bufferTime; 54 netStream.addEventListener(NetStatusEvent.NET_STATUS, onNetStatus, false, 0, true); 62 return netStream.bufferLength; 73 netStream.bufferTime = newTime; 82 bufferTime = netStream.bufferTime; 89 if (netStream.bufferTime == 0) 101 private var netStream:NetStream;
|
H A D | NetStreamLoadTrait.as | 83 public function get netStream():NetStream property in org.osmf.net.NetStreamLoadTrait 88 public function set netStream(value:NetStream):void property in org.osmf.net.NetStreamLoadTrait 182 && ( netStream.bytesTotal <= 0 183 || netStream.bytesTotal == uint.MAX_VALUE 187 netStream.addEventListener(NetStatusEvent.NET_STATUS, onNetStatus); 192 netStream = null; 203 return isStreamingResource ? NaN : (netStream != null ? netStream.bytesLoaded : NaN); 211 return isStreamingResource ? NaN : (netStream != null ? netStream.bytesTotal : NaN); 219 if (netStream != null && netStream.bytesTotal > 0) 227 , netStream.bytesTotal [all …]
|
H A D | NetStreamTimeTrait.as | 53 this.netStream = netStream; 54 NetClient(netStream.client).addHandler(NetStreamCodes.ON_META_DATA, onMetaData); 55 NetClient(netStream.client).addHandler(NetStreamCodes.ON_PLAY_STATUS, onPlayStatus); 56 netStream.addEventListener(NetStatusEvent.NET_STATUS, onNetStatus, false, 0, true); 72 if (durationOffset == (duration - (netStream.time - audioDelay))) 74 return netStream.time - audioDelay + durationOffset; 78 return netStream.time - audioDelay; 142 * fix that netStream.time has from the detected duration. This isn't 148 if ((netStream.time - audioDelay) != duration) 150 durationOffset = duration - (netStream.time - audioDelay); [all …]
|
H A D | NetStreamPlayTrait.as | 57 public function NetStreamPlayTrait(netStream:NetStream, resource:MediaResourceBase) 61 if (netStream == null) 65 this.netStream = netStream; 81 netStream.addEventListener(NetStatusEvent.NET_STATUS, onNetStatus, false, 1, true); 82 NetClient(netStream.client).addHandler(NetStreamCodes.ON_PLAY_STATUS, onPlayStatus, 1); 99 netStream.resume(); 134 netStream.pause(); 152 netStream.pause(); 185 netStream.play.apply(this, args); 207 netStream.play2(nspo); [all …]
|
H A D | NetStreamDynamicStreamTrait.as | 46 * @param netStream The NetStream object the class will work with. 55 …public function NetStreamDynamicStreamTrait(netStream:NetStream, switchManager:NetStreamSwitchMana… 59 this.netStream = netStream; 63 netStream.addEventListener(NetStatusEvent.NET_STATUS, onNetStatus); 64 NetClient(netStream.client).addHandler(NetStreamCodes.ON_PLAY_STATUS, onPlayStatus); 69 netStream = null; 161 private var netStream:NetStream;
|
H A D | NetStreamMetricsBase.as | 57 * @param netStream The NetStream instance the class will monitor. 64 public function NetStreamMetricsBase(netStream:NetStream) 68 _netStream = netStream; 79 netStream.addEventListener(NetStatusEvent.NET_STATUS, onNetStatusEvent); 109 public function get netStream():NetStream property in org.osmf.net.NetStreamMetricsBase 226 _maxFPS = netStream.currentFPS > _maxFPS ? netStream.currentFPS : _maxFPS; 231 …_droppedFPS = (netStream.info.droppedFrames - _lastFrameDropValue) / ((_timer.currentCount - _last… 233 _lastFrameDropValue = netStream.info.droppedFrames; 280 if (isNaN(netStream.time))
|
H A D | NetStreamDisplayObjectTrait.as | 38 …public function NetStreamDisplayObjectTrait(netStream:NetStream, view:DisplayObject, mediaWidth:Nu… 42 this.netStream = netStream; 43 NetClient(netStream.client).addHandler(NetStreamCodes.ON_META_DATA, onMetaData); 95 private var netStream:NetStream;
|
H A D | NetStreamSeekTrait.as | 52 public function NetStreamSeekTrait(temporal:TimeTrait, loadTrait:LoadTrait, netStream:NetStream) 56 this.netStream = netStream; 58 NetClient(netStream.client).addHandler(NetStreamCodes.ON_META_DATA, onMetaData); 59 netStream.addEventListener(NetStatusEvent.NET_STATUS, onNetStatus); 104 previousTime = netStream.time - audioDelay; 106 netStream.seek(time + audioDelay); 188 if ( previousTime != netStream.time - audioDelay 205 private var netStream:NetStream;
|
/dports/devel/flex-sdk/flex-sdk-4.6.0.23201/frameworks/projects/osmf/src/org/osmf/net/httpstreaming/ |
H A D | HTTPStreamingNetLoader.as | 103 …override protected function createNetStreamSwitchManager(connection:NetConnection, netStream:NetSt… 109 var metrics:HTTPNetStreamMetrics = new HTTPNetStreamMetrics(netStream as HTTPNetStream); 110 …return new NetStreamSwitchManager(connection, netStream, dsResource, metrics, getDefaultSwitchingR… 134 var netStream:HTTPNetStream = loadTrait.netStream as HTTPNetStream; 135 netStream.addEventListener(DVRStreamInfoEvent.DVRSTREAMINFO, onDVRStreamInfo); 136 netStream.DVRGetStreamInfo(null); 139 netStream.removeEventListener(DVRStreamInfoEvent.DVRSTREAMINFO, onDVRStreamInfo); 141 …loadTrait.setTrait(new HTTPStreamingDVRCastDVRTrait(loadTrait.connection, netStream, event.info as… 142 …loadTrait.setTrait(new HTTPStreamingDVRCastTimeTrait(loadTrait.connection, netStream, event.info a…
|
/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System/net/System/Net/mail/ |
H A D | DelegatedStream.cs | 18 NetworkStream netStream; field in System.Net.DelegatedStream 28 netStream = stream as NetworkStream; in DelegatedStream() 99 if(netStream != null){ in BeginRead() 100 result = this.netStream.UnsafeBeginRead (buffer, offset, count, callback, state); in BeginRead() 115 if(netStream != null){ in BeginWrite() 116 result = this.netStream.UnsafeBeginWrite(buffer, offset, count, callback, state); in BeginWrite()
|
/dports/games/ufoai/ufoai-2.5-source/src/client/ |
H A D | cl_main.cpp | 115 NET_WriteMsg(cls.netStream, msg); in Cmd_ForwardToServer() 151 NET_WriteMsg(cls.netStream, msg); in CL_ForwardToServer_f() 191 cls.netStream = nullptr; in CL_FreeClientStream() 204 assert(!cls.netStream); in CL_Connect() 215 if (cls.netStream) { in CL_Connect() 269 NET_WriteMsg(cls.netStream, msg); in CL_Disconnect() 274 NET_StreamFinished(cls.netStream); in CL_Disconnect() 275 cls.netStream = nullptr; in CL_Disconnect() 368 NET_WriteMsg(cls.netStream, buf); in CL_ConnectionlessPacket() 628 NET_WriteMsg(cls.netStream, msg); in CL_RequestNextDownload() [all …]
|
/dports/devel/flex-sdk/flex-sdk-4.6.0.23201/frameworks/projects/osmf/src/org/osmf/net/rtmpstreaming/ |
H A D | InsufficientBufferRule.as | 67 metrics.netStream.addEventListener(NetStatusEvent.NET_STATUS, monitorNetStatus, false, 0, true); 77 … (_panic || (rtmpMetrics.netStream.bufferLength < minBufferLength && rtmpMetrics.netStream.bufferL… 83 …debug("Buffer of " + Math.round(rtmpMetrics.netStream.bufferLength) + " < " + minBufferLength + "… 109 if (Math.round(rtmpMetrics.netStream.time) != 0)
|