moparisthebest/k-9
1
0
Fork 0
mirror of https://github.com/moparisthebest/k-9 synced 2025-02-07 10:40:11 -05:00
Code Issues Releases Wiki Activity

Move our IMAP Store to using a message's sizing method

Browse Source
This commit is contained in:
Jesse Vincent 2011-03-27 23:07:03 +08:00
parent 4f63a3de24
commit 97ec38d03f
1 changed files with 2 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/com/fsck/k9/mail/store/ImapStore.java
View File

@ -74,7 +74,6 @@ import com.fsck.k9.mail.PushReceiver;
import com.fsck.k9.mail.Pusher; import com.fsck.k9.mail.Pusher;
import com.fsck.k9.mail.Store; import com.fsck.k9.mail.Store;
import com.fsck.k9.mail.filter.Base64; import com.fsck.k9.mail.filter.Base64;
import com.fsck.k9.mail.filter.CountingOutputStream;
import com.fsck.k9.mail.filter.EOLConvertingOutputStream; import com.fsck.k9.mail.filter.EOLConvertingOutputStream;
import com.fsck.k9.mail.filter.FixedLengthInputStream; import com.fsck.k9.mail.filter.FixedLengthInputStream;
import com.fsck.k9.mail.filter.Hex; import com.fsck.k9.mail.filter.Hex;
@ -1582,22 +1581,17 @@ public class ImapStore extends Store {
checkOpen(); checkOpen();
try { try {
for (Message message : messages) { for (Message message : messages) {
CountingOutputStream out = new CountingOutputStream();
EOLConvertingOutputStream eolOut = new EOLConvertingOutputStream(out);
message.writeTo(eolOut);
eolOut.flush();
mConnection.sendCommand( mConnection.sendCommand(
String.format("APPEND %s (%s) {%d}", String.format("APPEND %s (%s) {%d}",
encodeString(encodeFolderName(getPrefixedName())), encodeString(encodeFolderName(getPrefixedName())),
combineFlags(message.getFlags()), combineFlags(message.getFlags()),
out.getCount()), false); message.calculateSize()), false);
ImapResponse response; ImapResponse response;
do { do {
response = mConnection.readResponse(); response = mConnection.readResponse();
handleUntaggedResponse(response); handleUntaggedResponse(response);
if (response.mCommandContinuationRequested) { if (response.mCommandContinuationRequested) {
eolOut = new EOLConvertingOutputStream(mConnection.mOut); EOLConvertingOutputStream eolOut = new EOLConvertingOutputStream(mConnection.mOut);
message.writeTo(eolOut); message.writeTo(eolOut);
eolOut.write('\r'); eolOut.write('\r');
eolOut.write('\n'); eolOut.write('\n');