X-Git-Url: http://git.silcnet.org/gitweb/?a=blobdiff_plain;f=lib%2Fsilcsftp%2Fsftp_server.c;h=de0b52ef9d7eaade18f4a1ac0b4418af93a4d1f6;hb=40f8443d8d3a6577336ee66d18e04d9ac4d956bb;hp=d0030a0cc2f1ffe7799f8ca670b1940f68d1dbd9;hpb=33b943ac6034b92fcc5c09802f9fe9add12a51c9;p=silc.git diff --git a/lib/silcsftp/sftp_server.c b/lib/silcsftp/sftp_server.c index d0030a0c..de0b52ef 100644 --- a/lib/silcsftp/sftp_server.c +++ b/lib/silcsftp/sftp_server.c @@ -1,10 +1,10 @@ /* - sftp_server.c + sftp_server.c Author: Pekka Riikonen - Copyright (C) 2001 Pekka Riikonen + Copyright (C) 2001 - 2004 Pekka Riikonen This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by @@ -18,48 +18,54 @@ */ /* $Id$ */ -#include "silcincludes.h" +#include "silc.h" #include "silcsftp.h" +#include "silcsftp_fs.h" #include "sftp_util.h" /* SFTP Server context */ typedef struct { - SilcSocketConnection sock; SilcSFTPSendPacketCallback send_packet; void *send_context; + SilcSFTPMonitors monitors; + SilcSFTPMonitor monitor; + void *monitor_context; SilcSFTPFilesystem fs; - void *fs_context; + SilcBuffer packet; } *SilcSFTPServer; /* General routine to send SFTP packet to the SFTP client. */ static void silc_sftp_send_packet(SilcSFTPServer sftp, - SilcSFTPPacket type, - uint32 len, ...) + SilcSFTPPacket type, + SilcUInt32 len, ...) { - SilcBuffer packet; + SilcBuffer tmp; va_list vp; va_start(vp, len); - packet = silc_sftp_packet_encode_vp(type, len, vp); + tmp = silc_sftp_packet_encode_vp(type, sftp->packet, len, vp); va_end(vp); - - if (!packet) + if (!tmp) return; + sftp->packet = tmp; - SILC_LOG_HEXDUMP(("SFTP packet to client"), packet->data, packet->len); + SILC_LOG_HEXDUMP(("SFTP packet to client"), sftp->packet->data, + sftp->packet->len); /* Send the packet */ - (*sftp->send_packet)(sftp->sock, packet, sftp->send_context); + (*sftp->send_packet)(sftp->packet, sftp->send_context); - silc_buffer_free(packet); + /* Clear packet */ + sftp->packet->data = sftp->packet->tail = sftp->packet->head; + sftp->packet->len = 0; } /* Sends error to the client */ static void silc_sftp_send_error(SilcSFTPServer sftp, SilcSFTPStatus status, - uint32 id) + SilcUInt32 id) { SILC_LOG_DEBUG(("Send error %d", status)); @@ -80,12 +86,12 @@ static void silc_sftp_server_status(SilcSFTP sftp, void *context) { SilcSFTPServer server = (SilcSFTPServer)sftp; - uint32 id = (uint32)context; + SilcUInt32 id = SILC_PTR_TO_32(context); int mlen, llen; SILC_LOG_DEBUG(("Status callback")); SILC_LOG_DEBUG(("Request ID: %d", id)); - + if (!message) message = ""; if (!language_tag) @@ -111,9 +117,9 @@ static void silc_sftp_server_handle(SilcSFTP sftp, void *context) { SilcSFTPServer server = (SilcSFTPServer)sftp; - uint32 id = (uint32)context; + SilcUInt32 id = SILC_PTR_TO_32(context); unsigned char *hdata; - uint32 hdata_len; + SilcUInt32 hdata_len; SILC_LOG_DEBUG(("Handle callback")); SILC_LOG_DEBUG(("Request ID: %d", id)); @@ -123,8 +129,8 @@ static void silc_sftp_server_handle(SilcSFTP sftp, return; } - hdata = server->fs->sftp_encode_handle(server->fs_context, sftp, - handle, &hdata_len); + hdata = server->fs->fs->sftp_encode_handle(server->fs->fs_context, sftp, + handle, &hdata_len); if (!hdata) { silc_sftp_send_error(server, SILC_SFTP_STATUS_FAILURE, id); return; @@ -142,11 +148,11 @@ static void silc_sftp_server_handle(SilcSFTP sftp, static void silc_sftp_server_data(SilcSFTP sftp, SilcSFTPStatus status, const unsigned char *data, - uint32 data_len, + SilcUInt32 data_len, void *context) { SilcSFTPServer server = (SilcSFTPServer)sftp; - uint32 id = (uint32)context; + SilcUInt32 id = SILC_PTR_TO_32(context); SILC_LOG_DEBUG(("Data callback")); SILC_LOG_DEBUG(("Request ID: %d", id)); @@ -171,7 +177,7 @@ static void silc_sftp_server_name(SilcSFTP sftp, void *context) { SilcSFTPServer server = (SilcSFTPServer)sftp; - uint32 id = (uint32)context; + SilcUInt32 id = SILC_PTR_TO_32(context); SilcBuffer namebuf; SILC_LOG_DEBUG(("Name callback")); @@ -202,7 +208,7 @@ static void silc_sftp_server_attr(SilcSFTP sftp, void *context) { SilcSFTPServer server = (SilcSFTPServer)sftp; - uint32 id = (uint32)context; + SilcUInt32 id = SILC_PTR_TO_32(context); SilcBuffer attr_buf; SILC_LOG_DEBUG(("Attr callback")); @@ -214,6 +220,10 @@ static void silc_sftp_server_attr(SilcSFTP sftp, } attr_buf = silc_sftp_attr_encode(attrs); + if (!attr_buf) { + silc_sftp_send_error(server, SILC_SFTP_STATUS_FAILURE, id); + return; + } silc_sftp_send_packet(server, SILC_SFTP_ATTRS, 4 + attr_buf->len, SILC_STR_UI_INT(id), @@ -228,11 +238,11 @@ static void silc_sftp_server_attr(SilcSFTP sftp, static void silc_sftp_server_extended(SilcSFTP sftp, SilcSFTPStatus status, const unsigned char *data, - uint32 data_len, + SilcUInt32 data_len, void *context) { SilcSFTPServer server = (SilcSFTPServer)sftp; - uint32 id = (uint32)context; + SilcUInt32 id = SILC_PTR_TO_32(context); SILC_LOG_DEBUG(("Extended callback")); SILC_LOG_DEBUG(("Request ID: %d", id)); @@ -248,26 +258,23 @@ static void silc_sftp_server_extended(SilcSFTP sftp, SILC_STR_END); } -/* Starts SFTP server by associating the socket connection `sock' to the - created SFTP server context. This function returns the allocated - SFTP client context or NULL on error. The `send_packet' is called +/* Starts SFTP server and returns context to it. This function returns the + allocated SFTP client context or NULL on error. The `send_packet' is called by the library when it needs to send a packet. The `fs' is the structure containing filesystem access callbacks. */ -SilcSFTP silc_sftp_server_start(SilcSocketConnection sock, - SilcSFTPSendPacketCallback send_packet, +SilcSFTP silc_sftp_server_start(SilcSFTPSendPacketCallback send_packet, void *send_context, - SilcSFTPFilesystem fs, - void *fs_context) + SilcSFTPFilesystem fs) { SilcSFTPServer server; server = silc_calloc(1, sizeof(*server)); - server->sock = sock; + if (!server) + return NULL; server->send_packet = send_packet; server->send_context = send_context; server->fs = fs; - server->fs_context = fs_context; SILC_LOG_DEBUG(("Starting SFTP server %p", server)); @@ -284,9 +291,24 @@ void silc_sftp_server_shutdown(SilcSFTP sftp) SILC_LOG_DEBUG(("Stopping SFTP server %p", server)); + if (server->packet) + silc_buffer_free(server->packet); silc_free(server); } +/* Sets monitor callback */ + +void silc_sftp_server_set_monitor(SilcSFTP sftp, + SilcSFTPMonitors monitors, + SilcSFTPMonitor monitor, + void *context) +{ + SilcSFTPServer server = (SilcSFTPServer)sftp; + server->monitors = monitors; + server->monitor = monitor; + server->monitor_context = context; +} + /* Function that is called to process the incmoing SFTP packet. */ /* XXX Some day this will go away and we have automatic receive callbacks for SilcSocketConnection API or SilcPacketContext API. */ @@ -299,23 +321,26 @@ void silc_sftp_server_receive_process(SilcSFTP sftp, SilcSFTPPacket type; char *filename = NULL, *path = NULL; const unsigned char *payload = NULL; - uint32 payload_len; + SilcUInt32 payload_len; int ret; SilcBufferStruct buf; - uint32 id; + SilcUInt32 id; SilcSFTPAttributes attrs; SilcSFTPHandle handle; + SilcSFTPMonitorDataStruct mdata; SILC_LOG_DEBUG(("Start")); /* Parse the packet */ - type = silc_sftp_packet_decode(packet->buffer, (unsigned char **)&payload, + type = silc_sftp_packet_decode(packet->buffer, (unsigned char **)&payload, &payload_len); if (!type) return; silc_buffer_set(&buf, (unsigned char *)payload, payload_len); + memset(&mdata, 0, sizeof(mdata)); + switch (type) { case SILC_SFTP_INIT: { @@ -329,6 +354,13 @@ void silc_sftp_server_receive_process(SilcSFTP sftp, if (ret < 0) break; + /* Call monitor */ + if (server->monitors & SILC_SFTP_MONITOR_INIT && server->monitor) { + mdata.version = version; + (*server->monitor)(sftp, SILC_SFTP_MONITOR_INIT, &mdata, + server->monitor_context); + } + silc_sftp_send_packet(server, SILC_SFTP_VERSION, 4, SILC_STR_UI_INT(SILC_SFTP_PROTOCOL_VERSION), SILC_STR_END); @@ -339,7 +371,7 @@ void silc_sftp_server_receive_process(SilcSFTP sftp, { SilcSFTPFileOperation pflags; unsigned char *attr_buf; - uint32 attr_len = 0; + SilcUInt32 attr_len = 0; SilcBufferStruct tmpbuf; SILC_LOG_DEBUG(("Open request")); @@ -348,7 +380,7 @@ void silc_sftp_server_receive_process(SilcSFTP sftp, SILC_STR_UI_INT(&id), SILC_STR_UI32_STRING_ALLOC(&filename), SILC_STR_UI_INT(&pflags), - SILC_STR_UI32_NSTRING(&attr_buf, + SILC_STR_UI32_NSTRING(&attr_buf, &attr_len), SILC_STR_END); if (ret < 0) @@ -357,13 +389,26 @@ void silc_sftp_server_receive_process(SilcSFTP sftp, if (attr_len) { silc_buffer_set(&tmpbuf, attr_buf, attr_len); attrs = silc_sftp_attr_decode(&tmpbuf); + if (!attrs) + goto failure; } else { attrs = silc_calloc(1, sizeof(*attrs)); + if (!attrs) + goto failure; + } + + /* Call monitor */ + if (server->monitors & SILC_SFTP_MONITOR_OPEN && server->monitor) { + mdata.name = filename; + mdata.pflags = pflags; + (*server->monitor)(sftp, SILC_SFTP_MONITOR_OPEN, &mdata, + server->monitor_context); } /* Open operation */ - server->fs->sftp_open(server->fs_context, sftp, filename, pflags, - attrs, silc_sftp_server_handle, (void *)id); + server->fs->fs->sftp_open(server->fs->fs_context, sftp, filename, pflags, + attrs, silc_sftp_server_handle, + SILC_32_TO_PTR(id)); silc_free(filename); silc_sftp_attr_free(attrs); @@ -373,45 +418,52 @@ void silc_sftp_server_receive_process(SilcSFTP sftp, case SILC_SFTP_CLOSE: { unsigned char *hdata; - uint32 hdata_len; + SilcUInt32 hdata_len; SILC_LOG_DEBUG(("Close request")); ret = silc_buffer_unformat(&buf, SILC_STR_UI_INT(&id), - SILC_STR_UI32_NSTRING(&hdata, + SILC_STR_UI32_NSTRING(&hdata, &hdata_len), SILC_STR_END); if (ret < 0) goto failure; /* Get the handle */ - handle = server->fs->sftp_get_handle(server->fs_context, sftp, - (const unsigned char *)hdata, - hdata_len); + handle = server->fs->fs->sftp_get_handle(server->fs->fs_context, sftp, + (const unsigned char *)hdata, + hdata_len); if (!handle) { silc_sftp_send_error(server, SILC_SFTP_STATUS_NO_SUCH_FILE, id); break; } + /* Call monitor */ + if (server->monitors & SILC_SFTP_MONITOR_CLOSE && server->monitor) { + (*server->monitor)(sftp, SILC_SFTP_MONITOR_CLOSE, &mdata, + server->monitor_context); + } + /* Close operation */ - server->fs->sftp_close(server->fs_context, sftp, handle, - silc_sftp_server_status, (void *)id); + server->fs->fs->sftp_close(server->fs->fs_context, sftp, handle, + silc_sftp_server_status, SILC_32_TO_PTR(id)); + } break; case SILC_SFTP_READ: { unsigned char *hdata; - uint32 hdata_len; - uint64 offset; - uint32 len; + SilcUInt32 hdata_len; + SilcUInt64 offset; + SilcUInt32 len; SILC_LOG_DEBUG(("Read request")); ret = silc_buffer_unformat(&buf, SILC_STR_UI_INT(&id), - SILC_STR_UI32_NSTRING(&hdata, + SILC_STR_UI32_NSTRING(&hdata, &hdata_len), SILC_STR_UI_INT64(&offset), SILC_STR_UI_INT(&len), @@ -420,54 +472,71 @@ void silc_sftp_server_receive_process(SilcSFTP sftp, goto failure; /* Get the handle */ - handle = server->fs->sftp_get_handle(server->fs_context, sftp, - (const unsigned char *)hdata, - hdata_len); + handle = server->fs->fs->sftp_get_handle(server->fs->fs_context, sftp, + (const unsigned char *)hdata, + hdata_len); if (!handle) { silc_sftp_send_error(server, SILC_SFTP_STATUS_NO_SUCH_FILE, id); break; } /* Read operation */ - server->fs->sftp_read(server->fs_context, sftp, handle, offset, len, - silc_sftp_server_data, (void *)id); + server->fs->fs->sftp_read(server->fs->fs_context, sftp, + handle, offset, len, + silc_sftp_server_data, SILC_32_TO_PTR(id)); + + /* Call monitor */ + if (server->monitors & SILC_SFTP_MONITOR_READ && server->monitor) { + mdata.offset = offset; + mdata.data_len = len; + (*server->monitor)(sftp, SILC_SFTP_MONITOR_READ, &mdata, + server->monitor_context); + } } break; case SILC_SFTP_WRITE: { unsigned char *hdata; - uint32 hdata_len; - uint64 offset; + SilcUInt32 hdata_len; + SilcUInt64 offset; unsigned char *data; - uint32 data_len; + SilcUInt32 data_len; SILC_LOG_DEBUG(("Read request")); ret = silc_buffer_unformat(&buf, SILC_STR_UI_INT(&id), - SILC_STR_UI32_NSTRING(&hdata, + SILC_STR_UI32_NSTRING(&hdata, &hdata_len), SILC_STR_UI_INT64(&offset), - SILC_STR_UI32_NSTRING(&data, + SILC_STR_UI32_NSTRING(&data, &data_len), SILC_STR_END); if (ret < 0) goto failure; /* Get the handle */ - handle = server->fs->sftp_get_handle(server->fs_context, sftp, - (const unsigned char *)hdata, - hdata_len); + handle = server->fs->fs->sftp_get_handle(server->fs->fs_context, sftp, + (const unsigned char *)hdata, + hdata_len); if (!handle) { silc_sftp_send_error(server, SILC_SFTP_STATUS_NO_SUCH_FILE, id); break; } /* Write operation */ - server->fs->sftp_write(server->fs_context, sftp, handle, offset, - (const unsigned char *)data, data_len, - silc_sftp_server_status, (void *)id); + server->fs->fs->sftp_write(server->fs->fs_context, sftp, handle, offset, + (const unsigned char *)data, data_len, + silc_sftp_server_status, SILC_32_TO_PTR(id)); + + /* Call monitor */ + if (server->monitors & SILC_SFTP_MONITOR_WRITE && server->monitor) { + mdata.offset = offset; + mdata.data_len = data_len; + (*server->monitor)(sftp, SILC_SFTP_MONITOR_WRITE, &mdata, + server->monitor_context); + } } break; @@ -482,9 +551,16 @@ void silc_sftp_server_receive_process(SilcSFTP sftp, if (ret < 0) goto failure; + /* Call monitor */ + if (server->monitors & SILC_SFTP_MONITOR_REMOVE && server->monitor) { + mdata.name = filename; + (*server->monitor)(sftp, SILC_SFTP_MONITOR_REMOVE, &mdata, + server->monitor_context); + } + /* Remove operation */ - server->fs->sftp_remove(server->fs_context, sftp, filename, - silc_sftp_server_status, (void *)id); + server->fs->fs->sftp_remove(server->fs->fs_context, sftp, filename, + silc_sftp_server_status, SILC_32_TO_PTR(id)); silc_free(filename); } @@ -504,9 +580,18 @@ void silc_sftp_server_receive_process(SilcSFTP sftp, if (ret < 0) goto failure; + /* Call monitor */ + if (server->monitors & SILC_SFTP_MONITOR_RENAME && server->monitor) { + mdata.name = filename; + mdata.name2 = newname; + (*server->monitor)(sftp, SILC_SFTP_MONITOR_RENAME, &mdata, + server->monitor_context); + } + /* Rename operation */ - server->fs->sftp_rename(server->fs_context, sftp, filename, newname, - silc_sftp_server_status, (void *)id); + server->fs->fs->sftp_rename(server->fs->fs_context, sftp, + filename, newname, + silc_sftp_server_status, SILC_32_TO_PTR(id)); silc_free(filename); silc_free(newname); @@ -516,7 +601,7 @@ void silc_sftp_server_receive_process(SilcSFTP sftp, case SILC_SFTP_MKDIR: { unsigned char *attr_buf; - uint32 attr_len = 0; + SilcUInt32 attr_len = 0; SilcBufferStruct tmpbuf; SILC_LOG_DEBUG(("Mkdir request")); @@ -533,13 +618,24 @@ void silc_sftp_server_receive_process(SilcSFTP sftp, if (attr_len) { silc_buffer_set(&tmpbuf, attr_buf, attr_len); attrs = silc_sftp_attr_decode(&tmpbuf); + if (!attrs) + goto failure; } else { attrs = silc_calloc(1, sizeof(*attrs)); + if (!attrs) + goto failure; + } + + /* Call monitor */ + if (server->monitors & SILC_SFTP_MONITOR_MKDIR && server->monitor) { + mdata.name = path; + (*server->monitor)(sftp, SILC_SFTP_MONITOR_MKDIR, &mdata, + server->monitor_context); } /* Mkdir operation */ - server->fs->sftp_mkdir(server->fs_context, sftp, path, attrs, - silc_sftp_server_status, (void *)id); + server->fs->fs->sftp_mkdir(server->fs->fs_context, sftp, path, attrs, + silc_sftp_server_status, SILC_32_TO_PTR(id)); silc_sftp_attr_free(attrs); silc_free(path); @@ -557,9 +653,16 @@ void silc_sftp_server_receive_process(SilcSFTP sftp, if (ret < 0) goto failure; + /* Call monitor */ + if (server->monitors & SILC_SFTP_MONITOR_RMDIR && server->monitor) { + mdata.name = path; + (*server->monitor)(sftp, SILC_SFTP_MONITOR_RMDIR, &mdata, + server->monitor_context); + } + /* Rmdir operation */ - server->fs->sftp_rmdir(server->fs_context, sftp, path, - silc_sftp_server_status, (void *)id); + server->fs->fs->sftp_rmdir(server->fs->fs_context, sftp, path, + silc_sftp_server_status, SILC_32_TO_PTR(id)); silc_free(path); } @@ -576,9 +679,16 @@ void silc_sftp_server_receive_process(SilcSFTP sftp, if (ret < 0) goto failure; + /* Call monitor */ + if (server->monitors & SILC_SFTP_MONITOR_OPENDIR && server->monitor) { + mdata.name = path; + (*server->monitor)(sftp, SILC_SFTP_MONITOR_OPENDIR, &mdata, + server->monitor_context); + } + /* Opendir operation */ - server->fs->sftp_opendir(server->fs_context, sftp, path, - silc_sftp_server_handle, (void *)id); + server->fs->fs->sftp_opendir(server->fs->fs_context, sftp, path, + silc_sftp_server_handle, SILC_32_TO_PTR(id)); silc_free(path); } @@ -587,30 +697,36 @@ void silc_sftp_server_receive_process(SilcSFTP sftp, case SILC_SFTP_READDIR: { unsigned char *hdata; - uint32 hdata_len; + SilcUInt32 hdata_len; SILC_LOG_DEBUG(("Readdir request")); ret = silc_buffer_unformat(&buf, SILC_STR_UI_INT(&id), - SILC_STR_UI32_NSTRING(&hdata, + SILC_STR_UI32_NSTRING(&hdata, &hdata_len), SILC_STR_END); if (ret < 0) goto failure; /* Get the handle */ - handle = server->fs->sftp_get_handle(server->fs_context, sftp, - (const unsigned char *)hdata, - hdata_len); + handle = server->fs->fs->sftp_get_handle(server->fs->fs_context, sftp, + (const unsigned char *)hdata, + hdata_len); if (!handle) { silc_sftp_send_error(server, SILC_SFTP_STATUS_NO_SUCH_FILE, id); break; } + /* Call monitor */ + if (server->monitors & SILC_SFTP_MONITOR_READDIR && server->monitor) { + (*server->monitor)(sftp, SILC_SFTP_MONITOR_READDIR, &mdata, + server->monitor_context); + } + /* Readdir operation */ - server->fs->sftp_readdir(server->fs_context, sftp, handle, - silc_sftp_server_name, (void *)id); + server->fs->fs->sftp_readdir(server->fs->fs_context, sftp, handle, + silc_sftp_server_name, SILC_32_TO_PTR(id)); } break; @@ -625,9 +741,16 @@ void silc_sftp_server_receive_process(SilcSFTP sftp, if (ret < 0) goto failure; + /* Call monitor */ + if (server->monitors & SILC_SFTP_MONITOR_STAT && server->monitor) { + mdata.name = path; + (*server->monitor)(sftp, SILC_SFTP_MONITOR_STAT, &mdata, + server->monitor_context); + } + /* Stat operation */ - server->fs->sftp_stat(server->fs_context, sftp, path, - silc_sftp_server_attr, (void *)id); + server->fs->fs->sftp_stat(server->fs->fs_context, sftp, path, + silc_sftp_server_attr, SILC_32_TO_PTR(id)); silc_free(path); } @@ -644,9 +767,16 @@ void silc_sftp_server_receive_process(SilcSFTP sftp, if (ret < 0) goto failure; + /* Call monitor */ + if (server->monitors & SILC_SFTP_MONITOR_LSTAT && server->monitor) { + mdata.name = path; + (*server->monitor)(sftp, SILC_SFTP_MONITOR_LSTAT, &mdata, + server->monitor_context); + } + /* Lstat operation */ - server->fs->sftp_lstat(server->fs_context, sftp, path, - silc_sftp_server_attr, (void *)id); + server->fs->fs->sftp_lstat(server->fs->fs_context, sftp, path, + silc_sftp_server_attr, SILC_32_TO_PTR(id)); silc_free(path); } @@ -655,37 +785,43 @@ void silc_sftp_server_receive_process(SilcSFTP sftp, case SILC_SFTP_FSTAT: { unsigned char *hdata; - uint32 hdata_len; + SilcUInt32 hdata_len; SILC_LOG_DEBUG(("Fstat request")); ret = silc_buffer_unformat(&buf, SILC_STR_UI_INT(&id), - SILC_STR_UI32_NSTRING(&hdata, + SILC_STR_UI32_NSTRING(&hdata, &hdata_len), SILC_STR_END); if (ret < 0) goto failure; /* Get the handle */ - handle = server->fs->sftp_get_handle(server->fs_context, sftp, - (const unsigned char *)hdata, - hdata_len); + handle = server->fs->fs->sftp_get_handle(server->fs->fs_context, sftp, + (const unsigned char *)hdata, + hdata_len); if (!handle) { silc_sftp_send_error(server, SILC_SFTP_STATUS_NO_SUCH_FILE, id); break; } + /* Call monitor */ + if (server->monitors & SILC_SFTP_MONITOR_FSTAT && server->monitor) { + (*server->monitor)(sftp, SILC_SFTP_MONITOR_FSTAT, &mdata, + server->monitor_context); + } + /* Fstat operation */ - server->fs->sftp_fstat(server->fs_context, sftp, handle, - silc_sftp_server_attr, (void *)id); + server->fs->fs->sftp_fstat(server->fs->fs_context, sftp, handle, + silc_sftp_server_attr, SILC_32_TO_PTR(id)); } break; case SILC_SFTP_SETSTAT: { unsigned char *attr_buf; - uint32 attr_len = 0; + SilcUInt32 attr_len = 0; SilcBufferStruct tmpbuf; SILC_LOG_DEBUG(("Setstat request")); @@ -702,13 +838,24 @@ void silc_sftp_server_receive_process(SilcSFTP sftp, if (attr_len) { silc_buffer_set(&tmpbuf, attr_buf, attr_len); attrs = silc_sftp_attr_decode(&tmpbuf); + if (!attrs) + goto failure; } else { attrs = silc_calloc(1, sizeof(*attrs)); + if (!attrs) + goto failure; + } + + /* Call monitor */ + if (server->monitors & SILC_SFTP_MONITOR_SETSTAT && server->monitor) { + mdata.name = path; + (*server->monitor)(sftp, SILC_SFTP_MONITOR_SETSTAT, &mdata, + server->monitor_context); } /* Setstat operation */ - server->fs->sftp_setstat(server->fs_context, sftp, path, attrs, - silc_sftp_server_status, (void *)id); + server->fs->fs->sftp_setstat(server->fs->fs_context, sftp, path, attrs, + silc_sftp_server_status, SILC_32_TO_PTR(id)); silc_sftp_attr_free(attrs); silc_free(path); @@ -718,14 +865,14 @@ void silc_sftp_server_receive_process(SilcSFTP sftp, case SILC_SFTP_FSETSTAT: { unsigned char *hdata, *attr_buf; - uint32 hdata_len, attr_len = 0; + SilcUInt32 hdata_len, attr_len = 0; SilcBufferStruct tmpbuf; SILC_LOG_DEBUG(("Fsetstat request")); ret = silc_buffer_unformat(&buf, SILC_STR_UI_INT(&id), - SILC_STR_UI32_NSTRING(&hdata, + SILC_STR_UI32_NSTRING(&hdata, &hdata_len), SILC_STR_UI32_NSTRING(&attr_buf, &attr_len), @@ -736,22 +883,34 @@ void silc_sftp_server_receive_process(SilcSFTP sftp, if (attr_len) { silc_buffer_set(&tmpbuf, attr_buf, attr_len); attrs = silc_sftp_attr_decode(&tmpbuf); + if (!attrs) + goto failure; } else { attrs = silc_calloc(1, sizeof(*attrs)); + if (!attrs) + goto failure; } /* Get the handle */ - handle = server->fs->sftp_get_handle(server->fs_context, sftp, - (const unsigned char *)hdata, - hdata_len); + handle = server->fs->fs->sftp_get_handle(server->fs->fs_context, sftp, + (const unsigned char *)hdata, + hdata_len); if (!handle) { silc_sftp_send_error(server, SILC_SFTP_STATUS_NO_SUCH_FILE, id); break; } + /* Call monitor */ + if (server->monitors & SILC_SFTP_MONITOR_FSETSTAT && server->monitor) { + (*server->monitor)(sftp, SILC_SFTP_MONITOR_FSETSTAT, &mdata, + server->monitor_context); + } + /* Fsetstat operation */ - server->fs->sftp_fsetstat(server->fs_context, sftp, handle, attrs, - silc_sftp_server_status, (void *)id); + server->fs->fs->sftp_fsetstat(server->fs->fs_context, sftp, + handle, attrs, + silc_sftp_server_status, + SILC_32_TO_PTR(id)); silc_sftp_attr_free(attrs); } @@ -768,9 +927,16 @@ void silc_sftp_server_receive_process(SilcSFTP sftp, if (ret < 0) goto failure; + /* Call monitor */ + if (server->monitors & SILC_SFTP_MONITOR_READLINK && server->monitor) { + mdata.name = path; + (*server->monitor)(sftp, SILC_SFTP_MONITOR_READLINK, &mdata, + server->monitor_context); + } + /* Readlink operation */ - server->fs->sftp_readlink(server->fs_context, sftp, path, - silc_sftp_server_name, (void *)id); + server->fs->fs->sftp_readlink(server->fs->fs_context, sftp, path, + silc_sftp_server_name, SILC_32_TO_PTR(id)); silc_free(path); } @@ -790,9 +956,17 @@ void silc_sftp_server_receive_process(SilcSFTP sftp, if (ret < 0) goto failure; + /* Call monitor */ + if (server->monitors & SILC_SFTP_MONITOR_SYMLINK && server->monitor) { + mdata.name = path; + mdata.name2 = target; + (*server->monitor)(sftp, SILC_SFTP_MONITOR_SYMLINK, &mdata, + server->monitor_context); + } + /* Symlink operation */ - server->fs->sftp_symlink(server->fs_context, sftp, path, target, - silc_sftp_server_status, (void *)id); + server->fs->fs->sftp_symlink(server->fs->fs_context, sftp, path, target, + silc_sftp_server_status, SILC_32_TO_PTR(id)); silc_free(path); silc_free(target); @@ -810,9 +984,16 @@ void silc_sftp_server_receive_process(SilcSFTP sftp, if (ret < 0) goto failure; + /* Call monitor */ + if (server->monitors & SILC_SFTP_MONITOR_REALPATH && server->monitor) { + mdata.name = path; + (*server->monitor)(sftp, SILC_SFTP_MONITOR_REALPATH, &mdata, + server->monitor_context); + } + /* Realpath operation */ - server->fs->sftp_realpath(server->fs_context, sftp, path, - silc_sftp_server_name, (void *)id); + server->fs->fs->sftp_realpath(server->fs->fs_context, sftp, path, + silc_sftp_server_name, SILC_32_TO_PTR(id)); silc_free(path); } @@ -822,7 +1003,7 @@ void silc_sftp_server_receive_process(SilcSFTP sftp, { char *request = NULL; unsigned char *data; - uint32 data_len; + SilcUInt32 data_len; SILC_LOG_DEBUG(("Extended request")); @@ -842,10 +1023,17 @@ void silc_sftp_server_receive_process(SilcSFTP sftp, goto failure; data_len = buf.len; + /* Call monitor */ + if (server->monitors & SILC_SFTP_MONITOR_EXTENDED && server->monitor) { + (*server->monitor)(sftp, SILC_SFTP_MONITOR_EXTENDED, &mdata, + server->monitor_context); + } + /* Extended operation */ - server->fs->sftp_extended(server->fs_context, sftp, - request, data, data_len, - silc_sftp_server_extended, (void *)id); + server->fs->fs->sftp_extended(server->fs->fs_context, sftp, + request, data, data_len, + silc_sftp_server_extended, + SILC_32_TO_PTR(id)); silc_free(request); }