Request lmkd to purge its list of pids after establishing connection am: 2b2011a805 (514aed29) · Commits · e / os / android_frameworks_base

services/core/java/com/android/server/am/ProcessList.java

+35 −18

Original line number	Original line	Diff line number	Diff line
	@@ -162,9 +162,11 @@ public final class ProcessList {
	// LMK_TARGET <minfree> <minkillprio> ... (up to 6 pairs)		// LMK_TARGET <minfree> <minkillprio> ... (up to 6 pairs)
	// LMK_PROCPRIO <pid> <uid> <prio>		// LMK_PROCPRIO <pid> <uid> <prio>
	// LMK_PROCREMOVE <pid>		// LMK_PROCREMOVE <pid>
			// LMK_PROCPURGE
	static final byte LMK_TARGET = 0;		static final byte LMK_TARGET = 0;
	static final byte LMK_PROCPRIO = 1;		static final byte LMK_PROCPRIO = 1;
	static final byte LMK_PROCREMOVE = 2;		static final byte LMK_PROCREMOVE = 2;
			static final byte LMK_PROCPURGE = 3;

	// These are the various interesting memory levels that we will give to		// These are the various interesting memory levels that we will give to
	// the OOM killer. Note that the OOM killer only supports 6 slots, so we		// the OOM killer. Note that the OOM killer only supports 6 slots, so we
	@@ -813,6 +815,24 @@ public final class ProcessList {
	return true;		return true;
	}		}

			// Never call directly, use writeLmkd() instead
			private static boolean writeLmkdCommand(ByteBuffer buf) {
			try {
			sLmkdOutputStream.write(buf.array(), 0, buf.position());
			} catch (IOException ex) {
			Slog.w(TAG, "Error writing to lowmemorykiller socket");

			try {
			sLmkdSocket.close();
			} catch (IOException ex2) {
			}

			sLmkdSocket = null;
			return false;
			}
			return true;
			}

	private static void writeLmkd(ByteBuffer buf) {		private static void writeLmkd(ByteBuffer buf) {

	for (int i = 0; i < 3; i++) {		for (int i = 0; i < 3; i++) {
	@@ -824,20 +844,17 @@ public final class ProcessList {
	}		}
	continue;		continue;
	}		}
	}

	try {
	sLmkdOutputStream.write(buf.array(), 0, buf.position());
	return;
	} catch (IOException ex) {
	Slog.w(TAG, "Error writing to lowmemorykiller socket");

	try {		// Purge any previously registered pids
	sLmkdSocket.close();		ByteBuffer purge_buf = ByteBuffer.allocate(4);
	} catch (IOException ex2) {		purge_buf.putInt(LMK_PROCPURGE);
			if (writeLmkdCommand(purge_buf) == false) {
			// Write failed, skip the rest and retry
			continue;
	}		}
			}
	sLmkdSocket = null;		if (writeLmkdCommand(buf)) {
			return;
	}		}
	}		}
	}		}