Home
last modified time | relevance | path

Searched refs:netStream (Results 1 – 25 of 49) sorted by relevance

12

/dports/security/cryptlib/cryptlib-3.4.3/io/
H A Dnet_trans.c78 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 Dhttp_wr.c179 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 Dtcp.c2081 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 Dnet.c215 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 Dhttp_rd.c121 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 Dstream.c61 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 Dnet_proxy.c80 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 Ddns_srv.c204 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 Dstream_int.h239 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 DoflaDemo.as43 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 DXSPWorker.cs49 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 DCompressExtension.cs25 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 DNetStreamAudioTrait.as49 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 DNetStreamBufferTrait.as48 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 DNetStreamLoadTrait.as83 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 DNetStreamTimeTrait.as53 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 DNetStreamPlayTrait.as57 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 DNetStreamDynamicStreamTrait.as46 * @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 DNetStreamMetricsBase.as57 * @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 DNetStreamDisplayObjectTrait.as38 …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 DNetStreamSeekTrait.as52 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 DHTTPStreamingNetLoader.as103 …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 DDelegatedStream.cs18 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 Dcl_main.cpp115 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 DInsufficientBufferRule.as67 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)

12