equal
deleted
inserted
replaced
1 // Copyright (c) 1999-2010 Nokia Corporation and/or its subsidiary(-ies). |
1 // Copyright (c) 1999-2009 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 |
|
27 |
21 |
28 #include "smsustrm.h" |
22 #include "smsustrm.h" |
29 #include "smsumain.h" |
23 #include "smsumain.h" |
30 #include <es_sock.h> |
24 #include <es_sock.h> |
31 #include "smsstacklog.h" |
25 #include "smsstacklog.h" |
52 TInt RSmsSocketBuf::UnderflowL(TInt) |
46 TInt RSmsSocketBuf::UnderflowL(TInt) |
53 //Leaves if the Request Status (s) is in error |
47 //Leaves if the Request Status (s) is in error |
54 //Panics if ERead==0 |
48 //Panics if ERead==0 |
55 // |
49 // |
56 { |
50 { |
57 OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_INTERNALS, RSMSSOCKETBUF_UNDERFLOWL_1, "RSmsSocketBuf::UnderflowL()"); |
51 LOGSMSU1("RSmsSocketBuf::UnderflowL()"); |
58 |
52 |
59 __ASSERT_ALWAYS(Avail(ERead)==0,SmsuPanic(KSsmuPanicStreamReadUnavailable)); |
53 __ASSERT_ALWAYS(Avail(ERead)==0,SmsuPanic(KSsmuPanicStreamReadUnavailable)); |
60 SocketWriteL(); |
54 SocketWriteL(); |
61 SetBuf(EWrite,iBuffer,iBuffer); |
55 SetBuf(EWrite,iBuffer,iBuffer); |
62 // |
56 // |
79 * The function panics if the socket is not writable. |
73 * The function panics if the socket is not writable. |
80 */ |
74 */ |
81 void RSmsSocketBuf::OverflowL() |
75 void RSmsSocketBuf::OverflowL() |
82 //Panics if EWrite == 0 |
76 //Panics if EWrite == 0 |
83 { |
77 { |
84 OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_INTERNALS, RSMSSOCKETBUF_OVERFLOWL_1, "RSmsSocketBuf::OverflowL()"); |
78 LOGSMSU1("RSmsSocketBuf::OverflowL()"); |
85 |
79 |
86 __ASSERT_ALWAYS(Avail(EWrite)==0,SmsuPanic(KSsmuPanicStreamWriteUnavailable)); |
80 __ASSERT_ALWAYS(Avail(EWrite)==0,SmsuPanic(KSsmuPanicStreamWriteUnavailable)); |
87 SetBuf(ERead,iBuffer,iBuffer); |
81 SetBuf(ERead,iBuffer,iBuffer); |
88 // |
82 // |
89 SocketWriteL(); |
83 SocketWriteL(); |
94 /** |
88 /** |
95 * Synchronises the stream buffer with the stream, leaving if any error occurs. |
89 * Synchronises the stream buffer with the stream, leaving if any error occurs. |
96 */ |
90 */ |
97 void RSmsSocketBuf::DoSynchL() |
91 void RSmsSocketBuf::DoSynchL() |
98 { |
92 { |
99 OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_INTERNALS, RSMSSOCKETBUF_DOSYNCHL_1, "RSmsSocketBuf::DoSynchL()"); |
93 LOGSMSU1("RSmsSocketBuf::DoSynchL()"); |
100 |
94 |
101 SocketWriteL(); |
95 SocketWriteL(); |
102 SetBuf(ERead|EWrite,iBuffer,iBuffer); |
96 SetBuf(ERead|EWrite,iBuffer,iBuffer); |
103 } // RSmsSocketBuf::DoSynchL |
97 } // RSmsSocketBuf::DoSynchL |
104 |
98 |
106 /** |
100 /** |
107 * Writes the buffered data to the socket. |
101 * Writes the buffered data to the socket. |
108 */ |
102 */ |
109 void RSmsSocketBuf::SocketWriteL() |
103 void RSmsSocketBuf::SocketWriteL() |
110 { |
104 { |
111 OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_INTERNALS, RSMSSOCKETBUF_SOCKETWRITEL_1, "RSmsSocketBuf::SocketWriteL()"); |
105 LOGSMSU1("RSmsSocketBuf::SocketWriteL()"); |
112 |
106 |
113 TInt length=Lag(EWrite); |
107 TInt length=Lag(EWrite); |
114 if (length==0) |
108 if (length==0) |
115 return; |
109 return; |
116 // |
110 // |
129 */ |
123 */ |
130 EXPORT_C RSmsSocketReadStream::RSmsSocketReadStream(RSocket& aSocket) |
124 EXPORT_C RSmsSocketReadStream::RSmsSocketReadStream(RSocket& aSocket) |
131 :RReadStream(&iBuf), |
125 :RReadStream(&iBuf), |
132 iBuf(aSocket) |
126 iBuf(aSocket) |
133 { |
127 { |
134 OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_BORDER, RSMSSOCKETREADSTREAM_CTOR_1, "RSmsSocketReadStream::RSmsSocketReadStream()"); |
128 LOGSMSU1("RSmsSocketReadStream::RSmsSocketReadStream()"); |
135 |
129 |
136 } // RSmsSocketReadStream::RSmsSocketReadStream |
130 } // RSmsSocketReadStream::RSmsSocketReadStream |
137 |
131 |
138 |
132 |
139 /** |
133 /** |
144 */ |
138 */ |
145 EXPORT_C RSmsSocketWriteStream::RSmsSocketWriteStream(RSocket& aSocket) |
139 EXPORT_C RSmsSocketWriteStream::RSmsSocketWriteStream(RSocket& aSocket) |
146 :RWriteStream(&iBuf), |
140 :RWriteStream(&iBuf), |
147 iBuf(aSocket) |
141 iBuf(aSocket) |
148 { |
142 { |
149 OstTraceDef0(OST_TRACE_CATEGORY_DEBUG, TRACE_BORDER, RSMSSOCKETWRITESTREAM_CTOR_1, "RSmsSocketWriteStream::RSmsSocketWriteStream()"); |
143 LOGSMSU1("RSmsSocketWriteStream::RSmsSocketWriteStream()"); |
150 |
144 |
151 } // RSmsSocketWriteStream::RSmsSocketWriteStream |
145 } // RSmsSocketWriteStream::RSmsSocketWriteStream |
152 |
146 |