equal
deleted
inserted
replaced
1 // Copyright (c) 1999-2009 Nokia Corporation and/or its subsidiary(-ies). |
1 // Copyright (c) 1999-2010 Nokia Corporation and/or its subsidiary(-ies). |
2 // All rights reserved. |
2 // All rights reserved. |
3 // This component and the accompanying materials are made available |
3 // This component and the accompanying materials are made available |
4 // under the terms of "Eclipse Public License v1.0" |
4 // under the terms of "Eclipse Public License v1.0" |
5 // which accompanies this distribution, and is available |
5 // which accompanies this distribution, and is available |
6 // at the URL "http://www.eclipse.org/legal/epl-v10.html". |
6 // at the URL "http://www.eclipse.org/legal/epl-v10.html". |
16 // |
16 // |
17 |
17 |
18 /** |
18 /** |
19 @file |
19 @file |
20 */ |
20 */ |
|
21 |
|
22 |
|
23 #include "OstTraceDefinitions.h" |
|
24 #ifdef OST_TRACE_COMPILER_IN_USE |
|
25 #include "smsustrmTraces.h" |
|
26 #endif |
21 |
27 |
22 #include "smsustrm.h" |
28 #include "smsustrm.h" |
23 #include "smsumain.h" |
29 #include "smsumain.h" |
24 #include <es_sock.h> |
30 #include <es_sock.h> |
25 #include "smsstacklog.h" |
31 #include "smsstacklog.h" |
46 TInt RSmsSocketBuf::UnderflowL(TInt) |
52 TInt RSmsSocketBuf::UnderflowL(TInt) |
47 //Leaves if the Request Status (s) is in error |
53 //Leaves if the Request Status (s) is in error |
48 //Panics if ERead==0 |
54 //Panics if ERead==0 |
49 // |
55 // |
50 { |
56 { |
51 LOGSMSU1("RSmsSocketBuf::UnderflowL()"); |
57 OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_INTERNALS, RSMSSOCKETBUF_UNDERFLOWL_1, "RSmsSocketBuf::UnderflowL()"); |
52 |
58 |
53 __ASSERT_ALWAYS(Avail(ERead)==0,SmsuPanic(KSsmuPanicStreamReadUnavailable)); |
59 __ASSERT_ALWAYS(Avail(ERead)==0,SmsuPanic(KSsmuPanicStreamReadUnavailable)); |
54 SocketWriteL(); |
60 SocketWriteL(); |
55 SetBuf(EWrite,iBuffer,iBuffer); |
61 SetBuf(EWrite,iBuffer,iBuffer); |
56 // |
62 // |
73 * The function panics if the socket is not writable. |
79 * The function panics if the socket is not writable. |
74 */ |
80 */ |
75 void RSmsSocketBuf::OverflowL() |
81 void RSmsSocketBuf::OverflowL() |
76 //Panics if EWrite == 0 |
82 //Panics if EWrite == 0 |
77 { |
83 { |
78 LOGSMSU1("RSmsSocketBuf::OverflowL()"); |
84 OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_INTERNALS, RSMSSOCKETBUF_OVERFLOWL_1, "RSmsSocketBuf::OverflowL()"); |
79 |
85 |
80 __ASSERT_ALWAYS(Avail(EWrite)==0,SmsuPanic(KSsmuPanicStreamWriteUnavailable)); |
86 __ASSERT_ALWAYS(Avail(EWrite)==0,SmsuPanic(KSsmuPanicStreamWriteUnavailable)); |
81 SetBuf(ERead,iBuffer,iBuffer); |
87 SetBuf(ERead,iBuffer,iBuffer); |
82 // |
88 // |
83 SocketWriteL(); |
89 SocketWriteL(); |
88 /** |
94 /** |
89 * Synchronises the stream buffer with the stream, leaving if any error occurs. |
95 * Synchronises the stream buffer with the stream, leaving if any error occurs. |
90 */ |
96 */ |
91 void RSmsSocketBuf::DoSynchL() |
97 void RSmsSocketBuf::DoSynchL() |
92 { |
98 { |
93 LOGSMSU1("RSmsSocketBuf::DoSynchL()"); |
99 OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_INTERNALS, RSMSSOCKETBUF_DOSYNCHL_1, "RSmsSocketBuf::DoSynchL()"); |
94 |
100 |
95 SocketWriteL(); |
101 SocketWriteL(); |
96 SetBuf(ERead|EWrite,iBuffer,iBuffer); |
102 SetBuf(ERead|EWrite,iBuffer,iBuffer); |
97 } // RSmsSocketBuf::DoSynchL |
103 } // RSmsSocketBuf::DoSynchL |
98 |
104 |
100 /** |
106 /** |
101 * Writes the buffered data to the socket. |
107 * Writes the buffered data to the socket. |
102 */ |
108 */ |
103 void RSmsSocketBuf::SocketWriteL() |
109 void RSmsSocketBuf::SocketWriteL() |
104 { |
110 { |
105 LOGSMSU1("RSmsSocketBuf::SocketWriteL()"); |
111 OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_INTERNALS, RSMSSOCKETBUF_SOCKETWRITEL_1, "RSmsSocketBuf::SocketWriteL()"); |
106 |
112 |
107 TInt length=Lag(EWrite); |
113 TInt length=Lag(EWrite); |
108 if (length==0) |
114 if (length==0) |
109 return; |
115 return; |
110 // |
116 // |
123 */ |
129 */ |
124 EXPORT_C RSmsSocketReadStream::RSmsSocketReadStream(RSocket& aSocket) |
130 EXPORT_C RSmsSocketReadStream::RSmsSocketReadStream(RSocket& aSocket) |
125 :RReadStream(&iBuf), |
131 :RReadStream(&iBuf), |
126 iBuf(aSocket) |
132 iBuf(aSocket) |
127 { |
133 { |
128 LOGSMSU1("RSmsSocketReadStream::RSmsSocketReadStream()"); |
134 OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_BORDER, RSMSSOCKETREADSTREAM_CTOR_1, "RSmsSocketReadStream::RSmsSocketReadStream()"); |
129 |
135 |
130 } // RSmsSocketReadStream::RSmsSocketReadStream |
136 } // RSmsSocketReadStream::RSmsSocketReadStream |
131 |
137 |
132 |
138 |
133 /** |
139 /** |
138 */ |
144 */ |
139 EXPORT_C RSmsSocketWriteStream::RSmsSocketWriteStream(RSocket& aSocket) |
145 EXPORT_C RSmsSocketWriteStream::RSmsSocketWriteStream(RSocket& aSocket) |
140 :RWriteStream(&iBuf), |
146 :RWriteStream(&iBuf), |
141 iBuf(aSocket) |
147 iBuf(aSocket) |
142 { |
148 { |
143 LOGSMSU1("RSmsSocketWriteStream::RSmsSocketWriteStream()"); |
149 OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_BORDER, RSMSSOCKETWRITESTREAM_CTOR_1, "RSmsSocketWriteStream::RSmsSocketWriteStream()"); |
144 |
150 |
145 } // RSmsSocketWriteStream::RSmsSocketWriteStream |
151 } // RSmsSocketWriteStream::RSmsSocketWriteStream |
146 |
152 |