added some log statements, fixed some typos
authorerickson <erickson@dcc99617-32d9-48b4-a31d-7c20da2025e4>
Thu, 1 Dec 2005 18:48:51 +0000 (18:48 +0000)
committererickson <erickson@dcc99617-32d9-48b4-a31d-7c20da2025e4>
Thu, 1 Dec 2005 18:48:51 +0000 (18:48 +0000)
git-svn-id: svn://svn.open-ils.org/ILS/trunk@2146 dcc99617-32d9-48b4-a31d-7c20da2025e4

Open-ILS/src/c-apps/oils_auth.c
Open-ILS/src/c-apps/oils_utils.c
Open-ILS/src/c-apps/oils_utils.h
OpenSRF/src/libstack/osrf_cache.c
OpenSRF/src/libstack/osrf_cache.h
OpenSRF/src/utils/log.c
OpenSRF/src/utils/log.h
OpenSRF/src/utils/socket_bundle.c
OpenSRF/src/utils/utils.c

index 2e7fa88..20f39a5 100644 (file)
@@ -90,6 +90,7 @@ int oilsAuthComplete( osrfMethodContext* ctx ) {
        char* uname = jsonObjectGetString(jsonObjectGetIndex(ctx->params, 0));
        char* password = jsonObjectGetString(jsonObjectGetIndex(ctx->params, 1));
        char* storageMethod = "open-ils.storage.direct.actor.user.search.usrname.atomic";
+       osrfMessage* omsg = NULL;
 
        if( uname && password ) {
 
@@ -97,10 +98,13 @@ int oilsAuthComplete( osrfMethodContext* ctx ) {
                osrfLogDebug( "oilsAuth calling method %s with username %s", storageMethod, uname );
 
                osrfAppSession* session = osrfAppSessionClientInit( "open-ils.storage" ); /**/
-               jsonObject* params = jsonNewObject(uname); /**/
+               //jsonObject* params = jsonNewObject(uname); /**/
+               jsonObject* params = jsonParseString("[\"%s\"]", uname);
                int reqid = osrfAppSessionMakeRequest( session, params, storageMethod, 1, NULL );
                jsonObjectFree(params);
-               osrfMessage* omsg = osrfAppSessionRequestRecv( session, reqid, 60 ); /**/
+               osrfLogInternal("oilsAuth waiting from response from storage...");
+               omsg = osrfAppSessionRequestRecv( session, reqid, 60 ); /**/
+               osrfLogInternal("oilsAuth storage request returned");
 
                if(!omsg) { 
                        osrfAppSessionFree(session);
@@ -150,8 +154,10 @@ int oilsAuthComplete( osrfMethodContext* ctx ) {
                        char* authToken = md5sum(string); /**/
                        char* authKey = va_list_to_string( "%s%s", OILS_AUTH_CACHE_PRFX, authToken ); /**/
 
+                       osrfLogInternal("oilsAuthComplete(): Setting fieldmapper string on the user object");
                        oilsFMSetString( userObj, "passwd", "" );
                        osrfCachePutObject( authKey, userObj, 28800 ); /* XXX config value */
+                       osrfLogInternal("oilsAuthComplete(): Placed user object into cache");
                        response = jsonNewObject( authToken );
                        free(string); free(authToken); free(authKey);
 
@@ -161,6 +167,7 @@ int oilsAuthComplete( osrfMethodContext* ctx ) {
                        response = jsonNewNumberObject(0);
                }
 
+               osrfLogInternal("oilsAuthComplete responding to client");
                osrfAppRespondComplete( ctx, response ); 
                jsonObjectFree(response);
                osrfMessageFree(omsg);
index c2fe147..19e1bcf 100644 (file)
@@ -16,8 +16,11 @@ jsonObject* oilsFMGetObject( jsonObject* object, char* field ) {
 
 int oilsFMSetString( jsonObject* object, char* field, char* string ) {
        if(!(object && field && string)) return -1;
+       osrfLogInternal("oilsFMSetString(): Collecing position for field %s", field);
        int pos = fm_ntop(object->classname, field);
        if( pos > -1 ) {
+               osrfLogInternal("oilsFMSetString(): Setting string "
+                               "%s at field %s [position %d]", string, field, pos );
                jsonObjectSetIndex( object, pos, jsonNewObject(string) );
                return 0;
        }
index 9c30bdc..a9c502b 100644 (file)
@@ -1,4 +1,5 @@
 #include "objson/object.h"
+#include "opensrf/log.h"
 #include "openils/fieldmapper_lookup.h"
 
 /**
index df5199a..9c06508 100644 (file)
@@ -34,6 +34,7 @@ int osrfCacheInit( char* serverStrings[], int size, time_t maxCacheSeconds ) {
 int osrfCachePutObject( char* key, const jsonObject* obj, time_t seconds ) {
        if( !(key && obj) ) return -1;
        char* s = jsonObjectToJSON( obj );
+       osrfLogInternal("osrfCachePut(): Putting object: %s", s);
        if( seconds < 0 ) seconds = __osrfCacheMaxSeconds;
 
        mc_set(__osrfCache, key, strlen(key), s, strlen(s), seconds, 0);
@@ -44,6 +45,7 @@ int osrfCachePutObject( char* key, const jsonObject* obj, time_t seconds ) {
 int osrfCachePutString( char* key, const char* value, time_t seconds ) {
        if( !(key && value) ) return -1;
        if( seconds < 0 ) seconds = __osrfCacheMaxSeconds;
+       osrfLogInternal("osrfCachePutString(): Putting string: %s", value);
        mc_set(__osrfCache, key, strlen(key), value, strlen(value), seconds, 0);
        return 0;
 }
@@ -54,6 +56,7 @@ jsonObject* osrfCacheGetObject( char* key, ... ) {
                VA_LIST_TO_STRING(key);
                char* data = (char*) mc_aget( __osrfCache, VA_BUF, strlen(VA_BUF) );
                if( data ) {
+                       osrfLogInternal("osrfCacheGetObject(): Returning object: %s", data);
                        obj = jsonParseString( data );
                        return obj;
                }
@@ -64,7 +67,9 @@ jsonObject* osrfCacheGetObject( char* key, ... ) {
 char* osrfCacheGetString( char* key, ... ) {
        if( key ) {
                VA_LIST_TO_STRING(key);
-               return (char*) mc_aget(__osrfCache, VA_BUF, strlen(VA_BUF) );
+               char* data = (char*) mc_aget(__osrfCache, VA_BUF, strlen(VA_BUF) );
+               osrfLogInternal("osrfCacheGetObject(): Returning object: %s", data);
+               return data;
        }
        return NULL;
 }
index 664036a..2159bdd 100644 (file)
@@ -17,6 +17,7 @@ GNU General Public License for more details.
 #include "objson/object.h"
 #include "objson/json_parser.h"
 #include "memcache.h"
+#include "log.h"
 
 /**
   osrfCache is a globally shared cache API
index eb6a100..40ec051 100644 (file)
@@ -63,7 +63,7 @@ void osrfLogError( const char* msg, ... ) { OSRF_LOG_GO(msg, OSRF_LOG_ERROR); }
 void osrfLogWarning( const char* msg, ... ) { OSRF_LOG_GO(msg, OSRF_LOG_WARNING); }
 void osrfLogInfo( const char* msg, ... ) { OSRF_LOG_GO(msg, OSRF_LOG_INFO); }
 void osrfLogDebug( const char* msg, ... ) { OSRF_LOG_GO(msg, OSRF_LOG_DEBUG); }
-void osrfLogInternal( const char* msg, ... ) { OSRF_LOG_GO(msg, OSRF_LOG_DEBUG); }
+void osrfLogInternal( const char* msg, ... ) { OSRF_LOG_GO(msg, OSRF_LOG_INTERNAL); }
 void osrfLogActivity( const char* msg, ... ) { 
        OSRF_LOG_GO(msg, OSRF_LOG_ACTIVITY); 
        /* activity log entries are also logged as info intries */
@@ -125,7 +125,7 @@ void osrfLogDetail( int level, char* filename, int line, char* func, char* msg,
                syslog( fac | lvl, "[%s:%d:%s:%s:%s] %s", l, getpid(), filename, lb, func, VA_BUF );
 
        else if( __osrfLogType == OSRF_LOG_TYPE_FILE )
-               _osrfLogToFile("[%s:%d:%s:%d:%s] %s", l, getpid(), filename, lb, func, VA_BUF );
+               _osrfLogToFile("[%s:%d:%s:%s:%s] %s", l, getpid(), filename, lb, func, VA_BUF );
 }
 
 
@@ -136,15 +136,16 @@ void _osrfLogToFile( char* msg, ... ) {
        VA_LIST_TO_STRING(msg);
 
        if(!__osrfLogAppname) __osrfLogAppname = strdup("osrf");
-       int l = strlen(VA_BUF) + strlen(__osrfLogAppname) + 24;
+       int l = strlen(VA_BUF) + strlen(__osrfLogAppname) + 36;
        char buf[l];
        bzero(buf,l);
 
-       char datebuf[24];
-       bzero(datebuf,24);
+
+       char datebuf[36];
+       bzero(datebuf,36);
        time_t t = time(NULL);
        struct tm* tms = localtime(&t);
-       strftime(datebuf, 24, "%Y-%m-%d %h:%m:%s", tms);
+       strftime(datebuf, 36, "%Y-%m-%d %h:%m:%s", tms);
 
        FILE* file = fopen(__osrfLogFile, "a");
        if(!file) {
@@ -153,7 +154,9 @@ void _osrfLogToFile( char* msg, ... ) {
        }
 
        fprintf(file, "%s %s %s\n", __osrfLogAppname, datebuf, VA_BUF );
-       fclose(file);
+       if( fclose(file) != 0 ) 
+               osrfLogWarning("Error closing log file: %s", strerror(errno));
+       
 }
 
 
index a425f97..3933ca6 100644 (file)
@@ -2,6 +2,7 @@
 #include <stdio.h>
 #include "utils.h"
 #include <time.h>
+#include <errno.h>
 
 #ifndef OSRF_LOG_INCLUDED
 #define OSRF_LOG_INCLUDED
index f1ae720..70d94ba 100644 (file)
@@ -404,9 +404,6 @@ void socket_disconnect(socket_manager* mgr, int sock_fd) {
 
        osrfLogDebug("Closing socket %d", sock_fd);
 
-       if( shutdown( sock_fd, SHUT_RDWR ) )
-               osrfLogWarning( "socket_disconnect(): Error shuting down socket, removing anyway" );
-
        if( close( sock_fd ) == -1 ) 
                osrfLogWarning( "socket_disconnect(): Error closing socket, removing anyway" );
 
@@ -477,7 +474,7 @@ int socket_wait_all(socket_manager* mgr, int timeout) {
        socket_node* node = mgr->socket;
        int max_fd = 0;
        while(node) {
-               //osrfLogDebug("Adding socket %d to select set",node->sock_fd);
+               osrfLogInternal("Adding socket fd %d to select set",node->sock_fd);
                FD_SET( node->sock_fd, &read_set );
                if(node->sock_fd > max_fd) max_fd = node->sock_fd;
                node = node->next;
@@ -492,16 +489,16 @@ int socket_wait_all(socket_manager* mgr, int timeout) {
 
                // If timeout is -1, there is no timeout passed to the call to select
                if( (retval = select( max_fd, &read_set, NULL, NULL, NULL)) == -1 ) {
+                       osrfLogWarning("Call to select interrupted (returned -1)");
                        osrfLogWarning("Sys Error: %s", strerror(errno));
-                       osrfLogWarning("Call to select interrupted");
                        return -1;
                }
 
        } else if( timeout != 0 ) { /* timeout of 0 means don't block */
 
                if( (retval = select( max_fd, &read_set, NULL, NULL, &tv)) == -1 ) {
+                       osrfLogWarning( "Call to select interrupted (returned -1)" );
                        osrfLogWarning("Sys Error: %s", strerror(errno));
-                       osrfLogWarning( "Call to select interrupted" );
                        return -1;
                }
        }
index cc1e284..bfeafb9 100644 (file)
@@ -381,7 +381,10 @@ char* file_to_string(const char* filename) {
 
        FILE* file = fopen(filename, "r");
        if(!file) {
-               perror("Unable to open file in json_parse_file()");
+               int l = strlen(filename) + 64;
+               char b[l];
+               snprintf(b,l,"Unable to open file [%s] in file_to_string()", filename);
+               perror(b);
                return NULL;
        }