Merge github.com:grpc/grpc into tis-but-thy-name

pull/2208/head
Craig Tiller 10 years ago
commit 03b4bb9dfa
  1. 2
      src/core/iomgr/alarm.h
  2. 11
      src/core/support/log_linux.c
  3. 8
      src/core/surface/call.c
  4. 2
      src/core/surface/call.h
  5. 2
      src/core/transport/stream_op.h

@ -41,9 +41,9 @@
typedef struct grpc_alarm { typedef struct grpc_alarm {
gpr_timespec deadline; gpr_timespec deadline;
gpr_uint32 heap_index; /* INVALID_HEAP_INDEX if not in heap */ gpr_uint32 heap_index; /* INVALID_HEAP_INDEX if not in heap */
int triggered;
struct grpc_alarm *next; struct grpc_alarm *next;
struct grpc_alarm *prev; struct grpc_alarm *prev;
int triggered;
grpc_iomgr_cb_func cb; grpc_iomgr_cb_func cb;
void *cb_arg; void *cb_arg;
} grpc_alarm; } grpc_alarm;

@ -43,7 +43,9 @@
#ifdef GPR_LINUX #ifdef GPR_LINUX
#include <grpc/support/alloc.h>
#include <grpc/support/log.h> #include <grpc/support/log.h>
#include <grpc/support/string_util.h>
#include <grpc/support/time.h> #include <grpc/support/time.h>
#include <stdio.h> #include <stdio.h>
#include <stdarg.h> #include <stdarg.h>
@ -71,6 +73,7 @@ void gpr_log(const char *file, int line, gpr_log_severity severity,
void gpr_default_log(gpr_log_func_args *args) { void gpr_default_log(gpr_log_func_args *args) {
char *final_slash; char *final_slash;
char *prefix;
const char *display_file; const char *display_file;
char time_buffer[64]; char time_buffer[64];
gpr_timespec now = gpr_now(); gpr_timespec now = gpr_now();
@ -89,10 +92,12 @@ void gpr_default_log(gpr_log_func_args *args) {
strcpy(time_buffer, "error:strftime"); strcpy(time_buffer, "error:strftime");
} }
fprintf(stderr, "%s%s.%09d %7ld %s:%d] %s\n", gpr_asprintf(&prefix, "%s%s.%09d %7tu %s:%d]",
gpr_log_severity_string(args->severity), time_buffer, gpr_log_severity_string(args->severity), time_buffer,
(int)(now.tv_nsec), gettid(), display_file, args->line, (int)(now.tv_nsec), gettid(), display_file, args->line);
args->message);
fprintf(stderr, "%-60s %s\n", prefix, args->message);
gpr_free(prefix);
} }
#endif #endif

@ -76,14 +76,14 @@ typedef struct {
typedef struct { typedef struct {
/* Overall status of the operation: starts OK, may degrade to /* Overall status of the operation: starts OK, may degrade to
non-OK */ non-OK */
int success; gpr_uint8 success;
/* Completion function to call at the end of the operation */
grpc_ioreq_completion_func on_complete;
void *user_data;
/* a bit mask of which request ops are needed (1u << opid) */ /* a bit mask of which request ops are needed (1u << opid) */
gpr_uint16 need_mask; gpr_uint16 need_mask;
/* a bit mask of which request ops are now completed */ /* a bit mask of which request ops are now completed */
gpr_uint16 complete_mask; gpr_uint16 complete_mask;
/* Completion function to call at the end of the operation */
grpc_ioreq_completion_func on_complete;
void *user_data;
} reqinfo_master; } reqinfo_master;
/* Status data for a request can come from several sources; this /* Status data for a request can come from several sources; this

@ -78,8 +78,8 @@ typedef union {
typedef struct { typedef struct {
grpc_ioreq_op op; grpc_ioreq_op op;
grpc_ioreq_data data;
gpr_uint32 flags; /**< A copy of the write flags from grpc_op */ gpr_uint32 flags; /**< A copy of the write flags from grpc_op */
grpc_ioreq_data data;
} grpc_ioreq; } grpc_ioreq;
typedef void (*grpc_ioreq_completion_func)(grpc_call *call, int success, typedef void (*grpc_ioreq_completion_func)(grpc_call *call, int success,

@ -41,7 +41,7 @@
#include "src/core/transport/metadata.h" #include "src/core/transport/metadata.h"
/* this many stream ops are inlined into a sopb before allocating */ /* this many stream ops are inlined into a sopb before allocating */
#define GRPC_SOPB_INLINE_ELEMENTS 16 #define GRPC_SOPB_INLINE_ELEMENTS 4
/* Operations that can be performed on a stream. /* Operations that can be performed on a stream.
Used by grpc_stream_op. */ Used by grpc_stream_op. */

Loading…
Cancel
Save