diff --git a/protocols/ssh/include/common.h b/protocols/ssh/include/common.h
index effcd67f..d6b224da 100644
--- a/protocols/ssh/include/common.h
+++ b/protocols/ssh/include/common.h
@@ -58,5 +58,11 @@ int guac_terminal_encode_utf8(int codepoint, char* utf8);
  */
 bool guac_terminal_has_glyph(int codepoint);
 
+/**
+ * Similar to write, but automatically retries the write operation until
+ * an error occurs.
+ */
+int guac_terminal_write_all(int fd, const char* buffer, int size);
+
 #endif
 
diff --git a/protocols/ssh/src/common.c b/protocols/ssh/src/common.c
index 00d6bdec..cdd069e4 100644
--- a/protocols/ssh/src/common.c
+++ b/protocols/ssh/src/common.c
@@ -36,6 +36,7 @@
  * ***** END LICENSE BLOCK ***** */
 
 #include <stdbool.h>
+#include <unistd.h>
 
 int guac_terminal_fit_to_range(int value, int min, int max) {
 
@@ -98,3 +99,23 @@ bool guac_terminal_has_glyph(int codepoint) {
         && codepoint != ' ';
 }
 
+int guac_terminal_write_all(int fd, const char* buffer, int size) {
+
+    int remaining = size;
+    while (remaining > 0) {
+
+        /* Attempt to write data */
+        int ret_val = write(fd, buffer, remaining);
+        if (ret_val <= 0)
+            return -1;
+
+        /* If successful, contine with what data remains (if any) */
+        remaining -= ret_val;
+        buffer += ret_val;
+
+    }
+
+    return size;
+
+}
+
diff --git a/protocols/ssh/src/ssh_client.c b/protocols/ssh/src/ssh_client.c
index 564ee8cf..90ecb820 100644
--- a/protocols/ssh/src/ssh_client.c
+++ b/protocols/ssh/src/ssh_client.c
@@ -45,30 +45,7 @@
 #include <guacamole/socket.h>
 
 #include "client.h"
-
-/**
- * Similar to write, but automatically retries the write operation until
- * an error occurs.
- */
-static int __write_all(int fd, const char* buffer, int size) {
-
-    int remaining = size;
-    while (remaining > 0) {
-
-        /* Attempt to write data */
-        int ret_val = write(fd, buffer, remaining);
-        if (ret_val <= 0)
-            return -1;
-
-        /* If successful, contine with what data remains (if any) */
-        remaining -= ret_val;
-        buffer += ret_val;
-
-    }
-
-    return size;
-
-}
+#include "common.h"
 
 /**
  * Reads a single line from STDIN.
@@ -85,7 +62,7 @@ static char* prompt(guac_client* client, const char* title, char* str, int size,
     int stdout_fd = client_data->term->stdout_pipe_fd[1];
 
     /* Print title */
-    __write_all(stdout_fd, title, strlen(title));
+    guac_terminal_write_all(stdout_fd, title, strlen(title));
 
     /* Make room for null terminator */
     size--;
@@ -98,14 +75,14 @@ static char* prompt(guac_client* client, const char* title, char* str, int size,
         if (in_byte == 0x08) {
 
             if (pos > 0) {
-                __write_all(stdout_fd, "\b \b", 3);
+                guac_terminal_write_all(stdout_fd, "\b \b", 3);
                 pos--;
             }
         }
 
         /* Newline (end of input */
         else if (in_byte == 0x0A) {
-            __write_all(stdout_fd, "\r\n", 2);
+            guac_terminal_write_all(stdout_fd, "\r\n", 2);
             break;
         }
 
@@ -116,9 +93,9 @@ static char* prompt(guac_client* client, const char* title, char* str, int size,
 
             /* Print character if echoing */
             if (echo)
-                __write_all(stdout_fd, &in_byte, 1);
+                guac_terminal_write_all(stdout_fd, &in_byte, 1);
             else
-                __write_all(stdout_fd, "*", 1);
+                guac_terminal_write_all(stdout_fd, "*", 1);
 
         }
 
@@ -251,7 +228,7 @@ void* ssh_client_thread(void* data) {
             continue;
 
         if (bytes_read > 0)
-            __write_all(stdout_fd, buffer, bytes_read);
+            guac_terminal_write_all(stdout_fd, buffer, bytes_read);
 
     }