119 // ----------------------------------------------------------------------------- |
119 // ----------------------------------------------------------------------------- |
120 // CUsbPnUsbSender::DeletePackets |
120 // CUsbPnUsbSender::DeletePackets |
121 // ----------------------------------------------------------------------------- |
121 // ----------------------------------------------------------------------------- |
122 void CUsbPnUsbSender::DeletePackets( ) |
122 void CUsbPnUsbSender::DeletePackets( ) |
123 { |
123 { |
124 OstTrace0( TRACE_API, CUSBPNUSBSENDER_DELETEPACKETS_ENTRY, "CUsbPnUsbSender::DeletePackets" ); |
124 OstTrace0( TRACE_BORDER, CUSBPNUSBSENDER_DELETEPACKETS_ENTRY, "CUsbPnUsbSender::DeletePackets" ); |
125 A_TRACE( ( _T( "CUsbPnUsbSender::DeletePackets()" ) ) ); |
125 A_TRACE( ( _T( "CUsbPnUsbSender::DeletePackets()" ) ) ); |
126 CUsbPnPacket* packet = NULL; |
126 CUsbPnPacket* packet = NULL; |
127 while(iPacketCount > 0) |
127 while(iPacketCount > 0) |
128 { |
128 { |
129 iPacketCount--; |
129 iPacketCount--; |
130 packet = &iPacket->NextPacket(); |
130 packet = &iPacket->NextPacket(); |
131 delete iPacket; |
131 delete iPacket; |
132 iPacket = packet; |
132 iPacket = packet; |
133 } |
133 } |
134 OstTrace0( TRACE_API, CUSBPNUSBSENDER_DELETEPACKETS_EXIT, "CUsbPnUsbSender::DeletePackets - return void" ); |
134 OstTrace0( TRACE_BORDER, CUSBPNUSBSENDER_DELETEPACKETS_EXIT, "CUsbPnUsbSender::DeletePackets - return void" ); |
135 A_TRACE( ( _T( "CUsbPnUsbSender::DeletePackets() - return void" ) ) ); |
135 A_TRACE( ( _T( "CUsbPnUsbSender::DeletePackets() - return void" ) ) ); |
136 } |
136 } |
137 |
137 |
138 // ----------------------------------------------------------------------------- |
138 // ----------------------------------------------------------------------------- |
139 // CUsbPnUsbSender::AddPacketBufferL |
139 // CUsbPnUsbSender::AddPacketBufferL |
182 // ----------------------------------------------------------------------------- |
182 // ----------------------------------------------------------------------------- |
183 // |
183 // |
184 void CUsbPnUsbSender::AddPacketToSendingQueue( CUsbPnPacket& aPacket ) |
184 void CUsbPnUsbSender::AddPacketToSendingQueue( CUsbPnPacket& aPacket ) |
185 { |
185 { |
186 ASSERT( &aPacket ); |
186 ASSERT( &aPacket ); |
187 OstTrace0( TRACE_API, CUSBPNUSBSENDER_ADDPACKETTOSENDINGQUEUE_ENTRY, "CUsbPnUsbSender::AddPacketToSendingQueue" ); |
187 OstTrace0( TRACE_BORDER, CUSBPNUSBSENDER_ADDPACKETTOSENDINGQUEUE_ENTRY, "CUsbPnUsbSender::AddPacketToSendingQueue" ); |
188 A_TRACE( ( _T( "CUsbPnUsbSender::Send()" ) ) ); |
188 A_TRACE( ( _T( "CUsbPnUsbSender::Send()" ) ) ); |
189 |
189 |
190 iPacket = &iPacket->NextPacket(); |
190 iPacket = &iPacket->NextPacket(); |
191 OstTrace1( TRACE_DETAILED, CUSBPNUSBSENDER_ADDPACKETTOSENDINGQUEUE, "CUsbPnUsbSender::AddPacketToSendingQueue;packet number:%d", iPacket->PacketNumber() ); |
191 OstTrace1( TRACE_INTERNALS, CUSBPNUSBSENDER_ADDPACKETTOSENDINGQUEUE, "CUsbPnUsbSender::AddPacketToSendingQueue;packet number:%d", iPacket->PacketNumber() ); |
192 E_TRACE( ( _T( "CUsbPnUsbSender::AddPacketToSendingQueue() - packet number:%d" ), iPacket->PacketNumber() ) ); |
192 E_TRACE( ( _T( "CUsbPnUsbSender::AddPacketToSendingQueue() - packet number:%d" ), iPacket->PacketNumber() ) ); |
193 |
193 |
194 TryToSendPacket( *iPacket ); |
194 TryToSendPacket( *iPacket ); |
195 |
195 |
196 OstTrace0( TRACE_API, CUSBPNUSBSENDER_ADDPACKETTOSENDINGQUEUE_EXIT, "CUsbPnUsbSender::AddPacketToSendingQueue - return void" ); |
196 OstTrace0( TRACE_BORDER, CUSBPNUSBSENDER_ADDPACKETTOSENDINGQUEUE_EXIT, "CUsbPnUsbSender::AddPacketToSendingQueue - return void" ); |
197 A_TRACE( ( _T( "CUsbPnUsbSender::AddPacketToSendingQueue() - return void" ) ) ); |
197 A_TRACE( ( _T( "CUsbPnUsbSender::AddPacketToSendingQueue() - return void" ) ) ); |
198 } |
198 } |
199 |
199 |
200 // ----------------------------------------------------------------------------- |
200 // ----------------------------------------------------------------------------- |
201 // CUsbPnUsbSender::TryToSendPacket |
201 // CUsbPnUsbSender::TryToSendPacket |
202 // ----------------------------------------------------------------------------- |
202 // ----------------------------------------------------------------------------- |
203 // |
203 // |
204 void CUsbPnUsbSender::TryToSendPacket( const CUsbPnPacket& aPacket ) |
204 void CUsbPnUsbSender::TryToSendPacket( const CUsbPnPacket& aPacket ) |
205 { |
205 { |
206 ASSERT( &aPacket ); |
206 ASSERT( &aPacket ); |
207 OstTraceExt2( TRACE_API, CUSBPNUSBSENDER_TRYTOSENDPACKET_ENTRY, "CUsbPnUsbSender::TryToSendPacket;aPacket=0x%x;iCurrentPacket=%d", ( TUint )&( aPacket ), iCurrentPacket->PacketNumber() ); |
207 OstTraceExt2( TRACE_BORDER, CUSBPNUSBSENDER_TRYTOSENDPACKET_ENTRY, "CUsbPnUsbSender::TryToSendPacket;aPacket=0x%x;iCurrentPacket=%d", ( TUint )&( aPacket ), iCurrentPacket->PacketNumber() ); |
208 A_TRACE( ( _T( "CUsbPnUsbSender::TryToSendPacket( aPacketNumber:0x%x, iCurrentPacket:%d )" ), &aPacket, iCurrentPacket->PacketNumber( ) )); |
208 A_TRACE( ( _T( "CUsbPnUsbSender::TryToSendPacket( aPacketNumber:0x%x, iCurrentPacket:%d )" ), &aPacket, iCurrentPacket->PacketNumber( ) )); |
209 |
209 |
210 // Write message to USB |
210 // Write message to USB |
211 if(!IsActive()) |
211 if(!IsActive()) |
212 { |
212 { |
213 if( &aPacket == ( &iCurrentPacket->NextPacket() ) |
213 if( &aPacket == ( &iCurrentPacket->NextPacket() ) |
214 || &aPacket == iCurrentPacket ) |
214 || &aPacket == iCurrentPacket ) |
215 { |
215 { |
216 OstTrace0( TRACE_DETAILED, CUSBPNUSBSENDER_TRYTOSENDPACKET, "CUsbPnUsbSender::TryToSendPacket - Write to socket" ); |
216 OstTrace0( TRACE_INTERNALS, CUSBPNUSBSENDER_TRYTOSENDPACKET, "CUsbPnUsbSender::TryToSendPacket - Write to socket" ); |
217 E_TRACE( ( _T( "CUsbPnUsbSender::TryToSendPacket() - Write to socket"))); |
217 E_TRACE( ( _T( "CUsbPnUsbSender::TryToSendPacket() - Write to socket"))); |
218 |
218 |
219 HBufC8& data(aPacket.Buffer()); |
219 HBufC8& data(aPacket.Buffer()); |
220 TInt length( data.Length() ); |
220 TInt length( data.Length() ); |
221 #ifdef EXTENDED_TRACE_FLAG |
221 #ifdef EXTENDED_TRACE_FLAG |
222 for(TInt i = 0; i < length; i++) |
222 for(TInt i = 0; i < length; i++) |
223 { |
223 { |
224 OstTraceExt2( TRACE_DETAILED, CUSBPNUSBSENDER_TRYTOSENDPACKET_DUP1, "CUsbPnUsbSender::Send( [%d] = %x )", i, data[i] ); |
224 OstTraceExt2( TRACE_INTERNALS, CUSBPNUSBSENDER_TRYTOSENDPACKET_DUP1, "CUsbPnUsbSender::Send( [%d] = %x )", i, data[i] ); |
225 E_TRACE( ( _T( "CUsbPnUsbSender::Send([%d] = %x )" ), i, data[i] ) ); |
225 E_TRACE( ( _T( "CUsbPnUsbSender::Send([%d] = %x )" ), i, data[i] ) ); |
226 i++; |
226 i++; |
227 } |
227 } |
228 #endif |
228 #endif |
229 |
229 |
243 TRACE_ASSERT_ALWAYS; |
243 TRACE_ASSERT_ALWAYS; |
244 } |
244 } |
245 } |
245 } |
246 else |
246 else |
247 { |
247 { |
248 OstTrace0( TRACE_DETAILED, CUSBPNUSBSENDER_TRYTOSENDPACKET_DUP2, "CUsbPnUsbSender::TryToSendPacket - Already sending" ); |
248 OstTrace0( TRACE_INTERNALS, CUSBPNUSBSENDER_TRYTOSENDPACKET_DUP2, "CUsbPnUsbSender::TryToSendPacket - Already sending" ); |
249 E_TRACE( ( _T( "CUsbPnUsbSender::TryToSendPacket() - Already sending"))); |
249 E_TRACE( ( _T( "CUsbPnUsbSender::TryToSendPacket() - Already sending"))); |
250 } |
250 } |
251 |
251 |
252 OstTrace0( TRACE_API, CUSBPNUSBSENDER_TRYTOSENDPACKET_EXIT, "CUsbPnUsbSender::TryToSendPacket - return void" ); |
252 OstTrace0( TRACE_BORDER, CUSBPNUSBSENDER_TRYTOSENDPACKET_EXIT, "CUsbPnUsbSender::TryToSendPacket - return void" ); |
253 A_TRACE( ( _T( "CUsbPnUsbSender::TryToSendPacket() - return void" ) ) ); |
253 A_TRACE( ( _T( "CUsbPnUsbSender::TryToSendPacket() - return void" ) ) ); |
254 } |
254 } |
255 |
255 |
256 // ----------------------------------------------------------------------------- |
256 // ----------------------------------------------------------------------------- |
257 // CUsbPnUsbSender::DoCancel |
257 // CUsbPnUsbSender::DoCancel |
270 // CUsbPnUsbSender::RunL |
270 // CUsbPnUsbSender::RunL |
271 // ----------------------------------------------------------------------------- |
271 // ----------------------------------------------------------------------------- |
272 // |
272 // |
273 void CUsbPnUsbSender::RunL( ) |
273 void CUsbPnUsbSender::RunL( ) |
274 { |
274 { |
275 OstTrace1( TRACE_API, CUSBPNUSBSENDER_RUNL_ENTRY, "CUsbPnUsbSender::RunL;iStatus:%d", iStatus.Int() ); |
275 OstTrace1( TRACE_BORDER, CUSBPNUSBSENDER_RUNL_ENTRY, "CUsbPnUsbSender::RunL;iStatus:%d", iStatus.Int() ); |
276 A_TRACE( ( _T( "CUsbPnUsbSender::RunL() iStatus:%d" ), iStatus.Int() ) ); |
276 A_TRACE( ( _T( "CUsbPnUsbSender::RunL() iStatus:%d" ), iStatus.Int() ) ); |
277 |
277 |
278 User::LeaveIfError( iStatus.Int() ); |
278 User::LeaveIfError( iStatus.Int() ); |
279 |
279 |
280 iCurrentPacket->ReleaseL(); |
280 iCurrentPacket->ReleaseL(); |
281 iBufferListener.Receive( ETrue ); |
281 iBufferListener.Receive( ETrue ); |
282 iCurrentPacket = &iCurrentPacket->NextPacket(); |
282 iCurrentPacket = &iCurrentPacket->NextPacket(); |
283 |
283 |
284 if(iCurrentPacket != iPacket) |
284 if(iCurrentPacket != iPacket) |
285 { |
285 { |
286 OstTraceExt2( TRACE_DETAILED, CUSBPNUSBSENDER_RUNL, "CUsbPnUsbSender::RunL - Write next in queue;tail=%d;head=%d", iCurrentPacket->PacketNumber(), iPacket->PacketNumber() ); |
286 OstTraceExt2( TRACE_INTERNALS, CUSBPNUSBSENDER_RUNL, "CUsbPnUsbSender::RunL - Write next in queue;tail=%d;head=%d", iCurrentPacket->PacketNumber(), iPacket->PacketNumber() ); |
287 E_TRACE( ( _T( "CUsbPnUsbSender::RunL() - Write next in queue tail:%d,head:%d " ), iCurrentPacket->PacketNumber(), iPacket->PacketNumber())); |
287 E_TRACE( ( _T( "CUsbPnUsbSender::RunL() - Write next in queue tail:%d,head:%d " ), iCurrentPacket->PacketNumber(), iPacket->PacketNumber())); |
288 TryToSendPacket( iCurrentPacket->NextPacket() ); |
288 TryToSendPacket( iCurrentPacket->NextPacket() ); |
289 } |
289 } |
290 OstTrace0( TRACE_API, CUSBPNUSBSENDER_RUNL_EXIT, "CUsbPnUsbSender::RunL - return void" ); |
290 OstTrace0( TRACE_BORDER, CUSBPNUSBSENDER_RUNL_EXIT, "CUsbPnUsbSender::RunL - return void" ); |
291 A_TRACE( ( _T( "CUsbPnUsbSender::RunL() - return void" ) ) ); |
291 A_TRACE( ( _T( "CUsbPnUsbSender::RunL() - return void" ) ) ); |
292 } |
292 } |
293 |
293 |
294 // ----------------------------------------------------------------------------- |
294 // ----------------------------------------------------------------------------- |
295 // CUsbPnUsbSender::RunError |
295 // CUsbPnUsbSender::RunError |
296 // ----------------------------------------------------------------------------- |
296 // ----------------------------------------------------------------------------- |
297 // |
297 // |
298 TInt CUsbPnUsbSender::RunError( TInt aError ) |
298 TInt CUsbPnUsbSender::RunError( TInt aError ) |
299 { |
299 { |
300 OstTrace1( TRACE_API, CUSBPNUSBSENDER_RUNERROR_ENTRY, "CUsbPnUsbSender::RunError;aError=%d", aError ); |
300 OstTrace1( TRACE_BORDER, CUSBPNUSBSENDER_RUNERROR_ENTRY, "CUsbPnUsbSender::RunError;aError=%d", aError ); |
301 A_TRACE( ( _T( "CUsbPnUsbSender::RunError(aError:%d)" ), aError ) ); |
301 A_TRACE( ( _T( "CUsbPnUsbSender::RunError(aError:%d)" ), aError ) ); |
302 |
302 |
303 switch( aError ) |
303 switch( aError ) |
304 { |
304 { |
305 case KErrUsbCableDetached: |
305 case KErrUsbCableDetached: |