set MR bits on newly-created files.

swap MR bits on file after a R-W-T event (after a read,
the read event is cleared and the write/truncate bits are set; after
a write, the write bit is clear and the read bit is set).

dmapi/src/suite1/cmd/print_event.c

@@ -57,6 +57,14 @@ int		 finish_responding(dm_sessid_t);
 int		 establish_handler(void);
 void		 exit_handler	(int);
 
+static int
+clear_region_event(
+	dm_sessid_t	 sid,
+	u_int		event,
+	void		*hanp,
+	size_t		 hlen,
+	char		*hans1);
+
 #define MAXNAMELEN 256
 
 /*
@@ -69,13 +77,17 @@ dm_sessid_t	 sid = 0;
 dm_sessid_t	 oldsid = 0;
 char		 *fsname;
 int		 register_new_mnts = 0;
+int		 rwt_bit_clear = 1;  /* Clear read/write/trunc bit before
+				      * responding to event; reset all other
+				      * bits.
+				      */
 
 void
 usage(
       char *prog)
 {
   fprintf(stderr, "Usage: %s ", prog);
-  fprintf(stderr, " <-S oldsid> <-v> <-s sleep> <-R> ");
+  fprintf(stderr, " <-S oldsid> <-v> <-s sleep> <-R> <-N> ");
   fprintf(stderr, "filesystem \n");
 }
 
@@ -95,7 +107,7 @@ main(
 /*  Progname  = argv[0];*/ Progname = "print_event";
   fsname  = NULL;
 
-  while ((c = getopt(argc, argv, "vs:S:R")) != EOF) {
+  while ((c = getopt(argc, argv, "vs:S:RN")) != EOF) {
     switch (c) {
     case 's':
       Sleep = atoi(optarg);
@@ -103,6 +115,9 @@ main(
     case 'R':
       register_new_mnts = 1;
       break;
+    case 'N':
+      rwt_bit_clear = 0;
+      break;
     case 'S':
       oldsid = atoi(optarg);
       break;
@@ -445,6 +460,22 @@ handle_message(
     hlen1  = DM_GET_LEN  (msg_de, de_handle);
     if (hanp1 && hlen1) {
       hantoa(hanp1, hlen1, hans1);
+      if (rwt_bit_clear) {
+	      u_int rgflag;
+	      switch(msg->ev_type) {
+		/* DM_EVENT_* and DM_REGION_* are different values, ug */
+		case DM_EVENT_READ:
+			rgflag = DM_REGION_READ;
+			break;
+		case DM_EVENT_WRITE:
+			rgflag = DM_REGION_WRITE;
+			break;
+		case DM_EVENT_TRUNCATE:
+			rgflag = DM_REGION_TRUNCATE;
+			break;
+	      }
+	      clear_region_event(sid, rgflag, hanp1, hlen1, hans1);
+      }
     } else {
       sprintf(hans1, "<BAD HANDLE, hlen %d>", hlen1);
     }
@@ -476,7 +507,7 @@ handle_message(
       break;
     default: break;
     }
-  }
+  } /* RWT */
 
   /***** DESTROY EVENT *****/
 
@@ -645,6 +676,7 @@ handle_message(
 	     "mode bits",	type,
 	     "retcode",		msg_ne->ne_retcode);
       respond = 0;
+      clear_region_event(sid, 0, hanp2, hlen2, hans2);
       break;
 
     case DM_EVENT_REMOVE:
@@ -1057,6 +1089,37 @@ clear_events(
 }
 
 
+
+static int
+clear_region_event(
+	dm_sessid_t	 sid,
+	u_int		event,
+	void		*hanp,
+	size_t		 hlen,
+	char		*hans1)
+{
+	dm_region_t	region = { 0, 0, 0 };
+	u_int		nelem = 1;
+	u_int		exactflag;
+
+	region.rg_flags = DM_REGION_READ|DM_REGION_WRITE|DM_REGION_TRUNCATE;
+	region.rg_flags &= ~event;
+
+	if (Verbose) {
+		err_msg("Clearing region mask 0x%x for file %s\n",
+			(int)event, hans1);
+		err_msg("Setting region mask 0x%x\n", region.rg_flags);
+	}
+
+	if (dm_set_region(sid, hanp, hlen, DM_NO_TOKEN, nelem, &region,
+			  &exactflag)) {
+		errno_msg("Can't set region event");
+		return(1);
+	}
+	return(0);
+}
+
+
 /*
  * Respond to any events which haven't been handled yet.
  * dm_getall_tokens provides a list of tokens for the outstanding events.